SmartPDCode/pro/src/common.h

#ifndef __COMMON_H_
#define __COMMON_H_

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <stdbool.h>
#include "sqlite3.h"
#include "pthread.h"
#include "list.h"
#include "modbus_handle.h"
#include "elog.h"
#include "mongoose.h"
#include "ntpclient.h"
#include <net-snmp/net-snmp-config.h>
#include <net-snmp/net-snmp-includes.h>
#include <net-snmp/agent/net-snmp-agent-includes.h>

#include "pduMIB_form.h"
#include "pduMIB_scalar.h"
#include "pduMIB_trap.h"
#include "language_hashmap.h"
#include "hlw8110_habdle.h"
#include <sys/shm.h>
//#define RS485_TYPE

#define MAX_CHN_COUNT       16
#define MAX_RELAY_CHN       100

//是否在OS环境下运行
#define OS_HANDWARE 1

#define WEB_ROOT            "../web"
#define PARAS_FILE          "pduParas"

#define DATABASE_NAME       "pdu_dat.db"
#define DATABASE_BAK_NAME   "pdu_dat_bak.db"
#define SNMP_MIB_NAME       "pduMIB"


#define INTERL_MODBUS_PORT "/dev/ttyAS5"
#define INTERL_MODBUS_BAUD 115200


//485温湿度传感器    选择串口1
#define INTERL_485_SENSOR_MODBUS_PORT "/dev/ttyS1"
#define INTERL_485_SENSOR_MODBUS_BAUD 9600

//继电器接口级联
#define INTERL_SENSOR_MODBUS_PORT "/dev/ttyAS2"
#define INTERL_SENSOR_MODBUS_BAUD 9600

//表头级联接口
#define CASCADE_MODBUS_PORT     "/dev/ttyAS4"
#define CASCADE_MODBUS_BAUD     115200

//485级联选择串口
#define INTERL_485_CASCADE_PORT "/dev/ttyAS4"
#define INTERL_485_CASCADE_BAUD 115200

#define AC_SINGLE_S_CUR_CHN_NUM 8
#define AC_SINGLE_B_CUR_CHN_NUM 4

#define AC_SINGLE_S_MAX_CHN_NUM 10  	//单个控制板最大数量
#define AC_SINGLE_S_MAX_ADDRESS_NUM 16  //控制板最大数量

#define AC_MAX_VOLTAGE_VAL 400
#define AC_MAX_CURRENT_VAL 100
#define AC_MAX_POWER_VAL 100

enum
{
	TOTAL_VOLTAGE_TYPE 			= 0,//统计电压类型
	TOTAL_CURRENT_TYPE 			= 1,//统计电流类型
	TOTAL_POWER_TYPE 			= 2,//统计功率类型
	TOTAL_POWER_CONS_TYPE 		= 3 //统计耗电量类型
};

enum
{
	POWER_MERITORIOUS_TYPE 			= 0,//有功功率类型
	POWER_REACTIVE_TYPE 			= 1,//无功功率类型
	POWER_APPARENT_TYPE 			= 2 //视在功率类型
};

enum
{
    SENSOR_TYPE_TEMPERATURE = 0 , //温度传感器
    SENSOR_TYPE_SMOKE       = 1 , //烟雾传感器
    SENSOR_TYPE_WATER       = 2 , //水浸传感器
    SENSOR_TYPE_DOOR        = 3 , //门禁传感器
    SENSOR_TYPE_GAS         = 4 , //气体传感器
    SENSOR_TYPE_AIR_PRESS   = 5   //气体、气压传感器
};

enum
{
    SENSOR_TYPE_VALUE = 0 , //传感器类型0、4、5
    SENSOR_TYPE_LIST =1     //传感器类型1、2、3
};

/// @brief 板子类型
enum MODBUS_BOARD_TYPE
{
    AC_SINGLE_S_TYPE=1,
    AC_SINGLE_B_TYPE,
    AC_MULTI_S_TYPE,
    AC_MULTI_B_TYPE,
    DC_OUT_TYPE,
    DC_IN_TYPE,
    DCPDU_TYPE,
    TREE_AC_TYPE,   //三相进三项出
    RS485_Type,
};

