|
@@ -259,6 +259,7 @@ public class DeviceMqttConsumerImpl implements DeviceMqttConsumer {
|
|
if (faultLevel1.intValue() < faultLevel) {
|
|
if (faultLevel1.intValue() < faultLevel) {
|
|
//小于,当前故障级别,更新
|
|
//小于,当前故障级别,更新
|
|
deviceFaultInfo.setFaultLevel(faultLevel);
|
|
deviceFaultInfo.setFaultLevel(faultLevel);
|
|
|
|
+ deviceInfoService.updateById(new DeviceInfo().setDeviceId(deviceId).setFaultLevel(faultLevel));
|
|
}
|
|
}
|
|
//累加次数
|
|
//累加次数
|
|
deviceFaultInfo.setEventNum(deviceFaultInfo.getEventNum() + 1);
|
|
deviceFaultInfo.setEventNum(deviceFaultInfo.getEventNum() + 1);
|
|
@@ -272,6 +273,7 @@ public class DeviceMqttConsumerImpl implements DeviceMqttConsumer {
|
|
.setEventCode(code)
|
|
.setEventCode(code)
|
|
.setEventNum(count.intValue())
|
|
.setEventNum(count.intValue())
|
|
);
|
|
);
|
|
|
|
+ deviceInfoService.updateById(new DeviceInfo().setDeviceId(deviceId).setFaultLevel(faultLevel));
|
|
}
|
|
}
|
|
//已按最大故障级别排序,所以满足条件就退出循环
|
|
//已按最大故障级别排序,所以满足条件就退出循环
|
|
break;
|
|
break;
|