ftp 同步修改调整

Administrator

2022-04-27 dd899673f3ff75ad59ae43afd124ef8ef0fc0180

 src/main/java/org/springblade/modules/system/controller/UserController.java

@@ -59,6 +59,7 @@
import org.springblade.core.tool.utils.*;
import org.springblade.modules.FTP.FtpUtil;
import org.springblade.modules.FTP.Monitor;
import org.springblade.modules.FTP.Result;
import org.springblade.modules.accreditation.entity.AccreditationRecords;
import org.springblade.modules.accreditation.service.AccreditationRecordsService;
import org.springblade.modules.dispatcher.entity.Dispatcher;
@@ -1182,6 +1183,7 @@
      user.setDispatch("1");
      user.setExaminationType("0");
      user.setAccount(user.getCardid());
      user.setStatus(1);

      User user1 = new User();
      user1.setIsDeleted(0);
@@ -1388,7 +1390,8 @@
      user.setRoleId(oneRole.getId().toString());
      user.setDispatch("1");
      user.setExaminationType("0");
      user.setAccount(user.getCardid());
      user.setAccount(user.getRealName());
      user.setStatus(1);

      //密码加密
      if (Func.isNotEmpty(user.getCardid())) {
@@ -1431,8 +1434,8 @@
      myAsyncService.FTPObject(map);

      int count = 0;
      boolean flag = false;
      R result = new R();
      int flag = 1;
      Result result = new Result();
      //调用ftp获取返回数据
      while (true){
         Thread.sleep(1000);
@@ -1440,9 +1443,18 @@
         result = Monitor.isFTPFileExist(uuid);
         //如果返回true,就退处
         if (result.getCode()==200){
            flag = true;
            flag = 1;
            break;
         }else {
         }else if (result.getCode()==201){
            flag = 2;
            break;
         }else if (result.getCode()==202){
            flag = 3;
            break;
         }else if (result.getCode()==203){
            flag = 4;
            break;
         }else{
            //计数
            count++;
            //如果超过10s 没有读取到，则退出
@@ -1451,10 +1463,15 @@
            }
         }
      }
      if (flag) {
      if (flag==1 || flag==2) {
         //返回
         return R.data(200, null, "新增成功!");
      }else {
      }else if (flag==3){
         throw new ServiceException(result.getMsg());
      }else if (flag==4){
//         return R.data(201, null, "保安证编号不匹配,请核实!也可通过提供保安证件信息提交核实申请!");
         return R.data(201, null, "保安证编号不匹配,请核实!");
      }else{
         //返回
         return R.data(400, null, "新增失败!");
      }