Commit 7832be9f authored by KeYong's avatar KeYong

修改冲突代码

parent 1243eb8e
...@@ -872,10 +872,10 @@ public class MqttReceiveServiceImpl implements MqttReceiveService { ...@@ -872,10 +872,10 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
} }
// 报警表新增信息 // 报警表新增信息
if (ObjectUtils.isEmpty(indexAlarms) && (TrueOrFalseEnum.real.value.equals(equipmentSpcIndex.getValue()))) { if (ObjectUtils.isEmpty(indexAlarms) && (TrueOrFalseEnum.real.value.equals(equipmentSpcIndex.getValue()))) {
addEquipmentSpecificAlarm(equipmentSpecificAlarms, equipmentSpcIndex, equipmentSpecificAlarm); equipmentSpecificAlarms = addEquipmentSpecificAlarm(equipmentSpecificAlarms, equipmentSpcIndex, equipmentSpecificAlarm);
} else { } else {
// 报警表更新信息 // 报警表更新信息
indexAlarms.forEach(action -> { for (EquipmentSpecificAlarm action : indexAlarms) {
if (TrueOrFalseEnum.real.value.equals(equipmentSpcIndex.getValue())) { if (TrueOrFalseEnum.real.value.equals(equipmentSpcIndex.getValue())) {
// 报警,修改发生频率 // 报警,修改发生频率
action.setFrequency((action.getFrequency() + 1)); action.setFrequency((action.getFrequency() + 1));
...@@ -895,7 +895,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService { ...@@ -895,7 +895,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
action.setEquipmentSpecificCode(equipmentSpcIndex.getEquipmentSpecificCode()); action.setEquipmentSpecificCode(equipmentSpcIndex.getEquipmentSpecificCode());
action.setBuildId(equipmentSpcIndex.getBuildId()); action.setBuildId(equipmentSpcIndex.getBuildId());
equipmentSpecificAlarms.add(action); equipmentSpecificAlarms.add(action);
}); }
} }
return equipmentSpecificAlarms; return equipmentSpecificAlarms;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment