supplier_system/src/dashoo.cn/backend/api/controllers/toolbox/toolbox.go

package toolbox

import (
	"dashoo.cn/backend/api/controllers/invoice"
	"dashoo.cn/backend/api/controllers/oilcontract"
	"dashoo.cn/backend/api/controllers/oilsupplier"
	"github.com/astaxie/beego/toolbox"
)

//type ToolboxController struct {
//	BaseController
//}

func TimingTask() {
	c := new(oilsupplier.OilSupplierCertController)
	invoice := new(invoice.OilInvoiceController)
	todo := new(oilsupplier.TodoListController)
	score := new(oilcontract.OilContractSumScoreController)
	//supplier := new(oilsupplier.OilSupplierController)

	//tkInFlag := toolbox.NewTask("myTaskInFlag", "0 0 1 * * *", func() error {
	//	c.UpdataInFlag()
	//	return nil
	//	})
	//err := tkInFlag.Run()
	//if err != nil {
	//	fmt.Println(err)
	//}
	//toolbox.AddTask("myTaskInFlag", tkInFlag)

	tkSMSnotice := toolbox.NewTask("myTaskSMSnotice", "0 0 10 * * *", func() error {
		c.SendingSMS()
		return nil
	})
	/*err := tkSMSnotice.Run()
	if err != nil {
		fmt.Println(err)
	}*/
	toolbox.AddTask("myTaskSMSnotice", tkSMSnotice)

	//  资质到期提醒
	tkSupplierFile := toolbox.NewTask("myTaskSupplierFile", "0 0 14 * * *", func() error {
		c.SendingSMSSupplierFile()
		return nil
	})
	/* err = tkSupplierFile.Run()
	if err != nil {
		fmt.Println(err)
	} */
	toolbox.AddTask("myTaskSupplierFile", tkSupplierFile)

	//  资质到期，年审到期 企业改为暂停
	tkSupplierStatus := toolbox.NewTask("myTaskSupplierStatus", "0 0 2 * * *", func() error {
		c.ChangeSupplierStatus()
		return nil
	})
	/* err = tkSupplierStatus.Run()
	if err != nil {
		fmt.Println(err)
	} */
	toolbox.AddTask("myTaskSupplierStatus", tkSupplierStatus)

	// 修正过期备注信息
	tkAmendSupplierCertRemark := toolbox.NewTask("myTaskAmendSupplierCertRemark", "0 0 3 * * *", func() error {
		c.AmendSupplierCertRemark()
		return nil
	})
	toolbox.AddTask("myTaskAmendSupplierCertRemark", tkAmendSupplierCertRemark)

	//  每分钟获取诺诺网开票状态
	tkInvoiceStatus := toolbox.NewTask("myTaskInvoiceStatus", "0/30 * * * * *", func() error {
		invoice.SelectInvoiceStatus()
		return nil
	})
	/* err = tkSupplierStatus.Run()
	if err != nil {
		fmt.Println(err)
	} */
	toolbox.AddTask("myTaskInvoiceStatus", tkInvoiceStatus)

	//  每分钟统计首页数据状态
	//tkStatisticsInfo := toolbox.NewTask("myTaskStatisticsInfo", "0 */1 * * * *", func() error {
	//	supplier.StatisticalNum()
	//	return nil
	//})
	/* err = tkSupplierStatus.Run()
	if err != nil {
		fmt.Println(err)
	} */
	//toolbox.AddTask("myTaskStatisticsInfo", tkStatisticsInfo)

	// 有待办调港信通
	tkToDo := toolbox.NewTask("myTaskToDo", "0 0 8 * * *", func() error { // 0 */2 * * * *	每两分钟一次
		todo.PushMsgForTodoUser()
		return nil
	})
	toolbox.AddTask("myTaskToDo", tkToDo)

	// 每年 1月1号0点 准入编号重置为1
	// cron表达式: https://www.cnblogs.com/zuxingyu/p/6023919.html
	tkNumberReset := toolbox.NewTask("myTaskToDo", "0 0 0 1 1 ?", func() error {
		c.NumberReset()
		return nil
	})
	toolbox.AddTask("myTaskNumberReset", tkNumberReset)

	// 每天 1点 获取公司的基本条件评价 0 0 1 * * ?
	basicConditionScore := toolbox.NewTask("myTaskBasicConditionScore", "0 0 1 * * ?", func() error {
		score.SaveBasicConditionScore()
		return nil
	})
	toolbox.AddTask("myTaskBasicConditionScore", basicConditionScore)

	toolbox.StartTask()

	//toolbox.StopTask()
	//beego.Run()

}