commit

aarch64/kinglong/common/config/c_platform.go

@@ -15,7 +15,7 @@ type taskTrigger struct {
 	TriggerType       string `json:"triggerType"`
 }
 
-type platformConfig struct {
+type PlatformConfigStruct struct {
 	TaskConfigId    string        `json:"taskConfigId"`   // 配置ID
 	TaskConfigName  string        `json:"taskConfigName"` // 配置名称
 	DropUploadData  bool          `json:"dropUploadData"` // 更新任务时 true 先上传旧任务 false 删除旧任务
@@ -29,15 +29,15 @@ type platformConfig struct {
 }
 
 type response struct {
-	Data    platformConfig `json:"data"`
-	Success bool           `json:"success"`
-	Message string         `json:"message"`
-	Code    int            `json:"code"`
-	NowTime string         `json:"nowTime"`
+	Data    PlatformConfigStruct `json:"data"`
+	Success bool                 `json:"success"`
+	Message string               `json:"message"`
+	Code    int                  `json:"code"`
+	NowTime string               `json:"nowTime"`
 }
 
 var (
-	PlatformConfig  platformConfig
+	PlatformConfig  PlatformConfigStruct
 	SubscribeTopics []string
 )
 
@@ -150,10 +150,10 @@ func GetStatus(taskConfigId string) (string, error) {
 	return dataMap["status"].(string), nil
 }
 
-func getConfig() (platformConfig, error) {
+func getConfig() (PlatformConfigStruct, error) {
 	token, err := GetAccessToken()
 	if err != nil {
-		return platformConfig{}, err
+		return PlatformConfigStruct{}, err
 	}
 	// 下载插件和获取配置
 	// 2 访问配置获取接口
@@ -168,13 +168,13 @@ func getConfig() (platformConfig, error) {
 	)
 	if err != nil {
 		c_log.GlobalLogger.Error("访问接口", CloudConfig.Platform.UrlTask, "失败：", err)
-		return platformConfig{}, err
+		return PlatformConfigStruct{}, err
 	}
 	var result response
 	err = json.Unmarshal([]byte(resp), &result)
 	if err != nil {
 		c_log.GlobalLogger.Error("解析【返回结果】", resp, "失败：", err)
-		return platformConfig{}, err
+		return PlatformConfigStruct{}, err
 	}
 	return result.Data, nil
 }

aarch64/kinglong/control/main/control.go

@@ -83,8 +83,8 @@ func main() {
 				//continue
 			}
 			lastStatus = status
-			c_log.GlobalLogger.Info("获取数据闭环平台最新配置。")
-			config.InitPlatformConfig()
+			c_log.GlobalLogger.Info("结束任务后，将数据闭环平台配置置空。")
+			config.PlatformConfig = config.PlatformConfigStruct{}
 			KillRpcClient.Close()
 		} else {
 			c_log.GlobalLogger.Error("未知的采集任务状态。【status】=", status)

aarch64/pji/control/main/control.go

@@ -86,8 +86,8 @@ func main() {
 				//continue
 			}
 			lastStatus = status
-			c_log.GlobalLogger.Info("获取数据闭环平台最新配置。")
-			commonConfig.InitPlatformConfig()
+			c_log.GlobalLogger.Info("结束任务后，将数据闭环平台配置置空。")
+			commonConfig.PlatformConfig = commonConfig.PlatformConfigStruct{}
 			KillRpcClient.Close()
 		} else {
 			c_log.GlobalLogger.Error("未知的采集任务状态。【status】=", status)