package com.iplatform.base.cache;
|
|
import com.iplatform.base.Constants;
|
import com.iplatform.base.DefaultUserPrincipal;
|
import com.iplatform.base.VariableConstants;
|
import com.iplatform.base.util.TokenUtils;
|
import com.iplatform.base.util.UserUtils;
|
import com.walker.cache.Cache;
|
import com.walker.infrastructure.utils.JsonUtils;
|
import com.walker.infrastructure.utils.StringUtils;
|
import com.walker.support.redis.cache.RedisCacheProvider;
|
import com.walker.web.UserOnlineProvider;
|
import com.walker.web.UserPrincipal;
|
|
/**
|
* Redis实现的用户登录缓存提供者。
|
* @author 时克英
|
* @date 2022-11-14
|
*/
|
public class RedisUserOnlineProvider extends RedisCacheProvider<String> implements UserOnlineProvider {
|
|
public RedisUserOnlineProvider(){
|
this.setUseRedis(true);
|
this.setLoadPage(false);
|
// 2024-01-05 设置支持缓存失效，该参数很重要，如果需要失效而没有设置在调用后会出现数据无法失效！
|
this.setSupportExpiredCache(true);
|
}
|
|
@Override
|
public String getProviderName() {
|
return Constants.CACHE_NAME_ONLINE_USER;
|
}
|
|
@Override
|
public Class<?> getProviderType() {
|
return String.class;
|
}
|
|
@Override
|
protected int loadDataToCache(Cache cache){
|
// 因为登录缓存在redis中，因此启动时无需重新加载
|
return 0;
|
}
|
|
@Override
|
public UserPrincipal<?> getUserPrincipal(String token) {
|
// UserPrincipal<?> userPrincipal = this.getCacheData(token);
|
String userJson = this.getCacheData(token);
|
if(StringUtils.isEmpty(userJson)){
|
logger.warn("缓存未获取登录信息, token=" + token);
|
return null;
|
}
|
try {
|
// 由于存在泛型，因此直接调用 JsonUtils.jsonStringToObject() 方法报错。
|
// 只能转成JSON自定义解析反序列化。2022-11-15
|
// ObjectNode objectNode = JsonUtils.jsonStringToObjectNode(userJson);
|
// return this.createUserPrincipal(objectNode);
|
return UserUtils.toUserPrincipal(userJson);
|
// return JsonUtils.jsonStringToObject(userJson, DefaultUserPrincipal.class);
|
} catch (Exception e) {
|
throw new RuntimeException("缓存获取登录信息错误, token=" + token + ", " + e.getMessage(), e);
|
}
|
|
// if(userPrincipal == null){
|
// logger.warn("UserOnlineProvider 缓存用户不存在, token = " + token);
|
// return null;
|
// }
|
// return userPrincipal;
|
}
|
|
@Deprecated
|
@Override
|
public boolean cacheUserPrincipal(String token, UserPrincipal<?> userPrincipal) {
|
// logger.debug("redis写入登录用户缓存(token=uuid): " + token);
|
// try {
|
// String userJson = JsonUtils.objectToJsonString((DefaultUserPrincipal)userPrincipal);
|
// this.putCacheData(token, userJson, TokenUtils.acquireCacheUserExpiredSeconds(VariableConstants.DEFAULT_TOKEN_EXPIRED_MINUTES));
|
// } catch (Exception e) {
|
// throw new RuntimeException("登录信息写入缓存错误: " + e.getMessage(), e);
|
// }
|
// return true;
|
return this.cacheUserPrincipal(token, userPrincipal, VariableConstants.DEFAULT_TOKEN_EXPIRED_MINUTES);
|
}
|
|
@Override
|
public boolean cacheUserPrincipal(String token, UserPrincipal<?> userPrincipal, long expiredMinutes) {
|
logger.debug("redis写入登录用户缓存(token=uuid): " + token);
|
try {
|
String userJson = JsonUtils.objectToJsonString((DefaultUserPrincipal)userPrincipal);
|
// logger.info(userJson);
|
this.putCacheData(token, userJson, TokenUtils.acquireCacheUserExpiredSeconds(expiredMinutes));
|
} catch (Exception e) {
|
throw new RuntimeException("登录信息写入缓存错误: " + e.getMessage(), e);
|
}
|
return true;
|
}
|
|
@Override
|
public boolean updateUserPrincipalTimeStamp(String token) {
|
return false;
|
}
|
|
@Override
|
public boolean removeUserPrincipal(String token) {
|
this.removeCacheData(token);
|
return true;
|
}
|
|
/*private DefaultUserPrincipal createUserPrincipal(ObjectNode objectNode){
|
JsonNode userInfoNode = objectNode.get("userInfo");
|
S_user_core user_core = new S_user_core();
|
user_core.setId(userInfoNode.get("id").asLong());
|
user_core.setUser_name(userInfoNode.get("user_name").asText());
|
user_core.setPassword(userInfoNode.get("password").asText());
|
user_core.setDept_id(userInfoNode.get("dept_id").asLong());
|
user_core.setNick_name(userInfoNode.get("nick_name").asText());
|
user_core.setUser_type(userInfoNode.get("user_type").asInt());
|
user_core.setCreate_time(new Date(userInfoNode.get("create_time").asLong()));
|
user_core.setOrg_id(userInfoNode.get("org_id").asLong());
|
user_core.setStatus(userInfoNode.get("status").asInt());
|
user_core.setDel_flag(userInfoNode.get("del_flag").asInt());
|
if(!JsonUtils.isEmptyObject(userInfoNode.get("sex"))){
|
user_core.setSex(userInfoNode.get("sex").asText());
|
} else {
|
user_core.setSex("2");
|
}
|
if(!JsonUtils.isEmptyObject(userInfoNode.get("phonenumber"))){
|
user_core.setPhonenumber(userInfoNode.get("phonenumber").asText());
|
}
|
if(!JsonUtils.isEmptyObject(userInfoNode.get("avatar"))){
|
user_core.setAvatar(userInfoNode.get("avatar").asText());
|
}
|
if(!JsonUtils.isEmptyObject(userInfoNode.get("email"))){
|
user_core.setEmail(userInfoNode.get("email").asText());
|
}
|
if(!JsonUtils.isEmptyObject(userInfoNode.get("remark"))){
|
user_core.setRemark(userInfoNode.get("remark").asText());
|
}
|
if(!JsonUtils.isEmptyObject(userInfoNode.get("create_by"))){
|
user_core.setCreate_by(userInfoNode.get("create_by").asText());
|
}
|
if(!JsonUtils.isEmptyObject(userInfoNode.get("login_date"))){
|
user_core.setLogin_date(new Date(userInfoNode.get("login_date").asLong()));
|
}
|
if(!JsonUtils.isEmptyObject(userInfoNode.get("login_ip"))){
|
user_core.setLogin_ip(userInfoNode.get("login_ip").asText());
|
}
|
if(!JsonUtils.isEmptyObject(userInfoNode.get("update_by"))){
|
user_core.setUpdate_by(userInfoNode.get("update_by").asText());
|
}
|
if(!JsonUtils.isEmptyObject(userInfoNode.get("update_time"))){
|
user_core.setUpdate_time(new Date(userInfoNode.get("update_time").asLong()));
|
}
|
JsonNode roleIdListJson = objectNode.get("roleIdList");
|
List<String> roleList = new ArrayList<>(4);
|
if(roleIdListJson.isArray()){
|
for(Iterator<JsonNode> it = roleIdListJson.iterator(); it.hasNext();){
|
roleList.add(it.next().asText());
|
}
|
}
|
|
DefaultUserPrincipal defaultUserPrincipal = new DefaultUserPrincipal(user_core);
|
defaultUserPrincipal.setRoleIdList(roleList);
|
|
// 2022-12-21
|
JsonNode dataScopeMap = objectNode.get("dataScopeMap");
|
if(dataScopeMap != null){
|
String functionMenuId = null;
|
for(Iterator<String> it = dataScopeMap.fieldNames(); it.hasNext();){
|
functionMenuId = it.next();
|
defaultUserPrincipal.addDataScope(functionMenuId, dataScopeMap.get(functionMenuId).asText());
|
}
|
}
|
|
return defaultUserPrincipal;
|
}*/
|
}
|
