| | |
| | | package com.qianwen.core.oss; |
| | | |
| | | import java.io.IOException; |
| | | import java.io.InputStream; |
| | | import java.util.Date; |
| | | import java.util.List; |
| | | |
| | | import org.springframework.web.multipart.MultipartFile; |
| | | |
| | | import com.qianwen.core.oss.model.BladeFile; |
| | | import com.qianwen.core.oss.model.OssFile; |
| | | import com.qianwen.core.oss.props.OssProperties; |
| | | import com.qianwen.core.oss.rule.OssRule; |
| | | import com.qianwen.core.tool.utils.CollectionUtil; |
| | | import com.qianwen.core.tool.utils.Func; |
| | | import com.qiniu.common.QiniuException; |
| | | import com.qiniu.common.Zone; |
| | | import com.qiniu.http.Response; |
| | |
| | | import com.qiniu.util.Auth; |
| | | import com.qiniu.util.StringMap; |
| | | |
| | | import java.io.IOException; |
| | | import java.io.InputStream; |
| | | import java.util.Date; |
| | | import java.util.List; |
| | | import com.qianwen.core.oss.model.BladeFile; |
| | | import com.qianwen.core.oss.model.OssFile; |
| | | import com.qianwen.core.oss.props.OssProperties; |
| | | import com.qianwen.core.oss.rule.OssRule; |
| | | import com.qianwen.core.tool.utils.CollectionUtil; |
| | | import com.qianwen.core.tool.utils.Func; |
| | | import org.springframework.web.multipart.MultipartFile; |
| | | |
| | | /* loaded from: blade-starter-oss-9.3.0.0-SNAPSHOT.jar:org/springblade/core/oss/QiniuTemplate.class */ |
| | | public class QiniuTemplate implements OssTemplate { |
| | | private final Auth auth; |
| | | private final UploadManager uploadManager; |
| | |
| | | this.ossRule = ossRule; |
| | | } |
| | | |
| | | @Override // com.qianwen.core.oss.OssTemplate |
| | | @Override |
| | | public void makeBucket(String bucketName) { |
| | | try { |
| | | if (!CollectionUtil.contains(this.bucketManager.buckets(), getBucketName(bucketName))) { |
| | |
| | | } |
| | | } |
| | | |
| | | @Override // com.qianwen.core.oss.OssTemplate |
| | | @Override |
| | | public void removeBucket(String bucketName) { |
| | | } |
| | | |
| | | @Override // com.qianwen.core.oss.OssTemplate |
| | | @Override |
| | | public boolean bucketExists(String bucketName) { |
| | | try { |
| | | return CollectionUtil.contains(this.bucketManager.buckets(), getBucketName(bucketName)); |
| | |
| | | } |
| | | } |
| | | |
| | | @Override // com.qianwen.core.oss.OssTemplate |
| | | @Override |
| | | public void copyFile(String bucketName, String fileName, String destBucketName) { |
| | | try { |
| | | this.bucketManager.copy(getBucketName(bucketName), fileName, getBucketName(destBucketName), fileName); |
| | |
| | | } |
| | | } |
| | | |
| | | @Override // com.qianwen.core.oss.OssTemplate |
| | | @Override |
| | | public void copyFile(String bucketName, String fileName, String destBucketName, String destFileName) { |
| | | try { |
| | | this.bucketManager.copy(getBucketName(bucketName), fileName, getBucketName(destBucketName), destFileName); |
| | |
| | | } |
| | | } |
| | | |
| | | @Override // com.qianwen.core.oss.OssTemplate |
| | | @Override |
| | | public OssFile statFile(String fileName) { |
| | | return statFile(this.ossProperties.getBucketName(), fileName); |
| | | } |
| | | |
| | | @Override // com.qianwen.core.oss.OssTemplate |
| | | @Override |
| | | public OssFile statFile(String bucketName, String fileName) { |
| | | try { |
| | | FileInfo stat = this.bucketManager.stat(getBucketName(bucketName), fileName); |
| | |
| | | } |
| | | } |
| | | |
| | | @Override // com.qianwen.core.oss.OssTemplate |
| | | @Override |
| | | public String filePath(String fileName) { |
| | | return getBucketName().concat("/").concat(fileName); |
| | | } |
| | | |
| | | @Override // com.qianwen.core.oss.OssTemplate |
| | | @Override |
| | | public String filePath(String bucketName, String fileName) { |
| | | return getBucketName(bucketName).concat("/").concat(fileName); |
| | | } |
| | | |
| | | @Override // com.qianwen.core.oss.OssTemplate |
| | | @Override |
| | | public String fileLink(String fileName) { |
| | | return this.ossProperties.getEndpoint().concat("/").concat(fileName); |
| | | } |
| | | |
| | | @Override // com.qianwen.core.oss.OssTemplate |
| | | @Override |
| | | public String fileLink(String bucketName, String fileName) { |
| | | return this.ossProperties.getEndpoint().concat("/").concat(fileName); |
| | | } |
| | | |
| | | @Override // com.qianwen.core.oss.OssTemplate |
| | | @Override |
| | | public InputStream getObject(String bucketName, String fileName, Long offset, Long length) { |
| | | return get(bucketName, fileName, offset, length); |
| | | } |
| | | |
| | | @Override // com.qianwen.core.oss.OssTemplate |
| | | @Override |
| | | public InputStream getObject(String fileName, Long offset, Long length) { |
| | | return get(this.ossProperties.getBucketName(), fileName, offset, length); |
| | | } |
| | | |
| | | @Override // com.qianwen.core.oss.OssTemplate |
| | | @Override |
| | | public InputStream getObject(String bucketName, String fileName) { |
| | | return get(bucketName, fileName); |
| | | } |
| | | |
| | | @Override // com.qianwen.core.oss.OssTemplate |
| | | @Override |
| | | public InputStream getObject(String fileName) { |
| | | return get(this.ossProperties.getBucketName(), fileName); |
| | | } |
| | | |
| | | @Override // com.qianwen.core.oss.OssTemplate |
| | | @Override |
| | | public BladeFile putFile(MultipartFile file) { |
| | | return putFile(this.ossProperties.getBucketName(), file.getOriginalFilename(), file); |
| | | } |
| | | |
| | | @Override // com.qianwen.core.oss.OssTemplate |
| | | @Override |
| | | public BladeFile putFile(String fileName, MultipartFile file) { |
| | | return putFile(this.ossProperties.getBucketName(), fileName, file); |
| | | } |
| | | |
| | | @Override // com.qianwen.core.oss.OssTemplate |
| | | @Override |
| | | public BladeFile putFile(String bucketName, String fileName, MultipartFile file) { |
| | | |
| | | try { |
| | |
| | | } |
| | | } |
| | | |
| | | @Override // com.qianwen.core.oss.OssTemplate |
| | | @Override |
| | | public BladeFile putFile(String fileName, InputStream stream) { |
| | | return putFile(this.ossProperties.getBucketName(), fileName, stream); |
| | | } |
| | | |
| | | @Override // com.qianwen.core.oss.OssTemplate |
| | | @Override |
| | | public BladeFile putFile(String bucketName, String fileName, InputStream stream) { |
| | | return put(bucketName, stream, fileName, false); |
| | | } |
| | |
| | | } |
| | | } |
| | | |
| | | @Override // com.qianwen.core.oss.OssTemplate |
| | | @Override |
| | | public void removeFile(String fileName) { |
| | | try { |
| | | this.bucketManager.delete(getBucketName(), fileName); |
| | |
| | | } |
| | | } |
| | | |
| | | @Override // com.qianwen.core.oss.OssTemplate |
| | | @Override |
| | | public void removeFile(String bucketName, String fileName) { |
| | | try { |
| | | this.bucketManager.delete(getBucketName(bucketName), fileName); |
| | |
| | | } |
| | | } |
| | | |
| | | @Override // com.qianwen.core.oss.OssTemplate |
| | | @Override |
| | | public void removeFiles(List<String> fileNames) { |
| | | fileNames.forEach(this::removeFile); |
| | | } |
| | | |
| | | @Override // com.qianwen.core.oss.OssTemplate |
| | | @Override |
| | | public void removeFiles(String bucketName, List<String> fileNames) { |
| | | fileNames.forEach(fileName -> { |
| | | removeFile(getBucketName(bucketName), fileName); |