1.正式考试，模拟考试考试申请接口修改 2.用户头像批量上传（压缩zip 包上传） 3.通知公告接口修改

Administrator

2021-09-02 2b5ca6cea92ff6a67582c3331a0704480e63b9b4

 src/main/java/org/springblade/modules/apply/controller/ApplyController.java

@@ -1,5 +1,6 @@
package org.springblade.modules.apply.controller;

import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.metadata.IPage;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
@@ -16,6 +17,8 @@
import org.springblade.core.tool.api.R;
import org.springblade.core.tool.utils.DateUtil;
import org.springblade.core.tool.utils.Func;
import org.springblade.modules.FTP.FtpUtil;
import org.springblade.modules.FTP.OutJson;
import org.springblade.modules.apply.entity.Apply;
import org.springblade.modules.apply.excel.ApplyExcel;
import org.springblade.modules.apply.excel.ApplyImporter;
@@ -24,16 +27,23 @@
import org.springblade.modules.apply.vo.ApplyPaPerVO;
import org.springblade.modules.apply.vo.ApplyVO;
import org.springblade.modules.exam.entity.ExamPaper;
import org.springblade.modules.exam.entity.ExamScore;
import org.springblade.modules.exam.service.ExamPaperService;
import org.springblade.modules.exam.service.ExamScoreService;
import org.springblade.modules.system.entity.User;
import org.springblade.modules.system.service.IUserService;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;

import javax.servlet.http.HttpServletResponse;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.text.DecimalFormat;
import java.text.SimpleDateFormat;
import java.util.*;

import static org.springblade.common.constant.FtpConstant.*;

/**
 * @author zhongrj
@@ -50,6 +60,8 @@
   private final ExamPaperService examPaperService;

   private final IUserService userService;

   private final ExamScoreService examScoreService;

   /**
    * 自定义分页
@@ -77,7 +89,7 @@
    */
   @PostMapping("/save")
   @ApiOperation(value = "新增", notes = "传入apply")
   public R save(@RequestBody Apply apply) {
   public R save(@RequestBody Apply apply){
      //查询人员是否已报名
      User user = userService.getById(apply.getUserId());
      if (null==user.getIsApply()){
@@ -93,12 +105,16 @@
         user1.setId(apply.getUserId());
         user1.setIsApply(1);
         userService.updateById(user1);

         //内网数据同步
         saveApply(apply,user1);

         return R.data(200,"报名成功");
      }else {
         if (1==user.getIsApply()){
            return R.data(201,"已报名，不能重复报名");
         }
         if (2==user.getIsApply() || -1==user.getIsApply()){
         if (1!=user.getIsApply()){
            //默认通过
            apply.setApplyStatus(2);
            //默认为未考试状态
@@ -110,10 +126,27 @@
            user1.setId(apply.getUserId());
            user1.setIsApply(1);
            userService.updateById(user1);

            //内网数据同步
            saveApply(apply,user1);

            return R.data(200,"报名成功");
         }
      }
      return R.data(202,"报名失败");
   }

   /**
    * 报名
    */
   private void saveApply(Apply apply,User user1){
      String formatStr = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
      Long id = apply.getId();
      String s = "insert into sys_apply(id,user_id,apply_time,apply_status,is_exam) " +
         "values(" + "'" + id + "'" + "," + "'" + apply.getUserId() + "'" + "," + "'" + formatStr +
         "'" + "," + "'" + apply.getApplyStatus() + "'" + "," +"'" + apply.getIsExam() + "'" + ");" +
         "update blade_user set is_apply = " + user1.getIsApply() + " " +"where id = " + "'" + user1.getId() + "'";
      FtpUtil.sqlFileUpload(s);
   }


@@ -142,7 +175,18 @@
   @PostMapping("import-apply")
   @ApiOperation(value = "导入报名考试数据", notes = "传入excel")
   public R importUser(MultipartFile file, Integer isCovered) {
      ApplyImporter applyImporter = new ApplyImporter(applyService, false);
      ApplyImporter applyImporter = new ApplyImporter(applyService, false,null);
      ExcelUtil.save(file, applyImporter, ApplyExcel.class);
      return R.success("操作成功");
   }

   /**
    * 导入报名考试数据(已生成考试)
    */
   @PostMapping("import-applys")
   @ApiOperation(value = "导入报名考试数据", notes = "传入excel")
   public R importUser(MultipartFile file, Integer isCovered,Long examId) {
      ApplyImporter applyImporter = new ApplyImporter(applyService, false,examId);
      ExcelUtil.save(file, applyImporter, ApplyExcel.class);
      return R.success("操作成功");
   }
@@ -325,7 +369,6 @@
    */
   @PostMapping("/remove")
   public R remove(@ApiParam(value = "主键集合") @RequestParam String ids) {
      //arg.sendPostRemoveByIds(arg.url+"/apply/remove",ids);
      return R.status(applyService.removeByIds(Func.toLongList(ids)));
   }

@@ -385,25 +428,43 @@
         //修改保安报名状态
         user.setIsApply(2);
         userService.updateById(user);

         //取消报名同步
         cancelApplySync(apply,user);

         if (status){
            return R.data(200,"取消报名成功");
         }

      }else {
         if (user.getIsApply()==2) {
            return R.data(201,"尚未报名");
         }
         if(user.getIsApply()==1){
            apply.setApplyStatus(4);
            boolean status = applyService.updateById(apply);
            //修改保安报名状态
            user.setIsApply(2);
            userService.updateById(user);

            //取消报名同步
            cancelApplySync(apply,user);

            if (status){
               return R.data(200,"取消报名成功");
            }
         }else {
            return R.data(201,"尚未报名");
         }
      }
      return R.data(202,"取消报名失败");
   }

   /**
    * 取消报名同步
    */
   private void cancelApplySync(Apply apply,User user){
      String s =
         "update sys_apply set apply_status = " + apply.getApplyStatus() + " " +"where id = " + "'" + apply.getId() + "';" +
            "update blade_user set is_apply = " + user.getIsApply() + " " +"where id = " + "'" + user.getId() + "'";
      FtpUtil.sqlFileUpload(s);
   }


