|
@@ -1,10 +1,8 @@
|
|
package cn.com.qmth.examcloud.core.oe.task.service.job;
|
|
package cn.com.qmth.examcloud.core.oe.task.service.job;
|
|
|
|
|
|
-import cn.com.qmth.examcloud.core.oe.admin.api.ExamScoreNoticeQueueCloudService;
|
|
|
|
import cn.com.qmth.examcloud.core.oe.admin.api.SyncExamDataCloudService;
|
|
import cn.com.qmth.examcloud.core.oe.admin.api.SyncExamDataCloudService;
|
|
import cn.com.qmth.examcloud.core.oe.admin.api.bean.ExamCaptureBean;
|
|
import cn.com.qmth.examcloud.core.oe.admin.api.bean.ExamCaptureBean;
|
|
import cn.com.qmth.examcloud.core.oe.admin.api.bean.ExamSyncCaptureBean;
|
|
import cn.com.qmth.examcloud.core.oe.admin.api.bean.ExamSyncCaptureBean;
|
|
-import cn.com.qmth.examcloud.core.oe.admin.api.request.AddExamScoreNoticeQueueReq;
|
|
|
|
import cn.com.qmth.examcloud.core.oe.admin.api.request.SyncExamDataReq;
|
|
import cn.com.qmth.examcloud.core.oe.admin.api.request.SyncExamDataReq;
|
|
import cn.com.qmth.examcloud.core.oe.student.base.OeConstants;
|
|
import cn.com.qmth.examcloud.core.oe.student.base.OeConstants;
|
|
import cn.com.qmth.examcloud.core.oe.student.dao.ExamRecordDataRepo;
|
|
import cn.com.qmth.examcloud.core.oe.student.dao.ExamRecordDataRepo;
|
|
@@ -14,14 +12,11 @@ import cn.com.qmth.examcloud.core.oe.task.service.ExamBossService;
|
|
import cn.com.qmth.examcloud.core.oe.task.service.ExamRecordDataService;
|
|
import cn.com.qmth.examcloud.core.oe.task.service.ExamRecordDataService;
|
|
import cn.com.qmth.examcloud.core.oe.task.service.ExamingSessionService;
|
|
import cn.com.qmth.examcloud.core.oe.task.service.ExamingSessionService;
|
|
import cn.com.qmth.examcloud.support.CacheConstants;
|
|
import cn.com.qmth.examcloud.support.CacheConstants;
|
|
-import cn.com.qmth.examcloud.support.Constants;
|
|
|
|
-import cn.com.qmth.examcloud.support.enums.ExamProperties;
|
|
|
|
import cn.com.qmth.examcloud.support.enums.ExamRecordStatus;
|
|
import cn.com.qmth.examcloud.support.enums.ExamRecordStatus;
|
|
import cn.com.qmth.examcloud.support.enums.SyncStatus;
|
|
import cn.com.qmth.examcloud.support.enums.SyncStatus;
|
|
import cn.com.qmth.examcloud.support.examing.ExamBoss;
|
|
import cn.com.qmth.examcloud.support.examing.ExamBoss;
|
|
import cn.com.qmth.examcloud.support.examing.ExamRecordData;
|
|
import cn.com.qmth.examcloud.support.examing.ExamRecordData;
|
|
import cn.com.qmth.examcloud.support.examing.ExamingSession;
|
|
import cn.com.qmth.examcloud.support.examing.ExamingSession;
|
|
-import cn.com.qmth.examcloud.support.helper.ExamCacheTransferHelper;
|
|
|
|
import cn.com.qmth.examcloud.support.helper.FaceBiopsyHelper;
|
|
import cn.com.qmth.examcloud.support.helper.FaceBiopsyHelper;
|
|
import cn.com.qmth.examcloud.support.redis.RedisKeyHelper;
|
|
import cn.com.qmth.examcloud.support.redis.RedisKeyHelper;
|
|
import cn.com.qmth.examcloud.web.exception.SequenceLockException;
|
|
import cn.com.qmth.examcloud.web.exception.SequenceLockException;
|
|
@@ -57,9 +52,6 @@ public class SyncExamRecordDataJobHandler {
|
|
@Autowired
|
|
@Autowired
|
|
private SyncExamDataCloudService syncExamDataCloudService;
|
|
private SyncExamDataCloudService syncExamDataCloudService;
|
|
|
|
|
|
- @Autowired
|
|
|
|
- private ExamScoreNoticeQueueCloudService examScoreNoticeQueueCloudService;
|
|
|
|
-
|
|
|
|
@Autowired
|
|
@Autowired
|
|
private ExamingSessionService examingSessionService;
|
|
private ExamingSessionService examingSessionService;
|
|
|
|
|
|
@@ -194,17 +186,6 @@ public class SyncExamRecordDataJobHandler {
|
|
examRecordDataService.saveExamRecordDataCache(examRecordDataId, examRecordDataCache);
|
|
examRecordDataService.saveExamRecordDataCache(examRecordDataId, examRecordDataCache);
|
|
|
|
|
|
this.afterSyncExamData(examRecordDataCache);
|
|
this.afterSyncExamData(examRecordDataCache);
|
|
-
|
|
|
|
- // 是否推送分数
|
|
|
|
- String isPushScore = ExamCacheTransferHelper.getCachedExamProperty(examId, studentId, ExamProperties.PUSH_SCORE.name()).getValue();
|
|
|
|
- if (Constants.isTrue.equals(isPushScore)) {
|
|
|
|
- AddExamScoreNoticeQueueReq req = new AddExamScoreNoticeQueueReq();
|
|
|
|
- req.setRootOrgId(rootOrgId);
|
|
|
|
-
|
|
|
|
- // 添加至成绩通知队列
|
|
|
|
- examScoreNoticeQueueCloudService.addExamScoreNoticeQueue(req);
|
|
|
|
- log.info("addExamScoreNoticeQueue ok, examRecordDataId:{}, studentId:{}", examRecordDataId, studentId);
|
|
|
|
- }
|
|
|
|
}
|
|
}
|
|
|
|
|
|
private void afterSyncExamData(ExamRecordData examRecordDataCache) {
|
|
private void afterSyncExamData(ExamRecordData examRecordDataCache) {
|