cicv_data_closed_loop/aarch64/pjibot_delivery/control/pkg/judge_cloud.go

package pkg

import (
	commonConfig "cicv-data-closedloop/aarch64/pjibot_delivery/common/config"
	"cicv-data-closedloop/common/config/c_log"
	"time"
)

var (
	maxRetryCount = 10
)

// UN_CHANGE 没有新的任务
// CHANGE 有新的任务
// NONE 设备没有配置任务
func GetCloudStatus(cloudStatus *string, lastCloudStatus *string, turnLength int) {
	// 轮询云端任务状态
	for {
		time.Sleep(time.Duration(turnLength) * time.Second)

		*lastCloudStatus = *cloudStatus
		taskStatus, err := commonConfig.GetStatus(commonConfig.PlatformConfig.TaskConfigId)
		if err != nil {
			c_log.GlobalLogger.Error("获取云端配置status失败：", err)
			continue
		}
		if taskStatus == "" || taskStatus == " " {
			taskStatus = "NONE"
		}
		*cloudStatus = taskStatus
	}
}

func GetCloudConfig(cloudStatus *string, lastCloudStatus *string, turnLength int) {
	for {
		time.Sleep(time.Duration(turnLength) * time.Second)
		if *cloudStatus == "CHANGE" {
			c_log.GlobalLogger.Error("cloudStatus：", *cloudStatus)
			if commonConfig.CheckPlatformConfigStatus(maxRetryCount) {
				c_log.GlobalLogger.Info("查询到数据闭环平台有配置任务。")
				commonConfig.InitPlatformConfig()
			}
		}
	}
}