修改bug

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/service/impl/MqttReceiveServiceImpl.java

@@ -744,12 +744,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
         iotDataListToCacheMap(iotDatalist);
         iotDatalist.forEach(iotDataVO -> {
             boolean alarmFlag = false;
-            String indexKey = iotDataVO.getKey();
-            String indexValue = iotDataVO.getValue().toString();
-            // 稳压泵启停信号处理
-            if (indexKey.equals(pressurePumpStart)) {
-                pressurePump(indexKey, indexValue, iotDatalist, topicEntity);
-            }
+
             for (EquipmentSpecificIndex equipmentSpecificIndex : indexList) {
                 if (!ObjectUtils.isEmpty(equipmentSpecificIndex.getNameKey())
                         && equipmentSpecificIndex.getNameKey().toLowerCase().equals(iotDataVO.getKey().toLowerCase())) {
@@ -869,6 +864,15 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
         TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
             @Override
             public void afterCommit() {
+                iotDatalist.forEach(iotDataVO -> {
+                    String indexKey = iotDataVO.getKey();
+                    String indexValue = iotDataVO.getValue().toString();
+                    // 稳压泵启停信号处理
+                    if (indexKey.equals(pressurePumpStart)) {
+                        pressurePump(indexKey, indexValue, iotDatalist, topicEntity);
+                    }
+                });
+
                 equipmentSpecificAlarms.forEach(action -> {
                     if (AlarmStatusEnum.BJ.getCode() == action.getStatus()) {
                         alarmLogs.add(addEquipAlarmLogRecord(action));