|
@@ -123,8 +123,8 @@ func releaseTask() {
|
|
|
checkDataInterface := task.NewTask("checkDataInterface", "0 */2 * * * * ", data.CheckDataInterface)
|
|
|
task.AddTask("checkDataInterface", checkDataInterface)
|
|
|
|
|
|
- //checkPbDataInterface := task.NewTask("checkPbDataInterface", "0 */5 * * * * ", data.CheckPbDataInterface)
|
|
|
- //task.AddTask("checkPbDataInterface", checkPbDataInterface)
|
|
|
+ checkPbDataInterface := task.NewTask("checkPbDataInterface", "0 */2 * * * * ", data.CheckPbDataInterface)
|
|
|
+ task.AddTask("checkPbDataInterface", checkPbDataInterface)
|
|
|
|
|
|
//初始化指标更新状态
|
|
|
resetEdbInfoIsUpdate := task.NewTask("resetEdbInfoIsUpdate", "0 0 0 * * *", data.ResetEdbInfoIsUpdate)
|
|
@@ -168,7 +168,7 @@ func RefreshData(cont context.Context) (err error) {
|
|
|
//同花顺
|
|
|
go data.RefreshDataFromThs(&wg)
|
|
|
//彭博
|
|
|
- //go data.RefreshDataFromPb(&wg)
|
|
|
+ go data.RefreshDataFromPb(&wg)
|
|
|
//手工数据
|
|
|
go data.RefreshDataFromManual(&wg)
|
|
|
//隆众数据
|