item：预案执行流程走redis优化

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

@@ -18,6 +18,7 @@ import com.yeejoin.amos.fas.business.action.util.ContingencyLogPublisher;
 import com.yeejoin.amos.fas.business.dao.mapper.ContingencyPlanInstanceMapper;
 import com.yeejoin.amos.fas.business.dao.mapper.PlanDetailMapper;
 import com.yeejoin.amos.fas.business.dao.mapper.PlanOperationRecordMapper;
+import com.yeejoin.amos.fas.business.dao.repository.IContingencyPlanInstanceRepository;
 import com.yeejoin.amos.fas.business.dao.repository.IPlanDetailDao;
 import com.yeejoin.amos.fas.business.dao.repository.IPlanOperationRecordDao;
 import com.yeejoin.amos.fas.business.feign.JcsFeign;
@@ -126,7 +127,7 @@ public class ContingencyAction implements CustomerAction {
     private IPlanRuleService planRuleService;
 
     @Autowired
-    private IPlanVisual3dService iPlanVisual3dService;
+    private IPlanVisual3dService planVisual3dService;
 
     @Autowired
     private ContingencyInstanceInfoService contingencyInstanceInfoService;
@@ -134,6 +135,9 @@ public class ContingencyAction implements CustomerAction {
     @Autowired
     private ContingencyPlanInstanceMapper contingencyPlanInstanceMapper;
 
+    @Autowired
+    private IContingencyPlanInstanceRepository contingencyPlanInstanceRepository;
+
     @Value("${rocket-plan-topic}")
     private String rocketTopic;
 
@@ -148,6 +152,8 @@ public class ContingencyAction implements CustomerAction {
 
     private static Map<String, String> OPERATE_RECORD_ID = new HashMap<>();
 
+    private static Map<String, ContingencyPlanInstance> OPERATE_CONTINGENCYPLAN_INSTANCE = new HashMap<>();
+
     private static Map<String, Map<String, String>> stringStringMap = new HashMap<>();
     static SimpleDateFormat sdf = new SimpleDateFormat("HH:mm:ss");
 
@@ -339,7 +345,6 @@ public class ContingencyAction implements CustomerAction {
                 e.printStackTrace();
             }
             result.add(tempmap1);
-            System.out.printf("=========recordarea=====396====%s=========%s=========%n", JSONObject.toJSONString(paramObj), JSONObject.toJSONString(result));
             sendcmd("recordarea", paramObj, result);
             sendweb("recordarea", paramObj, result);
         }
@@ -451,8 +456,9 @@ public class ContingencyAction implements CustomerAction {
             SafteyPlanResult result = new SafteyPlanResult();
             Map<String, Object> tempmap1 = new HashMap<>();
 
-            String contingencyPlanId = getContingencyPlanId(contingencyRo.getBatchNo(), actionName, icon, tips, buttonJson);
-
+//            String contingencyPlanId = getContingencyPlanId(contingencyRo.getBatchNo(), actionName, icon, tips, buttonJson);
+            ContingencyPlanInstance contingencyPlanInstance = getContingencyPlan(contingencyRo.getBatchNo(), actionName, icon, tips, buttonJson);
+            String contingencyPlanId = contingencyPlanInstance.getId();
             tempmap1.put("actionName", actionName);
             tempmap1.put("icon", icon);
             tempmap1.put("tips", tips);
@@ -463,16 +469,9 @@ public class ContingencyAction implements CustomerAction {
 
             if (!isUpdatePlanStep) {
                 try {
-                    System.out.println("======optionarea 加入队列参数信息======action=====");
-
                     ButtonJsonVO buttonJsonVO = JSONObject.parseObject(buttonJson, ButtonJsonVO.class);
                     Map<String, Object> map = buttonJsonVO.getOperate().get(buttonJsonVO.getOperate().size() - 1);
-                    System.out.println("batchNo-->" + batchNo);
-                    System.out.println("stepCode-->" + stepCode);
-                    System.out.println("stepCodeNew-->" + buttonJsonVO.getStepCode());
-                    System.out.println("contingencyPlanId-->" + contingencyPlanId);
-                    System.out.println("buttonCode-->" + map.get("code").toString());
-                    iContingencyInstance.fire(batchNo, buttonJsonVO.getStepCode(), contingencyPlanId, map.get("code").toString(), "CANCEL_0", "A", "false", RequestContext.getToken(), RequestContext.getProduct(), RequestContext.getAppKey());
+                    iContingencyInstance.fire(batchNo, buttonJsonVO.getStepCode(), buttonJson, contingencyPlanId, map.get("code").toString(), "CANCEL_0", "A", "false", RequestContext.getToken(), RequestContext.getProduct(), RequestContext.getAppKey());
                 } catch (Exception e) {
                     log.error("optionarea 加入队列失败-->" + e.getMessage());
                 }
@@ -486,7 +485,7 @@ public class ContingencyAction implements CustomerAction {
             messageVO.setIsSendApp(true);
             messageVO.setIsSendWeb(true);
             messageVO.setRelationId(batchNo);
-            iPlanVisual3dService.sendMessage(buttonCode, messageVO);
+            planVisual3dService.sendMessage(buttonCode, messageVO);
         }
     }
 
@@ -567,6 +566,19 @@ public class ContingencyAction implements CustomerAction {
         return contingencyPlanId;
     }
 
+    private ContingencyPlanInstance getContingencyPlan(String batchNo, String actionName, String icon, String tips, String buttonJson) {
+        String cacheKey = batchNo + actionName;
+        ContingencyPlanInstance contingencyPlanInstance = null;
+        if (OPERATE_CONTINGENCYPLAN_INSTANCE.get(cacheKey) == null) {
+            contingencyPlanInstance = iContingencyInstance.createInstanceRecord(batchNo, actionName, "DEFAULT", buttonJson, "OPERATE", icon);
+            OPERATE_CONTINGENCYPLAN_INSTANCE.put(cacheKey, contingencyPlanInstance);
+        } else {
+            contingencyPlanInstance = OPERATE_CONTINGENCYPLAN_INSTANCE.get(cacheKey);
+            OPERATE_CONTINGENCYPLAN_INSTANCE.remove(cacheKey);
+        }
+        return contingencyPlanInstance;
+    }
+
 
     /**
      * 地图动作推送
@@ -845,14 +857,17 @@ public class ContingencyAction implements CustomerAction {
         ContingencyRo contingencyRo = (ContingencyRo) paramObj;
         String batchNo = contingencyRo.getBatchNo();
         if (!findByBatchNoAndStatus(batchNo)) {
-            String contingencyPlanId = getContingencyPlanId(contingencyRo.getBatchNo(), actionName, icon, tips, buttonJson);
+//            String contingencyPlanId = getContingencyPlanId(contingencyRo.getBatchNo(), actionName, icon, tips, buttonJson);
+            ContingencyPlanInstance contingencyPlanInstance = getContingencyPlan(contingencyRo.getBatchNo(), actionName, icon, tips, buttonJson);
+            String contingencyPlanId = contingencyPlanInstance.getId();
             try {
-                ContingencyPlanInstance instance = contingencyInstance.getMessageById(contingencyPlanId);
-                if (instance != null) {
-                    instance.setRoleCode(contingencyInstance.getPlanStepRoleCodeByButtonCode(buttonCode));
-                    contingencyPlanInstanceMapper.updateMessageById(instance);
-                }
-                contingencyInstance.fire(contingencyRo.getBatchNo(), stepCode, contingencyPlanId, buttonCode, confirm, stepState, "true", RequestContext.getToken(), RequestContext.getProduct(), RequestContext.getAppKey());
+//                ContingencyPlanInstance instance = contingencyInstance.getMessageById(contingencyPlanId);
+//                if (contingencyPlanInstance != null) {
+                    contingencyPlanInstance.setRoleCode(contingencyInstance.getPlanStepRoleCodeByButtonCode(buttonCode));
+//                    contingencyPlanInstanceMapper.updateMessageById(contingencyPlanInstance);
+                    contingencyPlanInstanceRepository.save(contingencyPlanInstance);
+//                }
+                contingencyInstance.fire(contingencyRo.getBatchNo(), stepCode, buttonJson, contingencyPlanId, buttonCode, confirm, stepState, "true", RequestContext.getToken(), RequestContext.getProduct(), RequestContext.getAppKey());
             } catch (Exception e) {
                 e.printStackTrace();
             }
@@ -907,7 +922,8 @@ public class ContingencyAction implements CustomerAction {
         this.sendweb("recordarea", contingencyRo, result);
         updateNumberPlan(batchNo);
         // 应急处置中断，初始化planStep，json数据；更新预案结束时间
-        planRuleService.updatePlanRuleByBatchNo(batchNo);
+//        planRuleService.updatePlanRuleByBatchNo(batchNo);
+        planVisual3dService.initPlanStep();
         contingencyInstanceInfoService.updateEndTimeById(batchNo);
     }
 

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/controller/TimeLineController.java

@@ -7,6 +7,7 @@ import com.yeejoin.amos.fas.business.service.intfc.IContingencyInstance;
 import com.yeejoin.amos.fas.business.service.intfc.IContingencyOriginalDataService;
 import com.yeejoin.amos.fas.business.service.intfc.IEquipmentService;
 import com.yeejoin.amos.fas.business.service.intfc.IRuleRunningSnapshotService;
+import com.yeejoin.amos.fas.business.vo.PlanExecuteVo;
 import com.yeejoin.amos.fas.config.Permission;
 import com.yeejoin.amos.fas.core.common.request.CommonPageable;
 import com.yeejoin.amos.fas.core.common.request.CommonRequest;
@@ -67,15 +68,10 @@ public class TimeLineController extends BaseController {
 
     @Permission
     //@Authorization(ingore = true)
-    @ApiOperation(httpMethod = "PUT", value = "点击按钮", notes = "点击按钮")
-    @RequestMapping(value = "/fire", produces = "application/json;charset=UTF-8", method = RequestMethod.PUT)
-    public CommonResponse fire(@RequestParam("batchNo") String batchNo,
-                               @RequestParam("stepCode") String stepCode,
-                               @RequestParam("buttonCode") String buttonCode,
-                               @RequestParam("confirm") String confirm,
-                               @RequestParam("contingencyPlanId") String contingencyPlanId,
-                               @RequestParam("stepState") String stepState) throws Exception {
-        iContingencyInstance.fire(batchNo, stepCode, contingencyPlanId, buttonCode, confirm, stepState, "true", getToken(), getProduct(), getAppKey());
+    @ApiOperation(httpMethod = "POST", value = "点击按钮", notes = "点击按钮")
+    @RequestMapping(value = "/fire", produces = "application/json;charset=UTF-8", method = RequestMethod.POST)
+    public CommonResponse fire(@RequestBody PlanExecuteVo vo) throws Exception {
+        iContingencyInstance.fire(vo.getBatchNo(), vo.getStepCode(), vo.getButtonJson(), vo.getContingencyPlanId(), vo.getButtonCode(), vo.getConfirm(), vo.getStepState(), "true", getToken(), getProduct(), getAppKey());
         return CommonResponseUtil.success("SUCCESS");
     }
 

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

@@ -393,7 +393,8 @@ public class ContingencyInstanceImpl implements IContingencyInstance {
                 if ("CONFIRM".equals(buttonState) && ("FIRE_CANCEL".equals(code) || "END_EMERGENCY".equals(code))) {
                     redisTemplate.delete(RiskSourceServiceImpl.cacheKeyForCanBeRunning());
                     // 应急处置中断，初始化planStep，json数据
-                    planRuleService.updatePlanRuleByBatchNo(batchNo);
+//                    planRuleService.updatePlanRuleByBatchNo(batchNo);
+                    planVisual3dService.initPlanStep();
                     // 应急处置中断，更新预案信息表结束时间
                     contingencyInstanceInfoService.updateEndTimeById(batchNo);
                     String topic = String.format("/%s/%s/%s", serviceName, stationName, "plan");
@@ -447,7 +448,7 @@ public class ContingencyInstanceImpl implements IContingencyInstance {
     }
 
     @Override
-    public Optional<Equipment> fire(String batchNo, String stepCode, String contingencyPlanId, String buttonCode, String buttonState, String stepStateOnbutton, String isExecute, String token, String product, String appKey) throws Exception {
+    public Optional<Equipment> fire(String batchNo, String stepCode, String buttonJson, String contingencyPlanId, String buttonCode, String buttonState, String stepStateOnbutton, String isExecute, String token, String product, String appKey) throws Exception {
         Map<String, String> map = new HashMap<>();
         map.put("batchNo", batchNo);
         map.put("stepCode", stepCode);
@@ -456,20 +457,8 @@ public class ContingencyInstanceImpl implements IContingencyInstance {
         map.put("contingencyPlanId", contingencyPlanId);
         map.put("stepState", stepStateOnbutton);
         map.put("isExecute", isExecute);
+        map.put("buttonJson", buttonJson);
 
-        System.out.println("======加入队列参数=====fire===1===");
-        System.out.println("fireQueue-size:-->" + fireQueue.size());
-        System.out.println("batchNo-->" + batchNo);
-        System.out.println("stepCode-->" + stepCode);
-        System.out.println("buttonCode-->" + buttonCode);
-        System.out.println("confirm-->" + buttonState);
-        System.out.println("contingencyPlanId-->" + contingencyPlanId);
-        System.out.println("stepState-->" + stepStateOnbutton);
-        System.out.println("isExecute-->" + isExecute);
-        System.out.println("appKey-->" + appKey);
-        System.out.println("product-->" + product);
-        System.out.println("token-->" + token);
-        System.out.println("======加入队列参数=====fire===2===");
         if (StringUtils.isBlank(token) || StringUtils.isBlank(product)) {
             Toke serverToken = remoteSecurityService.getServerToken();
             map.put("token", serverToken.getToke());
@@ -591,27 +580,16 @@ public class ContingencyInstanceImpl implements IContingencyInstance {
         String contingencyPlanId = map.get("contingencyPlanId");
         String stepState = map.get("stepState");
         String isExecute = map.get("isExecute");
+        String buttonJson = map.get("buttonJson");
         String appKey = map.get("appKey");
         String product = map.get("product");
         String token = map.get("token");
         try {
-            System.out.println("======加入队列参数=====fireQueue===1===");
-            System.out.println("fireQueue-size:-->" + fireQueue.size());
-            System.out.println("batchNo-->" + batchNo);
-            System.out.println("stepCode-->" + stepCode);
-            System.out.println("buttonCode-->" + buttonCode);
-            System.out.println("confirm-->" + confirm);
-            System.out.println("contingencyPlanId-->" + contingencyPlanId);
-            System.out.println("stepState-->" + stepState);
-            System.out.println("isExecute-->" + isExecute);
-            System.out.println("appKey-->" + appKey);
-            System.out.println("product-->" + product);
-            System.out.println("token-->" + token);
-            System.out.println("======加入队列参数=====fireQueue===2===");
             RequestContext.setAppKey(appKey);
             RequestContext.setProduct(product);
             RequestContext.setToken(token);
-            planVisual3dService.updatePlanStep(batchNo, stepCode, contingencyPlanId, buttonCode, isExecute);
+//            planVisual3dService.updatePlanStep(batchNo, stepCode, buttonJson, contingencyPlanId, buttonCode, isExecute);
+            planVisual3dService.updatePlanStepToRedis(batchNo, stepCode, buttonJson, contingencyPlanId, buttonCode, isExecute);
             setButtonExecuted(batchNo, contingencyPlanId, buttonCode, confirm);
             fire(batchNo, stepCode, contingencyPlanId, buttonCode, confirm, stepState);
         } catch (Exception e) {

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

@@ -127,6 +127,7 @@ public class ContingencyPlanServiceImpl implements IContingencyPlanService {
         logger.info("========状态校验===========");
         ReserveEnum reserveEnum = this.runCheck(vo);
         result.setMessage(reserveEnum.getText());
+        planVisual3dService.initPlanStep();
         if (ReserveEnum.THISRUNNING.getStatus().equals(reserveEnum.getStatus())) {
             List<PlanOperationRecord> recordList = planOperationRecordDao.findByPlanId1(Long.valueOf(vo.getPlanId()));
             result.setMessage(ReserveEnum.THISRUNNING.getText());

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

@@ -40,6 +40,7 @@ import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.core.io.Resource;
+import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.CollectionUtils;
@@ -102,6 +103,9 @@ public class PlanVisual3dServiceImpl implements IPlanVisual3dService {
     @Autowired
     private IContingencyPlanInstanceRepository repository;
 
+    @Autowired
+    private RedisTemplate redisTemplate;
+
     @Value("${spring.application.name}")
     private String serviceName;
 
@@ -322,15 +326,13 @@ public class PlanVisual3dServiceImpl implements IPlanVisual3dService {
     public ToipResponse getPlanStepByBatchNo(String batchNo) {
         ToipResponse toipResponse = new ToipResponse();
         // 根据批次号查询预案步骤
-        String planStep = planOperationRecordMapper.getPlanStepByBatchNo(batchNo);
-        if (StringUtil.isNotEmpty(planStep)) {
-            JSONArray objects = JSON.parseArray(planStep);
+//        String planStep = planOperationRecordMapper.getPlanStepByBatchNo(batchNo);
+        String planStep = Objects.requireNonNull(redisTemplate.opsForValue().get("planStep")).toString();
+        JSONArray objects = JSON.parseArray(planStep);
+        Map<String, Object> msgContext = new HashMap<>(2);
+        if (StringUtil.isNotEmpty(planStep) && StringUtils.isNotBlank(batchNo)) {
             // 查询当前步骤
             ContingencyOriginalData contingencyOriginalData = contingencyOriginalDataDao.findByBatchNo(batchNo);
-            String step = contingencyOriginalData.getStep();
-            String confirm = contingencyOriginalData.getConfirm();
-            Map<String, Object> msgContext = new HashMap<>(2);
-            msgContext.put("step", objects);
             msgContext.put("currentStep", contingencyOriginalData.getStep());
             msgContext.put("confirm", contingencyOriginalData.getConfirm());
             msgContext.put("createDate", contingencyOriginalData.getCreateDate());
@@ -342,9 +344,10 @@ public class PlanVisual3dServiceImpl implements IPlanVisual3dService {
                 }
             }
             toipResponse.setMsgType("steparea");
-            toipResponse.setMsgContext(msgContext);
             toipResponse.setContingency(contingencyOriginalData);
         }
+        msgContext.put("step", objects);
+        toipResponse.setMsgContext(msgContext);
         return toipResponse;
     }
 
@@ -394,12 +397,21 @@ public class PlanVisual3dServiceImpl implements IPlanVisual3dService {
     }
 
     @Override
+    public void initPlanStep() {
+        try {
+            redisTemplate.opsForValue().set("planStep", IOUtils.toString(planStepResource.getInputStream(), String.valueOf(StandardCharsets.UTF_8)));
+            redisTemplate.delete("isMock");
+        } catch (IOException e) {
+            throw new RuntimeException("预案redis初始化planStep信息失败！");
+        }
+    }
+
+    @Override
     @Transactional
-    public void updatePlanStep(String batchNo, String stepCode, String contingencyPlanId, String buttonCode, String isExecute) {
+    public void updatePlanStep(String batchNo, String stepCode, String buttonJson, String contingencyPlanId, String buttonCode, String isExecute) {
         if (StringUtils.isNotBlank(batchNo) && StringUtils.isNotBlank(contingencyPlanId) && StringUtils.isNotBlank(buttonCode)) {
             // 根据批次号查询预案步骤
             PlanRule planRule = planOperationRecordMapper.getPlanRuleByBatchNo(batchNo);
-            System.out.println("======updatePlanStep==前===" + JSON.toJSONString(planRule));
             if (planRule != null) {
                 List<PlanStepJsonVO> list = JSONObject.parseArray(planRule.getPlanStep(), PlanStepJsonVO.class);
                 List<PlanStepJsonVO> collect = list.stream().peek(x -> {
@@ -427,13 +439,55 @@ public class PlanVisual3dServiceImpl implements IPlanVisual3dService {
                         //  通过contingencyPlanId获取buttonJson数据
                         x.setBatchNo(batchNo);
                         x.setCaseId(contingencyPlanId);
-                        ContingencyPlanInstance planInstance = iContingencyPlanInstanceRepository.getOne(contingencyPlanId);
-                        x.setButtonJson(planInstance.getContent());
+//                        ContingencyPlanInstance planInstance = iContingencyPlanInstanceRepository.getOne(contingencyPlanId);
+//                        x.setButtonJson(planInstance.getContent());
+                        x.setButtonJson(buttonJson);
                     }
                 }).collect(Collectors.toList());
                 planRule.setPlanStep(JSON.toJSONString(collect1));
                 planRuleDao.save(planRule);
-                System.out.println("======updatePlanStep==后===" + JSON.toJSONString(planRule));
+            }
+        }
+    }
+
+    @Override
+    public void updatePlanStepToRedis(String batchNo, String stepCode, String buttonJson, String contingencyPlanId, String buttonCode, String isExecute) {
+        if (StringUtils.isNotBlank(batchNo) && StringUtils.isNotBlank(contingencyPlanId) && StringUtils.isNotBlank(buttonCode)) {
+            // 根据批次号查询预案步骤
+            String planStep = Objects.requireNonNull(redisTemplate.opsForValue().get("planStep")).toString();
+            if (StringUtils.isNotBlank(planStep)) {
+                List<PlanStepJsonVO> list = JSONObject.parseArray(planStep, PlanStepJsonVO.class);
+                List<PlanStepJsonVO> collect = list.stream().peek(x -> {
+                    if ("true".equals(isExecute)) {
+                        //  更新进度条标志位
+                        if (StringUtils.isBlank(x.getTime()) && Integer.parseInt(x.getStepCode()) <= Integer.parseInt(stepCode)) {
+                            x.setShowLine(true);
+                        }
+                    }
+                }).collect(Collectors.toList());
+                List<PlanStepJsonVO> collect1 = collect.stream().peek(x -> {
+                    String code = x.getStepCode();
+                    if (code.equals(stepCode)) {
+                        if ("true".equals(isExecute)) {
+                            if (buttonCode.endsWith("_NOT")) {
+                                x.setCheckYesOrNo("0");
+                            } else {
+                                x.setCheckYesOrNo("1");
+                                if (StringUtils.isNotBlank(x.getTime())) {
+                                    x.setShowLine(true);
+                                }
+                            }
+                            x.setTime(DateFormatUtils.format(new Date(), "HH:mm:ss"));
+                        }
+                        //  通过contingencyPlanId获取buttonJson数据
+                        x.setBatchNo(batchNo);
+                        x.setCaseId(contingencyPlanId);
+//                        ContingencyPlanInstance planInstance = iContingencyPlanInstanceRepository.getOne(contingencyPlanId);
+//                        x.setButtonJson(planInstance.getContent());
+                        x.setButtonJson(buttonJson);
+                    }
+                }).collect(Collectors.toList());
+                redisTemplate.opsForValue().set("planStep", JSON.toJSONString(collect1));
             }
         }
     }

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/service/intfc/IContingencyInstance.java

@@ -24,7 +24,7 @@ public interface IContingencyInstance {
 
     void updateStep(String step, String batchNo);
 
-    Optional<Equipment> fire(String batchNo, String stepCode, String contingencyPlanId, String buttonCode, String buttonState, String stepStateOnbutton, String isExecute, String token, String product, String appKey) throws Exception;
+    Optional<Equipment> fire(String batchNo, String stepCode, String buttonJson, String contingencyPlanId, String buttonCode, String buttonState, String stepStateOnbutton, String isExecute, String token, String product, String appKey) throws Exception;
 
     /**
      * 扩展属性赋值

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/service/intfc/IPlanVisual3dService.java

@@ -90,7 +90,11 @@ public interface IPlanVisual3dService {
 
     PlanStepVo updatePlanStep(PlanStepVo planStepVo);
 
-    void updatePlanStep(String batchNo, String stepCode, String contingencyPlanId, String buttonCode, String isExecute);
+    void initPlanStep();
+
+    void updatePlanStep(String batchNo, String stepCode, String buttonJson, String contingencyPlanId, String buttonCode, String isExecute);
+
+    void updatePlanStepToRedis(String batchNo, String stepCode, String buttonJson, String contingencyPlanId, String buttonCode, String isExecute);
 
     Page<ContingencyPlanInstanceVO> selectDisposalActionPage(int current, int size, String batchNo, List<RoleModel> roleModelList, int dataType);
 

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/vo/PlanExecuteVo.java

+package com.yeejoin.amos.fas.business.vo;
+
+import lombok.Data;
+
+@Data
+public class PlanExecuteVo {
+
+    private String batchNo;
+    private String stepCode;
+    private String buttonJson;
+    private String buttonCode;
+    private String confirm;
+    private String contingencyPlanId;
+    private String stepState;
+}