53 lines
1.1 KiB
Go
53 lines
1.1 KiB
Go
/*
|
|
* @desc:定时任务配置
|
|
* @company:云南省奇讯科技有限公司
|
|
* @Author: yixiaohu
|
|
* @Date: 2021/7/16 15:45
|
|
*/
|
|
|
|
package task
|
|
|
|
import (
|
|
"context"
|
|
"github.com/gogf/gf/v2/frame/g"
|
|
"github.com/gogf/gf/v2/net/ghttp"
|
|
"github.com/gogf/gf/v2/os/gctx"
|
|
"github.com/tiger1103/gfast/v3/internal/app/system/model"
|
|
"github.com/tiger1103/gfast/v3/internal/app/system/service"
|
|
"github.com/tiger1103/gfast/v3/internal/mounter"
|
|
)
|
|
|
|
func init() {
|
|
mounter.Mount(func(ctx context.Context, s *ghttp.Server) {
|
|
Run()
|
|
})
|
|
}
|
|
|
|
func Run() {
|
|
task1 := &model.TimeTask{
|
|
FuncName: "test1",
|
|
Run: Test1,
|
|
}
|
|
task2 := &model.TimeTask{
|
|
FuncName: "test2",
|
|
Run: Test2,
|
|
}
|
|
checkUserOnlineTask := &model.TimeTask{
|
|
FuncName: "checkUserOnline",
|
|
Run: service.SysUserOnline().CheckUserOnline,
|
|
}
|
|
service.TaskList().AddTask(task1)
|
|
service.TaskList().AddTask(task2)
|
|
service.TaskList().AddTask(checkUserOnlineTask)
|
|
ctx := gctx.New()
|
|
//自动执行已开启的任务
|
|
jobs, err := service.SysJob().GetJobs(ctx)
|
|
if err != nil {
|
|
g.Log().Error(ctx, err)
|
|
return
|
|
}
|
|
for _, job := range jobs {
|
|
service.SysJob().JobStart(ctx, job)
|
|
}
|
|
}
|