enum AppProductType
{
    SmartPDU_AC=0,
    SmartPDU_DC=1,
    SmartPDU_Tree_AC_Tree=3,
    SmartPDU_Tree_AC_One=4    
};

/// @brief 三相网页数据
static char* g_product_t_ac_type_str[3] = {
    "L1",
    "L2",
    "L3",
};
/// @brief 按位标记
enum BIT_CTRL
{
    BIT_00 = 1 ,
    BIT_01 = 2 ,
    BIT_02 = 4 ,
    BIT_03 = 8 ,
    BIT_04 = 16,
    BIT_05 = 32,
    BIT_06 = 64,
    BIT_07 = 128,
    BIT_08 = 256,
    BIT_09 = 512,
    BIT_10 = 1024,
    BIT_11 = 2048,
    BIT_12 = 4096,
    BIT_13 = 8192,
    BIT_14 = 16384,
    BIT_15 = 32768,
};
/// @brief 使能位
enum ENABLE_BIT_CTRL
{
    ENABLE_V_UP     = 2 ,
    ENABLE_V_DOWN   = 8 ,
    ENABLE_A_UP     = 32,
    ENABLE_W_UP     = 128,
    ENABLE_P_UP     = 512,
};
/// @brief 使能位三项
enum ENABLE_TreeAC_CTRL
{
    ENABLE_TAC_V_UP     = BIT_01,
    ENABLE_TAC_V_DOWN   = BIT_02,
    ENABLE_TAC_A_UP     = BIT_03,
    ENABLE_TAC_W_UP     = BIT_04,
    ENABLE_TAC_P_UP     = BIT_05,
    ENABLE_TAC_STIME    = BIT_06,
    ENABLE_TAC_ETIME    = BIT_07,
};
/// @brief 报警位
enum WARNING_BIT_CTRL
{
    WARNING_V_UP     = 4 ,
    WARNING_V_DOWN   = 16 ,
    WARNING_A_UP     = 64, 
    WARNING_W_UP     = 256,
    WARNING_P_UP     = 1024,
};
///////////////////////////////////////////////////////////////////////////////////
///////////////////////////////////////////////////////////////////////////////////
//modbus信息管理
typedef struct
{
    bool            product_modbus_type ;       //modbus模式
    unsigned int    product_modbus_baud ;       //波特率
    unsigned char   product_modbus_addr         ;//从Modbus地址信息
    char            product_relay_ctrl_port[32] ;//继电器modbus控制端口
}ModbusInfo_t;

typedef struct
{
    int           mode;    						//1: static  0: dhcp
    char          ip_address[64] ; 				//ip地址
    char          mask[64]; 					//子网掩码
    char          gateway[64]; 					//网关
    char          dns1[64];    					//dns1
    char          dns2[64];    					//dns2
}NetworkInfo_t;


/// @brief 用户登录
typedef struct
{
    char user_name[64];
    char user_password[64];
    char user_uuid[64];
    char user_token[64];
    struct list_head list;
}_User_Log;

//设备总体管理表
typedef struct
{
    int             product_id                  ;//产品ID 
    char            product_number[16]          ;//产品编号    
    char            product_name[32]            ;//产品名称
    char            product_status[32]          ;//产品状态
    unsigned char   product_type                ;//产品类型
    unsigned char   product_pwr_type            ;//电源类型
    unsigned char   product_version[8]          ;//软件版本
    unsigned char   product_language           ; //多国语言
    unsigned char   product_count               ;//级联设备数
    unsigned short  product_samp_time           ;//采集周期 单位ms
    unsigned short  product_save_time           ;//采集周期 单位ms
    ModbusInfo_t    _modbus_info                ;//继电器控制端口
    NetworkInfo_t   _network_info ;             ;//网络信息
    ModbusInfo_t    _gmodbus_info               ;//级联端口      
}GlobalDeviceInfo;
///////////////////////////////////////////////////////////////////////////////////
///////////////////////////////////////////////////////////////////////////////////
//自定义共享内存类
typedef struct
{
    //电源数据
    int bPDUSet;
    int nSelectPowerCH;
    int nMaxCh;
    float fV;
    float fA;
    float fW;
    float fF;
    float fS;
    int nStatus;
    //传感器数据
    int nSelectSensor;
    float fT;//温度
    float fH;//湿度
} smartPDU_shm_data;

