|
@@ -49,10 +49,6 @@ func releaseTask() {
|
|
|
refreshData := task.NewTask("refreshData", "0 30 0,19 * * *", RefreshData)
|
|
|
task.AddTask("refreshData", refreshData)
|
|
|
|
|
|
- // TODO:14:00路透刷新测试
|
|
|
- refreshLtTest := task.NewTask("refreshLtTest", "0 0 14 * * *", RefreshLtTest)
|
|
|
- task.AddTask("refreshLtTest", refreshLtTest)
|
|
|
-
|
|
|
// 根据配置刷新指标数据
|
|
|
configRefreshData := task.NewTask("syncBaseDataExt", "0 */30 * * * * ", ConfigRefreshData)
|
|
|
task.AddTask("configRefreshData", configRefreshData)
|
|
@@ -297,17 +293,3 @@ func TaskInit() {
|
|
|
fmt.Println("TaskInit end")
|
|
|
return
|
|
|
}
|
|
|
-
|
|
|
-func RefreshLtTest(cont context.Context) (err error) {
|
|
|
- fmt.Println("RefreshLtTest End")
|
|
|
- wg := sync.WaitGroup{}
|
|
|
- wg.Add(1)
|
|
|
-
|
|
|
- // 路透
|
|
|
- go data.RefreshDataFromLt(&wg)
|
|
|
-
|
|
|
- wg.Wait()
|
|
|
-
|
|
|
- fmt.Println("RefreshLtTest End")
|
|
|
- return
|
|
|
-}
|