fix: 对接阿里oss图片服务

谢茂盛
1 parent 6502f370
Showing 10 changed files with 223 additions and 0 deletions
pom.xml
sql/table.sql
src/main/java/com/order/erp/common/constant/ServerResultCode.java
src/main/java/com/order/erp/common/utils/AliOssUtil.java
src/main/java/com/order/erp/controller/LocalStorageController.java
src/main/java/com/order/erp/domain/dto/order/OrderBaseInfoDO.java
src/main/java/com/order/erp/domain/vo/ImageRespVO.java
src/main/java/com/order/erp/domain/vo/order/OrderBaseInfoVO.java
src/main/java/com/order/erp/service/LocalStorageService.java
src/main/java/com/order/erp/service/impl/LocalStorageServiceImpl.java
@@ -41,6 +41,8 @@
         <guava.version>20.0</guava.version>
         <easy-captcha.version>1.6.2</easy-captcha.version>
         <aliyun-java-sdk-core.version>4.0.3</aliyun-java-sdk-core.version>
+        <aliyun-sdk-oss.version>3.15.0</aliyun-sdk-oss.version>
+        <thumbnailator.version>0.4.8</thumbnailator.version>
         <jjwt.version>0.10.6</jjwt.version>
     </properties>
@@ -240,6 +242,21 @@
             <artifactId>aliyun-java-sdk-core</artifactId>
             <version>${aliyun-java-sdk-core.version}</version>
         </dependency>
+
+        <!--alioss 图片服务-->
+        <dependency>
+            <groupId>com.aliyun.oss</groupId>
+            <artifactId>aliyun-sdk-oss</artifactId>
+            <version>${aliyun-sdk-oss.version}</version>
+        </dependency>
+
+        <!--thumbnailator 图片压缩工具-->
+        <dependency>
+            <groupId>net.coobird</groupId>
+            <artifactId>thumbnailator</artifactId>
+            <version>${thumbnailator.version}</version>
+        </dependency>
+
     </dependencies>
     <build>
         <finalName>order-erp.service-1.0-SNAPSHOT</finalName>
