Springboot整合工作流引擎Activiti之網關路由

作者：Spring源碼解讀 2021-12-17 08:39:39

本篇主要演示復雜的審批流程的應用：排他網關路由的使用(Exclusive Gateway),希望能夠幫助到你。

環境：Springboot2.3.12.RELEASE + Activiti7.1.0.M6

本篇主要演示復雜的審批流程的應用：排他網關路由的使用(Exclusive Gateway)

流程設計

審批說明：當員工請假天數小于等于3天時，部門經理審批，當部門經理同意flag==1流程結束，不同意flag==0流程返回到"員工請假"節點;當請假天數大于3天時，先由部門經理審批，再由總經理審批，當總經理同意flag==1流程結束，不同意flag==0流程返回到"員工請假"節點。

<?xml version="1.0" encoding="UTF-8"?> 
<definitions xmlns="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.xg.com"> 
  <process id="holiday3" name="holiday3" isExecutable="true"> 
    <startEvent id="startevent1" name="Start"></startEvent> 
    <userTask id="usertask1" name="員工請假" activiti:assignee="${userId}"></userTask> 
    <exclusiveGateway id="exclusivegateway1" name="Exclusive Gateway"></exclusiveGateway> 
    <sequenceFlow id="flow1" sourceRef="startevent1" targetRef="usertask1"></sequenceFlow> 
    <sequenceFlow id="flow2" sourceRef="usertask1" targetRef="exclusivegateway1"></sequenceFlow> 
    <userTask id="usertask2" name="部門經理審批" activiti:assignee="${d_mgr}"></userTask> 
    <sequenceFlow id="flow3" name="${days <=3}" sourceRef="exclusivegateway1" targetRef="usertask2"> 
      <conditionExpression xsi:type="tFormalExpression"><![CDATA[${days <=3}]]></conditionExpression> 
    </sequenceFlow> 
    <userTask id="usertask3" name="部門經理審批" activiti:assignee="${d_mgr}"></userTask> 
    <userTask id="usertask4" name="總經理審批" activiti:assignee="${g_mgr}"></userTask> 
    <sequenceFlow id="flow4" name="${days > 3}" sourceRef="exclusivegateway1" targetRef="usertask3"> 
      <conditionExpression xsi:type="tFormalExpression"><![CDATA[${days > 3}]]></conditionExpression> 
    </sequenceFlow> 
    <sequenceFlow id="flow5" sourceRef="usertask3" targetRef="usertask4"></sequenceFlow> 
    <endEvent id="endevent1" name="End"></endEvent> 
    <sequenceFlow id="flow6" name="${flag==1}" sourceRef="usertask2" targetRef="endevent1"> 
      <conditionExpression xsi:type="tFormalExpression"><![CDATA[${flag==1}]]></conditionExpression> 
    </sequenceFlow> 
    <sequenceFlow id="flow7" name="${flag==1}" sourceRef="usertask4" targetRef="endevent1"> 
      <conditionExpression xsi:type="tFormalExpression"><![CDATA[${flag==1}]]></conditionExpression> 
    </sequenceFlow> 
    <sequenceFlow id="flow8" name="${flag==0}" sourceRef="usertask2" targetRef="usertask1"> 
      <conditionExpression xsi:type="tFormalExpression"><![CDATA[${flag==0}]]></conditionExpression> 
    </sequenceFlow> 
    <sequenceFlow id="flow9" name="${flag==0}" sourceRef="usertask4" targetRef="usertask1"> 
      <conditionExpression xsi:type="tFormalExpression"><![CDATA[${flag==0}]]></conditionExpression> 
    </sequenceFlow> 
  </process> 
  <bpmndi:BPMNDiagram id="BPMNDiagram_holiday3"> 
    <bpmndi:BPMNPlane bpmnElement="holiday3" id="BPMNPlane_holiday3"> 
      <bpmndi:BPMNShape bpmnElement="startevent1" id="BPMNShape_startevent1"> 
        <omgdc:Bounds height="35.0" width="35.0" x="470.0" y="40.0"></omgdc:Bounds> 
      </bpmndi:BPMNShape> 
      <bpmndi:BPMNShape bpmnElement="usertask1" id="BPMNShape_usertask1"> 
        <omgdc:Bounds height="55.0" width="105.0" x="435.0" y="120.0"></omgdc:Bounds> 
      </bpmndi:BPMNShape> 
      <bpmndi:BPMNShape bpmnElement="exclusivegateway1" id="BPMNShape_exclusivegateway1"> 
        <omgdc:Bounds height="40.0" width="40.0" x="467.0" y="260.0"></omgdc:Bounds> 
      </bpmndi:BPMNShape> 
      <bpmndi:BPMNShape bpmnElement="usertask2" id="BPMNShape_usertask2"> 
        <omgdc:Bounds height="55.0" width="105.0" x="220.0" y="253.0"></omgdc:Bounds> 
      </bpmndi:BPMNShape> 
      <bpmndi:BPMNShape bpmnElement="usertask3" id="BPMNShape_usertask3"> 
        <omgdc:Bounds height="55.0" width="105.0" x="640.0" y="253.0"></omgdc:Bounds> 
      </bpmndi:BPMNShape> 
      <bpmndi:BPMNShape bpmnElement="usertask4" id="BPMNShape_usertask4"> 
        <omgdc:Bounds height="55.0" width="105.0" x="880.0" y="253.0"></omgdc:Bounds> 
      </bpmndi:BPMNShape> 
      <bpmndi:BPMNShape bpmnElement="endevent1" id="BPMNShape_endevent1"> 
        <omgdc:Bounds height="35.0" width="35.0" x="470.0" y="430.0"></omgdc:Bounds> 
      </bpmndi:BPMNShape> 
      <bpmndi:BPMNEdge bpmnElement="flow1" id="BPMNEdge_flow1"> 
        <omgdi:waypoint x="487.0" y="75.0"></omgdi:waypoint> 
        <omgdi:waypoint x="487.0" y="120.0"></omgdi:waypoint> 
      </bpmndi:BPMNEdge> 
      <bpmndi:BPMNEdge bpmnElement="flow2" id="BPMNEdge_flow2"> 
        <omgdi:waypoint x="487.0" y="175.0"></omgdi:waypoint> 
        <omgdi:waypoint x="487.0" y="260.0"></omgdi:waypoint> 
      </bpmndi:BPMNEdge> 
      <bpmndi:BPMNEdge bpmnElement="flow3" id="BPMNEdge_flow3"> 
        <omgdi:waypoint x="467.0" y="280.0"></omgdi:waypoint> 
        <omgdi:waypoint x="325.0" y="280.0"></omgdi:waypoint> 
        <bpmndi:BPMNLabel> 
          <omgdc:Bounds height="14.0" width="100.0" x="361.0" y="280.0"></omgdc:Bounds> 
        </bpmndi:BPMNLabel> 
      </bpmndi:BPMNEdge> 
      <bpmndi:BPMNEdge bpmnElement="flow4" id="BPMNEdge_flow4"> 
        <omgdi:waypoint x="507.0" y="280.0"></omgdi:waypoint> 
        <omgdi:waypoint x="640.0" y="280.0"></omgdi:waypoint> 
        <bpmndi:BPMNLabel> 
          <omgdc:Bounds height="14.0" width="100.0" x="538.0" y="280.0"></omgdc:Bounds> 
        </bpmndi:BPMNLabel> 
      </bpmndi:BPMNEdge> 
      <bpmndi:BPMNEdge bpmnElement="flow5" id="BPMNEdge_flow5"> 
        <omgdi:waypoint x="745.0" y="280.0"></omgdi:waypoint> 
        <omgdi:waypoint x="880.0" y="280.0"></omgdi:waypoint> 
      </bpmndi:BPMNEdge> 
      <bpmndi:BPMNEdge bpmnElement="flow6" id="BPMNEdge_flow6"> 
        <omgdi:waypoint x="272.0" y="308.0"></omgdi:waypoint> 
        <omgdi:waypoint x="272.0" y="447.0"></omgdi:waypoint> 
        <omgdi:waypoint x="470.0" y="447.0"></omgdi:waypoint> 
        <bpmndi:BPMNLabel> 
          <omgdc:Bounds height="14.0" width="100.0" x="300.0" y="429.0"></omgdc:Bounds> 
        </bpmndi:BPMNLabel> 
      </bpmndi:BPMNEdge> 
      <bpmndi:BPMNEdge bpmnElement="flow7" id="BPMNEdge_flow7"> 
        <omgdi:waypoint x="932.0" y="308.0"></omgdi:waypoint> 
        <omgdi:waypoint x="932.0" y="447.0"></omgdi:waypoint> 
        <omgdi:waypoint x="505.0" y="447.0"></omgdi:waypoint> 
        <bpmndi:BPMNLabel> 
          <omgdc:Bounds height="14.0" width="100.0" x="800.0" y="429.0"></omgdc:Bounds> 
        </bpmndi:BPMNLabel> 
      </bpmndi:BPMNEdge> 
      <bpmndi:BPMNEdge bpmnElement="flow8" id="BPMNEdge_flow8"> 
        <omgdi:waypoint x="272.0" y="253.0"></omgdi:waypoint> 
        <omgdi:waypoint x="272.0" y="147.0"></omgdi:waypoint> 
        <omgdi:waypoint x="435.0" y="147.0"></omgdi:waypoint> 
        <bpmndi:BPMNLabel> 
          <omgdc:Bounds height="14.0" width="100.0" x="290.0" y="151.0"></omgdc:Bounds> 
        </bpmndi:BPMNLabel> 
      </bpmndi:BPMNEdge> 
      <bpmndi:BPMNEdge bpmnElement="flow9" id="BPMNEdge_flow9"> 
        <omgdi:waypoint x="932.0" y="253.0"></omgdi:waypoint> 
        <omgdi:waypoint x="932.0" y="147.0"></omgdi:waypoint> 
        <omgdi:waypoint x="540.0" y="147.0"></omgdi:waypoint> 
        <bpmndi:BPMNLabel> 
          <omgdc:Bounds height="14.0" width="100.0" x="790.0" y="151.0"></omgdc:Bounds> 
        </bpmndi:BPMNLabel> 
      </bpmndi:BPMNEdge> 
    </bpmndi:BPMNPlane> 
  </bpmndi:BPMNDiagram> 
