|
@@ -11,8 +11,15 @@ func InitTask() {
|
|
|
//services.RefreshExcel()
|
|
|
c := cron.New(cron.WithSeconds())
|
|
|
|
|
|
+ // 定时统一更新(日度、周度指标)
|
|
|
+ if global.CONFIG.Serve.RefreshTime == "" {
|
|
|
+ //panic("未配置数据统一刷新时间")
|
|
|
+ // 未配置时间的话,那么默认每天17点更新一次
|
|
|
+ global.CONFIG.Serve.RefreshTime = "0 0 17 * * *"
|
|
|
+ }
|
|
|
+ //fmt.Println(global.CONFIG.Serve.RefreshTime)
|
|
|
// 每天下午5点开始刷新excel表格
|
|
|
- _, err := c.AddFunc("0 0 17 * * *", services.RefreshExcel)
|
|
|
+ _, err := c.AddFunc(global.CONFIG.Serve.RefreshTime, services.RefreshExcel)
|
|
|
//_, err := c.AddFunc("0 55 13 * * *", services.RefreshExcel)
|
|
|
if err != nil {
|
|
|
global.LOG.Info("RefreshExcel err" + err.Error())
|
|
@@ -21,6 +28,9 @@ func InitTask() {
|
|
|
//每2分钟检测一次指标文件是否更新
|
|
|
_, err = c.AddFunc("0 */1 * * * *", watch.ReadWatchIndexFile)
|
|
|
//_, err = c.AddFunc("*/30 * * * * *", watch.ReadWatchIndexFile)
|
|
|
+ if err != nil {
|
|
|
+ global.LOG.Info("watch.ReadWatchIndexFile err" + err.Error())
|
|
|
+ }
|
|
|
|
|
|
c.Start()
|
|
|
|