///////////////////////////////////////////////////////////////////////////////////
///////////////////////////////////////////////////////////////////////////////////
//超限管理表
typedef struct
{
    char            product_vol_upper_enable                   ;//电压上限使能
    float           product_vol_upper_threshold                ;//电压上限值
    char            product_vol_over_upper_threshold_ctrl      ;//电压超限动作
    char            product_vol_over_upper_threshold_ctrl_para ;//电压超限关联参数
    char            product_vol_lower_enable                   ;//电压下限使能
    float           product_vol_lower_threshold                ;//电压下限值
    char            product_vol_over_lower_threshold_ctrl      ;//电压超限动作 
    char            product_vol_over_lower_threshold_ctrl_para ;//电压超限动作   
    char            product_cur_upper_enable                   ;//电流下限使能
    float           product_cur_upper_threshold                ;//电流下限值
    float           product_cur_lower_threshold;                //
    char            product_cur_over_upper_threshold_ctrl      ;//电流超限动作 
    char            product_cur_over_upper_threshold_ctrl_para ;//电流超限动作   
    char            product_pwr_upper_enable                   ;//功率上限使能
    float           product_pwr_upper_threshold                ;//功率上限值
    char            product_pwr_over_upper_threshold_ctrl      ;//功率超限动作 
    char            product_pwr_over_upper_threshold_ctrl_para ;//功率超限动作      
    char            product_pwrcon_upper_enable                ;//耗电量上限使能
    float           product_pwrcon_upper_threshold             ;//耗电量上限值
    char            product_pwrcon_over_upper_threshold_ctrl   ;//耗电量超限动作   
    char            product_pwrcon_over_upper_threshold_ctrl_para   ;//耗电量超限动作   
}GlobalOverManager;


/// @brief 定时管理
typedef struct
{
    char                set_date[16]; //设置日期
    char                ds_date[16]; //设置时间
    char                ds_time[16]; //设置时间
    char                set_stats;    //状态
    struct list_head    list;   
}_PowerDSManage_t;


typedef struct
{
    int                 firingSortno;   //启动序号
    int                 closeSortno;    //关闭序号 
}_PowerSXManage_t;

typedef struct
{
    int                 product_id;
    int                 mode;
    char*               ntpName;
    char*               ntpaddress;
    int                 port;
    char*               time;
    int                 weekday;
    int                 tzone;
}NTPManager;
NTPManager _globalNTPManager;

typedef struct
{
    int                 product_id;
    int                 mode;
    int                 version;
    char*               public;
    int                 trapmode;
}SNMPManager;
SNMPManager _globalSNMPManager;

//分组管理
typedef struct
{
    int                 product_id;
    int                 GroupID;
    char               GroupName[64];
    char               GroupChList[512];
    struct list_head    list;  
}GroupInfo;


//电源部分
typedef struct 
{
    float           voltage                                     ;//电压
    float           current                                     ;//电流
    float           power                                       ;//功率
    float           freq                                        ;//频率
    float           consumption                                 ;//耗电量
    float           factor                                      ;//功率因素    
    unsigned short  status                                      ;//开关状态          
}PowerInfo;

//电源部分报警信息
typedef struct 
{
    bool           w_voltage_up                                  ;//电压上限报警
    bool           w_voltage_down                                ;//电压下限报警
    bool           w_current                                     ;//电流上限报警
    bool           w_power                                       ;//功率
    bool           w_consumption                                 ;//耗电量
    bool           w_phase_loss                                  ;//缺相报警              
}PowerWarningInfo;

