From 80b9f79da41f5982e2ff42c3a485ba879340fc96 Mon Sep 17 00:00:00 2001
From: Qin Dong Ming <2720806930@qq.com>
Date: Tue, 3 Sep 2024 16:34:35 +0800
Subject: [PATCH] =?UTF-8?q?Oss=E4=B8=8A=E4=BC=A0=E6=B5=8B=E8=AF=95?=
 =?UTF-8?q?=E7=B1=BB?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 cloud-etl-common/pom.xml                      |  6 ++
 .../main/java/com/muyu/utils/OssUpload.java   | 58 +++++++++++++++++++
 .../src/main/java/com/muyu/input/Demo.java    |  1 +
 3 files changed, 65 insertions(+)
 create mode 100644 cloud-etl-common/src/main/java/com/muyu/utils/OssUpload.java

diff --git a/cloud-etl-common/pom.xml b/cloud-etl-common/pom.xml
index 8ac9eb7..2f97eba 100644
--- a/cloud-etl-common/pom.xml
+++ b/cloud-etl-common/pom.xml
@@ -26,6 +26,12 @@
             <groupId>com.muyu</groupId>
             <artifactId>cloud-common-security</artifactId>
         </dependency>
+        <dependency>
+            <groupId>com.aliyun.oss</groupId>
+            <artifactId>aliyun-sdk-oss</artifactId>
+            <version>3.17.4</version>
+            <scope>compile</scope>
+        </dependency>
 
         <!--        <dependency>-->
         <!--            <groupId>org.springframework.boot</groupId>-->
diff --git a/cloud-etl-common/src/main/java/com/muyu/utils/OssUpload.java b/cloud-etl-common/src/main/java/com/muyu/utils/OssUpload.java
new file mode 100644
index 0000000..33e10ab
--- /dev/null
+++ b/cloud-etl-common/src/main/java/com/muyu/utils/OssUpload.java
@@ -0,0 +1,58 @@
+package com.muyu.utils;
+
+import com.aliyun.oss.OSS;
+
+import com.aliyun.oss.OSSClientBuilder;
+
+import com.aliyun.oss.model.PutObjectRequest;
+
+import com.muyu.common.core.domain.Result;
+
+import java.io.ByteArrayInputStream;
+
+import java.nio.charset.StandardCharsets;
+
+public class OssUpload {
+
+    private static final String endpoint = "https://oss-cn-shanghai.aliyuncs.com";
+
+    private static final String accessKeyId = "LTAI5t8LmMHfW8ckPaAZR6oQ";
+
+    private static final String accessKeySecret = "pwzEwkpxcTFgurkARyr7sG7V6syc9x";
+
+    private static final String bucketName = "011811";
+
+    public static Result<Object> uploadFiles(String content, String fileName) {
+
+        OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
+
+        String objectName = "build/rule/version/" + fileName + ".java";
+
+        try {
+            ByteArrayInputStream inputStream = new ByteArrayInputStream(content.getBytes(StandardCharsets.UTF_8));
+
+            PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, objectName, inputStream);
+
+            ossClient.putObject(putObjectRequest);
+
+            return Result.success(null, "文件" + fileName + ".java" + "存储成功");
+
+        } catch (Exception e) {
+
+            e.printStackTrace();
+
+            return Result.error(null, "文件" + fileName + ".java" + "存储失败");
+
+        } finally {
+
+            if (ossClient != null) {
+
+                ossClient.shutdown();
+
+            }
+
+        }
+
+    }
+
+}
diff --git a/cloud-etl-server/src/main/java/com/muyu/input/Demo.java b/cloud-etl-server/src/main/java/com/muyu/input/Demo.java
index 3ea808c..491fdf4 100644
--- a/cloud-etl-server/src/main/java/com/muyu/input/Demo.java
+++ b/cloud-etl-server/src/main/java/com/muyu/input/Demo.java
@@ -14,6 +14,7 @@ import java.io.InputStream;
 public class Demo {
 
     public static void main(String[] args) throws Exception {
+
         // Endpoint以华东1（杭州）为例，其它Region请按实际情况填写。
         String endpoint = "https://oss-cn-shanghai.aliyuncs.com";
         // 从环境变量中获取访问凭证。运行本代码示例之前，请确保已设置环境变量OSS_ACCESS_KEY_ID和OSS_ACCESS_KEY_SECRET。