</definitions>

到此流程設計完成。

Service接口

@Service 
public class HolidayService { 
 
  private static final Logger logger = LoggerFactory.getLogger(HolidayService2.class); 
  @Resource 
  private RuntimeService runtimeService ; 
  @Resource 
  private TaskService taskService ; 
  /** 
   *  <p> 
   *    設置assignee的取值，用戶可以在界面上設置流程的執行人 
   *  </p> 
   *  <p>時間：2021年1月22日-下午8:30:39</p> 
   * @author 爺爺 
   * @param processDefinitionId  
   * @return ProcessInstance 
   */ 
  public ProcessInstance startProcessInstanceAssignVariables(String processDefinitionId, Map<String, Object> variables) { 
    Authentication.setAuthenticatedUserId((String)variables.get("assignee")) ; 
    ProcessInstance processInstance = runtimeService.startProcessInstanceById(processDefinitionId, variables); 
    logger.info("流程定義ID: {}", processInstance.getProcessDefinitionId()); 
    logger.info("流程實例ID: {}", processInstance.getId()); 
    logger.info("BussinessKey: {}", processInstance.getBusinessKey()) ; 
    return processInstance ; 
    } 
  /** 
   *  <p>執行任務</p> 
   *  <p>時間：2021年1月24日-上午10:40:39</p> 
   * @author 爺爺 
   * @param variables 
   * @param instanceId  
   * @return void 
   */ 
  public void executionTask(Map<String, Object> variables, String instanceId) { 
    Task task = taskService.createTaskQuery().processInstanceId(instanceId).singleResult() ; 
    if (task == null) { 
      logger.error("任務【{}】不存在", instanceId) ; 
      throw new RuntimeException("任務【" + instanceId + "】不存在") ; 
    } 
    // 注意這里一定要設置變量，否則流程中設置的表達式無法獲取，如下圖 
    taskService.setVariables(task.getId(), variables); 
    taskService.complete(task.getId(), variables) ; 
  } 
}

