activiti（十）组任务Group

周杰伦本人

发布于 2023-10-12 14:06:53

2140

发布于 2023-10-12 14:06:53

文章被收录于专栏：同步文章

activiti组任务

第一种：直接指定办理人

bpmn文件：

第二种：使用流程变量

package cn.panda.l_group;

import java.io.InputStream;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.zip.ZipInputStream;

import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.history.HistoricIdentityLink;
import org.activiti.engine.history.HistoricProcessInstance;
import org.activiti.engine.history.HistoricTaskInstance;
import org.activiti.engine.history.HistoricVariableInstance;
import org.activiti.engine.repository.Deployment;
import org.activiti.engine.runtime.ProcessInstance;
import org.activiti.engine.task.IdentityLink;
import org.activiti.engine.task.Task;
import org.junit.Test;

public class TaskTest {

    ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();

    /**
     * 部署流程定义 (从inputStream)
     */
    @Test
    //key值相同 资源升级
    public void deployementProcessDefinition_inputStream() {
        //从当前文件夹查找
        InputStream inputStreamBpmn =this.getClass().getResourceAsStream("task.bpmn");
        InputStream inputStreamPng =this.getClass().getResourceAsStream("task.png");
        Deployment deployment = processEngine.getRepositoryService()//与流程定义和部署相关的service
                        .createDeployment()//创建部署对象
                        .name("任务")//添加部署对象
                        .addInputStream("task.bpmn", inputStreamBpmn)
                        .addInputStream("task.png", inputStreamPng)
                        .deploy();//完成部署
        System.out.println(deployment.getId());
        System.out.println(deployment.getName());
    }

    /**
     * 启动流程实例
     */
    @Test
    public void startProcessInstance() {
        //使用key值启动 默认按照最新版本的流程定义启动
        String processDefinitionKey="task";
        //启动流程实例同时 设置流程变量 使用流程变量指定任务办理人#{userID} 
        Map<String, Object> variables = new HashMap<String, Object>();
        variables.put("userIDs", "周杰伦,大大,中中,小小");
        ProcessInstance processInstance = processEngine.getRuntimeService()//与正在执行的流程实例和执行对象相关的Service
                        .startProcessInstanceByKey(processDefinitionKey,variables);//使用流程定义的key启动流程实例 key对应bpmn文件的id属性值
        System.out.println("流程实例id"+processInstance.getId());//流程实例id
        System.out.println("流程定义ID"+processInstance.getProcessDefinitionId());//流程定义ID
    }

    /**
     * 查询当前人的组任务act_ru_task
     */
    @Test
    public void findMyPersonalTask() {
        String candidateUser="大大";
        List<Task> list = processEngine.getTaskService()//与正在执行的任务管理相关的Service
                        .createTaskQuery()//创建任务查询对象
                        .taskCandidateUser(candidateUser)
                        .orderByTaskCreateTime().asc()
                        .list();
        if (list!=null&&list.size()>0) {
            for (Task task : list) {
                System.out.println("任务ID"+task.getId());
                System.out.println("任务名称"+task.getName());
                System.out.println("任务创建时间"+task.getCreateTime());
                System.out.println("任务的办理人"+task.getAssignee());
                System.out.println("流程实例id:"+task.getProcessInstanceId());
                System.out.println("执行对象id:"+task.getExecutionId());
                System.out.println("流程定义id:"+task.getProcessDefinitionId());

            }
        }
    }

    /**
     * 完成我的任务
     */
    @Test
    public void completeMyPersonalTask() {
        String taskId = "11105";
        processEngine.getTaskService()
                        .complete(taskId);
        System.out.println("完成任务 任务ID："+taskId);
    }

    /**
     * 查询正在执行的任务办理人表
     */
    @Test
    public void findRunPersonTask() {
        String taskId = "8701";
        List<IdentityLink> list = processEngine.getTaskService()
                        .getIdentityLinksForTask(taskId);
        if (list!=null&&list.size()>0) {
            for (IdentityLink identityLink : list) {
                System.out.println(identityLink.getUserId()+" "
                            +identityLink.getProcessInstanceId()+" "
                            +identityLink.getType());
            }
        }
    }

    /**
     * 查询历史任务的办理人
     */
    @Test
    public void findHistoryPersonTask() {
        String processInstanceId = "8901";
        List<HistoricIdentityLink> list = processEngine.getHistoryService()
                        .getHistoricIdentityLinksForProcessInstance(processInstanceId);
        if (list!=null&&list.size()>0) {
            for (HistoricIdentityLink historicIdentityLink : list) {
                System.out.println(historicIdentityLink.getTaskId()+" "
                +historicIdentityLink.getType()+" "
                +historicIdentityLink.getProcessInstanceId());
            }
        }
    }

