main.go 587 B

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