优化创建数据库

This commit is contained in:
zhangsheng 2024-10-31 20:18:26 +08:00
parent b33a44cff8
commit eab142ec5b
7 changed files with 29 additions and 10 deletions

1
.gitignore vendored
View File

@ -8,3 +8,4 @@ cgi-bin/
bin/ bin/
GateWay/ GateWay/
Release/ Release/
debug/makefile

BIN
Cidn-SH

Binary file not shown.

View File

@ -30,7 +30,7 @@ void SqliteDB::SqliteInit(const char *pDbName, bool isDB2)
//创建传感器信息存储表 //创建传感器信息存储表
memset(sql_exec, 0, 2048); memset(sql_exec, 0, 2048);
sprintf(sql_exec, "create table if not exists %s(%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s);", sprintf(sql_exec, "create table if not exists %s(%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s);",
T_SENSOR_INFO(TNAME), T_SENSOR_INFO(TNAME),
T_SENSOR_INFO(DATANODENO), T_SENSOR_INFO(DATANODENO),
T_SENSOR_INFO(DATANODENAME), T_SENSOR_INFO(DATANODENAME),
@ -75,7 +75,7 @@ void SqliteDB::SqliteInit(const char *pDbName, bool isDB2)
T_SENSOR_INFO(RSSI), T_SENSOR_INFO(RSSI),
"UpdateFlag", "UpdateFlag",
"LooseValue", "LooseValue",
"batteryPower"), "batteryPower");
CreateTable(sql_exec, isDB2); CreateTable(sql_exec, isDB2);
int iRet = GetTableRows(" sqlite_master "," name = 't_sensor_info' and sql LIKE '%LooseValue%' "); int iRet = GetTableRows(" sqlite_master "," name = 't_sensor_info' and sql LIKE '%LooseValue%' ");
@ -102,10 +102,16 @@ void SqliteDB::SqliteInit(const char *pDbName, bool isDB2)
memset(sql_exec, 0, 2048); memset(sql_exec, 0, 2048);
sprintf(sql_exec,"update t_sensor_info set MeasurementID = dataNodeNo where MeasurementID = '' ;"); sprintf(sql_exec,"update t_sensor_info set MeasurementID = dataNodeNo where MeasurementID = '' ;");
UpdateTableData(sql_exec,isDB2); UpdateTableData(sql_exec,isDB2);
memset(sql_exec, 0, 2048);
sprintf(sql_exec,"update t_sensor_info set NodeWaveSend = '0,0,0' where NodeWaveSend = '' ;");
UpdateTableData(sql_exec,isDB2);
memset(sql_exec, 0, 2048);
sprintf(sql_exec,"update t_sensor_info set NodeWaveSend = '0,0,0' where NodeWaveSend IS NULL ;");
UpdateTableData(sql_exec,isDB2);
//创建传感器数据存储表 //创建传感器数据存储表
memset(sql_exec, 0, 2048); memset(sql_exec, 0, 2048);
sprintf(sql_exec, "create table if not exists %s(%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s integer,%s,%s);", sprintf(sql_exec, "create table if not exists %s(%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s integer,%s,%s,%s);",
T_DATA_INFO(TNAME), T_DATA_INFO(TNAME),
T_DATA_INFO(DATANODENO), T_DATA_INFO(DATANODENO),
T_DATA_INFO(CHANNELID), T_DATA_INFO(CHANNELID),
@ -136,7 +142,7 @@ void SqliteDB::SqliteInit(const char *pDbName, bool isDB2)
//创建传感器静态数据存储表 //创建传感器静态数据存储表
memset(sql_exec, 0, 2048); memset(sql_exec, 0, 2048);
sprintf(sql_exec, "create table if not exists %s(%s,%s,%s,%s,%s,%s,%s,%s integer,%s,%s);", sprintf(sql_exec, "create table if not exists %s(%s,%s,%s,%s,%s,%s,%s,%s integer,%s,%s,%s);",
T_DATASTATIC_INFO(TNAME), T_DATASTATIC_INFO(TNAME),
T_DATASTATIC_INFO(DATANODENO), T_DATASTATIC_INFO(DATANODENO),
T_DATASTATIC_INFO(CHANNELID), T_DATASTATIC_INFO(CHANNELID),

View File

@ -696,6 +696,7 @@ std::string JsonData::JsonCmd_Cgi_02(Param_02 &param)
jsonVal["type"] = "GET"; jsonVal["type"] = "GET";
jsonVal["timeStamp"] = atoi(nowTimetamp.c_str()); jsonVal["timeStamp"] = atoi(nowTimetamp.c_str());
} }
jsonVal["timezone"] = ReadStrByOpt(SYSTEMINFOFILE, "SystemInfo", "timezone");
return showValue.write(jsonVal); return showValue.write(jsonVal);
} }
@ -1233,6 +1234,10 @@ std::string JsonData::JsonCmd_Cgi_25(Param_25 &param)
#ifdef IMX6UL_GATEWAY #ifdef IMX6UL_GATEWAY
strNet = param.mNet; strNet = param.mNet;
param.mNet = "Net"; param.mNet = "Net";
#endif
#ifdef G2UL_GATEWAY
strNet = param.mNet;
param.mNet = "eth0";
#endif #endif
if (0 == param.mMode &&(bFlag1 && bFlag2 && bFlag3 && bFlag4) && param.mNetworkPortStatus == "STATIC") { if (0 == param.mMode &&(bFlag1 && bFlag2 && bFlag3 && bFlag4) && param.mNetworkPortStatus == "STATIC") {
WriteStr2Config(NETWORKCONFIG, param.mNet, "dnsName", param.mDnsName); WriteStr2Config(NETWORKCONFIG, param.mNet, "dnsName", param.mDnsName);
@ -2411,7 +2416,12 @@ std::string JsonData::JsonCmd_Cgi_52(Param_52 &param)
jsonVal["cmdSerial"] = param.mCmdSerial; jsonVal["cmdSerial"] = param.mCmdSerial;
jsonVal["success"] = true; jsonVal["success"] = true;
jsonVal["message"] = " "; jsonVal["message"] = " ";
// #ifndef WIFI_MODULE
// jsonVal["success"] = false;
// jsonVal["message"] = " ";
// jsonVal["enable"] = false;
// return showValue.write(jsonVal);
// #endif
if (0 == param.mMode) { // 扫描 if (0 == param.mMode) { // 扫描
wifi::WPAClient wpa; wifi::WPAClient wpa;
std::string netssid = wpa.GetNetSsid(); std::string netssid = wpa.GetNetSsid();
@ -2825,4 +2835,4 @@ std::string JsonData::JsonCmd_Cgi_57(Param_57 &param)
jsonVal["content"] = jsBody; jsonVal["content"] = jsBody;
return showValue.write(jsonVal); return showValue.write(jsonVal);
} }

View File

@ -54,7 +54,7 @@ int main(int argc, char *argv[])
// UDP接收客户端发来的组播消息用于外接 QT 专家系统,屏蔽之 // UDP接收客户端发来的组播消息用于外接 QT 专家系统,屏蔽之
boost::thread searchT(SearchThread); boost::thread searchT(SearchThread);
searchT.detach(); searchT.detach();
// 串口处理线程,用于与 ZigBee 模块通信通过ZigBee无线通信技术与无线传感器通信 // 串口处理线程,用于与 ZigBee 模块通信通过ZigBee无线通信技术与无线传感器通信
boost::thread uartReadTh(UartStart); boost::thread uartReadTh(UartStart);
uartReadTh.detach(); uartReadTh.detach();
@ -64,8 +64,6 @@ int main(int argc, char *argv[])
boost::thread InitModuleReadTh(InitModule); boost::thread InitModuleReadTh(InitModule);
InitModuleReadTh.detach(); InitModuleReadTh.detach();
//boost::thread uartWatchDogReadTh(WatchDog);
//uartWatchDogReadTh.detach();
// 休眠2秒等待串口线程初始化完毕 // 休眠2秒等待串口线程初始化完毕
sleep(2); sleep(2);

View File

@ -629,6 +629,7 @@ dial5G:
} }
void UartStart() void UartStart()
{ {
print_info("2222222222222\n");
// onReceiveUart cb = (onReceiveUart)&ProtoConvert::HandleFromUart; // onReceiveUart cb = (onReceiveUart)&ProtoConvert::HandleFromUart;
// pUart->setCallBack(cb); // pUart->setCallBack(cb);
print_info("zigAckrep = %d,zigAckreset = %d,zigReset = %d,errorLed = %d,power = %d",\ print_info("zigAckrep = %d,zigAckreset = %d,zigReset = %d,errorLed = %d,power = %d",\
@ -668,6 +669,7 @@ void UartStart()
} }
void InitModule() void InitModule()
{ {
#ifdef NR5G_MODULE #ifdef NR5G_MODULE
#ifdef G2UL_GATEWAY #ifdef G2UL_GATEWAY
@ -722,6 +724,7 @@ void InitModule()
#endif #endif
#endif #endif
} }
void TestUart() void TestUart()
{ {
pUart->InitTestUart(B115200); pUart->InitTestUart(B115200);

View File

@ -1679,7 +1679,8 @@ void Uart::DealDataNodeName(const char* pData)
string hardVersion = vecRes[0][2]; string hardVersion = vecRes[0][2];
string softVersion = vecRes[0][3]; string softVersion = vecRes[0][3];
if((hardVersion == "3.0" && compareVersions(softVersion,"3.6") == -1) || if((hardVersion == "3.0" && compareVersions(softVersion,"3.6") == -1) ||
(hardVersion == "4.0" && compareVersions(softVersion,"4.6") == -1)){ (hardVersion == "4.0" && compareVersions(softVersion,"4.6") == -1) ||
(hardVersion == "1.0" && compareVersions(softVersion,"1.2") == -1)){
memcpy(MeasurementID , vecRes[0][0].c_str(),sizeof(MeasurementID)); memcpy(MeasurementID , vecRes[0][0].c_str(),sizeof(MeasurementID));
} }
std::string strNodeName(NodeName); std::string strNodeName(NodeName);