基于springboot的网盘服务端 私有云存储网盘项目，能够简单安全管理您的云端文件+源代码+文档说明

package com.jmal.clouddisk.service.impl; import cn.hutool.core.codec.Base64; import cn.hutool.core.convert.Convert; import cn.hutool.core.io.FileUtil; import cn.hutool.core.io.file.PathUtil; import cn.hutool.core.text.CharSequenceUtil; import cn.hutool.core.thread.ThreadUtil; import cn.hutool.core.util.BooleanUtil; import cn.hutool.core.util.ReUtil; import cn.hutool.core.util.StrUtil; import cn.hutool.crypto.SecureUtil; import cn.hutool.crypto.symmetric.AES; import com.jmal.clouddisk.exception.CommonException; import com.jmal.clouddisk.exception.ExceptionType; import com.jmal.clouddisk.interceptor.AuthInterceptor; import com.jmal.clouddisk.model.*; import com.jmal.clouddisk.model.rbac.ConsumerDO; import com.jmal.clouddisk.oss.web.WebOssCommonService; import com.jmal.clouddisk.oss.web.WebOssCopyFileService; import com.jmal.clouddisk.oss.web.WebOssService; import com.jmal.clouddisk.service.Constants; import com.jmal.clouddisk.service.IFileService; import com.jmal.clouddisk.service.IFileVersionService; import com.jmal.clouddisk.service.video.VideoProcessService; import com.jmal.clouddisk.util.*; import com.jmal.clouddisk.webdav.MyWebdavServlet; import com.mongodb.client.AggregateIterable; import jakarta.servlet.http.HttpServletRequest; import jakarta.servlet.http.HttpServletResponse; import lombok.extern.slf4j.Slf4j; import org.apache.catalina.connector.ClientAbortException; import org.apache.commons.compress.utils.Lists; import org.apache.tika.mime.MimeType; import org.apache.tika.mime.MimeTypeException; import org.apache.tika.mime.MimeTypes; import org.bson.BsonNull; import org.bson.Document; import org.bson.conversions.Bson; import org.jetbrains.annotations.NotNull; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.domain.Sort; import org.springframework.data.mongodb.core.query.Criteria; import org.springframework.data.mongodb.core.query.Query; import org.springframework.data.mongodb.core.query.Update; import org.springframework.stereotype.Service; import org.springframework.web.multipart.MultipartFile; import org.springframework.web.servlet.mvc.method.annotation.StreamingResponseBody; import javax.imageio.ImageIO; import java.awt.image.BufferedImage; import java.io.*; import java.net.URLEncoder; import java.nio.charset.Charset; import java.nio.charset.StandardCharsets; import java.nio.file.Files; import java.nio.file.Path; import java.nio.file.Paths; import java.time.LocalDateTime; import java.util.ArrayList; import java.util.Arrays; import java.util.List; import java.util.Optional; import static com.jmal.clouddisk.service.IUserService.USER_ID; import static com.mongodb.client.model.Accumulators.sum; import static com.mongodb.client.model.Aggregates.group; import static com.mongodb.client.model.Aggregates.match; import static com.mongodb.client.model.Filters.*; /** * @author jmal * @Description 文件管理 * @Author jmal * @Date 2020-01-14 13:05 */ @Service @Slf4j public class FileServiceImpl extends CommonFileService implements IFileService { @Autowired MultipartUpload multipartUpload; @Autowired WebOssService webOssService; @Autowired WebOssCopyFileService webOssCopyFileService; @Autowired VideoProcessService videoProcessService; @Autowired IFileVersionService fileVersionService; /*** * 前端文件夹树的第一级的文件Id */ private static final String FIRST_FILE_TREE_ID = "0"; private static final AES aes = SecureUtil.aes(); @Override public ResponseResult<Object> listFiles(UploadApiParamDTO upload) throws CommonException { ResponseResult<Object> result = ResultUtil.genResult(); Path path = Paths.get(upload.getUsername(), upload.getCurrentDirectory()); String ossPath = CaffeineUtil.getOssPath(path); if (ossPath != null) { return webOssService.searchFileAndOpenOssFolder(path, upload); } String currentDirectory = getUserDirectory(upload.getCurrentDirectory()); if (!CharSequenceUtil.isBlank(upload.getFolder()) && checkMountParam(upload, currentDirectory)) { return listFiles(upload); } Criteria criteria; String queryFileType = upload.getQueryFileType(); if (!CharSequenceUtil.isBlank(queryFileType)) { criteria = switch (upload.getQueryFileType()) { case Constants.AUDIO -> Criteria.where(Constants.CONTENT_TYPE).regex("^" + Constants.AUDIO); case Constants.VIDEO -> Criteria.where(Constants.CONTENT_TYPE).regex("^" + Constants.VIDEO); case Constants.CONTENT_TYPE_IMAGE -> Criteria.where(Constants.CONTENT_TYPE).regex("^image"); case "text" -> Criteria.where(Constants.SUFFIX).in(Arrays.asList(fileProperties.getSimText())); case "document" -> Criteria.where(Constants.SUFFIX).in(Arrays.asList(fileProperties.getDocument())); default -> Criteria.where("path").is(currentDirectory); }; } else { criteria = Criteria.where("path").is(currentDirectory); Boolean isFolder = upload.getIsFolder(); if (isFolder != null) { criteria = Criteria.where(Constants.IS_FOLDER).is(isFolder); } Boolean isFavorite = upload.getIsFavorite(); if (isFavorite != null) { criteria = Criteria.where(Constants.IS_FAVORITE).is(isFavorite); } } List<FileIntroVO> list = getFileDocuments(upload, criteria); result.setData(list); result.setCount(getFileDocumentsCount(upload, criteria)); return result; } /** * 查看是否有挂载文件 * @param upload 上传参数 * @param currentDirectory 当前目录 * @return 是否有挂载文件 */ private boolean checkMountParam(UploadApiParamDTO upload, String currentDirectory) { if (!CharSequenceUtil.isBlank(currentDirectory)) { Path currentDirectoryPath = Paths.get(currentDirectory); if (currentDirectoryPath.getFileName() == null) { return false; } String fileId = upload.getFolder(); FileDocument fileDocument = getById(fileId); if (fileDocument != null) { upload.setUserId(fileDocument.getUserId()); upload.setUsername(userService.getUserNameById(fileDocument.getUserId())); upload.setCurrentDirectory(fileDocument.getPath() + fileDocument.getName()); upload.setFolder(null); return true; } } return false; } @Override public long takeUpSpace(String userId) throws CommonException { return occupiedSpace(userId); } /*** * 通过查询条件获取文件数 * @param upload UploadApiParamDTO * @param criteriaList criteriaList * @return 文件数 */ private long getFileDocumentsCount(UploadApiParamDTO upload, Criteria... criteriaList) { Query query = new Query(); query.addCriteria(Criteria.where(USER_ID).is(upload.getUserId())); for (Criteria criteria : criteriaList) { query.addCriteria(criteria); } return mongoTemplate.count(query, COLLECTION_NAME); } private List<FileIntroVO> getFileDocuments(UploadApiParamDTO upload, Criteria... criteriaList) { List<FileIntroVO> fileIntroVOList; Query query = getQuery(upload, criteriaList); String order = listByPage(upload, query); if (!CharSequenceUtil.isBlank(order)) { String sortableProp = upload.getSortableProp(); Sort.Direction direction = Sort.Direction.ASC; if ("descending".equals(order)) { direction = Sort.Direction.DESC; } query.with(Sort.by(direction, sortableProp)); } else {