ftp 修改，新增保安员培训报名校验，新增押运员批量导入校验，批量导入保安员优化

Administrator

2022-04-29 dacafac0449f8df3ef7637a7ed05fa6270964f16

 src/main/java/org/springblade/modules/FTP/Monitor.java

@@ -108,7 +108,7 @@
   }

   /**
    * 读取文件（对象）
    * 读取文件（对象）用户批量操作返回
    * @param uuid 随机数
    * @return
    */
@@ -183,6 +183,81 @@
   }

   /**
    * 读取文件（对象）报名返回
    * @param uuid 随机数
    * @return
    */
   public static Result getFtpDataByUuidListTrain(String uuid) {
      //创建 ftp 对象
      FTPClient ftp = new FTPClient();
      boolean flag = false;
      try {
         //连接
         ftp.connect(ftpHost, ftpPort);
         // 登陆
         ftp.login(ftpUserName, ftpPassword);
         // 检验登陆操作的返回码是否正确
         if (!FTPReply.isPositiveCompletion(ftp.getReplyCode())) {
            ftp.disconnect();
            return new Result(400,null,"ftp 连接失败",null);
         }

         ftp.enterLocalActiveMode();

         // 设置文件类型为二进制，与ASCII有区别
         ftp.setFileType(FTP.BINARY_FILE_TYPE);

         // 设置编码格式
         ftp.setControlEncoding("GBK");

         // 检验文件是否存在
         ftp.changeWorkingDirectory(ftpPath);
         FTPFile[] files = ftp.listFiles();
         if (files.length==0){
            return new Result(400,null,"未读取到文件",null);
         } else {
            for (FTPFile file : files){
               String fileName = file.getName();
               InputStream is = ftp.retrieveFileStream(new String(fileName.getBytes("GBK"), FTP.DEFAULT_CONTROL_ENCODING));
               String substring1 = fileName.substring(0, 2);
               if (substring1.equals("nt")){
                  //把文件下载到本地
                  FtpUtil.downloadFtpFile(ftpHost, ftpUserName, ftpPassword, ftpPort, ftpPath, localPath, fileName);
                  // 解析数据
                  String s = OutJson.TestJson(fileName);
                  //数据处理
                  Result result = DataHandler.handlerList(s,uuid);
                  //匹配上了删除文件
                  if (result.getCode()==200) {
                     //删除本地文件
                     MysqlCenlint.deletess(fileName);
                     //删除 ftp 文件
                     FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, ftpPath, fileName);
                     //返回
                     return result;
                  }
                  is.close();
                  ftp.completePendingCommand();
               }
            }
            return new Result(400,null,"未读取到对应的文件",null);
         }
      } catch (Exception e) {
         System.out.println("ftp连接失败");
         e.printStackTrace();
      } finally {
         if (ftp != null) {
            try {
               ftp.disconnect();
            } catch (IOException e) {
               e.printStackTrace();
            }
         }
      }
      return new Result(400,null,"失败",null);
   }

   /**
    * 读取内外推送的文件,每30秒读取一次
    * @return
    */