[Fix][util] 修改 encryption_algorithm 默认值(TSG-22652)

2 files changed, 24 insertions, 10 deletions

diff --git a/src/main/java/com/mesalab/common/configuration/VaultConfiguration.java b/src/main/java/com/mesalab/common/configuration/VaultConfiguration.java
index 5a4ea3ee..3903948a 100644
--- a/src/main/java/com/mesalab/common/configuration/VaultConfiguration.java
+++ b/src/main/java/com/mesalab/common/configuration/VaultConfiguration.java
@@ -12,27 +12,30 @@ import org.springframework.context.annotation.Configuration;
 @Data
 @Configuration
 public class VaultConfiguration {
-    @NacosValue("${vault.url}")
+    @NacosValue(value = "${vault.url}", autoRefreshed = true)
     private String url;
 
-    @NacosValue("${vault.username}")
+    @NacosValue(value = "${vault.username}", autoRefreshed = true)
     private String username;
 
-    @NacosValue("${vault.password}")
+    @NacosValue(value = "${vault.password}", autoRefreshed = true)
     private String password;
 
-    @NacosValue("${vault.keyPath}")
+    @NacosValue(value = "${vault.keyPath}", autoRefreshed = true)
     private String keyPath;
 
-    @NacosValue("${vault.ssl.skipVerification}")
+    @NacosValue(value = "${vault.identifier}", autoRefreshed = true)
+    private String identifier;
+
+    @NacosValue(value = "${vault.ssl.skipVerification}", autoRefreshed = true)
     private boolean sslSkipVerification;
 
-    @NacosValue("${vault.ssl.privateKeyPath}")
+    @NacosValue(value = "${vault.ssl.privateKeyPath}", autoRefreshed = true)
     private String sslPrivateKeyPath;
 
-    @NacosValue("${vault.ssl.certificatePath}")
+    @NacosValue(value = "${vault.ssl.certificatePath}", autoRefreshed = true)
     private String sslCertificatePath;
 
-    @NacosValue("${vault.ssl.caCertificatePath}")
+    @NacosValue(value = "${vault.ssl.caCertificatePath}", autoRefreshed = true)
     private String sslCaCertificatePath;
 }
diff --git a/src/main/java/com/mesalab/qgw/controller/UtilController.java b/src/main/java/com/mesalab/qgw/controller/UtilController.java
index 376c31dc..7c6cdf88 100644
--- a/src/main/java/com/mesalab/qgw/controller/UtilController.java
+++ b/src/main/java/com/mesalab/qgw/controller/UtilController.java
@@ -3,6 +3,7 @@ package com.mesalab.qgw.controller;
 import cn.hutool.log.Log;
 import cn.hutool.log.LogFactory;
 import com.geedgenetworks.utils.StringUtil;
+import com.mesalab.common.configuration.VaultConfiguration;
 import com.mesalab.common.entity.BaseResult;
 import com.mesalab.common.enums.EncryptionAlgorithm;
 import com.mesalab.common.enums.HttpStatusCodeEnum;
@@ -22,8 +23,8 @@ public class UtilController {
 
     private static final Log log = LogFactory.get();
     private final static int CIPHERTEXT_LIST_MAX_SIZE = 100;
-    @Autowired
     private UtilService utilService;
+    private VaultConfiguration vaultConfiguration;
 
     @GetMapping(value = "/sql-parser", consumes = "application/x-www-form-urlencoded")
     @AuditLog("UtilController.getSQLSyntaxTree")
@@ -51,7 +52,7 @@ public class UtilController {
                     String.format(CommonErrorCode.PARAMETER_ERROR.getMessage(), "This ciphertext_list cannot be empty and must contain at most 100 items."));
         }
         if (StringUtil.isEmpty(param.getEncryptionAlgorithm())) {
-            param.setEncryptionAlgorithm(EncryptionAlgorithm.AES_128_GCM96.getValue());
+            param.setEncryptionAlgorithm(vaultConfiguration.getIdentifier());
         }
         if (!EncryptionAlgorithm.isValid(param.getEncryptionAlgorithm())) {
             throw new QGWBusinessException(HttpStatusCodeEnum.BAD_REQUEST.getCode(), CommonErrorCode.PARAMETER_ERROR.getCode(),
@@ -60,4 +61,14 @@ public class UtilController {
         return utilService.decryptWithKMS(param);
     }
 
+    @Autowired
+    public void setVaultConfiguration(VaultConfiguration vaultConfiguration) {
+        this.vaultConfiguration = vaultConfiguration;
+    }
+
+    @Autowired
+    public void setUtilService(UtilService utilService) {
+        this.utilService = utilService;
+    }
+
 }