FlowJobConfig.java 1.6 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253
  1. package jnpf.flowable.job;
  2. import org.quartz.*;
  3. import org.springframework.context.annotation.Bean;
  4. import org.springframework.context.annotation.Configuration;
  5. /**
  6. * 类的描述
  7. *
  8. * @author JNPF@YinMai Info. Co., Ltd
  9. * @version 5.0.x
  10. * @since 2024/5/23 18:16
  11. */
  12. @Configuration
  13. public class FlowJobConfig {
  14. @Bean
  15. public JobDetail autoAuditDetail() {
  16. JobDetail jobDetail = JobBuilder.newJob(AutoAuditJob.class)
  17. .storeDurably() // 必须调用该方法,添加任务
  18. .build();
  19. return jobDetail;
  20. }
  21. @Bean
  22. public Trigger autoAuditTrigger() {
  23. // 任务频率
  24. CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule("0/5 * * * * ?");
  25. CronTrigger trigger = TriggerBuilder.newTrigger()
  26. .forJob(autoAuditDetail())
  27. .withSchedule(cronScheduleBuilder)
  28. .build();
  29. return trigger;
  30. }
  31. @Bean
  32. public JobDetail autoTransferDetail() {
  33. JobDetail jobDetail = JobBuilder.newJob(AutoTransferJob.class)
  34. .storeDurably() // 必须调用该方法,添加任务
  35. .build();
  36. return jobDetail;
  37. }
  38. @Bean
  39. public Trigger autoTransferTrigger() {
  40. // 任务频率
  41. CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule("0/8 * * * * ?");
  42. CronTrigger trigger = TriggerBuilder.newTrigger()
  43. .forJob(autoTransferDetail())
  44. .withSchedule(cronScheduleBuilder)
  45. .build();
  46. return trigger;
  47. }
  48. }