From c5f3670dfaad3dc2fa3ba62751edcfc3296c963a Mon Sep 17 00:00:00 2001
From: 钟日健 <5689795+arsn@user.noreply.gitee.com>
Date: Mon, 30 May 2022 15:29:21 +0800
Subject: [PATCH] 新增保安员定时审查未审查的保安员任务

---
 src/main/java/org/springblade/modules/FTP/Monitor.java |   12 ++++++++++--
 1 files changed, 10 insertions(+), 2 deletions(-)

diff --git a/src/main/java/org/springblade/modules/FTP/Monitor.java b/src/main/java/org/springblade/modules/FTP/Monitor.java
index 7105194..3fa8d6e 100644
--- a/src/main/java/org/springblade/modules/FTP/Monitor.java
+++ b/src/main/java/org/springblade/modules/FTP/Monitor.java
@@ -104,6 +104,10 @@
 							//返回
 							return new Result(203,null,result.getMsg(),null);
 						}
+						if (result.getCode()==205){
+							//返回
+							return new Result(202,null,"新增失败,找不到该用户",null);
+						}
 					}
 				}
 				System.out.println("未读取到对应的文件");
@@ -286,7 +290,7 @@
 	 * 读取内外推送的文件,每30秒读取一次
 	 * @return
 	 */
-	@Scheduled(cron = "*/30 * * * * ?")
+//	@Scheduled(cron = "*/30 * * * * ?")
 	public static boolean isFTPFileExist() {
 		FTPClient ftp = new FTPClient();
 		try {
@@ -390,6 +394,10 @@
 		FTPClient ftp = new FTPClient();
 		boolean flag = false;
 		try {
+			//设置超时时间
+			ftp.setDataTimeout(60000);
+			//连接超时为60秒
+			ftp.setConnectTimeout(60000);
 			//连接
 			ftp.connect(ftpHost, ftpPort);
 			// 登陆
@@ -448,7 +456,7 @@
 			System.out.println("ftp连接失败");
 			e.printStackTrace();
 		} finally {
-			if (ftp != null) {
+			if (ftp.isConnected()) {
 				try {
 					ftp.disconnect();
 				} catch (IOException e) {

--
Gitblit v1.9.3