新增定时任务每天查询考试中的人员，进行成绩核算和修改状态

Administrator

2022-01-22 ff13be9aaa95de8be5341e93e95f8611a43d4403

 src/main/java/org/springblade/modules/training/service/impl/TrainingRegistrationServiceImpl.java

@@ -13,8 +13,10 @@
import org.springblade.modules.absentrecords.service.AbsentRecordsService;
import org.springblade.modules.apply.entity.Apply;
import org.springblade.modules.apply.excel.ApplyInfoExcel;
import org.springblade.modules.exam.entity.ExamAnswerRecord;
import org.springblade.modules.exam.entity.ExamPaper;
import org.springblade.modules.exam.entity.ExamScore;
import org.springblade.modules.exam.service.ExamAnswerRecordService;
import org.springblade.modules.exam.service.ExamPaperService;
import org.springblade.modules.exam.service.ExamScoreService;
import org.springblade.modules.system.entity.User;
@@ -26,6 +28,7 @@
import org.springblade.modules.training.service.TrainingRegistrationService;
import org.springblade.modules.training.util.LongTimeUtil;
import org.springblade.modules.training.vo.TrainingRegistrationVo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@@ -54,6 +57,8 @@

   private final ExamScoreService examScoreService;

   @Autowired
   private ExamAnswerRecordService examAnswerRecordService;

   @Override
   public IPage<TrainingRegistrationVo> selectTrainingRegistrationPage(IPage<TrainingRegistrationVo> page, TrainingRegistrationVo trainingRegistration) {
@@ -405,4 +410,72 @@
         });
      }
   }

   /**
    * 定时任务处理考试中的
    */
   @Override
   public void examLoading() {
      //封装条件
      TrainingRegistration trainingRegistration = new TrainingRegistration();
      trainingRegistration.setCancel(1);
      trainingRegistration.setAuditStatus(1);
      trainingRegistration.setIsExam(3);
      //查询考试申请审核通过，已报名，未考试的人员
      List<TrainingRegistration> trainingRegistrationList = baseMapper.selectTrainingRegistrationList(trainingRegistration);
      if (trainingRegistrationList.size()>0){
         //遍历
         trainingRegistrationList.forEach(trainingRegistration1 -> {
            //修改考试状态,已结束
            trainingRegistration1.setIsExam(2);
            //更新
            this.updateById(trainingRegistration1);
            //查询考试成绩记录
            ExamScore examScore = new ExamScore();
            examScore.setApplyId(trainingRegistration1.getId());
            List<ExamScore> list = examScoreService.list(Condition.getQueryWrapper(examScore));
            if (list.size()>0) {
               list.forEach(examScore1 -> {
                  //查询是否有考试记录
                  ExamAnswerRecord examAnswerRecord = new ExamAnswerRecord();
                  examAnswerRecord.setScoreId(examScore1.getId());
                  List<ExamAnswerRecord> examAnswerRecordList = examAnswerRecordService.list(Condition.getQueryWrapper(examAnswerRecord));
                  if (examAnswerRecordList.size()>0){
                     //计算成绩
                     int sum = examAnswerRecordList.stream().mapToInt(ExamAnswerRecord::getAnswerScore).sum();
                     examScore1.setTheoryGrade(sum);
                     if (sum>=60){
                        //暂未录入实操成绩
                        examScore1.setQualified(2);
                     }else {
                        examScore1.setQualified(1);
                     }
                  }else {
                     //理论成绩设置为0
                     examScore1.setTheoryGrade(0);
                     //不合格
                     examScore1.setQualified(1);
                  }
                  //更新成绩数据
                  examScoreService.updateById(examScore1);

                  //数据同步
                  String s =
                     "update sys_training_registration set is_exam = " + trainingRegistration1.getIsExam() +
                        " " + "where id = " + "'" + trainingRegistration1.getId() + "';" +
                     "update exam_score set theory_grade = " + examScore1.getTheoryGrade() +
                        ",qualified = " + "'" + examScore1.getQualified() + "'" +
                        " " + "where id = " + "'" + examScore1.getId() + "'";
                  FtpUtil.sqlFileUpload(s);
               });
            }else {
               //数据同步
               String s =
                  "update sys_training_registration set is_exam = " + trainingRegistration1.getIsExam() +
                     " " + "where id = " + "'" + trainingRegistration1.getId() + "'";
               FtpUtil.sqlFileUpload(s);
            }
         });
      }
   }
}