智慧保安后台管理-外网
钟日健
2022-02-25 afc2b4d2800d91c793523d14fbe2d6fbbd319fc0
src/main/java/org/springblade/modules/training/controller/TrainingRegistrationController.java
@@ -25,11 +25,17 @@
import org.springblade.modules.exam.service.ExamPaperService;
import org.springblade.modules.system.entity.User;
import org.springblade.modules.system.service.IUserService;
import org.springblade.modules.system.service.MyAsyncService;
import org.springblade.modules.system.vo.UserVO;
import org.springblade.modules.training.entity.TrainingRegistration;
import org.springblade.modules.training.excel.TrainingRegistrationExcel;
import org.springblade.modules.training.excel.TrainingRegistrationImporter;
import org.springblade.modules.training.service.TrainingRegistrationService;
import org.springblade.modules.training.vo.TrainingRegistrationVo;
import org.springblade.modules.vip.service.UserVipService;
import org.springblade.modules.vip.service.VipTopicService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
@@ -54,6 +60,12 @@
   private final IUserService userService;
   private final ExamPaperService examPaperService;
   private final UserVipService userVipService;
   private final VipTopicService vipTopicService;
   private final MyAsyncService myAsyncService;
   /**
    * 自定义分页
@@ -157,7 +169,8 @@
         + "," + "'" + trainingRegistration.getIsExam() + "'"
         + "," +"'" + trainingRegistration.getAuditStatus() + "'" + ");" +
         "update blade_user set is_train = " + user1.getIsTrain() + " " +"where id = " + "'" + user1.getId() + "'";
      FtpUtil.sqlFileUpload(sql);
      //FtpUtil.sqlFileUpload(sql);
      myAsyncService.FTP(sql);
   }
@@ -285,7 +298,8 @@
            ",audit_status = " + "'" + trainingRegistration.getAuditStatus() + "'" +
            " " +"where id = " + "'" + trainingRegistration.getId() + "';" +
            "update blade_user set is_train = " + user.getIsTrain() + " " +"where id = " + "'" + user.getId() + "'";
      FtpUtil.sqlFileUpload(s);
      //FtpUtil.sqlFileUpload(s);
      myAsyncService.FTP(s);
   }
   /**
@@ -302,9 +316,9 @@
      //遍历
      list.forEach(userId ->{
         User user = userService.getById(userId);
         UserVO userVO = userService.getUserAgeById(Long.parseLong(userId));
         //判断年龄
         Integer age = AgeUtil.idCardToAge(user.getCardid());
         if (age>=18 && age<=60) {
         if (userVO.getAge()>=18 && userVO.getAge()<=60) {
            //未报名的新增,已报名的不做处理
            if (null == user.getIsTrain()) {
               TrainingRegistration trainingRegistration1 = new TrainingRegistration();
@@ -618,7 +632,8 @@
               "," + "'" + examPaper.getCreator() +"'" +
               "," + "'" + creatorTimeFormat +"'" +
               ","  +"'" + examPaper.getAuditStatus() + "'" + ")";
            FtpUtil.sqlFileUpload(s);
            //FtpUtil.sqlFileUpload(s);
            myAsyncService.FTP(s);
            //修改报名信息
@@ -633,7 +648,8 @@
                     "update sys_training_registration set train_exam_id = " + "'" + trainingRegistration.getTrainExamId() + "'"
                        + ",audit_status = " + "'" + trainingRegistration.getAuditStatus() + "'"
                        + " " + "where id = " + "'" + trainingRegistration.getId() + "'";
                  FtpUtil.sqlFileUpload(s1);
                  //FtpUtil.sqlFileUpload(s1);
                  myAsyncService.FTP(s1);
               }
            });
         }
@@ -689,7 +705,8 @@
            "," + "'" + examPaper.getCreator() +"'" +
            "," + "'" + creatorTimeFormat +"'" +
            ","  +"'" + examPaper.getAuditStatus() + "'" + ")";
         FtpUtil.sqlFileUpload(s);
         //FtpUtil.sqlFileUpload(s);
         myAsyncService.FTP(s);
         //修改报名信息
         list.forEach(id ->{
@@ -706,11 +723,35 @@
                     "update sys_training_registration set train_exam_id = " + "'" + trainingRegistration.getTrainExamId() + "'"
                        + ",audit_status = " + "'" + trainingRegistration.getAuditStatus() + "'"
                        + " " + "where id = " + "'" + trainingRegistration.getId() + "'";
                  FtpUtil.sqlFileUpload(s1);
                  //FtpUtil.sqlFileUpload(s1);
                  myAsyncService.FTP(s1);
               }
            }
         });
      }
      return null;
   }
   /**
    * 是否为会员标记
    * @param trainingRegistration
    * @return
    */
   @PostMapping("/vipSign")
   @Transactional(rollbackFor = Exception.class)
   public R vipSign(@RequestBody TrainingRegistration trainingRegistration){
      //新增会员记录
      userVipService.insertUserVipInfo(trainingRegistration);
      //新增会员题库记录
      vipTopicService.insertVipTopicInfo(trainingRegistration);
      //内网报名信息同步
      String s1 =
         "update sys_training_registration set vip_status = " + "'" + trainingRegistration.getVipStatus() + "'"
            + " " + "where id = " + "'" + trainingRegistration.getId() + "'";
      //FtpUtil.sqlFileUpload(s1);
      myAsyncService.FTP(s1);
      //更新并返回数据
      return R.data(trainingRegistrationService.updateById(trainingRegistration));
   }
}