| | |
| | | package com.lf.server.service.data; |
| | | |
| | | import com.lf.server.entity.data.LoginEntity; |
| | | import com.lf.server.entity.data.TokenEntity; |
| | | import com.lf.server.entity.data.UsersEntity; |
| | | import com.lf.server.entity.sys.RedisCacheKey; |
| | | import com.lf.server.helper.StringHelper; |
| | | import com.lf.server.helper.WebHelper; |
| | |
| | | import javax.servlet.http.HttpServletRequest; |
| | | import javax.servlet.http.HttpServletResponse; |
| | | import java.util.List; |
| | | import java.util.concurrent.TimeUnit; |
| | | |
| | | /** |
| | | * 令牌表 |
| | |
| | | return tokenMapper.selectTokenAll(); |
| | | } |
| | | |
| | | /** |
| | | * 获取新的令牌实体类 |
| | | * |
| | | * @param userid |
| | | * @param req |
| | | * @return |
| | | */ |
| | | public TokenEntity getNewToken(int userid, HttpServletRequest req) { |
| | | int duration = 240; |
| | | |
| | |
| | | return te; |
| | | } |
| | | |
| | | /** |
| | | * 是否登录 |
| | | * |
| | | * @param req |
| | | * @param res |
| | | * @return |
| | | */ |
| | | public Boolean isLogin(HttpServletRequest req, HttpServletResponse res) { |
| | | String token = WebHelper.getToken(req); |
| | | if (StringHelper.isNull(token)) { |
| | |
| | | } |
| | | |
| | | // redis |
| | | if (redisService.hasKey(RedisCacheKey.ssoKey(token))) { |
| | | if (redisService.hasKey(RedisCacheKey.signTokenKey(token))) { |
| | | return true; |
| | | } |
| | | |
| | | return false; |
| | | } |
| | | |
| | | /** |
| | | * 根据令牌获取实体 |
| | | * |
| | | * @param token |
| | | * @return |
| | | */ |
| | | public TokenEntity getEntityByToken(String token) { |
| | | if (StringHelper.isNull(token)) { |
| | | return null; |
| | | } |
| | | |
| | | String key = RedisCacheKey.signTokenKey(token); |
| | | Object obj = redisService.get(key); |
| | | if (obj != null && obj instanceof TokenEntity) { |
| | | return (TokenEntity) obj; |
| | | } |
| | | |
| | | return null; |
| | | } |
| | | |
| | | /** |
| | | * 保存token |
| | | * |
| | | * @param te |
| | | * @param req |
| | | * @param res |
| | | */ |
| | | public void saveToken(UsersEntity ue, TokenEntity te, HttpServletRequest req, HttpServletResponse res) { |
| | | // 保存至Cookie |
| | | WebHelper.saveToken2Cookie(te.getToken(), req, res); |
| | | |
| | | // 令牌保存至Redis |
| | | String tokenKey = RedisCacheKey.signTokenKey(te.getToken()); |
| | | redisService.put(tokenKey, te, te.getDuration(), TimeUnit.MINUTES); |
| | | |
| | | String userKey = RedisCacheKey.signUserKey(te.getToken()); |
| | | redisService.put(userKey, ue, te.getDuration(), TimeUnit.MINUTES); |
| | | } |
| | | |
| | | /** |
| | | * 获取当前用户 |
| | | * @param req |
| | | * @return |
| | | */ |
| | | public UsersEntity getCurrentUser(HttpServletRequest req) { |
| | | String token = WebHelper.getToken(req); |
| | | if (StringHelper.isEmpty(token)) { |
| | | return null; |
| | | } |
| | | |
| | | String userKey = RedisCacheKey.signUserKey(token); |
| | | Object obj = redisService.get(userKey); |
| | | if (obj != null && obj instanceof UsersEntity) { |
| | | return (UsersEntity) obj; |
| | | } |
| | | |
| | | return null; |
| | | } |
| | | } |