opensource/RuoYi-Vue-Plus
2
0
Fork 1
mirror of https://gitee.com/dromara/RuoYi-Vue-Plus.git synced 2026-09-21 02:25:56 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

update oss工具优化报错信息

Browse Source
This commit is contained in:
AprilWind 2024-04-15 12:37:47 +08:00
parent 95a97ab06c
commit bd8994f0de
1 changed files with 33 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

52
ruoyi-common/ruoyi-common-oss/src/main/java/org/dromara/common/oss/core/OssClient.java
View File

@ -1,5 +1,6 @@
package org.dromara.common.oss.core; package org.dromara.common.oss.core;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.io.IoUtil; import cn.hutool.core.io.IoUtil;
import cn.hutool.core.util.IdUtil; import cn.hutool.core.util.IdUtil;
import org.dromara.common.core.constant.Constants; import org.dromara.common.core.constant.Constants;
@ -326,12 +327,17 @@ public class OssClient {
* @return 包含上传 ID 的 UploadResult 对象 * @return 包含上传 ID 的 UploadResult 对象
*/ */
public UploadResult initiateMultipartUpload(String key) { public UploadResult initiateMultipartUpload(String key) {
String uploadId = client.createMultipartUpload( try {
x -> x.bucket(properties.getBucketName()) String uploadId = client.createMultipartUpload(
.key(key) x -> x.bucket(properties.getBucketName())
.build() .key(key)
).join().uploadId(); .build()
return UploadResult.builder().url(getUrl() + StringUtils.SLASH + key).filename(key).uploadId(uploadId).build(); ).join().uploadId();
return UploadResult.builder().url(getUrl() + StringUtils.SLASH + key).filename(key).uploadId(uploadId).build();
} catch (Exception e) {
// 捕获异常并抛出自定义异常
throw new OssException("创建分片上传任务失败，请检查配置信息:[" + e.getMessage() + "]");
}
} }
/** /**
@ -367,19 +373,24 @@ public class OssClient {
* @return 包含分片上传结果信息的 PartUploadResult 对象列表 * @return 包含分片上传结果信息的 PartUploadResult 对象列表
*/ */
public List<PartUploadResult> listParts(String key, String uploadId, Integer maxParts, Integer partNumberMarker) { public List<PartUploadResult> listParts(String key, String uploadId, Integer maxParts, Integer partNumberMarker) {
List<Part> parts = client.listParts( try {
x -> x.bucket(properties.getBucketName()) List<Part> parts = client.listParts(
.key(key) x -> x.bucket(properties.getBucketName())
.uploadId(uploadId) .key(key)
.maxParts(maxParts != null ? maxParts : 1000) .uploadId(uploadId)
.partNumberMarker(partNumberMarker != null ? partNumberMarker : 0) .maxParts(maxParts != null ? maxParts : 1000)
.build()).join().parts(); .partNumberMarker(partNumberMarker != null ? partNumberMarker : 0)
return parts.stream() .build()).join().parts();
.map(x -> PartUploadResult.builder() return parts.stream()
.partNumber(x.partNumber()) .map(x -> PartUploadResult.builder()
.eTag(x.eTag()) .partNumber(x.partNumber())
.build()) .eTag(x.eTag())
.collect(Collectors.toList()); .build())
.collect(Collectors.toList());
} catch (Exception e) {
// 捕获异常并抛出自定义异常
throw new OssException("获取分片列表失败，请检查配置信息:[" + e.getMessage() + "]");
}
} }
/** /**
@ -391,6 +402,9 @@ public class OssClient {
* @return 包含上传结果信息的 UploadResult 对象 * @return 包含上传结果信息的 UploadResult 对象
*/ */
public UploadResult completeMultipartUpload(String key, String uploadId, List<PartUploadResult> partUploadResults) { public UploadResult completeMultipartUpload(String key, String uploadId, List<PartUploadResult> partUploadResults) {
if (CollUtil.isEmpty(partUploadResults)) {
throw new OssException("分片列表不能为空");
}
List<CompletedPart> completedParts = partUploadResults.stream() List<CompletedPart> completedParts = partUploadResults.stream()
.map(x -> CompletedPart.builder() .map(x -> CompletedPart.builder()
.partNumber(x.getPartNumber()) .partNumber(x.getPartNumber())