|
@@ -149,7 +149,7 @@ public class NettyAlarmMsgBaseHandler extends ChannelInboundHandlerAdapter {
|
|
|
int divide = resultCount / limitCout;
|
|
|
JSONArray alarmConfigs = new JSONArray();
|
|
|
if (divide > 1) {
|
|
|
- for (int i = 1; i <= divide; i++) {
|
|
|
+ for (int i = 1; i <= divide + 1; i++) {
|
|
|
data.put("onlyCount", false);
|
|
|
data.put("page", i);
|
|
|
data.put("size", limitCout);
|
|
@@ -169,6 +169,7 @@ public class NettyAlarmMsgBaseHandler extends ChannelInboundHandlerAdapter {
|
|
|
((JSONObject) alarmConfig).getString("projectId")
|
|
|
)
|
|
|
);
|
|
|
+ alarmConfigs.clear();
|
|
|
|
|
|
// 全量同步报警定义,同一个边缘端只能发送一条消息,如果有多条,只有最后一条生效。
|
|
|
// 因此这里需要先将需要给边缘端发送的消息整理在一起
|