From a7bfcafaac5b5581656fc0a764511566a0fc31ce Mon Sep 17 00:00:00 2001
From: 6c <420680616@qq.com>
Date: 星期五, 07 十一月 2025 15:05:57 +0800
Subject: [PATCH] 文件预览,保存到数据库,若是本地没有父文件夹,那么先创建父文件夹

---
 src/main/java/com/product/file/service/FileManagerService.java |   32 ++++++++++++++++++++++++--------
 1 files changed, 24 insertions(+), 8 deletions(-)

diff --git a/src/main/java/com/product/file/service/FileManagerService.java b/src/main/java/com/product/file/service/FileManagerService.java
index db4ae7e..4245667 100644
--- a/src/main/java/com/product/file/service/FileManagerService.java
+++ b/src/main/java/com/product/file/service/FileManagerService.java
@@ -886,6 +886,7 @@
                     if (saveInDb) {
                         File localFile = new File(Global.getSystemConfig("local.dir", "") + File.separator + attachmentFse.getString(CmnConst.ATTACHMENT_URL) + File.separator + fileName);
                         if (!localFile.exists()) {
+                            localFile.getParentFile().mkdirs();
                             Files.copy(is, localFile.toPath(), StandardCopyOption.REPLACE_EXISTING);
                         }
                     }
@@ -1024,13 +1025,22 @@
 					ftpService.downloadFile(path, os);
 				}
 			} else {
-				// 鐩存帴鍦ㄦ湰鍦扮殑鐩綍涓壘鏂囦欢
-				String localBasePath = Global.getSystemConfig("local.dir", "");
-				path = localBasePath + File.separator + path;
-				File file = new File(path);
-				int len;
-				byte[] b = new byte[1024];
-				try (InputStream is = new FileInputStream(file)) {
+                InputStream is = null;
+                try {
+                    Object fileContent = attachmentFse.getValue("file_content");
+                    boolean saveInDb = fileContent != null;
+                    if (saveInDb) {
+                        // 瀛樺偍鍒版暟鎹簱
+                        is = (InputStream) fileContent;
+                    } else {
+                        // 鐩存帴鍦ㄦ湰鍦扮殑鐩綍涓壘鏂囦欢
+                        String localBasePath = Global.getSystemConfig("local.dir", "");
+                        path = localBasePath + File.separator + path;
+                        File file = new File(path);
+                        is = Files.newInputStream(file.toPath());
+                    }
+                    int len;
+                    byte[] b = new byte[1024];
 					while ((len = is.read(b)) > 0) {
 						if (Global.getPropertyToBoolean("file.encrypt", "true")) {
 							// 闇�瑕佽В瀵�
@@ -1040,7 +1050,13 @@
 							os.write(b, 0, len);
 						}
 					}
-				}
+				} catch (Exception e) {
+                    throw new BaseException(FileCode.GET_FILE_BYTES_FAIL);
+                } finally {
+                    if (is != null) {
+                        is.close();
+                    }
+                }
 			}
 
 			return os.toByteArray();

--
Gitblit v1.9.2