【业务功能篇38】上篇：Springboot+activiti7 工作流引擎增加网关组件、Assignment分配权限

我就是我 2024-03-17 14:49 38阅读 0赞

> 在前面的一篇文章中，简单举例了一个 工单电子流，[【业务功能篇36】Springboot+activiti7 工作流引擎\_studyday1的博客-CSDN博客][36_Springboot_activiti7 _studyday1_-CSDN]仅有一个子任务，这种一般是针对比较简单的一个遗留问题记录场景，今天再介绍一个，相对比较复杂的流程，多个处理，审批节点任务，通过排他网关组件来进行流程走向，也通过设置Assignment指定任务节点的分配人员

### BPMN2.0流程图 ###

#### 1. XML文件： ####

<?xml version="1.0" encoding="UTF-8"?>
    <bpmn2:definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:bpmn2="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC" xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI" typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="http://www.activiti.org/test">
      <bpmn2:process id="COMP_FAIL_PROCESS_DEF_KEY" isExecutable="true">
        <bpmn2:startEvent id="start"></bpmn2:startEvent>
        <bpmn2:sequenceFlow id="sequenceFlow-cc8e14fa-bc92-48fb-aab1-ec4263dfe04a" sourceRef="start" targetRef="COMP_FAIL_TASK_APPLICATION"></bpmn2:sequenceFlow>
        <bpmn2:userTask id="COMP_FAIL_TASK_APPLICATION" name="委托人填写委托分析申请" activiti:assignee="${COMP_FAIL_TASK_APPLICATION_ASSIGNEE}"></bpmn2:userTask>
        <bpmn2:sequenceFlow id="sequenceFlow-687cdeb3-5dd1-449b-be05-1002a23289b3" sourceRef="COMP_FAIL_TASK_APPLICATION" targetRef="COMP_FAIL_EXCL_GATEWAY_APPLICATION_DEF_KEY"></bpmn2:sequenceFlow>
        <bpmn2:exclusiveGateway id="COMP_FAIL_EXCL_GATEWAY_APPLICATION_DEF_KEY"></bpmn2:exclusiveGateway>
        <bpmn2:sequenceFlow id="sequenceFlow-5f567ea0-02ce-4e8d-b08d-f884388a88be" sourceRef="COMP_FAIL_EXCL_GATEWAY_APPLICATION_DEF_KEY" targetRef="end">
          <conditionExpression xsi:type="tFormalExpression"><![CDATA[${COMP_FAIL_GATEWAY_CONDITION_APPLICATION == false}]]></conditionExpression>
        </bpmn2:sequenceFlow>
        <bpmn2:sequenceFlow id="sequenceFlow-1cec0e0f-7c6b-4b3d-8937-917481f82759" sourceRef="COMP_FAIL_EXCL_GATEWAY_APPLICATION_DEF_KEY" targetRef="COMP_FAIL_TASK_CONTACT_REVIEW">
          <conditionExpression xsi:type="tFormalExpression"><![CDATA[${COMP_FAIL_GATEWAY_CONDITION_APPLICATION == true}]]></conditionExpression>
        </bpmn2:sequenceFlow>
        <bpmn2:userTask id="COMP_FAIL_TASK_CONTACT_REVIEW" name="接口人审核" activiti:assignee="${COMP_FAIL_TASK_CONTACT_REVIEW_ASSIGNEE}"></bpmn2:userTask>
        <bpmn2:sequenceFlow id="sequenceFlow-4765a5bb-3156-41a5-8285-e409601f13ae" sourceRef="COMP_FAIL_TASK_CONTACT_REVIEW" targetRef="COMP_FAIL_EXCL_GATEWAY_CONTACT_REVIEW_DEF_KEY"></bpmn2:sequenceFlow>
        <bpmn2:exclusiveGateway id="COMP_FAIL_EXCL_GATEWAY_CONTACT_REVIEW_DEF_KEY"></bpmn2:exclusiveGateway>
        <bpmn2:sequenceFlow id="sequenceFlow-f4dca2a6-3d2e-463f-9c31-22d74572e970" sourceRef="COMP_FAIL_EXCL_GATEWAY_CONTACT_REVIEW_DEF_KEY" targetRef="COMP_FAIL_TASK_APPLICATION">
          <conditionExpression xsi:type="tFormalExpression"><![CDATA[${COMP_FAIL_GATEWAY_CONTACT_REVIEW_NORMAL_ADVANCE == false}]]></conditionExpression>
        </bpmn2:sequenceFlow>
        <bpmn2:sequenceFlow id="sequenceFlow-fd7f68c7-000f-4c55-a645-aef8d8556cc4" sourceRef="COMP_FAIL_EXCL_GATEWAY_CONTACT_REVIEW_DEF_KEY" targetRef="COMP_FAIL_TASK_ANALYSIS">
          <conditionExpression xsi:type="tFormalExpression"><![CDATA[${COMP_FAIL_GATEWAY_CONTACT_REVIEW_NORMAL_ADVANCE == true}]]></conditionExpression>
        </bpmn2:sequenceFlow>
        <bpmn2:userTask id="COMP_FAIL_TASK_ANALYSIS" name="分析人分析" activiti:assignee="${COMP_FAIL_TASK_ANALYSIS_ASSIGNEE}"></bpmn2:userTask>
        <bpmn2:sequenceFlow id="sequenceFlow-76fbde23-c91c-4911-b3ee-a0eea4643371" sourceRef="COMP_FAIL_TASK_ANALYSIS" targetRef="COMP_FAIL_EXCL_GATEWAY_ANALYSIS_DEF_KEY"></bpmn2:sequenceFlow>
        <bpmn2:exclusiveGateway id="COMP_FAIL_EXCL_GATEWAY_ANALYSIS_DEF_KEY"></bpmn2:exclusiveGateway>
        <bpmn2:sequenceFlow id="sequenceFlow-a4c486eb-003f-448c-bcea-a9d52c885dd4" sourceRef="COMP_FAIL_EXCL_GATEWAY_ANALYSIS_DEF_KEY" targetRef="COMP_FAIL_TASK_CONTACT_REVIEW">
          <conditionExpression xsi:type="tFormalExpression"><![CDATA[${COMP_FAIL_GATEWAY_ANALYSIS_NORMAL_ADVANCE == false}]]></conditionExpression>
        </bpmn2:sequenceFlow>
        <bpmn2:sequenceFlow id="sequenceFlow-97acf8b0-d186-4c28-9355-323b728ae768" sourceRef="COMP_FAIL_EXCL_GATEWAY_ANALYSIS_DEF_KEY" targetRef="COMP_FAIL_TASK_RISK">
          <conditionExpression xsi:type="tFormalExpression"><![CDATA[${COMP_FAIL_GATEWAY_ANALYSIS_NORMAL_ADVANCE == true}]]></conditionExpression>
        </bpmn2:sequenceFlow>
        <bpmn2:userTask id="COMP_FAIL_TASK_RISK" name="风险评估及改进" activiti:assignee="${COMP_FAIL_TASK_RISK_ASSIGNEE}"></bpmn2:userTask>
        <bpmn2:sequenceFlow id="sequenceFlow-cc7c2ba4-68ea-4481-82d7-51d7ead0ca65" sourceRef="COMP_FAIL_TASK_RISK" targetRef="COMP_FAIL_EXCL_GATEWAY_RISK_DEF_KEY"></bpmn2:sequenceFlow>
        <bpmn2:exclusiveGateway id="COMP_FAIL_EXCL_GATEWAY_RISK_DEF_KEY"></bpmn2:exclusiveGateway>
        <bpmn2:sequenceFlow id="sequenceFlow-cb4c7a54-524c-4587-bc72-6bc375ed0954" sourceRef="COMP_FAIL_EXCL_GATEWAY_RISK_DEF_KEY" targetRef="COMP_FAIL_TASK_ANALYSIS">
          <conditionExpression xsi:type="tFormalExpression"><![CDATA[${COMP_FAIL_GATEWAY_RISK_NORMAL_ADVANCE == false}]]></conditionExpression>
        </bpmn2:sequenceFlow>
        <bpmn2:sequenceFlow id="sequenceFlow-3cce8ca5-5a47-4733-87ae-3ab6718c0a3a" sourceRef="COMP_FAIL_EXCL_GATEWAY_RISK_DEF_KEY" targetRef="COMP_FAIL_TASK_PM_REVIEW">
          <conditionExpression xsi:type="tFormalExpression"><![CDATA[${COMP_FAIL_GATEWAY_RISK_NORMAL_ADVANCE == true}]]></conditionExpression>
        </bpmn2:sequenceFlow>
        <bpmn2:userTask id="COMP_FAIL_TASK_PM_REVIEW" name="项目经理审核" activiti:assignee="${COMP_FAIL_TASK_PM_REVIEW_ASSIGNEE}"></bpmn2:userTask>
        <bpmn2:sequenceFlow id="sequenceFlow-ea95d696-e932-4528-8f0c-131f46ccbab9" sourceRef="COMP_FAIL_TASK_PM_REVIEW" targetRef="COMP_FAIL_EXCL_GATEWAY_PM_REVIEW_DEF_KEY"></bpmn2:sequenceFlow>
        <bpmn2:exclusiveGateway id="COMP_FAIL_EXCL_GATEWAY_PM_REVIEW_DEF_KEY"></bpmn2:exclusiveGateway>
        <bpmn2:sequenceFlow id="sequenceFlow-ffcbf3ae-08f3-469a-8d61-263b2ed4c060" sourceRef="COMP_FAIL_EXCL_GATEWAY_PM_REVIEW_DEF_KEY" targetRef="COMP_FAIL_TASK_RISK">
          <conditionExpression xsi:type="tFormalExpression"><![CDATA[${COMP_FAIL_GATEWAY_PM_REVIEW_NORMAL_ADVANCE == false}]]></conditionExpression>
        </bpmn2:sequenceFlow>
        <bpmn2:sequenceFlow id="sequenceFlow-7dc193e2-ff59-4cde-836a-9be05f8c51de" sourceRef="COMP_FAIL_EXCL_GATEWAY_PM_REVIEW_DEF_KEY" targetRef="COMP_FAIL_TASK_ML_REVIEW">
          <conditionExpression xsi:type="tFormalExpression"><![CDATA[${COMP_FAIL_GATEWAY_PM_REVIEW_NORMAL_ADVANCE == true}]]></conditionExpression>
        </bpmn2:sequenceFlow>
        <bpmn2:userTask id="COMP_FAIL_TASK_ML_REVIEW" name="专家组长审核" activiti:assignee="${COMP_FAIL_TASK_ML_REVIEW_ASSIGNEE}"></bpmn2:userTask>
        <bpmn2:sequenceFlow id="sequenceFlow-627920df-9548-4c0e-8885-24de425aabb5" sourceRef="COMP_FAIL_TASK_ML_REVIEW" targetRef="COMP_FAIL_EXCL_GATEWAY_ML_REVIEW_DEF_KEY"></bpmn2:sequenceFlow>
        <bpmn2:exclusiveGateway id="COMP_FAIL_EXCL_GATEWAY_ML_REVIEW_DEF_KEY"></bpmn2:exclusiveGateway>
        <bpmn2:sequenceFlow id="sequenceFlow-a14fbb1c-8087-483f-82e6-ccb0a0f53102" sourceRef="COMP_FAIL_EXCL_GATEWAY_ML_REVIEW_DEF_KEY" targetRef="COMP_FAIL_TASK_PM_REVIEW">
          <conditionExpression xsi:type="tFormalExpression"><![CDATA[${COMP_FAIL_GATEWAY_ML_REVIEW_NORMAL_ADVANCE == false}]]></conditionExpression>
        </bpmn2:sequenceFlow>
        <bpmn2:sequenceFlow id="sequenceFlow-2dd3ceb3-dd78-46a1-9071-f3b0afc57687" sourceRef="COMP_FAIL_EXCL_GATEWAY_ML_REVIEW_DEF_KEY" targetRef="COMP_FAIL_TASK_CLOSE_REVIEW">
          <conditionExpression xsi:type="tFormalExpression"><![CDATA[${COMP_FAIL_GATEWAY_ML_REVIEW_NORMAL_ADVANCE == true}]]></conditionExpression>
        </bpmn2:sequenceFlow>
        <bpmn2:userTask id="COMP_FAIL_TASK_CLOSE_REVIEW" name="问题关闭审核" activiti:assignee="${COMP_FAIL_TASK_CLOSE_REVIEW_ASSIGNEE}"></bpmn2:userTask>
        <bpmn2:sequenceFlow id="sequenceFlow-ffb442cc-605a-418e-b5c7-5f2d0a0d7c01" sourceRef="COMP_FAIL_TASK_CLOSE_REVIEW" targetRef="COMP_FAIL_EXCL_GATEWAY_CLOSE_REVIEW_DEF_KEY"></bpmn2:sequenceFlow>
        <bpmn2:exclusiveGateway id="COMP_FAIL_EXCL_GATEWAY_CLOSE_REVIEW_DEF_KEY"></bpmn2:exclusiveGateway>
        <bpmn2:sequenceFlow id="sequenceFlow-81734467-b00d-4f0b-b7a2-7d3caabc56ee" sourceRef="COMP_FAIL_EXCL_GATEWAY_CLOSE_REVIEW_DEF_KEY" targetRef="COMP_FAIL_TASK_ML_REVIEW">
          <conditionExpression xsi:type="tFormalExpression"><![CDATA[${COMP_FAIL_GATEWAY_CLOSE_REVIEW_NORMAL_ADVANCE == false}]]></conditionExpression>
        </bpmn2:sequenceFlow>
        <bpmn2:sequenceFlow id="sequenceFlow-555ca10e-8b0a-45a9-b912-7a2aed7fde59" sourceRef="COMP_FAIL_EXCL_GATEWAY_CLOSE_REVIEW_DEF_KEY" targetRef="COMP_FAIL_TASK_FEEDBACK">
          <conditionExpression xsi:type="tFormalExpression"><![CDATA[${COMP_FAIL_GATEWAY_CLOSE_REVIEW_NORMAL_ADVANCE == true}]]></conditionExpression>
        </bpmn2:sequenceFlow>
        <bpmn2:userTask id="COMP_FAIL_TASK_FEEDBACK" name="委托人反馈意见" activiti:assignee="${COMP_FAIL_TASK_FEEDBACK_ASSIGNEE}"></bpmn2:userTask>
        <bpmn2:sequenceFlow id="sequenceFlow-4e4edef1-d382-4ad8-ad65-3e1fb13b7d65" sourceRef="COMP_FAIL_TASK_FEEDBACK" targetRef="end"></bpmn2:sequenceFlow>
        <bpmn2:endEvent id="end"></bpmn2:endEvent>
      </bpmn2:process>
      <bpmndi:BPMNDiagram id="BPMNDiagram_COMP_FAIL_PROCESS_DEF_KEY">
        <bpmndi:BPMNPlane bpmnElement="COMP_FAIL_PROCESS_DEF_KEY" id="BPMNPlane_COMP_FAIL_PROCESS_DEF_KEY">
          <bpmndi:BPMNShape bpmnElement="start" id="BPMNShape_start">
            <omgdc:Bounds height="30.0" width="30.0" x="0.0" y="123.0"></omgdc:Bounds>
          </bpmndi:BPMNShape>
          <bpmndi:BPMNShape bpmnElement="COMP_FAIL_TASK_RISK" id="BPMNShape_COMP_FAIL_TASK_RISK">
            <omgdc:Bounds height="60.0" width="100.0" x="800.0" y="100.0"></omgdc:Bounds>
          </bpmndi:BPMNShape>
          <bpmndi:BPMNShape bpmnElement="COMP_FAIL_EXCL_GATEWAY_PM_REVIEW_DEF_KEY" id="BPMNShape_COMP_FAIL_EXCL_GATEWAY_PM_REVIEW_DEF_KEY">
            <omgdc:Bounds height="40.0" width="40.0" x="1190.0" y="110.0"></omgdc:Bounds>
          </bpmndi:BPMNShape>
          <bpmndi:BPMNShape bpmnElement="COMP_FAIL_EXCL_GATEWAY_ANALYSIS_DEF_KEY" id="BPMNShape_COMP_FAIL_EXCL_GATEWAY_ANALYSIS_DEF_KEY">
            <omgdc:Bounds height="40.0" width="40.0" x="710.0" y="110.0"></omgdc:Bounds>
          </bpmndi:BPMNShape>
          <bpmndi:BPMNShape bpmnElement="COMP_FAIL_EXCL_GATEWAY_CLOSE_REVIEW_DEF_KEY" id="BPMNShape_COMP_FAIL_EXCL_GATEWAY_CLOSE_REVIEW_DEF_KEY">
            <omgdc:Bounds height="40.0" width="40.0" x="1670.0" y="150.0"></omgdc:Bounds>
          </bpmndi:BPMNShape>
          <bpmndi:BPMNShape bpmnElement="COMP_FAIL_TASK_FEEDBACK" id="BPMNShape_COMP_FAIL_TASK_FEEDBACK">
            <omgdc:Bounds height="60.0" width="100.0" x="1760.0" y="150.0"></omgdc:Bounds>
          </bpmndi:BPMNShape>
          <bpmndi:BPMNShape bpmnElement="COMP_FAIL_EXCL_GATEWAY_CONTACT_REVIEW_DEF_KEY" id="BPMNShape_COMP_FAIL_EXCL_GATEWAY_CONTACT_REVIEW_DEF_KEY">
            <omgdc:Bounds height="40.0" width="40.0" x="470.0" y="210.0"></omgdc:Bounds>
          </bpmndi:BPMNShape>
          <bpmndi:BPMNShape bpmnElement="COMP_FAIL_EXCL_GATEWAY_APPLICATION_DEF_KEY" id="BPMNShape_COMP_FAIL_EXCL_GATEWAY_APPLICATION_DEF_KEY">
            <omgdc:Bounds height="40.0" width="40.0" x="230.0" y="60.0"></omgdc:Bounds>
          </bpmndi:BPMNShape>
          <bpmndi:BPMNShape bpmnElement="COMP_FAIL_TASK_ML_REVIEW" id="BPMNShape_COMP_FAIL_TASK_ML_REVIEW">
            <omgdc:Bounds height="60.0" width="100.0" x="1280.0" y="100.0"></omgdc:Bounds>
          </bpmndi:BPMNShape>
          <bpmndi:BPMNShape bpmnElement="COMP_FAIL_TASK_CLOSE_REVIEW" id="BPMNShape_COMP_FAIL_TASK_CLOSE_REVIEW">
            <omgdc:Bounds height="60.0" width="100.0" x="1520.0" y="200.0"></omgdc:Bounds>
          </bpmndi:BPMNShape>
          <bpmndi:BPMNShape bpmnElement="COMP_FAIL_TASK_CONTACT_REVIEW" id="BPMNShape_COMP_FAIL_TASK_CONTACT_REVIEW">
            <omgdc:Bounds height="60.0" width="100.0" x="320.0" y="100.0"></omgdc:Bounds>
          </bpmndi:BPMNShape>
          <bpmndi:BPMNShape bpmnElement="COMP_FAIL_TASK_ANALYSIS" id="BPMNShape_COMP_FAIL_TASK_ANALYSIS">
            <omgdc:Bounds height="60.0" width="100.0" x="560.0" y="200.0"></omgdc:Bounds>
          </bpmndi:BPMNShape>
          <bpmndi:BPMNShape bpmnElement="COMP_FAIL_EXCL_GATEWAY_ML_REVIEW_DEF_KEY" id="BPMNShape_COMP_FAIL_EXCL_GATEWAY_ML_REVIEW_DEF_KEY">
            <omgdc:Bounds height="40.0" width="40.0" x="1430.0" y="210.0"></omgdc:Bounds>
          </bpmndi:BPMNShape>
          <bpmndi:BPMNShape bpmnElement="COMP_FAIL_EXCL_GATEWAY_RISK_DEF_KEY" id="BPMNShape_COMP_FAIL_EXCL_GATEWAY_RISK_DEF_KEY">
            <omgdc:Bounds height="40.0" width="40.0" x="950.0" y="210.0"></omgdc:Bounds>
          </bpmndi:BPMNShape>
          <bpmndi:BPMNShape bpmnElement="end" id="BPMNShape_end">
            <omgdc:Bounds height="30.0" width="30.0" x="1910.0" y="100.0"></omgdc:Bounds>
          </bpmndi:BPMNShape>
          <bpmndi:BPMNShape bpmnElement="COMP_FAIL_TASK_PM_REVIEW" id="BPMNShape_COMP_FAIL_TASK_PM_REVIEW">
            <omgdc:Bounds height="60.0" width="100.0" x="1040.0" y="200.0"></omgdc:Bounds>
          </bpmndi:BPMNShape>
          <bpmndi:BPMNShape bpmnElement="COMP_FAIL_TASK_APPLICATION" id="BPMNShape_COMP_FAIL_TASK_APPLICATION">
            <omgdc:Bounds height="60.0" width="100.0" x="80.0" y="108.0"></omgdc:Bounds>
          </bpmndi:BPMNShape>
          <bpmndi:BPMNEdge bpmnElement="sequenceFlow-cc7c2ba4-68ea-4481-82d7-51d7ead0ca65" id="BPMNEdge_sequenceFlow-cc7c2ba4-68ea-4481-82d7-51d7ead0ca65">
            <omgdi:waypoint x="900.0" y="142.5"></omgdi:waypoint>
            <omgdi:waypoint x="912.0" y="142.5"></omgdi:waypoint>
            <omgdi:waypoint x="912.0" y="230.0"></omgdi:waypoint>
            <omgdi:waypoint x="950.0" y="230.0"></omgdi:waypoint>
          </bpmndi:BPMNEdge>
          <bpmndi:BPMNEdge bpmnElement="sequenceFlow-ffcbf3ae-08f3-469a-8d61-263b2ed4c060" id="BPMNEdge_sequenceFlow-ffcbf3ae-08f3-469a-8d61-263b2ed4c060">
            <omgdi:waypoint x="1190.0" y="122.5"></omgdi:waypoint>
            <omgdi:waypoint x="1178.0" y="122.5"></omgdi:waypoint>
            <omgdi:waypoint x="1178.0" y="130.0"></omgdi:waypoint>
            <omgdi:waypoint x="800.0" y="130.0"></omgdi:waypoint>
          </bpmndi:BPMNEdge>
          <bpmndi:BPMNEdge bpmnElement="sequenceFlow-627920df-9548-4c0e-8885-24de425aabb5" id="BPMNEdge_sequenceFlow-627920df-9548-4c0e-8885-24de425aabb5">
            <omgdi:waypoint x="1380.0" y="142.5"></omgdi:waypoint>
            <omgdi:waypoint x="1392.0" y="142.5"></omgdi:waypoint>
            <omgdi:waypoint x="1392.0" y="230.0"></omgdi:waypoint>
            <omgdi:waypoint x="1430.0" y="230.0"></omgdi:waypoint>
          </bpmndi:BPMNEdge>
          <bpmndi:BPMNEdge bpmnElement="sequenceFlow-555ca10e-8b0a-45a9-b912-7a2aed7fde59" id="BPMNEdge_sequenceFlow-555ca10e-8b0a-45a9-b912-7a2aed7fde59">
            <omgdi:waypoint x="1710.0" y="170.0"></omgdi:waypoint>
            <omgdi:waypoint x="1722.0" y="170.0"></omgdi:waypoint>
            <omgdi:waypoint x="1722.0" y="180.0"></omgdi:waypoint>
            <omgdi:waypoint x="1760.0" y="180.0"></omgdi:waypoint>
          </bpmndi:BPMNEdge>
          <bpmndi:BPMNEdge bpmnElement="sequenceFlow-687cdeb3-5dd1-449b-be05-1002a23289b3" id="BPMNEdge_sequenceFlow-687cdeb3-5dd1-449b-be05-1002a23289b3">
            <omgdi:waypoint x="180.0" y="125.5"></omgdi:waypoint>
            <omgdi:waypoint x="192.0" y="125.5"></omgdi:waypoint>
            <omgdi:waypoint x="192.0" y="80.0"></omgdi:waypoint>
            <omgdi:waypoint x="230.0" y="80.0"></omgdi:waypoint>
          </bpmndi:BPMNEdge>
          <bpmndi:BPMNEdge bpmnElement="sequenceFlow-4765a5bb-3156-41a5-8285-e409601f13ae" id="BPMNEdge_sequenceFlow-4765a5bb-3156-41a5-8285-e409601f13ae">
            <omgdi:waypoint x="420.0" y="142.5"></omgdi:waypoint>
            <omgdi:waypoint x="432.0" y="142.5"></omgdi:waypoint>
            <omgdi:waypoint x="432.0" y="230.0"></omgdi:waypoint>
            <omgdi:waypoint x="470.0" y="230.0"></omgdi:waypoint>
          </bpmndi:BPMNEdge>
          <bpmndi:BPMNEdge bpmnElement="sequenceFlow-3cce8ca5-5a47-4733-87ae-3ab6718c0a3a" id="BPMNEdge_sequenceFlow-3cce8ca5-5a47-4733-87ae-3ab6718c0a3a">
            <omgdi:waypoint x="990.0" y="230.0"></omgdi:waypoint>
            <omgdi:waypoint x="1040.0" y="230.0"></omgdi:waypoint>
          </bpmndi:BPMNEdge>
          <bpmndi:BPMNEdge bpmnElement="sequenceFlow-5f567ea0-02ce-4e8d-b08d-f884388a88be" id="BPMNEdge_sequenceFlow-5f567ea0-02ce-4e8d-b08d-f884388a88be">
            <omgdi:waypoint x="270.0" y="72.5"></omgdi:waypoint>
            <omgdi:waypoint x="282.0" y="72.5"></omgdi:waypoint>
            <omgdi:waypoint x="282.0" y="115.0"></omgdi:waypoint>
            <omgdi:waypoint x="1910.0" y="115.0"></omgdi:waypoint>
          </bpmndi:BPMNEdge>
          <bpmndi:BPMNEdge bpmnElement="sequenceFlow-a14fbb1c-8087-483f-82e6-ccb0a0f53102" id="BPMNEdge_sequenceFlow-a14fbb1c-8087-483f-82e6-ccb0a0f53102">
            <omgdi:waypoint x="1430.0" y="237.5"></omgdi:waypoint>
            <omgdi:waypoint x="1418.0" y="237.5"></omgdi:waypoint>
            <omgdi:waypoint x="1418.0" y="230.0"></omgdi:waypoint>
            <omgdi:waypoint x="1040.0" y="230.0"></omgdi:waypoint>
          </bpmndi:BPMNEdge>
          <bpmndi:BPMNEdge bpmnElement="sequenceFlow-2dd3ceb3-dd78-46a1-9071-f3b0afc57687" id="BPMNEdge_sequenceFlow-2dd3ceb3-dd78-46a1-9071-f3b0afc57687">
            <omgdi:waypoint x="1470.0" y="230.0"></omgdi:waypoint>
            <omgdi:waypoint x="1520.0" y="230.0"></omgdi:waypoint>
          </bpmndi:BPMNEdge>
          <bpmndi:BPMNEdge bpmnElement="sequenceFlow-fd7f68c7-000f-4c55-a645-aef8d8556cc4" id="BPMNEdge_sequenceFlow-fd7f68c7-000f-4c55-a645-aef8d8556cc4">
            <omgdi:waypoint x="510.0" y="230.0"></omgdi:waypoint>
            <omgdi:waypoint x="560.0" y="230.0"></omgdi:waypoint>
          </bpmndi:BPMNEdge>
          <bpmndi:BPMNEdge bpmnElement="sequenceFlow-a4c486eb-003f-448c-bcea-a9d52c885dd4" id="BPMNEdge_sequenceFlow-a4c486eb-003f-448c-bcea-a9d52c885dd4">
            <omgdi:waypoint x="710.0" y="122.5"></omgdi:waypoint>
            <omgdi:waypoint x="698.0" y="122.5"></omgdi:waypoint>
            <omgdi:waypoint x="698.0" y="130.0"></omgdi:waypoint>
            <omgdi:waypoint x="320.0" y="130.0"></omgdi:waypoint>
          </bpmndi:BPMNEdge>
          <bpmndi:BPMNEdge bpmnElement="sequenceFlow-4e4edef1-d382-4ad8-ad65-3e1fb13b7d65" id="BPMNEdge_sequenceFlow-4e4edef1-d382-4ad8-ad65-3e1fb13b7d65">
            <omgdi:waypoint x="1860.0" y="180.0"></omgdi:waypoint>
            <omgdi:waypoint x="1872.0" y="180.0"></omgdi:waypoint>
            <omgdi:waypoint x="1872.0" y="115.0"></omgdi:waypoint>
            <omgdi:waypoint x="1910.0" y="115.0"></omgdi:waypoint>
          </bpmndi:BPMNEdge>
          <bpmndi:BPMNEdge bpmnElement="sequenceFlow-7dc193e2-ff59-4cde-836a-9be05f8c51de" id="BPMNEdge_sequenceFlow-7dc193e2-ff59-4cde-836a-9be05f8c51de">
            <omgdi:waypoint x="1230.0" y="130.0"></omgdi:waypoint>
            <omgdi:waypoint x="1280.0" y="130.0"></omgdi:waypoint>
          </bpmndi:BPMNEdge>
          <bpmndi:BPMNEdge bpmnElement="sequenceFlow-f4dca2a6-3d2e-463f-9c31-22d74572e970" id="BPMNEdge_sequenceFlow-f4dca2a6-3d2e-463f-9c31-22d74572e970">
            <omgdi:waypoint x="470.0" y="237.5"></omgdi:waypoint>
            <omgdi:waypoint x="458.0" y="237.5"></omgdi:waypoint>
            <omgdi:waypoint x="458.0" y="138.0"></omgdi:waypoint>
            <omgdi:waypoint x="80.0" y="138.0"></omgdi:waypoint>
          </bpmndi:BPMNEdge>
          <bpmndi:BPMNEdge bpmnElement="sequenceFlow-ea95d696-e932-4528-8f0c-131f46ccbab9" id="BPMNEdge_sequenceFlow-ea95d696-e932-4528-8f0c-131f46ccbab9">
            <omgdi:waypoint x="1140.0" y="217.5"></omgdi:waypoint>
            <omgdi:waypoint x="1152.0" y="217.5"></omgdi:waypoint>
            <omgdi:waypoint x="1152.0" y="130.0"></omgdi:waypoint>
            <omgdi:waypoint x="1190.0" y="130.0"></omgdi:waypoint>
          </bpmndi:BPMNEdge>
          <bpmndi:BPMNEdge bpmnElement="sequenceFlow-81734467-b00d-4f0b-b7a2-7d3caabc56ee" id="BPMNEdge_sequenceFlow-81734467-b00d-4f0b-b7a2-7d3caabc56ee">
            <omgdi:waypoint x="1670.0" y="162.5"></omgdi:waypoint>
            <omgdi:waypoint x="1658.0" y="162.5"></omgdi:waypoint>
            <omgdi:waypoint x="1658.0" y="130.0"></omgdi:waypoint>
            <omgdi:waypoint x="1280.0" y="130.0"></omgdi:waypoint>
          </bpmndi:BPMNEdge>
          <bpmndi:BPMNEdge bpmnElement="sequenceFlow-cc8e14fa-bc92-48fb-aab1-ec4263dfe04a" id="BPMNEdge_sequenceFlow-cc8e14fa-bc92-48fb-aab1-ec4263dfe04a">
            <omgdi:waypoint x="30.0" y="138.0"></omgdi:waypoint>
            <omgdi:waypoint x="80.0" y="138.0"></omgdi:waypoint>
          </bpmndi:BPMNEdge>
          <bpmndi:BPMNEdge bpmnElement="sequenceFlow-ffb442cc-605a-418e-b5c7-5f2d0a0d7c01" id="BPMNEdge_sequenceFlow-ffb442cc-605a-418e-b5c7-5f2d0a0d7c01">
            <omgdi:waypoint x="1620.0" y="230.0"></omgdi:waypoint>
            <omgdi:waypoint x="1632.0" y="230.0"></omgdi:waypoint>
            <omgdi:waypoint x="1632.0" y="170.0"></omgdi:waypoint>
            <omgdi:waypoint x="1670.0" y="170.0"></omgdi:waypoint>
          </bpmndi:BPMNEdge>
          <bpmndi:BPMNEdge bpmnElement="sequenceFlow-1cec0e0f-7c6b-4b3d-8937-917481f82759" id="BPMNEdge_sequenceFlow-1cec0e0f-7c6b-4b3d-8937-917481f82759">
            <omgdi:waypoint x="270.0" y="87.5"></omgdi:waypoint>
            <omgdi:waypoint x="282.0" y="87.5"></omgdi:waypoint>
            <omgdi:waypoint x="282.0" y="130.0"></omgdi:waypoint>
            <omgdi:waypoint x="320.0" y="130.0"></omgdi:waypoint>
          </bpmndi:BPMNEdge>
          <bpmndi:BPMNEdge bpmnElement="sequenceFlow-76fbde23-c91c-4911-b3ee-a0eea4643371" id="BPMNEdge_sequenceFlow-76fbde23-c91c-4911-b3ee-a0eea4643371">
            <omgdi:waypoint x="660.0" y="217.5"></omgdi:waypoint>
            <omgdi:waypoint x="672.0" y="217.5"></omgdi:waypoint>
            <omgdi:waypoint x="672.0" y="130.0"></omgdi:waypoint>
            <omgdi:waypoint x="710.0" y="130.0"></omgdi:waypoint>
          </bpmndi:BPMNEdge>
          <bpmndi:BPMNEdge bpmnElement="sequenceFlow-cb4c7a54-524c-4587-bc72-6bc375ed0954" id="BPMNEdge_sequenceFlow-cb4c7a54-524c-4587-bc72-6bc375ed0954">
            <omgdi:waypoint x="950.0" y="237.5"></omgdi:waypoint>
            <omgdi:waypoint x="938.0" y="237.5"></omgdi:waypoint>
            <omgdi:waypoint x="938.0" y="230.0"></omgdi:waypoint>
            <omgdi:waypoint x="560.0" y="230.0"></omgdi:waypoint>
          </bpmndi:BPMNEdge>
          <bpmndi:BPMNEdge bpmnElement="sequenceFlow-97acf8b0-d186-4c28-9355-323b728ae768" id="BPMNEdge_sequenceFlow-97acf8b0-d186-4c28-9355-323b728ae768">
            <omgdi:waypoint x="750.0" y="130.0"></omgdi:waypoint>
            <omgdi:waypoint x="800.0" y="130.0"></omgdi:waypoint>
          </bpmndi:BPMNEdge>
        </bpmndi:BPMNPlane>
      </bpmndi:BPMNDiagram>
    </bpmn2:definitions>

