明星电力充电桩
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
无关风月
2024-08-10 7f288c7515fa04cf83fadc3506317d08fb099630 
 ruoyi-gateway/src/main/java/com/ruoyi/gateway/filter/AuthFilter.java


@@ -1,5 +1,7 @@


package com.ruoyi.gateway.filter;




import com.alibaba.fastjson.JSONObject;


import org.apache.commons.codec.binary.Base64;


import org.slf4j.Logger;


import org.slf4j.LoggerFactory;


import org.springframework.beans.factory.annotation.Autowired;


@@ -7,7 +9,10 @@


import org.springframework.cloud.gateway.filter.GatewayFilterChain;


import org.springframework.cloud.gateway.filter.GlobalFilter;


import org.springframework.core.Ordered;


import org.springframework.core.io.buffer.DataBuffer;


import org.springframework.http.HttpHeaders;


import org.springframework.http.server.reactive.ServerHttpRequest;


import org.springframework.http.server.reactive.ServerHttpRequestDecorator;


import org.springframework.stereotype.Component;


import org.springframework.web.server.ServerWebExchange;


import com.ruoyi.common.core.constant.CacheConstants;


@@ -20,7 +25,14 @@


import com.ruoyi.common.redis.service.RedisService;


import com.ruoyi.gateway.config.properties.IgnoreWhiteProperties;


import io.jsonwebtoken.Claims;


import reactor.core.publisher.Flux;


import reactor.core.publisher.Mono;




import java.util.ArrayList;


import java.util.Collections;


import java.util.Comparator;


import java.util.List;


import java.util.concurrent.atomic.AtomicReference;




/**


 * 网关鉴权


@@ -37,9 +49,6 @@




    @Autowired


    private RedisService redisService;


    


    @Value("${security.sign}")


    private boolean parameter_signature;






    @Override


@@ -70,15 +79,7 @@


        if (StringUtils.isEmpty(userid) || StringUtils.isEmpty(username)) {


            return unauthorizedResponse(exchange, "令牌验证失败");


        }


        if(parameter_signature){


            String sign = request.getHeaders().getFirst(TokenConstants.SING);


            String nonce_str = request.getHeaders().getFirst(TokenConstants.NONCE_STR);


            if(StringUtils.isEmpty(sign) || StringUtils.isEmpty(nonce_str)){


                log.error("[鉴权签名异常处理]请求路径:{}", exchange.getRequest().getPath());


                return ServletUtils.webFluxResponseWriter(exchange.getResponse(), "签名校验失败", HttpStatus.BAD_REQUEST);


            }


        }


        




        // 设置用户信息到请求


        addHeader(mutate, SecurityConstants.USER_KEY, userkey);


        addHeader(mutate, SecurityConstants.DETAILS_USER_ID, userid);


@@ -126,10 +127,11 @@


        }


        return token;


    }




    


    


    @Override


    public int getOrder()


    {


        return -200;


        return -300;


    }


}