From f34897212678d8e30297f5d8a80cc8600f718252 Mon Sep 17 00:00:00 2001 From: wangw <1594593906@qq.com> Date: Fri, 7 Jun 2024 13:54:50 +0800 Subject: [PATCH] =?UTF-8?q?=E9=92=88=E5=AF=B9=E6=9C=AC=E8=BA=ABtoken?= =?UTF-8?q?=E8=BF=87=E6=9C=9F=E7=9A=84=E9=97=AE=E9=A2=98=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../cashierservice/auth/LoginFilter.java | 31 ++++++++++++------- .../rabbit/IntegralConsumer.java | 5 --- 2 files changed, 19 insertions(+), 17 deletions(-) diff --git a/src/main/java/com/chaozhanggui/system/cashierservice/auth/LoginFilter.java b/src/main/java/com/chaozhanggui/system/cashierservice/auth/LoginFilter.java index da85e9b..c2bc136 100644 --- a/src/main/java/com/chaozhanggui/system/cashierservice/auth/LoginFilter.java +++ b/src/main/java/com/chaozhanggui/system/cashierservice/auth/LoginFilter.java @@ -100,16 +100,32 @@ public class LoginFilter implements Filter { } String message = ""; String tokenKey=""; + + JSONObject jsonObject1 = TokenUtil.parseParamFromToken(token); + if (jsonObject1.containsKey("status")){ + String openId = request.getHeader("openId"); + String userId = request.getHeader("id"); + redisUtil.deleteByKey(RedisCst.ONLINE_USER.concat(openId)); + redisUtil.deleteByKey(RedisCst.ONLINE_USER.concat(userId)); + redisUtil.deleteByKey(RedisCst.ONLINE_APP_USER.concat(userId)); + Result result = new Result(CodeEnum.TOKEN_EXPIRED); + String jsonString = JSONObject.toJSONString(result); + JSONObject jsonObject = JSONObject.parseObject(jsonString, JSONObject.class); + response.getWriter().print(jsonObject); + response.getWriter().flush();//流里边的缓存刷出 + return; + } + if(environment.equals("app")){ //获取当前登录人的用户id - String userId = TokenUtil.parseParamFromToken(token).getString("userId"); + String userId = jsonObject1.getString("userId"); tokenKey=RedisCst.ONLINE_APP_USER.concat(userId); //获取redis中的token }else if(environment.equals("wx")){ //获取当前登录人的用户id - String openId = TokenUtil.parseParamFromToken(token).getString("openId"); + String openId = jsonObject1.getString("openId"); if(StringUtils.isBlank(openId)){ - openId = TokenUtil.parseParamFromToken(token).getString("userId"); + openId = jsonObject1.getString("userId"); } tokenKey=RedisCst.ONLINE_USER.concat(openId); } @@ -131,15 +147,6 @@ public class LoginFilter implements Filter { response.getWriter().flush();//流里边的缓存刷出 return; } - JSONObject jsonObject1 = TokenUtil.parseParamFromToken(token); - if (jsonObject1.containsKey("status")){ - Result result = new Result(CodeEnum.TOKEN_EXPIRED); - String jsonString = JSONObject.toJSONString(result); - JSONObject jsonObject = JSONObject.parseObject(jsonString, JSONObject.class); - response.getWriter().print(jsonObject); - response.getWriter().flush();//流里边的缓存刷出 - return; - } checkRenewal(tokenKey); chain.doFilter(req, resp); } diff --git a/src/main/java/com/chaozhanggui/system/cashierservice/rabbit/IntegralConsumer.java b/src/main/java/com/chaozhanggui/system/cashierservice/rabbit/IntegralConsumer.java index 0cc66d9..a4155f3 100644 --- a/src/main/java/com/chaozhanggui/system/cashierservice/rabbit/IntegralConsumer.java +++ b/src/main/java/com/chaozhanggui/system/cashierservice/rabbit/IntegralConsumer.java @@ -1,15 +1,10 @@ package com.chaozhanggui.system.cashierservice.rabbit; import com.alibaba.fastjson.JSON; -import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; -import com.chaozhanggui.system.cashierservice.exception.MsgException; -import com.chaozhanggui.system.cashierservice.redis.RedisCst; import com.chaozhanggui.system.cashierservice.redis.RedisUtil; -import com.chaozhanggui.system.cashierservice.service.CartService; import com.chaozhanggui.system.cashierservice.service.IntegralService; import lombok.extern.slf4j.Slf4j; -import org.apache.commons.lang3.StringUtils; import org.springframework.amqp.rabbit.annotation.RabbitHandler; import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.beans.factory.annotation.Autowired;