From 4af0a2ddc8940cd38d0e602409cace1a7c50ea13 Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期一, 04 八月 2025 09:55:58 +0800
Subject: [PATCH] 新增加开通城市基础配置功能
---
ManagementQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/qianyuntong/NCOSSUtil.java | 19 +++++++++++--------
1 files changed, 11 insertions(+), 8 deletions(-)
diff --git a/ManagementQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/qianyuntong/NCOSSUtil.java b/ManagementQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/qianyuntong/NCOSSUtil.java
index 8f25e90..e65e84f 100644
--- a/ManagementQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/qianyuntong/NCOSSUtil.java
+++ b/ManagementQYTTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/qianyuntong/NCOSSUtil.java
@@ -8,6 +8,7 @@
import com.heredata.hos.model.PutObjectResult;
import com.heredata.hos.model.bucket.Bucket;
import com.heredata.model.VoidResult;
+import com.stylefeng.guns.modular.system.util.SpringContextsUtil;
import lombok.extern.slf4j.Slf4j;
import java.io.InputStream;
@@ -19,7 +20,9 @@
*/
@Slf4j
public class NCOSSUtil {
-
+
+ private static QianYunTongConfig qianYunTongConfig = SpringContextsUtil.getBean(QianYunTongConfig.class).getQianYunTongConfig();;
+
/**
* 创建桶
* @param bucketName
@@ -32,7 +35,7 @@
* accessKey：向UAAS服务请求到的access_key
* secretKey：向UAAS服务请求到的secret_key
*/
- HOS hos = new HOSClientBuilder().build(QianYunTongProperties.endPoint, QianYunTongProperties.account, QianYunTongProperties.accessKey, QianYunTongProperties.secretKey);
+ HOS hos = new HOSClientBuilder().build(qianYunTongConfig.getEndPoint(), qianYunTongConfig.getAccount(), qianYunTongConfig.getAccessKey(), qianYunTongConfig.getSecretKey());
try {
// 创建请求对象，并且设置创建桶名为"example"的桶
CreateBucketRequest createBucketRequest = new CreateBucketRequest(bucketName);
@@ -61,7 +64,7 @@
* accessKey：向UAAS服务请求到的access_key
* secretKey：向UAAS服务请求到的secret_key
*/
- HOS hos = new HOSClientBuilder().build(QianYunTongProperties.endPoint, QianYunTongProperties.account, QianYunTongProperties.accessKey, QianYunTongProperties.secretKey);
+ HOS hos = new HOSClientBuilder().build(qianYunTongConfig.getEndPoint(), qianYunTongConfig.getAccount(), qianYunTongConfig.getAccessKey(), qianYunTongConfig.getSecretKey());
try {
// 查询桶名为"example"的详情
Bucket bucket = hos.getBucketInfo(bucketName);
@@ -85,7 +88,7 @@
* accessKey：向UAAS服务请求到的access_key
* secretKey：向UAAS服务请求到的secret_key
*/
- HOS hos = new HOSClientBuilder().build(QianYunTongProperties.endPoint, QianYunTongProperties.account, QianYunTongProperties.accessKey, QianYunTongProperties.secretKey);
+ HOS hos = new HOSClientBuilder().build(qianYunTongConfig.getEndPoint(), qianYunTongConfig.getAccount(), qianYunTongConfig.getAccessKey(), qianYunTongConfig.getSecretKey());
try {
VoidResult result = hos.deleteBucket(bucketName);
if (result.getResponse().isSuccessful()) {
@@ -137,7 +140,7 @@
* accessKey：向UAAS服务请求到的access_key
* secretKey：向UAAS服务请求到的secret_key
*/
- HOS hos = new HOSClientBuilder().build(QianYunTongProperties.endPoint, QianYunTongProperties.account, QianYunTongProperties.accessKey, QianYunTongProperties.secretKey);
+ HOS hos = new HOSClientBuilder().build(qianYunTongConfig.getEndPoint(), qianYunTongConfig.getAccount(), qianYunTongConfig.getAccessKey(), qianYunTongConfig.getSecretKey());
// 桶策略字符串
try {
VoidResult result = hos.setBucketPolicy(bucketName, policyText);
@@ -167,7 +170,7 @@
* accessKey：向UAAS服务请求到的access_key
* secretKey：向UAAS服务请求到的secret_key
*/
- HOS hos = new HOSClientBuilder().build(QianYunTongProperties.endPoint, QianYunTongProperties.account, QianYunTongProperties.accessKey, QianYunTongProperties.secretKey);
+ HOS hos = new HOSClientBuilder().build(qianYunTongConfig.getEndPoint(), qianYunTongConfig.getAccount(), qianYunTongConfig.getAccessKey(), qianYunTongConfig.getSecretKey());
try {
PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, key , inputStream);
PutObjectResult example = hos.putObject(putObjectRequest);
@@ -196,7 +199,7 @@
* accessKey：向UAAS服务请求到的access_key
* secretKey：向UAAS服务请求到的secret_key
*/
- HOS hos = new HOSClientBuilder().build(QianYunTongProperties.endPoint, QianYunTongProperties.account, QianYunTongProperties.accessKey, QianYunTongProperties.secretKey);
+ HOS hos = new HOSClientBuilder().build(qianYunTongConfig.getEndPoint(), qianYunTongConfig.getAccount(), qianYunTongConfig.getAccessKey(), qianYunTongConfig.getSecretKey());
try {
HOSObject example = hos.getObject(bucketName, key);
if (example.getResponse().isSuccessful()) {
@@ -224,7 +227,7 @@
* accessKey：向UAAS服务请求到的access_key
* secretKey：向UAAS服务请求到的secret_key
*/
- HOS hos = new HOSClientBuilder().build(QianYunTongProperties.endPoint, QianYunTongProperties.account, QianYunTongProperties.accessKey, QianYunTongProperties.secretKey);
+ HOS hos = new HOSClientBuilder().build(qianYunTongConfig.getEndPoint(), qianYunTongConfig.getAccount(), qianYunTongConfig.getAccessKey(), qianYunTongConfig.getSecretKey());
try {
VoidResult example = hos.deleteObject(bucketName, key);
if (example.getResponse().isSuccessful()) {
--
Gitblit v1.7.1