From ffa70a1adfcbc62f1d2f34d4e6e0003cd92186dd Mon Sep 17 00:00:00 2001
From: Administrator <admin>
Date: Fri, 10 Jun 2022 11:24:03 +0800
Subject: [PATCH] ftp  上传下载设置连接超时时间

---
 src/main/java/org/springblade/modules/quartz/task/Task.java |   19 +++++++++++--------
 1 files changed, 11 insertions(+), 8 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 aa0287e..e2d9194 100644
--- a/src/main/java/org/springblade/modules/quartz/task/Task.java
+++ b/src/main/java/org/springblade/modules/quartz/task/Task.java
@@ -104,7 +104,8 @@
 				return false;
 			}
 
-			ftp.enterLocalActiveMode();
+			//主动模式
+//			ftp.enterLocalActiveMode();
 
 			// 设置文件类型为二进制,与ASCII有区别
 			ftp.setFileType(FTP.BINARY_FILE_TYPE);
@@ -115,7 +116,7 @@
 			// 检验文件是否存在
 			ftp.changeWorkingDirectory(ftpPath);
 
-			// Use passive mode as default
+			// Use passive mode as default 被动模式
 			ftp.enterLocalPassiveMode();
 
 			FTPFile[] files = ftp.listFiles();
@@ -206,7 +207,7 @@
 				return false;
 			}
 
-			ftp.enterLocalActiveMode();
+//			ftp.enterLocalActiveMode();
 
 			// 设置文件类型为二进制,与ASCII有区别
 			ftp.setFileType(FTP.BINARY_FILE_TYPE);
@@ -309,7 +310,7 @@
 				return false;
 			}
 
-			ftp.enterLocalActiveMode();
+//			ftp.enterLocalActiveMode();
 
 			// 设置文件类型为二进制,与ASCII有区别
 			ftp.setFileType(FTP.BINARY_FILE_TYPE);
@@ -390,7 +391,8 @@
 	 * 用户集合信息处理
 	 * @param result
 	 */
-	private void userListInfoHandler(Result result) {
+	@Async
+	public void userListInfoHandler(Result result) {
 		//获取 result
 		List<Result> data1 = result.getData();
 		System.out.println("批量导入数据 = " + data1);
@@ -505,7 +507,7 @@
 				return false;
 			}
 
-			ftp.enterLocalActiveMode();
+//			ftp.enterLocalActiveMode();
 
 			// 设置文件类型为二进制,与ASCII有区别
 			ftp.setFileType(FTP.BINARY_FILE_TYPE);
@@ -514,7 +516,7 @@
 			ftp.setControlEncoding("GBK");
 
 			// 检验文件是否存在
-			ftp.changeWorkingDirectory(ftpPath);
+//			ftp.changeWorkingDirectory(ftpPath);
 
 			// Use passive mode as default
 			ftp.enterLocalPassiveMode();
@@ -582,7 +584,8 @@
 	 * 报名信息处理
 	 * @param result
 	 */
-	private void applyHandler(String uuid,Result result) {
+	@Async
+	public void applyHandler(String uuid,Result result) {
 		//取出培训学校id
 		//从redis 中获取用户数据
 		String s = redisTemplate.opsForValue().get(uuid).toString();

--
Gitblit v1.9.3