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())