新增定时任务处理保安员没有插入完的json文件

Administrator

2022-06-09 697391f7977fd6d5b4d52cb49dfdb29a76025505

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

@@ -77,7 +77,6 @@
                  FtpUtil.downloadFtpFile(ftpHost, ftpUserNameIn, ftpPasswordIn, ftpPort, ftpPath, localPath, fileName);
                  // 解析数据
                  String s = OutJson.TestJson(fileName);
                  System.out.println("s = " + s);
                  //数据处理
                  Result result = DataHandler.handler(s,uuid);
                  //匹配上了删除文件
@@ -89,7 +88,7 @@
                     FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName);
//                     ftp.dele(fileName);
                     //返回
                     return result.getData().get(0);
                     return result;
                  }
                  ftp.completePendingCommand();
                  ftp.logout();
@@ -174,7 +173,6 @@
                     //删除 ftp 文件
                     FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName);
//                     ftp.dele(fileName);

                     //返回
                     return result;
                  }
@@ -261,16 +259,16 @@
                     //删除 ftp 文件
//                     ftp.dele(fileName);
                     FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName);
                     ftp.completePendingCommand();
                     ftp.logout();
                     //返回
                     return result;
                  }
                  ftp.completePendingCommand();
                  ftp.logout();
               }
            }
            if (!flag){
               ftp.logout();
            }
//            if (!flag){
//               ftp.logout();
//            }
            return new Result(400,null,"未读取到对应的文件",null);
         }
      } catch (Exception e) {
@@ -286,99 +284,6 @@
         }
      }
      return new Result(400,null,"失败",null);
   }

   /**
    * 读取内外推送的文件,每30秒读取一次
    * @return
    */
//   @Scheduled(cron = "*/30 * * * * ?")
   public static boolean isFTPFileExist() {
      FTPClient ftp = new FTPClient();
      try {
         //设置超时时间
         ftp.setDataTimeout(60000);
         //连接超时为60秒
         ftp.setConnectTimeout(60000);
         //连接
         ftp.connect(ftpHost, ftpPort);
         // 登陆
         ftp.login(ftpUserNameIn, ftpPasswordIn);
         // 检验登陆操作的返回码是否正确
         if (!FTPReply.isPositiveCompletion(ftp.getReplyCode())) {
            ftp.disconnect();
            return false;
         }

         ftp.enterLocalActiveMode();

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

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

         // 检验文件是否存在
         ftp.changeWorkingDirectory(ftpPath);

         // Use passive mode as default
         ftp.enterLocalPassiveMode();

         FTPFile[] files = ftp.listFiles();
         if (files.length==0){
            return false;
         }
         else {
            for (FTPFile file : files) {
               String fileName = file.getName();
               if (fileName.contains("nq")) {
                  //把文件下载到本地
                  FtpUtil.downloadFtpFile(ftpHost, ftpUserNameIn, ftpPasswordIn, ftpPort, ftpPath, localPath, fileName);
                  //
                  String s = OutJson.TestJson(fileName);
                  //sql语句
                  String sql = OutJson.stringReplace(s);
                  String[] split = sql.split(";");//以逗号分割
                  for (String sqls : split) {
                     //判断是否是新增，删除，修改
                     String substring = sqls.substring(0, 2);
                     //新增
                     if (substring.equals("in")) {
                        //运行sql语句
                        MysqlCenlint.inster(sqls);
                     }
                     //修改
                     else if (substring.equals("up")) {
                        MysqlCenlint.update(sqls);
                     }
                     //删除
                     else {
                        MysqlCenlint.delete(sqls);
                     }
                  }
                  //删除本地服务器文件
                  MysqlCenlint.deletess(fileName);
                  //删除 ftp 服务器文件
//                     ftp.dele(fileName);
                  FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName);
               }
               ftp.completePendingCommand();
               ftp.logout();
            }
         }
      } catch (Exception e) {
         System.out.println("ftp连接失败");
         e.printStackTrace();
      } finally {
         if (ftp.isConnected()) {
            try {
               ftp.disconnect();
            } catch (IOException e) {
               e.printStackTrace();
            }
         }
      }
      return false;
   }

   /**
@@ -440,16 +345,17 @@
                     //删除 ftp 文件
//                     ftp.dele(fileName);
                     FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName);
                     ftp.completePendingCommand();
                     ftp.logout();

                     //返回
                     return result;
                  }
                  ftp.completePendingCommand();
                  ftp.logout();
               }
            }
            if (!flag){
               ftp.logout();
            }
//            if (!flag){
//               ftp.logout();
//            }
            return new Result(400,null,"未读取到对应的文件",null);
         }
      } catch (Exception e) {