From 91fcd48801ad1120651027824f7a60a14deadf87 Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期二, 08 七月 2025 19:21:21 +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