cron.go 769 B

123456789101112131415161718192021222324252627
  1. package bootstrap
  2. import (
  3. "designs/crons"
  4. "designs/global"
  5. "fmt"
  6. "github.com/robfig/cron/v3"
  7. "time"
  8. )
  9. func InitializeCron() {
  10. global.App.Cron = cron.New(cron.WithSeconds())
  11. go func() {
  12. global.App.Cron.AddFunc("0 0 2 * * *", func() {
  13. fmt.Println(time.Now())
  14. })
  15. global.App.Cron.AddFunc("0 0 1 * * *", crons.ActiveDelete) //清理用户在线数据文件夹
  16. global.App.Cron.AddFunc("0 0 2 * * *", crons.OnlineDatabaseDelete) //清理用户在线数据数据库
  17. global.App.Cron.AddFunc("0 0 1 * * *", crons.AdsDataSummary) //汇总昨日的广告数据
  18. global.App.Cron.AddFunc("0 0 3 * * *", crons.Behavior) //汇总用户的在线时长数据
  19. global.App.Cron.Start()
  20. defer global.App.Cron.Stop()
  21. select {}
  22. }()
  23. }