youngee_b_api/app/schedule/auto_task2.go

package schedule

import (
	"github.com/robfig/cron/v3"
	"log"
	"time"
	"youngee_b_api/app/dao"
)

func AutoTask2() error {
	// 新建一个定时任务对象
	crontab := cron.New(cron.WithSeconds()) // 精确到秒
	spec := "0 */2 * * * ?"                 //cron表达式

	// 定时任务  检查微信支付是否充值成功
	_, err1 := crontab.AddFunc(spec, AutoCheckWXRechargeTask)
	if err1 != nil {
		return err1
	}

	// 启动定时器
	crontab.Start()
	// 定时任务是另起协程执行的,这里使用 select 简单阻塞.需要根据实际情况进行控制
	//select {} //阻塞主线程停止
	return nil
}

// 定时任务  检查微信支付是否充值成功
func AutoCheckWXRechargeTask() {
	log.Println("AutoCheckWXRechargeTask running Start, Time :", time.Now())
	_ = dao.RechargeRecordDao{}.UpdateRechargeFailedList()
	log.Println("AutoCheckWXRechargeTask running End, Time :", time.Now())
}