fix: 清洁机器人修改存在正在数据的数据时暂停采集的逻辑

aarch64/pjibot_clean/common/service/rosbag_record.go

@@ -3,6 +3,7 @@ package service
 import (
 	"cicv-data-closedloop/aarch64/pjibot_clean/common/config"
 	"cicv-data-closedloop/common/config/c_log"
+	"cicv-data-closedloop/common/entity"
 	"cicv-data-closedloop/common/util"
 	"github.com/bluenviron/goroslib/v2"
 	"os"
@@ -84,6 +85,7 @@ func BagRecord(nodeName string) {
 		}
 		// 等待进程关闭信号
 		c_log.GlobalLogger.Info("启动record命令成功。等待进程关闭信号。")
+		entity.ProcessingFlag = false
 		for {
 			select {
 			case signal := <-ChannelKillRosRecord:

aarch64/pjibot_clean/common/service/rosbag_upload.go

@@ -225,7 +225,7 @@ outLoop:
 		if len(entity.TimeWindowConsumerQueue) == 0 {
 			c_log.GlobalLogger.Infof("已处理所有窗口，重启 record 命令。")
 			ChannelKillRosRecord <- 2
-			entity.ProcessingFlag = false
+			//entity.ProcessingFlag = false
 		}
 	}
 }

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

@@ -9248,11 +9248,11 @@ func canCollect() bool {
 		c_log.GlobalLogger.Error("当前设备未开启数采频率限制，无需判断采集数量是否达到限额。")
 	}
 
-	//// 本地判断是否存在正在处理的数据
-	//if entity.ProcessingFlag {
-	//	c_log.GlobalLogger.Info("存在正在处理的数据，此次不再采集。")
-	//	return false
-	//}
+	// 本地判断是否存在正在处理的数据
+	if entity.ProcessingFlag {
+		c_log.GlobalLogger.Info("存在正在处理的数据，此次不再采集。")
+		return false
+	}
 
 	c_log.GlobalLogger.Info("允许采集。")
 	return true