deason 2 жил өмнө
parent
commit
70d2147e08

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

@@ -1,20 +0,0 @@
-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);
-        // to do
-    }
-
-}

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

@@ -1,6 +1,9 @@
 package cn.com.qmth.examcloud.core.oe.task.starter.config;
 
-import cn.com.qmth.examcloud.core.oe.task.service.job.*;
+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 com.xxl.job.core.context.XxlJobHelper;
 import com.xxl.job.core.handler.annotation.XxlJob;
 import org.slf4j.Logger;
@@ -28,9 +31,6 @@ public class OeTaskExecutor {
     @Autowired
     private FaceVerifyJobHandler faceVerifyJobHandler;
 
-    @Autowired
-    private ScoreStatisticJobHandler scoreStatisticJobHandler;
-
     /**
      * 1、处理交卷前考试数据任务
      */
@@ -79,16 +79,4 @@ 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);
-    }
-
 }