Przeglądaj źródła

优化同步指标任务触发逻辑

- 移除了不必要的打印语句,提高代码整洁度
- 修改了指标同步任务的触发条件,只有当 SyncIndexPath 配置存在时才添加定时任务
- 将硬编码的 GnEdbListUri 替换为动态的 SyncIndexPath 配置,提高了代码的灵活性和可配置性
Roc 5 miesięcy temu
rodzic
commit
12715e3b3b

+ 1 - 2
services/data/base_edb_lib.go

@@ -83,7 +83,6 @@ func RefreshEdbData(edbInfoId, source, subSource int, edbCode, startDate string)
 	default:
 		urlStr = data_manage.GetEdbSourceRefreshMethodBySourceId(source) // 没有对应的从edb_source中取
 	}
-	fmt.Println("urlStr:", urlStr)
 	if urlStr == "" {
 		err = fmt.Errorf(fmt.Sprint("source:", source, ";未实现该指标的刷新接口,请联系管理员"))
 		return
@@ -163,6 +162,6 @@ func HttpPost(url, postData string, params ...string) ([]byte, error) {
 	}
 	defer resp.Body.Close()
 	b, err := ioutil.ReadAll(resp.Body)
-	fmt.Println("HttpPost:" + string(b))
+	//fmt.Println("HttpPost:" + string(b))
 	return b, err
 }

+ 1 - 1
services/eta_bridge/gn.go

@@ -186,7 +186,7 @@ func syncGnIndex(currIndex, pageSize int, baseLastUpdateTimeStr string) (err err
 		PageIndex:      currIndex,
 		PageSize:       pageSize,
 	}
-	bResult, err, _ := HttpEtaBridgePost(GnEdbListUri, params)
+	bResult, err, _ := HttpEtaBridgePost(utils.SyncIndexPath, params)
 	if err != nil {
 		return
 	}

+ 7 - 5
services/task_gn.go

@@ -9,11 +9,13 @@ import (
 func GnTask() {
 	// 指标相关
 	// 每小时同步一次指标列表
-	syncIndexTime := utils.SyncIndexTime
-	if syncIndexTime == `` {
-		syncIndexTime = "0 0 * * * *"
+	if utils.SyncIndexPath != `` {
+		syncIndexTime := utils.SyncIndexTime
+		if syncIndexTime == `` {
+			syncIndexTime = "0 0 * * * *"
+		}
+		syncIndex := task.NewTask("syncIndex", syncIndexTime, eta_bridge.SyncGnIndex)
+		task.AddTask("定时同步指标信息", syncIndex)
 	}
-	syncIndex := task.NewTask("syncIndex", syncIndexTime, eta_bridge.SyncGnIndex)
-	task.AddTask("定时同步指标信息", syncIndex)
 
 }