From df054296327ebca617a9c19bb01139b9c40bf232 Mon Sep 17 00:00:00 2001
From: Administrator <admin>
Date: Tue, 07 Jun 2022 11:25:44 +0800
Subject: [PATCH] 培训报名,保安员头像导入新增修改

---
 src/main/java/org/springblade/modules/FTP/Monitor.java |   23 ++++++++++++++---------
 1 files changed, 14 insertions(+), 9 deletions(-)

diff --git a/src/main/java/org/springblade/modules/FTP/Monitor.java b/src/main/java/org/springblade/modules/FTP/Monitor.java
index 3fa8d6e..16fd859 100644
--- a/src/main/java/org/springblade/modules/FTP/Monitor.java
+++ b/src/main/java/org/springblade/modules/FTP/Monitor.java
@@ -73,9 +73,9 @@
 					String fileName = file.getName();
 //					System.out.println("fileName = " + fileName);
 					InputStream is = ftp.retrieveFileStream(new String(fileName.getBytes("GBK"), FTP.DEFAULT_CONTROL_ENCODING));
-					String substring1 = fileName.substring(0, 1);
+					String substring1 = fileName.substring(0, 2);
 //					System.out.println("substring1 = " + substring1);
-					if (substring1.equals("n")){
+					if (substring1.equals("ni")){
 						System.out.println("-------接收到内网回传的文件: " + fileName);
 					    //把文件下载到本地
 						FtpUtil.downloadFtpFile(ftpHost, ftpUserNameIn, ftpPasswordIn, ftpPort, ftpPath, localPath, fileName);
@@ -85,7 +85,8 @@
 						Result result = DataHandler.handler(s,uuid);
 						//删除本地文件
 						MysqlCenlint.deletess(fileName);
-						FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName);
+						ftp.dele(fileName);
+//						FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName);
 						is.close();
 						ftp.completePendingCommand();
 						if (result.getCode()==200) {
@@ -182,7 +183,8 @@
 							//删除本地文件
 							MysqlCenlint.deletess(fileName);
 							//删除 ftp 文件
-							FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName);
+//							FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName);
+							ftp.dele(fileName);
 							//返回
 							return result;
 						}
@@ -261,7 +263,8 @@
 							//删除本地文件
 							MysqlCenlint.deletess(fileName);
 							//删除 ftp 文件
-							FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName);
+							ftp.dele(fileName);
+//							FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName);
 							//返回
 							return result;
 						}
@@ -331,8 +334,8 @@
 					if (null == is) {
 						return false;
 					} else {
-						String substring1 = fileName.substring(0, 4);
-						if (substring1.equals("nsql")) {
+						String substring1 = fileName.substring(0, 2);
+						if (substring1.equals("nq")) {
 							//把文件下载到本地
 							FtpUtil.downloadFtpFile(ftpHost, ftpUserNameIn, ftpPasswordIn, ftpPort, ftpPath, localPath, fileName);
 							//
@@ -360,7 +363,8 @@
 							//删除本地服务器文件
 							MysqlCenlint.deletess(fileName);
 							//删除 ftp 服务器文件
-							FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName);
+							ftp.dele(fileName);
+//							FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName);
 						}
 						//关闭流
 						is.close();
@@ -442,7 +446,8 @@
 							//删除本地文件
 							MysqlCenlint.deletess(fileName);
 							//删除 ftp 文件
-							FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName);
+							ftp.dele(fileName);
+//							FtpUtil.deleteFile(ftpHost, ftpPort, ftpUserNameIn, ftpPasswordIn, ftpPath, fileName);
 							//返回
 							return result;
 						}

--
Gitblit v1.9.3