FTP异步处理

tangzy

2022-02-24 d4b00c05321d9373a33bfb26618735e2a5868a81

 src/main/java/org/springblade/modules/exam/controller/ExamScoreController.java

@@ -31,6 +31,7 @@
import org.springblade.modules.system.entity.User;
import org.springblade.modules.system.service.IRoleService;
import org.springblade.modules.system.service.IUserService;
import org.springblade.modules.system.service.MyAsyncService;
import org.springblade.modules.system.vo.UserVO;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
@@ -59,6 +60,7 @@
   private final ExamPaperService examPaperService;

   private final SecurityPaperService securityPaperService;
   private final MyAsyncService myAsyncService;

   /**
    * 自定义分页
@@ -90,13 +92,16 @@
   @ApiOperation(value = "新增", notes = "传入examScore")
   public R save(@RequestBody ExamScore examScore) {
      boolean save = examScoreService.save(examScore);
      if (save) {
      //内网同步
      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) " +
         "values(" + "'" + sid + "'" +
         "," + "'" + format + "'" + ")";
      FtpUtil.sqlFileUpload(s);
         //FtpUtil.sqlFileUpload(s);
         myAsyncService.FTP(s);
      }
      //返回
      return R.status(save);
   }
@@ -115,6 +120,7 @@

   /**
    * 点击了开始考试后超过60分钟后再考试的，计算之前的考试成绩
    *
    * @param examScore 考试成绩信息对象
    */
   @GetMapping("/getExamScore")
@@ -143,12 +149,14 @@
   public R updateAbsent(@RequestBody ExamScore examScore) {
      examScore.setQualified(3);
      boolean status = examScoreService.updateByIdAndQualifiee(examScore);

      if (status) {
      //内网数据推送
      String s1 =
         "update exam_score set qualified = " + "'" + examScore.getQualified() + "'" +
            " " + "where id = " + "'" + examScore.getId() + "'";
      FtpUtil.sqlFileUpload(s1);
         //FtpUtil.sqlFileUpload(s1);
         myAsyncService.FTP(s1);
      }
      return R.status(status);
   }

@@ -205,30 +213,17 @@
               //修改为持证保安
               user1.setHold("1");
               //更新保安数据
               userService.updateById(user1);

               boolean b = userService.updateById(user1);
               if (b) {
               //数据同步
               String s1 =
                  "update blade_user set hold = " + "'" + user1.getHold() + "'" +
                     ",securitynumber = " + "'" + user1.getSecuritynumber() + "'" +
                     ",user_type = " + "'" + user1.getUserType() + "'" +
                     " " + "where id = " + "'" + user1.getId() + "'";

//               String s1 =
//                  "insert into sys_security_paper(id,number,create_time,people_name,id_card_no,user_id,apply_id,exam_id) " +
//                     "values(" + "'" + securityPaper.getId() + "'"
//                     + "," + "'" + securityPaper.getNumber() +"'"
//                     + "," + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(securityPaper.getCreateTime()) +"'"
//                     + "," + "'" + securityPaper.getPeopleName() + "'"
//                     + "," + "'" + securityPaper.getIdCardNo() + "'"
//                     + "," + "'" + securityPaper.getUserId() + "'"
//                     + "," + "'" + securityPaper.getApplyId() + "'"
//                     + "," +"'" + securityPaper.getExamId() + "'" + ");" +
//                  "update blade_user set hold = " + "'" + user1.getHold() + "'" +
//                     ",securitynumber = " + "'" + user1.getSecuritynumber() + "'" +
//                     ",user_type = " + "'" + user1.getUserType() + "'" +
//                     " " + "where id = " + "'" + user1.getId() + "'";
               FtpUtil.sqlFileUpload(s1);
                  //FtpUtil.sqlFileUpload(s1);
                  myAsyncService.FTP(s1);
               }
            }
         } else {
            //不合格
@@ -257,7 +252,8 @@
            ",all_grade = " + "'" + examScore.getAllGrade() + "'" +
            ",qualified = " + "'" + examScore.getQualified() + "'" +
            " " + "where id = " + "'" + examScore.getId() + "'";
      FtpUtil.sqlFileUpload(s1);
      //FtpUtil.sqlFileUpload(s1);
      myAsyncService.FTP(s1);

      //本地修改
      return R.status(examScoreService.updateById(examScore));
@@ -284,7 +280,8 @@
      list.forEach(id -> {
         //内网同步
         String s1 = "delete from exam_score where id = " + "'" + id + "'";
         FtpUtil.sqlFileUpload(s1);
         //FtpUtil.sqlFileUpload(s1);
         myAsyncService.FTP(s1);
      });
      return R.status(examScoreService.removeByIds(Func.toLongList(ids)));
   }
@@ -413,6 +410,7 @@
      cjhz.put("sccj",sccj);
      return R.data(cjhz);
   }

   /**
    * 自定义分页
    *
@@ -427,6 +425,7 @@

   /**
    * 考试成绩及状态修改
    *
    * @param updateParamVo
    */
   @GetMapping("/update-exam-score")
@@ -437,6 +436,7 @@

   /**
    * 考试重置（重考）
    *
    * @param updateParamVo
    */
   @PostMapping("/refreshTrainExamInfo")
@@ -459,6 +459,7 @@

   /**
    * 考试成绩恢复状态重置（重考）
    *
    * @param
    */
   @GetMapping("/refreshTrainExamScore")
@@ -468,6 +469,7 @@

   /**
    * 考试情况统计，按月统计各个培训学校考试合格人数和不合格人数
    *
    * @param
    */
   @GetMapping("/getExamStatisInfo")
@@ -477,13 +479,13 @@

   /**
    * 获取当前时间
    *
    * @param
    */
   @GetMapping("/getNowDate")
   public R getNowDate() {
      return R.data(System.currentTimeMillis());
   }



}