Commit a6987451 authored by 赵啸非's avatar 赵啸非

添加工作人员最后登录时间

parent 1cdb6978
...@@ -155,7 +155,7 @@ public class AccessLogFilter implements GlobalFilter, Ordered { ...@@ -155,7 +155,7 @@ public class AccessLogFilter implements GlobalFilter, Ordered {
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
private Mono writeBodyLog(ServerWebExchange exchange, GatewayFilterChain chain, AccessLogPdu accessLogPdu) { private Mono writeBodyLog(ServerWebExchange exchange, GatewayFilterChain chain, AccessLogPdu accessLogPdu) {
ServerRequest serverRequest = ServerRequest.create(exchange, messageReaders); ServerRequest serverRequest = ServerRequest.create(exchange, messageReaders);
log.info("decoratedRequest 000");
Mono<String> modifiedBody = serverRequest.bodyToMono(String.class) Mono<String> modifiedBody = serverRequest.bodyToMono(String.class)
.flatMap(body -> { .flatMap(body -> {
accessLogPdu.setRequestData(body); accessLogPdu.setRequestData(body);
...@@ -163,6 +163,7 @@ public class AccessLogFilter implements GlobalFilter, Ordered { ...@@ -163,6 +163,7 @@ public class AccessLogFilter implements GlobalFilter, Ordered {
}); });
// 通过 BodyInserter 插入 body(支持修改body), 避免 request body 只能获取一次 // 通过 BodyInserter 插入 body(支持修改body), 避免 request body 只能获取一次
log.info("decoratedRequest 111");
BodyInserter bodyInserter = BodyInserters.fromPublisher(modifiedBody, String.class); BodyInserter bodyInserter = BodyInserters.fromPublisher(modifiedBody, String.class);
HttpHeaders headers = new HttpHeaders(); HttpHeaders headers = new HttpHeaders();
headers.putAll(exchange.getRequest().getHeaders()); headers.putAll(exchange.getRequest().getHeaders());
...@@ -206,6 +207,7 @@ public class AccessLogFilter implements GlobalFilter, Ordered { ...@@ -206,6 +207,7 @@ public class AccessLogFilter implements GlobalFilter, Ordered {
*/ */
private ServerHttpRequestDecorator requestDecorate(ServerWebExchange exchange, HttpHeaders headers, private ServerHttpRequestDecorator requestDecorate(ServerWebExchange exchange, HttpHeaders headers,
CachedBodyOutputMessage outputMessage) { CachedBodyOutputMessage outputMessage) {
log.info("decoratedRequest 2");
return new ServerHttpRequestDecorator(exchange.getRequest()) { return new ServerHttpRequestDecorator(exchange.getRequest()) {
@Override @Override
public HttpHeaders getHeaders() { public HttpHeaders getHeaders() {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment