Skip to content

Y
YeeAmosFireAutoSysRoot
Commit 95f60d8e authored by KeYong's avatar KeYong
Browse files
Options

更新

parent a34f334f
Hide whitespace changes
Inline Side-by-side
Showing with 9 additions and 9 deletions
YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/service/impl/ContingencyPlanServiceImpl.java
View file @ 95f60d8e
...@@ -244,15 +244,15 @@ public class ContingencyPlanServiceImpl implements IContingencyPlanService { ...@@ -244,15 +244,15 @@ public class ContingencyPlanServiceImpl implements IContingencyPlanService {
result.setMessage(ReserveEnum.RUN.getText()); result.setMessage(ReserveEnum.RUN.getText());
result.setBatchNo(batchNo); result.setBatchNo(batchNo);
String topic = String.format("/%s/%s/%s", serviceName, stationName, "plan"); // String topic = String.format("/%s/%s/%s", serviceName, stationName, "plan");
Map<String, Object> map = new HashMap<>(); // Map<String, Object> map = new HashMap<>();
JSONObject msgContext = new JSONObject(); // JSONObject msgContext = new JSONObject();
msgContext.put("content", "startPlan"); // msgContext.put("content", "startPlan");
map.put("contingency", new ContingencyRo()); // map.put("contingency", new ContingencyRo());
// map.put("msgContext", "{\"content\":\"startPlan\"}"); //// map.put("msgContext", "{\"content\":\"startPlan\"}");
map.put("msgContext", msgContext); // map.put("msgContext", msgContext);
map.put("msgType", "refreshRecord"); // map.put("msgType", "refreshRecord");
webMqttComponent.publish(topic, JSON.toJSONString(map)); // webMqttComponent.publish(topic, JSON.toJSONString(map));
} }
return result; return result;
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment