diff --git a/zc-business/src/main/java/com/zc/business/service/impl/DcWarningServiceImpl.java b/zc-business/src/main/java/com/zc/business/service/impl/DcWarningServiceImpl.java index 266a685e..a52ca768 100644 --- a/zc-business/src/main/java/com/zc/business/service/impl/DcWarningServiceImpl.java +++ b/zc-business/src/main/java/com/zc/business/service/impl/DcWarningServiceImpl.java @@ -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 redisWarningStrategy = redisCache.getCacheMap(WARNINGSTRATEGY);//获取缓存全部的配置数据 - if (redisWarningStrategy==null){//如果缓存为空,查询数据重新加入缓存 + Map redisWarningStrategy = redisCache.getCacheMap(WARNINGSTRATEGY);//获取缓存全部的配置数据 + if (redisWarningStrategy==null||redisWarningStrategy.size()==0){//如果缓存为空,查询数据重新加入缓存 Map redisMap = new HashMap<>(); List 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 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