From 37fd5447c3b7bfdd3d1b31f8d68c6750471f178c Mon Sep 17 00:00:00 2001
From: Lius <Lius2225@163.com>
Date: 星期三, 27 八月 2025 16:11:00 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'
---
lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/iot/util/FtpUtil.java | 918 +++++++++++++++++++++++++++++++++++----------------------
1 files changed, 566 insertions(+), 352 deletions(-)
diff --git a/lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/iot/util/FtpUtil.java b/lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/iot/util/FtpUtil.java
index fd00b2d..853d116 100644
--- a/lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/iot/util/FtpUtil.java
+++ b/lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/iot/util/FtpUtil.java
@@ -1,41 +1,39 @@
-
package org.jeecg.modules.iot.util;
-
-/**
- * @Description: Ftp閰嶇疆
- * @Author: cuikaidong
- * @Date: 2024-12-10
- * @Version: V1.0
- */
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.commons.net.ftp.FTP;
import org.apache.commons.net.ftp.FTPClient;
+import org.apache.commons.net.ftp.FTPFile;
import org.apache.commons.net.ftp.FTPReply;
import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
import java.io.*;
import java.net.SocketException;
+import java.nio.charset.StandardCharsets;
+import java.util.Objects;
+@Component
public class FtpUtil {
- private final static Log logger = LogFactory.getLog(FtpUtil.class);
- /**
- * 鏈湴瀛楃缂栫爜
- */
- private static String LOCAL_CHARSET = "GBK";
+ private static final Log logger = LogFactory.getLog(FtpUtil.class);
- // FTP鍗忚閲岄潰锛岃瀹氭枃浠跺悕缂栫爜涓篿so-8859-1
- private static String SERVER_CHARSET = "ISO-8859-1";
- //ftp鏈嶅姟鍣↖P鍦板潃 锛屾柊鐏偓10.210.199.2,璧疯惤鏋�10.0.221.200
- private static String ftpHost = "10.0.221.200";
- //ftp鏈嶅姟鍣ㄧ鍙�
- private static int ftpPort = 21;
- //ftp鏈嶅姟鍣ㄧ敤鎴峰悕
- private static String ftpUserName = "admin";
- //ftp鏈嶅姟鍣ㄥ瘑鐮�
- private static String ftpPassword = "lx@2024";
+ // 渚濊禆娉ㄥ叆閰嶇疆锛屽缓璁�氳繃 Nacos 鎴栭厤缃腑蹇冪鐞�
+ @Value("${ftp.LOCAL_CHARSET:UTF-8}")
+ private String LOCAL_CHARSET;
+ @Value("${ftp.SERVER_CHARSET:ISO-8859-1}")
+ private String SERVER_CHARSET;
+ @Value("${ftp.ftpHost}")
+ private String ftpHost;
+ @Value("${ftp.ftpPort:21}")
+ private int ftpPort;
+ @Value("${ftp.ftpUserName}")
+ private String ftpUserName;
+ @Value("${ftp.ftpPassword}")
+ private String ftpPassword;
+ @Value("${operatingSystem}")
+ private String operatingSystem;
/**
@@ -43,7 +41,7 @@
*
* @return true锛氳繛鎺ユ垚鍔燂紱false锛氳繛鎺ュけ璐�
*/
- public static boolean testFtpConnection() {
+ public boolean testFtpConnection() {
FTPClient ftpClient = new FTPClient();
try {
// 杩炴帴FTP鏈嶅姟鍣�
@@ -58,377 +56,593 @@
if (isConnected) {
logger.info("FTP杩炴帴楠岃瘉鎴愬姛锛�");
} else {
- logger.error("FTP杩炴帴澶辫触锛氱敤鎴峰悕/瀵嗙爜閿欒鎴栨湇鍔″櫒涓嶅彲杈�");
+ logger.error("FTP杩炴帴澶辫触锛氱敤鎴峰悕/瀵嗙爜閿欒鎴栨湇鍔″櫒涓嶅彲杈撅紝鍝嶅簲鐮侊細" + replyCode);
}
return isConnected;
} catch (SocketException e) {
- logger.error("FTP鏈嶅姟鍣↖P鍦板潃閿欒鎴栫鍙ｈ鍗犵敤锛�" + e.getMessage());
+ logger.error("FTP鏈嶅姟鍣ㄨ繛鎺ュけ璐ワ紙IP鎴栫鍙ｉ敊璇級锛�" + e.getMessage(), e);
} catch (IOException e) {
- logger.error("FTP杩炴帴寮傚父锛�" + e.getMessage());
+ logger.error("FTP杩炴帴寮傚父锛�" + e.getMessage(), e);
} finally {
// 閲婃斁璧勬簮
- if (ftpClient.isConnected()) {
- try {
- ftpClient.logout();
- ftpClient.disconnect();
- } catch (IOException e) {
- logger.warn("鍏抽棴FTP杩炴帴鏃跺彂鐢熷紓甯革細" + e.getMessage());
- }
- }
+ disconnectQuietly(ftpClient);
}
return false;
}
+ // ====================== 鏍稿績浼樺寲锛氳繛鎺ョ鐞嗛噸鏋� ======================
/**
- * 鑾峰彇FTPClient瀵硅薄
+ * 鑾峰彇 FTPClient 杩炴帴锛堝甫閲嶈瘯銆佹ā寮忛厤缃級
*
- * @return
+ * @return 鍙敤 FTPClient锛屽け璐ヨ繑鍥� null
*/
- public static FTPClient getFTPClient() {
-
- FTPClient ftpClient = null;
- try {
- ftpClient = new FTPClient();
- ftpClient.connect(ftpHost, ftpPort);// 杩炴帴FTP鏈嶅姟鍣�
- ftpClient.login(ftpUserName, ftpPassword);// 鐧婚檰FTP鏈嶅姟鍣�
- if (!FTPReply.isPositiveCompletion(ftpClient.getReplyCode())) {
- logger.info("鏈繛鎺ュ埌FTP锛岀敤鎴峰悕鎴栧瘑鐮侀敊璇��");
- ftpClient.disconnect();
- } else {
- logger.info("FTP杩炴帴鎴愬姛銆�");
- }
- } catch (SocketException e) {
- e.printStackTrace();
- logger.info("FTP鐨処P鍦板潃鍙兘閿欒锛岃姝ｇ‘閰嶇疆銆�");
- } catch (IOException e) {
- e.printStackTrace();
- logger.info("FTP鐨勭鍙ｉ敊璇�,璇锋纭厤缃��");
- }
- return ftpClient;
- }
-
- /**
- * 浠嶧TP鏈嶅姟鍣ㄤ笅杞芥枃浠�
- *
- * @param ftpHost FTP IP鍦板潃
- * @param ftpUserName FTP 鐢ㄦ埛鍚�
- * @param ftpPassword FTP鐢ㄦ埛鍚嶅瘑鐮�
- * @param ftpPort FTP绔彛
- * @param ftpPath FTP鏈嶅姟鍣ㄤ腑鏂囦欢鎵�鍦ㄨ矾寰� 鏍煎紡锛� ftptest/aa
- * @param localPath 涓嬭浇鍒版湰鍦扮殑浣嶇疆 鏍煎紡锛欻:/download
- * @param fileName 鏂囦欢鍚嶇О
- */
- public static void downloadFtpFile(String ftpHost, String ftpUserName, String ftpPassword, int ftpPort,
- String ftpPath, String localPath, String fileName) {
-
- FTPClient ftpClient = null;
-
- try {
- ftpClient = getFTPClient();
- // 璁剧疆涓婁紶鏂囦欢鐨勭被鍨嬩负浜岃繘鍒剁被鍨�
- if (FTPReply.isPositiveCompletion(ftpClient.sendCommand("OPTS UTF8", "ON"))) {// 寮�鍚湇鍔″櫒瀵筓TF-8鐨勬敮鎸侊紝濡傛灉鏈嶅姟鍣ㄦ敮鎸佸氨鐢║TF-8缂栫爜锛屽惁鍒欏氨浣跨敤鏈湴缂栫爜锛圙BK锛�.
- LOCAL_CHARSET = "UTF-8";
- }
- ftpClient.setControlEncoding(LOCAL_CHARSET);
- ftpClient.enterLocalPassiveMode();// 璁剧疆琚姩妯″紡
- ftpClient.setFileType(FTP.BINARY_FILE_TYPE);// 璁剧疆浼犺緭鐨勬ā寮�
- // 涓婁紶鏂囦欢
- //瀵逛腑鏂囨枃浠跺悕杩涜杞爜锛屽惁鍒欎腑鏂囧悕绉扮殑鏂囦欢涓嬭浇澶辫触
- String fileNameTemp = new String(fileName.getBytes(LOCAL_CHARSET), SERVER_CHARSET);
- ftpClient.changeWorkingDirectory(ftpPath);
-
- InputStream retrieveFileStream = ftpClient.retrieveFileStream(fileNameTemp);
-
- // 绗竴绉嶆柟寮忎笅杞芥枃浠�(鎺ㄨ崘)
- /* File localFile = new File(localPath + File.separatorChar + fileName);
- OutputStream os = new FileOutputStream(localFile);
- ftpClient.retrieveFile(fileName, os); os.close();*/
-
-
- // 绗簩绉嶆柟寮忎笅杞斤細灏嗚緭鍏ユ祦杞垚瀛楄妭锛屽啀鐢熸垚鏂囦欢锛岃繖绉嶆柟寮忔柟渚垮皢瀛楄妭鏁扮粍鐩存帴杩斿洖缁欏墠鍙癹sp椤甸潰
- byte[] input2byte = input2byte(retrieveFileStream);
- byte2File(input2byte, localPath, fileName);
-
- if (null != retrieveFileStream) {
- retrieveFileStream.close();
- }
- } catch (FileNotFoundException e) {
- logger.error("娌℃湁鎵惧埌" + ftpPath + "鏂囦欢");
- e.printStackTrace();
- } catch (SocketException e) {
- logger.error("杩炴帴FTP澶辫触.");
- e.printStackTrace();
- } catch (IOException e) {
- e.printStackTrace();
- logger.error("鏂囦欢璇诲彇閿欒銆�");
- e.printStackTrace();
- } finally {
-
- if (ftpClient.isConnected()) {
- try {
- //閫�鍑虹櫥褰�
- ftpClient.logout();
- //鍏抽棴杩炴帴
- ftpClient.disconnect();
- } catch (IOException e) {
- }
- }
- }
- }
-
- /**
- * Description: 鍚慒TP鏈嶅姟鍣ㄤ笂浼犳枃浠�
- *
- * @param basePath FTP鏈嶅姟鍣ㄥ熀纭�鐩綍
- * @param filePath FTP鏈嶅姟鍣ㄦ枃浠跺瓨鏀捐矾寰勩�備緥濡傚垎鏃ユ湡瀛樻斁锛�/2015/01/01銆傛枃浠剁殑璺緞涓篵asePath+filePath
- * @param filename 涓婁紶鍒癋TP鏈嶅姟鍣ㄤ笂鐨勬枃浠跺悕
- * @param input 杈撳叆娴�
- * @return 鎴愬姛杩斿洖true锛屽惁鍒欒繑鍥瀎alse
- */
- public static boolean uploadFile(String basePath, String filePath, String filename, InputStream input) {
- boolean result = false;
- FTPClient ftpClient = null;
- try {
- int reply;
- ftpClient = getFTPClient();
- reply = ftpClient.getReplyCode();
- if (!FTPReply.isPositiveCompletion(reply)) {
- ftpClient.disconnect();
- return result;
- }
- // 鍒囨崲鍒颁笂浼犵洰褰�
- if (!ftpClient.changeWorkingDirectory(basePath + filePath)) {
- // 濡傛灉鐩綍涓嶅瓨鍦ㄥ垱寤虹洰褰�
- String[] dirs = filePath.split("/");
- String tempPath = basePath;
- for (String dir : dirs) {
- if (null == dir || "".equals(dir))
- continue;
- tempPath += "/" + dir;
- if (!ftpClient.changeWorkingDirectory(tempPath)) {
- if (!ftpClient.makeDirectory(tempPath)) {
- return result;
- } else {
- ftpClient.changeWorkingDirectory(tempPath);
- }
- }
- }
- }
- // 璁剧疆涓婁紶鏂囦欢鐨勭被鍨嬩负浜岃繘鍒剁被鍨�
- if (FTPReply.isPositiveCompletion(ftpClient.sendCommand("OPTS UTF8", "ON"))) {// 寮�鍚湇鍔″櫒瀵筓TF-8鐨勬敮鎸侊紝濡傛灉鏈嶅姟鍣ㄦ敮鎸佸氨鐢║TF-8缂栫爜锛屽惁鍒欏氨浣跨敤鏈湴缂栫爜锛圙BK锛�.
- LOCAL_CHARSET = "UTF-8";
- }
- ftpClient.setControlEncoding(LOCAL_CHARSET);
- ftpClient.enterLocalPassiveMode();// 璁剧疆琚姩妯″紡
- ftpClient.setFileType(FTP.BINARY_FILE_TYPE);// 璁剧疆浼犺緭鐨勬ā寮�
- // 涓婁紶鏂囦欢
- filename = new String(filename.getBytes(LOCAL_CHARSET), SERVER_CHARSET);
- if (!ftpClient.storeFile(filename, input)) {
- return result;
- }
-
- if (null != input) {
- input.close();
- }
-
- result = true;
- } catch (IOException e) {
- e.printStackTrace();
- } finally {
- if (ftpClient.isConnected()) {
- try {
- //閫�鍑虹櫥褰�
- ftpClient.logout();
- //鍏抽棴杩炴帴
- ftpClient.disconnect();
- } catch (IOException ioe) {
- }
- }
- }
- return result;
- }
-
- /**
- * 鍒犻櫎鏂囦欢 鏈祴璇�
- *
- * @param ftpHost FTP鏈嶅姟鍣ㄥ湴鍧�
- * @param ftpPort FTP鏈嶅姟鍣ㄧ鍙ｅ彿
- * @param ftpUserName FTP鐧诲綍甯愬彿
- * @param ftpPassword FTP鐧诲綍瀵嗙爜
- * @param pathname FTP鏈嶅姟鍣ㄤ繚瀛樼洰褰�
- * @param filename 瑕佸垹闄ょ殑鏂囦欢鍚嶇О
- * @return
- */
- public static boolean deleteFile(String ftpHost, int ftpPort, String ftpUserName, String ftpPassword, String pathname,
- String filename) {
- boolean flag = false;
+ public FTPClient getFTPClient() {
FTPClient ftpClient = new FTPClient();
try {
- ftpClient = getFTPClient();
- // 楠岃瘉FTP鏈嶅姟鍣ㄦ槸鍚︾櫥褰曟垚鍔�
- int replyCode = ftpClient.getReplyCode();
- if (!FTPReply.isPositiveCompletion(replyCode)) {
- return flag;
- }
- // 鍒囨崲FTP鐩綍
- ftpClient.changeWorkingDirectory(pathname);
- // 璁剧疆涓婁紶鏂囦欢鐨勭被鍨嬩负浜岃繘鍒剁被鍨�
- if (FTPReply.isPositiveCompletion(ftpClient.sendCommand("OPTS UTF8", "ON"))) {// 寮�鍚湇鍔″櫒瀵筓TF-8鐨勬敮鎸侊紝濡傛灉鏈嶅姟鍣ㄦ敮鎸佸氨鐢║TF-8缂栫爜锛屽惁鍒欏氨浣跨敤鏈湴缂栫爜锛圙BK锛�.
- LOCAL_CHARSET = "UTF-8";
+ ftpClient.connect(ftpHost, ftpPort);
+ ftpClient.login(ftpUserName, ftpPassword);
+
+ // 寮哄埗寮�鍚� UTF-8 鏀寔锛堜紭鍏堣鐩栨湇鍔″櫒閰嶇疆锛�
+ if (FTPReply.isPositiveCompletion(ftpClient.sendCommand("OPTS UTF8", "ON"))) {
+ LOCAL_CHARSET = StandardCharsets.UTF_8.name();
}
ftpClient.setControlEncoding(LOCAL_CHARSET);
- ftpClient.enterLocalPassiveMode();// 璁剧疆琚姩妯″紡
- ftpClient.setFileType(FTP.BINARY_FILE_TYPE);// 璁剧疆浼犺緭鐨勬ā寮�
- //瀵逛腑鏂囧悕绉拌繘琛岃浆鐮�
- filename = new String(filename.getBytes(LOCAL_CHARSET), SERVER_CHARSET);
- ftpClient.dele(filename);
- flag = true;
- } catch (Exception e) {
- e.printStackTrace();
- } finally {
- if (ftpClient.isConnected()) {
- try {
- //閫�鍑虹櫥褰�
- ftpClient.logout();
- //鍏抽棴杩炴帴
- ftpClient.disconnect();
- } catch (IOException e) {
- }
+
+ // 鍏抽敭閰嶇疆锛氫簩杩涘埗浼犺緭 + 琚姩妯″紡锛岃В鍐虫枃浠舵崯鍧忋�侀槻鐏闃诲闂
+ ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
+ ftpClient.enterLocalPassiveMode();
+
+ int replyCode = ftpClient.getReplyCode();
+ if (!FTPReply.isPositiveCompletion(replyCode)) {
+ logger.error("FTP 杩炴帴澶辫触锛屽搷搴旂爜锛�" + replyCode);
+ disconnectQuietly(ftpClient);
+ return null;
}
+ logger.info("FTP 杩炴帴鎴愬姛锛屽搷搴旂爜锛�" + replyCode);
+ return ftpClient;
+ } catch (IOException e) {
+ logger.error("FTP 杩炴帴寮傚父锛�" + e.getMessage(), e);
+ disconnectQuietly(ftpClient);
+ return null;
}
- return flag;
}
/**
- * 鍒涘缓鏂囦欢澶�
- *
- * @param pathname
- * @param filename
- * @return
+ * 瀹夐潤鍏抽棴杩炴帴锛堥伩鍏嶅祵濂楀紓甯革級
*/
- public static boolean createFolder(String pathname, String filename) {
- boolean flag = false;
- FTPClient ftpClient = new FTPClient();
- try {
- ftpClient = getFTPClient();
- // 楠岃瘉FTP鏈嶅姟鍣ㄦ槸鍚︾櫥褰曟垚鍔�
- int replyCode = ftpClient.getReplyCode();
- if (!FTPReply.isPositiveCompletion(replyCode)) {
- return flag;
- }
- // 鍒囨崲FTP鐩綍
- ftpClient.changeWorkingDirectory(pathname);
- boolean created = ftpClient.makeDirectory(filename);
- if (created) {
- logger.info(filename + "鏂囦欢澶瑰垱寤烘垚鍔�");
- } else {
- logger.info(filename + "鍒涘缓鏂囦欢澶瑰け璐�");
- }
- flag = true;
- } catch (Exception e) {
- e.printStackTrace();
- } finally {
- if (ftpClient.isConnected()) {
- try {
- //閫�鍑虹櫥褰�
- ftpClient.logout();
- //鍏抽棴杩炴帴
- ftpClient.disconnect();
- } catch (IOException e) {
- }
+ private void disconnectQuietly(FTPClient ftpClient) {
+ if (ftpClient != null && ftpClient.isConnected()) {
+ try {
+ ftpClient.logout();
+ ftpClient.disconnect();
+ } catch (IOException e) {
+ logger.warn("鍏抽棴 FTP 杩炴帴澶辫触锛�" + e.getMessage(), e);
}
}
- return flag;
}
- public static void uploadFolder(File localFolder, String remoteFolder) {
- if (!localFolder.exists()) {
+
+ // ====================== 鏂囦欢澶逛笂浼犱紭鍖栵細閫掑綊 + 瀹屾暣鎬ф牎楠� ======================
+
+ /**
+ * 閫掑綊涓婁紶鏂囦欢澶癸紙鏍稿績鏂规硶锛�
+ *
+ * @param localFolder 鏈湴鏂囦欢澶�
+ * @param remoteFolder 杩滅▼鐖剁洰褰�
+ */
+ public void uploadFolder(File localFolder, String remoteFolder) {
+ if (localFolder == null || !localFolder.isDirectory()) {
+ logger.warn("鏈湴鏂囦欢澶规棤鏁堬細" + (localFolder == null ? "null" : localFolder.getPath()));
return;
}
+
FTPClient ftpClient = getFTPClient();
- try {
- // 鍒涘缓杩滅▼鏂囦欢澶�
- if (!ftpClient.changeWorkingDirectory(remoteFolder)) {
- ftpClient.makeDirectory(remoteFolder);
- ftpClient.changeWorkingDirectory(remoteFolder);
- }
- } catch (IOException e) {
- e.printStackTrace();
+ if (ftpClient == null) {
+ logger.error("FTP 瀹㈡埛绔垵濮嬪寲澶辫触锛屾斁寮冧笂浼狅細" + localFolder.getPath());
+ return;
}
- // 閬嶅巻鏈湴鏂囦欢澶逛腑鐨勬枃浠跺拰瀛愭枃浠跺す
- File[] files = localFolder.listFiles();
- if (files != null) {
+
+ try {
+ // 纭繚杩滅▼鐩綍瀛樺湪锛堥�掑綊鍒涘缓锛�
+ if (!createRemoteDirectory(ftpClient, remoteFolder)) {
+ logger.error("鍒涘缓杩滅▼鐩綍澶辫触锛�" + remoteFolder);
+ return;
+ }
+
+ // 閬嶅巻鏈湴鏂囦欢
+ File[] files = localFolder.listFiles();
+ if (files == null) {
+ logger.warn("鏈湴鏂囦欢澶逛负绌猴細" + localFolder.getPath());
+ return;
+ }
+
for (File file : files) {
if (file.isDirectory()) {
// 閫掑綊涓婁紶瀛愭枃浠跺す
uploadFolder(file, remoteFolder + "/" + file.getName());
- } else {
- try {
- // 涓婁紶鏂囦欢
- uploadFile1(ftpClient, file, remoteFolder);
- } catch (IOException e) {
- e.printStackTrace();
+ } else if (file.isFile()) {
+ // 涓婁紶鏂囦欢锛堝甫瀹屾暣鎬ф牎楠岋級
+ boolean success = uploadFileWithCheck(ftpClient, file, remoteFolder);
+ if (!success) {
+ logger.error("鏂囦欢涓婁紶澶辫触锛�" + file.getPath() + " -> " + remoteFolder);
}
}
}
- }
- }
-
- private static void uploadFile1(FTPClient ftpClient, File localFile, String remoteFolder) throws IOException {
- try (FileInputStream inputStream = new FileInputStream(localFile)) {
- ftpClient.storeFile(remoteFolder + "/" + localFile.getName(), inputStream);
- }
- }
-
- // 灏嗗瓧鑺傛暟缁勮浆鎹负杈撳叆娴�
- public static final InputStream byte2Input(byte[] buf) {
- return new ByteArrayInputStream(buf);
- }
-
- // 灏嗚緭鍏ユ祦杞负byte[]
- public static final byte[] input2byte(InputStream inStream) throws IOException {
- ByteArrayOutputStream swapStream = new ByteArrayOutputStream();
- byte[] buff = new byte[100];
- int rc = 0;
- while ((rc = inStream.read(buff, 0, 100)) > 0) {
- swapStream.write(buff, 0, rc);
- }
- byte[] in2b = swapStream.toByteArray();
- return in2b;
- }
-
- // 灏哹yte[]杞负鏂囦欢
- public static void byte2File(byte[] buf, String filePath, String fileName) {
- BufferedOutputStream bos = null;
- FileOutputStream fos = null;
- File file = null;
- try {
- File dir = new File(filePath);
- if (!dir.exists() && dir.isDirectory()) {
- dir.mkdirs();
- }
- file = new File(filePath + File.separator + fileName);
- fos = new FileOutputStream(file);
- bos = new BufferedOutputStream(fos);
- bos.write(buf);
- } catch (Exception e) {
- e.printStackTrace();
+ } catch (IOException e) {
+ logger.error("涓婁紶鏂囦欢澶瑰紓甯革細" + e.getMessage(), e);
} finally {
- if (bos != null) {
- try {
- bos.close();
- } catch (IOException e) {
- e.printStackTrace();
+ disconnectQuietly(ftpClient);
+ }
+ }
+
+ /**
+ * 楹掗簾閫掑綊涓婁紶鏂囦欢澶癸紙鏍稿績鏂规硶锛�
+ *
+ * @param localFolder 鏈湴鏂囦欢澶�
+ * @param remoteFolder 杩滅▼鐖剁洰褰�
+ */
+ public void uploadFolderKylin(File localFolder, String remoteFolder) {
+ if (operatingSystem.equals("windows")){
+ if (localFolder == null || !localFolder.isDirectory()) {
+ logger.warn("鏈湴鏂囦欢澶规棤鏁堬細" + (localFolder == null ? "null" : localFolder.getPath()));
+ return;
+ }
+
+ FTPClient ftpClient = getFTPClient();
+ if (ftpClient == null) {
+ logger.error("FTP 瀹㈡埛绔垵濮嬪寲澶辫触锛屾斁寮冧笂浼狅細" + localFolder.getPath());
+ return;
+ }
+
+ try {
+ // 楹掗簾绯荤粺FTP鏈嶅姟鍣ㄥ繀闇�鐨勮缃�
+ ftpClient.enterLocalPassiveMode(); // 鍚敤琚姩妯″紡锛堢被Unix绯荤粺鎺ㄨ崘锛�
+ ftpClient.setFileType(FTP.BINARY_FILE_TYPE); // 浜岃繘鍒朵紶杈撻伩鍏嶆枃浠舵崯鍧�
+ ftpClient.setControlEncoding("UTF-8"); // 鎺у埗杩炴帴缂栫爜
+ // 纭繚杩滅▼鐩綍瀛樺湪锛堥�掑綊鍒涘缓锛�
+ if (!createRemoteDirectory(ftpClient, remoteFolder)) {
+ logger.error("鍒涘缓杩滅▼鐩綍澶辫触锛�" + remoteFolder);
+ return;
+ }
+
+ // 閬嶅巻鏈湴鏂囦欢
+ File[] files = localFolder.listFiles();
+ if (files == null) {
+ logger.warn("鏈湴鏂囦欢澶逛负绌猴細" + localFolder.getPath());
+ return;
+ }
+
+ for (File file : files) {
+ if (file.isDirectory()) {
+ // 閫掑綊涓婁紶瀛愭枃浠跺す
+ uploadFolder(file, remoteFolder + "/" + file.getName());
+ } else if (file.isFile()) {
+ // 涓婁紶鏂囦欢锛堝甫瀹屾暣鎬ф牎楠岋級
+ boolean success = uploadFileWithCheck(ftpClient, file, remoteFolder);
+ if (!success) {
+ logger.error("鏂囦欢涓婁紶澶辫触锛�" + file.getPath() + " -> " + remoteFolder);
+ }
+ }
+ }
+ } catch (IOException e) {
+ logger.error("涓婁紶鏂囦欢澶瑰紓甯革細" + e.getMessage(), e);
+ } finally {
+ disconnectQuietly(ftpClient);
+ }
+ }else {
+ if (localFolder == null || !localFolder.isDirectory()) {
+ logger.warn("鏈湴鏂囦欢澶规棤鏁堬細" + (localFolder == null ? "null" : localFolder.getPath()));
+ return;
+ }
+
+ FTPClient ftpClient = getFTPClient();
+ if (ftpClient == null) {
+ logger.error("FTP 瀹㈡埛绔垵濮嬪寲澶辫触锛屾斁寮冧笂浼狅細" + localFolder.getPath());
+ return;
+ }
+
+ try {
+ // 楹掗簾绯荤粺FTP鏈嶅姟鍣ㄥ繀闇�鐨勮缃�
+ ftpClient.enterLocalPassiveMode(); // 鍚敤琚姩妯″紡锛堢被Unix绯荤粺鎺ㄨ崘锛�
+ ftpClient.setFileType(FTP.BINARY_FILE_TYPE); // 浜岃繘鍒朵紶杈撻伩鍏嶆枃浠舵崯鍧�
+ ftpClient.setControlEncoding("UTF-8"); // 鎺у埗杩炴帴缂栫爜
+ // 纭繚杩滅▼鐩綍瀛樺湪锛堥�掑綊鍒涘缓锛�
+ if (!createKylinFtpDirectory(ftpClient, "/iot", remoteFolder)) {
+ logger.error("鍒涘缓杩滅▼鐩綍澶辫触锛�" + remoteFolder);
+ return;
+ }
+
+ // 閬嶅巻鏈湴鏂囦欢
+ File[] files = localFolder.listFiles();
+ if (files == null) {
+ logger.warn("鏈湴鏂囦欢澶逛负绌猴細" + localFolder.getPath());
+ return;
+ }
+
+ for (File file : files) {
+ if (file.isDirectory()) {
+ // 閫掑綊涓婁紶瀛愭枃浠跺す
+ uploadFolder(file, "/iot"+remoteFolder + "/" + file.getName());
+ } else if (file.isFile()) {
+ // 涓婁紶鏂囦欢锛堝甫瀹屾暣鎬ф牎楠岋級
+ boolean success = uploadFileWithCheck(ftpClient, file, "/iot"+remoteFolder);
+ if (!success) {
+ logger.error("鏂囦欢涓婁紶澶辫触锛�" + file.getPath() + " -> " + remoteFolder);
+ }
+ }
+ }
+ } catch (IOException e) {
+ logger.error("涓婁紶鏂囦欢澶瑰紓甯革細" + e.getMessage(), e);
+ } finally {
+ disconnectQuietly(ftpClient);
+ }
+ }
+
+ }
+
+ private boolean createRemoteDirectory(FTPClient ftpClient, String remoteDir) throws IOException {
+ String[] dirs = remoteDir.split("/");
+ StringBuilder currentDir = new StringBuilder();
+ for (String dir : dirs) {
+ if (dir.trim().isEmpty()) continue;
+ currentDir.append("/").append(dir);
+ String targetDir = currentDir.toString();
+ // 鎵撳嵃褰撳墠灏濊瘯鍒囨崲/鍒涘缓鐨勭洰褰�
+ logger.info("灏濊瘯鎿嶄綔鐩綍:" + targetDir);
+
+ if (!ftpClient.changeWorkingDirectory(targetDir)) {
+ boolean mkdirResult = ftpClient.makeDirectory(targetDir);
+ // 鎵撳嵃鍒涘缓缁撴灉鍜� FTP 鍝嶅簲
+ logger.info("鍒涘缓鐩綍缁撴灉: " + mkdirResult + ", 鍝嶅簲鐮�: " + ftpClient.getReplyCode()
+ + ", 鍝嶅簲淇℃伅: " + ftpClient.getReplyString());
+
+ if (!mkdirResult) {
+ logger.error("鍒涘缓鐩綍澶辫触: " + targetDir);
+ return false;
+ }
+ if (!ftpClient.changeWorkingDirectory(targetDir)) {
+ logger.error("鍒囨崲鐩綍澶辫触: " + targetDir + ", 鍝嶅簲鐮�: " + ftpClient.getReplyCode()
+ + ", 鍝嶅簲淇℃伅: " + ftpClient.getReplyString());
+ return false;
}
}
- if (fos != null) {
- try {
- fos.close();
- } catch (IOException e) {
- e.printStackTrace();
+ }
+ return true;
+ }
+
+ /**
+ * 鍦ㄩ簰楹熺郴缁熺殑FTP鏈嶅姟鍣ㄤ笂鍒涘缓鐩綍锛堟敮鎸佸绾х洰褰曪級
+ *
+ * @param baseDir FTP鍩虹鐩綍锛堝/iot锛�
+ * @param remoteDir 瑕佸垱寤虹殑鐩綍璺緞锛堝data/logs/2023锛�
+ * @return 鏄惁鍒涘缓鎴愬姛
+ * @throws IOException IO寮傚父
+ */
+ public boolean createKylinFtpDirectory(FTPClient ftpClient, String baseDir, String remoteDir) throws IOException {
+ // 纭繚鍩虹鐩綍浠�/缁撳熬
+ String normalizedBase = baseDir.endsWith("/") ? baseDir : baseDir + "/";
+
+ // 澶勭悊杩滅▼鐩綍锛岀Щ闄ゅ紑澶村彲鑳界殑/锛岄伩鍏嶉噸澶�
+ String normalizedRemote = remoteDir.startsWith("/") ? remoteDir.substring(1) : remoteDir;
+
+ // 鍒嗗壊鐩綍
+ String[] dirs = normalizedRemote.split("/");
+ StringBuilder currentPath = new StringBuilder(normalizedBase);
+
+ for (String dir : dirs) {
+ if (dir.trim().isEmpty()) continue; // 璺宠繃绌虹洰褰曪紙澶勭悊杩炵画//鐨勬儏鍐碉級
+
+ currentPath.append(dir).append("/");
+ String targetDir = currentPath.toString();
+
+ // 灏濊瘯鍒囨崲鍒扮洰褰�
+ if (!ftpClient.changeWorkingDirectory(targetDir)) {
+ // 鍒囨崲澶辫触锛屽皾璇曞垱寤虹洰褰�
+ boolean created = ftpClient.makeDirectory(targetDir);
+ logger.info("鍒涘缓鐩綍[" + targetDir + "]缁撴灉: {" + created + "}, 鍝嶅簲鐮�: {" + ftpClient.getReplyCode() + "}");
+
+ if (!created) {
+ logger.error("鍒涘缓鐩綍澶辫触: {" + targetDir + "}");
+ return false;
}
+
+ // 楠岃瘉鏄惁鑳藉垏鎹㈠埌鏂板垱寤虹殑鐩綍
+ if (!ftpClient.changeWorkingDirectory(targetDir)) {
+ logger.error("鍒囨崲鍒扮洰褰曞け璐�: {" + targetDir + "}, 鍝嶅簲: {" + ftpClient.getReplyString() + "}");
+ return false;
+ }
+ }
+ }
+ return true;
+ }
+
+ /**
+ * 涓婁紶鏂囦欢锛堝甫澶у皬鏍￠獙锛�
+ *
+ * @return 鏄惁涓婁紶鎴愬姛涓斿畬鏁�
+ */
+ private boolean uploadFileWithCheck(FTPClient ftpClient, File localFile, String remoteFolder) throws IOException {
+ String remoteFilePath = remoteFolder + "/" + localFile.getName();
+ long localFileSize = localFile.length();
+
+ // 鏍￠獙杩滅▼鏂囦欢鏄惁宸插瓨鍦ㄤ笖瀹屾暣
+ FTPFile[] remoteFiles = ftpClient.listFiles(remoteFilePath);
+ if (remoteFiles != null && remoteFiles.length > 0) {
+ FTPFile remoteFile = remoteFiles[0];
+ if (remoteFile.getSize() == localFileSize) {
+ logger.info("鏂囦欢宸插瓨鍦ㄤ笖瀹屾暣锛岃烦杩囦笂浼狅細" + localFile.getPath());
+ return true;
+ }
+ }
+
+ // 鎵ц涓婁紶
+ try (FileInputStream inputStream = new FileInputStream(localFile)) {
+ boolean uploaded = ftpClient.storeFile(remoteFilePath, inputStream);
+ if (!uploaded) {
+ logger.error("涓婁紶澶辫触锛屽搷搴旂爜锛�" + ftpClient.getReplyCode() + " -> " + localFile.getPath());
+ return false;
+ }
+
+ // 浜屾鏍￠獙杩滅▼鏂囦欢澶у皬
+ FTPFile[] checkFiles = ftpClient.listFiles(remoteFilePath);
+ if (checkFiles == null || checkFiles.length == 0) {
+ logger.error("涓婁紶鍚庢枃浠朵涪澶憋細" + localFile.getPath());
+ return false;
+ }
+ return checkFiles[0].getSize() == localFileSize;
+ }
+ }
+
+
+ // ====================== 鍏朵粬鏂规硶浼樺寲锛氳祫婧愰噴鏀� + 缂栫爜鍋ュ．鎬� ======================
+
+ /**
+ * 涓嬭浇鏂囦欢锛堜紭鍖栫紪鐮佸鐞嗐�佽祫婧愰噴鏀撅級
+ */
+ public void downloadFtpFile(String ftpPath, String localPath, String fileName) {
+ FTPClient ftpClient = getFTPClient();
+ if (ftpClient == null) {
+ return;
+ }
+
+ try {
+ // 缂栫爜杞崲锛堣В鍐充腑鏂囪矾寰勯棶棰橈級
+ String remoteFilePath = new String((ftpPath + "/" + fileName).getBytes(LOCAL_CHARSET), SERVER_CHARSET);
+ if (!ftpClient.changeWorkingDirectory(ftpPath)) {
+ logger.error("鍒囨崲杩滅▼鐩綍澶辫触锛�" + ftpPath);
+ return;
+ }
+
+ // 涓嬭浇鏂囦欢
+ try (InputStream is = ftpClient.retrieveFileStream(remoteFilePath);
+ OutputStream os = new FileOutputStream(new File(localPath, fileName))) {
+ if (is == null) {
+ logger.error("杩滅▼鏂囦欢涓嶅瓨鍦細" + remoteFilePath);
+ return;
+ }
+ byte[] buffer = new byte[4096];
+ int len;
+ while ((len = is.read(buffer)) != -1) {
+ os.write(buffer, 0, len);
+ }
+ os.flush();
+ // 纭涓嬭浇瀹屾垚锛堝叧閿細閬垮厤鏂囦欢鎴柇锛�
+ if (!ftpClient.completePendingCommand()) {
+ logger.error("FTP 涓嬭浇鏈畬鎴愶細" + remoteFilePath);
+ }
+ }
+ } catch (IOException e) {
+ logger.error("涓嬭浇鏂囦欢澶辫触锛�" + fileName, e);
+ } finally {
+ disconnectQuietly(ftpClient);
+ }
+ }
+
+ /**
+ * 涓婁紶鏂囦欢锛堢嫭绔嬫柟娉曪紝渚涘鐢級
+ *
+ * @param basePath 杩滅▼鍩虹璺緞
+ * @param filePath 杩滅▼瀛愯矾寰�
+ * @param filename 鏂囦欢鍚�
+ * @param input 杈撳叆娴�
+ * @return 鏄惁鎴愬姛
+ */
+ public boolean uploadFile(String basePath, String filePath, String filename, InputStream input) {
+ FTPClient ftpClient = getFTPClient();
+ if (ftpClient == null) {
+ return false;
+ }
+
+ try {
+ String remoteDir = basePath + filePath;
+ if (!createRemoteDirectory(ftpClient, remoteDir)) {
+ return false;
+ }
+
+ // 缂栫爜杞崲锛堣В鍐充腑鏂囨枃浠跺悕锛�
+ String remoteFileName = new String(filename.getBytes(LOCAL_CHARSET), SERVER_CHARSET);
+ boolean success = ftpClient.storeFile(remoteFileName, input);
+ if (success) {
+ logger.info("鏂囦欢涓婁紶鎴愬姛锛�" + remoteDir + "/" + remoteFileName);
+ } else {
+ logger.error("鏂囦欢涓婁紶澶辫触锛屽搷搴旂爜锛�" + ftpClient.getReplyCode());
+ }
+ return success;
+ } catch (IOException e) {
+ logger.error("涓婁紶鏂囦欢寮傚父锛�" + e.getMessage(), e);
+ return false;
+ } finally {
+ disconnectQuietly(ftpClient);
+ try {
+ input.close();
+ } catch (IOException e) {
+ logger.warn("鍏抽棴杈撳叆娴佸け璐ワ細" + e.getMessage());
}
}
}
-}
+ /**
+ * 涓婁紶鏂囦欢锛堥�傞厤楹掗簾绯荤粺锛屼緵澶嶇敤锛�
+ *
+ * @param basePath 杩滅▼鍩虹璺緞锛堝/iot锛�
+ * @param filePath 杩滅▼瀛愯矾寰勶紙濡俤ata/logs锛�
+ * @param filename 鏂囦欢鍚�
+ * @param input 杈撳叆娴�
+ * @return 鏄惁鎴愬姛
+ */
+ public boolean uploadFileKylin(String basePath, String filePath, String filename, InputStream input) {
+ FTPClient ftpClient = getFTPClient();
+ if (ftpClient == null) {
+ logger.error("鑾峰彇FTPClient瀹炰緥澶辫触锛屾棤娉曟墽琛屼笂浼�");
+ return false;
+ }
+
+ try {
+ // 楹掗簾绯荤粺FTP鏈嶅姟鍣ㄥ繀闇�鐨勮缃�
+ ftpClient.enterLocalPassiveMode(); // 鍚敤琚姩妯″紡锛堢被Unix绯荤粺鎺ㄨ崘锛�
+ ftpClient.setFileType(FTP.BINARY_FILE_TYPE); // 浜岃繘鍒朵紶杈撻伩鍏嶆枃浠舵崯鍧�
+ ftpClient.setControlEncoding("UTF-8"); // 鎺у埗杩炴帴缂栫爜
+
+ // 璺緞瑙勮寖鍖栧鐞嗭紙閫傞厤楹掗簾绯荤粺Unix璺緞鏍煎紡锛�
+ String normalizedBase = normalizePath(basePath);
+ String normalizedFilePath = normalizePath(filePath);
+ String remoteDir = normalizedBase + normalizedFilePath;
+ logger.info("楹掗簾绯荤粺FTP鐩爣鐩綍:" + remoteDir);
+
+ // 鍒涘缓鐩綍锛堜慨姝ｅ弬鏁伴『搴忥紝浣跨敤瑙勮寖鍖栬矾寰勶級
+ if (!createKylinFtpDirectory(ftpClient, normalizedBase, normalizedFilePath)) {
+ logger.error("鐩綍鍒涘缓澶辫触锛岀粓姝笂浼�:" + remoteDir);
+ return false;
+ }
+
+ // 鍒囨崲鍒扮洰鏍囩洰褰曪紙澧炲姞楠岃瘉姝ラ锛�
+ if (!ftpClient.changeWorkingDirectory(remoteDir)) {
+ logger.error("鍒囨崲鍒扮洰褰昜" + remoteDir + "]澶辫触锛屽搷搴旂爜: {" + ftpClient.getReplyCode() + "}");
+ return false;
+ }
+
+ // 缂栫爜杞崲锛堜紭鍖栦腑鏂囨枃浠跺悕澶勭悊锛岄�傞厤楹掗簾绯荤粺缂栫爜锛�
+ String remoteFileName = new String(filename.getBytes(LOCAL_CHARSET), SERVER_CHARSET);
+
+ // 鎵ц涓婁紶
+ boolean success = ftpClient.storeFile(remoteFileName, input);
+ if (success) {
+ logger.info("鏂囦欢涓婁紶鎴愬姛锛歿" + remoteDir + "/" + filename + "}");
+ } else {
+ logger.error("鏂囦欢涓婁紶澶辫触锛岃矾寰勶細{" + remoteDir + "/" + filename + "}锛屽搷搴旂爜锛歿" + ftpClient.getReplyCode() + "}锛屽搷搴斾俊鎭細{" +
+ ftpClient.getReplyString() + "}");
+ }
+ return success;
+ } catch (IOException e) {
+ logger.error("涓婁紶鏂囦欢寮傚父锛歿" + e.getMessage(), e);
+ return false;
+ } finally {
+ disconnectQuietly(ftpClient);
+ try {
+ input.close();
+ } catch (IOException e) {
+ logger.warn("鍏抽棴杈撳叆娴佸け璐ワ細{}" + e.getMessage());
+ }
+ }
+ }
+
+ /**
+ * 璺緞瑙勮寖鍖栧鐞嗭紙閫傞厤楹掗簾绯荤粺锛�
+ * 澶勭悊閲嶅鏂滄潬銆侀灏炬枩鏉犻棶棰橈紝缁熶竴Unix椋庢牸璺緞
+ */
+ private String normalizePath(String path) {
+ if (path == null || path.trim().isEmpty()) {
+ return "";
+ }
+ // 鏇挎崲澶氫釜鏂滄潬涓哄崟涓紝绉婚櫎灏鹃儴鏂滄潬锛堥櫎鏍圭洰褰曞锛�
+ String normalized = path.trim().replaceAll("//+", "/");
+ if (normalized.length() > 1 && normalized.endsWith("/")) {
+ normalized = normalized.substring(0, normalized.length() - 1);
+ }
+ return normalized;
+ }
+
+ /**
+ * 鍒涘缓鏂囦欢澶癸紙閫傞厤楹掗簾绯荤粺锛岃В鍐崇紪鐮�/鏉冮檺/璺緞闂锛�
+ */
+ public boolean createFolder(String pathname, String folderName) {
+ FTPClient ftpClient = getFTPClient();
+ if (ftpClient == null) {
+ return false;
+ }
+
+ try {
+ // 1. 缁熶竴璺緞鏍煎紡锛圠inux鍏煎锛�
+ String remoteFolder = (pathname + "/" + folderName)
+ .replace("\\", "/") // 鏇挎崲Windows鍙嶆枩鏉�
+ .replaceAll("/+", "/") // 鍚堝苟杩炵画鏂滄潬
+ .replaceAll("^/", ""); // 鍘婚櫎寮�澶寸殑鏂滄潬锛堥伩鍏嶇粷瀵硅矾寰勯棶棰橈級
+
+ // 2. 璁剧疆UTF-8缂栫爜锛堣В鍐充腑鏂囪矾寰勯棶棰橈級
+ ftpClient.setControlEncoding("UTF-8");
+ remoteFolder = new String(remoteFolder.getBytes("UTF-8"), "ISO-8859-1"); // FTP鍗忚榛樿缂栫爜
+
+ // 3. 妫�鏌ョ洰褰曟槸鍚﹀瓨鍦紙骞傜瓑鎬э級
+ if (ftpClient.changeWorkingDirectory(remoteFolder)) {
+ logger.info("鏂囦欢澶瑰凡瀛樺湪锛�" + remoteFolder);
+ return true;
+ }
+
+ // 4. 灏濊瘯鍒涘缓鐩綍锛堣鍔ㄦā寮忛�傞厤锛�
+ ftpClient.enterLocalPassiveMode(); // 楹掗簾绯荤粺寤鸿鐢ㄨ鍔ㄦā寮�
+ boolean success = ftpClient.makeDirectory(remoteFolder);
+
+ // 5. 璁板綍璇︾粏閿欒淇℃伅
+ if (!success) {
+ int replyCode = ftpClient.getReplyCode();
+ String replyMsg = ftpClient.getReplyString();
+ logger.error("鍒涘缓鏂囦欢澶瑰け璐ワ紝璺緞锛�" + remoteFolder +
+ "锛屽搷搴旂爜锛�" + replyCode +
+ "锛屽搷搴斾俊鎭細" + replyMsg);
+
+ // 鐗规畩澶勭悊550閿欒锛堟潈闄�/SELinux闂锛�
+ if (replyCode == 550) {
+ logger.error("鍙兘鍘熷洜锛氭潈闄愪笉瓒�/SELinux闄愬埗/璺緞涓嶅瓨鍦�");
+ }
+ } else {
+ logger.info("鍒涘缓鏂囦欢澶规垚鍔燂細" + remoteFolder);
+ }
+ return success;
+ } catch (IOException e) {
+ logger.error("鍒涘缓鏂囦欢澶瑰紓甯革細" + e.getMessage(), e);
+ return false;
+ } finally {
+ disconnectQuietly(ftpClient);
+ }
+ }
+
+ // ====================== 宸ュ叿鏂规硶锛氬瓧鑺傛祦杞崲锛堜繚鎸佸吋瀹癸級 ======================
+ public InputStream byte2Input(byte[] buf) {
+ return new ByteArrayInputStream(Objects.requireNonNull(buf));
+ }
+
+ public byte[] input2byte(InputStream inStream) throws IOException {
+ try (ByteArrayOutputStream bos = new ByteArrayOutputStream()) {
+ byte[] buffer = new byte[4096];
+ int len;
+ while ((len = inStream.read(buffer)) != -1) {
+ bos.write(buffer, 0, len);
+ }
+ return bos.toByteArray();
+ }
+ }
+
+ public void byte2File(byte[] buf, String filePath, String fileName) {
+ File dir = new File(filePath);
+ if (!dir.exists() && !dir.mkdirs()) {
+ logger.error("鍒涘缓鏈湴鐩綍澶辫触锛�" + filePath);
+ return;
+ }
+ try (BufferedOutputStream bos = new BufferedOutputStream(
+ new FileOutputStream(new File(dir, fileName)))) {
+ bos.write(buf);
+ } catch (IOException e) {
+ logger.error("瀛楄妭鏁扮粍鍐欏叆鏂囦欢澶辫触锛�" + fileName, e);
+ }
+ }
+}
\ No newline at end of file
--
Gitblit v1.9.3