From 181f68abea0ff8047e3a8b8a436a8e6125d44491 Mon Sep 17 00:00:00 2001
From: 钟日健 <5689795+arsn@user.noreply.gitee.com>
Date: Tue, 24 May 2022 23:01:32 +0800
Subject: [PATCH] 定时任务修改

---
 src/main/java/org/springblade/modules/quartz/task/Task.java |    3 +++
 1 files changed, 3 insertions(+), 0 deletions(-)

diff --git a/src/main/java/org/springblade/modules/quartz/task/Task.java b/src/main/java/org/springblade/modules/quartz/task/Task.java
index 4f11f69..582f4cc 100644
--- a/src/main/java/org/springblade/modules/quartz/task/Task.java
+++ b/src/main/java/org/springblade/modules/quartz/task/Task.java
@@ -95,6 +95,7 @@
 
 			FTPFile[] files = ftp.listFiles();
 			if (files.length==0){
+				ftp.logout();
 				return false;
 			}
 			else {
@@ -102,6 +103,7 @@
 					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, 4);
@@ -138,6 +140,7 @@
 						//关闭流
 						is.close();
 						ftp.completePendingCommand();
+						ftp.logout();
 					}
 					return true;
 				}

--
Gitblit v1.9.3