SmartPDCode/pro/src/sqlite_handle.h

#ifndef __SQLITE_HANDLE_H
#define __SQLITE_HANDLE_H

#include <stdlib.h>
#include <string.h>
#include <unistd.h>
// #include "sqlite3.h"
#include "common.h"
#include "json_handle.h"
#include "netswitch.h"


//#define USE_UTC_TIME

#ifdef USE_UTC_TIME
    #define time_data_t  uint32_t
#else
    #define time_data_t  char*
#endif

int sqlite_init(sqlite3** db,pthread_mutex_t* pDBMutex, const char* daba_name);
void sqlite_deinit(sqlite3 *db,pthread_mutex_t* pDBMutex);

int dev_get_device_info(sqlite3 *db,GlobalDeviceInfo* _globalDeviceInfo);
int dev_update_device_genera_info(sqlite3 *db,GlobalDeviceInfo* _globalDeviceInfo);
int dev_update_device_modus_info(sqlite3 *db,GlobalDeviceInfo* _globalDeviceInfo);

int dev_search_last_Index(sqlite3 *db,int* nIndex,char* tableName);
int dev_change_last_Index(sqlite3 *db,int* nIndex,int nDeleteNumber,char* tableName);
int dev_insert_power_info(sqlite3 *db,GlobalPowerInfo* _globalPowerChnInfo,int* nIndex);
int dev_search_latest_power_info(sqlite3 *db,int product_id,int product_ch_id,GlobalPowerInfo* _globalPowerInfo);
int dev_search_latest_power_All_info(GlobalDeviceManager* globalDeviceManger,_OverChnPwrAckInfo* __overChnPwrAckInfo, int dev_addr);
int dev_delete_power_info_all(sqlite3 *db);

int dev_search_latest_power_statistic_info(GlobalDeviceManager* globalDeviceManger, _OverAllPwrAckInfo *all);
int dev_search_latest_t_ac_power_statistic_info(int nCh,int nType,_OverAllPwrAckInfo* __overChnPwrAckInfo,GlobalDeviceManager* globalDeviceManger);

int dev_search_time_power_info(sqlite3 *db,int product_id,int product_ch_id,int total_type,GlobalPowerInfo* _globalPowerInfo,char* start_time,char* end_time);
int dev_search_time_t_ac_power_info(sqlite3 *db,int product_id,int product_ch_id,int product_ph_id,int total_type,GlobalPowerInfo* _globalPowerInfo,char* start_time,char* end_time);
int dev_get_system_total_info(sqlite3 *db,int product_id,int product_ch_id, SystemTotalInfo* __SystemTotalInfo,char* start_time,char* end_time);
int dev_search_power_trend_info(sqlite3 *db,int product_id,int product_ch_id,GlobalPowerInfo* _globalPowerInfo,char* start_time,char* end_time);
int dev_search_power_AC_trend_info(sqlite3 *db,int product_id,int product_ch_id,int product_ph_id,GlobalPowerInfo* _globalPowerInfo,char* start_time,char* end_time);
int dev_search_power_info(sqlite3 *db,
                        int product_id,
                        int product_ch_id,
                        char* start_time,
                        char* stop_time,
                        int page,
                        int pageSize,
                        int* size,
                        GlobalPowerInfo* _globalPowerInfo);

int dev_check_power_manage_info(sqlite3 *db, int cnt);
int dev_insert_power_manage_info(sqlite3 *db,int product_id,int product_ch_id,GlobalPowerManger* _globalPowerChnManger);
int dev_get_power_manage_info(sqlite3 *db,int product_id,int product_addr,int product_ch_id,GlobalPowerManger* _globalPowerChnManger);
int dev_get_power_manage_info_by_ID(sqlite3 *db,int product_id,int product_addr,int product_ch_id,GlobalPowerManger* _globalPowerChnManger);

