zhangsheng/WLG
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

优化创建特征值表名称

Browse Source
This commit is contained in:
zhangsheng 2024-11-21 11:06:07 +08:00
parent d2392eed91
commit 8d3f3bdc65
1 changed files with 18 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
uart/uart.cpp
View File

@ -635,6 +635,23 @@ void Uart::DealDataNodeName(const char *pData) {
sqlite_db_ctrl::instance().UpdateTableData(T_SENSOR_INFO(TNAME), uplCon, whereCon); sqlite_db_ctrl::instance().UpdateTableData(T_SENSOR_INFO(TNAME), uplCon, whereCon);
std::string strData = sqlite_db_ctrl::instance().GetNodeConfigureInfor(whereCon); std::string strData = sqlite_db_ctrl::instance().GetNodeConfigureInfor(whereCon);
data_publish(strData.c_str(), GlobalConfig::Topic_G.mPubConfig.c_str()); data_publish(strData.c_str(), GlobalConfig::Topic_G.mPubConfig.c_str());
char szTableName[50] = {0x00};
char sql_table_exist[50] = {0};
sprintf(szTableName, "t_data_%s", MeasurementID);
sprintf(sql_table_exist,"select count(*) from sqlite_master where type='table' and name = '%s';",szTableName);
int ret = sqlite_db_ctrl::instance().ExeSql(sql_table_exist);
if (ret == 0){
sqlite_db_ctrl::instance().Createtable(szTableName);
}
memset(sql_table_exist, 0x00, sizeof(sql_table_exist));
memset(szTableName, 0x00, sizeof(szTableName));
sprintf(szTableName, "t_dataStatic_%s", MeasurementID);
sprintf(sql_table_exist,"select count(*) from sqlite_master where type='table' and name = '%s';",szTableName);
ret = sqlite_db_ctrl::instance().ExeSql(sql_table_exist);
if (ret == 0){
sqlite_db_ctrl::instance().CreatedataStatictable(szTableName);
}
} }
void Uart::DealDataNodeInfo(const char *pData) { void Uart::DealDataNodeInfo(const char *pData) {
@ -884,12 +901,7 @@ void Uart::DealDataNodeInfo(const char *pData) {
zlog_error(zct, "res = %d", res); zlog_error(zct, "res = %d", res);
} }
} }
char szTableName[50] = {0x00};
sprintf(szTableName, "t_data_%s", dataNodeInfo.ZigbeeLongAddr.c_str());
sqlite_db_ctrl::instance().Createtable(szTableName);
memset(szTableName, 0x00, sizeof(szTableName));
sprintf(szTableName, "t_dataStatic_%s", dataNodeInfo.ZigbeeLongAddr.c_str());
sqlite_db_ctrl::instance().CreatedataStatictable(szTableName);
Json::Value jsonVal; Json::Value jsonVal;
jsonVal.clear(); jsonVal.clear();
jsonVal["cmd"] = "26"; jsonVal["cmd"] = "26";