BPM-子流程

雨点打透心脏的1/2处 2022-05-28 02:56 267阅读 0赞

# Activiti提供两种子流程实现： #

1、嵌入子流程

子流程元素 <subProcess> 内嵌在主流程元素<process>之内，只能在该流程中使用该子流程，外部是无法访问到的。这种子流程一般作为局部通用逻辑处理，或者因为特定业务需要，使得比较复杂的单个主流程设计清晰直观；

2、调用子流程

首先实现一个流程，在另一个流程中可以调用该流程，通常可以定义一些通用的流程作为这种调用子流程，供其他多个流程定义复用。这种子流程使用 <callActivity> 元素来进行调用，间接地嵌入到主流程中，用起来比较方便。

下面通过实例来看下两者的实现：

![20180328143831279][]

工作流子流程方案

# 子流程 #

子流程图元

# 多实例子流程 #

# 并发多实例子流程 #

注：1、集合，集合中可以存任意值，工作流会根据你集合里的值个数，去生成对应的子流程，

例如：我这里存的是3个科室code，\{0001，0002，0003\}，那么就会生成出3个子流程，

其实这里我简单说明一下，如果只传入1个值会生成4个流程实例，

传2个会生成出6个流程实例（多出的两个，一个是子流程subprocess的，一个是流程中第一个任务的），以此类推。

2、成员变量，用于在流程图中代替集合中表示当前子流程的变量（我这存的是科室code，所以表示的就是科室code）。

这个节点流程变量可以在当前子流程中任意的task中使用，例如子流程中的任务我就用到了这个变量。

3、完成条件，这里写的表达式如果满足即可到（第三步：立项书编制）这个任务。

# 子流程活动动态设置参与人 #

## 扩展角色 ##

数据结构

<table> 
 <tbody> 
 <tr> 
 <td style="background:rgb(165,165,165);">字段名</td> 
 <td style="background:rgb(165,165,165);">类型</td> 
 <td style="background:rgb(165,165,165);">长度</td> 
 <td style="background:rgb(165,165,165);">注释</td> 
 <td style="background:rgb(165,165,165);">说明</td> 
 </tr> 
 <tr> 
 <td style="background:rgb(237,237,237);">id_</td> 
 <td style="background:rgb(237,237,237);">varchar(64)</td> 
 <td style="background:rgb(237,237,237);">64</td> 
 <td style="background:rgb(237,237,237);">&nbsp;</td> 
 <td style="background:rgb(237,237,237);">&nbsp;</td> 
 </tr> 
 <tr> 
 <td>enable_</td> 
 <td>char(1)</td> 
 <td>1</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 </tr> 
 <tr> 
 <td style="background:rgb(237,237,237);">tenant_id_</td> 
 <td style="background:rgb(237,237,237);">varchar(64)</td> 
 <td style="background:rgb(237,237,237);">64</td> 
 <td style="background:rgb(237,237,237);">&nbsp;</td> 
 <td style="background:rgb(237,237,237);">&nbsp;</td> 
 </tr> 
 <tr> 
 <td>code_</td> 
 <td>varchar(64)</td> 
 <td>64</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 </tr> 
 <tr> 
 <td style="background:rgb(237,237,237);">name_</td> 
 <td style="background:rgb(237,237,237);">varchar(255)</td> 
 <td style="background:rgb(237,237,237);">255</td> 
 <td style="background:rgb(237,237,237);">&nbsp;</td> 
 <td style="background:rgb(237,237,237);">&nbsp;</td> 
 </tr> 
 <tr> 
 <td>adapterclazz_</td> 
 <td>varchar(500)</td> 
 <td>500</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 </tr> 
 <tr> 
 <td style="background:rgb(237,237,237);">create_time_</td> 
 <td style="background:rgb(237,237,237);">datetime</td> 
 <td style="background:rgb(237,237,237);">&nbsp;</td> 
 <td style="background:rgb(237,237,237);">&nbsp;</td> 
 <td style="background:rgb(237,237,237);">&nbsp;</td> 
 </tr> 
 <tr> 
 <td>modify_time_</td> 
 <td>datetime</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 </tr> 
 </tbody> 
</table>

扩展角色实体类：ExtendRoleEntity，位于ubpm-engine包中。

## 自定义适配器 ##

适配器类：BpmExtendUserAdapter，需继承基类AbstractParticipantAdapter。

需实现抽象方法：

public abstract List<Participant>find(ProcessParticipantItem processParticipantItem, ParticipantContextparticipantContext);

参考实现：

<table> 
 <tbody> 
 <tr> 
 <td>@Override &nbsp; public List&lt;Participant&gt; find(ProcessParticipantItem processParticipantItem, ParticipantContext participantContext) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; BpmEngineConfiguration bpmEngineConfiguration = (BpmEngineConfiguration)Context.getProcessEngineConfiguration(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String executionId = ParticipantContext.getExecution().getId(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String assignVar = ""; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if(executionId==null) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; List&lt;Participant&gt; list=new ArrayList&lt;Participant&gt;(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Participant Participant=new Participant(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Participant.setId(assignVar); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; list.add(Participant); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; return list; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; List&lt;String&gt; subCollection=(List)bpmEngineConfiguration.getRuntimeService().getVariable(executionId, "subCollection"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String subUserInfo = (String)bpmEngineConfiguration.getRuntimeService().getVariable(executionId, "subUserInfo"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String assignList = "default_user_id"; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if(subUserInfo.equalsIgnoreCase("人事")){ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; assignList="75176168-6125-11e7-96cf-b8aeed2e916b,default_user_id"; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }else { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; assignList="98279a81-7823-11e7-92ea-b8aeed2e916b,75176168-6125-11e7-96cf-b8aeed2e916b,default_user_id"; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } /*if(StringUtils.isBlank(assignList)){ &nbsp;&nbsp; log.error("AssignListAdapter can not find user!"); &nbsp;&nbsp; return new ArrayList&lt;Participant&gt;(0); }*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //assignList="98279a81-7823-11e7-92ea-b8aeed2e916b"; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; List&lt;User&gt; userEntityList = null; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if(assignList.indexOf("{")!=-1){ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;JSONObject assignsJson = JSONObject.fromObject(assignList); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if(assignsJson.containsKey("objectId")){ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Object assigns=assignsJson.get("objectId"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if(assigns != null){ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; userEntityList = new ArrayList&lt;User&gt;(1); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; User userEntity = bpmEngineConfiguration.getUserService().getUserById(assigns.toString().trim()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; userEntityList.add(userEntity); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }else{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String[] assignListArray = assignList.split(","); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; int len = assignListArray != null ? assignListArray.length : 0; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; userEntityList = new ArrayList&lt;User&gt;(len); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; for (int i = 0; i &lt; len; i++) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String userId = assignListArray[i]; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; User userEntity = bpmEngineConfiguration.getUserService().getUserById(userId); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; userEntityList.add(userEntity); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if(userEntityList == null || userEntityList.size() == 0){ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; return null; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; List&lt;Participant&gt; list = getResult(processParticipantItem, userEntityList.toArray(new UserEntity[0])); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; return list; &nbsp; } &nbsp;</td> 
 </tr> 
 </tbody> 
</table>

## 调用者 ##

<table> 
 <tbody> 
 <tr> 
 <td>List&lt;String&gt; subCollection = new ArrayList(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; subCollection.add("人事"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; subCollection.add("财务"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; processInstanceBuilder.addVariable("subCollection",subCollection); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; List&lt;String&gt; subUserCollection = new ArrayList(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; subUserCollection.add("5c6c5442-7758-11e7-93ff-b8aeed2e916b"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; subUserCollection.add("98279a81-7823-11e7-92ea-b8aeed2e916b"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; subUserCollection.add("default_user_id"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; processInstanceBuilder.addVariable("subUserCollection",subUserCollection); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String subUserInfo = Joiner.on(",").join(subUserCollection); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; processInstanceBuilder.addVariable("subUserInfo",subUserInfo); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; //流程启动,使用表单key &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; //ProcessInstance processInstance = runtimeService.startProcessInstanceByKeyAndTenantId(processDefinitionKey, businessKey, organizationsKey); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; processInstanceBuilder.processDefinitionKey(processDefinitionKey).tenantId(organizationsKey); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; processInstanceBuilder.processInstanceName(processName); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; processInstanceBuilder.businessKey(businessKey); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; ProcessInstance processInstance = runtimeService.startProcessInstance(processInstanceBuilder);</td> 
 </tr> 
 </tbody> 
</table>

[20180328143831279]: /images/20220528/dcfd684aa82e42338f0d49704f318ebc.png