Jelajahi Sumber

fix:数据刷新,阻塞基础指标更新完后,再去更新计算指标

Roc 3 tahun lalu
induk
melakukan
4800362fb0
1 mengubah file dengan 2 tambahan dan 2 penghapusan
  1. 2 2
      services/task.go

+ 2 - 2
services/task.go

@@ -162,7 +162,7 @@ func OneMinute(cont context.Context) (err error) {
 
 func RefreshData(cont context.Context) (err error) {
 	wg := sync.WaitGroup{}
-	wg.Add(6)
+	wg.Add(7)
 	//wind
 	go data.RefreshDataFromWind(&wg)
 	//同花顺
@@ -707,4 +707,4 @@ func deleteTask() {
 			break
 		}
 	}
-}
+}