|
@@ -177,6 +177,10 @@ func releaseTask() {
|
|
|
checkLtDataInterface := task.NewTask("checkLtDataInterface", "0 */2 * * * * ", data.CheckLtDataInterface)
|
|
|
task.AddTask("checkLtDataInterface", checkLtDataInterface)
|
|
|
|
|
|
+ //检测wind新服务器
|
|
|
+ checkWindDataInterface := task.NewTask("checkWindDataInterface", "0 */2 * * * * ", data.CheckWindDataInterface)
|
|
|
+ task.AddTask("checkWindDataInterface", checkWindDataInterface)
|
|
|
+
|
|
|
//初始化指标更新状态
|
|
|
resetEdbInfoIsUpdate := task.NewTask("resetEdbInfoIsUpdate", "0 0 0 * * *", data.ResetEdbInfoIsUpdate)
|
|
|
task.AddTask("resetEdbInfoIsUpdate", resetEdbInfoIsUpdate)
|
|
@@ -214,7 +218,10 @@ func OneMinute(cont context.Context) (err error) {
|
|
|
func RefreshData(cont context.Context) (err error) {
|
|
|
wg := sync.WaitGroup{}
|
|
|
wg.Add(8)
|
|
|
- go data.RefreshDataFromWind(&wg)
|
|
|
+ hour := time.Now().Hour()
|
|
|
+ if hour != 0 {
|
|
|
+ go data.RefreshDataFromWind(&wg)
|
|
|
+ }
|
|
|
//同花顺
|
|
|
go data.RefreshDataFromThs(&wg)
|
|
|
//彭博
|