规则触发生成动作信息发送消息给移动端刷新

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

@@ -283,6 +283,11 @@ public class ContingencyInstanceImpl implements IContingencyInstance {
                 ruleTrigger.publish(contingencyRo, "换流站消防专项预案/" + plan.get(0), ArrayUtils.toArray(equipment.getName()));
 
                 publisherPlanLog(stepCode, buttonCode, batchNo);
+
+                // 更新记录之后发送消息刷新
+                String topic = String.format("/%s/%s/%s", serviceName, stationName, "plan");
+                System.out.println("=========================> 刷新聊天记录 refreshRecord ");
+                webMqttComponent.publish(topic, "{\"msgType\":\"refreshRecord\"}");
             }
         } else {
             throw new Exception("数据异常,请联系管理员.");
@@ -390,6 +395,9 @@ public class ContingencyInstanceImpl implements IContingencyInstance {
                     planRuleService.updatePlanRuleByBatchNo(batchNo);
                     // 应急处置中断，更新预案信息表结束时间
                     contingencyInstanceInfoService.updateEndTimeById(batchNo);
+                    String topic = String.format("/%s/%s/%s", serviceName, stationName, "plan");
+                    System.out.println("=========================> 规则触发  预案动作结束 ");
+                    webMqttComponent.publish(topic, "{\"msgType\":\"stopOperate\"}");
                 }
             }
         }