REQ-3540: 更新文件大小

This commit is contained in:
yanglin 2025-03-21 14:16:37 +08:00
parent ff1cd0c47b
commit 61d1511493
2 changed files with 10 additions and 6 deletions

View File

@ -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<Boolean> deleteOssFile = Ref.create(false);
try {

View File

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