From 0285e2aea4bbb1569a82e5011c3b04cf0bac28ee Mon Sep 17 00:00:00 2001
From: caihaohan <caihaohan0712@foxmail.com>
Date: Wed, 24 Jan 2024 19:02:50 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E4=BC=81=E6=A0=87=E6=9B=B4=E6=94=B9?=
 =?UTF-8?q?=E6=B5=81=E7=A8=8B=E5=9C=A8=E7=BA=BF=E7=BC=96=E8=BE=91=E5=B7=B2?=
 =?UTF-8?q?=E6=9C=89=E6=96=87=E4=BB=B6=E8=8E=B7=E5=8F=96=E5=9C=A8=E7=BA=BF?=
 =?UTF-8?q?=E7=BC=96=E8=BE=91=E6=96=87=E4=BB=B6=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../controller/OnlyOfficeController.java      |  6 ++
 .../service/IBusProcessModelHisService.java   |  2 +
 .../impl/BusProcessModelHisServiceImpl.java   | 63 +++++++++++++++++++
 3 files changed, 71 insertions(+)

diff --git a/laws-modules/src/main/java/com/jero/modules/onlyoffice/controller/OnlyOfficeController.java b/laws-modules/src/main/java/com/jero/modules/onlyoffice/controller/OnlyOfficeController.java
index 1006ae49..bf24e288 100644
--- a/laws-modules/src/main/java/com/jero/modules/onlyoffice/controller/OnlyOfficeController.java
+++ b/laws-modules/src/main/java/com/jero/modules/onlyoffice/controller/OnlyOfficeController.java
@@ -316,6 +316,12 @@ public class OnlyOfficeController {
         return Result.OK(busProcessModelHisService.saveEditFile(model));
     }
 
+    @ApiOperation(value = "传入ossFileId获取在线编辑文件相关信息")
+    @GetMapping("/saveEditFileWithOss")
+    public Result<BusProcessModelHis> saveEditFileWithOss(String ossFileId) {
+        return Result.OK(busProcessModelHisService.saveEditFileWithOss(ossFileId));
+    }
+
     @ApiOperation(value = "根据路径下载文件")
     @GetMapping("/downLoadFile")
     public void downLoadFile(@RequestParam(name = "path") String path, HttpServletResponse response) {
diff --git a/laws-modules/src/main/java/com/jero/modules/onlyoffice/service/IBusProcessModelHisService.java b/laws-modules/src/main/java/com/jero/modules/onlyoffice/service/IBusProcessModelHisService.java
index 746c1d9c..16e7de6e 100644
--- a/laws-modules/src/main/java/com/jero/modules/onlyoffice/service/IBusProcessModelHisService.java
+++ b/laws-modules/src/main/java/com/jero/modules/onlyoffice/service/IBusProcessModelHisService.java
@@ -29,6 +29,8 @@ public interface IBusProcessModelHisService extends IService<BusProcessModelHis>
 
     BusProcessModelHis saveEditFile(String model);
 
+    BusProcessModelHis saveEditFileWithOss(String ossFileId);
+
     List<BusProcessModelHis> modelHisList(String pid);
 
     OnlineFileLog selectOnlineFile(String onlineFileId);
diff --git a/laws-modules/src/main/java/com/jero/modules/onlyoffice/service/impl/BusProcessModelHisServiceImpl.java b/laws-modules/src/main/java/com/jero/modules/onlyoffice/service/impl/BusProcessModelHisServiceImpl.java
index fe93e712..5c01763a 100644
--- a/laws-modules/src/main/java/com/jero/modules/onlyoffice/service/impl/BusProcessModelHisServiceImpl.java
+++ b/laws-modules/src/main/java/com/jero/modules/onlyoffice/service/impl/BusProcessModelHisServiceImpl.java
@@ -14,6 +14,7 @@ import com.jero.modules.onlyoffice.mapper.OnlineFileLogDao;
 import com.jero.modules.onlyoffice.service.IBusProcessModelHisService;
 import com.jero.modules.oss.entity.OSSFile;
 import com.jero.modules.oss.service.IOSSFileService;
+import com.jero.modules.sys.controller.SysCommonController;
 import io.minio.errors.*;
 import org.apache.commons.io.FileUtils;
 import org.apache.commons.lang.StringUtils;
@@ -113,6 +114,68 @@ public class BusProcessModelHisServiceImpl extends ServiceImpl<BusProcessModelHi
         return modelHis;
     }
 
+    @Override
+    public BusProcessModelHis saveEditFileWithOss(String ossFileId) {
+        OSSFile ossFile = ossFileService.getById(ossFileId);
+        BusProcessModelHis modelHis = new BusProcessModelHis();
+
+        try {
+            String taskId = generateTaskId();
+            String topId = generateTopId();
+            String builderModel = "model" + "/";
+            String targetPath = builderModel + taskId + "/" + taskId + "_" + topId + "_node.docx";
+
+            createDirectoryIfNotExists(filePath + builderModel);
+            createDirectoryIfNotExists(filePath + builderModel + taskId + "/");
+
+            String fileUrl = ossFile.getUrl();
+            String minioUrl = MinioUtil.getMinioUrl() + MinioUtil.getBucketName() + "/";
+            String url = fileUrl.replace(minioUrl, "");
+
+            InputStream minioFile = MinioUtil.getMinioFile(MinioUtil.getBucketName(), url);
+
+            File targetFile = new File(filePath + targetPath);
+
+            try (OutputStream outputStream = new FileOutputStream(targetFile)) {
+                byte[] buffer = new byte[1024];
+                int bytesRead;
+                while ((bytesRead = minioFile.read(buffer)) != -1) {
+                    outputStream.write(buffer, 0, bytesRead);
+                }
+            } catch (IOException e) {
+                log.error("文件写入失败：" + e.getMessage());
+            }
+
+            modelHis.setFileName(ossFile.getFileName());
+            modelHis.setTaskId(taskId);
+            modelHis.setPId(topId);
+            modelHis.setEditFilePath(targetPath);
+            modelHis.setDownLoadUrl(downloadUrl + targetPath);
+            this.baseMapper.insert(modelHis);
+        } catch (Exception e) {
+            logger.error(e.getMessage());
+        }
+
+        return modelHis;
+    }
+
+    private String generateTaskId() {
+        String preUuid2 = UUID.randomUUID().toString();
+        return "task_" + preUuid2.substring(0, 8);
+    }
+
+    private String generateTopId() {
+        String preUuid2 = UUID.randomUUID().toString();
+        return "top_" + preUuid2.substring(0, 8);
+    }
+
+    private void createDirectoryIfNotExists(String directoryPath) {
+        File dir = new File(directoryPath);
+        if (!dir.exists()) {
+            dir.mkdirs();
+        }
+    }
+
     @Override
     public OnlineFileLog selectOnlineFile(String onlineFileId) {
         BusProcessModelHis busProcessModelHis = baseMapper.selectById(onlineFileId);