FTP异步处理

tangzy

2022-02-24 d4b00c05321d9373a33bfb26618735e2a5868a81

 src/main/java/org/springblade/modules/equipage/controller/EquipageController.java

@@ -18,6 +18,7 @@
import org.springblade.modules.equipage.vo.EquipageVo;
import org.springblade.modules.exam.excel.ExamScoreExcel;
import org.springblade.modules.exam.excel.ExamScoreImporter;
import org.springblade.modules.system.service.MyAsyncService;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;

@@ -38,9 +39,11 @@
public class EquipageController {

   private final EquipageService equipageService;
   private final MyAsyncService myAsyncService;

   /**
    * 自定义分页
    *
    * @param query page,size
    * @param equipage 装备信息对象
    */
@@ -52,6 +55,7 @@

   /**
    * 新增
    *
    * @param equipage 装备信息对象
    */
   @PostMapping("/save")
@@ -62,6 +66,7 @@

   /**
    * 修改
    *
    * @param equipage 装备信息对象
    */
   @PostMapping("/update")
@@ -71,6 +76,7 @@

   /**
    * 新增或修改
    *
    * @param equipage 装备信息对象
    */
   @PostMapping("/submit")
@@ -79,7 +85,7 @@
      if (equipage.getId()==null){
         //新增
         status = equipageService.save(equipage);

         if (status) {
         //数据推送
         String s1 =
            "insert into sys_equipage(id,name,number,specifications,mode,dept_id,brand,date_for_production,jurisdiction,person_in_charge,num) " +
@@ -94,10 +100,13 @@
               "'" + equipage.getJurisdiction() + "'" + "," +
               "'" + equipage.getPersonInCharge() + "'" + "," +
               "'" +equipage.getNum() + "'" + ")";
         FtpUtil.sqlFileUpload(s1);
            //FtpUtil.sqlFileUpload(s1);
            myAsyncService.FTP(s1);
         }
      }else {
         //修改
         status = equipageService.updateById(equipage);
         if (status) {
         //内网同步
         String s1 =
            "update sys_equipage set name = " + "'" + equipage.getName() + "'" +
@@ -111,13 +120,16 @@
               ",num = " + "'" + equipage.getNum() + "'" +
               ",person_in_charge = " + "'" + equipage.getPersonInCharge() + "'" +
               " " +"where id = " + "'" + equipage.getId() + "'";
         FtpUtil.sqlFileUpload(s1);
            //FtpUtil.sqlFileUpload(s1);
            myAsyncService.FTP(s1);
         }
      }
      return R.status(status);
   }

   /**
    * 删除
    *
    * @param ids 装备信息ids 数组
    */
   @PostMapping("/remove")
@@ -127,13 +139,15 @@
      list.forEach(id ->{
         //内网同步
         String s1 = "delete from sys_equipage where id = " + "'" + id + "'";
         FtpUtil.sqlFileUpload(s1);
         //FtpUtil.sqlFileUpload(s1);
         myAsyncService.FTP(s1);
      });
      return R.status(equipageService.removeByIds(Func.toLongList(ids)));
   }

   /**
    * 详情
    *
    * @param equipage 装备信息对象
    */
   @GetMapping("/detail")
@@ -145,6 +159,7 @@

   /**
    * 导入装备数据
    *
    * @param isCovered 1 覆盖  0不覆盖
    * @return
    */