eta_mini_crm/scheduler/task.go

package scheduler

import (
	"fmt"
	"github.com/beego/beego/v2/task"
)

func InitJob() {
	fmt.Println("start task")
	// 每天凌晨12点检测, 修改用户状态
	//tk2 := task.NewTask("ModifyUserStatus", "5 0 0 * * *", ModifyUserStatus)
	//task.AddTask("定时修改用户状态", tk2)
	task.StartTask()
}

//func ModifyUserStatus(ctx context.Context) (err error) {
//	defer func() {
//		if err != nil {
//			utils.ApiLog.Info("修改用户状态，定时任务出错，Err: %s", err)
//		}
//		if err := recover(); err != nil {
//			utils.ApiLog.Warn("修改用户状态，定时任务出错，Err: %s", err)
//		}
//	}()
//	curTime := time.Now()
//	var pars []interface{}
//	condition := ` AND valid_end_time<?`
//	pars = append(pars, curTime)
//	condition += ` AND status=? `
//	pars = append(pars, 2)
//	userIds, err := models.GetUserIdListByCondition(condition, pars)
//	if err != nil {
//		return
//	}
//	err = models.UpdateUserStatus(condition, pars)
//	if err != nil {
//		return
//	}
//	userRecordList := make([]*models.UserChangeRecord, 0)
//	for _, v := range userIds {
//		record := &models.UserChangeRecord{}
//		record.UserId = v
//		record.SysUserId = 0
//		record.Content = "有效期到期禁用用户"
//		record.CreateTime = time.Now()
//		userRecordList = append(userRecordList, record)
//	}
//	if len(userRecordList) > 0 {
//		err = models.UserChangeRecordMultiInsert(userRecordList)
//		if err != nil {
//			return
//		}
//	}
//	return
//}