74474aaedcba0b5f8514ec7fac899813e7408692.svn-base 1.4 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859
  1. package cn.com.goldenwater.dcproj.utils;
  2. import cn.com.goldenwater.dcproj.model.BisInspTaskScheduler;
  3. import org.quartz.JobKey;
  4. import org.quartz.TriggerKey;
  5. /**
  6. * @author lhc
  7. * @date 2020/9/28 15:04
  8. * 任务管理模块的工具类
  9. */
  10. public class TaskUtils {
  11. /**
  12. * 基于cron调度的Job的默认组名
  13. */
  14. public static final String CRON_JOB_GROUP_NAME = "cron_task_group";
  15. /**
  16. * 产生JobKey
  17. *
  18. * @param job
  19. * @return
  20. */
  21. public static JobKey genCronJobKey(BisInspTaskScheduler job)
  22. {
  23. return new JobKey(job.getTaskName().trim(), CRON_JOB_GROUP_NAME);
  24. }
  25. /**
  26. * 产生TriggerKey
  27. *
  28. * @param job
  29. * @return
  30. */
  31. public static TriggerKey genCronTriggerKey(BisInspTaskScheduler job)
  32. {
  33. return new TriggerKey("trigger_" + job.getTaskName().trim(), CRON_JOB_GROUP_NAME);
  34. }
  35. /**
  36. * 判断是否两个trigger key是否相等
  37. *
  38. * @param tk1
  39. * @param tk2
  40. * @return
  41. */
  42. public static boolean isTriggerKeyEqual(TriggerKey tk1, TriggerKey tk2)
  43. {
  44. return tk1.getName().equals(tk2.getName()) && ((tk1.getGroup() == null && tk2.getGroup() == null)
  45. || (tk1.getGroup() != null && tk1.getGroup().equals(tk2.getGroup())));
  46. }
  47. }