Commit ed1da72701aa73694453374f88d5962cce833781
1 parent
0687f858
feat: oss 信息配置
Showing
4 changed files
with
71 additions
and
27 deletions
src/main/java/com/order/erp/common/utils/AliOssUtil.java
... | ... | @@ -6,6 +6,9 @@ import com.aliyun.oss.model.Bucket; |
6 | 6 | import com.aliyun.oss.model.CreateBucketRequest; |
7 | 7 | import com.aliyun.oss.model.PutObjectRequest; |
8 | 8 | import com.aliyun.oss.model.PutObjectResult; |
9 | +import com.order.erp.config.AliOssConfig; | |
10 | +import lombok.extern.slf4j.Slf4j; | |
11 | +import org.springframework.stereotype.Service; | |
9 | 12 | |
10 | 13 | import java.io.ByteArrayInputStream; |
11 | 14 | import java.util.Date; |
... | ... | @@ -18,37 +21,16 @@ import java.util.Random; |
18 | 21 | * @date: 2023/10/30 18:24 |
19 | 22 | * @version: 1.0 |
20 | 23 | */ |
24 | +@Slf4j | |
21 | 25 | public class AliOssUtil { |
22 | 26 | |
23 | - | |
24 | - | |
25 | - /** | |
26 | - * oss 地址 | |
27 | - */ | |
28 | - private static final String endpoint = "https://oss-cn-qingdao.aliyuncs.com"; | |
29 | - | |
30 | - /** | |
31 | - * 进入阿里oss获取产品key值 | |
32 | - */ | |
33 | - private static final String accessKeyId = "LTAIZCPI7OaWud0m"; | |
34 | - | |
35 | - /** | |
36 | - * key值对应密码 | |
37 | - */ | |
38 | - private static final String accessKeySecret = "nvtGeScBwRztGeoj8WSp5OWalalgpK"; | |
39 | - | |
40 | - /** | |
41 | - * 存储上传文件的容器 | |
42 | - */ | |
43 | - public static final String BUCKET = "order-erp"; | |
44 | - | |
45 | 27 | /** |
46 | 28 | * oss 客户端 |
47 | 29 | */ |
48 | 30 | private static OSS client; |
49 | 31 | |
50 | 32 | static { |
51 | - client = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret); | |
33 | + client = new OSSClientBuilder().build(AliOssConfig.ALIYUN_ENDPOINT, AliOssConfig.ALIYUN_ACCESS_ID, AliOssConfig.ALIYUN_ACCESS_KEY); | |
52 | 34 | } |
53 | 35 | |
54 | 36 | /** | ... | ... |
src/main/java/com/order/erp/config/AliOssConfig.java
0 → 100644
1 | +package com.order.erp.config; | |
2 | + | |
3 | +import org.springframework.beans.factory.InitializingBean; | |
4 | +import org.springframework.beans.factory.annotation.Value; | |
5 | +import org.springframework.context.annotation.Configuration; | |
6 | + | |
7 | +/** | |
8 | + * @author: xms | |
9 | + * @description: TODO | |
10 | + * @date: 2023/10/31 16:33 | |
11 | + * @version: 1.0 | |
12 | + */ | |
13 | + | |
14 | +@Configuration | |
15 | +public class AliOssConfig implements InitializingBean { | |
16 | + | |
17 | + /** | |
18 | + * oss 地址 | |
19 | + */ | |
20 | + @Value("${oss.endpoint}") | |
21 | + private String endpoint; | |
22 | + | |
23 | + /** | |
24 | + * 进入阿里oss获取产品key值 | |
25 | + */ | |
26 | + @Value("${oss.accessKeyId}") | |
27 | + private String accessKeyId; | |
28 | + | |
29 | + /** | |
30 | + * key值对应密码 | |
31 | + */ | |
32 | + @Value("${oss.accessKeySecret}") | |
33 | + private String accessKeySecret; | |
34 | + | |
35 | + /** | |
36 | + * 存储上传文件的容器 | |
37 | + */ | |
38 | + @Value("${oss.bucket}") | |
39 | + public String bucket; | |
40 | + | |
41 | + //声明静态变量 | |
42 | + public static String ALIYUN_ENDPOINT; | |
43 | + public static String ALIYUN_ACCESS_ID; | |
44 | + public static String ALIYUN_ACCESS_KEY; | |
45 | + public static String ALIYUN_BUCKET; | |
46 | + | |
47 | + @Override | |
48 | + public void afterPropertiesSet() throws Exception { | |
49 | + ALIYUN_ENDPOINT = endpoint; | |
50 | + ALIYUN_ACCESS_ID = accessKeyId; | |
51 | + ALIYUN_ACCESS_KEY = accessKeySecret; | |
52 | + ALIYUN_BUCKET = bucket; | |
53 | + } | |
54 | +} | ... | ... |
src/main/java/com/order/erp/service/impl/LocalStorageServiceImpl.java
... | ... | @@ -12,6 +12,7 @@ import com.order.erp.common.exception.BusinessException; |
12 | 12 | import com.order.erp.common.utils.AliOssUtil; |
13 | 13 | import com.order.erp.common.utils.FileUtil; |
14 | 14 | import com.order.erp.common.utils.StringUtils; |
15 | +import com.order.erp.config.AliOssConfig; | |
15 | 16 | import com.order.erp.domain.dto.LocalStorageDO; |
16 | 17 | import com.order.erp.domain.vo.ImageRespVO; |
17 | 18 | import com.order.erp.domain.vo.LocalStorageQueryVO; |
... | ... | @@ -57,13 +58,13 @@ public class LocalStorageServiceImpl extends ServiceImpl<LocalStorageMapper, Loc |
57 | 58 | ImageRespVO imageRespVO = new ImageRespVO(); |
58 | 59 | try { |
59 | 60 | File tempFile = new File(path + "images" + File.separator + tempFileName); |
60 | - if (AliOssUtil.upload(AliOssUtil.BUCKET, fileName, file.getBytes())) { | |
61 | - String originImageUrl = AliOssUtil.createUrl(AliOssUtil.BUCKET, fileName, new DateTime().plusYears(Constant.ENABLE_TEN).toDate()); | |
61 | + if (AliOssUtil.upload(AliOssConfig.ALIYUN_BUCKET, fileName, file.getBytes())) { | |
62 | + String originImageUrl = AliOssUtil.createUrl(AliOssConfig.ALIYUN_BUCKET, fileName, new DateTime().plusYears(Constant.ENABLE_TEN).toDate()); | |
62 | 63 | imageRespVO.setPicUrl(originImageUrl); |
63 | 64 | // 生成缩略图 |
64 | 65 | Thumbnails.of(file.getInputStream()).size(100, 100).toFile(tempFile); |
65 | - if (AliOssUtil.upload(AliOssUtil.BUCKET, tempFileName, FileUtil.readBytes(tempFile))) { | |
66 | - String thumbnailImageUrl = AliOssUtil.createUrl(AliOssUtil.BUCKET, tempFileName, new DateTime().plusYears(Constant.ENABLE_TEN).toDate()); | |
66 | + if (AliOssUtil.upload(AliOssConfig.ALIYUN_BUCKET, tempFileName, FileUtil.readBytes(tempFile))) { | |
67 | + String thumbnailImageUrl = AliOssUtil.createUrl(AliOssConfig.ALIYUN_BUCKET, tempFileName, new DateTime().plusYears(Constant.ENABLE_TEN).toDate()); | |
67 | 68 | imageRespVO.setSmallPicUrl(thumbnailImageUrl); |
68 | 69 | } |
69 | 70 | FileUtil.del(tempFile); | ... | ... |
src/main/resources/application-local.yml
... | ... | @@ -167,3 +167,10 @@ file: |
167 | 167 | # 文件大小 /M |
168 | 168 | maxSize: 100 |
169 | 169 | avatarMaxSize: 5 |
170 | + | |
171 | +# 阿里pss图片服务 | |
172 | +oss: | |
173 | + endpoint: https://oss-cn-qingdao.aliyuncs.com | |
174 | + accessKeyId: LTAIZCPI7OaWud0m | |
175 | + accessKeySecret: nvtGeScBwRztGeoj8WSp5OWalalgpK | |
176 | + bucket: order-erp | ... | ... |