考试交卷补偿任务

web/src/main/java/com/ynfy/buss/exam/exam/job/BreakExamJob.java

@@ -1,54 +0,0 @@
-package com.ynfy.buss.exam.exam.job;
-
-import com.alibaba.fastjson.JSON;
-import com.ynfy.buss.exam.exam.dto.ExamSubmitDTO;
-import com.ynfy.buss.exam.exam.enums.PaperState;
-import com.ynfy.buss.exam.exam.service.IExamService;
-import com.ynfy.buss.exam.userexam.entity.UserExam;
-import com.ynfy.buss.exam.userexam.service.IUserExamService;
-import lombok.extern.slf4j.Slf4j;
-import org.jeecg.common.util.RedisUtil;
-import org.quartz.Job;
-import org.quartz.JobDetail;
-import org.quartz.JobExecutionContext;
-import org.quartz.JobExecutionException;
-import org.springframework.beans.factory.annotation.Autowired;
-
-import java.util.Objects;
-
-/**
- * 超时自动交卷任务
- *
- * @author bool
- */
-@Slf4j
-public class BreakExamJob implements Job {
-
-    @Autowired
-    private IExamService examService;
-
-    @Autowired
-    private IUserExamService userExamService;
-
-    @Autowired
-    public RedisUtil redisUtil;
-
-    @Override
-    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
-        JobDetail detail = jobExecutionContext.getJobDetail();
-        String key = String.valueOf(detail.getJobDataMap().get("parameter"));
-
-        log.info("{} 定时任务：处理到期的交卷", key);
-        UserExam userExam = userExamService.getById(key);
-        if (!Objects.isNull(userExam) && userExam.getState().intValue() != PaperState.FINISHED) {
-            Object data = redisUtil.get(key);
-            // 强制交卷
-            if (!Objects.isNull(data)) {
-                ExamSubmitDTO dto = JSON.parseObject(String.valueOf(data), ExamSubmitDTO.class);
-                examService.submitExam(dto);
-                return;
-            }
-        }
-        examService.deleteAutoCommitJob(key);
-    }
-}

web/src/main/java/com/ynfy/buss/exam/exam/job/ExamStatisticsJob.java

@@ -1,41 +0,0 @@
-package com.ynfy.buss.exam.exam.job;
-
-import com.ynfy.buss.exam.exam.service.IExamService;
-import com.ynfy.buss.exam.examstatistics.service.IExamStatisticsService;
-import lombok.extern.slf4j.Slf4j;
-import org.quartz.Job;
-import org.quartz.JobExecutionContext;
-import org.quartz.JobExecutionException;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.util.CollectionUtils;
-
-import java.util.List;
-
-/**
- * 考试成绩统计任务
- */
-@Slf4j
-public class ExamStatisticsJob implements Job {
-
-    @Autowired
-    private IExamStatisticsService examStatisticsService;
-
-    @Autowired
-    private IExamService examService;
-
-    @Override
-    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
-        try {
-            log.info("考试成绩统计任务执行开始......");
-            //获取正在进行中的考试
-            List<String> examIdList = examService.listExamIng();
-            if (!CollectionUtils.isEmpty(examIdList)) {
-                //考试结果统计
-                examIdList.stream().forEach(examId -> examStatisticsService.calcExamDimension(examId));
-            }
-        } catch (Exception e) {
-            e.printStackTrace();
-            log.error("考试成绩统计任务异常：{}", e.getMessage());
-        }
-    }
-}

web/src/main/java/com/ynfy/buss/exam/exam/job/MakeupSubmitExamJob.java → web/src/main/java/com/ynfy/buss/exam/job/MakeupSubmitExamJob.java

@@ -1,4 +1,4 @@
-package com.ynfy.buss.exam.exam.job;
+package com.ynfy.buss.exam.job;
 
 import com.alibaba.fastjson.JSON;
 import com.ynfy.buss.exam.exam.dto.ExamSubmitDTO;