fix: 录包数量 - 添加清洁机器人录包启动后休眠

aarch64/pjibot_clean/common/service/rosbag_record.go

@@ -85,6 +85,7 @@ func BagRecord(nodeName string) {
 		}
 		// 等待进程关闭信号
 		c_log.GlobalLogger.Info("启动record命令成功。等待进程关闭信号。")
+		time.Sleep(30 * time.Second)
 		entity.ProcessingFlag = false
 		for {
 			select {

aarch64/pjibot_clean/master/package/service/produce_window.go

@@ -31,10 +31,10 @@ import (
 )
 
 var (
-	//triggerInterval = 3.0 // 每个触发器3秒触发一次
-	triggerInterval = 60.0 // 每个触发器60秒触发一次
-	logInterval     = 3.0
-	logTime         = time.Now()
+	triggerInterval = 3.0 // 每个触发器3秒触发一次
+	//triggerInterval = 60.0 // 每个触发器60秒触发一次
+	logInterval = 3.0
+	logTime     = time.Now()
 )
 
 // 负责监听所有主题并修改时间窗口
@@ -9218,7 +9218,7 @@ func getTopicsOfNode(faultLabel string) (masterTopics []string, slaveTopics []st
 func canCollect() bool {
 	// 如果开启了采集频率限制，则云端判断采集数量是否超过限额
 	if commonConfig.CloudConfig.CollectLimit.Flag == 1 {
-		c_log.GlobalLogger.Error("当前设备已开启数采频率限制，需判断采集数量是否达到限额。")
+		//c_log.GlobalLogger.Error("当前设备已开启数采频率限制，需判断采集数量是否达到限额。")
 		responseString, err := commonUtil.HttpPostJsonWithHeaders(
 			commonConfig.CloudConfig.CollectLimit.Url,
 			map[string]string{"Authorization": "U9yKpD6kZZDDe4LFKK6myAxBUT1XRrDM"},
@@ -9246,12 +9246,12 @@ func canCollect() bool {
 			return false
 		}
 	} else {
-		c_log.GlobalLogger.Error("当前设备未开启数采频率限制，无需判断采集数量是否达到限额。")
+		//c_log.GlobalLogger.Error("当前设备未开启数采频率限制，无需判断采集数量是否达到限额。")
 	}
 
 	// 本地判断是否存在正在处理的数据
 	if entity.ProcessingFlag {
-		c_log.GlobalLogger.Info("存在正在处理的数据，此次不再采集。")
+		//c_log.GlobalLogger.Info("存在正在处理的数据，此次不再采集。")
 		return false
 	}