    /**
     * 拾取任务 组任务分配给个人任务 指定任务的办理人字段
     */
    @Test
    public void claim() {
        //个人Id
        String userId = "大大";
        String taskId = "9905";
        //可以是组任务的成员 也可以是其他人
        processEngine.getTaskService()
        .claim(taskId, userId);
    }

    /**
     * 将个人任务回退到组任务 前提是之前一定是组任务
     */
    @Test
    public void setAssignee() {
        String taskId = "8905";
        processEngine.getTaskService()
                        .setAssignee(taskId, null);
    }

    /**
     * 向组任务中添加成员
     */
    @Test
    public void addGroupUser() {
        String taskId = "8905";
        String userId = "大S";
        processEngine.getTaskService()
                        .addCandidateUser(taskId, userId);
    }

    /**
     * 从组任务中删除成员
     */
    @Test
    public void deleteGroupUser() {
        String taskId = "8905";
        String userId = "大S";
        processEngine.getTaskService()
                        .deleteCandidateUser(taskId, userId);
    }
}

部署流程开启流程查看当前人的组任务组任务拾取个人任务完成任务（组任务最后也要个人来完成）

bpmn文件：

第三种：使用类

实体类：

package cn.panda.l_group03;

import org.activiti.engine.delegate.DelegateTask;
import org.activiti.engine.delegate.TaskListener;

@SuppressWarnings("serial")
public class TaskListenerImpl implements TaskListener {

    /**
     * 指定组任务的办理人
     */
    //通过类找办理人
    public void notify(DelegateTask delegateTask) {
        delegateTask.addCandidateUser("郭靖");
        delegateTask.addCandidateUser("黄蓉");
    }

}

测试类：

package cn.panda.l_group03;

import java.io.InputStream;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.zip.ZipInputStream;

import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.history.HistoricIdentityLink;
import org.activiti.engine.history.HistoricProcessInstance;
import org.activiti.engine.history.HistoricTaskInstance;
import org.activiti.engine.history.HistoricVariableInstance;
import org.activiti.engine.repository.Deployment;
import org.activiti.engine.runtime.ProcessInstance;
import org.activiti.engine.task.IdentityLink;
import org.activiti.engine.task.Task;
import org.junit.Test;

public class TaskTest {

    ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();

    /**
     * 部署流程定义 (从inputStream)
     */
    @Test
    //key值相同 资源升级
    public void deployementProcessDefinition_inputStream() {
        //从当前文件夹查找
        InputStream inputStreamBpmn =this.getClass().getResourceAsStream("task.bpmn");
        InputStream inputStreamPng =this.getClass().getResourceAsStream("task.png");
        Deployment deployment = processEngine.getRepositoryService()//与流程定义和部署相关的service
                        .createDeployment()//创建部署对象
                        .name("任务")//添加部署对象
                        .addInputStream("task.bpmn", inputStreamBpmn)
                        .addInputStream("task.png", inputStreamPng)
                        .deploy();//完成部署
        System.out.println(deployment.getId());
        System.out.println(deployment.getName());
    }

    /**
     * 启动流程实例
     */
    @Test
    public void startProcessInstance() {
        //使用key值启动 默认按照最新版本的流程定义启动
        String processDefinitionKey="task";
        ProcessInstance processInstance = processEngine.getRuntimeService()//与正在执行的流程实例和执行对象相关的Service
                        .startProcessInstanceByKey(processDefinitionKey);//使用流程定义的key启动流程实例 key对应bpmn文件的id属性值
        System.out.println("流程实例id"+processInstance.getId());//流程实例id
        System.out.println("流程定义ID"+processInstance.getProcessDefinitionId());//流程定义ID
    }

    /**
     * 查询当前人的组任务act_ru_task
     */
    @Test
    public void findMyPersonalTask() {
        String candidateUser="郭靖";
        List<Task> list = processEngine.getTaskService()//与正在执行的任务管理相关的Service
                        .createTaskQuery()//创建任务查询对象
                        .taskCandidateUser(candidateUser)
                        .orderByTaskCreateTime().asc()
                        .list();
        if (list!=null&&list.size()>0) {
            for (Task task : list) {
                System.out.println("任务ID"+task.getId());
                System.out.println("任务名称"+task.getName());
                System.out.println("任务创建时间"+task.getCreateTime());
                System.out.println("任务的办理人"+task.getAssignee());
                System.out.println("流程实例id:"+task.getProcessInstanceId());
                System.out.println("执行对象id:"+task.getExecutionId());
                System.out.println("流程定义id:"+task.getProcessDefinitionId());

            }
        }
    }

    /**
     * 完成我的任务
     */
    @Test
    public void completeMyPersonalTask() {
        String taskId = "10404";
        processEngine.getTaskService()
                        .complete(taskId);
        System.out.println("完成任务 任务ID："+taskId);
    }

