From dfa12137b587df5186b30113fbaa4d48940b2588 Mon Sep 17 00:00:00 2001
From: Administrator <admin>
Date: Mon, 13 Jun 2022 15:03:17 +0800
Subject: [PATCH] ftp 异常文件删除
---
src/main/java/org/springblade/modules/quartz/task/Task.java | 6 ++++--
1 files changed, 4 insertions(+), 2 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 8a84ee1..ae3bdd8 100644
--- a/src/main/java/org/springblade/modules/quartz/task/Task.java
+++ b/src/main/java/org/springblade/modules/quartz/task/Task.java
@@ -99,6 +99,7 @@
*/
public boolean readFile() {
FTPClient ftp = new FTPClient();
+ String fileName = null;
try {
//设置传输超时时间为60秒
ftp.setDataTimeout(10000);
@@ -136,7 +137,7 @@
}
else {
for (int i = files.length-1; i >=0 ; i--) {
- String fileName = files[i].getName();
+ fileName = files[i].getName();
String substring1 = fileName.substring(0, 2);
System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())+"：读取到文件 = " + fileName);
if (substring1.contains("nq")) {
@@ -181,7 +182,8 @@
// ftp.logout();
}
} catch (Exception e) {
- System.out.println("ftp连接失败");
+ //发生异常删除文件，有可能是空文件
+ FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName);
e.printStackTrace();
} finally {
try {
--
Gitblit v1.9.3