Activiti的任务评论和事件记录管理实战

红太狼 2021-07-24 13:03 723阅读 0赞

**一 代码**

/**
    * Copyright (C), 2020-2020, 软件公司
    * FileName: CommentQuery.java
    * Author:   cakin
    * Date:     2020/4/20
    * Description: ACT_HI_COMMENT表数据查询
    */
    package com.syc.activiti;
    
    
    import java.util.List;
    
    
    import org.activiti.engine.ProcessEngine;
    import org.activiti.engine.ProcessEngines;
    import org.activiti.engine.RepositoryService;
    import org.activiti.engine.RuntimeService;
    import org.activiti.engine.TaskService;
    import org.activiti.engine.repository.Deployment;
    import org.activiti.engine.repository.ProcessDefinition;
    import org.activiti.engine.runtime.ProcessInstance;
    import org.activiti.engine.task.Attachment;
    import org.activiti.engine.task.Comment;
    import org.activiti.engine.task.Event;
    import org.activiti.engine.task.Task;
    
    
    /**
    * @className: CommentQuery
    * @description: ACT_HI_COMMENT表数据查询
    * @date: 2020/4/20
    * @author: cakin
    */
    public class CommentQuery {
        public static void main( String[] args ) {
            // 获取流程引擎实例
            ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
            // 获取任务服务组件
            TaskService taskService = engine.getTaskService();
            // 获取运行服务组件
            RuntimeService runtimeService = engine.getRuntimeService();
            // 流程存储服务组件
            RepositoryService repositoryService = engine.getRepositoryService();
            // 部署流程描述文件
            Deployment dep = repositoryService.createDeployment()
                    .addClasspathResource("bpmn/vacation.bpmn").deploy();
            // 查找流程定义
            ProcessDefinition pd = repositoryService.createProcessDefinitionQuery()
                    .deploymentId(dep.getId()).singleResult();
            // 启动流程
            ProcessInstance pi = runtimeService
                    .startProcessInstanceById(pd.getId());
            // 查找任务
            Task task = taskService.createTaskQuery().processInstanceId(pi.getId())
                    .singleResult();
            // 调用各个记录事件的方法
            taskService.addComment(task.getId(), pi.getId(), "this is comment message");
            taskService.addUserIdentityLink(task.getId(), "1", "user");
            taskService.deleteUserIdentityLink(task.getId(), "1", "user");
            taskService.addGroupIdentityLink(task.getId(), "1", "group");
            taskService.deleteGroupIdentityLink(task.getId(), "1", "group");
            Attachment atta = taskService.createAttachment("test", task.getId(), pi.getId(), "test", "test", "");
            taskService.deleteAttachment(atta.getId());
            // 查询事件与评论
            List<Comment> commonts1 = taskService.getProcessInstanceComments(pi.getId());
            System.out.println("流程评论（事件）数量：" + commonts1.size());
            commonts1 = taskService.getTaskComments(task.getId());
            System.out.println("任务评论数量：" + commonts1.size());
            List<Event> events = taskService.getTaskEvents(task.getId());
            System.out.println("事件数量：" + events.size());
        }
    }

**二 运行**

流程评论（事件）数量：3
    任务评论数量：1
    事件数量：7

**三 数据库**