修改告警消息推送逻辑

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

@@ -282,7 +282,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
   }
 
   
-    static void upAlarmLogStatus(String iotCode, String equipmentSpecificIndexKey, IEquipmentSpecificAlarmLogService equipmentSpecificAlarmLogService) {
+    public List<EquipmentSpecificAlarmLog> upAlarmLogStatus(String iotCode, String equipmentSpecificIndexKey, IEquipmentSpecificAlarmLogService equipmentSpecificAlarmLogService) {
         LambdaQueryWrapper<EquipmentSpecificAlarmLog> queryWrapper = new LambdaQueryWrapper();
         queryWrapper.eq(EquipmentSpecificAlarmLog::getIotCode, iotCode);
         queryWrapper.eq(EquipmentSpecificAlarmLog::getEquipmentSpecificIndexKey, equipmentSpecificIndexKey);
@@ -295,6 +295,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
         if (!logs.isEmpty()) {
             equipmentSpecificAlarmLogService.updateBatchById(logs);
         }
+        return logs;
     }
 
     public void publishDataToCanvas(List<EquipmentSpecificIndex> indexList) {
@@ -723,16 +724,13 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
               }
               mqttSendGateway.sendToMqtt(TopicEnum.EQDQR.getTopic(), JSONArray.toJSON(action).toString());
           } else {
-              upAlarmLogStatus(action.getIotCode(), action.getEquipmentSpecificIndexKey(), equipmentSpecificAlarmLogService);
+        	  equipmentAlarmLogs.addAll(upAlarmLogStatus(action.getIotCode(), action.getEquipmentSpecificIndexKey(), equipmentSpecificAlarmLogService));
               mqttSendGateway.sendToMqtt(TopicEnum.EQYQR.getTopic(), JSONArray.toJSON(action).toString());
               bool = Boolean.TRUE;
           }
 		  
 	  });
-	  
-	  if(ObjectUtils.isEmpty(equipmentAlarmLogs)){
-		  return;
-	  }
+	 
 	  TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
           @Override
           public void afterCommit() {
@@ -770,7 +768,9 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
                   }
                   
                   // 向南瑞平台推送报警消息
-                  syncDataService.syncCreatedSendAlarm(equipmentAlarmLogs);
+                  if(!bool){
+                      syncDataService.syncCreatedSendAlarm(equipmentAlarmLogs);
+                  }
               }
           }
       });