From 27f24d1fe8a146a3b8256abe742b97ee92a1660c Mon Sep 17 00:00:00 2001
From: Administrator <admin>
Date: Fri, 10 Jun 2022 11:53:38 +0800
Subject: [PATCH] 挂载卷设置
---
src/main/java/org/springblade/modules/quartz/task/Task.java | 40 ++++++++++++++++++++++++++--------------
1 files changed, 26 insertions(+), 14 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..432878e 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,12 +116,11 @@
// 检验文件是否存在
ftp.changeWorkingDirectory(ftpPath);
- // Use passive mode as default
+ // Use passive mode as default 被动模式
ftp.enterLocalPassiveMode();
FTPFile[] files = ftp.listFiles();
if (files.length==0){
- ftp.logout();
return false;
}
else {
@@ -166,13 +166,18 @@
}
}
//关闭流
- ftp.completePendingCommand();
- ftp.logout();
+// ftp.completePendingCommand();
+// ftp.logout();
}
} catch (Exception e) {
System.out.println("ftp连接失败");
e.printStackTrace();
} finally {
+ try {
+ ftp.logout();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
if (ftp.isConnected()) {
try {
ftp.disconnect();
@@ -206,7 +211,7 @@
return false;
}
- ftp.enterLocalActiveMode();
+// ftp.enterLocalActiveMode();
// 设置文件类型为二进制，与ASCII有区别
ftp.setFileType(FTP.BINARY_FILE_TYPE);
@@ -309,7 +314,7 @@
return false;
}
- ftp.enterLocalActiveMode();
+// ftp.enterLocalActiveMode();
// 设置文件类型为二进制，与ASCII有区别
ftp.setFileType(FTP.BINARY_FILE_TYPE);
@@ -326,7 +331,7 @@
FTPFile[] files = ftp.listFiles();
//文件个数大于10个时开始处理
if (files.length==0){
- ftp.logout();
+
return false;
}
else {
@@ -368,13 +373,18 @@
}
}
//关闭流
- ftp.completePendingCommand();
- ftp.logout();
+// ftp.completePendingCommand();
+// ftp.logout();
}
} catch (Exception e) {
System.out.println("ftp连接失败");
e.printStackTrace();
} finally {
+ try {
+ ftp.logout();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
if (ftp.isConnected()) {
try {
ftp.disconnect();
@@ -390,7 +400,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 +516,7 @@
return false;
}
- ftp.enterLocalActiveMode();
+// ftp.enterLocalActiveMode();
// 设置文件类型为二进制，与ASCII有区别
ftp.setFileType(FTP.BINARY_FILE_TYPE);
@@ -514,7 +525,7 @@
ftp.setControlEncoding("GBK");
// 检验文件是否存在
- ftp.changeWorkingDirectory(ftpPath);
+// ftp.changeWorkingDirectory(ftpPath);
// Use passive mode as default
ftp.enterLocalPassiveMode();
@@ -582,7 +593,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