From 345d17cf82e1bbc1fbfbeec10193c2bed59cd674 Mon Sep 17 00:00:00 2001
From: Administrator <admin>
Date: Mon, 27 Sep 2021 22:21:21 +0800
Subject: [PATCH] 注册登录,车辆,装备,枪支,招聘,培训考试修改

---
 src/main/java/org/springblade/modules/FTP/monitor.java |   15 +++++++++------
 1 files changed, 9 insertions(+), 6 deletions(-)

diff --git a/src/main/java/org/springblade/modules/FTP/monitor.java b/src/main/java/org/springblade/modules/FTP/monitor.java
index 11c6d3e..d4388ef 100644
--- a/src/main/java/org/springblade/modules/FTP/monitor.java
+++ b/src/main/java/org/springblade/modules/FTP/monitor.java
@@ -10,12 +10,13 @@
 import java.io.IOException;
 import java.io.InputStream;
 
-import static org.springblade.common.constant.FtpConstant.*;
+import static org.springblade.common.config.FtpConfig.*;
+
 
 @Component
 public class monitor {
 
-//	@Scheduled(cron = "*/30 * * * * ?")
+	@Scheduled(cron = "*/30 * * * * ?")
 	public static boolean isFTPFileExist() {
 
 		FTPClient ftp = new FTPClient();
@@ -23,8 +24,9 @@
 		try {
 
 			// 连接ftp服务器
+//			System.out.println("ftpHost = " + ftpHost);
 
-			ftp.connect(ftpHost_dev, ftpPort);
+			ftp.connect(ftpHost, ftpPort);
 
 			// 登陆
 
@@ -63,6 +65,7 @@
 			//ftp.changeWorkingDirectory(new String(dir.getBytes("GBK"), FTP.DEFAULT_CONTROL_ENCODING));
 
 			// 检验文件是否存在
+			ftp.changeWorkingDirectory(ftpPath);
 			FTPFile[] files = ftp.listFiles();
 			if (files.length==0){
 				return false;
@@ -74,7 +77,7 @@
 					String substring1 = fileName.substring(0, 1);
 					if (substring1.equals("n")){
 						//把文件下载到本地
-						FtpUtil.downloadFtpFile(ftpHost_dev, ftpUserName, ftpPassword, ftpPort, ftpPath, localPath, fileName);
+						FtpUtil.downloadFtpFile(ftpHost, ftpUserName, ftpPassword, ftpPort, ftpPath, localPath, fileName);
 						//
 						String s = OutJson.TestJson(fileName);
 						//sql语句
@@ -100,7 +103,7 @@
 						//删除本地文件
 						//MysqlCenlint.deletes(fileName);
 						MysqlCenlint.deletess(fileName);
-						FtpUtil.deleteFile(ftpHost_dev, ftpPort, ftpUserName, ftpPassword, "anbao/", fileName);
+						FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserName, ftpPassword, ftpPath, fileName);
 						is.close();
 						ftp.completePendingCommand();
 					}
@@ -150,7 +153,7 @@
 
 
 		} catch (Exception e) {
-
+			System.out.println("ftp连接失败");
 			e.printStackTrace();
 
 		} finally {

--
Gitblit v1.9.3