haozq
/
ah_jjzhgd_service
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

拦截器修改

This commit is contained in:
haozq 2024-03-29 16:11:06 +08:00
parent 6ac961b286
commit 3e9e47f133
3 changed files with 5 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
securitycontrol-gateway/src/main/java/com/securitycontrol/gateway/filter/AuthFilter.java
View File

@ -45,8 +45,7 @@ public class AuthFilter implements GlobalFilter, Ordered
@Autowired @Autowired
private RedisService redisService; private RedisService redisService;
@Override @Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
{
ServerHttpRequest request = exchange.getRequest(); ServerHttpRequest request = exchange.getRequest();
ServerHttpRequest.Builder mutate = request.mutate(); ServerHttpRequest.Builder mutate = request.mutate();

8
securitycontrol-gateway/src/main/java/com/securitycontrol/gateway/filter/RsaDecryptResponseGatewayFilterFactory.java
View File

@ -41,16 +41,17 @@ class RsaDecryptResponseGatewayFilterFactory extends AbstractGatewayFilterFactor
@Value("${system.jm}") @Value("${system.jm}")
public boolean AQ_JM; public boolean AQ_JM;
public final static String heard_name="decrypt";
@Override @Override
public GatewayFilter apply(Object config) { public GatewayFilter apply(Object config) {
return (exchange, chain) -> { return (exchange, chain) -> {
System.err.println("进入拦截器");
ServerHttpRequest serverHttpRequest = exchange.getRequest(); ServerHttpRequest serverHttpRequest = exchange.getRequest();
String head= serverHttpRequest.getHeaders().getFirst("decrypt"); String head= serverHttpRequest.getHeaders().getFirst(heard_name);
if(StringHelper.isNotEmpty(head)&& "decrypt".equals(head)){ if(StringHelper.isNotEmpty(head)&& heard_name.equals(head)){
return chain.filter(exchange); return chain.filter(exchange);
} }
if(!AQ_JM){ if(!AQ_JM){
return chain.filter(exchange); return chain.filter(exchange);
} }
@ -83,7 +84,6 @@ class RsaDecryptResponseGatewayFilterFactory extends AbstractGatewayFilterFactor
} }
//未强制加密 //未强制加密
return chain.filter(exchange); return chain.filter(exchange);
// return CommonConstant.buildResponse(exchange, HttpStatus.BAD_REQUEST.value(), "请求参数不能为空"); // return CommonConstant.buildResponse(exchange, HttpStatus.BAD_REQUEST.value(), "请求参数不能为空");
} }

2
securitycontrol-gateway/src/main/java/com/securitycontrol/gateway/filter/ValidateCodeFilter.java
View File

@ -44,13 +44,11 @@ public class ValidateCodeFilter extends AbstractGatewayFilterFactory<Object>
{ {
return (exchange, chain) -> { return (exchange, chain) -> {
ServerHttpRequest request = exchange.getRequest(); ServerHttpRequest request = exchange.getRequest();
// 非登录/注册请求或验证码关闭，不处理 // 非登录/注册请求或验证码关闭，不处理
if (!StringUtils.containsAnyIgnoreCase(request.getURI().getPath(), VALIDATE_URL) || !captchaProperties.getEnabled()) if (!StringUtils.containsAnyIgnoreCase(request.getURI().getPath(), VALIDATE_URL) || !captchaProperties.getEnabled())
{ {
return chain.filter(exchange); return chain.filter(exchange);
} }
try try
{ {
String rspStr = resolveBodyFromRequest(request); String rspStr = resolveBodyFromRequest(request);