//三项数据
typedef struct
{
    int product_id;
    int product_ch_id;
    int product_ph_id;
    int product_ph_type;//0:A相 1:B相 2:C相                
    int product_saddr;
    int product_ch_addr;
    int product_ph_outputType;//三相控制方式1,三项2单项
    int product_ph_outputStatus;//该相是否输出，1输出2不输出
    PowerInfo           _PowerInfo;                              //存储最新的数据(兼容三项输入)
    GlobalOverManager*  global_over_manager                        ;//超限管理
    PowerWarningInfo    _PowerWarninginfo;                       //存储报警数据(兼容三项输入)  
    time_t              product_log_time;                           //存储最新时间   
    struct list_head    list_Tree_AC;                              //存储三项数据指针    
}GlobalTreeACManager;
//电源通道管理总表(输出)
typedef struct 
{
    int                 product_id                                 ;//产品ID
    //20240225 add
    char                product_saddr                              ;//modbus地址记录                       
    char                product_ch_id                              ;//通道号
    char                product_ch_addr                            ;//通道号实际地址
    char                product_ch_name[32]                        ;//通道名称
    char                product_ch_type                            ;//通道类型
    char                product_ch_status                          ;//通道状态
    unsigned short      product_ch_start_delay                     ;//通道延时 
    unsigned short      product_ch_stop_delay                      ;//通道延时 
    GlobalOverManager*  global_over_manager                        ;//超限管理
    _PowerDSManage_t*   _powerDsManage                             ;//定时设置      
    _PowerSXManage_t*   _PowerSXManage;                             //时序管理      
    PowerInfo           _PowerInfo;                                 //存储最新的数据     
    PowerWarningInfo    _PowerWarninginfo ;                         //存储报警数据     
    time_t              product_log_time;                           //存储最新时间     
    struct list_head    list_Tree_AC;                              //存储三项数据指针
    struct list_head    list;  
}   GlobalPowerManger;

//电源通道管理总表(输入)
typedef struct 
{
    int                 product_id                                 ;//产品ID
    //20240225 add
    char                product_saddr                              ;//modbus地址记录                       
    char                product_saddr_name[32]                     ;//输入名称
    char                product_saddr_type                         ;//输入类型
    GlobalOverManager*  global_over_manager                        ;//超限管理
    PowerInfo           _PowerInfo[3];                              //存储最新的数据(兼容三项输入)
    PowerWarningInfo    _PowerWarninginfo[3];                       //存储报警数据(兼容三项输入)    
    time_t              product_log_time;                           //存储最新时间                                        
}GlobalPowerInManger;

//电源控制板计数
typedef struct 
{
    char                product_saddr                              ;//modbus地址记录                       
    int                 product_number;                             //数量
    int                 product_type;                               //类型
    PowerInfo           _PowerInfo[AC_SINGLE_S_MAX_CHN_NUM];        //存储最新的数据     
    PowerWarningInfo    _PowerWarninginfo[AC_SINGLE_S_MAX_CHN_NUM] ;//存储报警数据     
    struct list_head    list;  //存储具有的通道指针
    GlobalPowerInManger _globalPowerInManger;                       //总输入数据
}GlobalPowerCtrlBoard;
///////////////////////////////////////////////////////////////////////////////////
///////////////////////////////////////////////////////////////////////////////////

//电源信息统计
typedef struct
{
	float ydata[60];    //value
    char  xAxis[60][32];//时间点
}GetTotalInfo;

//系统总数信息
typedef struct
{
    int channel_total  ;//通道总数
    int warn_total     ;//告警总数
    int sensor_total   ;//传感器总数
    int log_total      ;//运行日志总数
}SystemTotalInfo;

//功率趋势接口
typedef struct
{
    float  ydata[3][60]     ;//0：有功功率；1：无功功率；2：视在功率；
    char   xAxis[60][32]    ;//时间点      
}PowerTrendInfo;

///////////////////////////////////////////////////////////////////////////////////
///////////////////////////////////////////////////////////////////////////////////


//电源监控
typedef struct 
{
    int             product_id                                  ;//产品ID
    char            product_ch_id                               ;//电源通道
    unsigned short  product_status                              ;//当前状态
    PowerInfo       _power_info                                 ;//采集值
    char            samp_time[32]                               ;//采集时间
    GetTotalInfo	_total_voltage								;//统计电压
	GetTotalInfo	_total_current								;//统计电流
	GetTotalInfo	_total_power								;//统计功率
	GetTotalInfo	_total_consumption							;//统计耗电量
    SystemTotalInfo _system_total_info                          ;//系统总数信息
    PowerTrendInfo  _power_trend_info                           ;//功率趋势图
    struct list_head list;
}GlobalPowerInfo;
///////////////////////////////////////////////////////////////////////////////////
///////////////////////////////////////////////////////////////////////////////////


