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

Administrator

2022-01-22 ff13be9aaa95de8be5341e93e95f8611a43d4403

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

 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();
    }
}

 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

 src/main/java/org/springblade/modules/training/service/TrainingRegistrationService.java

@@ -67,4 +67,9 @@
     * 自动处理之前报了名，申请了考试又没有去考试的，做缺考标记，并将报名状态修改为已取消报名
     */
    void examApplyStatus();

    /**
     * 考试中的
     */
    void examLoading();
}

 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);
                }
            });
        }
    }
}