Browse Source

优化数据刷新逻辑

longyu 2 years ago
parent
commit
8884a01619
2 changed files with 10 additions and 2 deletions
  1. 8 0
      services/data/base_edb_lib.go
  2. 2 2
      services/task.go

+ 8 - 0
services/data/base_edb_lib.go

@@ -159,8 +159,16 @@ func EditPythonEdbData(param string) (resp *models.BaseResponse, err error) {
 	return
 }
 
+var count int64
+
 // postRefreshEdbData 刷新指标数据
 func postRefreshEdbData(param map[string]interface{}, urlStr string) (resp *models.BaseResponse, err error) {
+	count++
+
+	if count%2 == 0 {
+		utils.EDB_LIB_URL = "http://127.0.0.1:8300/edbapi/"
+	}
+
 	postUrl := utils.EDB_LIB_URL + urlStr
 	postData, err := json.Marshal(param)
 	if err != nil {

+ 2 - 2
services/task.go

@@ -179,8 +179,8 @@ func releaseTask() {
 	task.AddTask("refreshEicData", refreshEicData)
 
 	//刷新指标基础数据
-	refreshBaseData := task.NewTask("refreshBaseData", "0 */30 * * * * ", RefreshBaseData)
-	task.AddTask("refreshBaseData", refreshBaseData)
+	//refreshBaseData := task.NewTask("refreshBaseData", "0 */30 * * * * ", RefreshBaseData)
+	//task.AddTask("refreshBaseData", refreshBaseData)
 
 	//同步弘则数据库中来自,钢联,隆众,有色,人工等基础数据--每隔五分钟,同步一次最新数据
 	syncBaseData := task.NewTask("syncBaseData", "0 */5 * * * * ", SyncBaseData)