|
|
|
@ -89,27 +89,23 @@ public class DcWarningServiceImpl implements IDcWarningService |
|
|
|
@Override |
|
|
|
public int insertDcWarning(DcWarning dcWarning) |
|
|
|
{ |
|
|
|
|
|
|
|
dcWarning.setCreateTime(DateUtils.getNowDate()); |
|
|
|
//设置事件Id UUID无下划线格式32
|
|
|
|
String uuid = IdUtils.fastSimpleUUID(); |
|
|
|
dcWarning.setId(uuid); |
|
|
|
int priority = new DcWarningServiceImpl().priority(dcWarning); |
|
|
|
if (priority==0){ |
|
|
|
return 0; |
|
|
|
} |
|
|
|
return dcWarningMapper.insertDcWarning(dcWarning); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
//优先级策略
|
|
|
|
public int priority(DcWarning dcWarning){ |
|
|
|
if (StringUtils.isBlank(dcWarning.getStakeMark())||dcWarning.getWarningSource()==null||dcWarning.getWarningType()==null|| |
|
|
|
StringUtils.isBlank(dcWarning.getWarningSubclass())||StringUtils.isBlank(dcWarning.getDirection())){ |
|
|
|
StringUtils.isBlank(dcWarning.getWarningSubclass())||StringUtils.isBlank(dcWarning.getDirection())){ |
|
|
|
return 0; |
|
|
|
} |
|
|
|
String redisKye=dcWarning.getWarningSource().toString()+dcWarning.getWarningType().toString()+dcWarning.getWarningSubclass();//配置数据的key 事件源+事件类型+策略
|
|
|
|
Map<String, JSONObject> redisWarningStrategy = redisCache.getCacheMap(WARNINGSTRATEGY);//获取缓存全部的配置数据
|
|
|
|
if (redisWarningStrategy==null){//如果缓存为空,查询数据重新加入缓存
|
|
|
|
Map<String, HashMap> redisWarningStrategy = redisCache.getCacheMap(WARNINGSTRATEGY);//获取缓存全部的配置数据
|
|
|
|
if (redisWarningStrategy==null||redisWarningStrategy.size()==0){//如果缓存为空,查询数据重新加入缓存
|
|
|
|
Map<String, JSONObject> redisMap = new HashMap<>(); |
|
|
|
List<DcWaringStrategy> dcWaringStrategies = dcWarningMapper.selectDcWaringStrategyList();//数据库全部配置数据
|
|
|
|
for (DcWaringStrategy waringStrategy : dcWaringStrategies) { |
|
|
|
@ -118,7 +114,7 @@ public class DcWarningServiceImpl implements IDcWarningService |
|
|
|
JSONObject jsonObject = new JSONObject(); |
|
|
|
jsonObject.put("strategy", waringStrategy.getStrategy());//策略模式
|
|
|
|
jsonObject.put("strategyTime", waringStrategy.getStrategyTime());//模式时长，单位为分钟
|
|
|
|
jsonObject.put("priority", waringStrategy.getPriority());//策略模式
|
|
|
|
jsonObject.put("priority", waringStrategy.getPriority());//优先级
|
|
|
|
redisMap.put(key, jsonObject); |
|
|
|
} |
|
|
|
redisCache.setCacheMap(WARNINGSTRATEGY, redisMap);//数据库配置数据加入缓存中
|
|
|
|
@ -127,24 +123,28 @@ public class DcWarningServiceImpl implements IDcWarningService |
|
|
|
String key=dcWarning.getStakeMark()+dcWarning.getDirection()+dcWarning.getWarningSource(). |
|
|
|
toString()+dcWarning.getWarningType().toString()+dcWarning.getWarningSubclass();//key,redis存储事件的key(桩号+方向+事件源+类型)
|
|
|
|
String dataId = redisCache.getCacheObject(WARNINGDATA + key);//查看redis是否存在数据(id的值)
|
|
|
|
JSONObject redisValueOne = redisWarningStrategy.get(redisKye+"1");//查看传入的事件类型是否配置策略1(优先级策略)
|
|
|
|
HashMap redisValueOne = redisWarningStrategy.get(redisKye+"1");//查看传入的事件类型是否配置策略1(优先级策略)
|
|
|
|
if(redisValueOne!=null){//执行策略1(暂时未定义,定义后开发)
|
|
|
|
|
|
|
|
} |
|
|
|
JSONObject redisValueTwo = redisWarningStrategy.get(redisKye+"2");//查看传入的事件类型是否配置策略2(延迟策略)
|
|
|
|
HashMap redisValueTwo = redisWarningStrategy.get(redisKye+"2");//查看传入的事件类型是否配置策略2(延迟策略)
|
|
|
|
if (redisValueOne==null&&redisValueTwo!=null){ //执行策略2,执行到这里说明1不存在或者1未满足过滤条件
|
|
|
|
String strategyTime = redisValueTwo.getString("strategyTime").toString();//策略时长
|
|
|
|
String strategyTime = redisValueTwo.get("strategyTime").toString();//策略时长
|
|
|
|
if (dataId==null){//如果不存在直接加入数据库,加入缓存,配置对应的过期时间
|
|
|
|
int insertDcWarning = new DcWarningServiceImpl().insertDcWarning(dcWarning);//加入数据库
|
|
|
|
int insertDcWarning = dcWarningMapper.insertDcWarning(dcWarning);//加入数据库
|
|
|
|
if (insertDcWarning==0){ |
|
|
|
return 0; |
|
|
|
} |
|
|
|
String id = dcWarning.getId();//取出加入后的id作为value
|
|
|
|
redisCache.setCacheObject(WARNINGDATA+key,id,Integer.parseInt(strategyTime),TimeUnit.MINUTES);//加入缓存并设置延迟时间(单位分钟)
|
|
|
|
return 1;//结束
|
|
|
|
} |
|
|
|
//redis存在数据,取出redis的id找对对应事件的配置,合成事件配置,重新定义延迟时间
|
|
|
|
HashMap<String, Object> map = dcWarningMapper.selectDcWarningById(dataId); |
|
|
|
String otherConfig = map.get("otherConfig").toString();//取出原id的配置信息
|
|
|
|
String otherConfig=""; |
|
|
|
if (map.get("otherConfig")!=null){ |
|
|
|
otherConfig = map.get("otherConfig").toString(); //取出原id的配置信息
|
|
|
|
} |
|
|
|
String otherConfigString = dcWarning.getOtherConfig();//新增的配置信息
|
|
|
|
JSONObject jsonObjectOne = new JSONObject(otherConfig); |
|
|
|
JSONObject jsonObjectTwo = new JSONObject(otherConfigString); |
|
|
|
@ -156,7 +156,7 @@ public class DcWarningServiceImpl implements IDcWarningService |
|
|
|
} |
|
|
|
return 1; |
|
|
|
} |
|
|
|
JSONObject redisValueThree = redisWarningStrategy.get(redisKye+"3");//查看传入的事件类型是否配置策略3(时间窗口策略)
|
|
|
|
HashMap redisValueThree = redisWarningStrategy.get(redisKye+"3");//查看传入的事件类型是否配置策略3(时间窗口策略)
|
|
|
|
if (redisValueOne==null&&redisValueTwo==null&&redisValueThree!=null){ //执行策略3,执行到这里说明1不存在或者2不存在或者1未满足过滤条件
|
|
|
|
if (dataId==null){//如果不存在直接加入数据库,加入缓存,配置对应的过期时间(30分钟)
|
|
|
|
int insertDcWarning = new DcWarningServiceImpl().insertDcWarning(dcWarning);//加入数据库
|
|
|
|
@ -179,7 +179,7 @@ public class DcWarningServiceImpl implements IDcWarningService |
|
|
|
} |
|
|
|
return 1; |
|
|
|
} |
|
|
|
JSONObject redisValueFour = redisWarningStrategy.get(redisKye+"4");//查看传入的事件类型是否配置策略3(自动结束策略)
|
|
|
|
HashMap redisValueFour = redisWarningStrategy.get(redisKye+"4");//查看传入的事件类型是否配置策略3(自动结束策略)
|
|
|
|
if (redisValueOne==null&&redisValueTwo==null&&redisValueThree==null&&redisValueFour!=null){ //执行策略4,执行到这里说明1不存在或者2、3不存在或者1未满足过滤条件
|
|
|
|
if (dataId==null){//如果不存在直接加入数据库,加入缓存
|
|
|
|
int insertDcWarning = new DcWarningServiceImpl().insertDcWarning(dcWarning);//加入数据库
|
|
|
|
@ -203,7 +203,7 @@ public class DcWarningServiceImpl implements IDcWarningService |
|
|
|
} |
|
|
|
return 1; |
|
|
|
} |
|
|
|
return 1; |
|
|
|
return dcWarningMapper.insertDcWarning(dcWarning);//如果没有配置策略直接加入数据库;
|
|
|
|
} |
|
|
|
private JSONObject mergeJsonObjects(JSONObject jsonObjectOne, JSONObject jsonObjectTwo){ |
|
|
|
// 合并videoList
|
|
|
|
|
