新增定时任务重新计算当天成绩

Administrator

2022-06-11 bd024f2081dd68ddd2289b3f8fcbacfae1a6d104

 src/main/java/org/springblade/modules/quartz/task/Task.java

@@ -9,6 +9,10 @@
import org.apache.commons.net.ftp.FTPReply;
import org.springblade.common.utils.DesensitizedUtil;
import org.springblade.modules.FTP.*;
import org.springblade.modules.exam.entity.ExamAnswerRecord;
import org.springblade.modules.exam.entity.ExamScore;
import org.springblade.modules.exam.service.ExamAnswerRecordService;
import org.springblade.modules.exam.service.ExamScoreService;
import org.springblade.modules.log.entity.HandlerLog;
import org.springblade.modules.log.service.HandlerLogService;
import org.springblade.modules.system.entity.User;
@@ -56,6 +60,13 @@

   @Autowired
   private MyAsyncService myAsyncService;


   @Autowired
   private ExamAnswerRecordService examAnswerRecordService;

   @Autowired
   private ExamScoreService examScoreService;

   public void testTask(){
        System.out.println("测试定时任务执行-----------------");
@@ -866,5 +877,46 @@
      }
   }

   /**
    * 考试成绩同步
    * @return
    */
   public void examScoreSync() {
      System.out.println("考试成绩同步"+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
      //查询当天的考试成绩
      List<ExamScore> examScoreList = examScoreService.getExamScoreList();
      if (examScoreList.size()>0) {
         //遍历计算成绩
         for (ExamScore examScore : examScoreList) {
            ExamAnswerRecord record = new ExamAnswerRecord();
            record.setScoreId(examScore.getId());
            List<ExamAnswerRecord> list = examAnswerRecordService.list(new QueryWrapper<>(record));
            if (list.size()>0){
               int num = 0;
               for (ExamAnswerRecord examAnswerRecord : list) {
                  num = num + examAnswerRecord.getAnswerScore();
                  examScore.setExamEndTime(examAnswerRecord.getAnswerTime());
               }
               examScore.setTheoryGrade(num);
               examScore.setAllGrade(Math.round(num/2));
               //设置状态
               if (num >= 60) {
                  examScore.setQualified(2);
               } else {
                  examScore.setQualified(1);
               }
               String s1 =
                  "update exam_score set exam_id = " + examScore.getExamId() +
                     ",theory_grade = " + "'" + examScore.getTheoryGrade() + "'" +
                     ",all_grade = " + "'" + examScore.getAllGrade() + "'" +
                     ",exam_end_time = " + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:dd").format(examScore.getExamEndTime()) + "'" +
                     ",qualified = " + "'" + examScore.getQualified() + "'" +
                     " " + "where id = " + "'" + examScore.getId() + "'";
               myAsyncService.FTP(s1);
            }
         }
      }
   }


}