faceVerifyJobHandler

examcloud-core-oe-task-service/src/main/java/cn/com/qmth/examcloud/core/oe/task/service/job/FaceVerifyJobHandler.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 FaceVerifyJobHandler {
+
+    private static final Logger log = LoggerFactory.getLogger(FaceVerifyJobHandler.class);
+
+    public void run(int shardTotal, int shardIndex, String jobParam) throws Exception {
+        log.info("todo..");
+    }
+
+}

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

@@ -2,6 +2,7 @@ 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 com.xxl.job.core.context.XxlJobHelper;
 import com.xxl.job.core.handler.annotation.XxlJob;
@@ -27,6 +28,9 @@ public class OeTaskExecutor {
     @Autowired
     private SyncExamRecordDataJobHandler syncExamRecordDataJobHandler;
 
+    @Autowired
+    private FaceVerifyJobHandler faceVerifyJobHandler;
+
     /**
      * 1、处理交卷前考试数据任务
      */
@@ -63,4 +67,16 @@ public class OeTaskExecutor {
         syncExamRecordDataJobHandler.run(shardTotal, shardIndex, jobParam);
     }
 
+    /**
+     * 处理考试过程中抓拍照片比对任务
+     */
+    @XxlJob("faceVerifyJobHandler")
+    public void faceVerifyJobHandler() throws Exception {
+        int shardIndex = XxlJobHelper.getShardIndex();
+        int shardTotal = XxlJobHelper.getShardTotal();
+        String jobParam = XxlJobHelper.getJobParam();
+        XxlJobHelper.log("shardTotal:{}, shardIndex:{}", shardTotal, shardIndex);
+        faceVerifyJobHandler.run(shardTotal, shardIndex, jobParam);
+    }
+
 }