packagecom.gmac.backend.management.interceptor;importjavax.servlet.http.HttpServletRequest;importjavax.servlet.http.HttpServletResponse;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.security.oauth2.common.exceptions.InvalidTokenException;importorg.springframework.stereotype.Component;importorg.springframework.web.servlet.HandlerInterceptor;importorg.springframework.web.servlet.ModelAndView;importcom.gmac.backend.management.controller.BaseController;importcom.gmac.backend.management.redis.RedisService;importcom.gmac.common.utils.StringUtil;importlombok.extern.slf4j.Slf4j;/*** 自定义登录拦截器
*@authorV_PS68C7
**/@Slf4j
@Componentpublic class LoginInterceptor extends BaseController implementsHandlerInterceptor {
@AutowiredprivateRedisService redisService;/*** 在请求处理之前进行调用(Controller方法调用之前)*/@Overridepublic booleanpreHandle(HttpServletRequest request, HttpServletResponse response, Object object) {
log.debug("[START] - check userId");
String userId= super.getUserId();//从Redis中读取userId
if(StringUtil.isNullOrEmpty(userId)) {
log.debug("[error] - userId is empty");throw new InvalidTokenException("userId为空");
}else{//验证userId在Redis中是否存在
boolean check =redisService.checkUserId(userId);if(check) {//存在就重新添加覆盖掉之前的
redisService.addUserId(userId);
log.debug("[DEBUG] - 重新添加用户id到Redis");
}else{//不存在就抛出异常
String errorMsg = "用户访问超时 用户ID : ".concat(userId);
log.debug("[error] - Landing timeout return：{}", errorMsg);throw newInvalidTokenException(errorMsg);
}
}
log.debug("[END] - check userId");return true;
}/*** 请求处理之后进行调用，但是在视图被渲染之前(Controller方法调用之后)*/@Overridepublic void postHandle(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, Object object, ModelAndView modelAndView) throwsException {
}/*** 在整个请求结束之后被调用，也就是在DispatcherServlet 渲染了对应的视图之后执行(主要是用于进行资源清理工作)*/@Overridepublic void afterCompletion(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, Object object, Exception e) throwsException {
}
}