123456789101112131415161718192021222324252627282930313233343536 |
- package main
- import (
- "context"
- _ "github.com/gogf/gf/contrib/drivers/mysql/v2"
- "github.com/gogf/gf/v2/frame/g"
- "github.com/gogf/gf/v2/os/gcron"
- "github.com/gogf/gf/v2/os/gctx"
- "newuserSend/internal/logic"
- )
- func main() {
- var (
- err error
- ctx = gctx.New()
- )
- taskRun := g.Cfg().MustGet(ctx, "task.taskRun").Bool()
- firstRun := g.Cfg().MustGet(ctx, "task.firstRun").Bool()
- if taskRun {
- if firstRun {
- logic.Task(ctx)
- }
- cronStr := g.Cfg().MustGet(ctx, "task.cron").String()
- _, err = gcron.AddSingleton(ctx, cronStr, func(ctx context.Context) {
- g.Log().Print(ctx, "doing start")
- logic.Task(ctx)
- g.Log().Print(ctx, "end")
- }, "newusersend")
- if err != nil {
- panic(err)
- }
- }
- select {}
- }
|