main.go 725 B

123456789101112131415161718192021222324252627282930313233343536
  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. firstRun := g.Cfg().MustGet(ctx, "task.firstRun").Bool()
  17. if taskRun {
  18. if firstRun {
  19. logic.Task(ctx)
  20. }
  21. cronStr := g.Cfg().MustGet(ctx, "task.cron").String()
  22. _, err = gcron.AddSingleton(ctx, cronStr, func(ctx context.Context) {
  23. g.Log().Print(ctx, "doing start")
  24. logic.Task(ctx)
  25. g.Log().Print(ctx, "end")
  26. }, "newusersend")
  27. if err != nil {
  28. panic(err)
  29. }
  30. }
  31. select {}
  32. }