cronJobService.go 989 B

12345678910111213141516171819202122232425262728293031323334353637383940414243
  1. package service
  2. import (
  3. "github.com/robfig/cron/v3"
  4. "log"
  5. )
  6. // CronJobs CronJobs
  7. // 所有定时任务,在启动时会执行
  8. func CronJobs() {
  9. go func() {
  10. c := cron.New()
  11. // 每隔 20 秒执行
  12. spec := "*/20 * * * * ?"
  13. //每隔20秒将已经结束的流程数据迁移至历史数据表
  14. c.AddFunc(spec, func() {
  15. MoveFinishedProcInstToHistory()
  16. })
  17. // c.AddFunc("*/5 * * * * ?", func() {
  18. // log.Println("cron running")
  19. // })
  20. // 启动
  21. c.Start()
  22. log.Println("----------启动定时任务------------")
  23. defer c.Stop()
  24. select {}
  25. }()
  26. // c := cron.New()
  27. // // 每天0点执行
  28. // spec := "0 0 0 * * ?"
  29. // //每天0点时将已经结束的流程数据迁移至历史数据表
  30. // c.AddFunc(spec, func() {
  31. // MoveFinishedProcInstToHistory()
  32. // })
  33. // c.AddFunc("*/5 * * * * ?", func() {
  34. // log.Println("cron running")
  35. // })
  36. // // 启动
  37. // c.Start()
  38. // log.Println("----------启动定时任务------------")
  39. // defer c.Stop()
  40. // select {}
  41. }