1.事务问题 提交后再发送 否则前端刷新不出来

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

@@ -234,11 +234,11 @@ public class ConfirmAlarmServiceImpl extends ServiceImpl<ConfirmAlarmMapper, Equ
                 }
 //                syncDataService.syncCreatedSendAlarmReport(ent);
             }
-            //数字换流站使用
-            mqttSendGateway.sendToMqtt(TopicEnum.EQZXDT.getTopic(), "");
             TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
                 @Override
                 public void afterCommit() {
+                    //数字换流站使用
+                    mqttSendGateway.sendToMqtt(TopicEnum.EQZXDT.getTopic(), "");
                     JSONObject jsonObject = new JSONObject();
                     jsonObject.put("seqNo", UUID.randomUUID().toString().replace("-", "").toLowerCase());
                     mqttSendGateway.sendToMqtt(TopicEnum.ALARM_LOG_INSERT.getTopic(), jsonObject.toString());