用时分析代码整理+注释整理

yangys

2024-04-28 258a769f6790f832d1c67839d59be04a118767e5

 smart-man-boot/src/main/java/com/qianwen/smartman/modules/dnc/service/impl/FileServiceImpl.java

@@ -73,7 +73,6 @@
import lombok.NonNull;

@Service
/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/dnc/service/impl/FileServiceImpl.class */
public class FileServiceImpl extends BaseServiceImpl<FileMapper, File> implements IFileService {
    @Autowired
    private FileMapper fileMapper;
@@ -90,10 +89,10 @@
    private IObsFileService obsFileService;


    @Override // org.springblade.modules.dnc.service.IFileService
    @Override 
    @Transactional(rollbackFor = {Exception.class})
    public List<UploadFileOssVO> batchSave(BladeUser user, List<UploadFileOssVO> list, Integer operationType, Integer sourceType) {
        return (List) list.stream().peek(createFileDto -> {
        return list.stream().peek(createFileDto -> {
            String hash;
            OssFile fileDto = createFileDto.getOssFile();
            if (Func.isNotBlank(fileDto.getName())) {
@@ -161,7 +160,7 @@
        }).collect(Collectors.toList());
    }

    @Override // org.springblade.modules.dnc.service.IFileService
    @Override 
    public List<FolderTreeVO> folderTreeList(final Long userId) {
       List<File> list = list(Lambda.eq(File::getOwner, userId).eq(File::getFileType, 
                 Integer.valueOf(FileType.FOLDER.getValue())));
@@ -169,29 +168,16 @@
       return ForestNodeMerger.merge(list.stream().map(FileConvert.INSTANCE::convertToFolderTreeVO)
               .peek(vo -> vo.setGroup((vo.getParentId().longValue() == 0L || vo.getId().longValue() == 0L)))
               .collect(Collectors.toList()));
       /*
        List<File> list = list((Wrapper) Lambda.eq((v0) -> {
            return v0.getOwner();
        }, userId).eq((v0) -> {
            return v0.getFileType();
        }, Integer.valueOf(FileType.FOLDER.getValue())));
        
        Stream<File> stream = list.stream();
        FileConvert fileConvert = FileConvert.INSTANCE;
        fileConvert.getClass();
        return ForestNodeMerger.merge((List) stream.map(this::convertToFolderTreeVO).peek(vo -> {
            vo.setGroup(vo.getParentId().longValue() == 0 || vo.getId().longValue() == 0);
        }).collect(Collectors.toList()));*/
    }

    @Override // org.springblade.modules.dnc.service.IFileService
    @Override 
    public List<File> findFolderList(Long userId, String id) {
       LambdaQueryWrapper<File> query = Wrappers.<File>query().lambda().eq(File::getOwner, userId).eq(File::getParentId, id).eq(File::getFileType, Integer.valueOf(FileType.FOLDER.getValue()));
       
        return this.baseMapper.selectList(query);
    }

    @Override // org.springblade.modules.dnc.service.IFileService
    @Override 
    @Transactional(rollbackFor = {Exception.class})
    public Long createFolder(BladeUser user, NewFolderVO vo) {
        vo.setFileType(FileType.FOLDER);
@@ -207,11 +193,11 @@
        }).orElse(null);
    }

    @Override // org.springblade.modules.dnc.service.IFileService
    @Override 
    public FolderListVO list(Long userId, Long parent, String searchKey) {
        String parentName = getParentName(parent);
        Collection<File> fileList = findFiles(userId, parent, searchKey);
        Collection<FolderVO> folderDtoList = (Collection) fileList.stream().filter(f -> {
        Collection<FolderVO> folderDtoList = fileList.stream().filter(f -> {
            return f.getFileType().intValue() == FileType.FOLDER.getValue();
        }).map(f2 -> {
            FolderVO dto = FileConvert.INSTANCE.convertToFolderVO(f2);
@@ -223,7 +209,7 @@
            dto.setCreateUserName(Func.isNotEmpty(updateUser) ? updateUser.getAccount() : "");
            return dto;
        }).collect(Collectors.toList());
        Collection<FileVO> fileVOList = (Collection) fileList.stream().filter(f3 -> {
        Collection<FileVO> fileVOList = fileList.stream().filter(f3 -> {
            return f3.getFileType().intValue() == FileType.FILE.getValue();
        }).map(f4 -> {
            FileVO dto = FileConvert.INSTANCE.convert(f4);
@@ -288,7 +274,7 @@
        }
    }

    @Override // org.springblade.modules.dnc.service.IFileService
    @Override 
    public void updateAllPath(File file, Long parentId) {
        Optional<File> parentFile = (parentId == null || parentId.longValue() == -1) ? Optional.empty() : Optional.of(getById(parentId));
        String parentPath = (String) parentFile.map((v0) -> {
@@ -299,14 +285,14 @@
        updateById(file);
    }

    @Override // org.springblade.modules.dnc.service.IFileService
    @Override 
    public Long createFile(Long userId, CreateFileVO createFileVO) {
        OssFile ossFile = createFileVO.getOssFile();
        File file = File.builder().fileType(Integer.valueOf(FileType.FILE.getValue())).owner(userId).objectKey(ossFile.getName()).parentId(createFileVO.getTargetId()).contentMd5(ossFile.getHash()).displayName(createFileVO.getOriginalName()).contentType(ossFile.getContentType()).contentLength(Long.valueOf(ossFile.getLength())).suffix(DncConstant.SUFFIX).isCurrent(true).link(createFileVO.getOssFile().getLink()).build();
        return saveFile(userId, createFileVO.getTargetId(), file, DncEnums.LogOperationType.UPLOAD.getCode(), DncEnums.FileSource.MY_DOCUMENTS.getCode(), null, null);
    }

    @Override // org.springblade.modules.dnc.service.IFileService
    @Override 
    public Long saveFile(Long userId, Long parentId, File file, Integer operationType, Integer sourceType, String sourcePathId, String sourcePathName) {
        file.setParentId(parentId);
        file.changeParent(parentId);
@@ -352,7 +338,7 @@
        });
    }

    @Override // org.springblade.modules.dnc.service.IFileService
    @Override 
    @Transactional(rollbackFor = {Exception.class})
    public void updateFile(UpdateFileVO updateFileVO) {
        File file = (File) getById(updateFileVO.getFileId());
@@ -363,7 +349,7 @@
        saveOperationLog(AuthUtil.getUser(), file, DncEnums.LogOperationType.TO_UPDATE.getCode(), DncEnums.FileSource.MY_DOCUMENTS.getCode(), null, null);
    }

    @Override // org.springblade.modules.dnc.service.IFileService
    @Override 
    @Transactional(rollbackFor = {Exception.class})
    public void delete(DeleteFileVO deleteFileVO) {
        deleteFileVO.getSourceIdList().forEach(id -> {
@@ -393,7 +379,7 @@
        return new PathDto(allPath, allPathName);
    }

    @Override // org.springblade.modules.dnc.service.IFileService
    @Override 
    @Transactional(rollbackFor = {Exception.class})
    public void move(ChangeFileParentVO changeFileParentVO) {
        changeFileParentVO.getSourceIdList().forEach(source -> {
@@ -513,7 +499,7 @@
        }
    }

    @Override // org.springblade.modules.dnc.service.IFileService
    @Override 
    @Transactional(rollbackFor = {Exception.class})
    public void copy(ChangeFileParentVO changeFileParentVO) {
        changeFileParentVO.getSourceIdList().forEach(source -> {
@@ -572,7 +558,7 @@
        });
    }

    @Override // org.springblade.modules.dnc.service.IFileService
    @Override 
    @Transactional(rollbackFor = {Exception.class})
    public void rename(Long id, RenameVO renameVO) {
        String newName = renameVO.getNewName();
@@ -587,7 +573,7 @@
        saveOperationLog(AuthUtil.getUser(), file, DncEnums.LogOperationType.TO_UPDATE.getCode(), DncEnums.LogFileSourceType.MY_DOCUMENTS.getCode(), pathDto.getAllPathId(), pathDto.getAllPathName());
    }

    @Override // org.springblade.modules.dnc.service.IFileService
    @Override 
    public List<String> duplicateName(List<UploadFileOssVO> uploadFileOssVOList) {
        List<String> collect = new ArrayList<>();
        uploadFileOssVOList.forEach(file -> {
@@ -625,7 +611,7 @@
        return collect;
    }

    @Override // org.springblade.modules.dnc.service.IFileService
    @Override 
    public List<FileHistoryVO> history(Long pid, String name) {
       List<File> fileList = list(Wrappers.<File>lambdaQuery().eq(File::getParentId, pid)
               .eq(File::getDisplayName, name).eq(File::getOwner, AuthUtil.getUser().getUserId()).orderByDesc(File::getIsCurrent).orderByDesc(File::getVersion));
@@ -660,7 +646,7 @@
        return fileHistoryVOList;
    }

    @Override // org.springblade.modules.dnc.service.IFileService
    @Override 
    @Transactional(rollbackFor = {Exception.class})
    public Boolean changeVersion(Long oldId, Long newId) {
        File oldFile = (File) getById(oldId);
@@ -672,7 +658,7 @@
        return true;
    }

    @Override // org.springblade.modules.dnc.service.IFileService
    @Override 
    public IPage<FileVO> page(Long userId, Long parent, Integer fileType, String searchKey, Query query) {
       // Wrapper wrapper;
        List<String> suffix = new ArrayList<>();
@@ -735,7 +721,7 @@
        return fileVOIPage;
    }

    @Override // org.springblade.modules.dnc.service.IFileService
    @Override 
    public List<String> getSuffix() {
        String value = ParamCache.getValue(CommonConstant.FILE_SUFFIX_KEY);
        List<String> suffixList = new ArrayList<>();
@@ -752,7 +738,7 @@
    }

    /* JADX WARN: Multi-variable type inference failed */
    @Override // org.springblade.modules.dnc.service.IFileService
    @Override 
    public IPage<FileVO> filePage(Long userId, Long parent, Integer fileType, String searchKey, Query query) {
        List<String> suffix = new ArrayList<>();
        boolean result = false;
@@ -825,7 +811,7 @@
        return fileVOIPage;
    }

    @Override // org.springblade.modules.dnc.service.IFileService
    @Override 
    public FileSourcePathVO getFileSourcePath(String fileId) {
        FileSourcePathVO fileSourcePathVO = new FileSourcePathVO();
        if (Func.isNotBlank(fileId)) {
@@ -856,7 +842,7 @@
        return fileSourcePathVO;
    }

    @Override // org.springblade.modules.dnc.service.IFileService
    @Override 
    public Boolean existsFile(DeleteFileVO deleteFileVO) {
        List<File> fileList = new ArrayList<>();
        deleteFileVO.getSourceIdList().forEach(id -> {