hanzhengyi il y a 8 mois
Parent
commit
eca661a710

+ 1 - 0
service-job/src/main/java/com/ruoyi/job/service/SysJobServiceImpl.java

@@ -36,6 +36,7 @@ public class SysJobServiceImpl implements ISysJobService
     @PostConstruct
     public void init() throws SchedulerException, TaskException
     {
+        System.out.println("han----------------");
         scheduler.clear();
         List<SysJob> jobList = jobMapper.selectJobAll();
         for (SysJob job : jobList)

+ 2 - 2
service-job/src/main/java/com/ruoyi/job/util/ScheduleUtils.java

@@ -58,6 +58,7 @@ public class ScheduleUtils
      */
     public static void createScheduleJob(Scheduler scheduler, SysJob job) throws SchedulerException, TaskException
     {
+        System.out.println("han++++++++++++");
         Class<? extends Job> jobClass = getQuartzJobClass(job);
         // 构建job信息
         Long jobId = job.getJobId();
@@ -81,9 +82,8 @@ public class ScheduleUtils
             // 防止创建时存在数据问题 先移除,然后在执行创建操作
             scheduler.deleteJob(getJobKey(jobId, jobGroup));
         }
-
+        System.out.println("han=============");
         scheduler.scheduleJob(jobDetail, trigger);
-        System.out.println("ceshi+++++++++++++++");
 
         // 暂停任务
         if (job.getStatus().equals(ScheduleConstants.Status.PAUSE.getValue()))