方法的含義已經在代碼中說明了。

Controller接口

package com.pack.controller; 
 
import java.util.HashMap; 
import java.util.List; 
import java.util.Map; 
import java.util.stream.Collectors; 
 
import javax.annotation.Resource; 
 
import org.activiti.engine.history.HistoricActivityInstance; 
import org.activiti.engine.runtime.ProcessInstance; 
import org.activiti.engine.task.Task; 
import org.apache.commons.lang3.StringUtils; 
import org.springframework.web.bind.annotation.GetMapping; 
import org.springframework.web.bind.annotation.PathVariable; 
import org.springframework.web.bind.annotation.RequestMapping; 
import org.springframework.web.bind.annotation.RequestParam; 
import org.springframework.web.bind.annotation.RestController; 
 
import com.pack.dto.ProcessDefinitionDTO; 
import com.pack.dto.ProcessInstanceDTO; 
import com.pack.dto.R; 
import com.pack.task.HolidayService2; 
 
@RestController 
@RequestMapping("/holidays2") 
public class HolidayController2 { 
     
  @Resource 
  private HolidayService holidayService ; 
     
  /** 
   *  <p>啟動請假審批流程</p> 
   *  <p>時間：2021年1月23日-上午10:32:55</p> 
   * @author 爺爺 
   * @param userId 
   * @param processDefinitionId 流程定義Id 
   * @return R 
   */ 
  @GetMapping("/start") 
  public R startProcess(String userId, String processDefinitionId) { 
    Map<String, Object> variables = new HashMap<>() ; 
    variables.put("userId", userId) ; 
    ProcessInstance instance = holidayService.startProcessInstanceAssignVariables(processDefinitionId, variables) ; 
    ProcessInstanceDTO dto = new ProcessInstanceDTO() ; 
    dto.setInstanceId(instance.getId()) ; 
    return R.success(dto) ; 
  } 
  /** 
   *  <p> 
   *    填寫審批單 
   *  </p> 
   *  <p>時間：2021年1月23日-上午11:57:30</p> 
   * @author 爺爺 
   * @param Map取值如下 
   * @param days 請假天數 
   * @param explain 審批單說明 
   * @param instanceId 流程實例ID 
   * @param assignee 指定下一個流程執行人 
   * @return R 
   */ 
  @GetMapping("/apply") 
  public R fillApply(@RequestParam Map<String, Object> variables) { 
    String instanceId = (String) variables.remove("instanceId") ; 
    if (StringUtils.isEmpty(instanceId)) { 
      return R.failure("未知任務") ; 
    } 
    holidayService.executionTask(variables, instanceId); 
    return R.success() ;  
  } 
}