youngee_b_api/service/autoTask.go

package service

import (
	"fmt"
	"github.com/robfig/cron/v3"
	log "github.com/sirupsen/logrus"
	"time"
	"youngee_b_api/db"
)

func AutoTask() error {
	c := cron.New(cron.WithSeconds())
	//spec := "0 */30 * * * ?" //cron表达式，每半小时执行一次
	spec := "0 */1 * * * ?" //cron表达式，每1分钟一次
	//spec := "*/10 * * * * ?" //cron表达式，每10秒一次

	/*
		_, err1 := c.AddFunc(spec, AutoTaskUpdateStatus)
		if err1 != nil {
			log.Println("service [AutoTaskUpdateStatus] error:", err1)
			return err1
		}
		_, err2 := c.AddFunc("@midnight", AutoTaskUpdateApplyTimes)
		if err2 != nil {
			log.Println("service [AutoTaskUpdateApplyTimes] error:", err2)
			return err2
		}
		_, err3 := c.AddFunc(spec, AutoTaskCompleteSelection)
		if err3 != nil {
			log.Println("service [AutoTaskCompleteSecTask] error:", err2)
			return err3
		}

	*/
	_, err4 := c.AddFunc(spec, GetAutoDraftDefaultTask)
	if err4 != nil {
		log.Println("service [GetAutoDraftDefaultTask] error:", err4)
		return err4
	}
	_, err5 := c.AddFunc(spec, GetAutoLinkDefaultTask)
	if err5 != nil {
		log.Println("service [GetAutoLinkDefaultTask] error:", err4)
		return err5
	}
	_, err6 := c.AddFunc(spec, GetAutoCaseCloseDefaultTask)
	if err6 != nil {
		log.Println("service [GetAutoCaseCloseDefaultTask] error:", err4)
		return err6
	}
	fmt.Println(spec)
	c.Start()
	return nil
}

func AutoTaskUpdateStatus() {
	err := db.AutoUpdateStatus()
	log.Println("AutoTaskUpdateStatus is running ,Time :", time.Now())
	if err != nil {
		log.Println("AutoTaskUpdateStatus error : ", err)
	}
}

func AutoTaskUpdateApplyTimes() {
	err := db.AutoUpdateApplyTimes()
	log.Println("AutoUpdateApplyTimes is running ,Time :", time.Now())
	if err != nil {
		log.Println("AutoUpdateApplyTimes error : ", err)
	}
}

func AutoTaskCompleteSelection() {
	err := db.AutoCompleteSelection()
	log.Println("AutoUpdateApplyTimes is running ,Time :", time.Now())
	if err != nil {
		log.Println("AutoUpdateApplyTimes error : ", err)
	}
}

// GetAutoDraftDefaultTask 初稿超时违约
func GetAutoDraftDefaultTask() {
	err := db.GetAutoDraftDefaultTask()
	log.Println("GetAutoDraftDefaultInPicTask is running ,Time :", time.Now())
	if err != nil {
		log.Println("GetAutoDraftDefaultInPicTask error : ", err)
	}
}

// GetAutoLinkDefaultTask 链接超时违约
func GetAutoLinkDefaultTask() {
	err := db.GetAutoLinkDefaultTask()
	log.Println("GetAutoLinkDefaultTask is running ,Time :", time.Now())
	if err != nil {
		log.Println("GetAutoDraftDefaultInPicTask error : ", err)
	}
}

// GetAutoCaseCloseDefaultTask 数据超时违约
func GetAutoCaseCloseDefaultTask() {
	err := db.GetAutoCaseCloseDefaultTask()
	log.Println("GetAutoCaseCloseDefaultTask is running ,Time :", time.Now())
	if err != nil {
		log.Println("GetAutoCaseCloseDefaultTask error : ", err)
	}
}