From 907b130031f568ba27bf9bc5e113f2c8871ac02e Mon Sep 17 00:00:00 2001 From: chentaisen <14615430+chentaisen@user.noreply.gitee.com> Date: Fri, 9 Aug 2024 10:08:18 +0800 Subject: [PATCH] =?UTF-8?q?fix():=E4=BF=AE=E5=A4=8D=E4=BA=86nacosService?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../NacosNamespaceInterceptor.java | 20 ++++++++----------- 1 file changed, 8 insertions(+), 12 deletions(-) diff --git a/src/main/java/com/muyu/common/nacos/remote/interceptor/NacosNamespaceInterceptor.java b/src/main/java/com/muyu/common/nacos/remote/interceptor/NacosNamespaceInterceptor.java index e67250d..b59a4a9 100644 --- a/src/main/java/com/muyu/common/nacos/remote/interceptor/NacosNamespaceInterceptor.java +++ b/src/main/java/com/muyu/common/nacos/remote/interceptor/NacosNamespaceInterceptor.java @@ -19,22 +19,18 @@ public class NacosNamespaceInterceptor implements Interceptor { */ @Override public boolean beforeExecute(ForestRequest req) { - if(StringUtils.isNotEmpty(namespaceId)){ - // 执行在发送请求之前处理的代码 - Object reqNamespaceId =Convert.utf8Str( req.getQuery("namespaceId")); - if(reqNamespaceId==null){ - log.warn("本次请求nacos的namespaceId未携带，已添加[{}]",namespaceId); + if (StringUtils.isNotEmpty(namespaceId)) { + String reqNamespaceId = Convert.str(req.getQuery("namespaceId"), ""); + if (reqNamespaceId == null) { + log.warn("本次请求nacos的namespace未携带，已添加：[{}]", namespaceId); req.addQuery("namespaceId", namespaceId); // 添加URL的Query参数 - }else { - if(StringUtils.equals(Convert.str(reqNamespaceId,""),namespaceId)){ - log.warn("本次请求nacos的namespaceId和项目ID不符合,现已更改:[{}->{}]",reqNamespaceId,namespaceId); - req.addQuery("namespaceId", namespaceId); // 添加URL的Query参数 + } else { + if (StringUtils.equals(reqNamespaceId, namespaceId)) { + log.warn("本次请求nacos的namespace和项目ID不相符，现已更改：[{}->{}]", reqNamespaceId, namespaceId); + req.addQuery("namespaceId", namespaceId); } } } - - - return true; // 继续执行请求返回true }