测试

services/data_stat/edb_info_stat.go

@@ -4,16 +4,20 @@ import (
 	"context"
 	"errors"
 	"eta/eta_task/services/data"
+	"eta/eta_task/utils"
 )
 
 // SetEdbSourceStatTask 设置数据源指标更新情况定时任务
 func SetEdbSourceStatTask(cont context.Context) (err error) {
+	utils.FileLog.Info("SetEdbSourceStatTask 开始")
 	resp, err := data.SetEdbSourceStat()
 	if err != nil {
+		utils.FileLog.Info("SetEdbSourceStatTask 定时更新出错 Err:" + err.Error())
 		return errors.New("SetEdbSourceStat Err:" + err.Error())
 	}
 	if resp.Ret != 200 {
 		return errors.New("SetEdbSourceStat Err:" + resp.Msg + ";ErrMsg:" + resp.ErrMsg)
 	}
+	utils.FileLog.Info("SetEdbSourceStatTask 结束")
 	return
 }

services/task.go

@@ -23,7 +23,7 @@ func Task() {
 	publishSmartReport := task.NewTask("publishSmartReport", "0 */1 * * * *", PublishSmartReport)
 	task.AddTask("定时发布智能研报", publishSmartReport)
 	// 定时汇总数据源终端指标更新情况
-	setEdbSourceStatTask := task.NewTask("setEdbSourceStatTask", "0 30 23,19 * * *", data_stat.SetEdbSourceStatTask)
+	setEdbSourceStatTask := task.NewTask("setEdbSourceStatTask", "0 50 15,19 * * *", data_stat.SetEdbSourceStatTask)
 	task.AddTask("数据源统计表", setEdbSourceStatTask)
 
 	task.StartTask()