From a03c324b7ce6d6f2e4a591a3954f34e597f4194c Mon Sep 17 00:00:00 2001
From: 钟日健 <5689795+arsn@user.noreply.gitee.com>
Date: Tue, 26 Apr 2022 20:46:46 +0800
Subject: [PATCH] ftp 开启向外网推送结果数据
---
src/main/java/org/springblade/modules/FTP/monitor.java | 37 ++++++++++++-------------------------
1 files changed, 12 insertions(+), 25 deletions(-)
diff --git a/src/main/java/org/springblade/modules/FTP/monitor.java b/src/main/java/org/springblade/modules/FTP/monitor.java
index 79d8a31..71383f0 100644
--- a/src/main/java/org/springblade/modules/FTP/monitor.java
+++ b/src/main/java/org/springblade/modules/FTP/monitor.java
@@ -20,42 +20,31 @@
//private static String fileName = "nsql.json";
- @Scheduled(cron = "*/30 * * * * ?")
+ @Scheduled(cron = "*/1 * * * * ?")
public static boolean isFTPFileExist() {
FTPClient ftp = new FTPClient();
String fileName = null;
try {
-// System.out.println("ftpHost = " + ftpHost);
- // 连接ftp服务器
-
ftp.connect(ftpHost, ftpPort);
// 登陆
-
ftp.login(ftpUserName, ftpPassword);
-
-// System.out.println("ftp.getReplyCode() = " + ftp.getReplyCode());
// 检验登陆操作的返回码是否正确
if (!FTPReply.isPositiveCompletion(ftp.getReplyCode())) {
-
ftp.disconnect();
-
return false;
-
}
//被动模式，文件上传不成功会有提示
ftp.enterLocalActiveMode();
// 设置文件类型为二进制，与ASCII有区别
-
ftp.setFileType(FTP.BINARY_FILE_TYPE);
// 设置编码格式
-
ftp.setControlEncoding("GBK");
// 提取绝对地址的目录以及文件名
@@ -82,10 +71,9 @@
return false;
} else {
String substring1 = fileName.substring(0, 1);
+ //把文件下载到本地
+ FtpUtil.downloadFtpFile(ftpHost, ftpUserName, ftpPassword, ftpPort, ftpPath, localPath, fileName);
if (substring1.equals("w")) {
- //把文件下载到本地
- FtpUtil.downloadFtpFile(ftpHost, ftpUserName, ftpPassword, ftpPort, ftpPath, localPath, fileName);
- //
String s = OutJson.TestJson(fileName);
//sql语句
String sql = OutJson.stringReplace(s);
@@ -108,20 +96,19 @@
}
}
//删除本地文件
-// MysqlCenlint.deletes(fileName);
MysqlCenlint.deletess(fileName);
FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
- is.close();
- ftp.completePendingCommand();
- }
- else {
- //把文件下载到本地
- FtpUtil.downloadFtpFile(ftpHost, ftpUserName, ftpPassword, ftpPort, ftpPath, minioPath, fileName);
- //MysqlCenlint.deletess(fileName);
+ }else if(substring1.equals("o")){
+ //获取对象字符串
+ String json = OutJson.TestJson(fileName);
+ //数据处理
+ DataHanlder.handler(json);
+ //删除本地文件
+ MysqlCenlint.deletess(fileName);
FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
- is.close();
- ftp.completePendingCommand();
}
+ is.close();
+ ftp.completePendingCommand();
}
}
return true;
--
Gitblit v1.9.3