Merge branch 'develop_3.7.2.2' into develop_dl

YeeAmosFireAutoSysCommon/src/main/java/com/yeejoin/amos/fas/common/enums/PlanTypeEnum.java

+package com.yeejoin.amos.fas.common.enums;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+/**
+ * @author keyong
+ * @title: JudgeSignEnum
+ * <pre>
+ * @description: TODO
+ * </pre>
+ * @date 2023/3/8 20:54
+ */
+@Getter
+@AllArgsConstructor
+public enum PlanTypeEnum {
+    MAINTRANSFORM("MAINTRANSFORM","主变"),
+    HIGHRESISTANCE("HIGHRESISTANCE","高抗"),
+    NORMAL("NORMAL","数字预案");
+
+    private String key;
+
+    private String describe;
+}

YeeAmosFireAutoSysCommon/src/main/java/com/yeejoin/amos/fas/dao/dto/PlanStepJsonVO.java

+package com.yeejoin.amos.fas.dao.dto;
+
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class PlanStepJsonVO {
+    private String stepCode;
+    private String stepName;
+    private String stepStatus;
+
+    /**
+     * 是否并行，用于卡片展示；1:是，0:否
+     */
+    private String isParallel;
+    private String roleCode;
+    private String buttonCode;
+
+    private String batchNo;
+    private String caseId;
+    private String buttonJson;
+    private String time = "";
+
+    /**
+     * 进度条标识
+     */
+    private boolean showLine = false;
+
+    /**
+     * 1:是，0:否
+     */
+    private String checkYesOrNo = "";
+
+    /**
+     * 进度索引
+     */
+    private Integer index;
+
+    /**
+     * 节点物联设备指标之间关系
+     */
+    private String inAndOr;
+
+    /**
+     * 节点物联设备之间关系
+     */
+    private String outAndOr;
+
+    /**
+     * 是否自动执行；1自动，0非自动
+     */
+    private Integer isAuto;
+}

YeeAmosFireAutoSysCommon/src/main/java/com/yeejoin/amos/fas/dao/entity/EmergencyTaskContent.java

@@ -2,10 +2,9 @@ package com.yeejoin.amos.fas.dao.entity;
 
 import lombok.Data;
 
-import javax.persistence.Column;
-import javax.persistence.Entity;
-import javax.persistence.NamedQuery;
-import javax.persistence.Table;
+import javax.persistence.*;
+import java.util.ArrayList;
+import java.util.List;
 
 
 /**
@@ -17,22 +16,51 @@ import javax.persistence.Table;
 public class EmergencyTaskContent extends BasicEntity {
     private static final long serialVersionUID = 1L;
 
-
-
-    //分工内容id
+    //分工内容
     @Column(name = "content")
     private String content;
 
-    //人员名称
+    //编号
     @Column(name = "code")
     private String code;
 
-    //人员名称
+    //关联角色ID
     @Column(name = "obligation_id")
     private Long obligationId;
 
+    //所属流程步骤编号
+    @Column(name = "step_code")
+    private String stepCode;
+
+    //角色code
+    @Column(name = "role_code")
+    private String roleCode;
+
+    //任务排序号
+    @Column(name = "task_num")
+    private String taskNum;
+
+    //是否必填项
+    @Column(name = "is_must")
+    private boolean isMust;
 
-    //人员名称
+    //所属流程步骤编号
+    @Column(name = "button_json")
+    private String buttonJson;
+
+    //预案类型
+    @Column(name = "plan_type")
+    private String planType;
+
+    //关联角色名称
     @Column(name = "obligation_name")
     private String obligationName;
+
+    //是否必填项
+    @Transient
+    private String isMustString;
+
+    //所属角色
+    @Transient
+    private ArrayList<String> roleCodeList;
 }
\ No newline at end of file

YeeAmosFireAutoSysCommon/src/main/java/com/yeejoin/amos/fas/dao/entity/EmergencyTaskRole.java

+package com.yeejoin.amos.fas.dao.entity;
+
+import lombok.Data;
+import org.springframework.data.annotation.CreatedDate;
+
+import javax.persistence.*;
+import java.util.Date;
+
+@Data
+@Entity
+@Table(name="c_emergency_task_role")
+@NamedQuery(name="EmergencyTaskRole.findAll", query="SELECT e FROM EmergencyTaskRole e")
+public class EmergencyTaskRole {
+    /**
+     * id
+     */
+    @Id
+    @GeneratedValue(strategy=GenerationType.IDENTITY)
+    @Column(name = "id",nullable=false,unique=true)
+    private Long id;
+
+    @CreatedDate
+    @Column(name="create_date")
+    private Date createDate = new Date();
+
+    /**
+     * 角色名称
+     */
+    @Column(name="name")
+    private String name;
+
+    /**
+     * 角色编码
+     */
+    @Column(name="code")
+    private String code;
+
+    /**
+     * 排序字段
+     */
+    @Column(name="sort")
+    private Long sort;
+
+    /**
+     * 是否删除字段
+     */
+    @Column(name="is_delete")
+    private Integer isDelete = 0;
+
+    /**
+     * 备注
+     */
+    @Column(name="remark")
+    private String remark;
+
+    /**
+     * 版次
+     */
+    @Column(name="creater")
+    private String creater;
+
+    /**
+     * 机构编码
+     */
+    @Column(name="biz_org_code")
+    private String bizOrgCode;
+
+    /**
+     * 机构名称
+     */
+    @Column(name="biz_org_name")
+    private String bizOrgName;
+}

YeeAmosFireAutoSysCommon/src/main/java/com/yeejoin/amos/fas/dao/entity/PlanClassifyTree.java

@@ -42,4 +42,7 @@ public class PlanClassifyTree extends BasicEntity {
 	@Column(name="org_code")
 	private String orgCode;
 
+	@Column(name="plan_type")
+	private String planType;
+
 }
\ No newline at end of file

YeeAmosFireAutoSysCommon/src/main/java/com/yeejoin/amos/fas/dao/entity/PlanStepTree.java

+package com.yeejoin.amos.fas.dao.entity;
+
+import com.yeejoin.amos.fas.dao.dto.PlanStepJsonVO;
+import lombok.Data;
+
+import java.util.ArrayList;
+import java.util.List;
+
+@Data
+public class PlanStepTree extends BasicEntity {
+    private static final long serialVersionUID = 1L;
+
+    private String sequenceNbr;
+
+    //职责id
+    private Long obligationId;
+
+
+    //人员名称
+    private String name;
+
+    private String stepName;
+
+    //子级
+    private List<PlanStepJsonVO> children = new ArrayList<>();
+
+    //树节点展示标识
+    private String type;
+
+    private String code;
+
+    private Integer index;
+}
\ No newline at end of file

YeeAmosFireAutoSysService/pom.xml

@@ -70,22 +70,22 @@
 			<version>1.4.5.RELEASE</version>
 		</dependency>
            <!-- 平台接口 -->
-	 <dependency>
-	  <groupId>com.yeejoin</groupId>
-	  <artifactId>amos-feign-privilege</artifactId>
-	  <version>1.7.1</version>
-     </dependency> 
-    <dependency>
-	  <groupId>com.yeejoin</groupId>
-	  <artifactId>amos-feign-systemctl</artifactId>
-	  <version>1.7.1</version>
-     </dependency>
-     
-     <dependency>
-	  <groupId>com.yeejoin</groupId>
-	  <artifactId>amos-component-feign</artifactId>
-	  <version>1.4.8-SNAPSHOT</version>
-     </dependency>
+		<dependency>
+			<groupId>com.yeejoin</groupId>
+			<artifactId>amos-feign-privilege</artifactId>
+			<version>1.7.1</version>
+		</dependency>
+		<dependency>
+			<groupId>com.yeejoin</groupId>
+			<artifactId>amos-feign-systemctl</artifactId>
+			<version>1.7.1</version>
+		</dependency>
+
+		<dependency>
+			<groupId>com.yeejoin</groupId>
+			<artifactId>amos-component-feign</artifactId>
+			<version>1.4.8-SNAPSHOT</version>
+		</dependency>
 
 		<!-- <dependency>
 			<groupId>com.yeejoin.amos</groupId>

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

@@ -29,6 +29,7 @@ import com.yeejoin.amos.fas.business.util.JSONUtil;
 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.common.enums.PlanTypeEnum;
 import com.yeejoin.amos.fas.core.enums.NumberEnum;
 import com.yeejoin.amos.fas.core.util.DateUtil;
 import com.yeejoin.amos.fas.dao.entity.ContingencyPlanInstance;
