activiti工作流5.22.0 多人会审功能实现

背景

因业务需求需要实现指定多人来进行一个task，传统做法是使用网关来达到目的，但是显示情况是会审的人员是可变且易变的，比如我指定安全组来做一个检验任务，安全组今天可能是5个人，明天又有人离职变成了3个人，因此网关不大适合该场景，这里就需要用到activiti提供的parallel。

环境

activiti 5.19.0~5.22.0皆可

概念

Activiti User Guide 8.5.14. Multi-instance (for each)中有介绍，即设定一个task为sequentially（顺序执行）或parallel（并行执行）。前者在数据库中一次只产生一个task记录，顺序执行；后者产生多个记录，并行执行。

实现

本文流程要实现以下功能
提交一个测试申请，流转到并行任务，并行任务中各个执行人通过条件选择是否通过（网上流传的${nrOfCompletedInstances/nrOfInstances >= x }并没有提供条件选择的情况，且nrOfCompletedInstances与form表单条件无关）。

总体流程图如下

几个需要编辑的地方

1、第一个任务（t1）

需要添加一个自定义的task listener用来处理变量以及设置t2中会审的人员，比如在这个监听器中就可以通过groupID之类的参数去获取成员列表。

这里提供类代码，以作参考

public class MutiGroupsListener implements TaskListener {public static final Logger LOGGER = LoggerFactory.getLogger(MutiGroupsListener.class);@Overridepublic void notify(DelegateTask arg0) {//清0操作，如果t2会审步骤被驳回，回到t1，需要将通过数，总数重新清空if(arg0.getVariable("passCount")!=null){arg0.setVariable("passCount", 0);}if(arg0.getVariable("totalCount")!=null){arg0.setVariable("totalCount", 0);}//添加会签的人员，这里可以根据自己的业务逻辑去动态获取列表List<String> assigneeList = new ArrayList<String>();assigneeList.add("kermit");assigneeList.add("gonzo");arg0.setVariable("partyList",assigneeList);}}

2、第二个任务（t2）

在这里我们需要将task设置为parallel，XML采用如下设置：

<multiInstanceLoopCharacteristics isSequential="false">...
</multiInstanceLoopCharacteristics>

设计器如图：

其后，设置会签人员集合名称以及集合项名称，任务的办理人使用项名称获取。

表单选择项：

t2完成任务需要调用的方法

    public void completeTask(String taskId,String instanceId,String passflag){ProcessEngine processEngine =ProcessEngines.getDefaultProcessEngine();List<Task> tasks = processEngine.getTaskService().createTaskQuery().taskName("t2").processInstanceId("instanceId").list();int count = 0;int totalCount = 0;for(Task tmp:tasks){String tmpCount = processEngine.getTaskService().getVariable(tmp.getId(), "passCount")+"";//获取通过记录数，这里不能使用nrOfCompletedInstances，因为与我们业务无关String tmpTotal = processEngine.getTaskService().getVariable(tmp.getId(), "totalCount")+"";//获取记录总数if(!tmpCount.equals("null") && !tmpCount.trim().equals("")){count = Integer.parseInt(tmpCount);}if(!tmpTotal.equals("null") && !tmpTotal.trim().equals("")){totalCount = Integer.parseInt(tmpTotal);}System.out.println(tmp.getId()+"var = "+passflag);if(passflag.equals("yes")){//选择通过则+1count++;}totalCount++;}Map<String, Object> vars = new HashMap<String,Object>();//变量回写记录vars.put("passCount", count);vars.put("totalCount", totalCount);processEngine.getTaskService().complete(taskId,vars);}

表单条件查询，可以返回给页面，根据内容初始化页面组件

public void queryFormMsg(String taskId) {ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();TaskFormData td = processEngine.getFormService().getTaskFormData(taskId);List<FormProperty> pros = td.getFormProperties();for(FormProperty tmp:pros){System.out.println("pid:"+tmp.getId());System.out.println("pname:"+tmp.getName());System.out.println("pvalue:"+tmp.getValue());System.out.println("ptype:"+tmp.getType().getName());System.out.println("=========");}}

3、条件判断

这里设置如果全票通过则结束流程，否则返回t1，重新上传文件或是设置信息，这里根据业务而定。

测试，第一次循环一人选择”no”一人选择”yes”，然后第二次全部选择“yes”，通过归档。（这里流程启动、执行全部使用了自己写的方法，流程设计、记录查询借用了activiti explorer）