修改三方对接逻辑和环境参数配置

Pu Zhibing

2025-07-08 91fcd48801ad1120651027824f7a60a14deadf87

 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()) {