添加实体

pom.xml

@@ -73,6 +73,19 @@
             <groupId>org.springframework.cloud</groupId>
             <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
         </dependency>
+
+        <!--使用security-jwt-->
+        <dependency>
+            <groupId>org.springframework.security</groupId>
+            <artifactId>spring-security-jwt</artifactId>
+        </dependency>
+
+        <!--jwt解析相关-->
+        <dependency>
+            <groupId>io.jsonwebtoken</groupId>
+            <artifactId>jjwt</artifactId>
+            <version>0.9.1</version>
+        </dependency>
     </dependencies>
 
     <build>

src/main/java/com/unissoft/constant/ContentType.java

@@ -13,6 +13,9 @@ public class ContentType {
 
     public static String REDIS_LOGS = "logs";
 
+    //请求认证头
+    public static final String AUTHORIZATION = "Authorization";
+
     static Map<String, String> CONTENT_TYPE = new HashMap<>();
 
     static Map<String, String> FILE_CONTENT_TYPE = new HashMap<>();

src/main/java/com/unissoft/filter/RequestLogFilter.java

@@ -1,12 +1,15 @@
 package com.unissoft.filter;
 
 
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
 import com.google.common.collect.Lists;
 import com.unissoft.constant.ContentType;
 import com.unissoft.constant.HeaderConstant;
 import com.unissoft.constant.OrderedConstant;
 import com.unissoft.log.LogHelper;
 import com.unissoft.model.Log;
+import com.unissoft.model.SysUserPO;
 import com.unissoft.utils.GenerateIdUtils;
 import com.unissoft.utils.IpUtils;
 import com.unissoft.utils.RedisUtil;
@@ -23,6 +26,8 @@ import org.springframework.http.HttpHeaders;
 import org.springframework.http.MediaType;
 import org.springframework.http.server.reactive.ServerHttpRequest;
 import org.springframework.http.server.reactive.ServerHttpRequestDecorator;
+import org.springframework.security.jwt.Jwt;
+import org.springframework.security.jwt.JwtHelper;
 import org.springframework.stereotype.Component;
 import org.springframework.util.StopWatch;
 import org.springframework.web.reactive.function.server.HandlerStrategies;
@@ -32,10 +37,7 @@ import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 
 import java.net.URI;
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.List;
-import java.util.Objects;
+import java.util.*;
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.concurrent.atomic.AtomicReference;
 import java.util.function.Consumer;
@@ -96,20 +98,27 @@ public class RequestLogFilter implements GlobalFilter, Ordered {
                     newBody.set(true);
                 }
             }
-            final Log logDTO = new Log();
-            logDTO.setLevel(Log.LEVEL.INFO);
-            logDTO.setRequestUrl(url);
-            logDTO.setRequestBody(requestBody.get());
-            logDTO.setRequestMethod(method);
-            logDTO.setRequestId(requestId.get());
-            logDTO.setIp(IpUtils.getClientIp(request));
-            logDTO.setCreateTime(new Date());
+
+            //获取当前操作用户名字
+            String userName = null;
+            if (request.getHeaders().get(ContentType.AUTHORIZATION) != null) {
+                String authorization = request.getHeaders().get(ContentType.AUTHORIZATION).get(0).replace("bearer ","");;
+                Jwt decode = JwtHelper.decode(authorization);
+                String claims = decode.getClaims();
+                JSONObject jsonObject = JSON.parseObject(claims);
+                Map<String, String> jsonMap = JSONObject.toJavaObject(jsonObject, Map.class);
+                JSONObject user = JSON.parseObject(jsonMap.get("user_name"));
+                userName = JSONObject.toJavaObject(user, SysUserPO.class).getPersonnelName();
+            }
+
+//            final Log logDTO = new Log();
+            Log logDTO = new Log(Log.LEVEL.INFO, IpUtils.getClientIp(request), url, userName, requestBody.get(), requestId.get(), method, new Date());
             //存入redis
-            List<Object> logs = Lists.newArrayList();
-            logs.add(logDTO);
+            List<Object> logs = Lists.newArrayList(JSON.toJSONString(logDTO));
+
             redisUtil.lSetList(ContentType.REDIS_LOGS, logs);
 
-            ServerHttpRequest serverHttpRequest = exchange.getRequest().mutate().headers(httpHeadersConsumer).build();
+           /* ServerHttpRequest serverHttpRequest = exchange.getRequest().mutate().headers(httpHeadersConsumer).build();
             ServerWebExchange build = exchange.mutate().request(serverHttpRequest).build();
             return build.getSession().flatMap(webSession -> {
                 logDTO.setSessionId(webSession.getId());
@@ -133,7 +142,8 @@ public class RequestLogFilter implements GlobalFilter, Ordered {
                 } else {
                     return chain.filter(exchange).then(LogHelper.doRecord(logDTO));
                 }
-            });
+            });*/
+            return chain.filter(exchange).then(LogHelper.doRecord(logDTO));
         } catch (Exception e) {
             log.error("请求日志打印出现异常", e);
             return chain.filter(exchange);

src/main/java/com/unissoft/model/Log.java

@@ -51,6 +51,17 @@ public class Log {
         this(Log.TYPE.REQUEST);
     }
 
+    public Log(LEVEL level, String ip, String requestUrl, String userName, String requestBody, String requestId, String requestMethod, Date createTime) {
+        this.level = level;
+        this.ip = ip;
+        this.requestUrl = requestUrl;
+        this.userName = userName;
+        this.requestBody = requestBody;
+        this.requestId = requestId;
+        this.requestMethod = requestMethod;
+        this.createTime = createTime;
+    }
+
     public Log(Log.TYPE logType) {
         this.logType = logType;
         this.applicationName = EnvironmentUtils.getAppEnv();