REQ-3540: 更新文件大小

This commit is contained in:
yanglin 2025-03-21 15:22:25 +08:00
parent 49f687859c
commit 884989f61f

View File

@ -56,6 +56,8 @@ import cn.azxo.framework.common.model.Page;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import javax.annotation.Nullable;
/** /**
* @author yanglin * @author yanglin
*/ */
@ -118,7 +120,7 @@ public class FileDatabaseService {
asyncUtils.getOrTimeout(future, "激活"); asyncUtils.getOrTimeout(future, "激活");
} }
private Future<?> asyncCopySubtree(FileDatabase db, IndexNode templateRoot, Runnable nullablePostProcessor) { private Future<?> asyncCopySubtree(FileDatabase db, IndexNode templateRoot, @Nullable Runnable postProcessor) {
return indexManager.async(() -> { return indexManager.async(() -> {
// don't inline in transaction // don't inline in transaction
CopiedOssFiles copiedOssFiles = indexManager.copySubtreeOssFiles(templateRoot); CopiedOssFiles copiedOssFiles = indexManager.copySubtreeOssFiles(templateRoot);
@ -129,8 +131,8 @@ public class FileDatabaseService {
indexManager.copySubTree(templateRoot, null, new SetScopeCopyFileVisitor(copiedOssFiles, db)); indexManager.copySubTree(templateRoot, null, new SetScopeCopyFileVisitor(copiedOssFiles, db));
fileDatabaseDao.updateState(db.getCode(), FileDatabaseState.ACTIVATED); fileDatabaseDao.updateState(db.getCode(), FileDatabaseState.ACTIVATED);
fileDatabaseDao.setPurchaseTime(db.getCode(), new Date()); fileDatabaseDao.setPurchaseTime(db.getCode(), new Date());
if (nullablePostProcessor != null) if (postProcessor != null)
nullablePostProcessor.run(); postProcessor.run();
}); });
}); });
} }