bug 提交

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/action/ContingencyAction.java

@@ -2,6 +2,7 @@ package com.yeejoin.amos.fas.business.action;
 
 
 import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.yeejoin.amos.component.rule.MethodParam;
 import com.yeejoin.amos.component.rule.RuleActionBean;
@@ -25,10 +26,7 @@ import com.yeejoin.amos.fas.business.service.impl.RuleRunigSnapshotServiceImpl;
 import com.yeejoin.amos.fas.business.service.intfc.*;
 import com.yeejoin.amos.fas.business.service.model.ToipResponse;
 import com.yeejoin.amos.fas.business.util.JSONUtil;
-import com.yeejoin.amos.fas.business.vo.ButtonJsonVO;
-import com.yeejoin.amos.fas.business.vo.MessageVO;
-import com.yeejoin.amos.fas.business.vo.PlanStepJsonVO;
-import com.yeejoin.amos.fas.business.vo.Toke;
+import com.yeejoin.amos.fas.business.vo.*;
 import com.yeejoin.amos.fas.common.enums.ContingencyPlanStatusEnum;
 import com.yeejoin.amos.fas.common.enums.PlanRecordStatusEnum;
 import com.yeejoin.amos.fas.core.enums.NumberEnum;
@@ -1007,6 +1005,37 @@ public class ContingencyAction implements CustomerAction {
             contingencyPlanInstance.setContent(buttonJson);
             contingencyPlanInstanceRepository.save(contingencyPlanInstance);
 
+            if("0".equals(stepCode)) {
+                TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
+                    @Override
+                    public void afterCommit() {
+                        String planStep = "";
+                        if (redisTemplate.hasKey("planStep")) {
+                            planStep = Objects.requireNonNull(redisTemplate.opsForValue().get("planStep")).toString();
+                        } else {
+                            planStep = planStepService.getPlanStep();
+                        }
+                        JSONArray objects = JSON.parseArray(planStep);
+                        String topic = String.format("/%s/%s/%s", serviceName, stationName, "plan");
+                        Map<String, Object> result = new HashMap<>();
+                        result.put("contingency", new ContingencyRo());
+                        result.put("msgContext", Collections.EMPTY_MAP);
+                        result.put("msgType", "getStepList");
+                        result.put("planStep", objects);
+                        String planTask = "";
+                        if (redisTemplate.hasKey("planTask")) {
+                            planTask = Objects.requireNonNull(redisTemplate.opsForValue().get("planTask")).toString();
+                        } else {
+                            List<ContingencyPlanInstanceVO> lists = planVisual3dService.getTaskActionList(batchNo, 1);
+                            planTask = JSON.toJSONString(lists);
+                        }
+                        JSONArray taskObjects = JSON.parseArray(planTask);
+                        result.put("planTask", taskObjects);
+                        webMqttComponent.publish(topic, JSON.toJSONString(result));
+                    }
+                });
+            }
+
             MessageVO messageVO = new MessageVO();
             messageVO.setTitle("应急处置事项提醒");
             messageVO.setBody("【" + taskName + "】" + DateFormatUtils.format(new Date(), "yyyy-MM-dd HH:mm:ss"));