///////////////////////////////////////////////////////////////////////////////////
///////////////////////////////////////////////////////////////////////////////////
//传感器值
typedef struct
{
    char            samp_time[32]                               ;//采集时间
    int             product_id                                  ;//产品ID
    char            sensor_id                                   ;//传感器ID
    float           val1                                        ;//值1
    float           val2                                        ;//值2
    time_t          product_log_time;                           //存储最新时间     
    struct list_head list;
}GlobalSensorInfo;

typedef struct
{
    bool                sensor_val1_upper_enabled ;//
    float               sensor_val1_upper_threshold;
    char                sensor_val1_upper_threshold_ctrl;
    char                sensor_val1_upper_threshold_ctrl_para;
    bool                sensor_val1_lower_enabled ;//
    float               sensor_val1_lower_threshold;
    char                sensor_val1_lower_threshold_ctrl;
    char                sensor_val1_lower_threshold_ctrl_para;
    bool                sensor_val2_upper_enabled ;//
    float               sensor_val2_upper_threshold;
    char                sensor_val2_upper_threshold_ctrl;
    char                sensor_val2_upper_threshold_ctrl_para;
    bool                sensor_val2_lower_enabled ;//
    float               sensor_val2_lower_threshold;
    char                sensor_val2_lower_threshold_ctrl;
    char                sensor_val2_lower_threshold_ctrl_para;
}GlobalSensorOverManage;

//传感器管理总表
typedef struct 
{
    int                 product_id                                 ;//产品ID    
    char                sensor_id                                  ;//传感器ID
    char                sensor_type                                ;//传感器类型
    char                sensor_interface_type;                     //接口类型
    char                sensor_name[64]                            ;//传感器名称
    char                sensor_port_name[32]                       ;//传感器端口号
    int                 sensor_baud                                ;//波特率
    char                sensor_addr                                ;//modbus地址
    int                sensor_status                              ;//传感器状态
    char                sensor_val_count                           ;//传感器值个数
    int                 sensor_node_number                         ;//节点号
    GlobalSensorOverManage*  over_manager                          ;//超限管理   
    struct list_head    list;   
}GlobalSensorManger;
///////////////////////////////////////////////////////////////////////////////////
///////////////////////////////////////////////////////////////////////////////////



///////////////////////////////////////////////////////////////////////////////////
///////////////////////////////////////////////////////////////////////////////////
///温湿度数据信息管理
typedef struct
{
    float  temperature;
    float   humidity;
}SenorTempVal;


//采集KB值
typedef struct 
{
    float   voltage_k;//电压K
    float   voltage_b;//电压B
    float   current_k;//电流K
    float   current_b;//电流B
}SwitchKbVal;
///////////////////////////////////////////////////////////////////////////////////
///////////////////////////////////////////////////////////////////////////////////

//SMTP管理
typedef struct
{
    int                 idx;
    char*               receive_account;
    char*               receive_account_info;
    struct list_head    list;
}SMTPreceiveAccount;

typedef struct 
{
    int                 product_id;
    int                 mode;    				//状态
    char*               account;                //用户账号
    char*               password; 		        //用户密码
    char*               server; 			    //服务器
    int                 port;    		        //端口
    char                auth[16];    			//认证方式
    SMTPreceiveAccount* receive_account;        //接收账号列表

}SMTPManager;
SMTPManager globalSMTPManager;

typedef struct 
{
    int                 product_id;
    int                 userID;    				//用户ID
    char*               userName;                //用户名-登录
    char*               userPW; 		        //用户密码
    char*               nickName; 			    //用户名称
    int                 roleID;    		        //角色ID
    char*               createTime;             //用户创建时间     
    struct list_head    list;

}UserInfo;

typedef struct 
{
    int                 product_id;
    int                 roleID;    				//角色ID
    char*               roleName;               //角色名称
    int                 roleLevel; 		        //角色等级
    int                 roleAuthority; 			//角色权限
    int                 roleSort;    		    //显示顺序
    char*               createTime;             //创建时间     
    struct list_head    list;

}RoleInfo;



typedef struct CascadeDevices{
    int                 product_id;     //级联设备ID modbus地址
    int                 type;           //
    char                device_name[20];    //接连设备名;
    float               valtage;            //485
    float               current;
    float               power;
    float               factor;
    float               freq;
    float               consumption;
}CascadeDevices;

