From 3d2b51ea4520533de5e78f88dddf5b5c7dce4247 Mon Sep 17 00:00:00 2001
From: mitao <2763622819@qq.com>
Date: 星期四, 06 六月 2024 15:56:18 +0800
Subject: [PATCH] 管理后台添加营销员导入功能

---
 meiya-admin/src/main/java/com/sinata/core/util/huawei/obs/ObsUploadUtil.java |   22 ++++++++++++++++++++++
 1 files changed, 22 insertions(+), 0 deletions(-)

diff --git a/meiya-admin/src/main/java/com/sinata/core/util/huawei/obs/ObsUploadUtil.java b/meiya-admin/src/main/java/com/sinata/core/util/huawei/obs/ObsUploadUtil.java
index b5f00c9..cbd98c9 100644
--- a/meiya-admin/src/main/java/com/sinata/core/util/huawei/obs/ObsUploadUtil.java
+++ b/meiya-admin/src/main/java/com/sinata/core/util/huawei/obs/ObsUploadUtil.java
@@ -3,6 +3,7 @@
 import cn.hutool.core.util.StrUtil;
 import com.obs.services.ObsClient;
 import com.sinata.core.config.HuaWeiConfig;
+import java.io.ByteArrayInputStream;
 import org.springframework.web.multipart.MultipartFile;
 
 import java.io.IOException;
@@ -46,4 +47,25 @@
         }
         return objectName;
     }
+    public static String obsUploadInputStream(InputStream is, String dir,String fileName) throws IOException {
+        // 文件目录
+        dir = StrUtil.isBlank(dir) ? "excel/" : dir + "/";
+
+        String objectName = "";
+        // 创建ObsClient实例
+        ObsClient obsClient = new ObsClient(HuaWeiConfig.AK, HuaWeiConfig.SK, https + endPoint);
+
+        //获得指定文件的输入流
+        objectName = dir +  fileName;
+
+        // 上传对象至OBS
+        obsClient.putObject(bucketName, objectName, is);
+
+        if (objectName != null && !"".equals(objectName)) {
+            objectName = obsDomain + objectName;
+        }
+        // 关闭obsClient,全局使用一个ObsClient客户端的情况下,不建议主动关闭ObsClient客户端
+        obsClient.close();
+        return objectName;
+    }
 }

--
Gitblit v1.7.1