hongtao3_watch/init_serve/task.go

package init_serve

import (
	"github.com/robfig/cron/v3"
	"hongze/hongtao3_watch/global"
	"hongze/hongtao3_watch/services"
	"hongze/hongtao3_watch/watch"
)

func InitTask() {
	//services.RefreshExcel()
	c := cron.New(cron.WithSeconds())

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

	//////每30分钟检测一次，周度指标刷新
	////_, err = c.AddFunc("0 */30 * * * *", services.IndexRefreshWeek)
	////if err != nil {
	////	global.LOG.Info("DownloadCvTask err" + err.Error())
	////	panic("DownloadCvTask err" + err.Error())
	////}
	//
	// 每天下午5点开始刷新excel表格
	_, err := c.AddFunc("0 0 17 * * *", services.RefreshExcel)
	//_, err := c.AddFunc("0 01 15 * * *", services.RefreshExcel)
	if err != nil {
		global.LOG.Info("RefreshExcel err" + err.Error())
	}
	c.Start()
	//
	// 监听文件
	go watch.ListenFolderNew()

	// 处理excel
	go services.HandleFileUpdate()

	// 处理调用刷新excel的服务(调用python)
	go services.HandleRefreshExcel()

	////redis 队列刷新指标
	//go services.AutoRefresh()

	//CheckIndexCreate()
	//services.Merge()
	//yearFile="year.xlsx"

	//filePath := utils.IndexMsergeSaveDir + "season.xlsx"
	//services.DataAnalysis(filePath)

	//services.Merge()
}

//检测指标数据是否生成
//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()
//}