| | |
| | | * @author sws |
| | | * @date 2022-09-28 |
| | | */ |
| | | |
| | | @Service |
| | | public class TokenService implements TokenMapper { |
| | | @Autowired |
| | |
| | | @Override |
| | | public Integer updateTokenExpire(TokenEntity tokenEntity) { |
| | | clearCache(tokenEntity.getToken()); |
| | | |
| | | return tokenMapper.updateTokenExpire(tokenEntity); |
| | | } |
| | | |
| | |
| | | * 获取新的令牌实体类 |
| | | */ |
| | | public TokenEntity getNewToken(UserEntity ue, HttpServletRequest req) { |
| | | return getNewToken(0, SettingData.TOKEN_EXPIRE, ue, req); |
| | | } |
| | | |
| | | /** |
| | | * 获取新的令牌实体类 |
| | | */ |
| | | public TokenEntity getNewToken(Integer type, Integer min, UserEntity ue, HttpServletRequest req) { |
| | | TokenEntity te = new TokenEntity(); |
| | | te.setToken(WebHelper.getGuid()); |
| | | te.setDuration(SettingData.TOKEN_EXPIRE); |
| | | te.setExpire(WebHelper.getTimestamp(SettingData.TOKEN_EXPIRE)); |
| | | te.setType(0); |
| | | te.setDuration(min); |
| | | te.setExpire(WebHelper.getTimestamp(min)); |
| | | te.setType(type); |
| | | te.setIp(WebHelper.getIpAddress(req)); |
| | | te.setCreateUser(ue.getId()); |
| | | te.setUname(ue.getUname()); |
| | |
| | | |
| | | // db |
| | | TokenEntity te = selectOneByToken(token); |
| | | if (te != null) { |
| | | if (null != te) { |
| | | redisService.put(tokenKey, te, te.getDuration(), TimeUnit.MINUTES); |
| | | return true; |
| | | } |
| | |
| | | // db,设置令牌过期 |
| | | te.setUpdateUser(ue.getId()); |
| | | Integer rows = updateTokenExpire(te); |
| | | if (rows == 0) { |
| | | if (0 == rows) { |
| | | return false; |
| | | } |
| | | |
| | |
| | | |
| | | // db |
| | | TokenEntity te = selectOneByToken(token); |
| | | if (te != null) { |
| | | if (null != te) { |
| | | redisService.put(tokenKey, te, te.getDuration(), TimeUnit.MINUTES); |
| | | } |
| | | |
| | |
| | | return null; |
| | | } |
| | | |
| | | String userKey = RedisCacheKey.signUserKey(token); |
| | | |
| | | // redis |
| | | String userKey = RedisCacheKey.signUserKey(token); |
| | | Object obj = redisService.get(userKey); |
| | | if (obj instanceof UserEntity) { |
| | | return (UserEntity) obj; |
| | |
| | | |
| | | // db |
| | | UserEntity ue = usersService.selectByToken(token); |
| | | if (ue != null) { |
| | | TokenEntity te = getEntityByToken(token); |
| | | if (te != null) { |
| | | redisService.put(userKey, ue, te.getDuration(), TimeUnit.MINUTES); |
| | | } |
| | | } |
| | | // if (null != ue) { |
| | | // getEntityByToken(token); |
| | | // } |
| | | |
| | | return ue; |
| | | } |
| | |
| | | String key = RedisCacheKey.signPwdError(ue.getUid()); |
| | | Object objCount = redisService.get(key); |
| | | |
| | | return objCount != null && (int) objCount >= SettingData.PWD_ERR_COUNT; |
| | | return null != objCount && (int) objCount >= SettingData.PWD_ERR_COUNT; |
| | | } |
| | | } |