activiti6.0学习笔记（二）：核心api之TaskSer

一、前言

本章继续学习activiti6.0的核心api之TaskService    博客已经转至简书 （csdn写博客太痛苦了）

二、activiti6.0的核心api之TaskService

    1、复制 testProcess.bpmn20.xml 流程定义文件，并将其改名为 testProcess-task.bpmn20.xml

    2、修改 testProcess-task.bpmn20.xml中内容如下：

<process id="myProcess" isClosed="false" isExecutable="true" name="测试流程" processType="None">

  <startEvent id="startevent1" name="Start"/>

  <endEvent id="endevent1" name="End"/>

  <userTask activiti:candidateUsers="张三,李四,王五" activiti:exclusive="true" id="test" name="用户">

    <documentation>test task ${message}

  <sequenceFlow id="flow1" sourceRef="startevent1" targetRef="test"/>

  <sequenceFlow id="flow2" sourceRef="test" targetRef="endevent1"/>

</process>

3、测试代码如下：

/**

*

*    测试taskService  Task为任务，通常就是我们所说的代办任务

*    taskService作用：

*      1、对用户任务（UserTask）进行管理和流程的控制

*        a）Task对象的创建和删除

*        b）查询Task，并驱动Task节点完成执行

*        c）Task相关参数变量（variable）设置

*      2、设置用户任务（UserTask）的权限信息（拥有者，候选人，办理人）

*      3、针对用户任务添加任务附件、任务评论和事件记录

*        a）任务附件（Attachment）创建与查询

*        b）任务评论（Comment）创建与查询

*        c）事件记录（Event）创建与查询

* @author chaoge

* @since 2018/10/8 15:00

*/

public class TaskServiceTest {

private static final LoggerLOGGER = LoggerFactory.getLogger(RuntimeServiceTest.class);

    @Rule

    public ActivitiRulerule =new ActivitiRule();

    /**

    * 测试taskService设置和获取变量，完成任务

    */

    @Test

    @Deployment(resources ="processes/testProcess-task.bpmn20.xml")

public void testTaskService(){

Map variables = Maps.newHashMap();

        //可以在此处传递参数，在流程文件中通过${message}的方式接收参数，流程引擎会自动将其替换成设置的参数

        variables.put("message","测试信息");

        ProcessInstance myProcess =rule.getRuntimeService().startProcessInstanceByKey("myProcess",variables);

        TaskService taskService =rule.getTaskService();

        Task task = taskService.createTaskQuery().singleResult();

        LOGGER.info("task = {}",ToStringBuilder.reflectionToString(task,ToStringStyle.JSON_STYLE));

        LOGGER.info("task name = {}",task.getName());

        LOGGER.info("task des = {}",task.getDescription());

        System.out.println("task =  " + ToStringBuilder.reflectionToString(task,ToStringStyle.JSON_STYLE));

        //设置和获取变量  taskService.getVariables(task.getId())能获取到流程变量和本地变量，即第一种包含了第二种和第三种的变量

        Map taskServiceVariables = taskService.getVariables(task.getId());

        Map taskServiceVariablesLocal = taskService.getVariablesLocal(task.getId());

        Map processVariables =rule.getRuntimeService().getVariables(task.getExecutionId());

        LOGGER.info("taskServiceVariables = {}",ToStringBuilder.reflectionToString(taskServiceVariables,ToStringStyle.JSON_STYLE));

        LOGGER.info("taskServiceVariablesLocal = {}",ToStringBuilder.reflectionToString(taskServiceVariablesLocal,ToStringStyle.JSON_STYLE));

        LOGGER.info("processVariables = {}",ToStringBuilder.reflectionToString(processVariables,ToStringStyle.JSON_STYLE));

        //当前流程节点设置完成并走向下一个节点,同时设置参数

        Map variables2 = Maps.newHashMap();

        variables2.put("user1","chaoge");

        taskService.complete(task.getId(),variables2);

        Task task1 = taskService.createTaskQuery().taskId(task.getId()).singleResult();

        LOGGER.info("task1 = {}",task1);

    }

/**

    * 其中有两个字段：OWNER_，ASSIGNEE_

    * 这两个字段的意义是：

    * 1，ASSIGNEE_（受理人）：task任务的受理人，就是执行TASK的人，这个又分两种情况（有值，NULL）

    *     1），有值的情况：XML流程里面定义的受理人，TASK会直接填入这个人；

    *     2），NULL：XML没有指定受理人或者只指定了候选组；

    *        没有值的时候，可以使用签收功能去指定受理人，就是候选组里面谁签收谁就成了受理人

    * 2，OWNER_（委托人）：受理人委托其他人操作该TASK的时候，受理人就成了委托人OWNER_，其他人就成了受理人ASSIGNEE_

*/

