Commit 70fd40f2 authored by zhangsen's avatar zhangsen

修改bug

parent a58d7619
...@@ -121,7 +121,8 @@ public class MqttReceiveServiceImpl implements MqttReceiveService { ...@@ -121,7 +121,8 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
questionVO.getAlarmEventLog().forEach(item -> { questionVO.getAlarmEventLog().forEach(item -> {
if (StrUtil.isNotEmpty(item.getSignalId())) { if (StrUtil.isNotEmpty(item.getSignalId())) {
FireEquipmentSignalLog fireEquipmentSignalLog = new FireEquipmentSignalLog(); FireEquipmentSignalLog fireEquipmentSignalLog = new FireEquipmentSignalLog();
fireEquipmentSignalLog.setConfirmState(item.getStatus()); //只要已下发就先改为已处理
fireEquipmentSignalLog.setConfirmState("1");
UpdateWrapper<FireEquipmentSignalLog> updateWrapper = new UpdateWrapper<>(); UpdateWrapper<FireEquipmentSignalLog> updateWrapper = new UpdateWrapper<>();
updateWrapper.lambda().eq(FireEquipmentSignalLog::getSignalId, item.getSignalId()); updateWrapper.lambda().eq(FireEquipmentSignalLog::getSignalId, item.getSignalId());
fireEquipmentSignalLogServiceImpl.update(fireEquipmentSignalLog, updateWrapper); fireEquipmentSignalLogServiceImpl.update(fireEquipmentSignalLog, updateWrapper);
......
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