From ff13be9aaa95de8be5341e93e95f8611a43d4403 Mon Sep 17 00:00:00 2001
From: Administrator <admin>
Date: Sat, 22 Jan 2022 11:04:11 +0800
Subject: [PATCH] 新增定时任务每天查询考试中的人员，进行成绩核算和修改状态
---
src/main/java/org/springblade/modules/training/service/impl/TrainingRegistrationServiceImpl.java | 80 ++++++++++++++++++++++++++++++++++++++-
1 files changed, 77 insertions(+), 3 deletions(-)
diff --git a/src/main/java/org/springblade/modules/training/service/impl/TrainingRegistrationServiceImpl.java b/src/main/java/org/springblade/modules/training/service/impl/TrainingRegistrationServiceImpl.java
index 88c7df7..ef535ec 100644
--- a/src/main/java/org/springblade/modules/training/service/impl/TrainingRegistrationServiceImpl.java
+++ b/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) {
@@ -82,7 +87,7 @@
* @return
*/
@Override
- public List<ApplyInfoExcel> getTrainingRegistrationExcelList(TrainingRegistrationVo trainingRegistration) {
+ public List<TrainingRegistrationExcel> getTrainingRegistrationExcelList(TrainingRegistrationVo trainingRegistration) {
return baseMapper.getTrainingRegistrationExcelList(trainingRegistration);
}
@@ -346,13 +351,14 @@
//考试截止时间小于当前时间，说明已过考试时间
if (exanEndTime.before(now)) {
//修改报名状态
- trainingRegistration1.setCancel(2);
+ trainingRegistration1.setCancel(1);
//缺考标记
trainingRegistration1.setIsExam(4);
this.updateById(trainingRegistration1);
//修改保安报名状态
User user = userService.getById(trainingRegistration1.getUserId());
- user.setIsTrain(2);
+ //考试结束
+ user.setIsTrain(3);
userService.updateById(user);
//生成缺考记录
AbsentRecords absentRecords = new AbsentRecords();
@@ -404,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);
+ }
+ });
+ }
+ }
}
--
Gitblit v1.9.3