add reboot log

dbaccess/sql_db.cpp

@@ -248,6 +248,8 @@ void SqliteDB::SqliteInit(const char *pDbName) {
    execute_sql_file("/opt/configenv/firmware_upgrade.sql");
         
    execute_sql_file("/opt/configenv/receive_wave_status.sql");
+
+   execute_sql_file("/opt/configenv/reboot_record.sql");
 }
 
 void SqliteDB::Createtable(const char *ptableName) {

jsonparse/mqtt_cmd_parse.cpp

@@ -720,9 +720,20 @@ void JsonData::DataNodeStatusCheck() {
                 }
             }
         }
-        if (count == nSize && nodeOnline) {
+        if (count == nSize && nodeOnline && count != 0) {
             zlog_error(zct, "ALL Node offline,count = %d", count);
-            exit(0);
+            char whereCon[64]={0};
+            sprintf(whereCon,"DATE(timestamp, 'unixepoch') = DATE('now') ORDER BY timeStamp DESC limit 0,1");
+            std::string strCount = sqlite_db_ctrl::instance().GetData(" reboot_record ", "count", whereCon);
+            if (atoi(strCount.c_str()) < 3)//当天大于三次不再重启进程
+            {
+                char insertSql[64] = {0};
+                sprintf(insertSql, "'%s',%d,'%s'",localtimestamp,atoi(strCount.c_str())+1,"ALL Node offline");
+                sqlite_db_ctrl::instance().InsertData(" reboot_record ", insertSql);
+                exit(0);
+            }else{
+                zlog_warn(zct, "reboot now count = %d",atoi(strCount.c_str()));
+            }
         }
     }
 }

uart/uart_feature_parse.cpp

@@ -770,14 +770,16 @@ void Uart::DealWave() {
             wave_trans_ = false;
             return;
         }
-        char localtimestamp[32] = {0};
-        GetTimeNet(localtimestamp, 1);
-        char insertSql[100] = {0x00};
-        char whereCon[50] = {0x00};
-        sprintf(whereCon, "MeasurementID='%s'",strMeasurementID.c_str());
-        memset(whereCon, 0x00, sizeof(whereCon));
-        sprintf(insertSql, "'%s','%02x%02x','%s',0,'1','%s' ", strMeasurementID.c_str(),(wave_shortAddr >> 8) & 0xFF,wave_shortAddr & 0xFF,localtimestamp,"");
-        sqlite_db_ctrl::instance().InsertData(" receive_wave_status ", insertSql);
+       if (m_waveCountX > 0 || m_waveCountY > 0 || m_waveCountZ > 0){
+            char localtimestamp[32] = {0};
+            GetTimeNet(localtimestamp, 1);
+            char insertSql[100] = {0x00};
+            char whereCon[50] = {0x00};
+            sprintf(whereCon, "MeasurementID='%s'",strMeasurementID.c_str());
+            memset(whereCon, 0x00, sizeof(whereCon));
+            sprintf(insertSql, "'%s','%02x%02x','%s',0,'1','%s' ", strMeasurementID.c_str(),(wave_shortAddr >> 8) & 0xFF,wave_shortAddr & 0xFF,localtimestamp,"");
+            sqlite_db_ctrl::instance().InsertData(" receive_wave_status ", insertSql);
+        }
 
         std::string ran = "";
         int n = 0;