|
@@ -118,6 +118,11 @@ public class NettyAlarmMsgBaseHandler extends ChannelInboundHandlerAdapter {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ public static void main(String[] args) {
|
|
|
+ String[] split = "Pj3101170001".split(",");
|
|
|
+ System.out.println(split);
|
|
|
+ }
|
|
|
+
|
|
|
/**
|
|
|
* @description: 发送全部报警定义到边缘端
|
|
|
* @param: nettyMessage
|
|
@@ -159,10 +164,10 @@ public class NettyAlarmMsgBaseHandler extends ChannelInboundHandlerAdapter {
|
|
|
data.remove("onlyCount");
|
|
|
alarmConfigs = nettyAlarmService.queryAlarmConfig(data);
|
|
|
}
|
|
|
- log.info("===========>报警定义信息获取完成!共{}条!", alarmConfigs.size());
|
|
|
if (alarmConfigs == null || alarmConfigs.size() <= 0) {
|
|
|
return;
|
|
|
}
|
|
|
+ log.info("===========>报警定义信息获取完成!共{}条!", alarmConfigs.size());
|
|
|
// 查询到的报警定义按项目id分组,发送到对应的边缘端
|
|
|
Map<String, List<Object>> groups = alarmConfigs.stream().collect(
|
|
|
Collectors.groupingBy(alarmConfig ->
|