####  ####

#### 2. 流程图 ####

![4ac980748dab4b63b7f90993676ed9b0.png][]

### 网关 ###

>  *  从流程图中可以看出，我们每个节点流向都会先设定一个网关，用来判断流程走向，是成功，接着往下个任务走，还是失败，倒回某个节点，或者直接就到结束事件

**这里我们针对该流程进行举例：**

*  第一个子任务结束后，flow流就指向 排他网关， 那么在该子任务完成时，我们在程序代码中就可以设置对应的一个变量值，通过排他网关的下个流flow, 在 flow condition参数设置条件，动态表达式，比较灵活 ： $\{COMP\_FAIL\_GATEWAY\_CONDITION\_APPLICATION == true\} 那么我们就可以设置变量的值为true 或者 false, 前者，变成子任务完成，正常流向下个子任务，后者则是直接指向 结束事件
 *  具体的 flow condition 设置情况，根据业务流程来调整，该流程的多个排他网关，用法都一致，都是通过布尔值判断流程走向哪个子任务节点
 *  注意：设置条件，是在flow流箭头组件设置的

![7d47a22dd0f84d8eb53eb6a102837da6.png][]

![a5f65ec866c742ea863c8f4f804c924e.png][]

### Assignment 分配人 ###

*  $\{COMP\_FAIL\_TASK\_APPLICATION\_ASSIGNEE\} 这里设置的是子任务对应的分配责任人，也就是对应的委托人
 *  这里按照当前的经验，我们一般都是在前一个任务在提交完成的时候，设置一个全局变量，这里全局主要是整个流程都可能会共用到变量，所以用全局变量， 设置的变量，会包含我们下个任务的 分配人对应的员工信息， 以及排他网关的条件变量值
 *  创建实例时 同步变量设置：var是一个map集合，具体可以看下面实现类代码
    
        Map<String, Object> var
    
        runtimeService.startProcessInstanceByKey(COMP_FAIL_PROCESS_DEF_KEY, var)
 *  比如 我们这个流程，第一步先把流程定义对象创建实例，这里创建的时候，就可以把这里第一个子任务 分析申请 的 assignment变量进行赋值 
 *  流程创建实例后，流程会直接先来到第一个任务节点，而不是在开始事件上。