@@ -423,11 +484,15 @@
         //修改保安报名状态
         user.setIsApply(2);
         userService.updateById(user);

         //取消报名同步
         cancelApplySync(apply1,user);

         if (status){
            return R.data(200,"取消报名成功");
         }
      }else {
         if (user.getIsApply()==2) {
         if (user.getIsApply()!=1) {
            return R.data(201,"尚未报名");
         }
         if(user.getIsApply()==1){
@@ -436,6 +501,10 @@
            //修改保安报名状态
            user.setIsApply(2);
            userService.updateById(user);

            //取消报名同步
            cancelApplySync(apply1,user);

            if (status){
               return R.data(200,"取消报名成功");
            }
@@ -467,8 +536,11 @@
               //修改保安报名状态
               user.setIsApply(1);
               userService.updateById(user);

               //内网数据同步
               saveApply(apply1,user);
            } else {
               if (user.getIsApply() == 2 || -1==user.getIsApply()) {
               if (user.getIsApply() != 1) {
                  Apply apply1 = new Apply();
                  apply1.setApplyStatus(2);
                  //默认为未考试状态
@@ -479,13 +551,15 @@
                  //修改保安报名状态
                  user.setIsApply(1);
                  userService.updateById(user);

                  //内网数据同步
                  saveApply(apply1,user);
               }
            }
         });
      }else {
         //查询所有未报名的人员
         List<User> users = userService.getNotApplyIdList(deptId);
         System.out.println("users = " + users.size());
         if (users.size()>0){
            users.forEach(user ->{
               //未报名的新增，已报名的不做处理
@@ -500,8 +574,11 @@
                  //修改保安报名状态
                  user.setIsApply(1);
                  userService.updateById(user);

                  //内网数据同步
                  saveApply(apply1,user);
               } else {
                  if (user.getIsApply() == 2 || -1==user.getIsApply()) {
                  if (user.getIsApply() != 1) {
                     Apply apply1 = new Apply();
                     apply1.setApplyStatus(2);
                     //默认为未考试状态
@@ -512,6 +589,9 @@
                     //修改保安报名状态
                     user.setIsApply(1);
                     userService.updateById(user);

                     //内网数据同步
                     saveApply(apply1,user);
                  }
               }
            });
@@ -523,13 +603,14 @@


   /**
    * 生成试卷,报名
    * 生成考试,报名
    * @param ids 报名ids
    */
   @PostMapping("/batchExam")
   public R batchExam(@RequestParam String ids,
                  String examTime,
                  @RequestParam Date startTime,
                  @RequestParam Integer number,
                  Date endTime){
      if (!ids.equals("")){
         List<String> list = Arrays.asList(ids.split(","));
@@ -548,6 +629,14 @@
            examPaper.setExamName(examName);
            //生成考试
            examPaperService.save(examPaper);

            Long sid = examPaper.getId();
            String format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(examPaper.getStartTime());
            String s = "insert into ksxt_exam(id,exam_name,exam_type,start_time) " +
               "values(" + "'" + sid + "'" + "," + "'" + examPaper.getExamName() + "'" + "," + "'" + examPaper.getExamType() +
               "'" + ","  +"'" + format + "'" + ")";
            FtpUtil.sqlFileUpload(s);

            //修改报名信息
            list.forEach(id ->{
               Apply apply = new Apply();
@@ -555,12 +644,17 @@
               apply.setExamId(examPaper.getId());
               apply.setCandidateNo(getCandidateNo(apply));
               applyService.updateById(apply);

               String s1 =
                  "update sys_apply set exam_id = " + apply.getExamId() + ",candidate_no = " + "'" + apply.getCandidateNo() + "'" +
                     " " +"where id = " + "'" + apply.getId() + "'";
               FtpUtil.sqlFileUpload(s1);
            });
         }

      }else {
         //查询已报名未关联试卷的人员
         List<Long> applyIds = applyService.getApplyIds();
         List<Long> applyIds = applyService.getApplyIds(number);
         if (applyIds.size()>0){
            //生成考试
            ExamPaper examPaper = new ExamPaper();
@@ -577,6 +671,14 @@
            examPaper.setExamName(examName);
            //生成考试
            examPaperService.save(examPaper);

            Long sid = examPaper.getId();
            String format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(examPaper.getStartTime());
            String s = "insert into ksxt_exam(id,exam_name,exam_type,start_time) " +
               "values(" + "'" + sid + "'" + "," + "'" + examPaper.getExamName() + "'" + "," + "'" + examPaper.getExamType() +
               "'" + ","  +"'" + format + "'" + ")";
            FtpUtil.sqlFileUpload(s);

            //修改报名信息
            applyIds.forEach(id ->{
               Apply apply = new Apply();
@@ -584,6 +686,11 @@
               apply.setExamId(examPaper.getId());
               apply.setCandidateNo(getCandidateNo(apply));
               applyService.updateById(apply);

               String s1 =
                  "update sys_apply set exam_id = " + apply.getExamId() + ",candidate_no = " + "'" + apply.getCandidateNo() + "'" +
                     " " +"where id = " + "'" + apply.getId() + "'";
               FtpUtil.sqlFileUpload(s1);
            });
         }
      }
@@ -619,8 +726,54 @@
    * @return
    */
   @PostMapping("/updateApplyStatus")
   public void updateApplyStatus(@RequestBody ApplyVO apply){
   public ExamScore updateApplyStatus(@RequestBody ApplyVO apply){
      applyService.updateApplyStatus(apply);
      //新增考试成绩，没有成绩数据，待提交答题后更新数据
      ExamScore examScore = new ExamScore();
      examScore.setExamId(apply.getExamId().toString());
      examScore.setUserId(apply.getUserId().toString());
      examScore.setApplyId(apply.getId());
      examScore.setExamTime(new Date());
      //新增考试成绩
      examScoreService.save(examScore);
      //内网同步
      Long sid = examScore.getId();
      String format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(examScore.getExamTime());
//      String s = "insert into exam_score(id,exam_time,user_id,exam_id,apply_id) " +
//         "values(" + "'" + sid + "'" + "," + "'" +
//         format + "'" + "," + "'" +
//         examScore.getUserId() +"'" + ","  +"'" +
//         examScore.getExamId() +"'" + ","  +"'" +
//         examScore.getApplyId() + "'" + ")";
//      FtpUtil.sqlFileUpload(s);
      return examScore;
   }



   /**
    * test
    * @return
    */
   @GetMapping("/test")
   public Object test(){
      String s1 = "insert into exam_score(id,exam_id,apply_id) values(223,88,315)";
      String s2 = "111222333";
      String s3 = "select * from ksxt_exam";
      FtpUtil.sqlFileUpload(s1);
      FtpUtil.sqlFileUpload(s2);
//      FtpUtil.sqlFileUpload(s3);
      String json1 = JSON.toJSONString(s3);
      String response1 = String.valueOf((new Date()).getTime());
      OutJson.createJsonFile(json1, localPath, "f"+response1);
      FileInputStream in1 = null;
      try {
         in1 = new FileInputStream(new File(localPath + "f"+response1+".json"));
      } catch (FileNotFoundException e) {
         e.printStackTrace();
      }
      FtpUtil.uploadFile(ftpHost_dev, ftpPort, ftpUserName, ftpPassword, ftpPath, "/",  "f"+response1+".json", in1);
      return "成功";
   }