Преглед на файлове

定时任务增加是否启用

gaodm преди 5 години
родител
ревизия
460ee7c952
променени са 2 файла, в които са добавени 16 реда и са изтрити 2 реда
  1. 12 0
      src/main/java/com/diagbot/entity/SysTaskCron.java
  2. 4 2
      src/main/java/com/diagbot/task/BehospitalInfoAnalyzeTask.java

+ 12 - 0
src/main/java/com/diagbot/entity/SysTaskCron.java

@@ -58,6 +58,11 @@ public class SysTaskCron implements Serializable {
      */
     private String cron;
 
+    /**
+     * 0-未启用 1-启用
+     */
+    private Integer isUsed;
+
     /**
      * 备注
      */
@@ -119,6 +124,13 @@ public class SysTaskCron implements Serializable {
     public void setCron(String cron) {
         this.cron = cron;
     }
+    public Integer getIsUsed() {
+        return isUsed;
+    }
+
+    public void setIsUsed(Integer isUsed) {
+        this.isUsed = isUsed;
+    }
     public String getRemark() {
         return remark;
     }

+ 4 - 2
src/main/java/com/diagbot/task/BehospitalInfoAnalyzeTask.java

@@ -41,7 +41,9 @@ public class BehospitalInfoAnalyzeTask implements SchedulingConfigurer {
             @Override
             public void run() {
                 //1.添加任务内容(Runnable)
-                if (null != task001 && task001.getIsDeleted().equals(IsDeleteEnum.N.getKey())){
+                if (null != task001
+                        && task001.getIsDeleted().equals(IsDeleteEnum.N.getKey())
+                        && task001.getIsUsed().equals(1)) {
                     System.out.println("执行动态定时任务: " + LocalDateTime.now().toLocalTime());
                 }
             }
@@ -56,7 +58,7 @@ public class BehospitalInfoAnalyzeTask implements SchedulingConfigurer {
                 if (null != task001 && StringUtil.isNotBlank(task001.getCron())) {
                     cron = task001.getCron();
                 }
-                CronTrigger trigger=new CronTrigger(cron);
+                CronTrigger trigger = new CronTrigger(cron);
                 return trigger.nextExecutionTime(triggerContext);
             }
         });