main.go 628 B

1234567891011121314151617181920212223242526272829303132
  1. package main
  2. import (
  3. "context"
  4. _ "github.com/gogf/gf/contrib/drivers/mysql/v2"
  5. "github.com/gogf/gf/v2/frame/g"
  6. "github.com/gogf/gf/v2/os/gcron"
  7. "github.com/gogf/gf/v2/os/gctx"
  8. "newuserSend/internal/logic"
  9. )
  10. func main() {
  11. var (
  12. err error
  13. ctx = gctx.New()
  14. )
  15. taskRun := g.Cfg().MustGet(ctx, "task.taskRun").Bool()
  16. if taskRun {
  17. cronStr := g.Cfg().MustGet(ctx, "task.cron").String()
  18. _, err = gcron.AddSingleton(ctx, cronStr, func(ctx context.Context) {
  19. g.Log().Print(ctx, "doing start")
  20. logic.Task(ctx)
  21. g.Log().Print(ctx, "end")
  22. }, "newusersend")
  23. if err != nil {
  24. panic(err)
  25. }
  26. }
  27. select {}
  28. }