item：解决APP端，消息刷新不同步问题

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/service/impl/ContingencyInstanceImpl.java

@@ -186,7 +186,7 @@ public class ContingencyInstanceImpl implements IContingencyInstance {
         return categorys;
     }
 
-
+    @Transactional
     public Optional<Equipment> fire(String batchNo, String stepCode, String contingencyPlanId, String buttonCode, String buttonState, String stepStateOnbutton) throws Exception {
         //火灾误报
         ContingencyOriginalData contingencyOriginalData = iContingencyOriginalDataDao.findByBatchNo(batchNo);
@@ -278,10 +278,10 @@ public class ContingencyInstanceImpl implements IContingencyInstance {
                 publisherPlanLog(stepCode, buttonCode, batchNo);
 
                 // 更新记录之后发送消息刷新
-                String topic = String.format("/%s/%s/%s", serviceName, stationName, "plan");
-                System.out.println("=========================> 刷新聊天记录 refreshRecord ");
-
-                webMqttComponent.publish(topic, "{\"msgType\":\"refreshRecord\"}");
+//                String topic = String.format("/%s/%s/%s", serviceName, stationName, "plan");
+//                System.out.println("=========================> 刷新聊天记录 refreshRecord ");
+//
+//                webMqttComponent.publish(topic, "{\"msgType\":\"refreshRecord\"}");
             }
         } else {
             throw new Exception("数据异常,请联系管理员.");
@@ -585,6 +585,9 @@ public class ContingencyInstanceImpl implements IContingencyInstance {
         } catch (Exception e) {
             throw e;
         } finally {
+            // 更新记录之后发送消息刷新
+            String topic = String.format("/%s/%s/%s", serviceName, stationName, "plan");
+            webMqttComponent.publish(topic, "{\"msgType\":\"refreshRecord\"}");
             fireQueue.removeFirst();
         }
     }