From 519d4c1fa4ae04a77d9f4062e8bfd90a0e47333b Mon Sep 17 00:00:00 2001
From: tangzy <tangzy123456>
Date: Sun, 22 Aug 2021 15:05:13 +0800
Subject: [PATCH] 1.ftp

---
 src/main/java/org/springblade/modules/FTP/monitor.java |    4 +++-
 1 files changed, 3 insertions(+), 1 deletions(-)

diff --git a/src/main/java/org/springblade/modules/FTP/monitor.java b/src/main/java/org/springblade/modules/FTP/monitor.java
index 25fb817..db39a43 100644
--- a/src/main/java/org/springblade/modules/FTP/monitor.java
+++ b/src/main/java/org/springblade/modules/FTP/monitor.java
@@ -8,6 +8,7 @@
 import org.springframework.stereotype.Component;
 
 import java.io.IOException;
+import java.io.InputStream;
 
 @Component
 public class monitor {
@@ -82,6 +83,7 @@
 			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, 1);
 					if (substring1.equals("w")) {
 						//把文件下载到本地
@@ -112,7 +114,7 @@
 						MysqlCenlint.deletes(fileName);
 						MysqlCenlint.deletess(fileName);
 						FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
-						//is.close();
+						is.close();
 						ftp.completePendingCommand();
 					}
 				}

--
Gitblit v1.9.3