spring boot 配置 http转化器

男娘i 2023-07-08 14:24 21阅读 0赞

public class WithSignMessageConverter extends FastJsonHttpMessageConverter {
    
        @Autowired
        JwtProperties jwtProperties;
    
        @Autowired
        JwtTokenUtil jwtTokenUtil;
    
        @Autowired
        DataSecurityAction dataSecurityAction;
    
        @Autowired
        SpringContextUtils springContextUtils;
    
        @Override
        public Object read(Type type, Class<?> contextClass, HttpInputMessage inputMessage) throws IOException, HttpMessageNotReadableException {
    
            HttpServletRequest request = springContextUtils.getRequest();
            InputStream in = inputMessage.getBody();
            if (jwtProperties.getAuthPath().contains(request.getRequestURI())) {
                String json = IOUtils.toString(in, StandardCharsets.UTF_8);
                return JSON.parseObject(json, type);
            }
    
            Object o = JSON.parseObject(in, super.getFastJsonConfig().getCharset(), BaseTransferEntity.class, super.getFastJsonConfig().getFeatures());
    
            //先转化成原始的对象
            BaseTransferEntity baseTransferEntity = (BaseTransferEntity) o;
    
            //校验签名
            //String token = HttpKit.getRequest().getHeader(jwtProperties.getHeader()).substring(7);
            String token = request.getHeader(jwtProperties.getHeader()).substring(7);
            String md5KeyFromToken = jwtTokenUtil.getMd5KeyFromToken(token);
    
            String object = baseTransferEntity.getObject();
            String json = dataSecurityAction.unlock(object);
            String encrypt = MD5Util.encrypt(object + md5KeyFromToken);
    
            if (encrypt.equals(baseTransferEntity.getSign())) {
                System.out.println("签名校验成功!");
            } else {
                System.out.println("签名校验失败,数据被改动过!");
                throw new AttendanceException(ErrorCodeEnum.SIGN_ERROR);
            }
    
            //校验签名后再转化成应该的对象
            return JSON.parseObject(json, type);
        }