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 }