![78a3fc4e96734f77aa298a237840c47f.png][]![1bb04faf62aa460eaa0cb79a92519b28.png][]

### controller层 ###

package com.service;
    
    import com.model.CompFailAnalysisParam;
    import org.springframework.web.bind.annotation.*;
    import com.model.CompFailContactReviewParam;
    import com.model.CompFailMlReviewParam;
    import com.model.CompFailCreateParam;
    import com.model.CompFailRiskParam;
    import org.springframework.validation.annotation.Validated;
    import com.model.CompFailCloseReviewParam;
    import com.model.CompFailPmReviewParam;
    import com..tools.commonlib.exception.ServiceException;
    import com.model.CompFailApplicationParam;
    import org.springframework.beans.factory.annotation.Autowired;
    import com.model.CompFailFeedbackParam;
    import com.delegate.ProcessCompFailAnalysisDelegate;
    import com.model.OneFaIdParam;
    import com.model.ResponseVo;
    
    
    
    @RestController
    @RequestMapping(value = "/process/compFailAnalysis", produces = {"application/json;charset=UTF-8"})
    @Validated
    public class ProcessCompFailAnalysisController {
    
        @Autowired(required=false) 
        private ProcessCompFailAnalysisDelegate delegate;  
    	
        @RequestMapping(
        		value = "/cancelProcess", 
        		produces = { "application/json" }, 
        		method = RequestMethod.POST)
        public ResponseVo cancelProcess(@RequestBody OneFaIdParam oneRcIdParam) 
                throws ServiceException {
        	    
    		return delegate.cancelProcess(oneRcIdParam);
        }
    
    	
        @RequestMapping(
        		value = "/createCompAnalysisProcess", 
        		produces = { "application/json" }, 
        		method = RequestMethod.POST)
        public ResponseVo createCompAnalysisProcess(@RequestBody CompFailCreateParam compFailCreateParam) 
                throws ServiceException {
        	    
    		return delegate.createCompAnalysisProcess(compFailCreateParam);
        }
    
    	
        @RequestMapping(
        		value = "/draftItemAnalysis", 
        		produces = { "application/json" }, 
        		method = RequestMethod.POST)
        public ResponseVo draftItemAnalysis(@RequestBody CompFailAnalysisParam compFailAnalysisParam) 
                throws ServiceException {
        	    
    		return delegate.draftItemAnalysis(compFailAnalysisParam);
        }
    
    	
        @RequestMapping(
        		value = "/draftItemApplication", 
        		produces = { "application/json" }, 
        		method = RequestMethod.POST)
        public ResponseVo draftItemApplication(@RequestBody CompFailApplicationParam compFailApplicationParam) 
                throws ServiceException {
        	    
    		return delegate.draftItemApplication(compFailApplicationParam);
        }
    
    	
        @RequestMapping(
        		value = "/draftRiskProve", 
        		produces = { "application/json" }, 
        		method = RequestMethod.POST)
        public ResponseVo draftRiskProve(@RequestBody CompFailRiskParam riskParam) 
                throws ServiceException {
        	    
    		return delegate.draftRiskProve(riskParam);
        }
    
    	
        @RequestMapping(
        		value = "/getCheckHistoryProcessList", 
        		produces = { "application/json" }, 
        		method = RequestMethod.GET)
        public ResponseVo getCheckHistoryProcessList( @RequestParam(value = "pageNo", required = true) Integer pageNo,
        		 @RequestParam(value = "pageSize", required = true) Integer pageSize,
        		 @RequestParam(value = "componentCode", required = false) String componentCode) 
                throws ServiceException {
        	    
    		return delegate.getCheckHistoryProcessList(pageNo
    			, pageSize
    			, componentCode);
        }
    
    	
        @RequestMapping(
        		value = "/getCloseCheck", 
        		produces = { "application/json" }, 
        		method = RequestMethod.GET)
        public ResponseVo getCloseCheck( @RequestParam(value = "faId", required = true) String faId) 
                throws ServiceException {
        	    
    		return delegate.getCloseCheck(faId);
        }
    
    	
        @RequestMapping(
        		value = "/getComponentCode", 
        		produces = { "application/json" }, 
        		method = RequestMethod.GET)
        public ResponseVo getComponentCode( @RequestParam(value = "keyword", required = false) String keyword,
        		 @RequestParam(value = "processType", required = true) String processType) 
                throws ServiceException {
        	    
    		return delegate.getComponentCode(keyword
    			, processType);
        }
    
    	
        @RequestMapping(
        		value = "/getContactCheck", 
        		produces = { "application/json" }, 
        		method = RequestMethod.GET)
        public ResponseVo getContactCheck( @RequestParam(value = "faId", required = true) String faId) 
                throws ServiceException {
        	    
    		return delegate.getContactCheck(faId);
        }
    
    	
        @RequestMapping(
        		value = "/getDoingProcessList", 
        		produces = { "application/json" }, 
        		method = RequestMethod.GET)
        public ResponseVo getDoingProcessList( @RequestParam(value = "pageNo", required = true) Integer pageNo,
        		 @RequestParam(value = "pageSize", required = true) Integer pageSize,
        		 @RequestParam(value = "componentCode", required = false) String componentCode) 
                throws ServiceException {
        	    
    		return delegate.getDoingProcessList(pageNo
    			, pageSize
    			, componentCode);
        }
    
    	
        @RequestMapping(
        		value = "/getFeedback", 
        		produces = { "application/json" }, 
        		method = RequestMethod.GET)
        public ResponseVo getFeedback( @RequestParam(value = "faId", required = true) String faId) 
                throws ServiceException {
        	    
    		return delegate.getFeedback(faId);
        }
    
    	
        @RequestMapping(
        		value = "/getHistoryProcessList", 
        		produces = { "application/json" }, 
        		method = RequestMethod.GET)
        public ResponseVo getHistoryProcessList( @RequestParam(value = "pageNo", required = true) Integer pageNo,
        		 @RequestParam(value = "pageSize", required = true) Integer pageSize,
        		 @RequestParam(value = "componentCode", required = false) String componentCode) 
                throws ServiceException {
        	    
    		return delegate.getHistoryProcessList(pageNo
    			, pageSize
    			, componentCode);
        }
    
    	
        @RequestMapping(
        		value = "/getItemAnalysis", 
        		produces = { "application/json" }, 
        		method = RequestMethod.GET)
        public ResponseVo getItemAnalysis( @RequestParam(value = "faId", required = true) String faId) 
                throws ServiceException {
        	    
    		return delegate.getItemAnalysis(faId);
        }
    
    	
        @RequestMapping(
        		value = "/getItemApplication", 
        		produces = { "application/json" }, 
        		method = RequestMethod.GET)
        public ResponseVo getItemApplication( @RequestParam(value = "faId", required = true) String faId) 
                throws ServiceException {
        	    
    		return delegate.getItemApplication(faId);
        }
    
    	
        @RequestMapping(
        		value = "/getMlCheck", 
        		produces = { "application/json" }, 
        		method = RequestMethod.GET)
        public ResponseVo getMlCheck( @RequestParam(value = "faId", required = true) String faId) 
                throws ServiceException {
        	    
    		return delegate.getMlCheck(faId);
        }
    
    	
        @RequestMapping(
        		value = "/getPmCheck", 
        		produces = { "application/json" }, 
        		method = RequestMethod.GET)
        public ResponseVo getPmCheck( @RequestParam(value = "faId", required = true) String faId) 
                throws ServiceException {
        	    
    		return delegate.getPmCheck(faId);
        }
    
    	
        @RequestMapping(
        		value = "/getProcessTitle", 
        		produces = { "application/json" }, 
        		method = RequestMethod.GET)
        public ResponseVo getProcessTitle( @RequestParam(value = "faId", required = true) String faId) 
                throws ServiceException {
        	    
    		return delegate.getProcessTitle(faId);
        }
    
    	
        @RequestMapping(
        		value = "/getRiskProve", 
        		produces = { "application/json" }, 
        		method = RequestMethod.GET)
        public ResponseVo getRiskProve( @RequestParam(value = "faId", required = true) String faId) 
                throws ServiceException {
        	    
    		return delegate.getRiskProve(faId);
        }
    
    	
        @RequestMapping(
        		value = "/getShareProcessList", 
        		produces = { "application/json" }, 
        		method = RequestMethod.GET)
        public ResponseVo getShareProcessList( @RequestParam(value = "pageNo", required = true) Integer pageNo,
        		 @RequestParam(value = "pageSize", required = true) Integer pageSize,
        		 @RequestParam(value = "componentCode", required = false) String componentCode) 
                throws ServiceException {
        	    
    		return delegate.getShareProcessList(pageNo
    			, pageSize
    			, componentCode);
        }
    
    	
        @RequestMapping(
        		value = "/getWaitingProcessList", 
        		produces = { "application/json" }, 
        		method = RequestMethod.GET)
        public ResponseVo getWaitingProcessList( @RequestParam(value = "pageNo", required = true) Integer pageNo,
        		 @RequestParam(value = "pageSize", required = true) Integer pageSize,
        		 @RequestParam(value = "componentCode", required = false) String componentCode) 
                throws ServiceException {
        	    
    		return delegate.getWaitingProcessList(pageNo
    			, pageSize
    			, componentCode);
        }
    
    	
        @RequestMapping(
        		value = "/submitCloseCheck", 
        		produces = { "application/json" }, 
        		method = RequestMethod.POST)
        public ResponseVo submitCloseCheck(@RequestBody CompFailCloseReviewParam riskParam) 
                throws ServiceException {
        	    
    		return delegate.submitCloseCheck(riskParam);
        }
    
    	
        @RequestMapping(
        		value = "/submitContactCheck", 
        		produces = { "application/json" }, 
        		method = RequestMethod.POST)
        public ResponseVo submitContactCheck(@RequestBody CompFailContactReviewParam compFailApplicationParam) 
                throws ServiceException {
        	    
    		return delegate.submitContactCheck(compFailApplicationParam);
        }
    
    	
        @RequestMapping(
        		value = "/submitFeedback", 
        		produces = { "application/json" }, 
        		method = RequestMethod.POST)
        public ResponseVo submitFeedback(@RequestBody CompFailFeedbackParam riskParam) 
                throws ServiceException {
        	    
    		return delegate.submitFeedback(riskParam);
        }
    
    	
        @RequestMapping(
        		value = "/submitItemAnalysis", 
        		produces = { "application/json" }, 
        		method = RequestMethod.POST)
        public ResponseVo submitItemAnalysis(@RequestBody CompFailAnalysisParam compFailAnalysisParam) 
                throws ServiceException {
        	    
    		return delegate.submitItemAnalysis(compFailAnalysisParam);
        }
    
    	
        @RequestMapping(
        		value = "/submitItemApplication", 
        		produces = { "application/json" }, 
        		method = RequestMethod.POST)
        public ResponseVo submitItemApplication(@RequestBody CompFailApplicationParam compFailApplicationParam) 
                throws ServiceException {
        	    
    		return delegate.submitItemApplication(compFailApplicationParam);
        }
    
    	
        @RequestMapping(
        		value = "/submitMlCheck", 
        		produces = { "application/json" }, 
        		method = RequestMethod.POST)
        public ResponseVo submitMlCheck(@RequestBody CompFailMlReviewParam riskParam) 
                throws ServiceException {
        	    
    		return delegate.submitMlCheck(riskParam);
        }
    
    	
        @RequestMapping(
        		value = "/submitPmCheck", 
        		produces = { "application/json" }, 
        		method = RequestMethod.POST)
        public ResponseVo submitPmCheck(@RequestBody CompFailPmReviewParam riskParam) 
                throws ServiceException {
        	    
    		return delegate.submitPmCheck(riskParam);
        }
    
    	
        @RequestMapping(
        		value = "/submitRiskProve", 
        		produces = { "application/json" }, 
        		method = RequestMethod.POST)
        public ResponseVo submitRiskProve(@RequestBody CompFailRiskParam riskParam) 
                throws ServiceException {
        	    
    		return delegate.submitRiskProve(riskParam);
        }
    
    	
        @RequestMapping(
        		value = "/withdrawal", 
        		produces = { "application/json" }, 
        		method = RequestMethod.POST)
        public ResponseVo withdrawal( @RequestParam(value = "faId", required = true) String faId) 
                throws ServiceException {
        	    
    		return delegate.withdrawal(faId);
        }
    }

