mdc

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<ResourceEntity> 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);
             }