调度执行器

src/main/resources/modules/SpringBoot/java/module/wsys/mgr/TaskSqlManagerImpl.java

@@ -44,8 +44,6 @@ public class TaskSqlManagerImpl implements TaskSqlManager {
 
     @Autowired
     private TaskSqlMapper taskSqlMapper;
-    @Autowired
-    private Scheduler scheduler;
 
     /**
      * 插入
@@ -115,6 +113,7 @@ public class TaskSqlManagerImpl implements TaskSqlManager {
             return response;
         }
         response.setResult(result);
+        Scheduler scheduler = LocalData.getBean(Scheduler.class);
         scheduler.remove(String.valueOf(request.getId()));
 
         return response;
@@ -168,6 +167,7 @@ public class TaskSqlManagerImpl implements TaskSqlManager {
         if (request.getValid()) {
             createOrRepeat(MapperUtil.map(request, TaskSql.class));
         } else {
+            Scheduler scheduler = LocalData.getBean(Scheduler.class);
             scheduler.remove(String.valueOf(request.getId()));
         }
 
@@ -213,6 +213,7 @@ public class TaskSqlManagerImpl implements TaskSqlManager {
     public boolean createOrRepeat(TaskSql taskSql) {
         try {
             if ("Cron".equals(taskSql.getTaskType())) {
+                Scheduler scheduler = LocalData.getBean(Scheduler.class);
                 scheduler.createOrRepeat(new RunCronTask() {
 
                     @Override
@@ -241,6 +242,7 @@ public class TaskSqlManagerImpl implements TaskSqlManager {
                 });
             }
             if ("DelayRepeat".equals(taskSql.getTaskType())) {
+                Scheduler scheduler = LocalData.getBean(Scheduler.class);
                 scheduler.createOrRepeat(new RunDelayRepeatTask() {
                     @Override
                     public Duration interval() {
@@ -269,6 +271,7 @@ public class TaskSqlManagerImpl implements TaskSqlManager {
                 });
             }
             if ("FixRepeat".equals(taskSql.getTaskType())) {
+                Scheduler scheduler = LocalData.getBean(Scheduler.class);
                 scheduler.createOrRepeat(new RunFixRepeatTask() {
                     @Override
                     public Duration interval() {