commit

kinglong/control/main/control.go

@@ -22,8 +22,6 @@ func init() {
 	cfg.InitOssConfig()
 	// 初始化业务逻辑配置信息，配置文件在oss上（第2处配置，在oss文件）
 	cfg.InitCloudConfig()
-	// 首先初始化平台配置。
-	cfg.InitPlatformConfig()
 	// 初始化rpc客户端，用于杀死旧的采集程序
 	controlConfig.InitRpcClient()
 }
@@ -39,7 +37,6 @@ func main() {
 			log.GlobalLogger.Error("获取配置status失败：", err)
 			continue
 		}
-		log.GlobalLogger.Infof("【lastStatus】=%v，【status】=%v", lastStatus, status)
 		// 2 判断 status
 		// UN_CHANGE 没有新的任务，无需更改
 		// CHANGE 有新的任务，需要杀死旧的任务并重启

pji/control/main/control.go

@@ -22,8 +22,6 @@ func init() {
 	commonConfig.InitOssConfig()
 	// 初始化业务逻辑配置信息，配置文件在oss上（第2处配置，在oss文件）
 	commonConfig.InitCloudConfig()
-	//// 首先初始化平台配置。
-	//commonConfig.InitPlatformConfig()
 	// 初始化rpc客户端，用于杀死旧的采集程序
 	controlConfig.InitNacos()
 }
@@ -39,7 +37,6 @@ func main() {
 			c_log.GlobalLogger.Error("获取配置status失败：", err)
 			continue
 		}
-		c_log.GlobalLogger.Infof("【lastStatus】=%v，【status】=%v", lastStatus, status)
 		// 2 判断 status
 		// UN_CHANGE 没有新的任务，无需更改
 		// CHANGE 有新的任务，需要杀死旧的任务并重启

trigger/kinglong/data_read/manualTrig/main/manualTrig.go

@@ -0,0 +1,21 @@
+package main
+
+import (
+	"cicv-data-closedloop/kinglong_msgs"
+)
+
+func Topic() string {
+	return "/data_read"
+}
+
+func Label() string {
+	return "manualTrig"
+}
+
+func Rule(data *kinglong_msgs.Retrieval) string {
+	// 车辆紧急换道
+	if data.BCHornSt > 1 {
+		return "manualTrig"
+	}
+	return ""
+}