网关日志限制修改

ace-gate/pom.xml

@@ -93,6 +93,12 @@
             <artifactId>ace-interface</artifactId>
             <version>2.0-SNAPSHOT</version>
         </dependency>
+        <dependency>
+            <groupId>com.github.wxiaoqi</groupId>
+            <artifactId>ace-admin-api</artifactId>
+            <version>2.0-SNAPSHOT</version>
+            <scope>compile</scope>
+        </dependency>
         <dependency>
             <groupId>com.github.wxiaoqi</groupId>
             <artifactId>ace-auth-client</artifactId>

ace-gate/src/main/java/com/github/wxiaoqi/security/gate/GatewayServerBootstrap.java

@@ -4,7 +4,6 @@ import com.github.wxiaoqi.security.api.vo.config.HeaderConfig;
 import com.github.wxiaoqi.security.auth.client.EnableAceAuthClient;
 import com.github.wxiaoqi.security.gate.utils.DBLog;
 import org.springframework.boot.SpringApplication;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cloud.client.SpringCloudApplication;
 import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
 import org.springframework.cloud.openfeign.EnableFeignClients;
@@ -17,7 +16,7 @@ import org.springframework.cloud.openfeign.EnableFeignClients;
 @SpringCloudApplication
 @EnableDiscoveryClient
 @EnableAceAuthClient
-@EnableFeignClients(value = {"com.github.wxiaoqi.security.auth.client.feign","com.github.wxiaoqi.security.gate.feign"},defaultConfiguration = HeaderConfig.class)
+@EnableFeignClients(value = {"com.github.wxiaoqi.security.auth.client.feign","com.github.wxiaoqi.security.gate.feign","com.github.wxiaoqi.security.admin.feign"},defaultConfiguration = HeaderConfig.class)
 public class GatewayServerBootstrap {
     public static void main(String[] args) {
         DBLog.getInstance().start();

ace-gate/src/main/java/com/github/wxiaoqi/security/gate/filter/AccessGatewayFilter.java

 package com.github.wxiaoqi.security.gate.filter;
 
 import com.alibaba.fastjson.JSONObject;
+import com.github.wxiaoqi.security.admin.feign.UserFeign;
+import com.github.wxiaoqi.security.admin.feign.dto.AppUserDTO;
+import com.github.wxiaoqi.security.admin.feign.dto.UserDTO;
 import com.github.wxiaoqi.security.api.vo.authority.PermissionInfo;
 import com.github.wxiaoqi.security.api.vo.log.LogInfo;
 import com.github.wxiaoqi.security.auth.client.config.ServiceAuthConfig;
@@ -67,6 +70,9 @@ public class AccessGatewayFilter implements GlobalFilter {
     @Lazy
     private ILogService logService;
 
+    @Autowired
+    UserFeign userFeign;
+
     @Value("${gate.ignore.startWith}")
     private String startWith;
 
@@ -314,6 +320,8 @@ public class AccessGatewayFilter implements GlobalFilter {
     private void recordLog(ServerHttpRequest request, Object body) {
         // 记录要访问的url
         if (!getNotLogUri().contains(request.getURI().getRawPath())) {
+
+
             StringBuilder builder = new StringBuilder();
             log.info("=================请求uri:" + request.getURI().getRawPath());
             // 记录访问的方法
@@ -325,6 +333,12 @@ public class AccessGatewayFilter implements GlobalFilter {
             builder.append(", header { ");
             for (Map.Entry<String, List<String>> entry : request.getHeaders().entrySet()) {
                 builder.append(entry.getKey()).append(":").append(StringUtils.join(entry.getValue(), ",")).append(",");
+                if("Authorization".equals(entry.getKey())) {
+                    if(entry.getValue() != null && entry.getValue().size() > 0) {
+                        getAdminUserInfo(entry.getValue().get(0));
+                    }
+
+                }
             }
             log.info("=================请求头header:" + builder.toString());
             // 记录参数
@@ -343,10 +357,29 @@ public class AccessGatewayFilter implements GlobalFilter {
             log.info("=================请求参数:" + builder.toString());
         }
     }
+
+    private void getAdminUserInfo(String token) {
+        if(token !=null) {
+            UserDTO userDTO = userFeign.userinfoByToken(token).getData();
+            if(userDTO != null) {
+                log.info("=================后台用户名：username = {}", userDTO.getUsername());
+                log.info("=================后台姓名： name = {}", userDTO.getName());
+            } else {
+                AppUserDTO appUserDTO = userFeign.userDetailByToken(token).getData();
+                if(appUserDTO != null) {
+                    log.info("=================APP用户名：userId = {}", appUserDTO.getUserid());
+                    log.info("=================APP姓名： name = {}", appUserDTO.getRealname());
+                    log.info("=================APP手机号： phone = {}", appUserDTO.getUsername());
+                }
+            }
+        }
+    }
+
     @Value("${logback.ignore-log-path}")
     String[] path;
     public List<String> getNotLogUri() {
         return Arrays.asList(path);
     }
 
+
 }