Administrator
2021-08-31 08363052cecb30230a2c8b3eba791ca8d1be00a5
src/main/java/org/springblade/modules/apply/controller/ApplyController.java
@@ -19,7 +19,6 @@
import org.springblade.core.tool.utils.Func;
import org.springblade.modules.FTP.FtpUtil;
import org.springblade.modules.FTP.OutJson;
import org.springblade.modules.FTP.monitor;
import org.springblade.modules.apply.entity.Apply;
import org.springblade.modules.apply.excel.ApplyExcel;
import org.springblade.modules.apply.excel.ApplyImporter;
@@ -147,16 +146,7 @@
         "values(" + "'" + id + "'" + "," + "'" + apply.getUserId() + "'" + "," + "'" + formatStr +
         "'" + "," + "'" + apply.getApplyStatus() + "'" + "," +"'" + apply.getIsExam() + "'" + ");" +
         "update blade_user set is_apply = " + user1.getIsApply() + " " +"where id = " + "'" + user1.getId() + "'";
      String json = JSON.toJSONString(s);
      String response = String.valueOf((new Date()).getTime());
      OutJson.createJsonFile(json, "d:/", "w"+response);
      FileInputStream in = null;
      try {
         in = new FileInputStream(new File("D:\\" + "w"+response+".json"));
      } catch (FileNotFoundException e) {
         e.printStackTrace();
      }
      FtpUtil.uploadFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", "/",  "w"+response+".json", in);
      FtpUtil.sqlFileUpload(s);
   }
@@ -185,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("操作成功");
   }
@@ -463,16 +464,7 @@
      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() + "'";
      String json = JSON.toJSONString(s);
      String response = String.valueOf((new Date()).getTime());
      OutJson.createJsonFile(json, "d:/", "w"+response);
      FileInputStream in = null;
      try {
         in = new FileInputStream(new File("D:\\" + "w"+response+".json"));
      } catch (FileNotFoundException e) {
         e.printStackTrace();
      }
      FtpUtil.uploadFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", "/",  "w"+response+".json", in);
      FtpUtil.sqlFileUpload(s);
   }
@@ -642,16 +634,7 @@
            String s = "insert into ksxt_exam(id,exam_name,exam_type,start_time) " +
               "values(" + "'" + sid + "'" + "," + "'" + examPaper.getExamName() + "'" + "," + "'" + examPaper.getExamType() +
               "'" + ","  +"'" + format + "'" + ")";
            String json = JSON.toJSONString(s);
            String response = String.valueOf((new Date()).getTime());
            OutJson.createJsonFile(json, "d:/", "w"+response);
            FileInputStream in = null;
            try {
               in = new FileInputStream(new File("D:\\" + "w"+response+".json"));
            } catch (FileNotFoundException e) {
               e.printStackTrace();
            }
            FtpUtil.uploadFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", "/",  "w"+response+".json", in);
            FtpUtil.sqlFileUpload(s);
            //修改报名信息
            list.forEach(id ->{
@@ -662,18 +645,9 @@
               applyService.updateById(apply);
               String s1 =
                  "update sys_apply set exam_id = " + apply.getExamId() + "candidate_no = " + "'" + apply.getCandidateNo() + "'" +
                  "update sys_apply set exam_id = " + apply.getExamId() + ",candidate_no = " + "'" + apply.getCandidateNo() + "'" +
                     " " +"where id = " + "'" + apply.getId() + "'";
               String json1 = JSON.toJSONString(s1);
               String response1 = String.valueOf((new Date()).getTime());
               OutJson.createJsonFile(json1, "d:/", "w"+response1);
               FileInputStream in1 = null;
               try {
                  in1 = new FileInputStream(new File("D:\\" + "w"+response1+".json"));
               } catch (FileNotFoundException e) {
                  e.printStackTrace();
               }
               FtpUtil.uploadFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", "/",  "w"+response1+".json", in1);
               FtpUtil.sqlFileUpload(s1);
            });
         }
@@ -702,17 +676,7 @@
            String s = "insert into ksxt_exam(id,exam_name,exam_type,start_time) " +
               "values(" + "'" + sid + "'" + "," + "'" + examPaper.getExamName() + "'" + "," + "'" + examPaper.getExamType() +
               "'" + ","  +"'" + format + "'" + ")";
            String json = JSON.toJSONString(s);
            String response = String.valueOf((new Date()).getTime());
            OutJson.createJsonFile(json, "d:/", "w"+response);
            FileInputStream in = null;
            try {
               in = new FileInputStream(new File("D:\\" + "w"+response+".json"));
            } catch (FileNotFoundException e) {
               e.printStackTrace();
            }
            FtpUtil.uploadFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", "/",  "w"+response+".json", in);
            FtpUtil.sqlFileUpload(s);
            //修改报名信息
            applyIds.forEach(id ->{
@@ -725,16 +689,7 @@
               String s1 =
                  "update sys_apply set exam_id = " + apply.getExamId() + ",candidate_no = " + "'" + apply.getCandidateNo() + "'" +
                     " " +"where id = " + "'" + apply.getId() + "'";
               String json1 = JSON.toJSONString(s1);
               String response1 = String.valueOf((new Date()).getTime());
               OutJson.createJsonFile(json1, "d:/", "w"+response1);
               FileInputStream in1 = null;
               try {
                  in1 = new FileInputStream(new File("D:\\" + "w"+response1+".json"));
               } catch (FileNotFoundException e) {
                  e.printStackTrace();
               }
               FtpUtil.uploadFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", "/",  "w"+response1+".json", in1);
               FtpUtil.sqlFileUpload(s1);
            });
         }
      }
@@ -783,23 +738,41 @@
      //内网同步
      Long sid = examScore.getId();
      String format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(examScore.getExamTime());
      String s = "insert into ksxt_exam(id,exam_time,user_id,exam_id,apply_id) " +
         "values(" + "'" + sid + "'" + "," + "'" +
         format + "'" + "," + "'" +
         examScore.getUserId() +"'" + ","  +"'" +
         examScore.getExamId() +"'" + ","  +"'" +
         examScore.getApplyId() + "'" + ")";
      String json = JSON.toJSONString(s);
      String response = String.valueOf((new Date()).getTime());
      OutJson.createJsonFile(json, "d:/", "w"+response);
      FileInputStream in = null;
//      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 {
         in = new FileInputStream(new File("D:\\" + "w"+response+".json"));
         in1 = new FileInputStream(new File(localPath + "f"+response1+".json"));
      } catch (FileNotFoundException e) {
         e.printStackTrace();
      }
      FtpUtil.uploadFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", "/",  "w"+response+".json", in);
      return examScore;
      FtpUtil.uploadFile(ftpHost_dev, ftpPort, ftpUserName, ftpPassword, ftpPath, "/",  "f"+response1+".json", in1);
      return "成功";
   }