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

smart-gateway/src/main/java/com/mortals/xhx/base/framework/filter/AccessLogFilter.java

@@ -171,21 +171,38 @@ public class AccessLogFilter implements GlobalFilter, Ordered {
         headers.remove(HttpHeaders.CONTENT_LENGTH);
         CachedBodyOutputMessage outputMessage = new CachedBodyOutputMessage(exchange, headers);
         log.info("decoratedRequest 0");
+
         return bodyInserter.insert(outputMessage, new BodyInserterContext())
                 .then(Mono.defer(() -> {
-                    // 重新封装请求
                     Flux<DataBuffer> dataBuffers = Flux.from(outputMessage.getBody());
-                    log.info("decoratedRequest 1");
-                    ServerHttpRequest decoratedRequest = requestDecorate(exchange, headers, outputMessage);
-                    // 记录响应日志
-                    ServerHttpResponseDecorator decoratedResponse = recordResponseLog(exchange, accessLogPdu);
-                    // 记录普通的
-                    return chain.filter(exchange.mutate().request(decoratedRequest).response(decoratedResponse).build())
-                            .then(Mono.fromRunnable(() -> {
-                                // 打印日志 并发送
-                                writeAccessLog(accessLogPdu);
+                    return outputMessage.writeWith(dataBuffers.map(d -> {
+                        byte[] bytes = new byte[d.readableByteCount()];
+                        d.read(bytes);
+                        DataBufferUtils.release(d);
+                        return bytes;
+                    }).map(bytes -> {
+                        DataBuffer buffer = outputMessage.bufferFactory().wrap(bytes);
+                        return buffer;
+                    }).doOnError(error -> {
+                        //DataBufferUtils.release(dataBuffers);
                     }));
                 }));
+
+//        return bodyInserter.insert(outputMessage, new BodyInserterContext())
+//                .then(Mono.defer(() -> {
+//                    // 重新封装请求
+//                    Flux<DataBuffer> dataBuffers = Flux.from(outputMessage.getBody());
+//                    log.info("decoratedRequest 1");
+//                    ServerHttpRequest decoratedRequest = requestDecorate(exchange, headers, outputMessage);
+//                    // 记录响应日志
+//                    ServerHttpResponseDecorator decoratedResponse = recordResponseLog(exchange, accessLogPdu);
+//                    // 记录普通的
+//                    return chain.filter(exchange.mutate().request(decoratedRequest).response(decoratedResponse).build())
+//                            .then(Mono.fromRunnable(() -> {
+//                                // 打印日志 并发送
+//                                writeAccessLog(accessLogPdu);
+//                            }));
+//                }));
     }
 
     private void writeAccessLog(AccessLogPdu accessLogPdu) {