mysteel_watch/init_serve/task.go

package init_serve

import (
	"eta/mysteel_watch/services"
	"eta/mysteel_watch/utils"
	"eta/mysteel_watch/watch"
	"github.com/robfig/cron/v3"
	"time"

	"eta/mysteel_watch/global"
	"eta/mysteel_watch/services/alarm_msg"
)

func InitTask() {

	c := cron.New(cron.WithSeconds())

	//每1分钟检测一次，指标生成
	_, err := c.AddFunc("0 */5 * * * *", CheckIndexCreateMerge)
	if err != nil {
		global.LOG.Info("DownloadCvTask err" + err.Error())
	}

	//每天17点刷新指标
	_, err = c.AddFunc("0 0 17 * * *", services.MergeV2)
	if err != nil {
		global.LOG.Info("DownloadCvTask err" + err.Error())
	}

	//每2分钟检测一次指标文件是否更新
	_, err = c.AddFunc("0 */2 * * * *", watch.ReadWatchIndexFile)

	_, err = c.AddFunc("0 0 17 1 * *", services.MergeMonthSeasonYearV2)
	if err != nil {
		global.LOG.Info("DownloadCvTask err" + err.Error())
	}

	// 服务检测
	_, err = c.AddFunc("0 */1 * * * *", services.ServerCheck)
	if err != nil {
		global.LOG.Info("ServerCheck err" + err.Error())
	}

	// 指标更新检测
	if global.CONFIG.Serve.IsCheckIndexUpdate {
		services.IndexUpdateCheck()
		_, err = c.AddFunc("0 30 17 * * *", services.IndexUpdateCheck)
		if err != nil {
			global.LOG.Info("IndexUpdateCheck err" + err.Error())
		}

	}
	c.Start()
}

// CheckIndexCreate 检测指标数据是否生成
func CheckIndexCreate() {
	var err error
	defer func() {
		if err != nil && err.Error() != "record not found" {
			global.LOG.Info(utils.APPNAME + " 定时任务 出错" + time.Now().Format("2006-01-02 15:04:05") + ";Err:" + err.Error())
			go alarm_msg.SendAlarmMsg(utils.APPNAME+" 定时任务 出错"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+err.Error(), 3)
		}
	}()
	err = services.IndexCreateCheck()
}

// CheckIndexCreate 检测指标数据是否生成
func CheckIndexCreateMerge() {
	var err error
	defer func() {
		if err != nil && err.Error() != "record not found" {
			global.LOG.Info(utils.APPNAME + " 定时任务 出错" + time.Now().Format("2006-01-02 15:04:05") + ";Err:" + err.Error())
			//go alarm_msg.SendAlarmMsg(utils.APPNAME+" 定时任务 出错"+time.Now().Format("2006-01-02 15:04:05")+";Err:"+err.Error(), 3)
		}
	}()
	err = services.IndexCreateCheckMerge()
}