int dev_get_t_ac_power_manage_info(sqlite3 *db,int product_id,int product_addr,int product_ch_id,int product_ph_type,GlobalTreeACManager* _globalPowerChnManger);
int dev_insert_t_ac_power_manage_info(sqlite3 *db,int product_id,int product_ch_id,GlobalTreeACManager* _globalPowerChnManger);
int dev_insert_t_ac_power_info(sqlite3 *db,GlobalTreeACManager* _globalPowerChnInfo,int* nIndex,char* pTimeData);
int dev_update_t_ac_power_manage_info(sqlite3 *db,GlobalTreeACManager* _globalPowerChnInfo);
int dev_update_t_ac_power_manage_over_info(sqlite3 *db,GlobalTreeACManager* _globalPowerChnManger);
int dev_delete_ac_power_info_all(sqlite3 *db);

int dev_update_power_manage_genera_info(sqlite3 *db,int product_id,int product_ch_id,GlobalPowerManger* _globalPowerChnManger);
int dev_update_power_manage_genera_info_addr(sqlite3 *db,int product_id,int addr,int addr_ch_id,GlobalPowerManger* _globalPowerChnManger);
int dev_update_power_manage_over_info(sqlite3 *db,int product_id,int product_ch_id,GlobalPowerManger* _globalPowerChnManger);

int dev_insert_sensor_info(sqlite3 *db,GlobalSensorInfo* _globalSensorInfo,int *nIndex);
int dev_search_sensor_info(sqlite3 *db,
                        int product_id,
                        int sensor_id,
                        char* start_time,
                        char* stop_time,
                        int pageNum,
                        int pageSize,
                        int* size,
                        GlobalSensorInfo* _globalSensorInfo);

int dev_serach_latest_sensor_info(sqlite3 *db,int product_id,int sensor_id,GlobalSensorInfo* _globalSensorInfo);

int dev_get_sensor_manage_info(sqlite3 *db,int product_id,GlobalSensorManger* _globalSensorManger);
int dev_insert_sensor_genera_manage(sqlite3 *db,GlobalSensorManger* _globalSensorManger);
int dev_update_sensor_genera_manage(sqlite3 *db,int product_id,int sensor_id,GlobalSensorManger* _globalSensorManger);
int dev_update_sensor_over_manage(sqlite3 *db,int product_id,int sensor_id,GlobalSensorManger* _globalSensorManger);
int dev_delete_sensor_manage(sqlite3 *db,int product_id,int sensor_id);
int dev_delete_sensor_info_all(sqlite3 *db);


int dev_insert_alarm_info(sqlite3* db,int product_id,int alarm_type,time_data_t date_time,char* alarm_content);
int dev_search_alarm_info(sqlite3* db,
                        int product_id,
                        int alarm_type,
                        time_data_t start_time,
                        time_data_t end_time,
                        int page_num,
                        int page_size,
                        _AlarmAckInfo* _alarm_ack_info,
                        int* nAlarmSum
                        );

int dev_serarch_all_alarm(sqlite3* db,
                        int product_id,
                        int alarm_type,
                        int page_num,
                        int page_size,
                        _AlarmAckInfo* _alarm_ack_info,
                        int* nAlarmSum
                        );
int dev_delete_alarm_info_all(sqlite3* db,int alarm_type);

int dev_get_ntp_info(sqlite3 *db,NTPManager* _globalNTPInfo);
int dev_update_ntp_info(sqlite3 *db, int product_id, NTPManager* _globalNTPInfo);
int dev_insert_ntp_info(sqlite3 *db,NTPManager* _globalNTPInfo);

int dev_get_snmp_info(sqlite3 *db, SNMPManager* _globalSNMPInfo);
int dev_insert_snmp_info(sqlite3 *db, SNMPManager* _globalSNMPInfo);
int dev_update_snmp_info(sqlite3 *db, int product_id, SNMPManager* _globalSNMPInfo);

int dev_insert_alarm_ctrl(sqlite3* db,int product_id,int nAlarmType,char* alarm_content);
int dev_delete__group_info(sqlite3 *db,int product_id);
int dev_insert_group_info(sqlite3 *db,GroupInfo* _globalgroupInfo);
int dev_get_group_info(sqlite3 *db, GroupInfo* _globalgroupInfo);
int dev_update_group_info(sqlite3 *db, GroupInfo* _globalgroupInfo);

