Microservice/pqs
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

1.日志逻辑修改

Browse Source
This commit is contained in:
chendaofei
2024-10-09 11:25:28 +08:00
parent ae5ca42391
commit 33a0ddc6f9
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
pqs-gateway/src/main/java/com/njcn/gateway/config/ResourceServerConfig.java
View File

@@ -122,7 +122,7 @@ public class ResourceServerConfig {
return (exchange, e) -> Mono.defer(() -> Mono.just(exchange.getResponse())) return (exchange, e) -> Mono.defer(() -> Mono.just(exchange.getResponse()))
.flatMap(response -> { .flatMap(response -> {
ServerHttpRequest request = exchange.getRequest(); ServerHttpRequest request = exchange.getRequest();
JSONObject jsonObject = WebFluxRequestUtil.getJwtPayload(request); /* JSONObject jsonObject = WebFluxRequestUtil.getJwtPayload(request);
if(Objects.isNull(jsonObject)){ if(Objects.isNull(jsonObject)){
String ip = WebFluxRequestUtil.getRealIp(request); String ip = WebFluxRequestUtil.getRealIp(request);
LogInfoDTO logInfoDTO = new LogInfoDTO( LogInfoDTO logInfoDTO = new LogInfoDTO(
@@ -141,7 +141,7 @@ public class ResourceServerConfig {
); );
publisher.send("/userLog", PubUtils.obj2json(logInfoDTO), 2, false); publisher.send("/userLog", PubUtils.obj2json(logInfoDTO), 2, false);
publisher.send("/userLogPush", PubUtils.obj2json(logInfoDTO), 2, false); publisher.send("/userLogPush", PubUtils.obj2json(logInfoDTO), 2, false);
} }*/
return ResponseUtils.writeErrorInfo(response, GateWayEnum.ACCESS_TOKEN_EXPIRE_JWT); return ResponseUtils.writeErrorInfo(response, GateWayEnum.ACCESS_TOKEN_EXPIRE_JWT);
}); });
} }