ftp 文件读取修改

Administrator

2022-06-08 2ec204948e957a03149dba08ed78ef4561aa9758

 src/main/java/org/springblade/modules/quartz/task/Task.java

@@ -113,20 +113,17 @@
         else {
            for (FTPFile file : files) {
               String fileName = file.getName();
               InputStream is = ftp.retrieveFileStream(new String(fileName.getBytes("GBK"), FTP.DEFAULT_CONTROL_ENCODING));
               if (null == is) {
                  ftp.logout();
                  return false;
               } else {
                  String substring1 = fileName.substring(0, 2);
                  if (substring1.equals("nq")) {
               System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())+"：读取到文件 = " + fileName);
               if (fileName.contains("nq")) {
//                  InputStream is = ftp.retrieveFileStream(new String(fileName.getBytes("GBK"), FTP.DEFAULT_CONTROL_ENCODING));
                     //把文件下载到本地
                     FtpUtil.downloadFtpFile(ftpHost, ftpUserNameIn, ftpPasswordIn, ftpPort, ftpPath, localPath, fileName);
                     //
                     String s = OutJson.TestJson(fileName);
                     //sql语句
                     String sql = OutJson.stringReplace(s);
                     String[] split = sql.split(";");//以逗号分割
                  //以逗号分割
                  String[] split = sql.split(";");
                     for (String sqls : split) {
                        //判断是否是新增，删除，修改
                        String substring = sqls.substring(0, 2);
@@ -149,13 +146,11 @@
                     //删除 ftp 服务器文件
//                     ftp.dele(fileName);
                     FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName);
                  }
                  System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())+"：成功删除ftp文件 = " + fileName);
                  //关闭流
                  is.close();
                  ftp.completePendingCommand();
                  ftp.logout();
               }
               return true;
            }
         }
      } catch (Exception e) {