bug修复

src/main/java/com/project/exam/domain/job/ShortAnswerScoringJob.java

@@ -81,11 +81,16 @@ public class ShortAnswerScoringJob {
     }
 
     /**
-     * 每60秒执行一次，扫描待评分的简答题
+     * 每60秒执行一次，扫描待评分和评分失败的简答题
      */
     @Scheduled(fixedRateString = "${scoring.interval-ms:60000}")
-    public void processPendingScoring() {
-        log.debug(">>> [简答题评分任务] 开始扫描待评分简答题, batchSize={}", batchSize);
+    public void processScoring(){
+        processPendingAndFailedScoring(ExamRecordScoringStatusEnum.PENDING.getValue());
+        processPendingAndFailedScoring(ExamRecordScoringStatusEnum.FAILED.getValue());
+    }
+
+    public void processPendingAndFailedScoring(Integer ExamRecordScoringStatus) {
+        log.debug(">>> [简答题评分任务] 开始扫描待评分和评分失败的简答题, batchSize={}", batchSize);
         if ("local".equalsIgnoreCase(taskProps.getOwner())) {
             return;
         }
@@ -125,7 +130,7 @@ public class ShortAnswerScoringJob {
                     if (!QuestionTypeEnum.SHORT_ANSWER.getValue().equals(snapshot.getType())) {
                         continue;
                     }
-                    if (!Objects.equals(ExamRecordScoringStatusEnum.PENDING.getValue(), snapshot.getScoringStatus())) {
+                    if (!Objects.equals(ExamRecordScoringStatus, snapshot.getScoringStatus())) {
                         continue;
                     }