eta_mini_ht_api/task/sms/code_expired_task.go

package sms

import (
	logger "eta/eta_mini_ht_api/common/component/log"
	"eta/eta_mini_ht_api/common/contants"
	"eta/eta_mini_ht_api/domian/sms"
	"eta/eta_mini_ht_api/task/base"
)

var (
	taskName base.TaskType = "ExpiredCodeTask"
	cron                   = "0/10 * * * * *"
)

// Execute Task ETA取研报的数据
func (st *SMSTask) Execute(taskDetail *base.TaskDetail) error {
	logger.Info(contants.TaskFormat, "处理过期短信开始")
	err := sms.VerifiedCodeTask()
	if err != nil {
		logger.Error("自动更新短信状态失败:%v", err)
	}
	logger.Info(contants.TaskFormat, "处理过期短信结束")
	return err
}

type SMSTask struct {
}

func init() {
	smsTask := base.NewTask(taskName, cron, new(SMSTask), base.DEV)
	base.RegisterTask(&smsTask)
}