update

examcloud-core-oe-task-service/src/main/java/cn/com/qmth/examcloud/core/oe/task/service/job/ScoreStatisticJobHandler.java

@@ -0,0 +1,19 @@
+package cn.com.qmth.examcloud.core.oe.task.service.job;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Component;
+
+/**
+ * 处理考试成绩统计任务
+ */
+@Component
+public class ScoreStatisticJobHandler {
+
+    private static final Logger log = LoggerFactory.getLogger(ScoreStatisticJobHandler.class);
+
+    public void run(int shardTotal, int shardIndex, String jobParam) throws Exception {
+        log.warn("任务_{}_{}", shardTotal, shardIndex);
+    }
+
+}

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

@@ -1,9 +1,6 @@
 package cn.com.qmth.examcloud.core.oe.task.starter.config;
 
-import cn.com.qmth.examcloud.core.oe.task.service.job.AfterHandInExamJobHandler;
-import cn.com.qmth.examcloud.core.oe.task.service.job.BeforeHandInExamJobHandler;
-import cn.com.qmth.examcloud.core.oe.task.service.job.FaceVerifyJobHandler;
-import cn.com.qmth.examcloud.core.oe.task.service.job.SyncExamRecordDataJobHandler;
+import cn.com.qmth.examcloud.core.oe.task.service.job.*;
 import com.xxl.job.core.context.XxlJobHelper;
 import com.xxl.job.core.handler.annotation.XxlJob;
 import org.slf4j.Logger;
@@ -31,6 +28,9 @@ public class OeTaskExecutor {
     @Autowired
     private FaceVerifyJobHandler faceVerifyJobHandler;
 
+    @Autowired
+    private ScoreStatisticJobHandler scoreStatisticJobHandler;
+
     /**
      * 1、处理交卷前考试数据任务
      */
@@ -79,4 +79,16 @@ public class OeTaskExecutor {
         faceVerifyJobHandler.run(shardTotal, shardIndex, jobParam);
     }
 
+    /**
+     * 处理考试成绩统计任务
+     */
+    @XxlJob("scoreStatisticJobHandler")
+    public void scoreStatisticJobHandler() throws Exception {
+        int shardIndex = XxlJobHelper.getShardIndex();
+        int shardTotal = XxlJobHelper.getShardTotal();
+        String jobParam = XxlJobHelper.getJobParam();
+        XxlJobHelper.log("shardTotal:{}, shardIndex:{}", shardTotal, shardIndex);
+        scoreStatisticJobHandler.run(shardTotal, shardIndex, jobParam);
+    }
+
 }