小程序接口

liujie

2025-05-27 4f46dade49d809e1b8ef92530309dc5f19e39582

 ruoyi-system/src/main/java/com/ruoyi/system/task/base/QuartzManager.java

@@ -7,122 +7,5 @@
import java.util.Map;

public class QuartzManager {
   private static SchedulerFactory factory = new StdSchedulerFactory();
   private static final String TRIGGER_NAME_PREFIX = "TRIGGER_PREFIX_";
   private static final String JOB_NAME_PREFIX = "JOB_PREFIX_";
	
   /**
    * 添加定时任务：具体某个时间点执行一次的任务，如：在某个2015-06-01 12:00发送一条消息
    * 
    * @param jobName
    *            具体的任务名+ID标识唯一
    * @param jobType
    * @param date
    * @param jp
    */
   public synchronized static void addJob(Class<? extends Job> jobClass, String jobName, TimeJobType jobType, Date date,
                                           Map<String,  ? extends Object> jp) {
      //logger.debug("ADD JOB {},jobName={},jobTyep={},jobDate={},",jobClass.getName(),jobName,jobType,date);
      try {
         Scheduler sched = factory.getScheduler();
         JobDetail job = JobBuilder.newJob(jobClass).withIdentity(JOB_NAME_PREFIX + jobName, jobType.getType())
               .setJobData(new JobDataMap(jp)).build();

         SimpleTrigger trigger = (SimpleTrigger) TriggerBuilder.newTrigger()
               .withIdentity(TRIGGER_NAME_PREFIX + jobName, jobType.getType()).startAt(date).build();
         removeJob(jobName, jobType);
			
         sched.scheduleJob(job, trigger);

         if (!sched.isShutdown()) {
            sched.start();
         }
      } catch (Exception e) {
         //logger.error("ADD JOB exception {},jobName={},jobTyep={},jobDate={},",jobClass.getName(),jobName,jobType,date);
      }
   }
	
      /**
       * 修改一个任务的触发时间(使用默认的任务组名，触发器名，触发器组名) 
       * @param jobName 
       * @param time 
       */  
       public synchronized static void modifyJobTime(String jobName,TimeJobType jobType, Date time) {  
           //logger.error("Update JOB exception,jobName={},jobTyep={},jobDate={}," ,jobName,jobType,time);
           try {  
              JobKey jobKey = new JobKey(JOB_NAME_PREFIX + jobName, jobType.getType());
            TriggerKey key = new TriggerKey(TRIGGER_NAME_PREFIX + jobName, jobType.getType());
				
				
               Scheduler sched = factory.getScheduler();  
               SimpleTrigger trigger = (SimpleTrigger) sched.getTrigger(key);  
               if(trigger == null) {  
                   return;  
               }  
               Date oldTime = trigger.getStartTime();
	          
               if (oldTime.getTime() != time.getTime()) {  
                   JobDetail jobDetail = sched.getJobDetail(jobKey);  
                   Class<? extends Job> objJobClass = jobDetail.getJobClass();  
                   removeJob(jobName,jobType);  
                   Map<String, Object> jp = jobDetail.getJobDataMap();
                   addJob(objJobClass, jobName, jobType, time, jp); 
               }  
           } catch (Exception e) {  
              // logger.error("Update JOB exception,jobName={},jobTyep={},jobDate={}," ,jobName,jobType,time);
           }  
       }

   /**
    * 移除一个任务
    * 
    * @param jobName
    */
   public synchronized static void removeJob(String jobName, TimeJobType jobType) {
      try {
         JobKey jobKey = new JobKey(JOB_NAME_PREFIX + jobName, jobType.getType());
         TriggerKey key = new TriggerKey(TRIGGER_NAME_PREFIX + jobName, jobType.getType());
         Scheduler sched = factory.getScheduler();

         JobDetail detail = sched.getJobDetail(jobKey);
         if (detail != null) {
            sched.pauseJob(jobKey);
            sched.pauseTrigger(key);// 停止触发器
            sched.unscheduleJob(key);// 移除触发器
            sched.deleteJob(jobKey);// 删除任务
         }
      } catch (Exception e) {
         e.printStackTrace();
         throw new RuntimeException(e);
      }
   }

   /**
    * 启动所有定时任务
    */
   public synchronized static void startJobs() {
      try {
         Scheduler sched = factory.getScheduler();
         sched.start();
      } catch (Exception e) {
         e.printStackTrace();
         throw new RuntimeException(e);
      }
   }

   /**
    * 关闭所有定时任务
    */
   public synchronized static void shutdownJobs() {
      try {
         Scheduler sched = factory.getScheduler();
         if (!sched.isShutdown()) {
            sched.shutdown();
         }
      } catch (Exception e) {
         e.printStackTrace();
         throw new RuntimeException(e);
      }
   }

}