    @Test

    @Deployment(resources ="processes/testProcess-task.bpmn20.xml")

public void testTaskServiceUser(){

Map variables = Maps.newHashMap();

        //可以在此处传递参数，在流程文件中通过${message}的方式接收参数，流程引擎会自动将其替换成设置的参数

        variables.put("message","测试信息");

        ProcessInstance myProcess =rule.getRuntimeService().startProcessInstanceByKey("myProcess",variables);

        TaskService taskService =rule.getTaskService();

        Task task = taskService.createTaskQuery().singleResult();

        LOGGER.info("task = {}",ToStringBuilder.reflectionToString(task,ToStringStyle.JSON_STYLE));

        LOGGER.info("task des = {}",task.getDescription());

        taskService.setOwner(task.getId(),"user1");//owner通常是流程的发起人

        //taskService.setAssignee(task.getId(),"张三");//设置代办人，此种方式会覆盖掉原来的代办人，不推荐使用

        List taskList = taskService.createTaskQuery()

.taskCandidateUser("张三")//设置了办理用户是张三

                .taskUnassigned()//没有设置代办人

                .listPage(1, 100);

        try {

//当用户已经指定一个代办人的时候claim获取是会报错的

            taskList.forEach(task1->taskService.claim(task1.getId(),"张三"));//设置代办人

        }catch (Exception e) {

LOGGER.error(e.getMessage(),e);

        }

//获取任务相关的办理人，包括owner、candidateUsers

        List identityLinks = taskService.getIdentityLinksForTask(task.getId());

        identityLinks.forEach(identityLink->LOGGER.info("identityLink = {}",identityLink));

        //获取代办人是张三的任务

        List tasks = taskService.createTaskQuery().taskAssignee("张三").listPage(0, 100);

        tasks.forEach(task1 ->taskService.complete(task1.getId()));

        List tasks2 = taskService.createTaskQuery().taskAssignee("张三").listPage(0, 100);

        tasks2.forEach(task1 ->LOGGER.info("张三的代办任务task = {}",task1) );

    }

/**

    * 创建Attachment

*/

    @Test

    @Deployment(resources ="processes/testProcess-task.bpmn20.xml")

public void testTaskAttachment(){

Map variables = Maps.newHashMap();

        //可以在此处传递参数，在流程文件中通过${message}的方式接收参数，流程引擎会自动将其替换成设置的参数

        variables.put("message","测试信息");

        ProcessInstance myProcess =rule.getRuntimeService().startProcessInstanceByKey("myProcess",variables);

        TaskService taskService =rule.getTaskService();

        Task task = taskService.createTaskQuery().singleResult();

        LOGGER.info("task = {}",ToStringBuilder.reflectionToString(task,ToStringStyle.JSON_STYLE));

        LOGGER.info("task des = {}",task.getDescription());

        taskService.createAttachment("url",task.getId(),task.getProcessInstanceId(),"name","desc","/url/test.png");

        List taskAttachments = taskService.getTaskAttachments(task.getId());

        taskAttachments.forEach(taskAttach->LOGGER.info("taskAttach = {}",ToStringBuilder.reflectionToString(taskAttach,ToStringStyle.JSON_STYLE)));

    }

/**

    * 创建Comment 查询事件信息

    */

    @Test

    @Deployment(resources ="processes/testProcess-task.bpmn20.xml")

public void testTaskComment(){

Map variables = Maps.newHashMap();

        //可以在此处传递参数，在流程文件中通过${message}的方式接收参数，流程引擎会自动将其替换成设置的参数

        variables.put("message","测试信息");

        ProcessInstance myProcess =rule.getRuntimeService().startProcessInstanceByKey("myProcess",variables);

        TaskService taskService =rule.getTaskService();

        Task task = taskService.createTaskQuery().singleResult();

        LOGGER.info("task = {}",ToStringBuilder.reflectionToString(task,ToStringStyle.JSON_STYLE));

        LOGGER.info("task des = {}",task.getDescription());

        //添加评论

        taskService.addComment(task.getId(),task.getProcessInstanceId(),"这是我的评论");

        taskService.addComment(task.getId(),task.getProcessInstanceId(),"这还是我的评论");

        //查询评论

        List taskComments = taskService.getTaskComments(task.getId());

        taskComments.forEach(taskComment->LOGGER.info("taskComment = {}",ToStringBuilder.reflectionToString(taskComment,ToStringStyle.JSON_STYLE)));

        //查询事件

        List taskEvents = taskService.getTaskEvents(task.getId());

        taskEvents.forEach(taskEvent->LOGGER.info("taskEvent = {}",ToStringBuilder.reflectionToString(taskEvent,ToStringStyle.JSON_STYLE)));

    }

}