item：修改operateConfirmMessage、initOperate、replayMessage数据结构

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

@@ -386,12 +386,20 @@ public class ContingencyInstanceImpl implements IContingencyInstance {
                 ContingencyPlanInstance instance = repository.save(contingencyPlanInstance);
                 if (buttonState.equals("CONFIRM")) {
                     String topic = String.format("/%s/%s/%s", serviceName, stationName, "plan");
-                    webMqttComponent.publish(topic, "{\"msgType\":\"operateConfirmMessage\"}");
+                    Map<String, Object> map = new HashMap<>();
+                    map.put("contingency", new ContingencyRo());
+                    map.put("msgContext", Collections.EMPTY_MAP);
+                    map.put("msgType", "operateConfirmMessage");
+                    webMqttComponent.publish(topic, JSON.toJSONString(map));
                 }
                 if (buttonState.equals("CANCEL_0")) {
                     String topic = String.format("/%s/%s/%s", serviceName, stationName, "plan");
                     System.out.println("=========================> 规则触发  初始化动作 initOperate ");
-                    webMqttComponent.publish(topic, "{\"msgType\":\"initOperate\"}");
+                    Map<String, Object> map = new HashMap<>();
+                    map.put("contingency", new ContingencyRo());
+                    map.put("msgContext", Collections.EMPTY_MAP);
+                    map.put("msgType", "initOperate");
+                    webMqttComponent.publish(topic, JSON.toJSONString(map));
                 }
                 //  异步数据同步之消息发送
                 contingencyPlanInstanceDataSync(instance);

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

@@ -7,6 +7,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.google.common.collect.Lists;
 import com.yeejoin.amos.component.feign.config.InnerInvokException;
 import com.yeejoin.amos.component.feign.model.FeignClientResult;
+import com.yeejoin.amos.fas.business.action.model.ContingencyRo;
 import com.yeejoin.amos.fas.business.action.mq.WebMqttComponent;
 import com.yeejoin.amos.fas.business.constants.FasConstant;
 import com.yeejoin.amos.fas.business.dao.mapper.*;
@@ -560,7 +561,11 @@ public class PlanVisual3dServiceImpl implements IPlanVisual3dService {
         dto.setContent(StringUtil.isNotEmpty(dto.getContent()) ? dto.getContent() : "");
         repository.save(dto);
         String topic = String.format("/%s/%s/%s", serviceName, stationName, "plan");
-        webMqttComponent.publish(topic, "{\"msgType\":\"replayMessage\"}");
+        Map<String, Object> map = new HashMap<>();
+        map.put("contingency", new ContingencyRo());
+        map.put("msgContext", Collections.EMPTY_MAP);
+        map.put("msgType", "replayMessage");
+        webMqttComponent.publish(topic, JSON.toJSONString(map));
         return dto;
     }