@@ -156,8 +157,9 @@ public class ContingencyAction implements CustomerAction {
     private com.yeejoin.amos.component.rule.RuleTrigger ruleTrigger;
     @Autowired
     private IEquipmentFireEquipmentService equipmentFireEquipmentService;
-    @Value("classpath:/json/plan-step.json")
-    private Resource planStepResource;
+
+    @Autowired
+    private IPlanStepService iPlanStepService;
 
     /**
      * @param stepCode     当前步骤编号
@@ -803,13 +805,7 @@ public class ContingencyAction implements CustomerAction {
         tempmap1.put("content", content);
         result.add(tempmap1);
         String instanceId = iContingencyInstance.getInstanceIdByBatchNOAndCategory("OPERATE", stepName, batchNo);
-
-        String json;
-        try {
-            json = IOUtils.toString(planStepResource.getInputStream(), String.valueOf(StandardCharsets.UTF_8));
-        } catch (IOException e) {
-            throw new RuntimeException("获取预案节点信息失败！");
-        }
+        String json = iPlanStepService.getPlanStep();
         List<PlanStepJsonVO> res = JSONObject.parseArray(json, PlanStepJsonVO.class);
         PlanStepJsonVO vo = res.stream().filter(x -> x.getStepCode().equals(stepCode)).collect(Collectors.toList()).get(0);
         Object obj = equipmentFireEquipmentService.automaticExecutePoint(vo.getIndex());

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

@@ -19,6 +19,8 @@ import org.springframework.messaging.Message;
 import org.springframework.messaging.MessageChannel;
 import org.springframework.messaging.MessageHandler;
 
+import java.util.UUID;
+
 /**
  * @author keyong
  * @title: WebMqttSubscribe
@@ -76,7 +78,7 @@ public class WebMqttSubscribe {
 
     @Bean
     public MessageProducer inbound() {
-        adapter = new MqttPahoMessageDrivenChannelAdapter(clientId, mqttPahoClientFactory(), defaultTopic);
+        adapter = new MqttPahoMessageDrivenChannelAdapter(clientId+ UUID.randomUUID(), mqttPahoClientFactory(), defaultTopic);
         adapter.setConverter(new DefaultPahoMessageConverter());
         adapter.setQos(0);
         adapter.setOutputChannel(mqttInputChannel());

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

@@ -20,6 +20,7 @@ import org.springframework.web.bind.annotation.*;
 
 import java.util.*;
 import java.util.concurrent.atomic.AtomicBoolean;
+import java.util.stream.Collectors;
 
 @RestController
 @RequestMapping("/api/contingencyPlan")
@@ -283,7 +284,8 @@ public class ContingencyPlanController extends BaseController {
                                               @RequestParam(value = "batchNo", required = false) String batchNo,
                                               @RequestParam(value = "runState", required = false) String runState,
                                               @RequestParam(value = "updateDate", required = false) String updateDate,
-                                              @RequestParam(value = "roleName", required = false) String roleName
+                                              @RequestParam(value = "roleName", required = false) String roleName,
+                                              @RequestParam(value = "stepCode", required = false) String stepCode
     ) {
         if (current < 1 || size < 1) {
             throw new YeeException("分页参数有误");
@@ -293,7 +295,13 @@ public class ContingencyPlanController extends BaseController {
             String[] ids = new String(roleName).split(",");
             list = Arrays.asList(ids);
         }
-        return CommonResponseUtil2.success(contingencyPlanService.selectTaskActionPage(current, size, batchNo, runState, updateDate, list));
+        List<String> steps = new ArrayList<>();
+        if (!StringUtils.isEmpty(stepCode)) {
+            String[] codes = new String(stepCode).split(",");
+            steps = Arrays.asList(codes);
+            steps = steps.stream().map(x -> String.valueOf(Integer.valueOf(x) - 1)).collect(Collectors.toList());
+        }
+        return CommonResponseUtil2.success(contingencyPlanService.selectTaskActionPage(current, size, batchNo, runState, updateDate, list, steps));
     }
 
 }

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

@@ -2,29 +2,35 @@ package com.yeejoin.amos.fas.business.controller;
 
 
 import com.alibaba.fastjson.JSONObject;
+import org.springframework.data.domain.Page;
+import com.yeejoin.amos.fas.business.dao.mapper.EmergencyTaskMapper;
+import com.yeejoin.amos.fas.business.dao.mapper.EmergencyTaskRoleMapper;
 import com.yeejoin.amos.fas.business.feign.JcsFeign;
 import com.yeejoin.amos.fas.business.service.intfc.IDictService;
 import com.yeejoin.amos.fas.business.service.intfc.IEmergencyTaskService;
+import com.yeejoin.amos.fas.business.service.intfc.IPlanStepService;
 import com.yeejoin.amos.fas.business.vo.EmergencyRelationVo;
+import com.yeejoin.amos.fas.business.vo.PlanStepJsonVO;
+import com.yeejoin.amos.fas.config.Permission;
 import com.yeejoin.amos.fas.core.common.request.CommonPageable;
 import com.yeejoin.amos.fas.core.util.CommonResponse;
 import com.yeejoin.amos.fas.core.util.CommonResponseUtil;
-import com.yeejoin.amos.fas.dao.entity.Dict;
-import com.yeejoin.amos.fas.dao.entity.EmergencyRelation;
-import com.yeejoin.amos.fas.dao.entity.EmergencyRelationTree;
-import com.yeejoin.amos.fas.dao.entity.EmergencyTaskContent;
+import com.yeejoin.amos.fas.core.util.CommonResponseUtil2;
+import com.yeejoin.amos.fas.core.util.ResponseModel;
+import com.yeejoin.amos.fas.dao.entity.*;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Lazy;
-import org.springframework.data.domain.Page;
+import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Controller;
 import org.springframework.web.bind.annotation.*;
 
 import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
+import java.util.Objects;
 import java.util.stream.Collectors;
 
 @Controller
@@ -42,25 +48,43 @@ public class EmergencyTaskController extends BaseController{
     @Autowired
     private IDictService dictService;
 
+    @Autowired
+    private RedisTemplate redisTemplate;
+
+    @Autowired
+    private EmergencyTaskRoleMapper emergencyTaskRoleMapper;
+
+    @Autowired
+    private EmergencyTaskMapper emergencyTaskMapper;
+
+    @Autowired
+    private IPlanStepService planStepService;
+
     @ApiOperation(httpMethod = "GET",value = "岗位人员树", notes = "岗位人员树")
     @RequestMapping(value = "/tree", method = RequestMethod.GET)
-    public CommonResponse tree(){
+    public CommonResponse tree(@RequestParam(value = "type", required = false) String type){
         Dict dict = new Dict();
         dict.setDictCode("YJZC");
         //查询应急角色
-        List<Dict> dictList = dictService.getDictList(dict);
+//        List<Dict> dictList = dictService.getDictList(dict);
+        List<EmergencyTaskRole> emergencyTaskRoles = new ArrayList<>();
+        if (StringUtils.isNotEmpty(type)) {
+            emergencyTaskRoles = emergencyTaskRoleMapper.selectListFilterEmptyTask();
+        } else {
+            emergencyTaskRoles = emergencyTaskRoleMapper.selectList();
+        }
         List<EmergencyRelationTree> list = new ArrayList<>();
         List<EmergencyRelationTree> root = new ArrayList<>();
         List<EmergencyRelationTree> treeNodes = iEmergencyTaskService.treeList();
 
         //组装对应人员节点
-        dictList.forEach(e->{
+        emergencyTaskRoles.forEach(e->{
             EmergencyRelationTree tree = new EmergencyRelationTree();
             tree.setId(e.getId());
-            tree.setName(e.getDictName());
+            tree.setName(e.getName());
             tree.setType("0");
             tree.setSequenceNbr(String.valueOf(e.getId()));
-            tree.setCode(e.getDictValue());
+            tree.setCode(e.getCode());
             tree.setChildren(treeNodes.stream().filter(t->t.getObligationId().equals(e.getId())).collect(Collectors.toList()));
             list.add(tree);
         });
@@ -81,7 +105,7 @@ public class EmergencyTaskController extends BaseController{
 
     @ApiOperation(httpMethod = "GET",value = "分工内容列表", notes = "分工内容列表")
     @RequestMapping(value = "/list", method = RequestMethod.GET)
-    public CommonResponse list(Long obligationId ,@RequestParam int pageNumber,
+    public CommonResponse list(Long obligationId , @RequestParam(required = false) String planType,@RequestParam int pageNumber,
                                @RequestParam  int pageSize){
         if (pageNumber >=1 ){
             pageNumber = pageNumber -1 ;
@@ -90,7 +114,11 @@ public class EmergencyTaskController extends BaseController{
             obligationId = null;
         }
         CommonPageable commonPageable = new CommonPageable(pageNumber, pageSize);
-        Page<EmergencyTaskContent> list = iEmergencyTaskService.list(obligationId,commonPageable);
+
+        if (StringUtils.isNotEmpty(planType) && "0".equals(planType)) {
+            planType = null;
+        }
+        Page<EmergencyTaskContent> list = iEmergencyTaskService.list(obligationId, planType, commonPageable);
         return CommonResponseUtil.success(list);
     }
 
@@ -139,6 +167,30 @@ public class EmergencyTaskController extends BaseController{
         return CommonResponseUtil.success();
     }
 
+    @ApiOperation(httpMethod = "POST",value = "新增应急任务配置", notes = "新增应急任务配置")
+    @PostMapping(value = "/saveTaskConfig", produces = "application/json;charset=UTF-8")
+    public ResponseModel saveTaskConfig(@RequestBody EmergencyTaskContent emergencyTaskContent){
+        iEmergencyTaskService.saveTaskConfig(emergencyTaskContent);
+        return CommonResponseUtil2.success();
+    }
+
+
+    @ApiOperation(httpMethod = "GET",value = "查询流程节点", notes = "查询流程节点")
+    @GetMapping(value = "/findStep")
+    public ResponseModel<List<PlanStepJsonVO>> findStep(@RequestParam String planType){
+        return CommonResponseUtil2.success(planStepService.getPlanStepByParam(planType));
+    }
+
+    @Permission
+    @ApiOperation(value = "根据ID删除数据", notes = "根据ID删除数据")
+    @DeleteMapping(value = "/deleteById", produces = "application/json;charset=UTF-8")
+    public ResponseModel deleteById(@RequestParam(value = "id") Long id) {
+        if (!Objects.isNull(id)) {
+            emergencyTaskMapper.deleteTask(id);
+        }
+        return CommonResponseUtil2.success();
+    }
+
     @ApiOperation(httpMethod = "POST",value = "编辑树人员节点", notes = "编辑树人员节点")
     @PostMapping(value = "/editPerson", produces = "application/json;charset=UTF-8")
     public CommonResponse editPerson(@RequestBody EmergencyRelationVo vo){

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

+package com.yeejoin.amos.fas.business.controller;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yeejoin.amos.fas.business.dao.mapper.EmergencyTaskMapper;
+import com.yeejoin.amos.fas.business.dao.mapper.EmergencyTaskRoleMapper;
+import com.yeejoin.amos.fas.business.vo.ReginParams;
+import com.yeejoin.amos.fas.config.Permission;
+import com.yeejoin.amos.fas.core.util.CommonResponseUtil2;
+import com.yeejoin.amos.fas.core.util.ResponseModel;
+import com.yeejoin.amos.fas.dao.entity.EmergencyTaskRole;
+import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.util.ObjectUtils;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.Date;
+import java.util.List;
+
+@RestController
+@RequestMapping("/api/emergencyTaskRole")
+@Api(tags = "应急任务角色API")
+public class EmergencyTaskRoleController extends BaseController {
+
+    @Autowired
+    private EmergencyTaskRoleMapper emergencyTaskRoleMapper;
+
+    @Autowired
+    private EmergencyTaskMapper emergencyTaskMapper;
+
+    /**
+     * 创建数字预案
+     */
+    @Permission
+    @ApiOperation(value = "新增", notes = "新增")
+    @PostMapping(value = "/save", produces = "application/json;charset=UTF-8")
+    public ResponseModel save(@RequestBody EmergencyTaskRole emergencyTaskRole) {
+        if (null == emergencyTaskRole) {
+            return CommonResponseUtil2.failure("参数有误");
+        }
+        int i = emergencyTaskRoleMapper.countByCode(emergencyTaskRole.getCode());
+        if (i > 0) {
+            return CommonResponseUtil2.failure("角色编码已存在");
+        }
+        AgencyUserModel curUser = getUserInfo();
+        emergencyTaskRole.setCreater(curUser.getUserId());
+        ReginParams reginParams = getSelectedOrgInfo();
+        emergencyTaskRole.setBizOrgCode(getOrgCode(reginParams));
+        emergencyTaskRole.setBizOrgName(!ObjectUtils.isEmpty(reginParams) && !ObjectUtils.isEmpty(reginParams.getCompany()) ? reginParams.getCompany().getCompanyName() : "");
+        emergencyTaskRole.setCreateDate(new Date());
+        emergencyTaskRoleMapper.save(emergencyTaskRole);
+        return CommonResponseUtil2.success();
+    }
+
+    /**
+     * 修改数字预案
+     */
+    @Permission
+    @ApiOperation(value = "编辑", notes = "编辑")
+    @PutMapping(value = "/update", produces = "application/json;charset=UTF-8")
+    public ResponseModel update(@RequestBody EmergencyTaskRole emergencyTaskRole) {
+        if (null == emergencyTaskRole) {
+            return CommonResponseUtil2.failure("参数有误");
+        }
+        emergencyTaskRoleMapper.updateById(emergencyTaskRole);
+        return CommonResponseUtil2.success();
+    }
+
+
+    @Permission
+    @ApiOperation(value = "详情", notes = "详情")
+    @GetMapping(value = "/getById", produces = "application/json;charset=UTF-8")
+    public ResponseModel getById(@RequestParam(value = "id") Long id) {
+        EmergencyTaskRole emergencyTaskRole = emergencyTaskRoleMapper.selectById(id);
+        return CommonResponseUtil2.success(emergencyTaskRole);
+    }
+
+    @Permission
+    @ApiOperation(value = "根据角色编码查信息", notes = "根据角色编码查信息")
+    @GetMapping(value = "/getByCode", produces = "application/json;charset=UTF-8")
+    public ResponseModel getByCode(@RequestParam(value = "code") String code) {
+        EmergencyTaskRole emergencyTaskRole = emergencyTaskRoleMapper.selectByCode(code);
+        return CommonResponseUtil2.success(emergencyTaskRole);
+    }
+
+    @Permission
+    @ApiOperation(value = "分页查询", notes = "分页查询")
+    @PostMapping(value = "/getInfoByPage")
+    public ResponseModel<Page<EmergencyTaskRole>> getInfoByPage(@RequestBody EmergencyTaskRole emergencyTaskRole,
+                                                                @RequestParam Integer pageNum,
+                                                                @RequestParam Integer size) {
+        Page<EmergencyTaskRole> emergencyTaskRolePage = new Page<>(pageNum, size);
+        int infoCount = emergencyTaskRoleMapper.getInfoCount(emergencyTaskRole);
+        emergencyTaskRolePage.setTotal(infoCount);
+        List<EmergencyTaskRole> infoByPage = emergencyTaskRoleMapper.getInfoByPage((pageNum - 1) * size, size, emergencyTaskRole);
+        emergencyTaskRolePage.setRecords(infoByPage);
+        return CommonResponseUtil2.success(emergencyTaskRolePage);
+    }
+
+
+    @Permission
+    @ApiOperation(value = "根据ID删除数据", notes = "根据ID删除数据")
+    @DeleteMapping(value = "/deleteById", produces = "application/json;charset=UTF-8")
+    public ResponseModel deleteById(@RequestParam(value = "id") Long id) {
+        int total = emergencyTaskMapper.getEmergencyTaskCount(id, null);
+        if (total > 0) {
+            return CommonResponseUtil2.failure("已有应急任务，不能删除！");
+        }
+        emergencyTaskRoleMapper.deleteRelationByRoleId(id);
+        emergencyTaskRoleMapper.deleteById(id);
+        return CommonResponseUtil2.success();
+    }
+
+    @Permission
+    @ApiOperation(value = "下拉列表", notes = "下拉列表")
+    @GetMapping(value = "/getList")
+    public ResponseModel<List<EmergencyTaskRole>> getList() {
+        List<EmergencyTaskRole> emergencyTaskRoles = emergencyTaskRoleMapper.selectList();
+        return CommonResponseUtil2.success(emergencyTaskRoles);
+    }
+}

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