    /**
     * 查询正在执行的任务办理人表
     */
    @Test
    public void findRunPersonTask() {
        String taskId = "8701";
        List<IdentityLink> list = processEngine.getTaskService()
                        .getIdentityLinksForTask(taskId);
        if (list!=null&&list.size()>0) {
            for (IdentityLink identityLink : list) {
                System.out.println(identityLink.getUserId()+" "
                            +identityLink.getProcessInstanceId()+" "
                            +identityLink.getType());
            }
        }
    }

    /**
     * 查询历史任务的办理人
     */
    @Test
    public void findHistoryPersonTask() {
        String processInstanceId = "8901";
        List<HistoricIdentityLink> list = processEngine.getHistoryService()
                        .getHistoricIdentityLinksForProcessInstance(processInstanceId);
        if (list!=null&&list.size()>0) {
            for (HistoricIdentityLink historicIdentityLink : list) {
                System.out.println(historicIdentityLink.getTaskId()+" "
                +historicIdentityLink.getType()+" "
                +historicIdentityLink.getProcessInstanceId());
            }
        }
    }

    /**
     * 拾取任务 组任务分配给个人任务 指定任务的办理人字段
     */
    @Test
    public void claim() {
        //个人Id
        String userId = "郭靖";
        String taskId = "10404";
        //可以是组任务的成员 也可以是其他人
        processEngine.getTaskService()
        .claim(taskId, userId);
    }

    /**
     * 将个人任务回退到组任务 前提是之前一定是组任务
     */
    @Test
    public void setAssignee() {
        String taskId = "8905";
        processEngine.getTaskService()
                        .setAssignee(taskId, null);
    }

    /**
     * 向组任务中添加成员
     */
    @Test
    public void addGroupUser() {
        String taskId = "8905";
        String userId = "大S";
        processEngine.getTaskService()
                        .addCandidateUser(taskId, userId);
    }

    /**
     * 从组任务中删除成员
     */
    @Test
    public void deleteGroupUser() {
        String taskId = "8905";
        String userId = "大S";
        processEngine.getTaskService()
                        .deleteCandidateUser(taskId, userId);
    }
}

bpmn文件：

1）在类中使用delegateTask.addCandidateUser (userId);的方式分配组任务的办理人，此时孙悟空和猪八戒是下一个任务的办理人。

2）通过processEngine.getTaskService().claim (taskId, userId);将组任务分配给个人任务，也叫认领任务，即指定某个人去办理这个任务，此时由如来去办理任务。

注意：认领任务的时候，可以是组任务成员中的人，也可以不是组任务成员的人，此时通过Type的类型为participant来指定任务的办理人

3） addCandidateUser()即向组任务添加成员，deleteCandidateUser()即删除组任务的成员。

在开发中，可以将每一个任务的办理人规定好，例如张三的领导是李四和王五，这样张三提交任务，由李四或者王五去查询组任务，可以看到对应张三的申请，李四或王五再通过认领任务（

claim）的方式，由某个人去完成这个任务。

总结：

组任务及三种分配方式：

1：在taskProcess.bpmn中直接写 candidate-users=“小A,小B,小C,小D”

2：在taskProcess.bpmn中写 candidate-users =“#{userIDs}”，变量的值要是String的。

使用流程变量指定办理

Map<String, Object>variables = new HashMap<String, Object>();
 variables.put("userIDs", "大大,小小,中中");

3，使用TaskListener接口，使用类实现该接口，在类中定义：

//添加组任务的用户

delegateTask.addCandidateUser(userId1);

delegateTask.addCandidateUser(userId2);

组任务分配给个人任务（认领任务）：

processEngine.getTaskService().claim(taskId, userId);

个人任务分配给组任务：

processEngine.getTaskService(). setAssignee(taskId,null);

向组任务添加人员：

processEngine.getTaskService().addCandidateUser(taskId, userId);

向组任务删除人员：

processEngine.getTaskService().deleteCandidateUser(taskId, userId);

个人任务和组任务存放办理人对应的表：

act_ru_identitylink表存放任务的办理人，包括个人任务和组任务，表示正在执行的任务

act_hi_identitylink表存放任务的办理人，包括个人任务和组任务，表示历史任务

区别在于：如果是个人任务TYPE的类型表示participant（参与者）

如果是组任务TYPE的类型表示candidate（候选者）和participant（参与者）两种完成任务的是参与者而不是候选者

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

原始发表：2023-10-11，如有侵权请联系 cloudcommunity@tencent.com 删除

activiti

本文分享自作者个人站点/博客前往查看

如有侵权，请联系 cloudcommunity@tencent.com 删除。

本文参与腾讯云自媒体同步曝光计划，欢迎热爱写作的你一起参与！

登录后参与评论

0 条评论

热度