ParkerZhou
4 years ago
committed by
GitHub
commit
a04f65aef2
@ -1,35 +0,0 @@
|
||||
/**
|
||||
* Copyright 2020 OPSLI 快速开发平台 https://www.opsli.com
|
||||
* <p>
|
||||
* Licensed under the Apache License, Version 2.0 (the "License"); you may not
|
||||
* use this file except in compliance with the License. You may obtain a copy of
|
||||
* the License at
|
||||
* <p>
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* <p>
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
||||
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
||||
* License for the specific language governing permissions and limitations under
|
||||
* the License.
|
||||
*/
|
||||
package org.opsli.common.constants;
|
||||
|
||||
/**
|
||||
* 字典缓存 常量
|
||||
*
|
||||
* @author Parker
|
||||
* @date 2020-09-16 17:42
|
||||
*/
|
||||
public interface DictConstants {
|
||||
|
||||
/** 缓存前缀 NAME */
|
||||
String CACHE_PREFIX_NAME = "dict:name:";
|
||||
|
||||
/** 缓存前缀 VALUE*/
|
||||
String CACHE_PREFIX_VALUE = "dict:value:";
|
||||
|
||||
/** 缓存前缀 LIST*/
|
||||
String CACHE_PREFIX_LIST = "dict:list:";
|
||||
|
||||
}
|
||||
@ -0,0 +1,68 @@
|
||||
package org.opsli.common.constants;
|
||||
|
||||
/**
|
||||
* Redis 常量
|
||||
* {} 为项目名称
|
||||
* @author 周鹏程
|
||||
* @date 2021/12/10 19:52
|
||||
*/
|
||||
public final class RedisConstants {
|
||||
|
||||
|
||||
/** 字典名称 */
|
||||
public static final String PREFIX_DICT_NAME = "hash#{}:dict:name:";
|
||||
|
||||
/** 字典值 VALUE */
|
||||
public static final String PREFIX_DICT_VALUE = "hash#{}:dict:value:";
|
||||
|
||||
/** 菜单编号 */
|
||||
public static final String PREFIX_MENU_CODE = "kv#{}:menu:code:";
|
||||
|
||||
/** 参数编号 */
|
||||
public static final String PREFIX_OPTIONS_CODE = "hash#{}:options";
|
||||
|
||||
/** 用户搜索记录 */
|
||||
public static final String PREFIX_HIS_USERNAME = "zset#{}:his:username:";
|
||||
|
||||
|
||||
|
||||
/** 用户ID */
|
||||
public static final String PREFIX_USER_ID = "kv#{}:user_id:";
|
||||
|
||||
/** 用户ID 和 角色 */
|
||||
public static final String PREFIX_USER_ID_AND_ROLES = "kv#{}:user_id:roles:";
|
||||
|
||||
/** 用户ID 和 默认角色 */
|
||||
public static final String PREFIX_USER_ID_DEF_ROLE = "kv#{}:user_id:def_role_id:";
|
||||
|
||||
/** 用户ID 和 组织 */
|
||||
public static final String PREFIX_USER_ID_ORGS = "kv#{}:user_id:orgs:";
|
||||
|
||||
/** 用户ID 和 默认组织 */
|
||||
public static final String PREFIX_USER_ID_DEF_ORG = "kv#{}:user_id:def_org:";
|
||||
|
||||
/** 用户ID 和 权限 */
|
||||
public static final String PREFIX_USER_ID_PERMISSIONS = "kv#{}:user_id:permissions:";
|
||||
|
||||
/** 用户ID 和 菜单 */
|
||||
public static final String PREFIX_USER_ID_MENUS = "kv#{}:user_id:menus:";
|
||||
|
||||
/** 用户名 */
|
||||
public static final String PREFIX_USERNAME = "kv#{}:username:";
|
||||
|
||||
|
||||
|
||||
/** 票据 */
|
||||
public static final String PREFIX_TICKET = "set#{}:ticket:";
|
||||
|
||||
/** 账号失败次数 */
|
||||
public static final String PREFIX_ACCOUNT_SLIP_COUNT = "kv#{}:account:slip:count:";
|
||||
|
||||
/** 账号失败锁定KEY */
|
||||
public static final String PREFIX_ACCOUNT_SLIP_LOCK = "kv#{}:account:slip:lock:";
|
||||
|
||||
|
||||
|
||||
|
||||
private RedisConstants(){}
|
||||
}
|
||||
@ -0,0 +1,73 @@
|
||||
/**
|
||||
* Copyright 2020 OPSLI 快速开发平台 https://www.opsli.com
|
||||
* <p>
|
||||
* Licensed under the Apache License, Version 2.0 (the "License"); you may not
|
||||
* use this file except in compliance with the License. You may obtain a copy of
|
||||
* the License at
|
||||
* <p>
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* <p>
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
||||
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
||||
* License for the specific language governing permissions and limitations under
|
||||
* the License.
|
||||
*/
|
||||
package org.opsli.core.cache;
|
||||
|
||||
import cn.hutool.core.convert.Convert;
|
||||
import cn.hutool.core.util.StrUtil;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.opsli.core.autoconfigure.properties.CacheProperties;
|
||||
import org.opsli.core.msg.CoreMsg;
|
||||
import org.opsli.core.utils.ThrowExceptionUtil;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.core.annotation.Order;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
import static org.opsli.common.constants.OrderConstants.UTIL_ORDER;
|
||||
|
||||
/**
|
||||
* 缓存工具类
|
||||
*
|
||||
* @author Parker
|
||||
* @date 2020-09-16 16:20
|
||||
*/
|
||||
@Slf4j
|
||||
@Order(UTIL_ORDER)
|
||||
@Component
|
||||
public class CacheUtil {
|
||||
|
||||
|
||||
/** 热点数据前缀 */
|
||||
private static String PREFIX_NAME;
|
||||
|
||||
/** 增加初始状态开关 防止异常使用 */
|
||||
private static boolean IS_INIT;
|
||||
|
||||
|
||||
|
||||
/**
|
||||
* 格式化Key
|
||||
* @param key 缓存Key
|
||||
* @return String
|
||||
*/
|
||||
public static String formatKey(String key){
|
||||
// 判断 工具类是否初始化完成
|
||||
ThrowExceptionUtil.isThrowException(!IS_INIT,
|
||||
CoreMsg.OTHER_EXCEPTION_UTILS_INIT);
|
||||
|
||||
return StrUtil.format(key, PREFIX_NAME);
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 初始化
|
||||
*/
|
||||
@Autowired
|
||||
public void init(CacheProperties cacheProperties){
|
||||
CacheUtil.PREFIX_NAME = Convert.toStr(cacheProperties.getPrefix(), "opsli");
|
||||
IS_INIT = true;
|
||||
}
|
||||
|
||||
}
|
||||
@ -1,38 +0,0 @@
|
||||
/**
|
||||
* Copyright 2020 OPSLI 快速开发平台 https://www.opsli.com
|
||||
* <p>
|
||||
* Licensed under the Apache License, Version 2.0 (the "License"); you may not
|
||||
* use this file except in compliance with the License. You may obtain a copy of
|
||||
* the License at
|
||||
* <p>
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* <p>
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
||||
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
||||
* License for the specific language governing permissions and limitations under
|
||||
* the License.
|
||||
*/
|
||||
package org.opsli.core.cache.pushsub.entity;
|
||||
|
||||
import lombok.AllArgsConstructor;
|
||||
import lombok.Data;
|
||||
import lombok.NoArgsConstructor;
|
||||
import org.apache.commons.lang3.builder.ToStringBuilder;
|
||||
import org.opsli.core.cache.pushsub.enums.PushSubType;
|
||||
|
||||
/**
|
||||
* 热点数据处理 Entity
|
||||
*
|
||||
* @author Parker
|
||||
* @date 2020-09-18 00:01
|
||||
*/
|
||||
@Data
|
||||
@AllArgsConstructor
|
||||
@NoArgsConstructor
|
||||
public class CacheDataEntity {
|
||||
|
||||
/** key */
|
||||
private String key;
|
||||
|
||||
}
|
||||
@ -1,34 +0,0 @@
|
||||
/**
|
||||
* Copyright 2020 OPSLI 快速开发平台 https://www.opsli.com
|
||||
* <p>
|
||||
* Licensed under the Apache License, Version 2.0 (the "License"); you may not
|
||||
* use this file except in compliance with the License. You may obtain a copy of
|
||||
* the License at
|
||||
* <p>
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* <p>
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
||||
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
||||
* License for the specific language governing permissions and limitations under
|
||||
* the License.
|
||||
*/
|
||||
package org.opsli.core.cache.pushsub.enums;
|
||||
|
||||
/**
|
||||
* 缓存操作类型
|
||||
*
|
||||
* @author Parker
|
||||
* @date 2020-09-16
|
||||
*/
|
||||
public enum CacheHandleType {
|
||||
|
||||
/** 更新 */
|
||||
UPDATE,
|
||||
|
||||
/** 删除 */
|
||||
DELETE,
|
||||
|
||||
;
|
||||
|
||||
}
|
||||
@ -1,34 +0,0 @@
|
||||
/**
|
||||
* Copyright 2020 OPSLI 快速开发平台 https://www.opsli.com
|
||||
* <p>
|
||||
* Licensed under the Apache License, Version 2.0 (the "License"); you may not
|
||||
* use this file except in compliance with the License. You may obtain a copy of
|
||||
* the License at
|
||||
* <p>
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* <p>
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
||||
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
||||
* License for the specific language governing permissions and limitations under
|
||||
* the License.
|
||||
*/
|
||||
package org.opsli.core.cache.pushsub.enums;
|
||||
|
||||
/**
|
||||
* 缓存操作类型
|
||||
*
|
||||
* @author Parker
|
||||
* @date 2020-09-16
|
||||
*/
|
||||
public enum DictModelType {
|
||||
|
||||
/** 对象 */
|
||||
OBJECT,
|
||||
|
||||
/** 集合 */
|
||||
COLLECTION,
|
||||
|
||||
;
|
||||
|
||||
}
|
||||
@ -1,67 +0,0 @@
|
||||
/**
|
||||
* Copyright 2020 OPSLI 快速开发平台 https://www.opsli.com
|
||||
* <p>
|
||||
* Licensed under the Apache License, Version 2.0 (the "License"); you may not
|
||||
* use this file except in compliance with the License. You may obtain a copy of
|
||||
* the License at
|
||||
* <p>
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* <p>
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
||||
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
||||
* License for the specific language governing permissions and limitations under
|
||||
* the License.
|
||||
*/
|
||||
package org.opsli.core.cache.pushsub.enums;
|
||||
|
||||
/**
|
||||
* 消息具体类型
|
||||
*
|
||||
* @author Parker
|
||||
* @date 2020-09-16
|
||||
*/
|
||||
public enum MsgArgsType {
|
||||
|
||||
/** 字典模型 */
|
||||
DICT_MODEL,
|
||||
/** 字典模型-集合 */
|
||||
DICT_MODELS,
|
||||
/** 字典模型-传输类型 */
|
||||
DICT_MODEL_TYPE,
|
||||
/** 字典操作类型 */
|
||||
DICT_TYPE,
|
||||
|
||||
/** 用户ID */
|
||||
USER_ID,
|
||||
/** 用户名 */
|
||||
USER_USERNAME,
|
||||
/** 用户数据类型 */
|
||||
USER_MODEL_TYPE,
|
||||
/** 用户数据*/
|
||||
USER_MODEL_DATA,
|
||||
|
||||
/** 组织 用户ID */
|
||||
ORG_USER_ID,
|
||||
/** 组织 用户数据 */
|
||||
ORG_USER_DATA,
|
||||
|
||||
/** 租户ID */
|
||||
TENANT_ID,
|
||||
/** 租户数据 */
|
||||
TENANT_DATA,
|
||||
|
||||
/** 参数编号 */
|
||||
OPTION_CODE,
|
||||
/** 参数数据*/
|
||||
OPTION_MODEL_DATA,
|
||||
|
||||
/** 缓存数据Key */
|
||||
CACHE_DATA_KEY,
|
||||
/** 缓存数据Value */
|
||||
CACHE_DATA_VALUE,
|
||||
/** 缓存数据Type */
|
||||
CACHE_DATA_TYPE,
|
||||
;
|
||||
|
||||
}
|
||||
@ -1,50 +0,0 @@
|
||||
/**
|
||||
* Copyright 2020 OPSLI 快速开发平台 https://www.opsli.com
|
||||
* <p>
|
||||
* Licensed under the Apache License, Version 2.0 (the "License"); you may not
|
||||
* use this file except in compliance with the License. You may obtain a copy of
|
||||
* the License at
|
||||
* <p>
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* <p>
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
||||
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
||||
* License for the specific language governing permissions and limitations under
|
||||
* the License.
|
||||
*/
|
||||
package org.opsli.core.cache.pushsub.enums;
|
||||
|
||||
/**
|
||||
* 发布订阅类型
|
||||
*
|
||||
* @author Parker
|
||||
* @date 2020-09-16
|
||||
*/
|
||||
public enum PushSubType {
|
||||
|
||||
/** 字典类型 */
|
||||
DICT,
|
||||
|
||||
/** 用户数据 */
|
||||
USER,
|
||||
|
||||
/** 菜单数据 */
|
||||
MENU,
|
||||
|
||||
/** 组织数据 */
|
||||
ORG,
|
||||
|
||||
/** 租户 */
|
||||
TENANT,
|
||||
|
||||
/** 系统数据 */
|
||||
OPTION,
|
||||
|
||||
/** 热点数据 */
|
||||
HOT_DATA,
|
||||
|
||||
;
|
||||
|
||||
|
||||
}
|
||||
@ -1,37 +0,0 @@
|
||||
/**
|
||||
* Copyright 2020 OPSLI 快速开发平台 https://www.opsli.com
|
||||
* <p>
|
||||
* Licensed under the Apache License, Version 2.0 (the "License"); you may not
|
||||
* use this file except in compliance with the License. You may obtain a copy of
|
||||
* the License at
|
||||
* <p>
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* <p>
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
||||
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
||||
* License for the specific language governing permissions and limitations under
|
||||
* the License.
|
||||
*/
|
||||
package org.opsli.core.cache.pushsub.enums;
|
||||
|
||||
/**
|
||||
* 用户缓存操作类型
|
||||
*
|
||||
* @author Parker
|
||||
* @date 2020-09-16
|
||||
*/
|
||||
public enum UserModelType {
|
||||
|
||||
/** 用户模型 */
|
||||
USER_MODEL,
|
||||
/** 用户角色集合模型 */
|
||||
USER_ROLES_MODEL,
|
||||
/** 用户权限集合模型 */
|
||||
USER_PERMS_MODEL,
|
||||
/** 用户菜单集合模型 */
|
||||
USER_MENU_MODEL,
|
||||
|
||||
;
|
||||
|
||||
}
|
||||
@ -1,109 +0,0 @@
|
||||
/**
|
||||
* Copyright 2020 OPSLI 快速开发平台 https://www.opsli.com
|
||||
* <p>
|
||||
* Licensed under the Apache License, Version 2.0 (the "License"); you may not
|
||||
* use this file except in compliance with the License. You may obtain a copy of
|
||||
* the License at
|
||||
* <p>
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* <p>
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
||||
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
||||
* License for the specific language governing permissions and limitations under
|
||||
* the License.
|
||||
*/
|
||||
package org.opsli.core.cache.pushsub.handler;
|
||||
|
||||
import cn.hutool.core.collection.CollUtil;
|
||||
import cn.hutool.core.convert.Convert;
|
||||
import com.alibaba.fastjson.JSONObject;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.opsli.api.wrapper.system.dict.DictWrapper;
|
||||
import org.opsli.common.constants.CacheConstants;
|
||||
import org.opsli.common.constants.DictConstants;
|
||||
import org.opsli.common.enums.CacheType;
|
||||
import org.opsli.core.cache.local.CacheUtil;
|
||||
import org.opsli.core.cache.pushsub.enums.CacheHandleType;
|
||||
import org.opsli.core.cache.pushsub.enums.DictModelType;
|
||||
import org.opsli.core.cache.pushsub.enums.MsgArgsType;
|
||||
import org.opsli.core.cache.pushsub.enums.PushSubType;
|
||||
import org.opsli.plugins.cache.EhCachePlugin;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 字典消息处理
|
||||
*
|
||||
* @author Parker
|
||||
* @date 2020-09-16
|
||||
*/
|
||||
@Slf4j
|
||||
public class DictHandler implements RedisPushSubHandler{
|
||||
|
||||
@Autowired
|
||||
private EhCachePlugin ehCachePlugin;
|
||||
|
||||
@Override
|
||||
public PushSubType getType() {
|
||||
return PushSubType.DICT;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void handler(JSONObject msgJson) {
|
||||
DictModelType dictModelType = DictModelType.valueOf((String) msgJson.get(MsgArgsType.DICT_MODEL_TYPE.toString()));
|
||||
CacheHandleType type = CacheHandleType.valueOf((String) msgJson.get(MsgArgsType.DICT_TYPE.toString()));
|
||||
|
||||
if(DictModelType.COLLECTION == dictModelType){
|
||||
Object dictListObj = msgJson.get(MsgArgsType.DICT_MODELS.toString());
|
||||
List<DictWrapper> dictWrappers = Convert.toList(DictWrapper.class, dictListObj);
|
||||
if(CollUtil.isNotEmpty(dictWrappers)){
|
||||
for (DictWrapper dictWrapper : dictWrappers) {
|
||||
this.handler(dictWrapper, type);
|
||||
}
|
||||
}
|
||||
} else if(DictModelType.OBJECT == dictModelType){
|
||||
JSONObject jsonObject = msgJson.getJSONObject(MsgArgsType.DICT_MODEL.toString());
|
||||
if(jsonObject == null){
|
||||
return;
|
||||
}
|
||||
|
||||
DictWrapper dictWrapperModel = jsonObject.toJavaObject(DictWrapper.class);
|
||||
this.handler(dictWrapperModel, type);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 真正处理 - 只是处理自己本地的缓存
|
||||
* @param dictWrapperModel model
|
||||
* @param type 类型
|
||||
*/
|
||||
private void handler(DictWrapper dictWrapperModel, CacheHandleType type){
|
||||
|
||||
// 解析 key
|
||||
String ehKeyByName = CacheUtil.handleKey(CacheType.EDEN_HASH, DictConstants.CACHE_PREFIX_NAME +
|
||||
dictWrapperModel.getTypeCode() + ":" + dictWrapperModel.getDictName());
|
||||
String ehKeyByValue = CacheUtil.handleKey(CacheType.EDEN_HASH, DictConstants.CACHE_PREFIX_VALUE +
|
||||
dictWrapperModel.getTypeCode() + ":" + dictWrapperModel.getDictValue());
|
||||
|
||||
// 缓存更新
|
||||
if(CacheHandleType.UPDATE == type){
|
||||
ehCachePlugin.delete(CacheConstants.EHCACHE_SPACE, ehKeyByName);
|
||||
ehCachePlugin.delete(CacheConstants.EHCACHE_SPACE, ehKeyByValue);
|
||||
|
||||
// 统一转换为 JSONObject
|
||||
String jsonStr = JSONObject.toJSONString(dictWrapperModel.getModel());
|
||||
JSONObject value = JSONObject.parseObject(jsonStr);
|
||||
ehCachePlugin.put(CacheConstants.EHCACHE_SPACE, ehKeyByName, value);
|
||||
ehCachePlugin.put(CacheConstants.EHCACHE_SPACE, ehKeyByValue, value);
|
||||
}
|
||||
// 缓存删除
|
||||
else if(CacheHandleType.DELETE == type){
|
||||
ehCachePlugin.delete(CacheConstants.EHCACHE_SPACE, ehKeyByName);
|
||||
ehCachePlugin.delete(CacheConstants.EHCACHE_SPACE, ehKeyByValue);
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
@ -1,68 +0,0 @@
|
||||
/**
|
||||
* Copyright 2020 OPSLI 快速开发平台 https://www.opsli.com
|
||||
* <p>
|
||||
* Licensed under the Apache License, Version 2.0 (the "License"); you may not
|
||||
* use this file except in compliance with the License. You may obtain a copy of
|
||||
* the License at
|
||||
* <p>
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* <p>
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
||||
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
||||
* License for the specific language governing permissions and limitations under
|
||||
* the License.
|
||||
*/
|
||||
package org.opsli.core.cache.pushsub.handler;
|
||||
|
||||
import com.alibaba.fastjson.JSONObject;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.apache.commons.lang3.StringUtils;
|
||||
import org.opsli.common.constants.CacheConstants;
|
||||
import org.opsli.core.cache.local.CacheUtil;
|
||||
import org.opsli.core.cache.pushsub.enums.CacheHandleType;
|
||||
import org.opsli.core.cache.pushsub.enums.MsgArgsType;
|
||||
import org.opsli.core.cache.pushsub.enums.PushSubType;
|
||||
import org.opsli.plugins.cache.EhCachePlugin;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
|
||||
/**
|
||||
* 热数据处理
|
||||
*
|
||||
* @author Parker
|
||||
* @date 2020-09-16
|
||||
*/
|
||||
@Slf4j
|
||||
public class HotDataHandler implements RedisPushSubHandler{
|
||||
|
||||
@Autowired
|
||||
private EhCachePlugin ehCachePlugin;
|
||||
|
||||
@Override
|
||||
public PushSubType getType() {
|
||||
return PushSubType.HOT_DATA;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void handler(JSONObject msgJson) {
|
||||
String key = (String) msgJson.get(MsgArgsType.CACHE_DATA_KEY.toString());
|
||||
Object value = msgJson.get(MsgArgsType.CACHE_DATA_VALUE.toString());
|
||||
CacheHandleType type = CacheHandleType.valueOf((String )msgJson.get(MsgArgsType.CACHE_DATA_TYPE.toString()));
|
||||
|
||||
if(StringUtils.isEmpty(key)){
|
||||
return;
|
||||
}
|
||||
|
||||
// 拼装缓存key
|
||||
String cacheName = CacheUtil.handleKey(CacheConstants.HOT_DATA_PREFIX +":"+ key);
|
||||
|
||||
if(CacheHandleType.UPDATE == type){
|
||||
ehCachePlugin.put(CacheConstants.EHCACHE_SPACE, cacheName, value);
|
||||
}
|
||||
// 缓存删除
|
||||
else if(CacheHandleType.DELETE == type){
|
||||
ehCachePlugin.delete(CacheConstants.EHCACHE_SPACE, cacheName);
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
@ -1,76 +0,0 @@
|
||||
/**
|
||||
* Copyright 2020 OPSLI 快速开发平台 https://www.opsli.com
|
||||
* <p>
|
||||
* Licensed under the Apache License, Version 2.0 (the "License"); you may not
|
||||
* use this file except in compliance with the License. You may obtain a copy of
|
||||
* the License at
|
||||
* <p>
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* <p>
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
||||
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
||||
* License for the specific language governing permissions and limitations under
|
||||
* the License.
|
||||
*/
|
||||
package org.opsli.core.cache.pushsub.handler;
|
||||
|
||||
import com.alibaba.fastjson.JSONObject;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.apache.commons.lang3.StringUtils;
|
||||
import org.opsli.common.constants.CacheConstants;
|
||||
import org.opsli.core.cache.local.CacheUtil;
|
||||
import org.opsli.core.cache.pushsub.enums.MsgArgsType;
|
||||
import org.opsli.core.cache.pushsub.enums.PushSubType;
|
||||
import org.opsli.core.utils.OptionsUtil;
|
||||
import org.opsli.plugins.cache.EhCachePlugin;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
|
||||
/**
|
||||
* 系统参数消息处理
|
||||
*
|
||||
* @author Parker
|
||||
* @date 2020-09-16
|
||||
*/
|
||||
@Slf4j
|
||||
public class OptionHandler implements RedisPushSubHandler{
|
||||
|
||||
@Autowired
|
||||
private EhCachePlugin ehCachePlugin;
|
||||
|
||||
@Override
|
||||
public PushSubType getType() {
|
||||
return PushSubType.OPTION;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void handler(JSONObject msgJson) {
|
||||
// 系统参数刷新
|
||||
this.optionHandler(msgJson);
|
||||
}
|
||||
|
||||
/**
|
||||
* 用户数据处理
|
||||
* @param msgJson 信息Json
|
||||
*/
|
||||
private void optionHandler(JSONObject msgJson){
|
||||
JSONObject data = msgJson.getJSONObject(MsgArgsType.OPTION_MODEL_DATA.toString());
|
||||
// 数据为空则不执行
|
||||
if(data == null){
|
||||
return;
|
||||
}
|
||||
|
||||
// 获得参数编号
|
||||
String optionCode = (String) msgJson.get(MsgArgsType.OPTION_CODE.toString());
|
||||
if(StringUtils.isEmpty(optionCode)){
|
||||
return;
|
||||
}
|
||||
|
||||
String cacheKey = CacheUtil.handleKey(OptionsUtil.PREFIX_CODE + optionCode);
|
||||
|
||||
// 先删除
|
||||
ehCachePlugin.delete(CacheConstants.EHCACHE_SPACE, cacheKey);
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
@ -1,77 +0,0 @@
|
||||
/**
|
||||
* Copyright 2020 OPSLI 快速开发平台 https://www.opsli.com
|
||||
* <p>
|
||||
* Licensed under the Apache License, Version 2.0 (the "License"); you may not
|
||||
* use this file except in compliance with the License. You may obtain a copy of
|
||||
* the License at
|
||||
* <p>
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* <p>
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
||||
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
||||
* License for the specific language governing permissions and limitations under
|
||||
* the License.
|
||||
*/
|
||||
package org.opsli.core.cache.pushsub.handler;
|
||||
|
||||
import com.alibaba.fastjson.JSONObject;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.apache.commons.lang3.StringUtils;
|
||||
import org.opsli.common.constants.CacheConstants;
|
||||
import org.opsli.core.cache.local.CacheUtil;
|
||||
import org.opsli.core.cache.pushsub.enums.MsgArgsType;
|
||||
import org.opsli.core.cache.pushsub.enums.PushSubType;
|
||||
import org.opsli.core.utils.OrgUtil;
|
||||
import org.opsli.core.utils.UserUtil;
|
||||
import org.opsli.plugins.cache.EhCachePlugin;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
|
||||
/**
|
||||
* 用户组织消息处理
|
||||
*
|
||||
* @author Parker
|
||||
* @date 2020-09-16
|
||||
*/
|
||||
@Slf4j
|
||||
public class OrgHandler implements RedisPushSubHandler{
|
||||
|
||||
@Autowired
|
||||
private EhCachePlugin ehCachePlugin;
|
||||
|
||||
@Override
|
||||
public PushSubType getType() {
|
||||
return PushSubType.ORG;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void handler(JSONObject msgJson) {
|
||||
// 用户刷新
|
||||
this.orgHandler(msgJson);
|
||||
}
|
||||
|
||||
/**
|
||||
* 用户组织数据处理
|
||||
* @param msgJson 信息Json
|
||||
*/
|
||||
private void orgHandler(JSONObject msgJson){
|
||||
JSONObject data = msgJson.getJSONObject(MsgArgsType.ORG_USER_DATA.toString());
|
||||
// 数据为空则不执行
|
||||
if(data == null){
|
||||
return;
|
||||
}
|
||||
|
||||
// 获得用户ID
|
||||
String userId = (String) msgJson.get(MsgArgsType.ORG_USER_ID.toString());
|
||||
if(StringUtils.isEmpty(userId)){
|
||||
return;
|
||||
}
|
||||
|
||||
String cacheKey = CacheUtil.handleKey(UserUtil.PREFIX_ID_ORGS + userId);
|
||||
|
||||
// 先删除
|
||||
ehCachePlugin.delete(CacheConstants.EHCACHE_SPACE, cacheKey);
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
@ -1,41 +0,0 @@
|
||||
/**
|
||||
* Copyright 2020 OPSLI 快速开发平台 https://www.opsli.com
|
||||
* <p>
|
||||
* Licensed under the Apache License, Version 2.0 (the "License"); you may not
|
||||
* use this file except in compliance with the License. You may obtain a copy of
|
||||
* the License at
|
||||
* <p>
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* <p>
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
||||
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
||||
* License for the specific language governing permissions and limitations under
|
||||
* the License.
|
||||
*/
|
||||
package org.opsli.core.cache.pushsub.handler;
|
||||
|
||||
import com.alibaba.fastjson.JSONObject;
|
||||
import org.opsli.core.cache.pushsub.enums.PushSubType;
|
||||
|
||||
/**
|
||||
* 标示类 用于获得 消息未知
|
||||
*
|
||||
* @author Parker
|
||||
* @date 2020-09-16
|
||||
*/
|
||||
public interface RedisPushSubHandler {
|
||||
|
||||
/**
|
||||
* 获得类型
|
||||
* @return 类型
|
||||
*/
|
||||
PushSubType getType();
|
||||
|
||||
/**
|
||||
* 消息处理
|
||||
* @param msgJson 信息Json
|
||||
*/
|
||||
void handler(JSONObject msgJson);
|
||||
|
||||
}
|
||||
@ -1,76 +0,0 @@
|
||||
/**
|
||||
* Copyright 2020 OPSLI 快速开发平台 https://www.opsli.com
|
||||
* <p>
|
||||
* Licensed under the Apache License, Version 2.0 (the "License"); you may not
|
||||
* use this file except in compliance with the License. You may obtain a copy of
|
||||
* the License at
|
||||
* <p>
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* <p>
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
||||
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
||||
* License for the specific language governing permissions and limitations under
|
||||
* the License.
|
||||
*/
|
||||
package org.opsli.core.cache.pushsub.handler;
|
||||
|
||||
import com.alibaba.fastjson.JSONObject;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.apache.commons.lang3.StringUtils;
|
||||
import org.opsli.common.constants.CacheConstants;
|
||||
import org.opsli.core.cache.local.CacheUtil;
|
||||
import org.opsli.core.cache.pushsub.enums.MsgArgsType;
|
||||
import org.opsli.core.cache.pushsub.enums.PushSubType;
|
||||
import org.opsli.core.utils.TenantUtil;
|
||||
import org.opsli.plugins.cache.EhCachePlugin;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
|
||||
/**
|
||||
* 租户消息处理
|
||||
*
|
||||
* @author Parker
|
||||
* @date 2020-09-16
|
||||
*/
|
||||
@Slf4j
|
||||
public class TenantHandler implements RedisPushSubHandler{
|
||||
|
||||
@Autowired
|
||||
private EhCachePlugin ehCachePlugin;
|
||||
|
||||
@Override
|
||||
public PushSubType getType() {
|
||||
return PushSubType.TENANT;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void handler(JSONObject msgJson) {
|
||||
// 用户刷新
|
||||
this.orgHandler(msgJson);
|
||||
}
|
||||
|
||||
/**
|
||||
* 租户数据处理
|
||||
* @param msgJson 信息Json
|
||||
*/
|
||||
private void orgHandler(JSONObject msgJson){
|
||||
JSONObject data = msgJson.getJSONObject(MsgArgsType.TENANT_DATA.toString());
|
||||
// 数据为空则不执行
|
||||
if(data == null){
|
||||
return;
|
||||
}
|
||||
|
||||
// 获得租户ID
|
||||
String tenantId = (String) msgJson.get(MsgArgsType.TENANT_ID.toString());
|
||||
if(StringUtils.isEmpty(tenantId)){
|
||||
return;
|
||||
}
|
||||
|
||||
String cacheKey = CacheUtil.handleKey(TenantUtil.PREFIX_CODE + tenantId);
|
||||
|
||||
// 先删除
|
||||
ehCachePlugin.delete(CacheConstants.EHCACHE_SPACE, cacheKey);
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
@ -1,168 +0,0 @@
|
||||
/**
|
||||
* Copyright 2020 OPSLI 快速开发平台 https://www.opsli.com
|
||||
* <p>
|
||||
* Licensed under the Apache License, Version 2.0 (the "License"); you may not
|
||||
* use this file except in compliance with the License. You may obtain a copy of
|
||||
* the License at
|
||||
* <p>
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* <p>
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
||||
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
||||
* License for the specific language governing permissions and limitations under
|
||||
* the License.
|
||||
*/
|
||||
package org.opsli.core.cache.pushsub.handler;
|
||||
|
||||
import com.alibaba.fastjson.JSONArray;
|
||||
import com.alibaba.fastjson.JSONObject;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.apache.commons.lang3.StringUtils;
|
||||
import org.opsli.common.constants.CacheConstants;
|
||||
import org.opsli.core.cache.local.CacheUtil;
|
||||
import org.opsli.core.cache.pushsub.enums.MsgArgsType;
|
||||
import org.opsli.core.cache.pushsub.enums.PushSubType;
|
||||
import org.opsli.core.cache.pushsub.enums.UserModelType;
|
||||
import org.opsli.core.utils.UserUtil;
|
||||
import org.opsli.plugins.cache.EhCachePlugin;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
|
||||
/**
|
||||
* 用户消息处理
|
||||
*
|
||||
* @author Parker
|
||||
* @date 2020-09-16
|
||||
*/
|
||||
@Slf4j
|
||||
public class UserHandler implements RedisPushSubHandler{
|
||||
|
||||
@Autowired
|
||||
private EhCachePlugin ehCachePlugin;
|
||||
|
||||
@Override
|
||||
public PushSubType getType() {
|
||||
return PushSubType.USER;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void handler(JSONObject msgJson) {
|
||||
UserModelType userModelType = UserModelType.valueOf((String)
|
||||
msgJson.get(MsgArgsType.USER_MODEL_TYPE.toString()));
|
||||
|
||||
// 用户刷新
|
||||
if(UserModelType.USER_MODEL == userModelType){
|
||||
this.userHandler(msgJson);
|
||||
}
|
||||
// 用户角色刷新
|
||||
else if(UserModelType.USER_ROLES_MODEL == userModelType){
|
||||
this.userRolesHandler(msgJson);
|
||||
}
|
||||
// 用户权限刷新
|
||||
else if(UserModelType.USER_PERMS_MODEL == userModelType){
|
||||
this.userPermsHandler(msgJson);
|
||||
}
|
||||
// 用户菜单刷新
|
||||
else if(UserModelType.USER_MENU_MODEL == userModelType){
|
||||
this.userMenusHandler(msgJson);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* 用户数据处理
|
||||
* @param msgJson 信息Json
|
||||
*/
|
||||
private void userHandler(JSONObject msgJson){
|
||||
JSONObject data = msgJson.getJSONObject(MsgArgsType.USER_MODEL_DATA.toString());
|
||||
// 数据为空则不执行
|
||||
if(data == null){
|
||||
return;
|
||||
}
|
||||
|
||||
// 获得用户ID 和 用户名
|
||||
String userId = (String) msgJson.get(MsgArgsType.USER_ID.toString());
|
||||
String username = (String) msgJson.get(MsgArgsType.USER_USERNAME.toString());
|
||||
if(StringUtils.isEmpty(userId) || StringUtils.isEmpty(username) ){
|
||||
return;
|
||||
}
|
||||
|
||||
String cacheKeyById = CacheUtil.handleKey(UserUtil.PREFIX_ID + userId);
|
||||
String cacheKeyByName = CacheUtil.handleKey(UserUtil.PREFIX_USERNAME + username);
|
||||
|
||||
// 先删除
|
||||
ehCachePlugin.delete(CacheConstants.EHCACHE_SPACE, cacheKeyById);
|
||||
ehCachePlugin.delete(CacheConstants.EHCACHE_SPACE, cacheKeyByName);
|
||||
}
|
||||
|
||||
/**
|
||||
* 用户角色数据处理
|
||||
* @param msgJson 信息Json
|
||||
*/
|
||||
private void userRolesHandler(JSONObject msgJson){
|
||||
JSONArray dataArray = msgJson.getJSONArray(MsgArgsType.USER_MODEL_DATA.toString());
|
||||
// 数据为空则不执行
|
||||
if(dataArray == null || dataArray.isEmpty()){
|
||||
return;
|
||||
}
|
||||
|
||||
// 获得用户ID
|
||||
String userId = (String) msgJson.get(MsgArgsType.USER_ID.toString());
|
||||
if(StringUtils.isEmpty(userId)){
|
||||
return;
|
||||
}
|
||||
|
||||
String cacheKey = CacheUtil.handleKey(UserUtil.PREFIX_ID_ROLES + userId);
|
||||
|
||||
// 先删除
|
||||
ehCachePlugin.delete(CacheConstants.EHCACHE_SPACE, cacheKey);
|
||||
}
|
||||
|
||||
/**
|
||||
* 用户权限数据处理
|
||||
* @param msgJson 信息Json
|
||||
*/
|
||||
private void userPermsHandler(JSONObject msgJson){
|
||||
JSONArray dataArray = msgJson.getJSONArray(MsgArgsType.USER_MODEL_DATA.toString());
|
||||
// 数据为空则不执行
|
||||
if(dataArray == null || dataArray.isEmpty()){
|
||||
return;
|
||||
}
|
||||
|
||||
// 获得用户ID
|
||||
String userId = (String) msgJson.get(MsgArgsType.USER_ID.toString());
|
||||
if(StringUtils.isEmpty(userId)){
|
||||
return;
|
||||
}
|
||||
|
||||
String cacheKey = CacheUtil.handleKey(UserUtil.PREFIX_ID_PERMISSIONS + userId);
|
||||
|
||||
// 先删除
|
||||
ehCachePlugin.delete(CacheConstants.EHCACHE_SPACE, cacheKey);
|
||||
}
|
||||
|
||||
/**
|
||||
* 用户菜单数据处理
|
||||
* @param msgJson 信息Json
|
||||
*/
|
||||
private void userMenusHandler(JSONObject msgJson){
|
||||
JSONArray dataArray = msgJson.getJSONArray(MsgArgsType.USER_MODEL_DATA.toString());
|
||||
// 数据为空则不执行
|
||||
if(dataArray == null || dataArray.isEmpty()){
|
||||
return;
|
||||
}
|
||||
|
||||
// 获得用户ID
|
||||
String userId = (String) msgJson.get(MsgArgsType.USER_ID.toString());
|
||||
if(StringUtils.isEmpty(userId)){
|
||||
return;
|
||||
}
|
||||
|
||||
String cacheKey = CacheUtil.handleKey(UserUtil.PREFIX_ID_MENUS + userId);
|
||||
|
||||
// 先删除
|
||||
ehCachePlugin.delete(CacheConstants.EHCACHE_SPACE, cacheKey);
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
@ -1,64 +0,0 @@
|
||||
/**
|
||||
* Copyright 2020 OPSLI 快速开发平台 https://www.opsli.com
|
||||
* <p>
|
||||
* Licensed under the Apache License, Version 2.0 (the "License"); you may not
|
||||
* use this file except in compliance with the License. You may obtain a copy of
|
||||
* the License at
|
||||
* <p>
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* <p>
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
||||
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
||||
* License for the specific language governing permissions and limitations under
|
||||
* the License.
|
||||
*/
|
||||
package org.opsli.core.cache.pushsub.msgs;
|
||||
|
||||
import com.alibaba.fastjson.JSONObject;
|
||||
import lombok.Data;
|
||||
import lombok.experimental.Accessors;
|
||||
import org.opsli.core.cache.pushsub.entity.CacheDataEntity;
|
||||
import org.opsli.core.cache.pushsub.enums.CacheHandleType;
|
||||
import org.opsli.core.cache.pushsub.enums.MsgArgsType;
|
||||
import org.opsli.core.cache.pushsub.enums.PushSubType;
|
||||
import org.opsli.core.cache.pushsub.receiver.RedisPushSubReceiver;
|
||||
import org.opsli.plugins.redis.pushsub.entity.BaseSubMessage;
|
||||
|
||||
/**
|
||||
* 热数据消息
|
||||
*
|
||||
* @author Parker
|
||||
* @date 2020-09-15
|
||||
*/
|
||||
@Data
|
||||
@Accessors(chain = true)
|
||||
public final class CacheDataMsgFactory extends BaseSubMessage{
|
||||
|
||||
/** 通道 */
|
||||
private static final String CHANNEL = RedisPushSubReceiver.BASE_CHANNEL + RedisPushSubReceiver.CHANNEL;
|
||||
|
||||
private CacheDataMsgFactory(){}
|
||||
|
||||
/**
|
||||
* 构建消息 热数据
|
||||
* @param cacheDataEntity 热数据对象
|
||||
* @param value 值
|
||||
* @param cacheHandleType 类型
|
||||
* @return 消息
|
||||
*/
|
||||
public static BaseSubMessage createMsg(CacheDataEntity cacheDataEntity, Object value,
|
||||
CacheHandleType cacheHandleType){
|
||||
BaseSubMessage baseSubMessage = new BaseSubMessage();
|
||||
// 数据
|
||||
JSONObject jsonObj = new JSONObject();
|
||||
jsonObj.put(MsgArgsType.CACHE_DATA_KEY.toString(),cacheDataEntity.getKey());
|
||||
jsonObj.put(MsgArgsType.CACHE_DATA_VALUE.toString(),value);
|
||||
jsonObj.put(MsgArgsType.CACHE_DATA_TYPE.toString(), cacheHandleType.toString());
|
||||
|
||||
// 热点数据 - 系统数据
|
||||
baseSubMessage.build(CHANNEL, PushSubType.HOT_DATA.toString(), jsonObj);
|
||||
return baseSubMessage;
|
||||
}
|
||||
|
||||
}
|
||||
@ -1,83 +0,0 @@
|
||||
/**
|
||||
* Copyright 2020 OPSLI 快速开发平台 https://www.opsli.com
|
||||
* <p>
|
||||
* Licensed under the Apache License, Version 2.0 (the "License"); you may not
|
||||
* use this file except in compliance with the License. You may obtain a copy of
|
||||
* the License at
|
||||
* <p>
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* <p>
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
||||
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
||||
* License for the specific language governing permissions and limitations under
|
||||
* the License.
|
||||
*/
|
||||
package org.opsli.core.cache.pushsub.msgs;
|
||||
|
||||
import com.alibaba.fastjson.JSONObject;
|
||||
import lombok.Data;
|
||||
import lombok.experimental.Accessors;
|
||||
import org.opsli.api.wrapper.system.dict.DictWrapper;
|
||||
import org.opsli.core.cache.pushsub.enums.CacheHandleType;
|
||||
import org.opsli.core.cache.pushsub.enums.DictModelType;
|
||||
import org.opsli.core.cache.pushsub.enums.MsgArgsType;
|
||||
import org.opsli.core.cache.pushsub.enums.PushSubType;
|
||||
import org.opsli.core.cache.pushsub.receiver.RedisPushSubReceiver;
|
||||
import org.opsli.plugins.redis.pushsub.entity.BaseSubMessage;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 字典消息
|
||||
*
|
||||
* @author Parker
|
||||
* @date 2020-09-15
|
||||
*/
|
||||
@Data
|
||||
@Accessors(chain = true)
|
||||
public final class DictMsgFactory extends BaseSubMessage{
|
||||
|
||||
/** 通道 */
|
||||
private static final String CHANNEL = RedisPushSubReceiver.BASE_CHANNEL+RedisPushSubReceiver.CHANNEL;
|
||||
|
||||
private DictMsgFactory(){}
|
||||
|
||||
/**
|
||||
* 构建消息 字典
|
||||
* @param dictWrapperModel 字典模型
|
||||
* @param cacheHandleType 缓存类型
|
||||
* @return 消息
|
||||
*/
|
||||
public static BaseSubMessage createMsg(DictWrapper dictWrapperModel, CacheHandleType cacheHandleType){
|
||||
BaseSubMessage baseSubMessage = new BaseSubMessage();
|
||||
// 数据
|
||||
JSONObject jsonObj = new JSONObject();
|
||||
jsonObj.put(MsgArgsType.DICT_MODEL.toString(), dictWrapperModel);
|
||||
jsonObj.put(MsgArgsType.DICT_MODEL_TYPE.toString(), DictModelType.OBJECT);
|
||||
jsonObj.put(MsgArgsType.DICT_TYPE.toString(), cacheHandleType.toString());
|
||||
|
||||
// DICT 字典
|
||||
baseSubMessage.build(CHANNEL,PushSubType.DICT.toString(),jsonObj);
|
||||
return baseSubMessage;
|
||||
}
|
||||
|
||||
/**
|
||||
* 构建消息 字典
|
||||
* @param dictWrapperModels 字典模型集合
|
||||
* @param cacheHandleType 缓存类型
|
||||
* @return 消息
|
||||
*/
|
||||
public static BaseSubMessage createMsg(List<DictWrapper> dictWrapperModels, CacheHandleType cacheHandleType){
|
||||
BaseSubMessage baseSubMessage = new BaseSubMessage();
|
||||
// 数据
|
||||
JSONObject jsonObj = new JSONObject();
|
||||
jsonObj.put(MsgArgsType.DICT_MODELS.toString(), dictWrapperModels);
|
||||
jsonObj.put(MsgArgsType.DICT_MODEL_TYPE.toString(), DictModelType.COLLECTION);
|
||||
jsonObj.put(MsgArgsType.DICT_TYPE.toString(), cacheHandleType.toString());
|
||||
|
||||
// DICT 字典
|
||||
baseSubMessage.build(CHANNEL,PushSubType.DICT.toString(),jsonObj);
|
||||
return baseSubMessage;
|
||||
}
|
||||
}
|
||||
@ -1,61 +0,0 @@
|
||||
/**
|
||||
* Copyright 2020 OPSLI 快速开发平台 https://www.opsli.com
|
||||
* <p>
|
||||
* Licensed under the Apache License, Version 2.0 (the "License"); you may not
|
||||
* use this file except in compliance with the License. You may obtain a copy of
|
||||
* the License at
|
||||
* <p>
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* <p>
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
||||
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
||||
* License for the specific language governing permissions and limitations under
|
||||
* the License.
|
||||
*/
|
||||
package org.opsli.core.cache.pushsub.msgs;
|
||||
|
||||
import com.alibaba.fastjson.JSONObject;
|
||||
import lombok.Data;
|
||||
import lombok.experimental.Accessors;
|
||||
import org.opsli.api.wrapper.system.menu.MenuModel;
|
||||
import org.opsli.api.wrapper.system.options.OptionsModel;
|
||||
import org.opsli.core.cache.pushsub.enums.MsgArgsType;
|
||||
import org.opsli.core.cache.pushsub.enums.PushSubType;
|
||||
import org.opsli.core.cache.pushsub.receiver.RedisPushSubReceiver;
|
||||
import org.opsli.plugins.redis.pushsub.entity.BaseSubMessage;
|
||||
|
||||
/**
|
||||
* 参数消息
|
||||
*
|
||||
* @author Parker
|
||||
* @date 2020-09-15
|
||||
*/
|
||||
@Data
|
||||
@Accessors(chain = true)
|
||||
public final class OptionMsgFactory extends BaseSubMessage{
|
||||
|
||||
/** 通道 */
|
||||
private static final String CHANNEL = RedisPushSubReceiver.BASE_CHANNEL+RedisPushSubReceiver.CHANNEL;
|
||||
|
||||
private OptionMsgFactory(){}
|
||||
|
||||
/**
|
||||
* 构建消息 - 参数
|
||||
* @param optionsModel 参数模型
|
||||
* @return 消息
|
||||
*/
|
||||
public static BaseSubMessage createOptionMsg(OptionsModel optionsModel){
|
||||
BaseSubMessage baseSubMessage = new BaseSubMessage();
|
||||
// 数据
|
||||
JSONObject jsonObj = new JSONObject();
|
||||
jsonObj.put(MsgArgsType.OPTION_CODE.toString(), optionsModel.getOptionCode());
|
||||
jsonObj.put(MsgArgsType.OPTION_MODEL_DATA.toString(), optionsModel);
|
||||
|
||||
// 参数
|
||||
baseSubMessage.build(CHANNEL,PushSubType.OPTION.toString(),jsonObj);
|
||||
return baseSubMessage;
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
@ -1,60 +0,0 @@
|
||||
/**
|
||||
* Copyright 2020 OPSLI 快速开发平台 https://www.opsli.com
|
||||
* <p>
|
||||
* Licensed under the Apache License, Version 2.0 (the "License"); you may not
|
||||
* use this file except in compliance with the License. You may obtain a copy of
|
||||
* the License at
|
||||
* <p>
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* <p>
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
||||
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
||||
* License for the specific language governing permissions and limitations under
|
||||
* the License.
|
||||
*/
|
||||
package org.opsli.core.cache.pushsub.msgs;
|
||||
|
||||
import com.alibaba.fastjson.JSONObject;
|
||||
import lombok.Data;
|
||||
import lombok.experimental.Accessors;
|
||||
import org.opsli.api.wrapper.system.user.UserOrgRefWebModel;
|
||||
import org.opsli.core.cache.pushsub.enums.MsgArgsType;
|
||||
import org.opsli.core.cache.pushsub.enums.PushSubType;
|
||||
import org.opsli.core.cache.pushsub.receiver.RedisPushSubReceiver;
|
||||
import org.opsli.plugins.redis.pushsub.entity.BaseSubMessage;
|
||||
|
||||
/**
|
||||
* 用户组织消息
|
||||
*
|
||||
* @author Parker
|
||||
* @date 2020-09-15
|
||||
*/
|
||||
@Data
|
||||
@Accessors(chain = true)
|
||||
public final class OrgMsgFactory extends BaseSubMessage{
|
||||
|
||||
/** 通道 */
|
||||
private static final String CHANNEL = RedisPushSubReceiver.BASE_CHANNEL+RedisPushSubReceiver.CHANNEL;
|
||||
|
||||
private OrgMsgFactory(){}
|
||||
|
||||
/**
|
||||
* 构建消息 - 用户组织
|
||||
* @param orgRefModel 用户组织模型
|
||||
* @return 消息
|
||||
*/
|
||||
public static BaseSubMessage createOrgMsg(UserOrgRefWebModel orgRefModel){
|
||||
BaseSubMessage baseSubMessage = new BaseSubMessage();
|
||||
// 数据
|
||||
JSONObject jsonObj = new JSONObject();
|
||||
jsonObj.put(MsgArgsType.ORG_USER_ID.toString(), orgRefModel.getUserId());
|
||||
jsonObj.put(MsgArgsType.ORG_USER_DATA.toString(), orgRefModel);
|
||||
|
||||
// 组织
|
||||
baseSubMessage.build(CHANNEL,PushSubType.ORG.toString(),jsonObj);
|
||||
return baseSubMessage;
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
@ -1,60 +0,0 @@
|
||||
/**
|
||||
* Copyright 2020 OPSLI 快速开发平台 https://www.opsli.com
|
||||
* <p>
|
||||
* Licensed under the Apache License, Version 2.0 (the "License"); you may not
|
||||
* use this file except in compliance with the License. You may obtain a copy of
|
||||
* the License at
|
||||
* <p>
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* <p>
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
||||
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
||||
* License for the specific language governing permissions and limitations under
|
||||
* the License.
|
||||
*/
|
||||
package org.opsli.core.cache.pushsub.msgs;
|
||||
|
||||
import com.alibaba.fastjson.JSONObject;
|
||||
import lombok.Data;
|
||||
import lombok.experimental.Accessors;
|
||||
import org.opsli.api.wrapper.system.tenant.TenantModel;
|
||||
import org.opsli.core.cache.pushsub.enums.MsgArgsType;
|
||||
import org.opsli.core.cache.pushsub.enums.PushSubType;
|
||||
import org.opsli.core.cache.pushsub.receiver.RedisPushSubReceiver;
|
||||
import org.opsli.plugins.redis.pushsub.entity.BaseSubMessage;
|
||||
|
||||
/**
|
||||
* 租户消息
|
||||
*
|
||||
* @author Parker
|
||||
* @date 2020-09-15
|
||||
*/
|
||||
@Data
|
||||
@Accessors(chain = true)
|
||||
public final class TenantMsgFactory extends BaseSubMessage{
|
||||
|
||||
/** 通道 */
|
||||
private static final String CHANNEL = RedisPushSubReceiver.BASE_CHANNEL+RedisPushSubReceiver.CHANNEL;
|
||||
|
||||
private TenantMsgFactory(){}
|
||||
|
||||
/**
|
||||
* 构建消息 - 租户
|
||||
* @param tenantModel 租户模型
|
||||
* @return 消息
|
||||
*/
|
||||
public static BaseSubMessage createTenantMsg(TenantModel tenantModel){
|
||||
BaseSubMessage baseSubMessage = new BaseSubMessage();
|
||||
// 数据
|
||||
JSONObject jsonObj = new JSONObject();
|
||||
jsonObj.put(MsgArgsType.TENANT_ID.toString(), tenantModel.getId());
|
||||
jsonObj.put(MsgArgsType.TENANT_DATA.toString(), tenantModel);
|
||||
|
||||
// 租户
|
||||
baseSubMessage.build(CHANNEL,PushSubType.TENANT.toString(),jsonObj);
|
||||
return baseSubMessage;
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
@ -1,122 +0,0 @@
|
||||
/**
|
||||
* Copyright 2020 OPSLI 快速开发平台 https://www.opsli.com
|
||||
* <p>
|
||||
* Licensed under the Apache License, Version 2.0 (the "License"); you may not
|
||||
* use this file except in compliance with the License. You may obtain a copy of
|
||||
* the License at
|
||||
* <p>
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* <p>
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
||||
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
||||
* License for the specific language governing permissions and limitations under
|
||||
* the License.
|
||||
*/
|
||||
package org.opsli.core.cache.pushsub.msgs;
|
||||
|
||||
import com.alibaba.fastjson.JSONObject;
|
||||
import lombok.Data;
|
||||
import lombok.experimental.Accessors;
|
||||
import org.opsli.api.wrapper.system.menu.MenuModel;
|
||||
import org.opsli.api.wrapper.system.user.UserModel;
|
||||
import org.opsli.core.cache.pushsub.enums.MsgArgsType;
|
||||
import org.opsli.core.cache.pushsub.enums.PushSubType;
|
||||
import org.opsli.core.cache.pushsub.enums.UserModelType;
|
||||
import org.opsli.core.cache.pushsub.receiver.RedisPushSubReceiver;
|
||||
import org.opsli.plugins.redis.pushsub.entity.BaseSubMessage;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 用户消息
|
||||
*
|
||||
* @author Parker
|
||||
* @date 2020-09-15
|
||||
*/
|
||||
@Data
|
||||
@Accessors(chain = true)
|
||||
public final class UserMsgFactory extends BaseSubMessage{
|
||||
|
||||
/** 通道 */
|
||||
private static final String CHANNEL = RedisPushSubReceiver.BASE_CHANNEL+RedisPushSubReceiver.CHANNEL;
|
||||
|
||||
private UserMsgFactory(){}
|
||||
|
||||
/**
|
||||
* 构建消息 - 用户
|
||||
* @param userModel 用户模型
|
||||
* @return 消息
|
||||
*/
|
||||
public static BaseSubMessage createUserMsg(UserModel userModel){
|
||||
BaseSubMessage baseSubMessage = new BaseSubMessage();
|
||||
// 数据
|
||||
JSONObject jsonObj = new JSONObject();
|
||||
jsonObj.put(MsgArgsType.USER_ID.toString(), userModel.getId());
|
||||
jsonObj.put(MsgArgsType.USER_USERNAME.toString(), userModel.getUsername());
|
||||
jsonObj.put(MsgArgsType.USER_MODEL_TYPE.toString(), UserModelType.USER_MODEL.toString());
|
||||
jsonObj.put(MsgArgsType.USER_MODEL_DATA.toString(), userModel);
|
||||
|
||||
// 用户
|
||||
baseSubMessage.build(CHANNEL,PushSubType.USER.toString(),jsonObj);
|
||||
return baseSubMessage;
|
||||
}
|
||||
|
||||
/**
|
||||
* 构建消息 - 用户角色
|
||||
* @param userId 用户ID
|
||||
* @param roles 角色集合
|
||||
* @return 消息
|
||||
*/
|
||||
public static BaseSubMessage createUserRolesMsg(String userId, List<String> roles){
|
||||
BaseSubMessage baseSubMessage = new BaseSubMessage();
|
||||
// 数据
|
||||
JSONObject jsonObj = new JSONObject();
|
||||
jsonObj.put(MsgArgsType.USER_ID.toString(), userId);
|
||||
jsonObj.put(MsgArgsType.USER_MODEL_TYPE.toString(), UserModelType.USER_ROLES_MODEL.toString());
|
||||
jsonObj.put(MsgArgsType.USER_MODEL_DATA.toString(), roles);
|
||||
|
||||
// 用户
|
||||
baseSubMessage.build(CHANNEL,PushSubType.USER.toString(),jsonObj);
|
||||
return baseSubMessage;
|
||||
}
|
||||
|
||||
/**
|
||||
* 构建消息 - 用户权限
|
||||
* @param userId 用户ID
|
||||
* @param perms 权限集合
|
||||
* @return 消息
|
||||
*/
|
||||
public static BaseSubMessage createUserPermsMsg(String userId, List<String> perms){
|
||||
BaseSubMessage baseSubMessage = new BaseSubMessage();
|
||||
// 数据
|
||||
JSONObject jsonObj = new JSONObject();
|
||||
jsonObj.put(MsgArgsType.USER_ID.toString(), userId);
|
||||
jsonObj.put(MsgArgsType.USER_MODEL_TYPE.toString(), UserModelType.USER_PERMS_MODEL.toString());
|
||||
jsonObj.put(MsgArgsType.USER_MODEL_DATA.toString(), perms);
|
||||
|
||||
// 用户
|
||||
baseSubMessage.build(CHANNEL,PushSubType.USER.toString(),jsonObj);
|
||||
return baseSubMessage;
|
||||
}
|
||||
|
||||
/**
|
||||
* 构建消息 - 用户菜单
|
||||
* @param userId 用户ID
|
||||
* @param menus 菜单集合
|
||||
* @return 消息
|
||||
*/
|
||||
public static BaseSubMessage createUserMenusMsg(String userId, List<MenuModel> menus){
|
||||
BaseSubMessage baseSubMessage = new BaseSubMessage();
|
||||
// 数据
|
||||
JSONObject jsonObj = new JSONObject();
|
||||
jsonObj.put(MsgArgsType.USER_ID.toString(), userId);
|
||||
jsonObj.put(MsgArgsType.USER_MODEL_TYPE.toString(), UserModelType.USER_MENU_MODEL.toString());
|
||||
jsonObj.put(MsgArgsType.USER_MODEL_DATA.toString(), menus);
|
||||
|
||||
// 用户
|
||||
baseSubMessage.build(CHANNEL,PushSubType.USER.toString(),jsonObj);
|
||||
return baseSubMessage;
|
||||
}
|
||||
|
||||
}
|
||||
@ -1,132 +0,0 @@
|
||||
/**
|
||||
* Copyright 2020 OPSLI 快速开发平台 https://www.opsli.com
|
||||
* <p>
|
||||
* Licensed under the Apache License, Version 2.0 (the "License"); you may not
|
||||
* use this file except in compliance with the License. You may obtain a copy of
|
||||
* the License at
|
||||
* <p>
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* <p>
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
||||
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
||||
* License for the specific language governing permissions and limitations under
|
||||
* the License.
|
||||
*/
|
||||
package org.opsli.core.cache.pushsub.receiver;
|
||||
|
||||
import cn.hutool.core.util.ClassUtil;
|
||||
import com.alibaba.fastjson.JSONObject;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.apache.commons.lang3.builder.ToStringBuilder;
|
||||
import org.opsli.common.enums.SystemInfo;
|
||||
import org.opsli.core.cache.pushsub.enums.PushSubType;
|
||||
import org.opsli.core.cache.pushsub.handler.RedisPushSubHandler;
|
||||
import org.opsli.core.msg.CoreMsg;
|
||||
import org.opsli.plugins.redis.pushsub.entity.BaseSubMessage;
|
||||
import org.opsli.plugins.redis.pushsub.receiver.BaseReceiver;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.beans.factory.config.AutowireCapableBeanFactory;
|
||||
import org.springframework.beans.factory.support.DefaultListableBeanFactory;
|
||||
import org.springframework.context.annotation.Bean;
|
||||
import org.springframework.context.annotation.Configuration;
|
||||
|
||||
import java.lang.reflect.Modifier;
|
||||
import java.util.Set;
|
||||
import java.util.concurrent.ConcurrentHashMap;
|
||||
import java.util.concurrent.ConcurrentMap;
|
||||
|
||||
/**
|
||||
* Redis 消息订阅 更新本地缓存
|
||||
* 字典缓存更新
|
||||
*
|
||||
* @author Parker
|
||||
* @date 2020-09-15
|
||||
*/
|
||||
@Slf4j
|
||||
@Configuration
|
||||
public class RedisPushSubReceiver extends BaseReceiver {
|
||||
|
||||
/** Spring Bean 前缀 */
|
||||
public static final String SPRING_PREFIX = "redisPushSub_";
|
||||
|
||||
/** 监听信道 */
|
||||
public static final String CHANNEL = "opsli";
|
||||
|
||||
/** 处理方法集合 */
|
||||
private static final ConcurrentMap<PushSubType, RedisPushSubHandler> HANDLER_MAP = new ConcurrentHashMap<>();
|
||||
|
||||
|
||||
@Autowired
|
||||
private AutowireCapableBeanFactory beanFactory;
|
||||
|
||||
@Autowired
|
||||
private DefaultListableBeanFactory defaultListableBeanFactory;
|
||||
|
||||
public RedisPushSubReceiver() {
|
||||
super(CHANNEL);
|
||||
}
|
||||
|
||||
@Bean
|
||||
public void initRedisPushSubHandler(){
|
||||
|
||||
// 拿到state包下 实现了 SystemEventState 接口的,所有子类
|
||||
Set<Class<?>> clazzSet = ClassUtil.scanPackageBySuper(
|
||||
RedisPushSubHandler.class.getPackage().getName(),
|
||||
RedisPushSubHandler.class
|
||||
);
|
||||
|
||||
for (Class<?> aClass : clazzSet) {
|
||||
// 位运算 去除抽象类
|
||||
if((aClass.getModifiers() & Modifier.ABSTRACT) != 0){
|
||||
continue;
|
||||
}
|
||||
|
||||
try {
|
||||
Object obj = aClass.newInstance();
|
||||
|
||||
RedisPushSubHandler handler = (RedisPushSubHandler) obj;
|
||||
|
||||
// 加入集合
|
||||
HANDLER_MAP.put(handler.getType(),handler);
|
||||
|
||||
//将new出的对象放入Spring容器中
|
||||
defaultListableBeanFactory.registerSingleton(SPRING_PREFIX+aClass.getSimpleName(), obj);
|
||||
|
||||
//自动注入依赖
|
||||
beanFactory.autowireBean(obj);
|
||||
|
||||
} catch (Exception e){
|
||||
log.error(CoreMsg.REDIS_EXCEPTION_PUSH_SUB.getMessage());
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@Override
|
||||
public void receiveMessage(String msg) {
|
||||
if(msg == null || "".equals(msg)){
|
||||
return;
|
||||
}
|
||||
long beginTime = System.currentTimeMillis();
|
||||
// 替换 转意符
|
||||
String replaceAll = msg.replaceAll("\\\\", "");
|
||||
String substring = replaceAll.substring(1, replaceAll.length() - 1);
|
||||
JSONObject msgJson = JSONObject.parseObject(substring);
|
||||
String type = (String) msgJson.get(BaseSubMessage.BASE_TYPE);
|
||||
String identifier = (String) msgJson.get(BaseSubMessage.BASE_ID);
|
||||
// 本机不广播
|
||||
if(SystemInfo.INSTANCE.getSystemID().equals(identifier)){
|
||||
return;
|
||||
}
|
||||
PushSubType pt = PushSubType.valueOf(type);
|
||||
RedisPushSubHandler redisPushSubHandler = HANDLER_MAP.get(pt);
|
||||
if(redisPushSubHandler == null){
|
||||
return;
|
||||
}
|
||||
redisPushSubHandler.handler(msgJson);
|
||||
long endTime = System.currentTimeMillis();
|
||||
log.info("订阅节点更新缓存 耗时(毫秒):{}",(endTime-beginTime));
|
||||
}
|
||||
|
||||
}
|
||||
@ -1,299 +0,0 @@
|
||||
/**
|
||||
* Copyright 2020 OPSLI 快速开发平台 https://www.opsli.com
|
||||
* <p>
|
||||
* Licensed under the Apache License, Version 2.0 (the "License"); you may not
|
||||
* use this file except in compliance with the License. You may obtain a copy of
|
||||
* the License at
|
||||
* <p>
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* <p>
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
||||
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
||||
* License for the specific language governing permissions and limitations under
|
||||
* the License.
|
||||
*/
|
||||
package org.opsli.core.filters.aspect;
|
||||
|
||||
import cn.hutool.core.collection.CollUtil;
|
||||
import cn.hutool.core.convert.Convert;
|
||||
import com.google.common.collect.Lists;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.aspectj.lang.ProceedingJoinPoint;
|
||||
import org.aspectj.lang.annotation.Around;
|
||||
import org.aspectj.lang.annotation.Aspect;
|
||||
import org.aspectj.lang.annotation.Pointcut;
|
||||
import org.aspectj.lang.reflect.MethodSignature;
|
||||
import org.opsli.api.base.warpper.ApiWrapper;
|
||||
import org.opsli.common.annotation.hotdata.EnableHotData;
|
||||
import org.opsli.common.annotation.hotdata.HotDataDel;
|
||||
import org.opsli.common.annotation.hotdata.HotDataPut;
|
||||
import org.opsli.common.constants.CacheConstants;
|
||||
import org.opsli.core.cache.local.CacheUtil;
|
||||
import org.opsli.core.cache.pushsub.entity.CacheDataEntity;
|
||||
import org.opsli.core.cache.pushsub.enums.CacheHandleType;
|
||||
import org.opsli.core.cache.pushsub.msgs.CacheDataMsgFactory;
|
||||
import org.opsli.plugins.redis.RedisPlugin;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.core.annotation.Order;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
import java.lang.annotation.Annotation;
|
||||
import java.lang.reflect.Method;
|
||||
import java.util.Collection;
|
||||
import java.util.List;
|
||||
|
||||
import static org.opsli.common.constants.OrderConstants.HOT_DATA_ORDER;
|
||||
|
||||
/**
|
||||
* 热点数据 拦截处理
|
||||
*
|
||||
* @author parker
|
||||
* @date 2020-09-16
|
||||
*/
|
||||
@Slf4j
|
||||
@Order(HOT_DATA_ORDER)
|
||||
@Aspect
|
||||
@Component
|
||||
public class CacheDataAop {
|
||||
|
||||
@Autowired
|
||||
private RedisPlugin redisPlugin;
|
||||
|
||||
@Pointcut("@annotation(org.opsli.common.annotation.hotdata.HotDataPut)")
|
||||
public void hotDataPut() {
|
||||
}
|
||||
|
||||
@Pointcut("@annotation(org.opsli.common.annotation.hotdata.HotDataDel)")
|
||||
public void hotDataDel() {
|
||||
}
|
||||
|
||||
/**
|
||||
* 切如 更新数据
|
||||
* @param point point
|
||||
* @return Object
|
||||
* @throws Throwable 异常
|
||||
*/
|
||||
@Around("hotDataPut()")
|
||||
public Object hotDataPutProcess(ProceedingJoinPoint point) throws Throwable {
|
||||
Object[] args = point.getArgs();
|
||||
Object returnValue = point.proceed(args);
|
||||
// 判断 方法上是否使用 EnableHotData注解 如果没有表示开启热数据 则直接跳过
|
||||
Annotation annotation = point.getTarget().getClass().getAnnotation(EnableHotData.class);
|
||||
if(annotation == null){
|
||||
return returnValue;
|
||||
}
|
||||
|
||||
List<CacheDataEntity> cacheDataEntityList = this.putHandlerData(point, returnValue);
|
||||
// 非法判断
|
||||
if(CollUtil.isEmpty(cacheDataEntityList)){
|
||||
return returnValue;
|
||||
}
|
||||
|
||||
for (CacheDataEntity cacheDataEntity : cacheDataEntityList) {
|
||||
// 更新缓存数据
|
||||
// 热点数据
|
||||
boolean putRet = CacheUtil.put(CacheConstants.HOT_DATA_PREFIX +":"+ cacheDataEntity.getKey(),
|
||||
returnValue);
|
||||
if(putRet){
|
||||
// 广播缓存数据 - 通知其他服务器同步数据
|
||||
redisPlugin.sendMessage(
|
||||
CacheDataMsgFactory.createMsg(
|
||||
cacheDataEntity, returnValue, CacheHandleType.UPDATE)
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
return returnValue;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 切如 删除数据 和 逻辑删除上
|
||||
* @param point point
|
||||
* @return Object
|
||||
* @throws Throwable 异常
|
||||
*/
|
||||
@Around("hotDataDel()")
|
||||
public Object hotDataDelProcess(ProceedingJoinPoint point) throws Throwable {
|
||||
Object[] args= point.getArgs();
|
||||
Object returnValue = point.proceed(args);
|
||||
// 判断 方法上是否使用 EnableHotData注解 如果没有表示开启热数据 则直接跳过
|
||||
Annotation annotation = point.getTarget().getClass().getAnnotation(EnableHotData.class);
|
||||
if(annotation == null){
|
||||
return returnValue;
|
||||
}
|
||||
|
||||
// 删除状态判断
|
||||
try {
|
||||
Boolean ret = (Boolean) returnValue;
|
||||
if(ret == null || !ret){
|
||||
return returnValue;
|
||||
}
|
||||
}catch (Exception e){
|
||||
log.error(e.getMessage(),e);
|
||||
return returnValue;
|
||||
}
|
||||
|
||||
List<CacheDataEntity> cacheDataEntityList = this.delHandlerData(point, args);
|
||||
// 非法判断
|
||||
if(CollUtil.isEmpty(cacheDataEntityList)){
|
||||
return returnValue;
|
||||
}
|
||||
|
||||
for (CacheDataEntity cacheDataEntity : cacheDataEntityList) {
|
||||
// 更新缓存数据 - 删除缓存
|
||||
boolean delRet = CacheUtil.del(CacheConstants.HOT_DATA_PREFIX +":"+ cacheDataEntity.getKey());
|
||||
if(delRet){
|
||||
// 广播缓存数据 - 通知其他服务器同步数据
|
||||
redisPlugin.sendMessage(
|
||||
CacheDataMsgFactory.createMsg(
|
||||
cacheDataEntity, null, CacheHandleType.DELETE)
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
return returnValue;
|
||||
}
|
||||
|
||||
|
||||
// ===========================================================================
|
||||
|
||||
|
||||
/***
|
||||
* PUT 处理数据
|
||||
* @param point point
|
||||
*/
|
||||
private List<CacheDataEntity> putHandlerData(ProceedingJoinPoint point, Object returnValue){
|
||||
// 这里 只对 继承了 ApiWrapper 的类做处理
|
||||
if(!(returnValue instanceof ApiWrapper)){
|
||||
return null;
|
||||
}
|
||||
|
||||
// 消息集合 后续可能会考虑 多消息存储
|
||||
List<CacheDataEntity> cacheDataEntities = Lists.newArrayListWithCapacity(1);
|
||||
|
||||
// 报错不处理
|
||||
try {
|
||||
// 获得方法
|
||||
Method objMethod = this.getMethod(point);
|
||||
if(objMethod == null) {
|
||||
return null;
|
||||
}
|
||||
|
||||
// 获取注解参数
|
||||
HotDataPut aCache = objMethod.getAnnotation(HotDataPut.class);
|
||||
if(aCache != null){
|
||||
// 这里 只对 继承了 BaseEntity 的类做处理
|
||||
ApiWrapper apiWrapper = (ApiWrapper) returnValue;
|
||||
|
||||
CacheDataEntity ret = new CacheDataEntity(apiWrapper.getId());
|
||||
// 存放数据
|
||||
this.putCacheData(cacheDataEntities, ret);
|
||||
|
||||
return cacheDataEntities;
|
||||
}
|
||||
}catch (Exception e){
|
||||
log.error(e.getMessage(),e);
|
||||
}
|
||||
return null;
|
||||
}
|
||||
|
||||
|
||||
/***
|
||||
* DEL 处理数据
|
||||
* @param point point
|
||||
*/
|
||||
private List<CacheDataEntity> delHandlerData(ProceedingJoinPoint point, Object[] args){
|
||||
if(args == null || args.length == 0){
|
||||
return null;
|
||||
}
|
||||
|
||||
// 消息集合
|
||||
List<CacheDataEntity> cacheDataEntities = Lists.newArrayListWithCapacity(args.length);
|
||||
|
||||
// 报错不处理
|
||||
try {
|
||||
// 获得方法
|
||||
Method objMethod = this.getMethod(point);
|
||||
if(objMethod == null) {
|
||||
return null;
|
||||
}
|
||||
|
||||
// 获取注解参数
|
||||
HotDataDel aCache= objMethod.getAnnotation(HotDataDel.class);
|
||||
if(aCache != null){
|
||||
|
||||
List<String> keyList = null;
|
||||
|
||||
// 处理数据
|
||||
for (Object arg : args) {
|
||||
if (arg instanceof ApiWrapper) {
|
||||
// key 存储ID
|
||||
ApiWrapper apiWrapper = Convert.convert(ApiWrapper.class, arg);
|
||||
keyList = Convert.toList(String.class, apiWrapper.getId());
|
||||
} else if (arg instanceof Collection) {
|
||||
try {
|
||||
keyList = Lists.newArrayList();
|
||||
List<ApiWrapper> baseEntityList = Convert.toList(ApiWrapper.class, arg);
|
||||
for (ApiWrapper baseEntity : baseEntityList) {
|
||||
keyList.add(baseEntity.getId());
|
||||
}
|
||||
}catch (Exception e){
|
||||
log.error(e.getMessage(),e);
|
||||
}
|
||||
}else {
|
||||
keyList = Convert.toList(String.class, arg);
|
||||
}
|
||||
}
|
||||
|
||||
if(keyList != null && CollUtil.isNotEmpty(keyList)){
|
||||
for (String key : keyList) {
|
||||
CacheDataEntity ret = new CacheDataEntity(key);
|
||||
// 存放数据
|
||||
this.putCacheData(cacheDataEntities, ret);
|
||||
}
|
||||
}
|
||||
|
||||
return cacheDataEntities;
|
||||
}
|
||||
}catch (Exception e){
|
||||
log.error(e.getMessage(),e);
|
||||
}
|
||||
return null;
|
||||
}
|
||||
|
||||
|
||||
// =====================
|
||||
|
||||
/**
|
||||
* 获得方法
|
||||
* @param point point
|
||||
* @return Method 方法
|
||||
*/
|
||||
private Method getMethod(ProceedingJoinPoint point){
|
||||
Method m = null;
|
||||
try {
|
||||
String methodName= point.getSignature().getName();
|
||||
Class<?> classTarget= point.getTarget().getClass();
|
||||
Class<?>[] par=((MethodSignature) point.getSignature()).getParameterTypes();
|
||||
m = classTarget.getMethod(methodName, par);
|
||||
}catch (Exception ignored){}
|
||||
return m;
|
||||
}
|
||||
|
||||
/**
|
||||
* 存放数据
|
||||
* @param cacheDataList 缓存数据集合
|
||||
* @param cacheData 缓存数据
|
||||
*/
|
||||
private void putCacheData(List<CacheDataEntity> cacheDataList, CacheDataEntity cacheData){
|
||||
// 非法判断
|
||||
if(cacheDataList == null){
|
||||
return;
|
||||
}
|
||||
cacheDataList.add(cacheData);
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
@ -1,10 +1,4 @@
|
||||
{
|
||||
"properties": [
|
||||
{
|
||||
"name": "spring.redis.pushsub.enable",
|
||||
"type": "java.lang.Boolean",
|
||||
"defaultValue": false,
|
||||
"description": "开启消息订阅."
|
||||
}
|
||||
]
|
||||
}
|
||||
|
||||
Loading…
Reference in new issue