Commit af717b55 authored by maoying's avatar maoying

修改数据接收异常bug

parent 2b75457a
...@@ -285,8 +285,9 @@ public class MqttReceiveServiceImpl implements MqttReceiveService { ...@@ -285,8 +285,9 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
// 报警数据保存 // 报警数据保存
List<EquipmentSpecificAlarmLog> alarmLogs = new ArrayList<>(); List<EquipmentSpecificAlarmLog> alarmLogs = new ArrayList<>();
equipmentSpecificAlarmService.saveOrUpdateBatch(equipmentSpecificAlarms); if(!ObjectUtils.isEmpty(equipmentSpecificAlarms)){
equipmentSpecificAlarmService.saveOrUpdateBatch(equipmentSpecificAlarms);
}
// 需要在事务提交之后,否侧事务隔离查询不出数据 // 需要在事务提交之后,否侧事务隔离查询不出数据
TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() { TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
@Override @Override
......
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