From 2ec204948e957a03149dba08ed78ef4561aa9758 Mon Sep 17 00:00:00 2001
From: Administrator <admin>
Date: Wed, 08 Jun 2022 15:48:18 +0800
Subject: [PATCH] ftp 文件读取修改
---
src/main/java/org/springblade/modules/FTP/Monitor.java | 48 +++++++++++++++++++++++-------------------------
1 files changed, 23 insertions(+), 25 deletions(-)
diff --git a/src/main/java/org/springblade/modules/FTP/Monitor.java b/src/main/java/org/springblade/modules/FTP/Monitor.java
index 3ebc751..53d9c4e 100644
--- a/src/main/java/org/springblade/modules/FTP/Monitor.java
+++ b/src/main/java/org/springblade/modules/FTP/Monitor.java
@@ -70,9 +70,9 @@
} 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("ni")){
+// InputStream is = ftp.retrieveFileStream(new String(fileName.getBytes("GBK"), FTP.DEFAULT_CONTROL_ENCODING));
+// String substring1 = fileName.substring(0, 2);
+ if (fileName.contains("ni")){
System.out.println("-------接收到内网回传的文件： " + fileName);
//把文件下载到本地
FtpUtil.downloadFtpFile(ftpHost, ftpUserNameIn, ftpPasswordIn, ftpPort, ftpPath, localPath, fileName);
@@ -84,7 +84,7 @@
MysqlCenlint.deletess(fileName);
// ftp.dele(fileName);
FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName);
- is.close();
+// is.close();
ftp.completePendingCommand();
if (result.getCode()==200) {
//返回
@@ -169,9 +169,9 @@
} 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("nl")){
+ if (fileName.contains("nl")){
+ //转流
+// InputStream is = ftp.retrieveFileStream(new String(fileName.getBytes("GBK"), FTP.DEFAULT_CONTROL_ENCODING));
//把文件下载到本地
FtpUtil.downloadFtpFile(ftpHost, ftpUserNameIn, ftpPasswordIn, ftpPort, ftpPath, localPath, fileName);
// 解析数据
@@ -188,7 +188,7 @@
//返回
return result;
}
- is.close();
+// is.close();
ftp.completePendingCommand();
}
}
@@ -252,9 +252,9 @@
} 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")){
+// InputStream is = ftp.retrieveFileStream(new String(fileName.getBytes("GBK"), FTP.DEFAULT_CONTROL_ENCODING));
+// String substring1 = fileName.substring(0, 2);
+ if (fileName.contains("nt")){
//把文件下载到本地
FtpUtil.downloadFtpFile(ftpHost, ftpUserNameIn, ftpPasswordIn, ftpPort, ftpPath, localPath, fileName);
// 解析数据
@@ -271,7 +271,7 @@
//返回
return result;
}
- is.close();
+// is.close();
ftp.completePendingCommand();
}
}
@@ -335,12 +335,12 @@
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) {
- return false;
- } else {
- String substring1 = fileName.substring(0, 2);
- if (substring1.equals("nq")) {
+// InputStream is = ftp.retrieveFileStream(new String(fileName.getBytes("GBK"), FTP.DEFAULT_CONTROL_ENCODING));
+// if (null == is) {
+// return false;
+// } else {
+// String substring1 = fileName.substring(0, 2);
+ if (fileName.contains("nq")) {
//把文件下载到本地
FtpUtil.downloadFtpFile(ftpHost, ftpUserNameIn, ftpPasswordIn, ftpPort, ftpPath, localPath, fileName);
//
@@ -372,10 +372,8 @@
FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName);
}
//关闭流
- is.close();
+// is.close();
ftp.completePendingCommand();
- }
- return true;
}
}
} catch (Exception e) {
@@ -437,9 +435,9 @@
} 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("ns")){
+// InputStream is = ftp.retrieveFileStream(new String(fileName.getBytes("GBK"), FTP.DEFAULT_CONTROL_ENCODING));
+// String substring1 = fileName.substring(0, 2);
+ if (fileName.contains("ns")){
//把文件下载到本地
FtpUtil.downloadFtpFile(ftpHost, ftpUserNameIn, ftpPasswordIn, ftpPort, ftpPath, localPath, fileName);
// 解析数据
@@ -456,7 +454,7 @@
//返回
return result;
}
- is.close();
+// is.close();
ftp.completePendingCommand();
}
}
--
Gitblit v1.9.3