### service层 接口 ###

package com.delegate;
    
    import com.model.CompFailCloseReviewParam;
    import com.model.CompFailAnalysisParam;
    import com.model.CompFailPmReviewParam;
    import com..tools.commonlib.exception.ServiceException;
    import com.model.CompFailApplicationParam;
    import com.model.CompFailContactReviewParam;
    import com.model.CompFailFeedbackParam;
    import com.model.CompFailMlReviewParam;
    import com.model.CompFailCreateParam;
    import com.model.OneFaIdParam;
    import com.model.ResponseVo;
    import com.model.CompFailRiskParam;
    
    
    
    public interface ProcessCompFailAnalysisDelegate {
      
        ResponseVo cancelProcess(OneFaIdParam oneRcIdParam) 
        	throws ServiceException;
      
        ResponseVo createCompAnalysisProcess(CompFailCreateParam compFailCreateParam) 
        	throws ServiceException;
      
        ResponseVo draftItemAnalysis(CompFailAnalysisParam compFailAnalysisParam) 
        	throws ServiceException;
      
        ResponseVo draftItemApplication(CompFailApplicationParam compFailApplicationParam) 
        	throws ServiceException;
      
        ResponseVo draftRiskProve(CompFailRiskParam riskParam) 
        	throws ServiceException;
      
        ResponseVo getCheckHistoryProcessList(Integer pageNo,
                         Integer pageSize,
                         String componentCode) 
        	throws ServiceException;
      
        ResponseVo getCloseCheck(String faId) 
        	throws ServiceException;
      
        ResponseVo getComponentCode(String keyword,
                         String processType) 
        	throws ServiceException;
      
        ResponseVo getContactCheck(String faId) 
        	throws ServiceException;
      
        ResponseVo getDoingProcessList(Integer pageNo,
                         Integer pageSize,
                         String componentCode) 
        	throws ServiceException;
      
        ResponseVo getFeedback(String faId) 
        	throws ServiceException;
      
        ResponseVo getHistoryProcessList(Integer pageNo,
                         Integer pageSize,
                         String componentCode) 
        	throws ServiceException;
      
        ResponseVo getItemAnalysis(String faId) 
        	throws ServiceException;
      
        ResponseVo getItemApplication(String faId) 
        	throws ServiceException;
      
        ResponseVo getMlCheck(String faId) 
        	throws ServiceException;
      
        ResponseVo getPmCheck(String faId) 
        	throws ServiceException;
      
        ResponseVo getProcessTitle(String faId) 
        	throws ServiceException;
      
        ResponseVo getRiskProve(String faId) 
        	throws ServiceException;
      
        ResponseVo getShareProcessList(Integer pageNo,
                         Integer pageSize,
                         String componentCode) 
        	throws ServiceException;
      
        ResponseVo getWaitingProcessList(Integer pageNo,
                         Integer pageSize,
                         String componentCode) 
        	throws ServiceException;
      
        ResponseVo submitCloseCheck(CompFailCloseReviewParam riskParam) 
        	throws ServiceException;
      
        ResponseVo submitContactCheck(CompFailContactReviewParam compFailApplicationParam) 
        	throws ServiceException;
      
        ResponseVo submitFeedback(CompFailFeedbackParam riskParam) 
        	throws ServiceException;
      
        ResponseVo submitItemAnalysis(CompFailAnalysisParam compFailAnalysisParam) 
        	throws ServiceException;
      
        ResponseVo submitItemApplication(CompFailApplicationParam compFailApplicationParam) 
        	throws ServiceException;
      
        ResponseVo submitMlCheck(CompFailMlReviewParam riskParam) 
        	throws ServiceException;
      
        ResponseVo submitPmCheck(CompFailPmReviewParam riskParam) 
        	throws ServiceException;
      
        ResponseVo submitRiskProve(CompFailRiskParam riskParam) 
        	throws ServiceException;
      
        ResponseVo withdrawal(String faId) 
        	throws ServiceException;
      
    }

