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"



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_search_latest_power_statistic_info(GlobalDeviceManager* globalDeviceManger);
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 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_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_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_id,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_power_manage_genera_info(sqlite3 *db,int product_id,int product_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_insert_alarm_info(sqlite3* db,int product_id,int alarm_type,char* date_time,char* alarm_content);
int dev_search_alarm_info(sqlite3* db,
                        int product_id,
                        int alarm_type,
                        char* start_time,
                        char* 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_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_get_smtp_info(sqlite3 *db, SMTPManager* _globalSMTPInfo);

int dev_get_smtp_recv_user_list(sqlite3 *db, SMTPreceiveAccount* _globalSMTPreceiveAccount);


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_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);
#endif