|
@@ -39,7 +39,7 @@ public class ReCountService {
|
|
|
int thisReCount = reCount == null ? 0 : reCount.intValue();
|
|
int thisReCount = reCount == null ? 0 : reCount.intValue();
|
|
|
log.info("【设备预警】消息标识{}:当前设备ID:{}, 预警配置ID:{} 的重复次数为: {}", messageId, warnResult.getDevId(), warnResult.getConfigId(), thisReCount);
|
|
log.info("【设备预警】消息标识{}:当前设备ID:{}, 预警配置ID:{} 的重复次数为: {}", messageId, warnResult.getDevId(), warnResult.getConfigId(), thisReCount);
|
|
|
if (thisReCount + 1 > targetReCount) {
|
|
if (thisReCount + 1 > targetReCount) {
|
|
|
- log.info("【设备预警】消息标识{}:达到或超过阈值, 不再增加重复次数", messageId);
|
|
|
|
|
|
|
+ log.info("【设备预警】消息标识{}:达到或超过阈值, 不再增加重复次数,直接生成预警记录", messageId);
|
|
|
iotWarnBussinessService.insertWarnRecord(buildWarnMessage(messageId, warnResult));
|
|
iotWarnBussinessService.insertWarnRecord(buildWarnMessage(messageId, warnResult));
|
|
|
} else if (thisReCount + 1 == targetReCount) {
|
|
} else if (thisReCount + 1 == targetReCount) {
|
|
|
log.info("【设备预警】消息标识{}:初次达到阈值, 增加重复次数并生成预警记录", messageId);
|
|
log.info("【设备预警】消息标识{}:初次达到阈值, 增加重复次数并生成预警记录", messageId);
|