|
@@ -39,28 +39,19 @@ var PlatformConfig platformConfig
|
|
|
|
|
|
// InitPlatformConfig 初始化数据闭环平台的配置
|
|
|
func InitPlatformConfig() {
|
|
|
+ var err error
|
|
|
c_log.GlobalLogger.Info("获取数据闭环平台配置 - 开始")
|
|
|
// 1 如果车辆没有配置任务,则阻塞在这里,不启动任务
|
|
|
for {
|
|
|
time.Sleep(time.Duration(1))
|
|
|
c_log.GlobalLogger.Info("获取数据闭环平台配置 - 进行中")
|
|
|
- status, err := GetStatus("")
|
|
|
+ // 判断是否有配置,第一次访问状态应该为:CHANGE(一共三种状态 CHANGE|UNCHANGE|NONE)
|
|
|
+ PlatformConfig, err = getConfig()
|
|
|
if err != nil {
|
|
|
c_log.GlobalLogger.Error("获取配置status失败:", err)
|
|
|
continue
|
|
|
}
|
|
|
- // 判断是否有配置,第一次访问状态应该为:CHANGE(一共三种状态 CHANGE|UNCHANGE|NONE)
|
|
|
- if status == "CHANGE" {
|
|
|
- PlatformConfig, err = getConfig()
|
|
|
- if err != nil {
|
|
|
- c_log.GlobalLogger.Error("获取配置status失败:", err)
|
|
|
- continue
|
|
|
- } else {
|
|
|
- break
|
|
|
- }
|
|
|
- } else {
|
|
|
- c_log.GlobalLogger.Error("车辆没有配置采集任务,等待平台配置。status=", status)
|
|
|
- }
|
|
|
+ break
|
|
|
}
|
|
|
c_log.GlobalLogger.Info("获取数据闭环平台配置 - 成功。")
|
|
|
}
|