修改告警更新后向前端推送消息逻辑

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

@@ -730,7 +730,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
         	  JSONObject jsonObject = new JSONObject();
               jsonObject.put("seqNo", UUID.randomUUID().toString().replace("-", "").toLowerCase());
               mqttSendGateway.sendToMqtt(TopicEnum.ALARM_LOG_INSERT.getTopic(), jsonObject.toString());
-        	  
+              mqttSendGateway.sendToMqtt(TopicEnum.EQZXDT.getTopic(), "");
         	  //   数字换流站数据处理（高斯库同步及南瑞告警推送）
         	  if (syncSwitch) {
                   List<FireEquipmentFireAlarm> alarmList = createFireEquipmentFireAlarmVo(equipmentAlarmLogs);
@@ -913,7 +913,6 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
       TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
           @Override
           public void afterCommit() {
-        	  mqttSendGateway.sendToMqtt(TopicEnum.EQZXDT.getTopic(), "");
         	  mqttSendGateway.sendToMqtt(TopicEnum.EQXXTJ.getTopic(), "");
               iEquipmentSpecificSerivce.integrationPageSysDataRefresh(topicEntity.getCode());
               iEquipmentSpecificSerivce.updateEquipmentSpecIndexRealtimeData(equipmentSpecificIndexList);