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