activiti6.0 java类配置 使用监听器实现 会签功能

简介： 使用activiti 监听器 实现会签功能

使用监听器存储会签人员信息，在监听器启动时取出会签人员信息 ，写入流程变量之中，实现会签功能。

 

1.用户任务配置

   /**
     * 创建用户任务节点
     * 多人审批（会签）
     * sign  是否会签
     * assignee 操作组人员id集合
     */
    public static UserTask createUsersTask(String id, String name, List<String> assignee,boolean sign){
        UserTask userTask = new UserTask();
        userTask.setName(name);
        userTask.setId(id);
        //会签 使用监听器完成
        if(sign){
            //编组会签人员id
            String assigneeList="";
            for(String str:assignee){
                assigneeList+=str+",";
            }
            //去除最后一位逗号
            assigneeList=assigneeList.substring(0,assigneeList.length()-1);

            //会签配置
            MultiInstanceLoopCharacteristics  multiInstanceLoopCharacteristics1 = new MultiInstanceLoopCharacteristics();
            //会签循环次数（等于操作组数量）
            multiInstanceLoopCharacteristics1.setLoopCardinality(String.valueOf(assignee.size()));
            //会签通过条件（通过人数等于审批人数）
            multiInstanceLoopCharacteristics1.setCompletionCondition("${nrOfActiveInstances == nrOfInstances}");
            //会签
            multiInstanceLoopCharacteristics1.setSequential(false);
            //审批人集合参数
            multiInstanceLoopCharacteristics1.setInputDataItem("assigneeList");
            //迭代集合
            multiInstanceLoopCharacteristics1.setElementVariable("assignee");
            //写入参数
            userTask.setLoopCharacteristics(multiInstanceLoopCharacteristics1);

           45 
            //配置监听器2
            ArrayList<ActivitiListener> listener = new ArrayList<>();
            ActivitiListener activitiListener = new ActivitiListener();
            //开始执行
            activitiListener.setEvent("start");
            //执行方式
            activitiListener.setImplementationType("class");
            //实现类
            activitiListener.setImplementation("com.windseeker.common.activiti.utils.MyTaskListener");
            //监听器参数
            FieldExtension file2=new FieldExtension();
            //会签操作组
            file2.setFieldName("assignee");
            file2.setStringValue(assigneeList);
            List<FieldExtension> list2=new ArrayList<>();
            list2.add(file2);
            //写入参数
            activitiListener.setFieldExtensions(list2);
            listener.add(activitiListener);
            userTask.setExecutionListeners(listener);

            //设置会签操作组人员配置
            userTask.setAssignee("${assignee}");
        }else{
            //非会签 直接写入操作组
            userTask.setCandidateUsers(assignee);
        }
        return userTask;
    }

 

2.监听类配置

/**
 * activiti 监听器实现类 5  *
 */
public class MyTaskListener implements ExecutionListener{

    /**
     * 会签操作组对象
     */
    private Expression assignee;

    public Expression getAssignee() {
        return assignee;
    }

    public void setAssignee(Expression assignee) {
        this.assignee = assignee;
    }

    /**
     * 会签功能实现方法
     * @param delegateTask
     */

    @Override
    public void notify(DelegateExecution delegateTask) {
        String eventName = delegateTask.getEventName();
        if ("start".equals(eventName)) {
            // 流程开始
            System.out.println("start......");
        } else if ("end".equals(eventName)) {
            // 流程结束
            System.out.println("end......");
        } else if ("take".equals(eventName)) {
            // 连线监听器
            System.out.println("take......");
        }
        // delegateTask 可以操作activiti引擎的一些东西

        //获取会签操作组信息
        List<String> assigneeList1 = new ArrayList<>();
        String[] result = assignee.getValue(delegateTask).toString().split(",");
        for(int k=0;k<result.length;k++){
            if(!result[k].equals("")){
                assigneeList1.add(result[k]);
            }
        }
        //将会签操作组信息写入流程实例变量
        delegateTask.setVariable("assigneeList",assigneeList1);

    }
}