Ver Fonte

Merge remote-tracking branch 'origin/release_v5.0.6'

deason há 1 semana atrás
pai
commit
2042625509

Diff do ficheiro suprimidas por serem muito extensas
+ 146 - 0
examcloud-core-oe-task-service/src/main/java/cn/com/qmth/examcloud/core/oe/task/service/job/WarningJobHandler.java


+ 15 - 0
examcloud-core-oe-task-starter/src/main/java/cn/com/qmth/examcloud/core/oe/task/starter/config/OeTaskExecutor.java

@@ -34,6 +34,9 @@ public class OeTaskExecutor {
     @Autowired
     @Autowired
     private ClearExpireDataJobHandler clearExpireDataJobHandler;
     private ClearExpireDataJobHandler clearExpireDataJobHandler;
 
 
+    @Autowired
+    private WarningJobHandler warningJobHandler;
+
     /**
     /**
      * 1、处理考试中考试数据任务
      * 1、处理考试中考试数据任务
      */
      */
@@ -106,4 +109,16 @@ public class OeTaskExecutor {
         clearExpireDataJobHandler.run(shardTotal, shardIndex, jobParam);
         clearExpireDataJobHandler.run(shardTotal, shardIndex, jobParam);
     }
     }
 
 
+    /**
+     * 系统预警任务
+     */
+    @XxlJob("warningJobHandler")
+    public void warningJobHandler() throws Exception {
+        int shardIndex = XxlJobHelper.getShardIndex();
+        int shardTotal = XxlJobHelper.getShardTotal();
+        String jobParam = XxlJobHelper.getJobParam();
+        XxlJobHelper.log("shardTotal:{}, shardIndex:{}, jobParam:{}", shardTotal, shardIndex, jobParam);
+        warningJobHandler.run(shardTotal, shardIndex, jobParam);
+    }
+
 }
 }

Alguns ficheiros não foram mostrados porque muitos ficheiros mudaram neste diff