|
@@ -91,10 +91,14 @@ public class WebFluxUserRequestInfoFilter implements GlobalFilter {
|
|
|
//just skip this adapter
|
|
//just skip this adapter
|
|
|
return chain.filter(exchange);
|
|
return chain.filter(exchange);
|
|
|
}
|
|
}
|
|
|
|
|
+ //租户转换类型
|
|
|
|
|
+ List<String> tenantMap = (List<String>) jwsObject.getPayload().toJSONObject().get("tenant");
|
|
|
|
|
+ String tenant = tenantMap.isEmpty()? "unknown" : tenantMap.get(0);
|
|
|
ServerHttpRequest request = exchange.getRequest()
|
|
ServerHttpRequest request = exchange.getRequest()
|
|
|
.mutate()
|
|
.mutate()
|
|
|
.header("userId", String.valueOf(jwsObject.getPayload().toJSONObject().get("sub")))
|
|
.header("userId", String.valueOf(jwsObject.getPayload().toJSONObject().get("sub")))
|
|
|
.header("userName", String.valueOf(jwsObject.getPayload().toJSONObject().get("preferred_username")))
|
|
.header("userName", String.valueOf(jwsObject.getPayload().toJSONObject().get("preferred_username")))
|
|
|
|
|
+ .header("tenant", String.valueOf(tenant))
|
|
|
.build();
|
|
.build();
|
|
|
// 把新的 exchange 放回到过滤链
|
|
// 把新的 exchange 放回到过滤链
|
|
|
return chain.filter(exchange.mutate().request(request).build());
|
|
return chain.filter(exchange.mutate().request(request).build());
|