ak/file
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

阿里云OSS支持集群部署

Browse Source
This commit is contained in:
马超 2021-08-10 14:33:48 +08:00
parent e66d5c31c7
commit 497407a2a8
2 changed files with 16 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pom.xml
View File

@ -6,12 +6,12 @@
<parent> <parent>
<groupId>com.qiwenshare</groupId> <groupId>com.qiwenshare</groupId>
<artifactId>qiwenshare</artifactId> <artifactId>qiwenshare</artifactId>
<version>1.0.6</version> <version>1.0.7</version>
</parent> </parent>
<groupId>com.qiwenshare</groupId> <groupId>com.qiwenshare</groupId>
<artifactId>qiwen-file</artifactId> <artifactId>qiwen-file</artifactId>
<version>1.0.6-SNAPSHOT</version> <version>1.0.7-SNAPSHOT</version>
<name>qiwen-file</name> <name>qiwen-file</name>
<description>fileos.qiwenshare.com</description> <description>fileos.qiwenshare.com</description>
<packaging>jar</packaging> <packaging>jar</packaging>

28
src/main/java/com/qiwenshare/file/service/FiletransferService.java
View File

@ -33,9 +33,10 @@ import com.qiwenshare.file.domain.StorageBean;
import com.qiwenshare.file.mapper.StorageMapper; import com.qiwenshare.file.mapper.StorageMapper;
import com.qiwenshare.file.mapper.UserFileMapper; import com.qiwenshare.file.mapper.UserFileMapper;
import com.qiwenshare.file.vo.file.FileListVo; import com.qiwenshare.file.vo.file.FileListVo;
import com.qiwenshare.ufop.constant.StorageTypeEnum;
import com.qiwenshare.ufop.constant.UploadFileStatusEnum;
import com.qiwenshare.ufop.exception.DownloadException; import com.qiwenshare.ufop.exception.DownloadException;
import com.qiwenshare.ufop.exception.UploadException; import com.qiwenshare.ufop.exception.UploadException;
import com.qiwenshare.ufop.factory.StorageTypeEnum;
import com.qiwenshare.ufop.factory.UFOPFactory; import com.qiwenshare.ufop.factory.UFOPFactory;
import com.qiwenshare.ufop.operation.delete.Deleter; import com.qiwenshare.ufop.operation.delete.Deleter;
import com.qiwenshare.ufop.operation.delete.domain.DeleteFile; import com.qiwenshare.ufop.operation.delete.domain.DeleteFile;
@ -45,6 +46,7 @@ import com.qiwenshare.ufop.operation.preview.Previewer;
import com.qiwenshare.ufop.operation.preview.domain.PreviewFile; import com.qiwenshare.ufop.operation.preview.domain.PreviewFile;
import com.qiwenshare.ufop.operation.upload.Uploader; import com.qiwenshare.ufop.operation.upload.Uploader;
import com.qiwenshare.ufop.operation.upload.domain.UploadFile; import com.qiwenshare.ufop.operation.upload.domain.UploadFile;
import com.qiwenshare.ufop.operation.upload.domain.UploadFileResult;
import com.qiwenshare.ufop.util.PathUtil; import com.qiwenshare.ufop.util.PathUtil;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
@ -86,16 +88,16 @@ public class FiletransferService implements IFiletransferService {
throw new UploadException("上传失败"); throw new UploadException("上传失败");
} }
List<UploadFile> uploadFileList = uploader.upload(request, uploadFile); List<UploadFileResult> uploadFileResultList = uploader.upload(request, uploadFile);
for (int i = 0; i < uploadFileList.size(); i++){ for (int i = 0; i < uploadFileResultList.size(); i++){
uploadFile = uploadFileList.get(i); UploadFileResult uploadFileResult = uploadFileResultList.get(i);
FileBean fileBean = new FileBean(); FileBean fileBean = new FileBean();
BeanUtil.copyProperties(uploadFileDto, fileBean); BeanUtil.copyProperties(uploadFileDto, fileBean);
// fileBean.setTimeStampName(uploadFile.getTimeStampName()); // fileBean.setTimeStampName(uploadFile.getTimeStampName());
if (uploadFile.getSuccess() == 1){ if (UploadFileStatusEnum.SUCCESS.equals(uploadFileResult.getStatus())){
fileBean.setFileUrl(uploadFile.getUrl()); fileBean.setFileUrl(uploadFileResult.getFileUrl());
fileBean.setFileSize(uploadFile.getFileSize()); fileBean.setFileSize(uploadFileResult.getFileSize());
fileBean.setStorageType(uploadFile.getStorageType()); fileBean.setStorageType(uploadFileResult.getStorageType().getCode());
fileBean.setPointCount(1); fileBean.setPointCount(1);
fileMapper.insert(fileBean); fileMapper.insert(fileBean);
UserFile userFile = new UserFile(); UserFile userFile = new UserFile();
@ -109,8 +111,8 @@ public class FiletransferService implements IFiletransferService {
userFile.setFilePath(uploadFileDto.getFilePath()); userFile.setFilePath(uploadFileDto.getFilePath());
} }
userFile.setUserId(userId); userFile.setUserId(userId);
userFile.setFileName(uploadFile.getFileName()); userFile.setFileName(uploadFileResult.getFileName());
userFile.setExtendName(uploadFile.getFileType()); userFile.setExtendName(uploadFileResult.getExtendName());
userFile.setDeleteFlag(0); userFile.setDeleteFlag(0);
userFile.setIsDir(0); userFile.setIsDir(0);
List<FileListVo> userFileList = userFileMapper.userFileList(userFile, null, null); List<FileListVo> userFileList = userFileMapper.userFileList(userFile, null, null);
@ -172,7 +174,6 @@ public class FiletransferService implements IFiletransferService {
ZipOutputStream zos = new ZipOutputStream(csum); ZipOutputStream zos = new ZipOutputStream(csum);
BufferedOutputStream out = new BufferedOutputStream(zos); BufferedOutputStream out = new BufferedOutputStream(zos);
// zos.setComment("");
try { try {
for (UserFile userFile1 : userFileList) { for (UserFile userFile1 : userFileList) {
FileBean fileBean = fileMapper.selectById(userFile1.getFileId()); FileBean fileBean = fileMapper.selectById(userFile1.getFileId());
@ -220,7 +221,7 @@ public class FiletransferService implements IFiletransferService {
e.printStackTrace(); e.printStackTrace();
} }
} }
Downloader downloader = ufopFactory.getDownloader(StorageTypeEnum.LOCAL.getStorageType()); Downloader downloader = ufopFactory.getDownloader(StorageTypeEnum.LOCAL.getCode());
DownloadFile downloadFile = new DownloadFile(); DownloadFile downloadFile = new DownloadFile();
downloadFile.setFileUrl("temp" + File.separator+userFile.getFileName() + ".zip"); downloadFile.setFileUrl("temp" + File.separator+userFile.getFileName() + ".zip");
File tempFile = FileOperation.newFile(PathUtil.getStaticPath() + downloadFile.getFileUrl()); File tempFile = FileOperation.newFile(PathUtil.getStaticPath() + downloadFile.getFileUrl());
@ -245,8 +246,7 @@ public class FiletransferService implements IFiletransferService {
throw new UploadException("预览失败"); throw new UploadException("预览失败");
} }
PreviewFile previewFile = new PreviewFile(); PreviewFile previewFile = new PreviewFile();
String fileUrl = PathUtil.getAliyunObjectNameByFileUrl(fileBean.getFileUrl()); previewFile.setFileUrl(fileBean.getFileUrl());
previewFile.setFileUrl("/" + fileUrl);
previewFile.setFileSize(fileBean.getFileSize()); previewFile.setFileSize(fileBean.getFileSize());
if ("true".equals(previewDTO.getIsMin())) { if ("true".equals(previewDTO.getIsMin())) {
previewer.imageThumbnailPreview(httpServletResponse, previewFile); previewer.imageThumbnailPreview(httpServletResponse, previewFile);