int dev_update_user_info(sqlite3 *db, UserInfo* _globaluserInfo);
int dev_insert_user_info(sqlite3 *db,UserInfo* _globaluserInfo);
int dev_get_user_info(sqlite3 *db, UserInfo* _globaluserInfo);
int dev_delete_user_info(sqlite3 *db,int userID);

int dev_update_role_info(sqlite3 *db, RoleInfo* _globalRoleInfo);
int dev_insert_role_info(sqlite3 *db,RoleInfo* _globalRoleInfo);
int dev_get_role_info(sqlite3 *db, RoleInfo* _globalRoleInfo);

//��ʱ������
int dev_get_power_ds(sqlite3 *db,GlobalPowerManger* _powerAll,char* dateSelect);
int dev_update_power_ds(sqlite3 *db,int product_id,int nChn,_PowerDSManage_t* _powerDS);
int dev_insert_power_ds(sqlite3 *db,int product_id,int nChn,_PowerDSManage_t* _powerDS);
int dev_delete_power_ds(sqlite3 *db,int product_id,int nChn,_PowerDSManage_t* _powerDS);

//报警信息处理
int dev_Alarm_send_message(GlobalDeviceManager* globalDeviceManger,GlobalPowerManger* __globalPowerTemp,int _AlarmType);
int dev_Alarm_T_AC_message(GlobalDeviceManager* globalDeviceManger,GlobalTreeACManager* __globalPowerTemp,int _AlarmType);
int dev_sensor_Alarm_send_message(GlobalDeviceManager* globalDeviceManger,GlobalSensorManger* __globalPowerTemp,int _AlarmType);

int dev_Alarm_Run_message(GlobalDeviceManager* globalDeviceManger,const char* strRunMSG, const char *strOther);

int dev_get_breaker_manage_info(sqlite3 *db,int product_id,GlobalBreakerManager* _globalBreakerManager);
int dev_insert_breaker_genera_manage(sqlite3 *db,GlobalBreakerManager* _globalBreakerManager);
int dev_update_breaker_genera_manage(sqlite3 *db,int product_id,int breaker_id,GlobalBreakerManager* _globalBreakerManager);
int dev_delete_breaker_manage(sqlite3 *db,int product_id,int breaker_id);

int dev_switch_init(sqlite3 *db, netswitch_info_t *sw);
int dev_switch_update_port(sqlite3 *db, port_info_t *pt);
int dev_switch_update_all(sqlite3 *db, netswitch_info_t *sw);

int dev_mail_init(sqlite3 *db, mail_info_t *info);
int dev_mail_get(sqlite3 *db, mail_info_t *info);
int dev_mail_update_send(sqlite3 *db, mail_send_t *send);
int dev_mail_update_recv(sqlite3 *db, mail_recv_t *recv);

int dev_mqtt_init(sqlite3 *db, mqtt_info_t *info);
int dev_mqtt_get(sqlite3 *db, mqtt_info_t *info);
int dev_mqtt_update_ser(sqlite3 *db, mqtt_server_t *ser);
int dev_mqtt_update_info(sqlite3 *db, mqtt_info_t *info);

int dev_sql_VACCUM(sqlite3 *db);
int dev_sql_set_overwrite(int flag);


enum {
    IO_IMPORT=0,
    IO_EXPORT,

    IO_MAX,
};
enum {
    TAB_ID_NTP=0,
    TAB_ID_USER,
    TAB_ID_ROLE,
    TAB_ID_GROUP,
    TAB_ID_SNMP,
    TAB_ID_MAIL,
    TAB_ID_MQTT,
    TAB_ID_TIMER,
    TAB_ID_POWER,
    TAB_ID_POWER3,
    TAB_ID_SENSOR,
    TAB_ID_SENSOR_INFO,
    TAB_ID_BREAKER,
    
    TAB_ID_LOG_INFO,
    TAB_ID_ALARM_INFO,
    TAB_ID_POWER_INFO,
    TAB_ID_POWER3_INFO,
    
    TAB_ID_MAX
};
int dev_sql_xport(sqlite3 *db, int tab_id, int io_type, uint32_t time_s, uint32_t time_e, void *data, int *cnt);


















#endif