From 61d1511493fa85572cb00a19240dbcda384986e7 Mon Sep 17 00:00:00 2001 From: yanglin Date: Fri, 21 Mar 2025 14:16:37 +0800 Subject: [PATCH] =?UTF-8?q?REQ-3540:=20=E6=9B=B4=E6=96=B0=E6=96=87?= =?UTF-8?q?=E4=BB=B6=E5=A4=A7=E5=B0=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../cn/axzo/nanopart/doc/file/index/IndexManager.java | 11 +++++++++-- .../axzo/nanopart/doc/wps/wpsedit/WpsEditManager.java | 5 +---- 2 files changed, 10 insertions(+), 6 deletions(-) diff --git a/doc/doc-server/src/main/java/cn/axzo/nanopart/doc/file/index/IndexManager.java b/doc/doc-server/src/main/java/cn/axzo/nanopart/doc/file/index/IndexManager.java index 09f7ef81..90ae521a 100644 --- a/doc/doc-server/src/main/java/cn/axzo/nanopart/doc/file/index/IndexManager.java +++ b/doc/doc-server/src/main/java/cn/axzo/nanopart/doc/file/index/IndexManager.java @@ -81,11 +81,18 @@ public class IndexManager { BizAssertions.assertNotBlank(ossFile.getOssFileKey(), "oosFileKey不能为空"); BizAssertions.assertNotBlank(ossFile.getExtension(), "extension不能为空"); IndexNode fileNode = createFile(node, ossFile); - indexNodeDao.updateFileSize(fileNode.getCode(), ossFile.getSize()); - fileBroadcaster.fireFileSizeChanged(fileNode.getCode()); + updateFileSize(fileNode, ossFile.getSize()); return fileNode; } + @BizTransactional + public void updateFileSize(IndexNode fileNode, int size) { + if (fileNode == null || !fileNode.isFile()) + return; + indexNodeDao.updateFileSize(fileNode.getCode(), size); + fileBroadcaster.fireFileSizeChanged(fileNode.getCode()); + } + public IndexNode createFile(NodeCreate create, OssFile ossFile) { Ref deleteOssFile = Ref.create(false); try { diff --git a/doc/doc-server/src/main/java/cn/axzo/nanopart/doc/wps/wpsedit/WpsEditManager.java b/doc/doc-server/src/main/java/cn/axzo/nanopart/doc/wps/wpsedit/WpsEditManager.java index d81a6764..9ac35c2b 100644 --- a/doc/doc-server/src/main/java/cn/axzo/nanopart/doc/wps/wpsedit/WpsEditManager.java +++ b/doc/doc-server/src/main/java/cn/axzo/nanopart/doc/wps/wpsedit/WpsEditManager.java @@ -17,7 +17,6 @@ import cn.axzo.nanopart.doc.api.wps.response.WpsEditUploadCompleteResponse; import cn.axzo.nanopart.doc.api.wps.response.WpsEditUploadPrepareResponse; import cn.axzo.nanopart.doc.config.DocProps; import cn.axzo.nanopart.doc.dao.IndexNodeDao; -import cn.axzo.nanopart.doc.dao.TemplateDatabaseDao; import cn.axzo.nanopart.doc.entity.IndexNode; import cn.axzo.nanopart.doc.file.index.IndexManager; import cn.axzo.nanopart.doc.file.mq.FileBroadcaster; @@ -41,7 +40,6 @@ import lombok.extern.slf4j.Slf4j; public class WpsEditManager { private final IndexManager indexManager; - private final TemplateDatabaseDao templateDatabaseDao; private final IndexNodeDao indexNodeDao; private final DocOssGateway docOssGateway; private final FileBroadcaster fileBroadcaster; @@ -110,8 +108,7 @@ public class WpsEditManager { public WpsEditUploadCompleteResponse uploadComplete(WpsEditUploadCompleteRequest request) { log.info("wpsEditManager-uploadComplete-params,request:{}", request); IndexNode node = indexNodeDao.findOrNull(request.getDocCode()); - indexNodeDao.updateFileSize(request.getDocCode(), request.getSize()); - fileBroadcaster.fireFileSizeChanged(request.getDocCode()); + indexManager.updateFileSize(node, request.getSize()); return WpsEditUploadCompleteResponse.builder() .docCode(request.getDocCode()) .name(node.getFullFileName())