diff --git a/minio-plus-core/src/main/java/org/liuxp/minioplus/core/engine/impl/StorageEngineServiceImpl.java b/minio-plus-core/src/main/java/org/liuxp/minioplus/core/engine/impl/StorageEngineServiceImpl.java index cc4718d..0b2b136 100644 --- a/minio-plus-core/src/main/java/org/liuxp/minioplus/core/engine/impl/StorageEngineServiceImpl.java +++ b/minio-plus-core/src/main/java/org/liuxp/minioplus/core/engine/impl/StorageEngineServiceImpl.java @@ -500,9 +500,10 @@ public class StorageEngineServiceImpl implements StorageEngineService { FileMetadataInfoDTO fileMetadataInfo = new FileMetadataInfoDTO(); fileMetadataInfo.setFileMd5(metadata.getFileMd5()); - List metadataList = metadataRepository.list(fileMetadataInfo); + fileMetadataInfo.setIsFinished(Boolean.TRUE); + FileMetadataInfoVo fileMetadataInfoVo = metadataRepository.one(fileMetadataInfo); - if (CollUtil.isEmpty(metadataList)) { + if (null == fileMetadataInfoVo) { // 当不存在任何该MD5值的文件元数据时,删除物理文件 minioS3Client.removeObject(metadata.getStorageBucket(), metadata.getStoragePath() + "/" + metadata.getFileMd5()); if (Boolean.TRUE.equals(metadata.getIsPreview())) { @@ -524,9 +525,9 @@ public class StorageEngineServiceImpl implements StorageEngineService { FileMetadataInfoDTO fileMetadataInfo = new FileMetadataInfoDTO(); fileMetadataInfo.setFileKey(fileKey); // 取得md5元数据 - List fileMetadataInfoVoList = metadataRepository.list(fileMetadataInfo); + FileMetadataInfoVo fileMetadataInfoVo = metadataRepository.one(fileMetadataInfo); - for (FileMetadataInfoVo fileMetadataInfoVo : fileMetadataInfoVoList) { + if ( null!= fileMetadataInfoVo ) { if (Boolean.FALSE.equals(fileMetadataInfoVo.getIsPrivate()) || fileMetadataInfoVo.getCreateUser().equals(userId)) { return fileMetadataInfoVo; }