From 41ef6325f9c2b9f39b3b0c235b04bf60241d54f6 Mon Sep 17 00:00:00 2001 From: lihongjie0209 Date: Tue, 15 Aug 2023 09:29:04 +0800 Subject: [PATCH] mdc --- src/main/java/cn/lihongjie/coal/filter/AuthFilter.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/src/main/java/cn/lihongjie/coal/filter/AuthFilter.java b/src/main/java/cn/lihongjie/coal/filter/AuthFilter.java index 9678b9c9..54cd407b 100644 --- a/src/main/java/cn/lihongjie/coal/filter/AuthFilter.java +++ b/src/main/java/cn/lihongjie/coal/filter/AuthFilter.java @@ -16,6 +16,7 @@ import jakarta.servlet.http.HttpServletResponse; import lombok.SneakyThrows; import org.apache.commons.lang3.StringUtils; import org.apache.http.entity.ContentType; +import org.slf4j.MDC; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.server.PathContainer; import org.springframework.stereotype.Component; @@ -42,7 +43,7 @@ public class AuthFilter extends OncePerRequestFilter { @Override protected void doFilterInternal(HttpServletRequest request, HttpServletResponse response, FilterChain filterChain) throws ServletException, IOException { - + MDC.remove("user"); if (isMatches(request)) { filterChain.doFilter(request, response); @@ -70,6 +71,8 @@ public class AuthFilter extends OncePerRequestFilter { if (resource.get().getAnonymous()) { sessionService.anonymousSession(); + UserEntity user = Ctx.currentUser(); + MDC.put("user", user.getUsername()); filterChain.doFilter(request, response); } else { @@ -93,6 +96,7 @@ public class AuthFilter extends OncePerRequestFilter { UserEntity user = Ctx.currentUser(); + MDC.put("user", user.getUsername()); Optional userResource = user.getRoles().stream() .flatMap(x -> x.getPermissions().stream()) @@ -104,7 +108,6 @@ public class AuthFilter extends OncePerRequestFilter { writeResponse(new BizException("invalidAccess", "当前资源未授权，请联系机构管理员处理。"), response); } else { - filterChain.doFilter(request, response); }