@@ -69,6 +69,8 @@ public class LoginController {
     @Value("${amos.system.user.app-key}")
     private String appKey;
 
+    private String aProduct = "AMOS_STUDIO_WEB";
+
 
 
     @ApiOperation(value = "通过userId登录", notes = "查询设备指标")
@@ -81,14 +83,14 @@ public class LoginController {
         HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder
                 .getRequestAttributes()).getRequest();
         String token = "szhlz";
-        		//ObjectUtils.isEmpty(request.getHeader("token"))?"szhlz":request.getHeader("token").toString() ;
+        //ObjectUtils.isEmpty(request.getHeader("token"))?"szhlz":request.getHeader("token").toString() ;
         ReginParams reginParams;
         reginParams = JSON.parseObject(redisTemplate.opsForValue().get(buildKey(userId, token)), ReginParams.class);
         if(reginParams == null){
-        	reginParams = getLogin(userId, token);
+            reginParams = getLogin(userId, token);
         }else{
-        	RequestContext.setProduct(product);
-            String cacheKey = Redis.genKey(new String[]{CacheType.ERASABLE.name(), "SESSION_TOKEN", RequestContext.getProduct(), reginParams.getToken()});
+            RequestContext.setProduct(product);
+            String cacheKey = Redis.genKey(new String[]{CacheType.ERASABLE.name(), "SESSION_TOKEN", aProduct, reginParams.getToken()});
             boolean hasKey = Redis.getRedisTemplate().hasKey(cacheKey);
             if (hasKey) {
                 return reginParams;
@@ -99,21 +101,21 @@ public class LoginController {
         }
         return reginParams;
     }
-    
-
-	private   ReginParams getLogin(String userId, String token) throws Exception{
-		 ReginParams reginParams = new ReginParams();
-		 IdPasswordAuthModel  dPasswordAuthModel = new IdPasswordAuthModel();
-         dPasswordAuthModel.setLoginId(userId);
-         dPasswordAuthModel.setPassword(DesUtil.encode(password, "qaz"));
-         RequestContext.setProduct(product);
- 		FeignClientResult feignClientResult = Privilege.authClient.idpassword(dPasswordAuthModel);
-         if (ObjectUtils.isEmpty(feignClientResult.getResult())){
-             throw new Exception("缺失登录信息");
-         }
-         // 调用平台授权接口
-         Map<String ,String > re = (Map<String, String>) feignClientResult.getResult();
-         String amosToken = re.get("token");
+
+
+    private   ReginParams getLogin(String userId, String token) throws Exception{
+        ReginParams reginParams = new ReginParams();
+        IdPasswordAuthModel  dPasswordAuthModel = new IdPasswordAuthModel();
+        dPasswordAuthModel.setLoginId(userId);
+        dPasswordAuthModel.setPassword(DesUtil.encode(password, "qaz"));
+        RequestContext.setProduct(product);
+        FeignClientResult feignClientResult = Privilege.authClient.idpassword(dPasswordAuthModel);
+        if (ObjectUtils.isEmpty(feignClientResult.getResult())){
+            throw new Exception("缺失登录信息");
+        }
+        // 调用平台授权接口
+        Map<String ,String > re = (Map<String, String>) feignClientResult.getResult();
+        String amosToken = re.get("token");
 
         logger.info("应用授权开始======================================"+amosToken);
         RequestContext.setToken(amosToken);
@@ -125,23 +127,23 @@ public class LoginController {
 
         logger.info("应用授权结束======================================"+JSON.toJSONString(fd)+amosToken);
 
-         AgencyUserModel userModel  =  (AgencyUserModel) Privilege.agencyUserClient.getme().getResult();
-         CompanyModel companyModel = userModel.getCompanys().get(0);
-         List<DepartmentModel> deptList = remoteSecurityService.getDepartmentTreeByCompanyId(amosToken, product, appKey, companyModel.getSequenceNbr().toString());
-         if(deptList.size() > 0){
-             CompanyBo companyBo = convertCompanyModelToBo(companyModel);
-             DepartmentBo departmentBo = convertDepartmentModelToBo(deptList.get(0));
-             reginParams.setDepartment(departmentBo);
-             reginParams.setCompany(companyBo);
-         }
-         reginParams.setToken(amosToken);
-         reginParams.setUserModel(userModel);
-         redisTemplate.opsForValue().set(buildKey(userId, token), JSONObject.toJSONString(reginParams),28, TimeUnit.DAYS);
-         // redisTemplate.opsForValue().set(buildKey(userId, amosToken), JSONObject.toJSONString(reginParams),28, TimeUnit.DAYS);
-		return reginParams;
-	}
-	
-	
+        AgencyUserModel userModel  =  (AgencyUserModel) Privilege.agencyUserClient.getme().getResult();
+        CompanyModel companyModel = userModel.getCompanys().get(0);
+        List<DepartmentModel> deptList = remoteSecurityService.getDepartmentTreeByCompanyId(amosToken, product, appKey, companyModel.getSequenceNbr().toString());
+        if(deptList.size() > 0){
+            CompanyBo companyBo = convertCompanyModelToBo(companyModel);
+            DepartmentBo departmentBo = convertDepartmentModelToBo(deptList.get(0));
+            reginParams.setDepartment(departmentBo);
+            reginParams.setCompany(companyBo);
+        }
+        reginParams.setToken(amosToken);
+        reginParams.setUserModel(userModel);
+        redisTemplate.opsForValue().set(buildKey(userId, token), JSONObject.toJSONString(reginParams),28, TimeUnit.DAYS);
+        // redisTemplate.opsForValue().set(buildKey(userId, amosToken), JSONObject.toJSONString(reginParams),28, TimeUnit.DAYS);
+        return reginParams;
+    }
+
+
     private DepartmentBo convertDepartmentModelToBo(DepartmentModel departmentModel){
         DepartmentBo departmentBo = new DepartmentBo();
         if(departmentModel != null) {

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

@@ -5,6 +5,7 @@ import com.yeejoin.amos.fas.business.vo.PlanClassifyTreeVo;
 import com.yeejoin.amos.fas.business.vo.ReginParams;
 import com.yeejoin.amos.fas.core.util.CommonResponseUtil2;
 import com.yeejoin.amos.fas.core.util.ResponseModel;
+import com.yeejoin.amos.fas.dao.entity.EmergencyRelationTree;
 import com.yeejoin.amos.fas.dao.entity.PlanClassifyTree;
 import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
 import io.swagger.annotations.Api;
@@ -12,7 +13,10 @@ import io.swagger.annotations.ApiOperation;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
+import java.util.ArrayList;
 import java.util.Collection;
+import java.util.List;
+import java.util.UUID;
 
 @RestController
 @RequestMapping("/api/planClassifyTree")
@@ -30,6 +34,7 @@ public class PlanClassifyTreeController extends BaseController {
 		String compCode = getOrgCode(reginParams);
 		model.setOrgCode(compCode);
 		model.setCreator(user.getUserId());
+		model.setPlanType(UUID.randomUUID().toString());
 		return CommonResponseUtil2.success(planClassifyTreeService.create(model));
 	}
 
@@ -62,4 +67,31 @@ public class PlanClassifyTreeController extends BaseController {
 		}
 		return CommonResponseUtil2.success(list);
 	}
+
+	@ApiOperation(value = "查询分类树 - 新页面使用")
+	@RequestMapping(value = "/treeNew", method = RequestMethod.GET)
+	public ResponseModel getTreeNew() {
+		Collection<PlanClassifyTreeVo>  list = null;
+		try {
+			list = planClassifyTreeService.getTree();
+		}catch (Exception e){
+			e.printStackTrace();
+			System.out.println(e.getStackTrace().toString());
+		}
+		//增加根节点
+		PlanClassifyTreeVo tree = new PlanClassifyTreeVo();
+		tree.setId(0);
+		tree.setClassifyName("全部");
+		tree.setPlanType("0");
+		tree.setChildren(list);
+		List<PlanClassifyTreeVo> root = new ArrayList<>();
+		root.add(tree);
+		return CommonResponseUtil2.success(root);
+	}
+
+	@ApiOperation(value = "查询分类信息 - 新页面使用")
+	@RequestMapping(value = "/getPlanClassifyInfo", method = RequestMethod.GET)
+	public ResponseModel getPlanClassifyInfo() {
+		return CommonResponseUtil2.success(planClassifyTreeService.findAllInfo());
+	}
 }

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

@@ -10,7 +10,9 @@ import com.yeejoin.amos.fas.core.util.CommonResponse;
 import com.yeejoin.amos.fas.core.util.CommonResponseUtil;
 import com.yeejoin.amos.fas.core.util.CommonResponseUtil2;
 import com.yeejoin.amos.fas.core.util.ResponseModel;
+import com.yeejoin.amos.fas.dao.dto.PlanStepJsonVO;
 import com.yeejoin.amos.fas.dao.entity.ContingencyPlanInstance;
+import com.yeejoin.amos.fas.dao.entity.PlanStepTree;
 import com.yeejoin.amos.fas.dao.entity.TextPlan;
 import com.yeejoin.amos.fas.exception.YeeException;
 import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
@@ -30,6 +32,7 @@ import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
 import java.io.*;
 import java.util.*;
+import java.util.stream.Collectors;
 
 @RestController
 @RequestMapping(value = "/api/visual")
@@ -165,6 +168,30 @@ public class PlanVisual3dController extends BaseController {
     }
 
     @Permission
+    @ApiOperation(value = "根据批次号获取预案的步骤", notes = "根据批次号获取预案的步骤")
+    @GetMapping(value = "/plan/step/tree")
+    public ResponseModel getPlanStepTree(@RequestParam(value = "batchNo", required = false) String batchNo) {
+        if (StringUtils.isEmpty(batchNo)) {
+            batchNo = planVisual3dService.getNewestBatchNo();
+        }
+        List<PlanStepTree> root = new ArrayList<>();
+        List<PlanStepJsonVO> list = planVisual3dService.getPlanStepList(batchNo);
+        list.stream().map(x -> {x.setIndex(x.getIndex() + 1); return x;}).collect(Collectors.toList());
+        //增加根节点
+        PlanStepTree tree = new PlanStepTree();
+        tree.setId(0);
+        tree.setIndex(0);
+        tree.setSequenceNbr("0");
+        tree.setName("全部");
+        tree.setStepName("全部");
+        tree.setType("3");
+        tree.setCode("0");
+        tree.setChildren(list);
+        root.add(tree);
+        return CommonResponseUtil.successNew(root);
+    }
+
+    @Permission
     @ApiOperation(value = "根据批次号更新预案的步骤", notes = "根据批次号更新预案的步骤")
     @PostMapping(value = "/plan/updatePlanStep")
     public ResponseModel updatePlanStep(@RequestBody PlanStepVo planStepVo) {

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/dao/mapper/ContingencyInstanceInfoMapper.java

@@ -38,8 +38,8 @@ public interface ContingencyInstanceInfoMapper extends BaseMapper<ContingencyIns
 
     List<ContingencyPlanInstanceVO> getTaskActionList(@Param("type") String type, @Param("status") String status, @Param("batchNo") String batchNo);
 
-    int countTaskPage(@Param("type") String type, @Param("batchNo") String batchNo, @Param("list") List<String> roles);
+    int countTaskPage(@Param("type") String type, @Param("batchNo") String batchNo, @Param("list") List<String> roles, @Param("steps") List<String> steps);
 
-    List<ContingencyPlanInstanceVO> getTaskActionPage(@Param("current") int current, @Param("size") int size, @Param("batchNo") String batchNo, @Param("type") String type, @Param("runState") String runState, @Param("updateDate") String updateDate, @Param("list") List<String> roles);
+    List<ContingencyPlanInstanceVO> getTaskActionPage(@Param("current") int current, @Param("size") int size, @Param("batchNo") String batchNo, @Param("type") String type, @Param("runState") String runState, @Param("updateDate") String updateDate, @Param("list") List<String> roles, @Param("steps") List<String> steps);
 
 }

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/dao/mapper/EmergencyTaskMapper.java

@@ -9,23 +9,29 @@ import org.apache.ibatis.annotations.Param;
 import java.util.List;
 
 public interface EmergencyTaskMapper extends BaseMapper {
-    List<EmergencyTaskContent> getEmergencyTaskList(Long obligationId,Long  offset,int pageSize);
-    int getEmergencyTaskCount(Long obligationId);
+    List<EmergencyTaskContent> getEmergencyTaskList(@Param("obligationId") Long obligationId, @Param("offset")Long  offset,  @Param("pageSize")int pageSize, @Param("planType") String planType);
+    int getEmergencyTaskCount(@Param("obligationId") Long obligationId, @Param("planType") String planType);
 
     List<EmergencyRelationTree> treeList();
 
     void deleteTreeNode(Long obligationId , Long personId);
 
+
+    void deleteTask(@Param("id") Long id);
+
+
     void save(EmergencyRelation emergencyRelation);
 
+    void saveTaskConfig(EmergencyTaskContent emergencyTaskContent);
+
     List<String> roleCodes(String amosOrgId);
 
     List<Long> getPersonIds(Long obligationId);
 
     List<String> roleNames(String amosOrgId);
 
-    List<EmergencyTaskContentVo> getContentList(@Param("stepCode") String stepCode);
+    List<EmergencyTaskContentVo> getContentList(@Param("stepCode") String stepCode, @Param("planType") String planType);
 
-    List<EmergencyTaskContentVo> getMustTaskList(@Param("stepCode") String stepCode);
+    List<EmergencyTaskContentVo> getMustTaskList(@Param("stepCode") String stepCode, @Param("planType") String planType);
 
 }

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/dao/mapper/EmergencyTaskRoleMapper.java

+package com.yeejoin.amos.fas.business.dao.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.yeejoin.amos.fas.dao.entity.EmergencyTaskRole;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+@Mapper
+public interface EmergencyTaskRoleMapper extends BaseMapper<EmergencyTaskRole> {
+
+    void save(EmergencyTaskRole emergencyTaskRole);
+
+    int countByCode(String code);
+
+    int updateById(EmergencyTaskRole emergencyTaskRole);
+
+    EmergencyTaskRole selectById(Long id);
+
+    int getInfoCount(EmergencyTaskRole emergencyTaskRole);
+
+    List<EmergencyTaskRole> getInfoByPage(Integer pageNum,
+                                          Integer size,
+                                          EmergencyTaskRole emergencyTaskRole);
+
+    int deleteById(Long id);
+
+    int deleteRelationByRoleId(Long roleId);
+
+    EmergencyTaskRole selectByCode(String code);
+
+    List<EmergencyTaskRole> selectList();
+
+    List<EmergencyTaskRole> selectListFilterEmptyTask();
+
+    String getPlanStepInfoByType(@Param("planType") String planType);
+}

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/dao/mapper/PlanDetailMapper.java

@@ -57,4 +57,6 @@ public interface PlanDetailMapper {
     
 
 	String queryBatchNoByFireEquipmentId(@Param("fireEquipmentId") String fireEquipmentId);
+
+    PlanDetailVo getPlanDetailById(@Param("id") String id);
 }

YeeAmosFireAutoSysService/src/main/java/com/yeejoin/amos/fas/business/dao/repository/EmergencyTaskRoleDao.java

+package com.yeejoin.amos.fas.business.dao.repository;
+
+import com.yeejoin.amos.fas.dao.entity.EmergencyTaskRole;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface EmergencyTaskRoleDao extends BaseDao<EmergencyTaskRole, Long> {
+}

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

@@ -455,12 +455,19 @@ public class ContingencyInstanceImpl implements IContingencyInstance {
 
     @Override
     public Optional<Equipment> clickButton(String batchNo, String stepCode, String buttonJson, String contingencyPlanId, String buttonCode, String buttonState, String stepStateOnbutton, String isExecute, String isAuto, String token, String product, String appKey,String startUserName) throws Exception {
-        if ("0".equals(stepCode)) {
+        String planType = null;
+        if (redisTemplate.hasKey("planType")) {
+            planType = redisTemplate.boundValueOps("planType").get(0, -1);
+        }
+        // 此处逻辑修改为所有任务执行完成才会点亮节点
+        List<EmergencyTaskContentVo> tasks = emergencyTaskService.getMustTaskList(stepCode, planType);
+        boolean flag = judgeIfConfirmed(tasks, batchNo);
+
+        if ("0".equals(stepCode) && flag) {
             contingencyInstance.fire(batchNo, stepCode, buttonJson, contingencyPlanId,
                     "FIRE_CONFIRM", buttonState, stepStateOnbutton, "true", "false", token,
                     product, appKey, startUserName);
         }
-
         ContingencyPlanInstance instance = contingencyPlanInstanceMapper.getMessageById(contingencyPlanId);
         instance.setId(null);
         instance.setRecordType("REPLYMESSAGE");
@@ -468,8 +475,6 @@ public class ContingencyInstanceImpl implements IContingencyInstance {
         instance.setContent(instance.getCategory());
         ContingencyPlanInstance res = repository.save(instance);
         if (!ObjectUtils.isEmpty(res)) {
-            List<EmergencyTaskContentVo> mustTasks = emergencyTaskService.getMustTaskList(stepCode);
-            boolean flag = judgeIfConfirmed(mustTasks, batchNo);
             if (!"-1".equals(stepCode) && flag) {
                 PlanExecuteVo vo = new PlanExecuteVo();
                 vo.setConfirm(buttonState);
@@ -532,17 +537,16 @@ public class ContingencyInstanceImpl implements IContingencyInstance {
         return Optional.empty();
     }
 
-    private boolean judgeIfConfirmed(List<EmergencyTaskContentVo> mustTasks, String batchNo) {
-        if (0 == mustTasks.size()) {
-            return true;
-        }
-        EmergencyTaskContentVo vo = mustTasks.get(0);
-        Integer count = contingencyPlanInstanceMapper.getPlanInstanceByRunState(vo.getStepCode(), batchNo);
-        if (0 == count) {
-            return true;
-        } else {
-            return false;
+    private boolean judgeIfConfirmed(List<EmergencyTaskContentVo> tasks, String batchNo) {
+        boolean flag = Boolean.TRUE;
+        if (!CollectionUtils.isEmpty(tasks)) {
+            EmergencyTaskContentVo contentVo = tasks.get(0);
+            Integer count = contingencyPlanInstanceMapper.getPlanInstanceByRunState(contentVo.getStepCode(), batchNo);
+            if (0 != count) {
+                flag = Boolean.FALSE;
+            }
         }
+        return flag;
     }
 
     @Autowired

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

@@ -13,10 +13,7 @@ import com.yeejoin.amos.fas.business.param.AlarmParam;
 import com.yeejoin.amos.fas.business.service.intfc.*;
 import com.yeejoin.amos.fas.business.util.TreeUtil;
 import com.yeejoin.amos.fas.business.vo.*;
-import com.yeejoin.amos.fas.common.enums.ContingencyPlanStatusEnum;
-import com.yeejoin.amos.fas.common.enums.EquipmentRiskTypeEnum;
-import com.yeejoin.amos.fas.common.enums.ExecutionTypeEnum;
-import com.yeejoin.amos.fas.common.enums.PlanRecordStatusEnum;
+import com.yeejoin.amos.fas.common.enums.*;
 import com.yeejoin.amos.fas.core.enums.NumberEnum;
 import com.yeejoin.amos.fas.core.enums.ReserveEnum;
 import com.yeejoin.amos.fas.core.util.DateUtil;
@@ -25,6 +22,7 @@ import com.yeejoin.amos.fas.datasync.bo.PlanDetailSyncBo;
 import com.yeejoin.amos.fas.datasync.bo.PlanOperationRecordSyncBo;
 import com.yeejoin.amos.fas.exception.YeeException;
 import com.yeejoin.amos.feign.privilege.model.RoleModel;
+import org.apache.commons.io.IOUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
@@ -46,6 +44,7 @@ import org.typroject.tyboot.component.emq.EmqxListener;
 import org.typroject.tyboot.core.foundation.utils.Bean;
 import org.typroject.tyboot.core.foundation.utils.ValidationUtil;
 
+import java.nio.charset.StandardCharsets;
 import java.util.*;
 import java.util.concurrent.atomic.AtomicBoolean;
 
@@ -147,7 +146,13 @@ public class ContingencyPlanServiceImpl implements IContingencyPlanService {
         logger.info("========状态校验===========");
         ReserveEnum reserveEnum = this.runCheck(vo);
         result.setMessage(reserveEnum.getText());
-        planStepService.initPlanStep();
+        PlanDetailVo detailVo = planDetailMapper.getPlanDetailById(vo.getPlanId());
+        Optional<PlanClassifyTree> tree = classifyTreeDao.findById(detailVo.getClassifyId());
+        if (tree.isPresent()) {
+            PlanClassifyTree entity = tree.get();
+            redisTemplate.opsForValue().set("planType", entity.getPlanType());
+            planStepService.initPlanStep();
+        }
         if (ReserveEnum.THISRUNNING.getStatus().equals(reserveEnum.getStatus())) {
             List<PlanOperationRecord> recordList = planOperationRecordDao.findByPlanId1(Long.valueOf(vo.getPlanId()));
             result.setMessage(ReserveEnum.THISRUNNING.getText());
@@ -866,11 +871,11 @@ public class ContingencyPlanServiceImpl implements IContingencyPlanService {
     }
 
     @Override
-    public Page<ContingencyPlanInstanceVO> selectTaskActionPage(int current, int size, String batchNo, String runState, String updateDate, List<String> roleList) {
+    public Page<ContingencyPlanInstanceVO> selectTaskActionPage(int current, int size, String batchNo, String runState, String updateDate, List<String> roleList, List<String> steps) {
         String type = "TASKOPERATE";
         Page<ContingencyPlanInstanceVO> page = new Page<>(current, size);
         int total = 0;
-        total = contingencyInstanceInfoMapper.countTaskPage(type, batchNo, roleList);
+        total = contingencyInstanceInfoMapper.countTaskPage(type, batchNo, roleList, steps);
         long start = (page.getCurrent() - 1) * page.getSize();
         if (total == 0) {
             page.setCurrent(1);
@@ -879,7 +884,7 @@ public class ContingencyPlanServiceImpl implements IContingencyPlanService {
                 page.setCurrent(1);
                 start = 0;
             }
-            List<ContingencyPlanInstanceVO> list = contingencyInstanceInfoMapper.getTaskActionPage((int) start, size, batchNo, type, runState, updateDate, roleList);
+            List<ContingencyPlanInstanceVO> list = contingencyInstanceInfoMapper.getTaskActionPage((int) start, size, batchNo, type, runState, updateDate, roleList, steps);
             list.stream().forEach(e->{
                 if(ObjectUtils.isEmpty(e.getCreateUser())) {
                     List<String> userName = planVisual3dService.getUserName(e.getRoleCode());

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

+package com.yeejoin.amos.fas.business.service.impl;
+
+import com.yeejoin.amos.fas.business.service.intfc.IEmergencyTaskRoleService;
+import com.yeejoin.amos.fas.business.vo.PlanDetailVo;
+import com.yeejoin.amos.fas.common.enums.ContingencyPlanStatusEnum;
+import com.yeejoin.amos.fas.dao.entity.*;
+import com.yeejoin.amos.fas.exception.YeeException;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.BeanUtils;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+public class EmergencyTaskRoleServiceImpl implements IEmergencyTaskRoleService {
+
+}

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

@@ -5,6 +5,7 @@ import com.alibaba.fastjson.JSONArray;
 import com.yeejoin.amos.fas.business.action.model.ContingencyRo;
 import com.yeejoin.amos.fas.business.action.mq.WebMqttComponent;
 import com.yeejoin.amos.fas.business.dao.mapper.EmergencyTaskMapper;
+import com.yeejoin.amos.fas.business.dao.mapper.EmergencyTaskRoleMapper;
 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.IPlanOperationRecordDao;
@@ -17,10 +18,7 @@ import com.yeejoin.amos.fas.business.vo.EmergencyTaskContentVo;
 import com.yeejoin.amos.fas.business.vo.MessageVO;
 import com.yeejoin.amos.fas.core.common.request.CommonPageable;
 import com.yeejoin.amos.fas.core.util.StringUtil;
-import com.yeejoin.amos.fas.dao.entity.ContingencyPlanInstance;
-import com.yeejoin.amos.fas.dao.entity.EmergencyRelation;
-import com.yeejoin.amos.fas.dao.entity.EmergencyRelationTree;
-import com.yeejoin.amos.fas.dao.entity.EmergencyTaskContent;
+import com.yeejoin.amos.fas.dao.entity.*;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.commons.lang3.time.DateFormatUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -67,23 +65,29 @@ public class EmergencyTaskServiceImpl implements IEmergencyTaskService {
     @Autowired
     private PlanOperationRecordMapper planOperationRecordMapper;
 
+    @Autowired
+    private EmergencyTaskRoleMapper emergencyTaskRoleMapper;
+
     @Value("${spring.application.name}")
     private String serviceName;
 
     @Value("${station.name}")
     private String stationName;
 
+    String taskJson = "{\"type\":\"button\",\"operate\":[{\"code\":\"STOP_OIL_CONSERVATOR_DRAIN\",\"icon\":\"yellow\",\"state\":\"wait\",\"title\":\"已执行\",\"confirm\":false,\"content\":\"_content\",\"delayed\":[0],\"stepState\":\"A\",\"requestUrl\":\"/fireAutoSys/api/timeline/click\"}],\"stepCode\":\"_stepCode\"}";
+
     @Override
-    public Page<EmergencyTaskContent> list(Long obligationId, CommonPageable pageable) {
-        int total = emergencyTaskMapper.getEmergencyTaskCount(obligationId);
-        List<EmergencyTaskContent> emergencyTaskList = emergencyTaskMapper.getEmergencyTaskList(obligationId, pageable.getOffset(), pageable.getPageSize());
-        Page<EmergencyTaskContent> result = new PageImpl<>(emergencyTaskList, pageable, total);
+    public Page<EmergencyTaskContent> list(Long obligationId, String planType, CommonPageable pageable) {
+        int total = emergencyTaskMapper.getEmergencyTaskCount(obligationId, planType);
+        List<EmergencyTaskContent> emergencyTaskList = emergencyTaskMapper.getEmergencyTaskList(obligationId, pageable.getOffset(), pageable.getPageSize(), planType);
+        org.springframework.data.domain.Page<EmergencyTaskContent> result = new PageImpl<>(emergencyTaskList, pageable, total);
         return result;
 
     }
 
     @Override
     public List<EmergencyRelationTree> treeList() {
+
         return emergencyTaskMapper.treeList();
     }
 
@@ -98,6 +102,26 @@ public class EmergencyTaskServiceImpl implements IEmergencyTaskService {
     }
 
     @Override
+    public void saveTaskConfig(EmergencyTaskContent emergencyTaskContent) {
+            List<String> roleList = emergencyTaskContent.getRoleCodeList();
+        for (String role : roleList
+             ) {
+            String json = taskJson.replace("_content", emergencyTaskContent.getContent()).replace("_stepCode", emergencyTaskContent.getStepCode());
+            emergencyTaskContent.setButtonJson(json);
+            EmergencyTaskRole emergencyTaskRole = emergencyTaskRoleMapper.selectById(Long.valueOf(role));
+            emergencyTaskContent.setRoleCode(emergencyTaskRole.getCode());
+            emergencyTaskContent.setObligationName(emergencyTaskRole.getName());
+            if("1".equals(emergencyTaskContent.getIsMustString())) {
+                emergencyTaskContent.setMust(true);
+            } else {
+                emergencyTaskContent.setMust(false);
+            }
+            emergencyTaskContent.setObligationId(emergencyTaskRole.getId());
+            emergencyTaskMapper.saveTaskConfig(emergencyTaskContent);
+        }
+    }
+
+    @Override
     public String getRolesByUserId(String userId) {
         List<String> list = emergencyTaskMapper.roleCodes(userId);
         String roleCodes = String.join(",", list);
@@ -120,7 +144,11 @@ public class EmergencyTaskServiceImpl implements IEmergencyTaskService {
     @Transactional
     @Override
     public void saveTask(String stepCode, String batchId) {
-        List<EmergencyTaskContentVo> list = emergencyTaskMapper.getContentList(stepCode);
+        String planType = null;
+        if (redisTemplate.hasKey("planType")) {
+            planType = redisTemplate.boundValueOps("planType").get(0, -1);
+        }
+        List<EmergencyTaskContentVo> list = emergencyTaskMapper.getContentList(stepCode, planType);
         if (0 < list.size()) {
             String batchNo = StringUtil.isNotEmpty(batchId) ? batchId : planOperationRecordMapper.getLastBatchNo();
             if (!findByBatchNoAndStatus(batchNo)) {
@@ -142,7 +170,7 @@ public class EmergencyTaskServiceImpl implements IEmergencyTaskService {
                     contingencyPlanInstance.setTaskSort(taskNum);
                     contingencyPlanInstance.setStepCode(stepCode);
                     contingencyPlanInstance.setContent(buttonJson);
-                    contingencyPlanInstanceRepository.save(contingencyPlanInstance);
+                    contingencyPlanInstanceRepository.saveAndFlush(contingencyPlanInstance);
 
                     if ("0".equals(stepCode)) {
                         TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
@@ -194,7 +222,7 @@ public class EmergencyTaskServiceImpl implements IEmergencyTaskService {
     }
 
     @Override
-    public List<EmergencyTaskContentVo> getMustTaskList(String stepCode) {
-        return emergencyTaskMapper.getMustTaskList(stepCode);
+    public List<EmergencyTaskContentVo> getMustTaskList(String stepCode, String planType) {
+        return emergencyTaskMapper.getMustTaskList(stepCode, planType);
     }
 }

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

@@ -2,36 +2,28 @@ package com.yeejoin.amos.fas.business.service.impl;
 
 
 import com.alibaba.fastjson.JSONObject;
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
-import com.yeejoin.amos.fas.business.dao.mapper.EquipmentSpecificIndexMapper;
-import com.yeejoin.amos.fas.business.dao.mapper.EquipmentSpecificMapper;
-import com.yeejoin.amos.fas.business.dao.mapper.PlanMessageMapper;
-import com.yeejoin.amos.fas.business.dao.mapper.PlanOperationRecordMapper;
+import com.yeejoin.amos.fas.business.dao.mapper.*;
 import com.yeejoin.amos.fas.business.dao.repository.IEquipmentDao;
 import com.yeejoin.amos.fas.business.dao.repository.IEquipmentFireEquipmentDao;
 import com.yeejoin.amos.fas.business.dao.repository.IPlanMessageDao;
 import com.yeejoin.amos.fas.business.service.intfc.EquipmentSpecificIndexService;
 import com.yeejoin.amos.fas.business.service.intfc.IEquipmentFireEquipmentService;
+import com.yeejoin.amos.fas.business.service.intfc.IPlanStepService;
 import com.yeejoin.amos.fas.business.vo.ConditionVO;
 import com.yeejoin.amos.fas.business.vo.PlanStepJsonVO;
 import com.yeejoin.amos.fas.common.enums.SqlKeyWordEnum;
-import com.yeejoin.amos.fas.dao.entity.Equipment;
 import com.yeejoin.amos.fas.dao.entity.EquipmentFireEquipment;
 import com.yeejoin.amos.fas.dao.entity.PlanMessage;
-import org.apache.commons.io.IOUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.core.io.Resource;
+
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 import org.springframework.util.ObjectUtils;
 import org.typroject.tyboot.core.foundation.utils.Bean;
 
-import java.io.IOException;
-import java.nio.charset.StandardCharsets;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
@@ -86,10 +78,8 @@ public class EquipmentFireEquipmentServiceImpl implements IEquipmentFireEquipmen
     EquipmentSpecificIndexMapper equipmentSpecificIndexMapper;
 
     @Autowired
-    private EquipmentSpecificMapper equipmentSpecificMapper;
+    private IPlanStepService iPlanStepService;
 
-    @Value("classpath:/json/plan-step.json")
-    private Resource planStepResource;
 
     @Override
     public List<EquipmentFireEquipment> findByEquipmentId(Long equipmentId) {
@@ -178,13 +168,8 @@ public class EquipmentFireEquipmentServiceImpl implements IEquipmentFireEquipmen
         if (ObjectUtils.isEmpty(index)) {
             return false;
         }
-        String json;
-        try {
-            json = IOUtils.toString(planStepResource.getInputStream(), String.valueOf(StandardCharsets.UTF_8));
-        } catch (IOException e) {
-            throw new RuntimeException("获取预案节点信息失败！");
-        }
-        List<PlanStepJsonVO> result = JSONObject.parseArray(json, PlanStepJsonVO.class);
+        String planStep = iPlanStepService.getPlanStep();
+        List<PlanStepJsonVO> result = JSONObject.parseArray(planStep, PlanStepJsonVO.class);
         if (!CollectionUtils.isEmpty(result)) {
             // 获取电力设备id及batchNo
             Map<String, Object> map = planOperationRecordMapper.getLatestFireEquipId();

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

@@ -25,9 +25,11 @@ import com.yeejoin.amos.fas.business.util.RpnUtils;
 import com.yeejoin.amos.fas.business.vo.*;
 import com.yeejoin.amos.fas.client.invoke.RsDataQueue;
 import com.yeejoin.amos.fas.common.enums.EquipmentRiskTypeEnum;
+import com.yeejoin.amos.fas.common.enums.PlanTypeEnum;
 import com.yeejoin.amos.fas.core.util.StringUtil;
 import com.yeejoin.amos.fas.dao.entity.*;
 import com.yeejoin.amos.fas.datasync.bo.ContingencyOriginalDataSyncBo;
+import org.apache.commons.io.IOUtils;
 import org.apache.commons.lang3.ArrayUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -44,6 +46,7 @@ import org.typroject.tyboot.core.foundation.context.RequestContext;
 
 import java.awt.*;
 import java.math.BigDecimal;
+import java.nio.charset.StandardCharsets;
 import java.text.SimpleDateFormat;
 import java.util.*;
 import java.util.List;
@@ -79,10 +82,16 @@ public class HandlerMqttMessageImpl implements IEquipmentHandlerService {
 
     @Value("${integrated3Dtype}")
     private String integrated3Dtype;
-    
+
     @Value("${plan.dynamic.execut.topic}")
     private String planDynamicExecutTopic;
 
+    @Value("${plan.dynamic.execut.zb.topic}")
+    private String planDynamicExecutZBTopic;
+
+    @Value("${plan.dynamic.execut.gk.topic}")
+    private String planDynamicExecutGKTopic;
+
     @Autowired
     private WebMqttComponent webMqttComponent;
 
@@ -142,7 +151,7 @@ public class HandlerMqttMessageImpl implements IEquipmentHandlerService {
 
     @Value("${autoSys.fire.pool.index_key}")
     private String firePoolIndexKey;
-    
+
     @Value("${plan.index}")
     private String planIndex;
 
@@ -197,16 +206,16 @@ public class HandlerMqttMessageImpl implements IEquipmentHandlerService {
         if ("false".equals(topicEntity.getSimulationDate()) && nameKeys.contains(typeCode) && indexStateIsChange(equipmentSpecificIndex)) {
             log.info("指标值没有发生变化： " + equipmentSpecificIndex.getIotCode() + "-" + equipmentSpecificIndex.getNameKey() + ":" + equipmentSpecificIndex.getValue());
             //  三维屏指标状态推送,没有绑定模型的设备不需要推送至三维
-            if("true".equals(equipmentSpecific.getPush3D())){
-            	equipmentSpecificIndex.setId(equipmentSpecific.getId());
+            if ("true".equals(equipmentSpecific.getPush3D())) {
+                equipmentSpecificIndex.setId(equipmentSpecific.getId());
                 equipmentSpecificIndex.setName(equipmentSpecific.getName());
                 equipmentSpecificIndex.setCode(equipmentSpecific.getCode());
                 equipmentSpecificIndex.setType("equip");
                 String msg = JSON.toJSONString(equipmentSpecificIndex);
                 String title = String.format("/%s/%s", serviceName, "data/refresh/indexStatus");
                 webMqttComponent.publish(title, msg);
-             }
-            
+            }
+
         }
 
         Equipment equipment = topicEntity.getEquipment() == null ? impAndFireEquipMapper.queryImpEqumtByFireEquipmt(eqSpecId) : topicEntity.getEquipment();
@@ -266,7 +275,7 @@ public class HandlerMqttMessageImpl implements IEquipmentHandlerService {
             refreshFireSafety(equipmentSpecific.getOrgCode());
             String monitorData = String.format("/%s/%s/%s", serviceName, stationName, "data/refresh/monitorData");
             webMqttComponent.publish(monitorData, JSON.toJSONString(view3dService.getEquipStatusList(equipmentSpecific.getOrgCode())));
-        
+
         } else {
             // 监测数据逻辑
             log.info("(监测)Message type is: " + specificIndexType);
@@ -283,36 +292,46 @@ public class HandlerMqttMessageImpl implements IEquipmentHandlerService {
             webMqttComponent.publish(title, JSON.toJSONString(view3dService.getEquipStatusList(equipmentSpecific.getOrgCode())));
         }
         //根据指标数据处理预案按钮
-        if(planIndex.contains(nameKey) && !ObjectUtils.isEmpty(equipment)){
-	        DeviceRo deviceRo = new DeviceRo();
-	        deviceRo.setEquipmentCode(equipment.getCode());
-	        deviceRo.setEquipmentId(equipment.getId());
-	        deviceRo.setEquipmentSpecificId(equipmentSpecific.getId());
-	        deviceRo.setEquipmentSpecificCode(equipmentSpecific.getCode());
-	        deviceRo.setIotCode(equipmentSpecific.getIotCode());
-	        deviceRo.setValue(equipmentSpecificIndex.getValue());
-	        deviceRo.setEquipmentIndexKey(equipmentSpecificIndex.getNameKey());
-        	planAutoExec(equipment, toke, deviceRo);
+        if (planIndex.contains(nameKey) && !ObjectUtils.isEmpty(equipment)) {
+            DeviceRo deviceRo = new DeviceRo();
+            deviceRo.setEquipmentCode(equipment.getCode());
+            deviceRo.setEquipmentId(equipment.getId());
+            deviceRo.setEquipmentSpecificId(equipmentSpecific.getId());
+            deviceRo.setEquipmentSpecificCode(equipmentSpecific.getCode());
+            deviceRo.setIotCode(equipmentSpecific.getIotCode());
+            deviceRo.setValue(equipmentSpecificIndex.getValue());
+            deviceRo.setEquipmentIndexKey(equipmentSpecificIndex.getNameKey());
+            planAutoExec(equipment, toke, deviceRo);
         }
     }
 
     /**
      * 触发规则（用来）动态执行规则步骤
+     *
      * @param equipment
      * @param toke
      * @param deviceRo
      */
     private void planAutoExec(Equipment equipment, Toke toke, DeviceRo deviceRo) {
-    	 try {
-    		 	RequestContext.setToken(toke.getToke());
-    	        RequestContext.setProduct(toke.getProduct());
-				ruleTrigger.publish(deviceRo, planDynamicExecutTopic, new String[] {});
-			} catch (Exception e) {
-				e.printStackTrace();
-			}
-	}
-
-	@Async
+        try {
+            RequestContext.setToken(toke.getToke());
+            RequestContext.setProduct(toke.getProduct());
+            if (redisTemplate.hasKey("planType")) {
+                String planType = redisTemplate.boundValueOps("planType").get(0, -1);
+                if (PlanTypeEnum.MAINTRANSFORM.getKey().equalsIgnoreCase(planType)) {
+                    ruleTrigger.publish(deviceRo, planDynamicExecutZBTopic, new String[]{});
+                } else if (PlanTypeEnum.HIGHRESISTANCE.getKey().equalsIgnoreCase(planType)) {
+                    ruleTrigger.publish(deviceRo, planDynamicExecutGKTopic, new String[]{});
+                } else {
+                    ruleTrigger.publish(deviceRo, planDynamicExecutTopic, new String[]{});
+                }
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+
+    @Async
     public void sendWaterLevel(FormInstanceVo formInstanceVo) {
         try {
             String topic = String.format("/%s/%s/%s", serviceName, stationName, "analogue");

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

@@ -62,6 +62,7 @@ public class PlanClassifyTreeServiceImpl implements IPlanClassifyTreeService {
         for (PlanClassifyTree planClassifyTree : list) {
             PlanClassifyTreeVo planClassifyTreeVo = new PlanClassifyTreeVo();
             BeanUtils.copyProperties(planClassifyTree, planClassifyTreeVo);
+            planClassifyTreeVo.setParentId(0L);
             voList.add(planClassifyTreeVo);
         }
         Map<Object, PlanClassifyTreeVo> map = Bean.listToMap(voList, "id", PlanClassifyTree.class);
@@ -73,6 +74,11 @@ public class PlanClassifyTreeServiceImpl implements IPlanClassifyTreeService {
         return TreeBuilder.buildByRecursive(completeList, ROOT);
     }
 
+    @Override
+    public List<PlanClassifyTree> findAllInfo() {
+        return planClassifyTreeDao.findAll();
+    }
+
     private List<PlanClassifyTreeVo> buildWithParent(PlanClassifyTreeVo groupModel, Map<Object, PlanClassifyTreeVo> map) {
 
         List<PlanClassifyTreeVo> completeList = new ArrayList<>();
@@ -137,6 +143,11 @@ public class PlanClassifyTreeServiceImpl implements IPlanClassifyTreeService {
         return planClassifyTreeDao.save(model);
     }
 
+    @Override
+    public PlanClassifyTree findById(Long id) {
+        return planClassifyTreeDao.findById(id).orElse(new PlanClassifyTree());
+    }
+
     private boolean classifyNameExist(String classifyName, Long parentId) {
         return 0 < planClassifyTreeDao.countByClassifyNameAndParentId(classifyName, parentId);
     }

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

 package com.yeejoin.amos.fas.business.service.impl;
 
 import com.alibaba.fastjson.JSONObject;
+import com.yeejoin.amos.fas.business.dao.mapper.EmergencyTaskRoleMapper;
 import com.yeejoin.amos.fas.business.service.intfc.IPlanStepService;
 import com.yeejoin.amos.fas.business.vo.PlanStepJsonVO;
-import org.apache.commons.io.IOUtils;
 import org.apache.commons.lang3.StringUtils;
 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.util.CollectionUtils;
 
-import java.io.IOException;
-import java.nio.charset.StandardCharsets;
 import java.util.List;
 import java.util.stream.Collectors;
 
@@ -23,8 +19,8 @@ public class PlanStepServiceImpl implements IPlanStepService {
     @Autowired
     private RedisTemplate redisTemplate;
 
-    @Value("classpath:/json/plan-step.json")
-    private Resource planStepResource;
+    @Autowired
+    private EmergencyTaskRoleMapper emergencyTaskRoleMapper;
 
     @Override
     public String getPlanStepRoleCodeByButtonCode(String buttonCode) {
@@ -52,23 +48,26 @@ public class PlanStepServiceImpl implements IPlanStepService {
 
     @Override
     public List<PlanStepJsonVO> getPlanStepJsonVOS() {
-        String json = "";
-        try {
-            json = IOUtils.toString(planStepResource.getInputStream(), String.valueOf(StandardCharsets.UTF_8));
-        } catch (IOException e) {
-            throw new RuntimeException("获取预案相关角色信息失败！");
-        }
-        List<PlanStepJsonVO> result = JSONObject.parseArray(json, PlanStepJsonVO.class);
+        String planStepString = getPlanStep();
+        List<PlanStepJsonVO> result = JSONObject.parseArray(planStepString, PlanStepJsonVO.class);
         return result;
     }
 
     @Override
     public String getPlanStep() {
-        try {
-            return IOUtils.toString(planStepResource.getInputStream(), String.valueOf(StandardCharsets.UTF_8));
-        } catch (IOException e) {
-            throw new RuntimeException("获取预案初始化planStep信息失败！");
+        String planType = "";
+        if (redisTemplate.hasKey("planType")) {
+            planType = redisTemplate.boundValueOps("planType").get(0, -1);
         }
+        String json = emergencyTaskRoleMapper.getPlanStepInfoByType(planType);
+        return json;
+    }
+
+    @Override
+    public List<PlanStepJsonVO> getPlanStepByParam(String planType) {
+        String json = emergencyTaskRoleMapper.getPlanStepInfoByType(planType);
+        List<PlanStepJsonVO> result = JSONObject.parseArray(json, PlanStepJsonVO.class);
+        return result;
     }
 
     @Override

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

@@ -25,6 +25,7 @@ import com.yeejoin.amos.fas.core.util.CommonResponse;
 import com.yeejoin.amos.fas.core.util.CommonResponseUtil;
 import com.yeejoin.amos.fas.core.util.ResponseModel;
 import com.yeejoin.amos.fas.dao.entity.*;
+import com.yeejoin.amos.fas.dao.dto.PlanStepJsonVO;
 import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
 import com.yeejoin.amos.feign.privilege.model.RoleModel;
 import com.yeejoin.amos.feign.systemctl.Systemctl;
@@ -277,6 +278,13 @@ public class PlanVisual3dServiceImpl implements IPlanVisual3dService {
     }
 
     @Override
+    public List<PlanStepJsonVO> getPlanStepList(String batchNo) {
+        String json = planStepService.getPlanStep();
+        List<PlanStepJsonVO> res = JSONObject.parseArray(json, PlanStepJsonVO.class);
+        return res;
+    }
+
+    @Override
     public ToipResponse getPlaneRecordByBatchNo(String batchNo) {
         // 根据批次号获取预案记录
         List<Map<String, Object>> instancesList = contingencyPlanInstanceRepository.queryRecord(batchNo, "MESSAGE");

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

@@ -142,5 +142,5 @@ public interface IContingencyPlanService {
 
     String getPlanBatchNo();
 
-    Page<ContingencyPlanInstanceVO> selectTaskActionPage(int current, int size, String batchNo, String runState, String updateDate, List<String> roleList);
+    Page<ContingencyPlanInstanceVO> selectTaskActionPage(int current, int size, String batchNo, String runState, String updateDate, List<String> roleList, List<String> steps);
 }

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

+package com.yeejoin.amos.fas.business.service.intfc;
+
+import com.yeejoin.amos.fas.business.vo.PlanDetailVo;
+import com.yeejoin.amos.fas.exception.YeeException;
+import org.springframework.transaction.annotation.Transactional;
+
+public interface IEmergencyTaskRoleService {
+
+}

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

@@ -12,7 +12,7 @@ import java.util.List;
 
 public interface IEmergencyTaskService  {
 
-   Page<EmergencyTaskContent> list(Long obligationId, CommonPageable pageable);
+   Page<EmergencyTaskContent> list(Long obligationId, String planType, CommonPageable pageable);
 
    List<EmergencyRelationTree> treeList();
 
@@ -20,6 +20,8 @@ public interface IEmergencyTaskService  {
 
    void save(EmergencyRelation emergencyRelation);
 
+   void saveTaskConfig(EmergencyTaskContent emergencyTaskContent);
+
    String getRolesByUserId(String userId);
 
    List<Long> getPersonIds(Long obligationId);
@@ -28,5 +30,5 @@ public interface IEmergencyTaskService  {
 
    void saveTask(String stepCode, String batchNo);
 
-   List<EmergencyTaskContentVo> getMustTaskList(String stepCode);
+   List<EmergencyTaskContentVo> getMustTaskList(String stepCode, String planType);
 }

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

@@ -4,6 +4,7 @@ import com.yeejoin.amos.fas.business.vo.PlanClassifyTreeVo;
 import com.yeejoin.amos.fas.dao.entity.PlanClassifyTree;
 
 import java.util.Collection;
+import java.util.List;
 
 /**
  * @author wjk
@@ -28,4 +29,8 @@ public interface IPlanClassifyTreeService {
     PlanClassifyTree create(PlanClassifyTree model);
 
     PlanClassifyTree update(PlanClassifyTree model);
+
+    PlanClassifyTree findById(Long id);
+
+    List<PlanClassifyTree> findAllInfo();
 }

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

@@ -26,6 +26,8 @@ public interface IPlanStepService {
 
     String getPlanStep();
 
+    List<PlanStepJsonVO> getPlanStepByParam(String planType);
+
     void initPlanStep();
 
     void initPlanTask();

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

@@ -2,10 +2,8 @@ package com.yeejoin.amos.fas.business.service.intfc;
 
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.yeejoin.amos.fas.business.service.model.ToipResponse;
-import com.yeejoin.amos.fas.business.vo.ContingencyPlanInstanceVO;
-import com.yeejoin.amos.fas.business.vo.MessageVO;
-import com.yeejoin.amos.fas.business.vo.PlanStepVo;
-import com.yeejoin.amos.fas.business.vo.TreeSubjectVo;
+import com.yeejoin.amos.fas.business.vo.*;
+import com.yeejoin.amos.fas.dao.dto.PlanStepJsonVO;
 import com.yeejoin.amos.fas.core.util.CommonResponse;
 import com.yeejoin.amos.fas.dao.entity.ContingencyPlanInstance;
 import com.yeejoin.amos.fas.dao.entity.TextPlan;
@@ -142,4 +140,6 @@ public interface IPlanVisual3dService {
      * @return
      */
     ContingencyPlanInstance updateStatusByIdWeb(ContingencyPlanInstance contingencyPlanInstance, Boolean runStatus);
+
+    List<PlanStepJsonVO> getPlanStepList(String batchNo);
 }

YeeAmosFireAutoSysStart/src/main/resources/application-dev.properties

 #DB properties:
-spring.datasource.url = jdbc:mysql://172.16.11.201:3306/dl_business_v3.0.1.3_pyh_0510?allowMultiQueries=true&serverTimezone=GMT%2B8&characterEncoding=utf8
+spring.datasource.url = jdbc:mysql://172.16.10.241:3306/dl_business_v3.0.1.3?allowMultiQueries=true&serverTimezone=GMT%2B8&characterEncoding=utf8
 spring.datasource.username=root
 spring.datasource.password=Yeejoin@2020
 spring.datasource.driver-class-name = com.mysql.cj.jdbc.Driver
@@ -19,7 +19,7 @@ amos.system.user.product=STUDIO_APP_WEB
 
 
 
-eureka.client.serviceUrl.defaultZone: http://${spring.security.user.name}:${spring.security.user.password}@172.16.11.201:10001/eureka/
+eureka.client.serviceUrl.defaultZone: http://${spring.security.user.name}:${spring.security.user.password}@172.16.10.241:10001/eureka/
 eureka.instance.prefer-ip-address=true
 management.endpoint.health.show-details=always
 management.endpoints.web.exposure.include=*
@@ -34,11 +34,11 @@ spring.security.user.password=a1234560
 
 
 
-#eureka.instance.ip-address = 172.16.11.201
+#eureka.instance.ip-address = 172.16.10.241
 
 #redis
 spring.redis.database=1
-spring.redis.host=172.16.11.201
+spring.redis.host=172.16.10.241
 spring.redis.port=6379
 spring.redis.password=yeejoin@2020
 spring.redis.jedis.pool.max-active=200
@@ -51,18 +51,18 @@ windows.img.path = C:\\
 linux.img.path = /
 file.uploadUrl=C:\\upload\\files\\
 #picture read
-file.readUrl=http://172.16.11.201:8085/file/getFile?in=
+file.readUrl=http://172.16.10.241:8085/file/getFile?in=
 
 ## emqx
 emqx.clean-session=true
 emqx.client-id=${spring.application.name}-${random.int[1024,65536]}
-emqx.broker=tcp://172.16.11.201:1883
+emqx.broker=tcp://172.16.10.241:1883
 emqx.client-user-name=admin
 emqx.client-password=public
 emqx.max-inflight=1000
 riskSourceService
 #\u6587\u4EF6\u670D\u52A1\u5668\u5730\u5740
-file.downLoad.url=http://172.16.11.201:9000/
+file.downLoad.url=http://172.16.10.241:9000/
 
 #\u5E94\u6025\u5904\u7F6E\u79FB\u52A8\u7AEF\u9ED8\u8BA4\u5934\u50CF\u5730\u5740
 plan.instance.personImg=upload/3dview_icon/plan_via.png
@@ -105,6 +105,9 @@ plan.web.isUpdatePlanStep=false
 maparea.action.is-area=action1-2,action1-6
 
 plan.dynamic.execut.topic=\u6362\u6D41\u7AD9\u6D88\u9632\u4E13\u9879\u9884\u6848/autoExec
+# \u65B0\u589E\u4E3B\u53D8\u548C\u9AD8\u6297\u81EA\u52A8\u6267\u884C\u4E3B\u9898\u914D\u7F6E
+plan.dynamic.execut.zb.topic=\u6362\u6D41\u7AD9\u6D88\u9632\u4E13\u9879\u9884\u6848/autoExec-ZB
+plan.dynamic.execut.gk.topic=\u6362\u6D41\u7AD9\u6D88\u9632\u4E13\u9879\u9884\u6848/autoExec-GK
 
 #\u670D\u52A1\u7AEF\u83B7\u53D6isdp\u7684token\u7528
 sso.client.id=dce

YeeAmosFireAutoSysStart/src/main/resources/db/changelog/fas-2.0.1.xml

@@ -967,4 +967,53 @@
         </sql>
     </changeSet>
 
+    <changeSet author="zs" id="20240418-01">
+        <preConditions onFail="MARK_RAN">
+            <not>
+                <tableExists tableName="c_emergency_task_role" />
+            </not>
+        </preConditions>
+        <comment>create table c_emergency_task_role</comment>
+        <sql>
+            CREATE TABLE `c_emergency_task_role` (
+            `id` bigint NOT NULL AUTO_INCREMENT,
+            `name` varchar(255) DEFAULT NULL COMMENT '角色名称',
+            `code` varchar(255) DEFAULT NULL COMMENT '角色编码',
+            `sort` varchar(255) DEFAULT NULL COMMENT '排序字段',
+            `is_delete` int DEFAULT NULL COMMENT '是否删除',
+            `remark` text COMMENT '备注',
+            `creater` varchar(255) DEFAULT NULL COMMENT '创建者',
+            `create_date` datetime DEFAULT NULL COMMENT '创建时间',
+            `biz_org_code` varchar(255) DEFAULT NULL COMMENT '机构编码',
+            `biz_org_name` varchar(255) DEFAULT NULL COMMENT '机构名称',
+            PRIMARY KEY (`id`)
+            ) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
+        </sql>
+    </changeSet>
+
+    <changeSet author="zs" id="20240419-01">
+        <preConditions onFail="MARK_RAN">
+            <not>
+                <tableExists tableName="c_plan_step_config" />
+            </not>
+        </preConditions>
+        <comment>create table c_plan_step_config</comment>
+        <sql>
+            CREATE TABLE `c_plan_step_config` (
+            `id` int NOT NULL AUTO_INCREMENT COMMENT '主键',
+            `type` varchar(255) DEFAULT NULL COMMENT '类型',
+            `data` longtext COMMENT 'json数据',
+            PRIMARY KEY (`id`)
+            ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
+        </sql>
+    </changeSet>
+    <changeSet author="litengwei" id="20240425-1">
+        <preConditions onFail="MARK_RAN">
+                <columnExists tableName="c_plan_classify_tree" columnName="plan_type" />
+        </preConditions>
+        <comment>c_plan_classify_tree</comment>
+        <sql>
+            ALTER TABLE `c_plan_classify_tree` MODIFY COLUMN plan_type varchar(100) NULL COMMENT '分类TYPE';
+        </sql>
+    </changeSet>
 </databaseChangeLog>
\ No newline at end of file

YeeAmosFireAutoSysStart/src/main/resources/db/mapper/ContingencyInstanceInfoMapper.xml

@@ -321,6 +321,11 @@
                     role_code like concat('%',#{role},'%')
                 </foreach>
             </if>
+            <if test="steps != null and steps.size() >0">
+                <foreach collection="steps" item="code" index="index" open="and (" close=") " separator="or">
+                    step_code = #{code}
+                </foreach>
+            </if>
         </where>
         UNION ALL
         select  count(1) AS tmpcount from contingency_plan_instance
@@ -337,6 +342,11 @@
                     role_code like concat('%',#{role},'%')
                 </foreach>
             </if>
+            <if test="steps != null and steps.size() >0">
+                <foreach collection="steps" item="code" index="index" open="and (" close=") " separator="or">
+                    step_code = #{code}
+                </foreach>
+            </if>
         </where>
         ) a
     </select>
@@ -346,10 +356,10 @@
         select  cpi.id, cpi.`record_type`, cpi.`category`, cpi.`content`, cpi.`icon`, cpi.`sort`, cpi.`sequence_num`
         , cpi.`batch_no`, cpi.`create_date`, cpi.`create_user`, cpi.`update_date`
         , cpi.`update_user`, cpi.`is_delete`, cpi.`tips`, IFNULL(cpi.`runstate`, 0) AS runstate, cpi.`file_path`
-        , `file_type`, `role_name`, `role_code`, `start_user_name`
+        , `file_type`, `role_code`, ro.name AS role_name,  `start_user_name`
         , cpi.`start_user_id`, cpi.`person_img`,cii.name
         from  contingency_plan_instance cpi left  join  contingency_instance_info  cii
-        on cpi.batch_no = cii.id
+        on cpi.batch_no = cii.id left  join c_emergency_task_role ro on ro.`code` = cpi.role_code
         <where>
             cpi.step_code != "-1"
             <if test="batchNo != null and batchNo != ''">
@@ -363,6 +373,11 @@
                     cpi.role_code like concat('%',#{role},'%')
                 </foreach>
             </if>
+            <if test="steps != null and steps.size() >0">
+                <foreach collection="steps" item="code" index="index" open="and (" close=") " separator="or">
+                    step_code = #{code}
+                </foreach>
+            </if>
         </where>
         UNION ALL
         select  cpi.id, cpi.`record_type`, cpi.`category`, cpi.`content`, cpi.`icon`, cpi.`sort`, cpi.`sequence_num`
@@ -385,6 +400,11 @@
                     cpi.role_code like concat('%',#{role},'%')
                 </foreach>
             </if>
+            <if test="steps != null and steps.size() >0">
+                <foreach collection="steps" item="code" index="index" open="and (" close=") " separator="or">
+                    step_code = #{code}
+                </foreach>
+            </if>
         </where>
         ) tmp
         <if test="updateDate != null and updateDate != '' and updateDate == 0">

YeeAmosFireAutoSysStart/src/main/resources/db/mapper/EmergencyTaskRoleMapper.xml

+<?xml version="1.0" encoding="UTF-8" ?> <!DOCTYPE mapper
+        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.yeejoin.amos.fas.business.dao.mapper.EmergencyTaskRoleMapper">
+
+    <insert id="save" parameterType="com.yeejoin.amos.fas.dao.entity.EmergencyTaskRole">
+        INSERT INTO `c_emergency_task_role`(`name`, `code`, `sort`, `is_delete`, `remark`, `creater`, `create_date`, `biz_org_code`, `biz_org_name` )
+        VALUES (#{name}, #{code}, #{sort},  #{isDelete},#{remark},#{creater},#{createDate},#{bizOrgCode},#{bizOrgName});
+    </insert>
+
+    <update id="updateById">
+        UPDATE
+        c_emergency_task_role
+        SET `name` = #{name},
+            `code` = #{code},
+            `sort` = #{sort},
+            `remark` = #{remark},
+            `creater` = #{creater}
+        WHERE
+            `id` = #{id}
+    </update>
+
+    <select id="selectById" resultType="com.yeejoin.amos.fas.dao.entity.EmergencyTaskRole">
+        select * from c_emergency_task_role where id = #{id}
+    </select>
+
+    <select id="getInfoByPage" resultType="com.yeejoin.amos.fas.dao.entity.EmergencyTaskRole">
+        select * from
+            c_emergency_task_role
+        where 1 = 1
+            and is_delete = 0
+        order by create_date DESC
+            limit #{pageNum}, #{size}
+    </select>
+
+    <select id="getInfoCount" resultType="java.lang.Integer">
+        select count(1) from
+            c_emergency_task_role
+        where 1 = 1
+          and is_delete = 0
+    </select>
+
+    <delete id="deleteById">
+        delete from
+            c_emergency_task_role
+        WHERE
+            `id` = #{id}
+    </delete>
+
+    <select id="countByCode" resultType="int">
+        select count(1) from c_emergency_task_role where is_delete = 0 and code = #{code}
+    </select>
+
+    <select id="selectByCode" resultType="com.yeejoin.amos.fas.dao.entity.EmergencyTaskRole">
+        select * from c_emergency_task_role where is_delete = 0 and code = #{code}
+    </select>
+
+    <select id="selectList" resultType="com.yeejoin.amos.fas.dao.entity.EmergencyTaskRole">
+        select * from c_emergency_task_role where is_delete = 0 order by sort desc
+    </select>
+
+    <select id="selectListFilterEmptyTask" resultType="com.yeejoin.amos.fas.dao.entity.EmergencyTaskRole">
+        SELECT
+            *
+        FROM
+            c_emergency_task_role cet
+            JOIN c_emergency_task_content cetc ON cetc.obligation_id = cet.id
+        WHERE
+            is_delete = 0
+        GROUP BY
+            cet.`code`
+        ORDER BY
+            cet.sort DESC
+    </select>
+
+    <select id="getPlanStepInfoByType" resultType="java.lang.String">
+        select `data` from c_plan_step_config
+        <where>
+            1 = 1
+            <if test="planType != null and planType != ''">
+                AND type = #{planType}
+            </if>
+        </where>
+        order by id ASC
+         limit 1
+    </select>
+
+    <delete id="deleteRelationByRoleId">
+        delete from
+            c_emergency_relation
+        WHERE
+            `obligationId` = #{roleId}
+    </delete>
+</mapper>
\ No newline at end of file

YeeAmosFireAutoSysStart/src/main/resources/db/mapper/PlanDetailMapper.xml

@@ -134,6 +134,16 @@
       and d.is_delete = false
       limit 1
    </select>
+  <select id="getPlanDetailById" resultType="com.yeejoin.amos.fas.business.vo.PlanDetailVo">
+    select
+      d.classify_id AS classifyId
+    from
+      c_plan_detail d
+          LEFT JOIN c_plan_classify_tree ct ON d.classify_id = ct.id
+    where d.id = #{id}
+      and d.is_delete = false
+      limit 1
+  </select>
 
   <update id="planReset">
     UPDATE c_plan_detail SET `status` = 2;

YeeAmosFireAutoSysStart/src/main/resources/db/mapper/PlanOperationRecordMapper.xml

@@ -147,7 +147,7 @@
     </select>
   <select id="getArraysUserName" resultType="java.lang.String">
     SELECT  person_name from c_emergency_relation cer where obligationId in (
-      select id from f_dict fd where dict_value = #{roleCode}
+      select id from c_emergency_task_role  where code = #{roleCode}
     )
   </select>
 </mapper>
\ No newline at end of file

YeeAmosFireAutoSysStart/src/main/resources/db/mapper/dbTemplate_emergency_task.xml

@@ -16,8 +16,11 @@
             <if test="obligationId != null ">
                 obligation_id = #{obligationId}
             </if>
+            <if test="planType != null ">
+                AND plan_type = #{planType}
+            </if>
         </where>
-        LIMIT #{offset},  #{pageSize}
+        LIMIT #{offset}, #{pageSize}
 
         </select>
 
@@ -28,11 +31,13 @@
         FROM
             c_emergency_task_content
         <where>
-            <if test="_parameter != null ">
+            <if test="obligationId != null ">
                 obligation_id = #{obligationId}
             </if>
+            <if test="planType != null ">
+                AND plan_type = #{planType}
+            </if>
         </where>
-
         </select>
 
 
@@ -50,9 +55,9 @@
 
     <select id="roleCodes" resultType="string">
         SELECT
-            f.dict_value
+            f.code
         FROM
-            c_emergency_relation cer LEFT JOIN  f_dict f ON cer.obligationId = f.id
+            c_emergency_relation cer LEFT JOIN  c_emergency_task_role f ON cer.obligationId = f.id
         <where>
             <if test="_parameter != null  ">
                 cer.amos_id = #{amosOrgId}
@@ -62,9 +67,9 @@
 
     <select id="roleNames" resultType="string">
     SELECT
-    f.dict_name AS dictName
+    f.name AS dictName
     FROM
-    c_emergency_relation cer LEFT JOIN  f_dict f ON cer.obligationId = f.id
+    c_emergency_relation cer LEFT JOIN  c_emergency_task_role f ON cer.obligationId = f.id
     <where>
         <if test="_parameter != null  ">
             cer.amos_id = #{amosOrgId}
@@ -84,6 +89,17 @@
         </where>
     </select>
 
+    <delete id="deleteTask">
+
+        delete  from   c_emergency_task_content cer
+
+        <where>
+            <if test="id != null  ">
+                cer.id = #{id}
+            </if>
+        </where>
+    </delete>
+
     <delete id="deleteTreeNode">
 
        delete  from   c_emergency_relation cer
@@ -103,6 +119,11 @@
         VALUES (#{id}, #{obligationId}, #{personId}, #{amosOrgId},  #{personName},#{createDate});
     </insert>
 
+    <insert id="saveTaskConfig" parameterType="com.yeejoin.amos.fas.dao.entity.EmergencyTaskContent">
+        INSERT INTO `c_emergency_task_content`(`content`, `code`, `obligation_id`, `create_date`, `obligation_name`, `step_code`, `role_code`,`button_json`, `task_num`,`is_must`, `plan_type`)
+        VALUES (#{content}, #{code}, #{obligationId},  #{createDate},#{obligationName}, #{stepCode}, #{roleCode}, #{buttonJson},#{taskNum}, #{isMust} ,#{planType} );
+    </insert>
+
     <select id="getContentList" resultType="com.yeejoin.amos.fas.business.vo.EmergencyTaskContentVo">
         SELECT
             *
@@ -115,6 +136,9 @@
             <if test="stepCode != null and stepCode != '' and stepCode == '-2'">
                 step_code = -1
             </if>
+            <if test="planType != null ">
+                AND plan_type = #{planType}
+            </if>
         </where>
     </select>
 
@@ -124,9 +148,11 @@
         FROM
         c_emergency_task_content
         <where>
-            is_must = true
             <if test="stepCode != null and stepCode != ''">
-                and step_code = #{stepCode}
+                step_code = #{stepCode}
+            </if>
+            <if test="planType != null ">
+                AND plan_type = #{planType}
             </if>
         </where>
     </select>

YeeAmosFireAutoSysStart/src/main/resources/json/plan-step-UHV-gk.json

+[
+  {
+    "stepCode": "0",
+    "stepName": "确认火情",
+    "stepStatus": "0",
+    "buttonCode": "FIRE_CONFIRM",
+    "isParallel": "1",
+    "roleCode": "Digital_Responsing_Plan_A",
+    "index": 0,
+    "checkYesOrNo": ""
+  },
+  {
+    "stepCode": "1",
+    "stepName": "汇报，通知，报警",
+    "stepStatus": "0",
+    "buttonCode": "CALL_PHONE",
+    "isParallel": "1",
+    "roleCode": "Digital_Responsing_Plan_A",
+    "index": 1,
+    "checkYesOrNo": ""
+  },
+  {
+    "stepCode": "2",
+    "stepName": "确认开关跳闸",
+    "stepStatus": "0",
+    "buttonCode": "OPEN_THREE_SIDE_SWITCHES",
+    "isParallel": "0",
+    "roleCode": "Digital_Responsing_Plan_A",
+    "index": 2,
+    "isAuto": 0,
+    "checkYesOrNo": ""
+  },
+  {
+    "stepCode": "3",
+    "stepName": "检查固定喷雾灭火设施启动",
+    "stepStatus": "0",
+    "buttonCode": "OPEN_SPRAYINGSYSTEM",
+    "isParallel": "0",
+    "roleCode": "Digital_Responsing_Plan_A",
+    "index": 3,
+    "condition": [
+      {
+        "equipName": "主机",
+        "equipCode": "92030100TGX44",
+        "equipSpeName": "",
+        "equipSpeCode": "",
+        "equipSpeIndexKey": "CAFS_CompAirFoamHost_Outfire",
+        "standardValue": "true",
+        "inAndOr": "and"
+      }
+    ],
+    "outAndOr": "and",
+    "isAuto": 0,
+    "checkYesOrNo": ""
+  },
+  {
+    "stepCode": "4",
+    "stepName": "启动CAFS消防系统",
+    "stepStatus": "0",
+    "buttonCode": "OPEN_WATERSYSTEM",
+    "isParallel": "0",
+    "roleCode": "Digital_Responsing_Plan_A",
+    "index": 4,
+    "checkYesOrNo": "",
+    "condition": [
+      {
+        "equipName": "雨淋阀",
+        "equipCode": "92130300BH644",
+        "equipSpeName": "",
+        "equipSpeCode": "",
+        "equipSpeIndexKey": "WSS_DelugeValve_Start",
+        "standardValue": "true",
+        "inAndOr": "and"
+      }
+    ],
+    "outAndOr": "and",
+    "isAuto": 0
+  },
+  {
+    "stepCode": "5",
+    "stepName": "启动CAFS举高灭火机器人",
+    "stepStatus": "0",
+    "buttonCode": "START_TURBOFAN_ROBOT",
+    "isParallel": "0",
+    "roleCode": "Digital_Responsing_Plan_B",
+    "index": 5,
+    "checkYesOrNo": ""
+  },
+  {
+    "stepCode": "6",
+    "stepName": "申请调检修",
+    "stepStatus": "0",
+    "buttonCode": "APPLY_FOR_OVERHAUL",
+    "isParallel": "0",
+    "roleCode": "Digital_Responsing_Plan_A",
+    "index": 6,
+    "checkYesOrNo": ""
+  },
+
+  {
+    "stepCode": "7",
+    "stepName": "断开交、直流电源",
+    "stepStatus": "0",
+    "buttonCode": "OFF_POWER",
+    "isParallel": "1",
+    "roleCode": "Digital_Responsing_Plan_A",
+    "index": 7,
+    "checkYesOrNo": ""
+  },
+  {
+    "stepCode": "8",
+    "stepName": "执行转检修操作",
+    "stepStatus": "0",
+    "buttonCode": "FIRE_TRANSVERTER_TO_OVERHAUL",
+    "isParallel": "0",
+    "roleCode": "Digital_Responsing_Plan_B",
+    "index": 8,
+    "checkYesOrNo": ""
+  },
+  {
+    "stepCode": "9",
+    "stepName": "电缆沟封堵",
+    "stepStatus": "0",
+    "buttonCode": "PLUG_CABLETRENCH",
+    "isParallel": "0",
+    "roleCode": "Digital_Responsing_Plan_B",
+    "index": 9,
+    "checkYesOrNo": ""
+  },
+  {
+    "stepCode": "10",
+    "stepName": "政府消防队指挥权交接",
+    "stepStatus": "0",
+    "buttonCode": "HANDOVER_FIGTHHING",
+    "isParallel": "0",
+    "roleCode": "Digital_Responsing_Plan_B",
+    "index": 10,
+    "checkYesOrNo": ""
+  },
+  {
+    "stepCode": "11",
+    "stepName": "确认明火扑灭，确认着火设备温度降为环境温度",
+    "stepStatus": "0",
+    "buttonCode": "FIRE_EXTINCT",
+    "isParallel": "0",
+    "roleCode": "Digital_Responsing_Plan_B",
+    "index": 11,
+    "checkYesOrNo": ""
+  },
+  {
+    "stepCode": "12",
+    "stepName": "检查现场情况，汇报调度",
+    "stepStatus": "0",
+    "buttonCode": "ACCIDENT_REPORT",
+    "isParallel": "0",
+    "roleCode": "Digital_Responsing_Plan_B",
+    "index": 12,
+    "checkYesOrNo": ""
+  },
+  {
+    "stepCode": "13",
+    "stepName": "退出预案",
+    "stepStatus": "0",
+    "buttonCode": "END_EMERGENCY",
+    "isParallel": "1",
+    "roleCode": "Digital_Responsing_Plan_B",
+    "index": 13,
+    "checkYesOrNo": ""
+  }
+]
\ No newline at end of file

YeeAmosFireAutoSysStart/src/main/resources/json/plan-step-UHV-zb.json

+[
+  {
+    "stepCode": "0",
+    "stepName": "确认火情",
+    "stepStatus": "0",
+    "buttonCode": "FIRE_CONFIRM",
+    "isParallel": "1",
+    "roleCode": "Digital_Responsing_Plan_A",
+    "index": 0,
+    "checkYesOrNo": ""
+  },
+  {
+    "stepCode": "1",
+    "stepName": "汇报，通知，报警",
+    "stepStatus": "0",
+    "buttonCode": "CALL_PHONE",
+    "isParallel": "1",
+    "roleCode": "Digital_Responsing_Plan_A",
+    "index": 1,
+    "checkYesOrNo": ""
+  },
+  {
+    "stepCode": "2",
+    "stepName": "确认开关跳闸",
+    "stepStatus": "0",
+    "buttonCode": "OPEN_THREE_SIDE_SWITCHES",
+    "isParallel": "0",
+    "roleCode": "Digital_Responsing_Plan_A",
+    "index": 2,
+    "isAuto": 0
+  },
+  {
+    "stepCode": "3",
+    "stepName": "检查固定喷雾灭火设施启动",
+    "stepStatus": "0",
+    "buttonCode": "OPEN_SPRAYINGSYSTEM",
+    "isParallel": "0",
+    "roleCode": "Digital_Responsing_Plan_A",
+    "index": 3,
+    "condition": [
+      {
+        "equipName": "主机",
+        "equipCode": "92030100TGX44",
+        "equipSpeName": "",
+        "equipSpeCode": "",
+        "equipSpeIndexKey": "CAFS_CompAirFoamHost_Outfire",
+        "standardValue": "true",
+        "inAndOr": "and"
+      }
+    ],
+    "outAndOr": "and",
+    "isAuto": 0,
+    "checkYesOrNo": ""
+  },
+  {
+    "stepCode": "4",
+    "stepName": "启动CAFS消防系统",
+    "stepStatus": "0",
+    "buttonCode": "OPEN_WATERSYSTEM",
+    "isParallel": "0",
+    "roleCode": "Digital_Responsing_Plan_A",
+    "index": 4,
+    "checkYesOrNo": "",
+    "condition": [
+      {
+        "equipName": "雨淋阀",
+        "equipCode": "92130300BH644",
+        "equipSpeName": "",
+        "equipSpeCode": "",
+        "equipSpeIndexKey": "WSS_DelugeValve_Start",
+        "standardValue": "true",
+        "inAndOr": "and"
+      }
+    ],
+    "outAndOr": "and",
+    "isAuto": 0
+  },
+  {
+    "stepCode": "5",
+    "stepName": "启动应急排油",
+    "stepStatus": "0",
+    "buttonCode": "DRAIN_OIL_CONFIRM",
+    "isParallel": "0",
+    "roleCode": "Digital_Responsing_Plan_A",
+    "index": 5,
+    "condition": [
+      {
+        "equipName": "排油阀",
+        "equipCode": "92100400VWE44",
+        "equipSpeName": "",
+        "equipSpeCode": "",
+        "equipSpeIndexKey": "ONL_DrainOilValve_Open",
+        "standardValue": "true",
+        "inAndOr": "and"
+      }
+    ],
+    "outAndOr": "and",
+    "isAuto": 0,
+    "checkYesOrNo": ""
+  },
+  {
+    "stepCode": "6",
+    "stepName": "启动CAFS举高灭火机器人",
+    "stepStatus": "0",
+    "buttonCode": "START_TURBOFAN_ROBOT",
+    "isParallel": "0",
+    "roleCode": "Digital_Responsing_Plan_B",
+    "index": 6,
+    "checkYesOrNo": ""
+  },
+  {
+    "stepCode": "7",
+    "stepName": "申请调检修",
+    "stepStatus": "0",
+    "buttonCode": "APPLY_FOR_OVERHAUL",
+    "isParallel": "0",
+    "roleCode": "Digital_Responsing_Plan_A",
+    "index": 7,
+    "checkYesOrNo": ""
+  },
+
+  {
+    "stepCode": "8",
+    "stepName": "断开交、直流电源",
+    "stepStatus": "0",
+    "buttonCode": "OFF_POWER",
+    "isParallel": "1",
+    "roleCode": "Digital_Responsing_Plan_A",
+    "index": 8,
+    "checkYesOrNo": ""
+  },
+  {
+    "stepCode": "9",
+    "stepName": "执行转检修操作",
+    "stepStatus": "0",
+    "buttonCode": "FIRE_TRANSVERTER_TO_OVERHAUL",
+    "isParallel": "0",
+    "roleCode": "Digital_Responsing_Plan_B",
+    "index": 9,
+    "checkYesOrNo": ""
+  },
+  {
+    "stepCode": "10",
+    "stepName": "电缆沟封堵",
+    "stepStatus": "0",
+    "buttonCode": "PLUG_CABLETRENCH",
+    "isParallel": "0",
+    "roleCode": "Digital_Responsing_Plan_B",
+    "index": 10,
+    "checkYesOrNo": ""
+  },
+  {
+    "stepCode": "11",
+    "stepName": "政府消防队指挥权交接",
+    "stepStatus": "0",
+    "buttonCode": "HANDOVER_FIGTHHING",
+    "isParallel": "0",
+    "roleCode": "Digital_Responsing_Plan_B",
+    "index": 11,
+    "checkYesOrNo": ""
+  },
+  {
+    "stepCode": "12",
+    "stepName": "确认明火扑灭，确认着火设备温度降为环境温度",
+    "stepStatus": "0",
+    "buttonCode": "FIRE_EXTINCT",
+    "isParallel": "0",
+    "roleCode": "Digital_Responsing_Plan_B",
+    "index": 12,
+    "checkYesOrNo": ""
+  },
+  {
+    "stepCode": "13",
+    "stepName": "检查现场情况，汇报调度",
+    "stepStatus": "0",
+    "buttonCode": "ACCIDENT_REPORT",
+    "isParallel": "0",
+    "roleCode": "Digital_Responsing_Plan_B",
+    "index": 13,
+    "checkYesOrNo": ""
+  },
+  {
+    "stepCode": "14",
+    "stepName": "退出预案",
+    "stepStatus": "0",
+    "buttonCode": "END_EMERGENCY",
+    "isParallel": "1",
+    "roleCode": "Digital_Responsing_Plan_B",
+    "index": 14,
+    "checkYesOrNo": ""
+  }
+]
\ No newline at end of file

YeeAmosFireAutoSysStart/src/main/resources/json/plan-step.json

@@ -15,7 +15,7 @@
     "stepStatus": "0",
     "buttonCode": "CALL_PHONE",
     "isParallel": "1",
-    "roleCode": "Digital_Responsing_Plan_B",
+    "roleCode": "Digital_Responsing_Plan_A",
     "index": 1,
     "checkYesOrNo": ""
   },
@@ -27,7 +27,8 @@
     "isParallel": "0",
     "roleCode": "Digital_Responsing_Plan_A",
     "index": 2,
-    "isAuto": 0
+    "isAuto": 0,
+    "checkYesOrNo": ""
   },
   {
     "stepCode": "3",
@@ -54,36 +55,49 @@
   },
   {
     "stepCode": "4",
-    "stepName": "启动应急排油",
+    "stepName": "启动CAFS消防系统",
     "stepStatus": "0",
-    "buttonCode": "FIRE_TRANSVERTER_TO_OVERHAUL",
+    "buttonCode": "OPEN_WATERSYSTEM",
     "isParallel": "0",
-    "roleCode": "Digital_Responsing_Plan_B",
+    "roleCode": "Digital_Responsing_Plan_A",
     "index": 4,
-    "checkYesOrNo": ""
+    "checkYesOrNo": "",
+    "condition": [
+      {
+        "equipName": "雨淋阀",
+        "equipCode": "92130300BH644",
+        "equipSpeName": "",
+        "equipSpeCode": "",
+        "equipSpeIndexKey": "WSS_DelugeValve_Start",
+        "standardValue": "true",
+        "inAndOr": "and"
+      }
+    ],
+    "outAndOr": "and",
+    "isAuto": 0
   },
   {
     "stepCode": "5",
-    "stepName": "CAFS喷淋系统已开启",
+    "stepName": "启动应急排油",
     "stepStatus": "0",
-    "buttonCode": "VERIFY_EQUIP_STATUS",
+    "buttonCode": "DRAIN_OIL_CONFIRM",
     "isParallel": "0",
     "roleCode": "Digital_Responsing_Plan_A",
     "index": 5,
-    "checkYesOrNo": "",
     "condition": [
       {
-        "equipName": "雨淋阀",
-        "equipCode": "92130300BH644",
+        "equipName": "排油阀",
+        "equipCode": "92100400VWE44",
         "equipSpeName": "",
         "equipSpeCode": "",
-        "equipSpeIndexKey": "WSS_DelugeValve_Start",
+        "equipSpeIndexKey": "ONL_DrainOilValve_Open",
         "standardValue": "true",
         "inAndOr": "and"
       }
     ],
     "outAndOr": "and",
-    "isAuto": 0
+    "isAuto": 0,
+    "checkYesOrNo": ""
   },
   {
     "stepCode": "6",
@@ -122,7 +136,7 @@
     "stepStatus": "0",
     "buttonCode": "FIRE_TRANSVERTER_TO_OVERHAUL",
     "isParallel": "0",
-    "roleCode": "Digital_Responsing_Plan_A",
+    "roleCode": "Digital_Responsing_Plan_B",
     "index": 9,
     "checkYesOrNo": ""
   },