struct modbus_slave_read_reg{
    uint16_t deveice_type;              //设备类型
    uint16_t slave_addr;                //设备地址
    uint32_t voltage;                   //当前电压
    uint32_t current;                   //当前电流
    uint32_t power;                     //当前功率
    uint32_t consumption_cur;           //耗电量
    uint32_t freq;                      //频率
    uint32_t factor;                    //功率因素
    uint32_t temprature;                //温度值
    uint32_t humidity;                  //湿度值
    uint32_t warning;                   //告警
    uint16_t power_supplay_status;      //供电状态
    uint16_t sencor_status;             //传感器状态

//    uint32_t Warinfo;
//    uint16_t sercor_type;
};

struct modbus_slave_write_reg{
    uint16_t      voltage_high_enable:1;           //电压高阈值检测使能
    uint16_t       voltage_low_enable:1;            //电压低阈值检测使能
    uint16_t           current_enable:1;            //电流阈值使能
    uint16_t             power_enable:1;            //功率阈值使能
    uint16_t   consumption_cur_enable:1;            //功耗阈值使能
    uint32_t    voltage_upper_threshold;            //
    uint32_t    voltage_lower_threshold;
    uint32_t    current_upper_threshold;
    uint32_t      power_upper_threshold;
    uint32_t      consumption_threshold;
};


//设备总体管理
typedef struct
{
    sqlite3*            db;             //数据库接口
    pthread_mutex_t     dbThreadlock;        //写入线程锁 
    pthread_t           appweb_thread;  //appweb线程
    pthread_t           dev_samp_thread;//电源采集与控制线程
 
    unsigned char       view_page ; //前端切换页面 1->总体信息 2->通道信息
    pthread_t           dev_update_thread;//电源采集与控制线程

    pthread_t           io_thread;  //IO采集线程
    pthread_t           sensor_thread; //传感器采集现成
    bool                dev_samp_flag ; //电源采集线程标志
    GlobalDeviceInfo*   _global_device_info;    //设备管理信息
    GlobalPowerManger  _globalPowerManger;      //电源管理表
    GlobalSensorManger _globalSensorManger;     //传感器管理表  
    Modbus_Manger      sensor_modbus_manager;  //通信接口管理
    unsigned int        useSlaveCount ;         //有效地址
    Modbus_Manger       _globalRelaySampManger; //内部继电器使用
    
    unsigned char       uart_init_flag[6] ; //

    bool                 ws_isok; //ws准备好
    struct mg_connection *ws_client;   //websocket管理信息
    HashTable*           _global_alarmLanguage; //全局的报警映射
    int                 nTreeACLshow; //三项总数据显示L1=0,L2=1,L3=2
    pthread_t           snmp_agent_thread;//SNMP代理线程
    bool                _ReloadChm_flag; //重新加载端口数据
    GlobalPowerCtrlBoard _all_ctrl_board[16]; //所有控制板
    LowConf*            _RS485LowConfData;//485Data
      //传感器
    struct modbus_slave_read_reg g_modebus_read;
    struct modbus_slave_write_reg g_modebus_write;
    smartPDU_shm_data* g_shm_Data;
   
}GlobalDeviceManager;
GlobalDeviceManager __globalDeviceManage;
GlobalDeviceManager __globalDeviceManage2;

NTPClient* globalNTPclient;
bool bStopNTPthread;
pthread_t NTPthread;

unsigned long __globalSxIdx;

_User_Log _GlobalUserLoginInfo;//全局用户登录信息
UserInfo _GlobalUserInfoNew;////最近登录的信息
char _GlobalUserToken[64];////最近登录的信息


void initLogger(void);

//打印设备信息结构
void printf_global_device_info(GlobalDeviceInfo* _globalDeviceInfo);
//打印设备超限电源管理
void printf_global_power_manage_info(GlobalPowerManger* _globalPowerManger);
//打印设备超限电源通道管理
//void printf_global_power_chn_manage_info(GlobalPowerChnManger* _globalPowerChnManger);

void printf_power_info(GlobalPowerInfo* _globalPowerInfo);


int getTotalMemorySize(unsigned int* totalSize);
char* getLocalIpAddress(char* dev);
char* get_mac_address(const char *iface_name) ;
void get_disk_occupy(char ** reused);
int set_local_timeandzone(struct tm* t, int zone);
char* getUserNamebyToken(char* Token);
int is_process_running(const char *process_name);


#endif