Fix naming errors
This commit is contained in:
parent
e5e6235bae
commit
0a93a26f80
|
|
@ -37,7 +37,7 @@ import static org.springframework.http.MediaType.MULTIPART_FORM_DATA_VALUE;
|
||||||
public class AecDecryptParamFilter extends AbstractGatewayFilterFactory {
|
public class AecDecryptParamFilter extends AbstractGatewayFilterFactory {
|
||||||
|
|
||||||
@Value("${system.decryptEnabled}")
|
@Value("${system.decryptEnabled}")
|
||||||
public boolean jaData;
|
public boolean decryptEnabled;
|
||||||
|
|
||||||
public final static String HEARD_NAME="decrypt";
|
public final static String HEARD_NAME="decrypt";
|
||||||
|
|
||||||
|
|
@ -49,7 +49,7 @@ public class AecDecryptParamFilter extends AbstractGatewayFilterFactory {
|
||||||
if(StringUtils.isNotEmpty(head)&& HEARD_NAME.equals(head)){
|
if(StringUtils.isNotEmpty(head)&& HEARD_NAME.equals(head)){
|
||||||
return chain.filter(exchange);
|
return chain.filter(exchange);
|
||||||
}
|
}
|
||||||
if(!jaData){
|
if(!decryptEnabled){
|
||||||
return chain.filter(exchange);
|
return chain.filter(exchange);
|
||||||
}
|
}
|
||||||
//get请求 默认
|
//get请求 默认
|
||||||
|
|
|
||||||
|
|
@ -33,8 +33,8 @@ import java.util.concurrent.TimeUnit;
|
||||||
public class AuthFilter implements GlobalFilter, Ordered
|
public class AuthFilter implements GlobalFilter, Ordered
|
||||||
{
|
{
|
||||||
|
|
||||||
@Value("${system.decryptEnabled}")
|
@Value("${system.encryptEnabled}")
|
||||||
public boolean jaData;
|
public boolean encryptEnabled;
|
||||||
private static final Logger log = LoggerFactory.getLogger(AuthFilter.class);
|
private static final Logger log = LoggerFactory.getLogger(AuthFilter.class);
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
@ -124,7 +124,7 @@ public class AuthFilter implements GlobalFilter, Ordered
|
||||||
|
|
||||||
private Mono<Void> unauthorizedResponse(ServerWebExchange exchange, String msg) {
|
private Mono<Void> unauthorizedResponse(ServerWebExchange exchange, String msg) {
|
||||||
log.error("[鉴权异常处理]请求路径:{}", exchange.getRequest().getPath());
|
log.error("[鉴权异常处理]请求路径:{}", exchange.getRequest().getPath());
|
||||||
return ServletUtils.webFluxResponseWriter(exchange.getResponse(), msg, HttpStatus.UNAUTHORIZED,jaData);
|
return ServletUtils.webFluxResponseWriter(exchange.getResponse(), msg, HttpStatus.UNAUTHORIZED,encryptEnabled);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
|
||||||
|
|
@ -18,8 +18,8 @@ import com.bonus.common.core.utils.ServletUtils;
|
||||||
@Component
|
@Component
|
||||||
public class BlackListUrlFilter extends AbstractGatewayFilterFactory<BlackListUrlFilter.Config>
|
public class BlackListUrlFilter extends AbstractGatewayFilterFactory<BlackListUrlFilter.Config>
|
||||||
{
|
{
|
||||||
@Value("${system.decryptEnabled}")
|
@Value("${system.encryptEnabled}")
|
||||||
public boolean jaData;
|
public boolean encryptEnabled;
|
||||||
@Override
|
@Override
|
||||||
public GatewayFilter apply(Config config)
|
public GatewayFilter apply(Config config)
|
||||||
{
|
{
|
||||||
|
|
@ -28,7 +28,7 @@ public class BlackListUrlFilter extends AbstractGatewayFilterFactory<BlackListUr
|
||||||
String url = exchange.getRequest().getURI().getPath();
|
String url = exchange.getRequest().getURI().getPath();
|
||||||
if (config.matchBlacklist(url))
|
if (config.matchBlacklist(url))
|
||||||
{
|
{
|
||||||
return ServletUtils.webFluxResponseWriter(exchange.getResponse(), "请求地址不允许访问",jaData);
|
return ServletUtils.webFluxResponseWriter(exchange.getResponse(), "请求地址不允许访问",encryptEnabled);
|
||||||
}
|
}
|
||||||
|
|
||||||
return chain.filter(exchange);
|
return chain.filter(exchange);
|
||||||
|
|
|
||||||
|
|
@ -50,7 +50,7 @@ import java.util.Map;
|
||||||
public class RequestCoverFilter implements GlobalFilter, Ordered {
|
public class RequestCoverFilter implements GlobalFilter, Ordered {
|
||||||
|
|
||||||
@Value("${system.decryptEnabled}")
|
@Value("${system.decryptEnabled}")
|
||||||
public boolean jaData;
|
public boolean decryptEnabled;
|
||||||
public final static String APPLICATION_JSON_UTF8="application/json;charset=UTF-8";
|
public final static String APPLICATION_JSON_UTF8="application/json;charset=UTF-8";
|
||||||
/**
|
/**
|
||||||
* default HttpMessageReader
|
* default HttpMessageReader
|
||||||
|
|
@ -85,7 +85,7 @@ public class RequestCoverFilter implements GlobalFilter, Ordered {
|
||||||
return chain.filter(exchange);
|
return chain.filter(exchange);
|
||||||
}
|
}
|
||||||
//是否进行加密
|
//是否进行加密
|
||||||
if(jaData){
|
if(decryptEnabled){
|
||||||
Object obj= formData.get(SystemGlobal.FORM_DATA);
|
Object obj= formData.get(SystemGlobal.FORM_DATA);
|
||||||
if(!ObjectUtils.isEmpty(obj)){
|
if(!ObjectUtils.isEmpty(obj)){
|
||||||
String data= obj.toString();
|
String data= obj.toString();
|
||||||
|
|
|
||||||
|
|
@ -41,7 +41,7 @@ import static org.springframework.http.MediaType.MULTIPART_FORM_DATA_VALUE;
|
||||||
public class ResponseEncryptFilter implements GlobalFilter, Ordered {
|
public class ResponseEncryptFilter implements GlobalFilter, Ordered {
|
||||||
|
|
||||||
@Value("${system.encryptEnabled}")
|
@Value("${system.encryptEnabled}")
|
||||||
public boolean jaData;
|
public boolean encryptEnabled;
|
||||||
/**
|
/**
|
||||||
* 返回的数据 是否加密
|
* 返回的数据 是否加密
|
||||||
*/
|
*/
|
||||||
|
|
@ -77,7 +77,7 @@ public class ResponseEncryptFilter implements GlobalFilter, Ordered {
|
||||||
return chain.filter(exchange);
|
return chain.filter(exchange);
|
||||||
}
|
}
|
||||||
//是否加密
|
//是否加密
|
||||||
if(!jaData){
|
if(!encryptEnabled){
|
||||||
return chain.filter(exchange);
|
return chain.filter(exchange);
|
||||||
}
|
}
|
||||||
// 根据具体业务内容,修改响应体
|
// 根据具体业务内容,修改响应体
|
||||||
|
|
|
||||||
|
|
@ -35,6 +35,9 @@ public class ValidateCodeFilter extends AbstractGatewayFilterFactory<Object>
|
||||||
{
|
{
|
||||||
private final static String[] VALIDATE_URL = new String[] { "/auth/login", "/auth/register" };
|
private final static String[] VALIDATE_URL = new String[] { "/auth/login", "/auth/register" };
|
||||||
|
|
||||||
|
@Value("${system.decryptEnabled}")
|
||||||
|
public boolean decryptEnabled;
|
||||||
|
|
||||||
@Value("${system.encryptEnabled}")
|
@Value("${system.encryptEnabled}")
|
||||||
public boolean encryptEnabled;
|
public boolean encryptEnabled;
|
||||||
|
|
||||||
|
|
@ -63,7 +66,9 @@ public class ValidateCodeFilter extends AbstractGatewayFilterFactory<Object>
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
String rspStr = resolveBodyFromRequest(request);
|
String rspStr = resolveBodyFromRequest(request);
|
||||||
|
if (decryptEnabled) {
|
||||||
rspStr= AesCbcUtils.decrypt(rspStr);
|
rspStr= AesCbcUtils.decrypt(rspStr);
|
||||||
|
}
|
||||||
if(StringUtils.isEmpty(rspStr)){
|
if(StringUtils.isEmpty(rspStr)){
|
||||||
throw new CaptchaException("请求参数异常");
|
throw new CaptchaException("请求参数异常");
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue