eta_email_analysis/init_serve/task.go

package init_serve

import (
	"eta/eta_email_analysis/global"
	"eta/eta_email_analysis/services/pcsg"
	"github.com/robfig/cron/v3"
)

func InitTask() {
	// 如果配置文件中设置了停止任务，则不执行定时任务
	// 此功能用于多服务器部署时，定时任务只需一台服务器执行，其他服务器不执行；所以只需要一台服务器设置为false，其他服务器设置为true
	if global.CONFIG.Serve.IsStopTask {
		return
	}

	// 开始定时任务
	c := cron.New(cron.WithSeconds())

	//// 定时清除指标更新日志
	//if global.CONFIG.Mysql.Binlog.IsListen {
	//	_, err := c.AddFunc("0 0 0 * * *", index_data.DeleteBeforeTenDayLog)
	//	if err != nil {
	//		global.LOG.Error("DeleteBeforeTenDayLog err" + err.Error())
	//	}
	//}

	{
		syncTime := global.CONFIG.Email.SyncEmailTime
		if syncTime == `` {
			syncTime = `0 */30 * * * *`
		}
		_, err := c.AddFunc(syncTime, pcsg.ListenMail)
		if err != nil {
			global.LOG.Error("pcsg.ListenMail err" + err.Error())
		}
	}
	//pcsg.ListenMail()

	c.Start()
}