文档中心

搜索

Ask AI

全部文档

展现

模型

流程与逻辑

数据与集成

平台

先胜云平台

文档中心工作流最佳实践多实例子流程

多实例子流程

如何控制各子流程的执行顺序

目前多实例执行方式只有并行，执行时会根据启动多实例的数组，对数组变量中的每个成员，创建1个子流程实例，但创建子流程实例的先后顺序无法指定。

若对子流程实例内的任务/服务的处理顺序有要求，可参考如下思路，在子流程的开始节点后增加等待计时节点，以达到控制顺序的目的。

业务场景举例：主流程中利用多实例子流程节点为HR用户，生成结算各部门工资的子流程任务，但各部门间的任务处理有先后顺序。

需要存储部门的处理顺序，本例中用对象举例
启动多实例的数组：department_code
子流程中定义全局变量

定义的全局变量都基于启动参数department_code作为查询条件。

定义全局变量department_name(string)，初始值为查询部门名称的JS，用作任务名称：

Copy

var a = fn$queryByDeepQL(
  "select department{*} filter .department_code = <str>$department_code", 
  {"department_code":wfi$department_code});
a[0].department_name["zh-cn"]

定义全局变量order(integer)，初始值为查询处理顺序的JS，用作计算等待时间：

Copy

var a = fn$queryByDeepQL(
  "select department{*} filter .department_code = <str>$department_code", 
  {"department_code":wfi$department_code});
a[0].order

定义全局变量cal_time(datetime)，基于流程实例开始时间和order，计算等待时间，流程实例开始后需要等待order-1分钟：

Copy

// 基于流程实例的开始时间
var currentDate = new Date(wfp$start_time);
 
// 要增加的分钟数=oder-1
var minutesToAdd = (wfv$order-1);
 
// 增加分钟数后
currentDate.setMinutes(currentDate.getMinutes() + minutesToAdd)

currentDate

子流程中，在开始节点后，增加等待计时节点，基准时间设为**cal_time**
子流程中，后续任务节点的名称展示部门名称和顺序号，以备检查
效果
1. 发起主流程，数组是[“PURCHASE_2”,”PURCHASE_1”,”SALES_1”,”SALES_2”]
2. 维护好的顺序是[“SALES_1”, “SALES_2”, “PURCHASE_1”, “PURCHASE_2”]
3. 进入待办，查看子流程的任务开始时间：按照设定的顺序[“SALES_1”, “SALES_2”, “PURCHASE_1”, “PURCHASE_2”]生成

子流程撤回主流程节点，其他子流程重走

业务场景举例：

主流程中利用多实例子流程节点发起一系列表单的预算填报，调用的子流程中仅包含一个单人任务节点，当对应预算员提交后，完成此子流程。

需求：

预算员在子流程中提交预算后，可随时撤回，

一旦撤回，则全部表单重新发起，需要全部重新填报

。

核心实现逻辑：

子流程的UX-任务处理界面中配置按钮，关联发起消息事件（用来向主流程发送撤回消息）
主流程中配置等待消息节点（用来等待撤回消息）
主流程中配置发送消息节点（用来终止其他预算填报的子流程）
子流程中配置等待消息节点（用来接收到消息后终止当前流程）

具体配置：

1、主流程设计

创建消息budget_withdraw，添加参数withdraw(boolean)，用来接收撤回消息
增加全局变量submit_count(integer)、budget_withdraw(boolean)，分别用来记录
已提交的预算数量
、
是否有预算员撤回
（多实例子流程）预算员填报节点：增加完成时映射
1. wfv$submit_count = 如下JS表达式

Copy

var result = macr$list_of_submit_result
var result1 = result.filter(function(item) {
  return item !== null;
})
var count = result1.length
count

Copy

2. wfv$budget_withdraw = 如下JS表达式

Copy

!(wfv$submit_count == macp$nr_of_instances)

（排他网关）是否有撤回节点：
1. 条件1（有人撤回）：wfv$budget_withdraw=true（静态值）
2. 条件1跳转至节点：重新发起预算员填报
3. ELSE跳转至节点：更新提交状态-已填报待部门提交
（跳转）重新发起预算员填报节点：
1. 跳转目标：重置任务状态-待提交
（等待消息）等待撤回消息节点：
1. 订阅消息budget_withdraw
2. 完成时映射wfv$submit_count= true（表达式）
（发送消息）终止进行中的所有子流程节点：
1. 发送目标是：其他流程-预算员填报的子流程
2. 发送消息：在子流程中定义的消息terminate_msg
3. 消息参数：true（表达式）
4. 发送范围：广播（因为需要所有子流程实例都终止）
原本主线流程中的结束节点更改为终止节点，防止因为等待消息节点一直在进行中而无法结束流程

2、子流程设计

创建消息terminate_msg，添加参数terminate(boolean)，用来接收终止消息（节点内编排的终止节点，用于完成整个流程实例）
（等待消息）等待终止消息节点：订阅消息terminate_msg
（单人任务）预算员填报节点：待办跳转界面增加跳转参数parent_proc_id=wfp$parent_proc_id，用来向主流程发送撤回消息
原本主线流程中的结束节点更改为终止节点，防止因为等待消息节点一直在进行中而无法结束流程

3、UX-任务处理页面设计（这是子流程中单人任务预算员填报节点的待办跳转界面）：

增加数据源DeepQL，QL语句中的space编码需替换：

Copy

# 仅当该流程实例中，已完成的任务、当前用户是任务处理人时、父流程还在进行中，才可以看到撤回按钮
select DFTask{*}
filter
  .process.proc_inst_id = <str>$proc_id
and .task_status = "Completed"
and .assignee.system_user = global spacehreevs::current_user
and .process.parent.state = "ACTIVE"
order by .start_time desc
limit 1

增加撤回按钮
1. 隐藏条件（条件中的数据源编码需替换）：($var.task_id == null) || ($dataSources.data_query3_EMcZ.data?.[0].task_inst_id != $var.task_id)
2. 事件为发起消息事件，向主流程发送budget_withdraw消息，消息参数withdraw赋值true（表达式），发送范围的流程实例ID是$urlQuery.parent_proc_id