ftp sql 同步封装

Administrator

2021-12-15 8d43111bd0e598bc0b2014cbfa69a32e74959dff

 src/main/java/org/springblade/modules/exam/service/impl/ExamScoreServiceImpl.java

@@ -192,7 +192,7 @@
            //数据同步
            String s =
               "update sys_training_registration set is_exam = " + trainingRegistration1.getIsExam() + " " +"where id = " + "'" + trainingRegistration1.getId() + "';" +
                  "update blade_user set is_apply = " + user.getIsApply() + " " +"where id = " + "'" + user.getId() + "'";
                  "update blade_user set is_train = " + user.getIsTrain() + " " +"where id = " + "'" + user.getId() + "'";
            FtpUtil.sqlFileUpload(s);
         }

@@ -273,45 +273,44 @@
                     if (null!=examScore) {
                        //查询当前保安信息
                        UserVO user = userService.getUserAgeById(Long.parseLong(examScore.getUserId()));
                        //设置实操成绩
                        examScore.setLearnGrade(examScoreExcel.getLearnGrade());
                        if (examScore.getTheoryGrade() >= 60 && examScore.getLearnGrade() >= 60) {
                           //合格
                           examScore.setQualified(0);
                           //修改制证状态为未制证
                           user.setUserType(7);
                           //正式考试通过生成保安证编号
//                     if (examPaper.getExamType()==1) {
                           //如果已有保安证编号，不更新用户信息
                           if (null==user.getSecuritynumber() || user.getSecuritynumber().equals("")) {
                              //去生成保安证编号
                              String pre = SecurityPaperUtil.getSecurityPaper();
                              //查询当前年份已有的保安证编号
                              int count = userService.getSecurityPaperCount(pre);
                              String result = null;
                              if (count == 0) {
                                 result = pre + "00001";
                              } else {
                                 //格式化
                                 DecimalFormat decimalFormat = new DecimalFormat("00000");
                                 count++;
                                 result = pre + (decimalFormat.format(count));
                              }
                              user.setSecuritynumber(result);
                              //发证日期
//                        user.setPaperTime(new Date());
                              //修改为持证保安
                              user.setHold("1");
                              user.setUpdateTime(new Date());
                              //更新保安数据
                              userService.updateById(user);
                        if (null!=examScore.getTheoryGrade()){
                           if (examScore.getTheoryGrade() >= 60 && examScore.getLearnGrade() >= 60) {
                              //合格
                              examScore.setQualified(0);
                              //修改制证状态为未制证
                              user.setUserType(7);
                              //如果已有保安证编号，不更新用户信息
                              if (null == user.getSecuritynumber() || user.getSecuritynumber().equals("")) {
                                 //去生成保安证编号
                                 String pre = SecurityPaperUtil.getSecurityPaper();
                                 //查询当前年份已有的保安证编号
                                 int count = userService.getSecurityPaperCount(pre);
                                 String result = null;
                                 if (count == 0) {
                                    result = pre + "00001";
                                 } else {
                                    //格式化
                                    DecimalFormat decimalFormat = new DecimalFormat("00000");
                                    count++;
                                    result = pre + (decimalFormat.format(count));
                                 }
                                 user.setSecuritynumber(result);
                                 //修改为持证保安
                                 user.setHold("1");
                                 user.setUpdateTime(new Date());
                                 //更新保安数据
                                 userService.updateById(user);

                              String s1 =
                                 "update blade_user set hold = " + "'" + user.getHold() + "'" +
                                    ",securitynumber = " + "'" + user.getSecuritynumber() + "'" +
                                    ",update_time = " + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(user.getUpdateTime()) + "'" +
                                    ",user_type = " + "'" + user.getUserType() + "'" +
                                    " " + "where id = " + "'" + user.getId() + "'";
                              FtpUtil.sqlFileUpload(s1);
                                 String s1 =
                                    "update blade_user set hold = " + "'" + user.getHold() + "'" +
                                       ",securitynumber = " + "'" + user.getSecuritynumber() + "'" +
                                       ",update_time = " + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(user.getUpdateTime()) + "'" +
                                       ",user_type = " + "'" + user.getUserType() + "'" +
                                       " " + "where id = " + "'" + user.getId() + "'";
                                 FtpUtil.sqlFileUpload(s1);
                              }
                           }
                        } else {
                           //不合格
@@ -716,4 +715,85 @@
      });
      return false;
   }

   /**
    * 点击了开始考试后超过60分钟后再考试的，计算之前的考试成绩
    * @param examScore
    * @return
    */
   @Override
   public boolean getExamScore(ExamScoreVO examScore) {
      //查询考试成绩
      ExamScore score = this.getById(examScore.getId());
      //查询考试记录
      ExamAnswerRecord examAnswerRecord = new ExamAnswerRecord();
      examAnswerRecord.setScoreId(examScore.getId());
      List<ExamAnswerRecord> list = examAnswerRecordService.list(Condition.getQueryWrapper(examAnswerRecord));
      //设置默认理论成绩为0
      int count = 0;
      //计算成绩
      if (list.size()>0){
         //成绩相加
         count = list.stream().mapToInt(ExamAnswerRecord::getAnswerScore).sum();

      }else {
         //没有考试记录，本次考试理论成绩为 0
         count = 0;
      }
      int age = 0;
      UserVO user = new UserVO();
      //查询培训报名数据
      TrainingRegistration trainingRegistration = new TrainingRegistration();
      trainingRegistration.setCandidateNo(score.getCandidateNo());
      trainingRegistration.setCancel(1);
      TrainingRegistration trainingRegistration1 = trainingRegistrationService.getOne(Condition.getQueryWrapper(trainingRegistration));
      //查询用户年龄，根据年龄计算总分
      user = userService.getUserAgeById(Long.parseLong(trainingRegistration1.getUserId()));
      //修改用户的培训状态,理论考试结束
      user.setIsTrain(3);
      age = user.getAge();
      userService.updateById(user);
      //修改为已考试
      trainingRegistration1.setIsExam(2);
      trainingRegistrationService.updateById(trainingRegistration1);

      //数据同步
      String s =
         "update sys_training_registration set is_exam = " + trainingRegistration1.getIsExam() + " " +"where id = " + "'" + trainingRegistration1.getId() + "';" +
            "update blade_user set is_train = " + user.getIsTrain() + " " +"where id = " + "'" + user.getId() + "'";
      FtpUtil.sqlFileUpload(s);

      //设置理论得分
      score.setTheoryGrade(count);
      //计算总成绩,此时没有实操成绩，总成绩为实操成绩和理论成绩和的一半
      if (age<=50) {
         score.setAllGrade(Math.round(count / 2));
      }
      if (age>50) {
         score.setAllGrade(Integer.parseInt(String.valueOf(Math.round(count*0.5))));
      }
      //设置状态
      if (count>=60){
         score.setQualified(2);
      }else {
         score.setQualified(1);
      }
      //修改成绩数据
      int i = baseMapper.updateById(score);

      String s1 =
         "update exam_score set exam_id = " + score.getExamId() +
            ",theory_grade = " + "'" + score.getTheoryGrade() + "'" +
            ",all_grade = " + "'" + score.getAllGrade() + "'" +
            ",exam_end_time = " + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:dd").format(new Date()) + "'" +
            ",qualified = " + "'" + score.getQualified() + "'" +
            " " +"where id = " + "'" + score.getId() + "'";
      FtpUtil.sqlFileUpload(s1);

      if (i>0){
         //返回结果
         return true;
      }
      return false;
   }
}