commit

aarch64/pjibot_delivery/common/service/rosbag_record.go

@@ -47,8 +47,8 @@ func BagRecord(nodeName string) {
 		var recordProcessPid int
 		var recordSubProcessPid int
 		var cmd *exec.Cmd
-		systemEnv := os.Environ()
-		c_log.GlobalLogger.Info("系统环境变量为：", systemEnv)
+		//systemEnv := os.Environ()
+		//c_log.GlobalLogger.Info("系统环境变量为：", systemEnv)
 	parent:
 		for {
 			c_log.GlobalLogger.Info("record 环境变量为：", config.RosbagEnvs)

aarch64/pjibot_delivery/control/main.go

@@ -27,10 +27,18 @@ func init() {
 }
 
 func main() {
+	init := true
+	turnLength := 60
 	lastStatus := "NONE"
 	//  轮询任务接口判断是否有更新
 	for {
-		time.Sleep(time.Duration(60) * time.Second)
+		c_log.GlobalLogger.Errorf("一轮次扫描时间【%v】秒：", turnLength)
+		if init {
+			time.Sleep(time.Duration(1) * time.Second)
+			init = false
+		} else {
+			time.Sleep(time.Duration(turnLength) * time.Second)
+		}
 		// 1 获取当前设备的任务的 status
 		status, err := commonConfig.GetStatus(commonConfig.PlatformConfig.TaskConfigId)
 		if err != nil {

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

@@ -350,7 +350,7 @@ func PrepareTimeWindowProducerQueue() {
 			}
 		}
 	}
-
+	c_log.GlobalLogger.Infof("全部订阅者创建完成。")
 	select {
 	case signal := <-commonService.ChannelKillSubscriber:
 		if signal == 1 {

aarch64/pjibot_guide/common/service/rosbag_record.go

@@ -47,8 +47,8 @@ func BagRecord(nodeName string) {
 		var recordProcessPid int
 		var recordSubProcessPid int
 		var cmd *exec.Cmd
-		systemEnv := os.Environ()
-		c_log.GlobalLogger.Info("系统环境变量为：", systemEnv)
+		//systemEnv := os.Environ()
+		//c_log.GlobalLogger.Info("系统环境变量为：", systemEnv)
 	parent:
 		for {
 			c_log.GlobalLogger.Info("record 环境变量为：", config.RosbagEnvs)

aarch64/pjibot_guide/control/main.go

@@ -28,12 +28,18 @@ func init() {
 }
 
 func main() {
+	init := true
 	turnLength := 60
 	lastStatus := "NONE"
 	//  轮询任务接口判断是否有更新
 	for {
 		c_log.GlobalLogger.Errorf("一轮次扫描时间【%v】秒：", turnLength)
-		time.Sleep(time.Duration(turnLength) * time.Second)
+		if init {
+			time.Sleep(time.Duration(1) * time.Second)
+			init = false
+		} else {
+			time.Sleep(time.Duration(turnLength) * time.Second)
+		}
 		// 1 获取当前设备的任务的 status
 		status, err := commonConfig.GetStatus(commonConfig.PlatformConfig.TaskConfigId)
 		if err != nil {

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

@@ -68,7 +68,7 @@ func PrepareTimeWindowProducerQueue() {
 			}
 		}
 	}
-
+	c_log.GlobalLogger.Infof("全部订阅者创建完成。")
 	select {
 	case signal := <-commonService.ChannelKillSubscriber:
 		if signal == 1 {

aarch64/pjibot_patrol/common/service/rosbag_record.go

@@ -47,8 +47,8 @@ func BagRecord(nodeName string) {
 		var recordProcessPid int
 		var recordSubProcessPid int
 		var cmd *exec.Cmd
-		systemEnv := os.Environ()
-		c_log.GlobalLogger.Info("系统环境变量为：", systemEnv)
+		//systemEnv := os.Environ()
+		//c_log.GlobalLogger.Info("系统环境变量为：", systemEnv)
 	parent:
 		for {
 			c_log.GlobalLogger.Info("record 环境变量为：", config.RosbagEnvs)

aarch64/pjibot_patrol/control/main.go

@@ -28,10 +28,18 @@ func init() {
 }
 
 func main() {
+	init := true
+	turnLength := 60
 	lastStatus := "NONE"
 	//  轮询任务接口判断是否有更新
 	for {
-		time.Sleep(time.Duration(60) * time.Second)
+		c_log.GlobalLogger.Errorf("一轮次扫描时间【%v】秒：", turnLength)
+		if init {
+			time.Sleep(time.Duration(1) * time.Second)
+			init = false
+		} else {
+			time.Sleep(time.Duration(turnLength) * time.Second)
+		}
 		// 1 获取当前设备的任务的 status
 		status, err := commonConfig.GetStatus(commonConfig.PlatformConfig.TaskConfigId)
 		if err != nil {

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

@@ -350,7 +350,7 @@ func PrepareTimeWindowProducerQueue() {
 			}
 		}
 	}
-
+	c_log.GlobalLogger.Infof("全部订阅者创建完成。")
 	select {
 	case signal := <-commonService.ChannelKillSubscriber:
 		if signal == 1 {

aarch64/pjisuv/master/service/produce_window.go

@@ -1956,8 +1956,9 @@ func ProduceWindow() {
 				break
 			}
 		}
-	}
 
+	}
+	c_log.GlobalLogger.Infof("全部订阅者创建完成。")
 	select {
 	case signal := <-service.ChannelKillWindowProducer:
 		if signal == 1 {