### service 层 接口实现类 ###

package com.impl.process;
    
    import com.delegate.ProcessCompFailAnalysisDelegate;
    import com.model.CompFailAnalysisParam;
    import com.model.CompFailApplicationParam;
    import com.model.CompFailCloseReviewParam;
    import com.model.CompFailContactReviewParam;
    import com.model.CompFailCreateParam;
    import com.model.CompFailFeedbackParam;
    import com.model.CompFailMlReviewParam;
    import com.model.CompFailPmReviewParam;
    import com.model.CompFailRiskParam;
    import com.model.OneFaIdParam;
    import com.model.ResponseVo;
    import com.domain.entity.VerifyInfo;
    import com.domain.vo.process.CompFailTitleVo;
    import com.service.process.ProcessCompFailService;
    import com.utils.ResponseUtils;
    
    import org.springframework.stereotype.Service;
    
    import javax.annotation.Resource;
    
    /**
     * ProcessCompFailAnalysisDelegateImpl
     *
     */
    @Service
    public class ProcessCompFailAnalysisDelegateImpl implements ProcessCompFailAnalysisDelegate {
        @Resource
        private ProcessCompFailService processCompFailService;
    
    
        /**
         * cancelProcess
         * 
         * @param oneFaIdParam oneFaIdParam
         * @return ResponseVo
         */
        @Override
        public ResponseVo cancelProcess(OneFaIdParam oneFaIdParam) {
            VerifyInfo verifyInfo = processCompFailService.cancelProcess(oneFaIdParam);
            return verifyInfo.isPass()
                ? ResponseUtils.successResponse(verifyInfo.getMessage())
                : ResponseUtils.errorResponse(verifyInfo.getMessage());
        }
    
    
        /**
         * createCompAnalysisProcess
         * 
         * @param compFailCreateParam compFailCreateParam
         * @return ResponseVo
         */
        @Override
        public ResponseVo createCompAnalysisProcess(CompFailCreateParam compFailCreateParam) {
            VerifyInfo verifyInfo = processCompFailService.createProcessInst(compFailCreateParam);
            return verifyInfo.isPass()
                ? ResponseUtils.successResponse(verifyInfo.getMessage())
                : ResponseUtils.errorResponse(verifyInfo.getMessage());
        }
    
    
        /**
         * getProcessTitle
         * 
         * @param faId faId
         * @return ResponseVo
         */
        @Override
        public ResponseVo getProcessTitle(String faId) {
            CompFailTitleVo processTitle = processCompFailService.getProcessTitle(faId);
            if (processTitle == null) {
                return ResponseUtils.errorResponse("获取流程Title失败，可能原因是无权限访问该流程");
            }
            return ResponseUtils.successResponse(processTitle, "获取信息成功");
        }
    
    
        /**
         * submitItemApplication
         * 
         * @param compFailApplicationParam compFailApplicationParam
         * @return ResponseVo
         */
        @Override
        public ResponseVo submitItemApplication(CompFailApplicationParam compFailApplicationParam) {
            VerifyInfo verifyInfo = processCompFailService.submitApplication(compFailApplicationParam);
            return verifyInfo.isPass()
                ? ResponseUtils.successResponse(verifyInfo.getMessage())
                : ResponseUtils.errorResponse(verifyInfo.getMessage());
        }
    
    
        /**
         * draftItemApplication
         * 
         * @param compFailApplicationParam compFailApplicationParam
         * @return ResponseVo
         */
        @Override
        public ResponseVo draftItemApplication(CompFailApplicationParam compFailApplicationParam) {
            VerifyInfo verifyInfo = processCompFailService.draftApplication(compFailApplicationParam);
            return verifyInfo.isPass()
                ? ResponseUtils.successResponse(verifyInfo.getMessage())
                : ResponseUtils.errorResponse(verifyInfo.getMessage());
        }
    
    
        /**
         * getItemApplication
         * 
         * @param faId faId
         * @return ResponseVo
         */
        @Override
        public ResponseVo getItemApplication(String faId) {
            return ResponseUtils.successResponse(processCompFailService.getApplication(faId), "获取信息成功");
        }
    
    
        /**
         * submitContactCheck
         * 
         * @param contactReviewParam contactReviewParam
         * @return ResponseVo
         */
        @Override
        public ResponseVo submitContactCheck(CompFailContactReviewParam contactReviewParam) {
            VerifyInfo verifyInfo = processCompFailService.submitContactReview(contactReviewParam);
            return verifyInfo.isPass()
                ? ResponseUtils.successResponse(verifyInfo.getMessage())
                : ResponseUtils.errorResponse(verifyInfo.getMessage());
        }
    
    
        /**
         * getContactCheck
         * 
         * @param faId faId
         * @return ResponseVo
         */
        @Override
        public ResponseVo getContactCheck(String faId) {
            return ResponseUtils.successResponse(processCompFailService.getContactReview(faId), "获取信息成功");
        }
    
    
        /**
         * submitItemAnalysis
         * 
         * @param compFailAnalysisParam compFailAnalysisParam
         * @return ResponseVo
         */
        @Override
        public ResponseVo submitItemAnalysis(CompFailAnalysisParam compFailAnalysisParam) {
            VerifyInfo verifyInfo = processCompFailService.submitAnalysis(compFailAnalysisParam);
            return verifyInfo.isPass()
                ? ResponseUtils.successResponse(verifyInfo.getMessage())
                : ResponseUtils.errorResponse(verifyInfo.getMessage());
        }
    
    
        /**
         * draftItemAnalysis
         * 
         * @param compFailAnalysisParam compFailAnalysisParam
         * @return ResponseVo
         */
        @Override
        public ResponseVo draftItemAnalysis(CompFailAnalysisParam compFailAnalysisParam) {
            VerifyInfo verifyInfo = processCompFailService.draftAnalysis(compFailAnalysisParam);
            return verifyInfo.isPass()
                ? ResponseUtils.successResponse(verifyInfo.getMessage())
                : ResponseUtils.errorResponse(verifyInfo.getMessage());
        }
    
    
        /**
         * getItemAnalysis
         * 
         * @param faId faId
         * @return ResponseVo
         */
        @Override
        public ResponseVo getItemAnalysis(String faId) {
            return ResponseUtils.successResponse(processCompFailService.getAnalysis(faId), "获取信息成功");
        }
    
    
        /**
         * submitRiskProve
         * 
         * @param riskParam riskParam
         * @return ResponseVo
         */
        @Override
        public ResponseVo submitRiskProve(CompFailRiskParam riskParam) {
            VerifyInfo verifyInfo = processCompFailService.submitRisk(riskParam);
            return verifyInfo.isPass()
                ? ResponseUtils.successResponse(verifyInfo.getMessage())
                : ResponseUtils.errorResponse(verifyInfo.getMessage());
        }
    
    
        /**
         * withdrawal
         * 
         * @param faId faId
         * @return ResponseVo
         */
        @Override
        public ResponseVo withdrawal(String faId) {
            VerifyInfo verifyInfo = processCompFailService.withdrawApplication(faId);
            return verifyInfo.isPass()
                ? ResponseUtils.successResponse(verifyInfo.getMessage())
                : ResponseUtils.errorResponse(verifyInfo.getMessage());
        }
    
    
        /**
         * draftRiskProve
         * 
         * @param riskParam riskParam
         * @return ResponseVo
         */
        @Override
        public ResponseVo draftRiskProve(CompFailRiskParam riskParam) {
            VerifyInfo verifyInfo = processCompFailService.draftRisk(riskParam);
            return verifyInfo.isPass()
                ? ResponseUtils.successResponse(verifyInfo.getMessage())
                : ResponseUtils.errorResponse(verifyInfo.getMessage());
        }
    
    
        /**
         * getRiskProve
         * 
         * @param faId faId
         * @return ResponseVo
         */
        @Override
        public ResponseVo getRiskProve(String faId) {
            return ResponseUtils.successResponse(processCompFailService.getRisk(faId), "获取信息成功");
        }
    
    
        /**
         * submitPmCheck
         * 
         * @param riskParam riskParam
         * @return ResponseVo
         */
        @Override
        public ResponseVo submitPmCheck(CompFailPmReviewParam riskParam) {
            VerifyInfo verifyInfo = processCompFailService.submitPmReview(riskParam);
            return verifyInfo.isPass()
                ? ResponseUtils.successResponse(verifyInfo.getMessage())
                : ResponseUtils.errorResponse(verifyInfo.getMessage());
        }
    
    
        /**
         * getPmCheck
         * 
         * @param faId faId
         * @return ResponseVo
         */
        @Override
        public ResponseVo getPmCheck(String faId) {
            return ResponseUtils.successResponse(processCompFailService.getPmReview(faId), "获取信息成功");
        }
    
    
        /**
         * submitMlCheck
         * 
         * @param riskParam riskParam
         * @return ResponseVo
         */
        @Override
        public ResponseVo submitMlCheck(CompFailMlReviewParam riskParam) {
            VerifyInfo verifyInfo = processCompFailService.submitMlReview(riskParam);
            return verifyInfo.isPass()
                ? ResponseUtils.successResponse(verifyInfo.getMessage())
                : ResponseUtils.errorResponse(verifyInfo.getMessage());
        }
    
    
        /**
         * getMlCheck
         * 
         * @param faId faId
         * @return ResponseVo
         */
        @Override
        public ResponseVo getMlCheck(String faId) {
            return ResponseUtils.successResponse(processCompFailService.getMlReview(faId), "获取信息成功");
        }
    
    
        /**
         * submitCloseCheck
         * 
         * @param riskParam riskParam
         * @return ResponseVo
         */
        @Override
        public ResponseVo submitCloseCheck(CompFailCloseReviewParam riskParam) {
            VerifyInfo verifyInfo = processCompFailService.submitCloseReview(riskParam);
            return verifyInfo.isPass()
                ? ResponseUtils.successResponse(verifyInfo.getMessage())
                : ResponseUtils.errorResponse(verifyInfo.getMessage());
        }
    
        /**
         * getCloseCheck
         * 
         * @param faId faId
         * @return ResponseVo
         */
        @Override
        public ResponseVo getCloseCheck(String faId) {
            return ResponseUtils.successResponse(processCompFailService.getCloseReview(faId), "获取信息成功");
        }
    
    
        /**
         * submitFeedback
         * 
         * @param riskParam riskParam
         * @return ResponseVo
         */
        @Override
        public ResponseVo submitFeedback(CompFailFeedbackParam riskParam) {
            VerifyInfo verifyInfo = processCompFailService.submitFeedback(riskParam);
            return verifyInfo.isPass()
                ? ResponseUtils.successResponse(verifyInfo.getMessage())
                : ResponseUtils.errorResponse(verifyInfo.getMessage());
        }
    
    
        /**
         * getFeedback
         * 
         * @param faId faId
         * @return ResponseVo
         */
        @Override
        public ResponseVo getFeedback(String faId) {
            return ResponseUtils.successResponse(processCompFailService.getFeedback(faId), "获取信息成功");
        }
    
    
        /**
         * getWaitingProcessList
         * 
         * @param pageNo pageNo
         * @param pageSize pageSize
         * @param componentCode componentCode
         * @return ResponseVo
         */
        @Override
        public ResponseVo getWaitingProcessList(Integer pageNo, Integer pageSize, String componentCode) {
            return processCompFailService.getWaitingProcessList(pageNo, pageSize, componentCode);
        }
    
    
        /**
         * getDoingProcessList
         * 
         * @param pageNo pageNo
         * @param pageSize pageSize
         * @param componentCode componentCode
         * @return ResponseVo
         */
        @Override
        public ResponseVo getDoingProcessList(Integer pageNo, Integer pageSize, String componentCode) {
            return processCompFailService.getDoingProcessList(pageNo, pageSize, componentCode);
        }
    
    
        /**
         * getHistoryProcessList
         * 
         * @param pageNo pageNo
         * @param pageSize pageSize
         * @param componentCode componentCode
         * @return ResponseVo
         */
        @Override
        public ResponseVo getHistoryProcessList(Integer pageNo, Integer pageSize, String componentCode) {
            return processCompFailService.getHistoryProcessList(pageNo, pageSize, componentCode);
        }
    
        /**
         * getCheckHistoryProcessList
         * 
         * @param pageNo pageNo
         * @param pageSize pageSize
         * @param componentCode componentCode
         * @return ResponseVo
         */
        @Override
        public ResponseVo getCheckHistoryProcessList(Integer pageNo, Integer pageSize, String componentCode) {
            return processCompFailService.getCheckHistoryProcessList(pageNo, pageSize, componentCode);
        }
    
    
        /**
         * getShareProcessList
         * 
         * @param pageNo pageNo
         * @param pageSize pageSize
         * @param componentCode componentCode
         * @return ResponseVo
         */
        @Override
        public ResponseVo getShareProcessList(Integer pageNo, Integer pageSize, String componentCode) {
            return processCompFailService.getShareProcessList(pageNo, pageSize, componentCode);
        }
    
    
        /**
         * getComponentCode
         * 
         * @param keyword keyword
         * @param processType processType
         * @return ResponseVo
         */
        @Override
        public ResponseVo getComponentCode(String keyword, String processType) {
            return ResponseUtils.successResponse(processCompFailService.getComponentCode(keyword, processType), "");
        }
    }

