Base64 上传 阿里云

CODE/smart-community/property-api/src/main/java/com/community/huiju/controller/ImageController.java

@@ -55,16 +55,11 @@ public class ImageController extends BaseController {
     public ResponseBean uploadImgBase64AndGetUrl(@ApiParam(value = "uploadFiles" ,required = true) String[] uploadFiles) throws Exception {
         ResponseBean responseBean = new ResponseBean();
         List<String> urls = new ArrayList<String>();
-//        for (MultipartFile uploadFile : uploadFiles){
-//            String url = imageService.getImageUrl(uploadFile);
-//            urls.add(url);
-//        }
         for (String base64Url : uploadFiles) {
             BASE64Decoder base64Decoder = new BASE64Decoder();
             byte[] bytes = base64Decoder.decodeBuffer(base64Url);
             ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(bytes);
-            MultipartFile multipartFil = new MockMultipartFile(String.valueOf(System.currentTimeMillis()), byteArrayInputStream);
-            String url = imageService.getImageUrl(multipartFil);
+            String url = imageService.getImageUrl(byteArrayInputStream);
             urls.add(url);
         }
         responseBean.addSuccess(urls);

CODE/smart-community/property-api/src/main/java/com/community/huiju/service/ImageServiceI.java

@@ -3,6 +3,7 @@ package com.community.huiju.service;
 import org.springframework.web.multipart.MultipartFile;
 
 import java.io.IOException;
+import java.io.InputStream;
 
 /**
  * @author admin
@@ -12,4 +13,12 @@ import java.io.IOException;
  */
 public interface ImageServiceI {
     String getImageUrl(MultipartFile uploadFile) throws IOException;
+
+    /**
+     * 二进制方式 上传 阿里云
+     * @param uploadFile
+     * @return
+     * @throws IOException
+     */
+    String getImageUrl(InputStream uploadFile) throws IOException;
 }

CODE/smart-community/property-api/src/main/java/com/community/huiju/service/impl/ImageServiceimpl.java

@@ -7,6 +7,7 @@ import org.springframework.web.multipart.MultipartFile;
 
 import java.io.ByteArrayInputStream;
 import java.io.IOException;
+import java.io.InputStream;
 import java.util.Date;
 
 /**
@@ -43,4 +44,27 @@ public class ImageServiceimpl implements ImageServiceI {
         url = url.substring(0, url.lastIndexOf("&Signature"));
         return url;
     }
+
+    @Override
+    public String getImageUrl(InputStream uploadFile) throws IOException {
+
+        String imgName = System.currentTimeMillis() + ".png";
+        // 创建OSSClient实例
+        OSSClient ossClient = new OSSClient(endpoint, accessKeyId, accessKeySecret);
+        // 上传
+        long time = System.currentTimeMillis();
+
+        ossClient.putObject(bucketName, imgName, uploadFile);
+
+        // 关闭client
+        ossClient.shutdown();
+        Date expiration = new Date(time + 3600 * 1000 * 24 * 365 * 10);
+        String url = ossClient.generatePresignedUrl(bucketName, imgName, expiration).toString();
+
+        // 截取掉签名
+        url = url.substring(0, url.lastIndexOf("&Signature"));
+        return url;
+
+        return null;
+    }
 }