From ca38f03d6799bd31d8ad26156f160009fe3fb6e0 Mon Sep 17 00:00:00 2001
From: 无关风月 <443237572@qq.com>
Date: 星期三, 22 一月 2025 11:25:31 +0800
Subject: [PATCH] 房屋

---
 /dev/null                                                                   |   51 ------------
 ruoyi-admin/src/main/java/com/ruoyi/web/controller/tool/TencentCosUtil.java |  108 +++++++++++++++++++++++++++
 ruoyi-admin/src/main/resources/application-test.yml                         |    7 +
 ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/COSController.java   |   40 ++++++++++
 ruoyi-admin/src/main/resources/application-prod.yml                         |    7 +
 ruoyi-system/pom.xml                                                        |    6 +
 6 files changed, 167 insertions(+), 52 deletions(-)

diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/COSController.java b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/COSController.java
new file mode 100644
index 0000000..eeba769
--- /dev/null
+++ b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/COSController.java
@@ -0,0 +1,40 @@
+package com.ruoyi.web.controller.api;
+
+import com.ruoyi.common.core.domain.R;
+import com.ruoyi.web.controller.tool.TencentCosUtil;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.multipart.MultipartFile;
+
+import javax.annotation.Resource;
+
+/**
+ * @author HJL
+ * @version 1.0
+ * @since 2024-05-30 9:27
+ */
+@RestController
+@RequestMapping("/cos")
+@Api(tags = "公共-文件上传")
+public class COSController {
+
+    @Resource
+    private TencentCosUtil tencentCosUtil;
+
+    @PostMapping("/upload")
+    @ApiOperation(value = "文件上传", tags = "公共-文件上传")
+    @ApiImplicitParams({
+            @ApiImplicitParam(value = "文件", name = "file", dataType = "MultipartFile", required = true)
+    })
+    public R<String> upload(@RequestParam("file") MultipartFile file) {
+        String s = tencentCosUtil.upLoadFile(file);
+        return R.ok(s, s);
+    }
+
+}
diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/OssController.java b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/OssController.java
deleted file mode 100644
index d84919e..0000000
--- a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/OssController.java
+++ /dev/null
@@ -1,51 +0,0 @@
-package com.ruoyi.web.controller.api;
-
-import com.aliyun.oss.OSSClient;
-import com.aliyun.oss.model.ObjectMetadata;
-import com.aliyun.oss.model.PutObjectRequest;
-import com.aliyun.oss.model.PutObjectResult;
-import io.swagger.annotations.ApiOperation;
-import org.springframework.http.ResponseEntity;
-import org.springframework.web.bind.annotation.*;
-import org.springframework.web.multipart.MultipartFile;
-
-import java.io.IOException;
-
-@CrossOrigin
-@RestController
-@RequestMapping("/base/oss")
-class OssController {
-
-    private static final String endpoint = "oss-cn-chengdu.aliyuncs.com";
-    private static final String accessKeyId = "LTAI5tCQHjSsP7TXuyjSG1PJ";
-    private static final String accessKeySecret = "RIDXxzOrdMS0V8vQDT53MGvAgsegRV";
-    private static final String bucketName = "inspectionbucket";
-
-    @PostMapping("/upload")
-    @ApiOperation(value = "文件上传",tags = "文件上传")
-    public ResponseEntity<String> upload(@RequestParam("file") MultipartFile file) throws IOException {
-        // 创建 OSSClient 实例
-        OSSClient ossClient = new OSSClient(endpoint, accessKeyId, accessKeySecret);
-
-
-        // 创建 PutObjectRequest 对象
-        PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, file.getOriginalFilename(), file.getInputStream());
-
-        ObjectMetadata metadata = new ObjectMetadata();
-        // 取消文件缓存,文件每次都会从OSS服务器获取
-        metadata.setHeader("Cache-Control", "no-cache");
-        metadata.setHeader("Expires", "0");
-
-
-        // 上传文件
-        PutObjectResult putObjectResult = ossClient.putObject(putObjectRequest);
-
-        // 关闭 OSSClient 实例
-        ossClient.shutdown();
-
-        String fileUrl = "https://" + bucketName + "." + endpoint + "/" + file.getOriginalFilename();
-        return ResponseEntity.ok(fileUrl);
-    }
-
-
-}
diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/tool/TencentCosUtil.java b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/tool/TencentCosUtil.java
new file mode 100644
index 0000000..a492575
--- /dev/null
+++ b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/tool/TencentCosUtil.java
@@ -0,0 +1,108 @@
+package com.ruoyi.web.controller.tool;
+
+import com.qcloud.cos.COSClient;
+import com.qcloud.cos.ClientConfig;
+import com.qcloud.cos.auth.BasicCOSCredentials;
+import com.qcloud.cos.auth.COSCredentials;
+import com.qcloud.cos.http.HttpProtocol;
+import com.qcloud.cos.model.ObjectMetadata;
+import com.qcloud.cos.model.PutObjectResult;
+import com.qcloud.cos.region.Region;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.io.InputStream;
+import java.util.UUID;
+
+/**
+ * @author HJL
+ */
+@Component
+public class TencentCosUtil {
+
+    /**
+     * COS的SecretId
+     */
+    @Value("${cos.client.accessKey}")
+    private String secretId;
+    /**
+     * COS的SecretKey
+     */
+    @Value("${cos.client.secretKey}")
+    private String secretKey;
+    /**
+     * 文件上传后访问路径的根路径,后面要最佳文件名字与类型
+     */
+    @Value("${cos.client.rootSrc}")
+    private String rootSrc;
+    /**
+     * 上传的存储桶的地域
+     */
+    @Value("${cos.client.bucketAddr}")
+    private String bucketAddr;
+    /**
+     * 存储桶的名字,是自己在存储空间自己创建的,我创建的名字是:qq-test-1303******
+     */
+    @Value("${cos.client.bucket}")
+    private String bucketName;
+
+    /**
+     * 1.调用静态方法getCosClient()就会获得COSClient实例
+     * 2.本方法根据永久密钥初始化 COSClient的,官方是不推荐,官方推荐使用临时密钥,是可以限制密钥使用权限,创建cred时有些区别
+     *
+     * @return COSClient实例
+     */
+    private COSClient getCosClient() {
+        // 1 初始化用户身份信息(secretId, secretKey)。
+        COSCredentials cred = new BasicCOSCredentials(secretId, secretKey);
+        // 2.1 设置存储桶的地域(上文获得)
+        Region region = new Region(bucketAddr);
+        ClientConfig clientConfig = new ClientConfig(region);
+        // 2.2 使用https协议传输
+        clientConfig.setHttpProtocol(HttpProtocol.https);
+        // 生成 cos 客户端
+        return new COSClient(cred, clientConfig);
+    }
+
+    /**
+     * 只要调用静态方法upLoadFile(MultipartFile multipartFile)就可以获取上传后文件的全路径
+     *
+     * @param file
+     * @return 返回文件的浏览全路径
+     */
+    public String upLoadFile(MultipartFile file) {
+        try {
+            // 获取上传的文件的输入流
+            InputStream inputStream = file.getInputStream();
+            // 避免文件覆盖,获取文件的原始名称,如123.jpg,然后通过截取获得文件的后缀,也就是文件的类型
+            String originalFilename = file.getOriginalFilename();
+            //获取文件的类型
+            String fileType = originalFilename.substring(originalFilename.lastIndexOf("."));
+            //使用UUID工具  创建唯一名称,放置文件重名被覆盖,在拼接上上命令获取的文件类型
+            String fileName = UUID.randomUUID() + fileType;
+            // 指定文件上传到 COS 上的路径,即对象键。最终文件会传到存储桶名字中的images文件夹下的fileName名字
+            String key = "xizang/" + fileName;
+            // 创建上传Object的Metadata
+            ObjectMetadata objectMetadata = new ObjectMetadata();
+            // - 使用输入流存储,需要设置请求长度
+            objectMetadata.setContentLength(inputStream.available());
+            // - 设置缓存
+            objectMetadata.setCacheControl("no-cache");
+            // - 设置Content-Type
+            objectMetadata.setContentType(fileType);
+            //上传文件
+            PutObjectResult putResult = getCosClient().putObject(bucketName, key, inputStream, objectMetadata);
+            // 创建文件的网络访问路径
+            String url = rootSrc + key;
+            //关闭 cosClient,并释放 HTTP 连接的后台管理线程
+            getCosClient().shutdown();
+            return url;
+        } catch (Exception e) {
+            e.printStackTrace();
+            // 发生IO异常、COS连接异常等,返回空
+            return null;
+        }
+    }
+
+}
\ No newline at end of file
diff --git a/ruoyi-admin/src/main/resources/application-prod.yml b/ruoyi-admin/src/main/resources/application-prod.yml
index d12c582..b90646c 100644
--- a/ruoyi-admin/src/main/resources/application-prod.yml
+++ b/ruoyi-admin/src/main/resources/application-prod.yml
@@ -206,3 +206,10 @@
     accessKeySecret: 0SRb6XGkciQDPWn2rYqbJtq2qRMDY8
     signName: "四川金达通信工程"
     templateCode: "SMS_293985284"
