1.ftp

tangzy

2021-08-22 30436febfa0201f2e3f03eae09dae379fa7f8d70

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

@@ -79,45 +79,47 @@
         if (files.length==0){
            return false;
         }
         for (FTPFile file : files){
            String fileName = file.getName();
            String substring1 = fileName.substring(0, 1);
            if (substring1.equals("w")) {
               //把文件下载到本地
               FtpUtil.downloadFtpFile(ftpHost, ftpUserName, ftpPassword, 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 {
            for (FTPFile file : files){
               String fileName = file.getName();
               String substring1 = fileName.substring(0, 1);
               if (substring1.equals("w")) {
                  //把文件下载到本地
                  FtpUtil.downloadFtpFile(ftpHost, ftpUserName, ftpPassword, 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);
                     }
                  }
                  //修改
                  else if (substring.equals("up")) {
                     MysqlCenlint.update(sqls);
                  }
                  //删除
                  else {
                     MysqlCenlint.delete(sqls);
                  }
                  //删除本地文件
                  MysqlCenlint.deletes(fileName);
                  MysqlCenlint.deletess(fileName);
                  FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
                  //is.close();
                  ftp.completePendingCommand();
               }
               //删除本地文件
               MysqlCenlint.deletes(fileName);
               MysqlCenlint.deletess(fileName);
               FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
               //is.close();
               ftp.completePendingCommand();
               return true;
            }
            return true;
         }


         //InputStream is = ftp.retrieveFileStream(new String(file.getBytes("GBK"), FTP.DEFAULT_CONTROL_ENCODING));

//         if (is == null || ftp.getReplyCode() == FTPReply.FILE_UNAVAILABLE) {