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 | 73 ++++++++++++++++++++++++++++++++++++
src/main/java/org/springblade/modules/exam/mapper/ExamPaperMapper.xml | 8 ++--
src/main/java/org/springblade/modules/training/service/TrainingRegistrationService.java | 5 ++
src/main/java/org/springblade/modules/crontab/Crontab.java | 11 +++--
4 files changed, 89 insertions(+), 8 deletions(-)
diff --git a/src/main/java/org/springblade/modules/crontab/Crontab.java b/src/main/java/org/springblade/modules/crontab/Crontab.java
index 87ae9ff..77e53db 100644
--- a/src/main/java/org/springblade/modules/crontab/Crontab.java
+++ b/src/main/java/org/springblade/modules/crontab/Crontab.java
@@ -34,11 +34,14 @@
}
-// @Scheduled(cron = "*/30 * * * * ?")
- @GetMapping("/aaa")
+ /**
+ * 定时任务，处理考试中的人员
+ */
+ @Scheduled(cron = "0 0 22 * * ?")
+ @GetMapping("/examLoading")
public void aa(){
System.out.println("定时任务2：执行时间："+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
- //自动处理之前报了名，申请了考试又没有去考试的，做缺考标记，并将报名状态修改为已取消报名
-// trainingRegistrationService.examApplyStatus();
+ //自动处理之前报了名，考试忘记提交或者中断考试的
+ trainingRegistrationService.examLoading();
}
}
diff --git a/src/main/java/org/springblade/modules/exam/mapper/ExamPaperMapper.xml b/src/main/java/org/springblade/modules/exam/mapper/ExamPaperMapper.xml
index dc3951e..ca809af 100644
--- a/src/main/java/org/springblade/modules/exam/mapper/ExamPaperMapper.xml
+++ b/src/main/java/org/springblade/modules/exam/mapper/ExamPaperMapper.xml
@@ -492,10 +492,10 @@
bu.real_name securityName,
bd.dept_name companyName,
es.theory_grade theoryGrade,es.learn_grade learnGrade,es.all_grade allGrade,
- case when str.is_exam=2 then "发布成绩"
- when str.is_exam=3 then "考试中"
- when str.is_exam=4 then "缺考"
- when str.is_exam=5 then "纸质考试"
+ case when es.qualified=0 then "合格"
+ when es.qualified=1 then "不合格"
+ when es.qualified=2 then "暂未录入实操成绩"
+ when es.qualified=3 then "缺考"
else "" end as sortName
from
exam_score es
diff --git a/src/main/java/org/springblade/modules/training/service/TrainingRegistrationService.java b/src/main/java/org/springblade/modules/training/service/TrainingRegistrationService.java
index 9d4fc3f..90ed7a8 100644
--- a/src/main/java/org/springblade/modules/training/service/TrainingRegistrationService.java
+++ b/src/main/java/org/springblade/modules/training/service/TrainingRegistrationService.java
@@ -67,4 +67,9 @@
* 自动处理之前报了名，申请了考试又没有去考试的，做缺考标记，并将报名状态修改为已取消报名
*/
void examApplyStatus();
+
+ /**
+ * 考试中的
+ */
+ void examLoading();
}
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 a21e5f4..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) {
@@ -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);
+ }
+ });
+ }
+ }
}
--
Gitblit v1.9.3