@@ -12,6 +12,7 @@ CREATE TABLE `order_base_info` (
           `po_color` varchar(32) DEFAULT NULL COMMENT 'PO COLOR',
           `cn_color` varchar(32) DEFAULT NULL COMMENT '颜色中文',
           `pic_url` varchar(128) DEFAULT NULL COMMENT 'pic图片地址',
+          `small_pic_url` varchar(128) DEFAULT NULL COMMENT 'pic图片地址-缩略图',
           `production_comment` text DEFAULT NULL COMMENT '生产要求',
           `order_count` int DEFAULT NULL COMMENT '数量',
           `order_composition` varchar(128) DEFAULT NULL COMMENT '订单成分',
@@ -66,6 +66,9 @@ public enum ServerResultCode implements ErrorInfo {
     //申请
     APPLY_UNLOCK_FIELD_EXIST(80001, "还有未审批完结的申请，请等上一个申请单完结！"),
     APPLY_NOT_EXIST(80002, "申请单不存在！"),
+
+    //上传图片
+    UPLOAD_IMAGES_ERROR(900021, "上传图片失败！"),
     ;
+package com.order.erp.common.utils;
+
+import com.aliyun.oss.OSS;
+import com.aliyun.oss.OSSClientBuilder;
+import com.aliyun.oss.model.Bucket;
+import com.aliyun.oss.model.CreateBucketRequest;
+import com.aliyun.oss.model.PutObjectRequest;
+import com.aliyun.oss.model.PutObjectResult;
+
+import java.io.ByteArrayInputStream;
+import java.util.Date;
+import java.util.Objects;
+import java.util.Random;
+
+/**
+ * @author: xms
+ * @description: 阿里oss图片存储工具类
+ * @date: 2023/10/30 18:24
+ * @version: 1.0
+ */
+public class AliOssUtil {
+
+
+
+    /**
+     * oss 地址
+     */
+    private static final String endpoint = "https://oss-cn-qingdao.aliyuncs.com";
+
+    /**
+     * 进入阿里oss获取产品key值
+     */
+    private static final String accessKeyId = "LTAIZCPI7OaWud0m";
+
+    /**
+     * key值对应密码
+     */
+    private static final String accessKeySecret = "nvtGeScBwRztGeoj8WSp5OWalalgpK";
+
+    /**
+     * 存储上传文件的容器
+     */
+    public static final String BUCKET = "order-erp";
+
+    /**
+     * oss 客户端
+     */
+    private static OSS client;
+
+    static {
+        client = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
+    }
+
+    /**
+     * 实现文件名的重命名和限长
+     *
+     * @param fileName
+     * @return
+     */
+    public static String getUniqueFileName(String fileName) {
+        if (fileName.length() > 50) {
+            fileName = fileName.substring(fileName.length() - 50);
+        }
+        return System.currentTimeMillis() + "-" + new Random().nextInt(10000) + fileName;
+    }
+
+    /**
+     * 创建储存空间名称
+     *
+     * @param bucketName 创建存储空间名称
+     * @return
+     */
+    public static boolean create(String bucketName) {
+        CreateBucketRequest createBucketRequest = new CreateBucketRequest(bucketName);
+
+        Bucket bucket = client.createBucket(createBucketRequest);
+        return Objects.nonNull(bucket);
+    }
+
+    /**
+     * 实现文件上传
+     *
+     * @param bucket 存储空间名称
+     * @param obj    存储对象名称，带文件后缀
+     * @param data   文件内容
+     * @return
+     */
+    public static boolean upload(String bucket, String obj, byte[] data) {
+        PutObjectRequest request = new PutObjectRequest(bucket, obj, new ByteArrayInputStream(data));
+        request.setProcess("true");
+        PutObjectResult result = client.putObject(request);
+        return result.getResponse().getStatusCode() == 200;
+    }
+
+    /**
+     * 创建访问链接
+     *
+     * @param bucket 存储空间名称
+     * @param obj    存储对象名称，带文件名后缀
+     * @param etime  访问地址的失效时间
+     * @return 访问地址
+     */
+    public static String createUrl(String bucket, String obj, Date etime) {
+        return client.generatePresignedUrl(bucket, obj, etime).toString();
+    }
+
+    /**
+     * 删除文件
+     *
+     * @param bucket 存储空间名称
+     * @param obj    存储对象名称，带文件后缀
+     */
+    public static void deFile(String bucket, String obj) {
+        client.deleteObject(bucket, obj);
+    }
+
+}
 \ No newline at end of file
@@ -31,4 +31,11 @@ public class LocalStorageController {
         return localStorageService.create(name, file);
     }
+    @ApiOperation("上传文件到oss服务")
+    @PostMapping(value = "/upload_oss")
+    @AnonymousAccess
+    public ServerResult upload2oss(@RequestParam String name, @RequestParam("file") MultipartFile file) {
+        return localStorageService.uploadByAliOss(name, file);
+    }
+
 }
 \ No newline at end of file
@@ -69,6 +69,10 @@ public class OrderBaseInfoDO extends BaseDO implements Serializable {
      */
     private String picUrl;
     /**
+     * 缩略图地址
+     */
+    private String smallPicUrl;
+    /**
      * 生产要求
      */
     private String productionComment;
+package com.order.erp.domain.vo;
+
+import lombok.*;
+import lombok.experimental.SuperBuilder;
+
+import java.io.Serializable;
+
+/**
+ * 图片上传实体类
+ *
+ * @author xms
+ * @since 2023-10-08 14:52:27
+ */
+@Data
+@AllArgsConstructor
+@ToString
+@NoArgsConstructor
+@EqualsAndHashCode(callSuper = false)
+@SuperBuilder
+public class ImageRespVO implements Serializable {
+
+    /**
+     * pic图片地址
+     */
+    private String picUrl;
+    /**
+     * 缩略图地址
+     */
+    private String smallPicUrl;
+}
@@ -65,6 +65,11 @@ public class OrderBaseInfoVO implements Serializable {
      * pic图片地址
      */
     private String picUrl;
+
+    /**
+     * 缩略图片地址
+     */
+    private String smallPicUrl;
     /**
      * 生产要求
      */
@@ -15,6 +15,14 @@ import org.springframework.web.multipart.MultipartFile;
  */
 public interface LocalStorageService extends IService<LocalStorageDO> {
+    /**
+     * 通过阿里oss上传
+     *
+     * @param name
+     * @param file
+     * @return
+     */
+    ServerResult uploadByAliOss(String name, MultipartFile file);
     ServerResult create(String name, MultipartFile file);
@@ -7,15 +7,20 @@ import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.order.erp.common.constant.Constant;
 import com.order.erp.common.constant.ServerResult;
+import com.order.erp.common.constant.ServerResultCode;
 import com.order.erp.common.exception.BusinessException;
+import com.order.erp.common.utils.AliOssUtil;
 import com.order.erp.common.utils.FileUtil;
 import com.order.erp.common.utils.StringUtils;
 import com.order.erp.domain.dto.LocalStorageDO;
+import com.order.erp.domain.vo.ImageRespVO;
 import com.order.erp.domain.vo.LocalStorageQueryVO;
 import com.order.erp.domain.vo.LocalStorageVO;
 import com.order.erp.mapper.LocalStorageMapper;
 import com.order.erp.service.LocalStorageService;
 import lombok.extern.slf4j.Slf4j;
+import net.coobird.thumbnailator.Thumbnails;
+import org.joda.time.DateTime;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.web.multipart.MultipartFile;
@@ -45,6 +50,32 @@ public class LocalStorageServiceImpl extends ServiceImpl&lt;LocalStorageMapper, Loc
     private long maxSize;
     @Override
+    public ServerResult uploadByAliOss(String name, MultipartFile file) {
+        FileUtil.checkSize(maxSize, file.getSize());
+        String fileName = AliOssUtil.getUniqueFileName(name);
+        String tempFileName = "Thumbnails" + Constant.CROSS_BAR_CHARACTER + fileName;
+        ImageRespVO imageRespVO = new ImageRespVO();
+        try {
+            File tempFile = new File(path + "images" + File.separator + tempFileName);
+            if (AliOssUtil.upload(AliOssUtil.BUCKET, fileName, file.getBytes())) {
+                String originImageUrl = AliOssUtil.createUrl(AliOssUtil.BUCKET, fileName, new DateTime().plusYears(Constant.ENABLE_TEN).toDate());
+                imageRespVO.setPicUrl(originImageUrl);
+                // 生成缩略图
+                Thumbnails.of(file.getInputStream()).size(100, 100).toFile(tempFile);
+                if (AliOssUtil.upload(AliOssUtil.BUCKET, tempFileName, FileUtil.readBytes(tempFile))) {
+                    String thumbnailImageUrl = AliOssUtil.createUrl(AliOssUtil.BUCKET, tempFileName, new DateTime().plusYears(Constant.ENABLE_TEN).toDate());
+                    imageRespVO.setSmallPicUrl(thumbnailImageUrl);
+                }
+                FileUtil.del(tempFile);
+            }
+            return ServerResult.success(imageRespVO);
+        } catch (Exception e) {
+            log.error("上传图片异常：{}", e.getMessage());
+            throw new BusinessException(ServerResultCode.UPLOAD_IMAGES_ERROR);
+        }
+    }
+
+    @Override
     public ServerResult create(String name, MultipartFile multipartFile) {
         FileUtil.checkSize(maxSize, multipartFile.getSize());
         String suffix = FileUtil.getExtensionName(multipartFile.getOriginalFilename());