timer.go 870 B

12345678910111213141516171819202122232425262728293031323334353637
  1. package initialize
  2. import (
  3. "fmt"
  4. "server/task"
  5. "github.com/robfig/cron/v3"
  6. "server/global"
  7. )
  8. func Timer() {
  9. go func() {
  10. var option []cron.Option
  11. option = append(option, cron.WithSeconds())
  12. // 清理DB定时任务
  13. _, err := global.GVA_Timer.AddTaskByFunc("ClearDB", "@daily", func() {
  14. err := task.ClearTable(global.GVA_DB) // 定时任务方法定在task文件包中
  15. if err != nil {
  16. fmt.Println("timer error:", err)
  17. }
  18. }, "定时清理数据库【日志,黑名单】内容", option...)
  19. if err != nil {
  20. fmt.Println("add timer error:", err)
  21. }
  22. // 其他定时任务定在这里 参考上方使用方法
  23. //_, err := global.GVA_Timer.AddTaskByFunc("定时任务标识", "corn表达式", func() {
  24. // 具体执行内容...
  25. // ......
  26. //}, option...)
  27. //if err != nil {
  28. // fmt.Println("add timer error:", err)
  29. //}
  30. }()
  31. }