+cos:
+  client:
+    accessKey: AKIDCF5EF2c0DE1e5JK8r4EGJF4mNsMgp26x
+    secretKey: lLl184rUyFOOE0d5KNGC3kmfNsCWk4GU
+    bucket: xzgttest-1305134071
+    bucketAddr: ap-nanjing
+    rootSrc: https://cdn.hyhsbqgc.com/
\ No newline at end of file
diff --git a/ruoyi-admin/src/main/resources/application-test.yml b/ruoyi-admin/src/main/resources/application-test.yml
index 237700e..29bfa28 100644
--- a/ruoyi-admin/src/main/resources/application-test.yml
+++ b/ruoyi-admin/src/main/resources/application-test.yml
@@ -205,3 +205,10 @@
     accessKeySecret: 0SRb6XGkciQDPWn2rYqbJtq2qRMDY8
     signName: "四川金达通信工程"
     templateCode: "SMS_293985284"
+cos:
+  client:
+    accessKey: AKIDHVcchrvvtBiRJB25bHFFJc2Laq4NnHsY
+    secretKey: pgUGwX4Z1SrAPXYk1PxgXVem2HlRJG9k
+    bucketAddr: ap-nanjing
+    bucket: huishou-1323682843
+    rootSrc: https://cdn.hyhsbqgc.com/
\ No newline at end of file
diff --git a/ruoyi-system/pom.xml b/ruoyi-system/pom.xml
index 10998d3..f4f7c3b 100644
--- a/ruoyi-system/pom.xml
+++ b/ruoyi-system/pom.xml
@@ -16,7 +16,11 @@
     </description>
 
     <dependencies>
-
+        <dependency>
+            <groupId>com.qcloud</groupId>
+            <artifactId>cos_api</artifactId>
+            <version>5.6.227</version>
+        </dependency>
         <!-- 通用工具-->
         <dependency>
             <groupId>com.ruoyi</groupId>

--
Gitblit v1.7.1