基于Java的R-Pan文件管理系统设计源码

package com.rubin.rpan.services.modules.file.service.impl; import com.google.common.collect.Lists; import com.rubin.rpan.services.common.constant.CommonConstant; import com.rubin.rpan.services.common.exception.RPanException; import com.rubin.rpan.services.common.response.ResponseCode; import com.rubin.rpan.services.modules.file.bo.FilePositionBO; import com.rubin.rpan.services.modules.file.constant.FileConstant; import com.rubin.rpan.services.modules.file.dao.RPanUserFileMapper; import com.rubin.rpan.services.modules.file.entity.RPanFile; import com.rubin.rpan.services.modules.file.entity.RPanUserFile; import com.rubin.rpan.services.modules.file.service.IFileService; import com.rubin.rpan.services.modules.file.service.IUserFileService; import com.rubin.rpan.services.modules.file.vo.*; import com.rubin.rpan.services.modules.share.service.IShareService; import com.rubin.rpan.services.modules.user.service.IUserSearchHistoryService; import com.rubin.rpan.storage.StorageManager; import com.rubin.rpan.util.FileUtil; import com.rubin.rpan.util.HttpUtil; import com.rubin.rpan.util.IdGenerator; import com.rubin.rpan.util.StringListUtil; import com.rubin.rpan.util.file.type.context.FileTypeContext; import org.apache.commons.collections.CollectionUtils; import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Propagation; import org.springframework.transaction.annotation.Transactional; import org.springframework.web.multipart.MultipartFile; import javax.servlet.http.HttpServletResponse; import java.io.UnsupportedEncodingException; import java.util.*; import java.util.stream.Collectors; /** * 用户文件业务处理实现 * Created by RubinChu on 2021/1/22 下午 4:11 */ @Service(value = "userFileService") @Transactional(rollbackFor = Exception.class, propagation= Propagation.SUPPORTS) public class UserFileServiceImpl implements IUserFileService { private static final Logger log = LoggerFactory.getLogger(UserFileServiceImpl.class); @Autowired @Qualifier(value = "rPanUserFileMapper") private RPanUserFileMapper rPanUserFileMapper; @Autowired @Qualifier(value = "fileService") private IFileService iFileService; @Autowired @Qualifier(value = "userSearchHistoryService") private IUserSearchHistoryService iUserSearchHistoryService; @Autowired @Qualifier(value = "shareService") private IShareService iShareService; @Autowired @Qualifier(value = "storageManager") private StorageManager storageManager; /** * 获取文件列表 * * @param parentId * @param fileTypes * @param userId * @return */ @Override public List<RPanUserFileVO> list(Long parentId, String fileTypes, Long userId) { return list(parentId, fileTypes, userId, FileConstant.DelFlagEnum.NO.getCode()); } /** * 获取文件列表 * * @param parentId * @param fileTypes * @param userId * @param delFlag * @return */ @Override public List<RPanUserFileVO> list(Long parentId, String fileTypes, Long userId, Integer delFlag) { List<Integer> fileTypeArray = null; if (Objects.equals(CommonConstant.ZERO_LONG, parentId)) { return Lists.newArrayList(); } if (!Objects.equals(fileTypes, FileConstant.ALL_FILE_TYPE)) { fileTypeArray = StringListUtil.string2IntegerList(fileTypes); } return rPanUserFileMapper.selectRPanUserFileVOListByUserIdAndFileTypeAndParentIdAndDelFlag(userId, fileTypeArray, parentId, delFlag); } /** * 获取文件列表 * * @param fileIds * @return */ @Override public List<RPanUserFileVO> list(String fileIds) { return rPanUserFileMapper.selectRPanUserFileVOListByFileIdList(StringListUtil.string2LongList(fileIds)); } /** * 创建文件夹 * * @param parentId * @param folderName * @param userId */ @Override public void createFolder(Long parentId, String folderName, Long userId) { saveUserFile(parentId, folderName, FileConstant.FolderFlagEnum.YES, null, null, userId, null); } /** * 文件重命名 * * @param fileId * @param newFilename * @param userId */ @Override public void updateFilename(Long fileId, String newFilename, Long userId) { RPanUserFile originalUserFileInfo = getRPanUserFileByFileIdAndUserId(fileId, userId); if (Objects.equals(originalUserFileInfo.getFilename(), newFilename)) { throw new RPanException("请使用一个新名称"); } if (rPanUserFileMapper.selectCountByUserIdAndFilenameAndParentId(userId, newFilename, originalUserFileInfo.getParentId()) > CommonConstant.ZERO_INT) { throw new RPanException("名称已被占用"); } originalUserFileInfo.setFilename(newFilename); originalUserFileInfo.setUpdateUser(userId); originalUserFileInfo.setUpdateTime(new Date()); if (rPanUserFileMapper.updateByPrimaryKeySelective(originalUserFileInfo) != CommonConstant.ONE_INT) { throw new RPanException("文件重命名失败"); } } /** * 删除文件(批量) * * @param fileIds * @param userId */ @Override public void delete(String fileIds, Long userId) { List<Long> idList = StringListUtil.string2LongList(fileIds); if (rPanUserFileMapper.deleteBatch(idList, userId) != idList.size()) { throw new RPanException("删除失败"); } iShareService.refreshShareStatus(getAllAvailableFileIdByFileIds(fileIds)); } /** * 文件上传 * * @param file * @param parentId * @param identifier * @param totalSize */ @Override public void upload(MultipartFile file, Long parentId, Long userId, String identifier, Long totalSize, String filename) { RPanFile rPanFile = uploadRealFile(file, userId, identifier, totalSize, FileUtil.getFileSuffix(filename)); saveUserFile(parentId, filename, FileConstant.FolderFlagEnum.NO, FileTypeContext.getFileTypeCode(filename), rPanFile.getFileId(), userId, rPanFile.getFileSizeDesc()); } /** * 文件分片上传 * * @param file * @param userId * @param identifier * @param totalChunks * @param chunkNumber * @param totalSize * @param filename * @return */ @Override public FileChunkUploadVO uploadWithChunk(MultipartFile file, Long userId, String identifier, Integer totalChunks, Integer chunkNumber, Long totalSize, String filename) { FileChunkUploadVO fileChunkUploadVO = new FileChunkUploadVO(); fileChunkUploadVO.setMergeFlag(FileConstant.MergeFlag.NOT_READY.getCode()); if (iFileService.saveWithChunk(file, userId, identifier, totalChunks, chunkNumber, totalSize, filename)) { fileChunkUploadVO.setMergeFlag(FileConstant.MergeFlag.READY.getCode()); } return fileChunkUploadVO; } /** * 文件下载 * * @param fileId * @param response * @param userId */ @Override public void download(Long fileId, HttpServletResponse response, Long userId) { try { getRPanUserFileByFileIdAndUserId(fileId, userId); } catch (RPanException e) { throw new RPanException("您没有下载权限"); } download(fileId, response); } /** * 文件下载 * * @param fileId * @param response */ @Override public void download(Long fileId, HttpServletResponse response) { if (checkIsFolder(fileId)) { throw new RPanException("不能选择