### service层 电子流分析服务接口 ###

package com.service.process;
    
    import com.model.*;
    import com.domain.entity.VerifyInfo;
    import com.domain.vo.process.CompFailTitleVo;
    
    import java.util.Collection;
    
    /**
     * 失效分析服务
     *
     */
    public interface ProcessCompFailService {
    
        /**
         * 创建流程实例
         *
         * @param createParam createParam
         * @return VerifyInfo
         */
        VerifyInfo createProcessInst(CompFailCreateParam createParam);
    
        /**
         * 用户撤销电子流
         *
         * @param oneFaIdParam oneFaIdParam
         * @return VerifyInfo
         */
        VerifyInfo cancelProcess(OneFaIdParam oneFaIdParam);
    
        /**
         * 获取流程标题
         *
         * @param businessId businessId
         * @return CompFailTitleVo
         */
        CompFailTitleVo getProcessTitle(String businessId);
    
        /**
         * 提交申请
         *
         * @param applicationParam applicationParam
         * @return VerifyInfo
         */
        VerifyInfo submitApplication(CompFailApplicationParam applicationParam);
    
        /**
         * 申请提交后，申请人撤销申请
         *
         * @param faId faId
         * @return VerifyInfo
         */
        VerifyInfo withdrawApplication(String faId);
    
        /**
         * 保存申请草稿
         *
         * @param applicationParam applicationParam
         * @return VerifyInfo
         */
        VerifyInfo draftApplication(CompFailApplicationParam applicationParam);
    
        /**
         * 获取申请信息
         *
         * @param faId faId
         * @return CompFailApplicationParam
         */
        CompFailApplicationParam getApplication(String faId);
    
        /**
         * 提交接口人审核
         *
         * @param contactReviewParam contactReviewParam
         * @return VerifyInfo
         */
        VerifyInfo submitContactReview(CompFailContactReviewParam contactReviewParam);
    
        /**
         * 获取接口人审核信息
         *
         * @param faId faId
         * @return CompFailContactReviewParam
         */
        CompFailContactReviewParam getContactReview(String faId);
    
    
        /**
         * 提交分析
         *
         * @param analysisParam analysisParam
         * @return VerifyInfo
         */
        VerifyInfo submitAnalysis(CompFailAnalysisParam analysisParam);
    
        /**
         * 保存分析草稿
         *
         * @param analysisParam analysisParam
         * @return VerifyInfo
         */
        VerifyInfo draftAnalysis(CompFailAnalysisParam analysisParam);
    
        /**
         * 获取分析信息
         *
         * @param faId faId
         * @return CompFailAnalysisParam
         */
        CompFailAnalysisParam getAnalysis(String faId);
    
        /**
         * 提交风险评估
         *
         * @param riskParam riskParam
         * @return VerifyInfo
         */
        VerifyInfo submitRisk(CompFailRiskParam riskParam);
    
        /**
         * 保存风险评估草稿
         *
         * @param riskParam riskParam
         * @return VerifyInfo
         */
        VerifyInfo draftRisk(CompFailRiskParam riskParam);
    
        /**
         * 获取风险评估
         *
         * @param faId faId
         * @return CompFailRiskParam
         */
        CompFailRiskParam getRisk(String faId);
    
        /**
         * 提交项目经理审核
         *
         * @param pmReviewParam pmReviewParam
         * @return VerifyInfo
         */
        VerifyInfo submitPmReview(CompFailPmReviewParam pmReviewParam);
    
        /**
         * 获取项目经理审核
         *
         * @param faId faId
         * @return CompFailPmReviewParam
         */
        CompFailPmReviewParam getPmReview(String faId);
    
        /**
         * 提交专家审核
         *
         * @param mlReviewParam mlReviewParam
         * @return VerifyInfo
         */
        VerifyInfo submitMlReview(CompFailMlReviewParam mlReviewParam);
        
    
        /**
         * getMlReview
         * 
         * @param faId faId
         * @return CompFailMlReviewParam
         */
        CompFailMlReviewParam getMlReview(String faId);
    
        /**
         * 提交关闭审核
         *
         * @param closeReviewParam closeReviewParam
         * @return VerifyInfo
         */
        VerifyInfo submitCloseReview(CompFailCloseReviewParam closeReviewParam);
    
    
        /**
         * getCloseReview
         * 
         * @param faId faId
         * @return CompFailCloseReviewParam
         */
        CompFailCloseReviewParam getCloseReview(String faId);
    
        /**
         * 提交反馈意见
         *
         * @param feedbackParam feedbackParam
         * @return VerifyInfo
         */
        VerifyInfo submitFeedback(CompFailFeedbackParam feedbackParam);
    
    
        /**
         * getFeedback
         * 
         * @param faId faId
         * @return CompFailFeedbackParam
         */
        CompFailFeedbackParam getFeedback(String faId);
    
        /**
         * 待我处理流程
         *
         * @param pageNo pageNo
         * @param pageSize pageSize
         * @param componentCode componentCode
         * @return ResponseVo
         */
        ResponseVo getWaitingProcessList(Integer pageNo, Integer pageSize, String componentCode);
    
        /**
         * 创建流程
         *
         * @param pageNo pageNo
         * @param pageSize pageSize
         * @param componentCode componentCode
         * @return ResponseVo
         */
        ResponseVo getDoingProcessList(Integer pageNo, Integer pageSize, String componentCode);
    
        /**
         * 历史流程（用户创建的，走完所有任务并关闭的）
         *
         * @param pageNo pageNo
         * @param pageSize pageSize
         * @param componentCode componentCode
         * @return ResponseVo
         */
        ResponseVo getHistoryProcessList(Integer pageNo, Integer pageSize, String componentCode);
    
        /**
         * 审批历史流程
         *
         * @param pageNo pageNo
         * @param pageSize pageSize
         * @param componentCode componentCode
         * @return ResponseVo
         */
        ResponseVo getCheckHistoryProcessList(Integer pageNo, Integer pageSize, String componentCode);
    
        /**
         * 共享流程
         *
         * @param pageNo pageNo
         * @param pageSize pageSize
         * @param componentCode componentCode
         * @return ResponseVo
         */
        ResponseVo getShareProcessList(Integer pageNo, Integer pageSize, String componentCode);
    
        /**
         * 模糊查询编码
         *
         * @param keyword keyword
         * @param processType processType
         * @return Collection<String>
         */
        Collection<String> getComponentCode(String keyword, String processType);
    
    
        /**
         * getProcessState
         * 
         * @param businessId businessId
         * @return String
         */
        String getProcessState(String businessId);
    }

### service层 电子流分析服务接口实现类 ###

下篇待续.......

[36_Springboot_activiti7 _studyday1_-CSDN]: https://blog.csdn.net/studyday1/article/details/131463428?spm=1001.2014.3001.5502
[4ac980748dab4b63b7f90993676ed9b0.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/3f3dd87a46e54f6dbf0effdb4d05d9af.png
[7d47a22dd0f84d8eb53eb6a102837da6.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/6239a00c7da14308808d8da60828e3f1.png
[a5f65ec866c742ea863c8f4f804c924e.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/fcf0e394eeba4f4baceb6c74b1b5ba75.png
[78a3fc4e96734f77aa298a237840c47f.png]: https://img-blog.csdnimg.cn/78a3fc4e96734f77aa298a237840c47f.png
[1bb04faf62aa460eaa0cb79a92519b28.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/d4d062d9a5d341f2a80d1d85a3341b21.png