mirror of
https://github.com/tiger1103/gfast.git
synced 2026-09-21 18:20:47 +00:00
39 lines
767 B
Go
39 lines
767 B
Go
/*
|
|
* @desc:定时任务配置
|
|
* @company:云南省奇讯科技有限公司
|
|
* @Author: yixiaohu
|
|
* @Date: 2021/7/16 15:45
|
|
*/
|
|
|
|
package task
|
|
|
|
import (
|
|
"gfast/app/system/api"
|
|
"gfast/app/system/service"
|
|
"github.com/gogf/gf/frame/g"
|
|
)
|
|
|
|
func init() {
|
|
task1 := &service.TimeTask{
|
|
FuncName: "test1",
|
|
Run: Test1,
|
|
}
|
|
task2 := &service.TimeTask{
|
|
FuncName: "test2",
|
|
Run: Test2,
|
|
}
|
|
checkUserOnlineTask := &service.TimeTask{
|
|
FuncName: "checkUserOnline",
|
|
Run: api.Auth.CheckUserOnline,
|
|
}
|
|
service.TimeTaskList.AddTask(task1).AddTask(task2).AddTask(checkUserOnlineTask)
|
|
//自动执行已开启的任务
|
|
jobs, err := service.SysJob.GetJobs()
|
|
if err != nil {
|
|
g.Log().Error(err)
|
|
}
|
|
for _, job := range jobs {
|
|
service.SysJob.JobStart(job)
|
|
}
|
|
}
|