Activiti搭建

Posted 2022-02-11 jpfss

Activiti搭建

前期准备：

JDK+Eclipse+Tomcat+Maven的安装与配置

参考：http://blog.csdn.net/zhshulin/article/details/30779873

创建一个Maven项目来配置环境

参考：http://blog.csdn.net/zhshulin/article/details/37921705

1，导入activiti包文件

 1 <activiti-version>5.18.0</activiti-version> 

 1 <!--         activiti依赖包 -->
 2         <dependency>
 3             <groupId>org.activiti</groupId>
 4             <artifactId>activiti-engine</artifactId>
 5             <version>$activiti-version</version>
 6         </dependency>
 7         <dependency>
 8             <groupId>org.activiti</groupId>
 9             <artifactId>activiti-spring</artifactId>
10             <version>$activiti-version</version>
11         </dependency>
12         <dependency>
13             <groupId>org.activiti</groupId>
14             <artifactId>activiti-bpmn-converter</artifactId>
15             <version>$activiti-version</version>
16         </dependency>
17         <dependency>
18             <groupId>org.activiti</groupId>
19             <artifactId>activiti-bpmn-model</artifactId>
20             <version>$activiti-version</version>
21         </dependency>
22         <dependency>
23             <groupId>org.activiti</groupId>
24             <artifactId>activiti-bpmn-layout</artifactId>
25             <version>$activiti-version</version>
26         </dependency>

 

2、 eclipse安装activiti-designer插件

      打开eclipse软件，然后点击菜单栏的help选项，选择install New Software,示例如下：

      出现如下对话框：

         点击添加【Add】按钮，出现如下对话框

 

      输入如下地址：

Location:http://activiti.org/designer/update/   

Name:Activiti

      点击OK按钮出现如下窗体：

 

       选择Activiti BPMN Desisner，然后一直选择下一步，直到出现如下窗体：

 

     如果出现这个窗体，就表明eclipse正在给您下载相应的插件，但是这个办法是在有网的情况下，而且会比较慢，你得耐心等待，

当然还有一个简单的办法，就是我们将下载好的插件放到指定文件夹下。

        如果能出现，就证明我们的工作流插件就算是安装成功了。

3、spring-activiti.xml配置文件

建立spring-activiti.xml配置文件

 1 <?xml version="1.0" encoding="UTF-8"?>
 2 <beans xmlns="http://www.springframework.org/schema/beans"
 3     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 4     xsi:schemaLocation="http://www.springframework.org/schema/beans   http://www.springframework.org/schema/beans/spring-beans.xsd">
 5     <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
 6         <property name="driverClassName" value="com.mysql.jdbc.Driver" />
 7         <property name="url" value="jdbc:mysql://localhost:3306/数据库名称" />
 8         <property name="username" value="用户名" />
 9         <property name="password" value="密码" />
10         <property name="defaultAutoCommit" value="false" />
11     </bean>
12     
13     <bean id="processEngineConfiguration"
14         class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">
15         <property name="dataSource" ref="dataSource" />
16         <property name="databaseType" value="mysql"/>
17         <property name="databaseSchemaUpdate" value="true" />
18         <property name="jobExecutorActivate" value="false" />
19     </bean>
20     
21     <bean id="processEngine" class="org.activiti.spring.ProcessEngineFactoryBean">
22         <property name="processEngineConfiguration" ref="processEngineConfiguration" />
23     </bean>
24     
25     <bean id="repositoryService" factory-bean="processEngine" factory-method="getRepositoryService" />
26     <bean id="runtimeService" factory-bean="processEngine" factory-method="getRuntimeService" />
27     <bean id="taskService" factory-bean="processEngine" factory-method="getTaskService" />
28     <bean id="historyService" factory-bean="processEngine" factory-method="getHistoryService" />
29     <bean id="formService" factory-bean="processEngine" factory-method="getFormService" />
30     <bean id="identityService" factory-bean="processEngine" factory-method="getIdentityService" />
31     
32     <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
33         <property name="dataSource" ref="dataSource" />
34     </bean>
35 </beans>

4、生成activiti数据表

BaseTestCase.java文件，运行

 1 package org.projMgr.TestCase;
 2 
 3 import org.junit.Test;
 4 import org.junit.runner.RunWith;
 5 import org.springframework.test.context.ContextConfiguration;
 6 import org.springframework.test.context.junit4.AbstractTransactionalJUnit4SpringContextTests;
 7 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
 8 import org.springframework.test.context.transaction.TransactionConfiguration;
 9 import org.springframework.transaction.annotation.Transactional;
10 
11 
12 
13 @RunWith(SpringJUnit4ClassRunner.class)
14 @ContextConfiguration("classpath:spring-activiti.xml")
15 @TransactionConfiguration(transactionManager="transactionManager", defaultRollback=false)
16 @Transactional
17 public class BaseTestCase extends AbstractTransactionalJUnit4SpringContextTests
18 
19     @Test
20     public void test()
21         System.out.println ("通导test"); 
22     
23     
24 

运行结果：

 1 SLF4J: Class path contains multiple SLF4J bindings.
 2 SLF4J: Found binding in [jar:file:/D:/developing/eclipse/workspace/ProjectManagement/projectManagement/src/main/webapp/WEB-INF/lib/slf4j-log4j12-1.7.6.jar!/org/slf4j/impl/StaticLoggerBinder.class]
 3 SLF4J: Found binding in [jar:file:/C:/Users/Administrator/.m2/repository/org/slf4j/slf4j-log4j12/1.7.7/slf4j-log4j12-1.7.7.jar!/org/slf4j/impl/StaticLoggerBinder.class]
 4 SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
 5 SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]
 6 [org.springframework.beans.factory.xml.XmlBeanDefinitionReader] - Loading XML bean definitions from class path resource [spring-activiti.xml]
 7 [org.springframework.context.support.GenericApplicationContext] - Refreshing org.springframework.context.support.GenericApplicationContext@5383967b: startup date [Tue Feb 28 18:32:15 CST 2017]; root of context hierarchy
 8 [org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor] - JSR-330 ‘javax.inject.Inject‘ annotation found and supported for autowiring
 9 [org.activiti.engine.impl.db.DbSqlSession] - performing create on engine with resource org/activiti/db/create/activiti.mysql.create.engine.sql
10 [org.activiti.engine.impl.db.DbSqlSession] - Found MySQL: majorVersion=5 minorVersion=1
11 [org.activiti.engine.impl.db.DbSqlSession] - performing create on history with resource org/activiti/db/create/activiti.mysql.create.history.sql
12 [org.activiti.engine.impl.db.DbSqlSession] - Found MySQL: majorVersion=5 minorVersion=1
13 [org.activiti.engine.impl.db.DbSqlSession] - performing create on identity with resource org/activiti/db/create/activiti.mysql.create.identity.sql
14 [org.activiti.engine.impl.db.DbSqlSession] - Found MySQL: majorVersion=5 minorVersion=1
15 [org.activiti.engine.impl.ProcessEngineImpl] - ProcessEngine default created
16 [org.springframework.test.context.transaction.TransactionalTestExecutionListener] - Began transaction (1) for test context [[email protected] testClass = BaseTestCase, testInstance = [email protected], testMethod = [email protected], testException = [null], mergedContextConfiguration = [[email protected] testClass = BaseTestCase, locations = ‘classpath:spring-activiti.xml‘, classes = ‘‘, contextInitializerClasses = ‘[]‘, activeProfiles = ‘‘, contextLoader = ‘org.springframework.test.context.support.DelegatingSmartContextLoader‘, parent = [null]]]; transaction manager [o[email protected]2453f95d]; rollback [false]
17 通导test
18 [org.springframework.test.context.transaction.TransactionalTestExecutionListener] - Committed transaction after test execution for test context [[email protected] testClass = BaseTestCase, testInstance = [email protected], testMethod = [email protected], testException = [null], mergedContextConfiguration = [[email protected] testClass = BaseTestCase, locations = ‘classpath:spring-activiti.xml‘, classes = ‘‘, contextInitializerClasses = ‘[]‘, activeProfiles = ‘‘, contextLoader = ‘org.springframework.test.context.support.DelegatingSmartContextLoader‘, parent = [null]]]
19 [org.springframework.context.support.GenericApplicationContext] - Closing [email protected]83967b: startup date [Tue Feb 28 18:32:15 CST 2017]; root of context hierarchy

数据库自动生成25张表：

 

 

 

5、测试

在需要存放文件的文件夹右键-new-other，选择activiti diagram

 

 设置文件名-next

 activiti diagram内置了一些 流程定义模板，但是这里我们选择不使用：

 finish之后出现.bpmn文件：

打开这个文件，输入配置信息：

id：流程的唯一标识，建议使用纯英文

 在设计区域右边找到StartEven，拖进来：

设置id、name（这里使用默认，没改）

单击左下第二个图标，选择“create user task”

设置id、name

设置节点分配人：

再建两个user task以及EndEvent：

 

右击文件Leave.bpmn选择OpenWith-XML Editor，可查看XML格式文件，将请假申请、销假的节点分配人设置为proposer（可在上一步设置）：

 

设置自动生成流程图片：

单击window菜单，选择preference，按下图设置：

在原有流程中随意拖动一点，再次保存，即可在同目录下生成png文件：

自动生成测试代码：

在Leave.bpmn文件右键-activiti-generate unit test，之后会在test/java/org/activiti/test包中生成ProcessTestLeave.java文件，

把它拉到holleworld文件夹下，修改包路径

ProcessTestLeave.java文件代码，其中filename路径的\\需要修改为/：

 1 package org.holleworld;
 2 
 3 import static org.junit.Assert.*;
 4 
 5 import java.util.HashMap;
 6 import java.util.Map;
 7 import java.io.FileInputStream;
 8 
 9 import org.activiti.engine.RepositoryService;
10 import org.activiti.engine.RuntimeService;
11 import org.activiti.engine.runtime.ProcessInstance;
12 import org.activiti.engine.test.ActivitiRule;
13 import org.junit.Rule;
14 import org.junit.Test;
15 
16 public class ProcessTestLeave 
17 
18     private String filename = "D:/developing/eclipse/workspace/ProjectManagement/projectManagement/src/test/java/org/holleworld/Leave.bpmn";
19 
20     @Rule
21     public ActivitiRule activitiRule = new ActivitiRule();
22 
23     @Test
24     public void startProcess() throws Exception 
25         RepositoryService repositoryService = activitiRule.getRepositoryService();
26         repositoryService.createDeployment().addInputStream("leave.bpmn20.xml",
27                 new FileInputStream(filename)).deploy();
28         RuntimeService runtimeService = activitiRule.getRuntimeService();
29         Map<String, Object> variableMap = new HashMap<String, Object>();
30         variableMap.put("name", "Activiti");
31         ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("leave", variableMap);
32         assertNotNull(processInstance.getId());
33         System.out.println("id " + processInstance.getId() + " "
34                 + processInstance.getProcessDefinitionId());
35     
36 

run as - JUnitTest，出错......

 repositoryService.createDeployment().addInputStream("leave.bpmn20.xml",new FileInputStream(filename)).deploy();

这步就跳出，且没有报错信息......尝试
修改leave.bpmn20.xml变成leave.bpmn.xml或者leave.bpmn
修改filename = "org/holleworld/Leave.bpmn";
均无用。

 另外找到测试代码：

TestActivitiHelloLeave.java

 

  1 package org.projMgr.TestCase;
  2   
  3 import java.util.Date;
  4 import java.util.List;
  5 
  6 import org.activiti.engine.HistoryService;
  7 import org.activiti.engine.ProcessEngine;
  8 import org.activiti.engine.ProcessEngineConfiguration;
  9 import org.activiti.engine.RepositoryService;
 10 import org.activiti.engine.RuntimeService;
 11 import org.activiti.engine.TaskService;
 12 import org.activiti.engine.history.HistoricActivityInstance;
 13 import org.activiti.engine.history.HistoricActivityInstanceQuery;
 14 import org.activiti.engine.history.HistoricProcessInstance;
 15 import org.activiti.engine.history.HistoricProcessInstanceQuery;
 16 import org.activiti.engine.history.HistoricTaskInstance;
 17 import org.activiti.engine.history.HistoricTaskInstanceQuery;
 18 import org.activiti.engine.repository.Deployment;
 19 import org.activiti.engine.repository.DeploymentBuilder;
 20 import org.activiti.engine.runtime.ProcessInstance;
 21 import org.activiti.engine.task.Task;
 22 import org.activiti.engine.task.TaskQuery;
 23 import org.junit.Before;
 24 import org.junit.Test;
 25   
 26 /**
 27  * Activiti入门程序
 28  * 
 29  */
 30 public class TestActivitiHello 
 31     ProcessEngine processEngine = null;
 32     @Before
 33     public void init()
 34         //自动加载classpath下名为activiti.cfg.xml文件
 35         processEngine = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource("spring-activiti.xml").buildProcessEngine();
 36     
 37     
 38     
 39   
 40     /** 部署流程定义 */
 41     @Test
 42     public void deploymentProcessDefinitionTest() 
 43         /**
 44          * RepositoryService是Activiti的仓库服务类,流程定义和部署对象相关的Service
 45          * 所谓的仓库指流程定义文档的两个文件：bpmn文件和流程图片
 46          */
 47         RepositoryService repositoryService = processEngine.getRepositoryService();
 48         // 创建一个部署对象DeploymentBuilder，用来定义流程部署的相关参数
 49         DeploymentBuilder deploymentBuilder = repositoryService.createDeployment();
 50         // 添加部署的名称
 51         deploymentBuilder.name("activiti");
 52         // 添加hello.bpmn和hello.png
 53         deploymentBuilder.addClasspathResource("org/projMgr/TestCase/hello.bpmn");
 54         deploymentBuilder.addClasspathResource("org/projMgr/TestCase/hello.png");
 55         // 部署流程定义
 56         Deployment deployment = deploymentBuilder.deploy();
 57   
 58         System.out.println("部署ID：" + deployment.getId());//1
 59         System.out.println("部署名称：" + deployment.getName());//activiti入门程序
 60     
 61     
 62 //    /** 启动流程实例 */
 63 //    @Test
 64 //    public void startHelloProcessInstanceTest() 
 65 //        // 流程定义的key
 66 //        String processDefinitionKey = "hello";
 67 //        RuntimeService service = processEngine.getRuntimeService();
 68 //        /**
 69 //         * 使用流程定义的key启动流程实例，key对应hello.bpmn文件中id的属性值，
 70 //         * 使用key值启动，默认是按照最新版本的流程定义启动
 71 //         */
 72 //        ProcessInstance pi = service.startProcessInstanceByKey(processDefinitionKey);
 73 //        System.out.println("流程实例ID:" + pi.getId());// 流程实例ID:2501
 74 //        // 流程定义ID:hello:1:4
 75 //        System.out.println("流程定义ID:" + pi.getProcessDefinitionId());
 76 //    
 77     
 78 //            @Test  
 79 //            public void setVariables()  
 80 //                String taskId = "342504";  
 81 //                TaskService taskService = processEngine.getTaskService();  
 82 //                taskService.setVariableLocal(taskId, "请假天数", 3);   //与任务ID绑定  
 83 //                    taskService.setVariable(taskId, "请假日期", new Date());  
 84 //                taskService.setVariable(taskId, "请假原因", "回家看亲");  
 85 //                  
 86 //                System.out.println("设置成功了");  
 87 //               
 88     
 89     
 90 //    /** 查看历史流程实例 */ 
 91 //    @Test
 92 //    public void queryHistoricProcessInstanceTest() throws Exception 
 93 //        HistoryService service = processEngine.getHistoryService();
 94 //      
 95 //        // 获取历史流程实例的查询对象
 96 //        HistoricProcessInstanceQuery hpiQuery = service.createHistoricProcessInstanceQuery();
 97 //        // 设置流程定义KEY
 98 //        hpiQuery.processDefinitionKey("hello");
 99 //        // 分页条件
100 //        //hpiQuery.listPage(firstResult, maxResults);
101 //        // 排序
102 //        hpiQuery.orderByProcessInstanceStartTime().desc();
103 //      
104 //        // 执行查询
105 //        List<HistoricProcessInstance> hpis = hpiQuery.list();
106 //        // 遍历查看结果
107 //        for (HistoricProcessInstance hpi : hpis) 
108 //            System.out.print("pid:" + hpi.getId() + ",");
109 //            System.out.print("pdid:" + hpi.getProcessDefinitionId() + ",");
110 //            System.out.print("startTime:" + hpi.getStartTime() + ",");
111 //            System.out.print("endTime:" + hpi.getEndTime() + ",");
112 //            System.out.print("duration:" + hpi.getDurationInMillis() + ",");
113 //            System.out.println("vars:" + hpi.getProcessVariables());
114 //        
115 //      
116 //    
117 //    /** 查看历史活动实例 */
118 //    @Test
119 //    public void queryHistoricActivityInstanceTest() throws Exception 
120 //        HistoryService service = processEngine.getHistoryService();
121 //        HistoricActivityInstanceQuery haiq=service.createHistoricActivityInstanceQuery();
122 //        //过滤条件
123 //        haiq.processInstanceId("45001");
124 //        // 分页条件
125 //        //haiq.listPage(firstResult, maxResults);
126 //        //排序
127 //        haiq.orderByHistoricActivityInstanceEndTime().asc();
128 //        List<HistoricActivityInstance> hais = haiq.list();
129 //      
130 //        for (HistoricActivityInstance hai : hais) 
131 //            System.out.print("activitiId:" + hai.getActivityId() + "，");
132 //            System.out.print("name:" + hai.getActivityName() + "，");
133 //            System.out.print("type:" + hai.getActivityType() + "，");
134 //            System.out.print("pid:" + hai.getProcessInstanceId() + "，");
135 //            System.out.print("assignee:" + hai.getAssignee() + "，");
136 //            System.out.print("startTime:" + hai.getStartTime() + "，");
137 //            System.out.print("endTime:" + hai.getEndTime() + "，");
138 //            System.out.println("duration:" + hai.getDurationInMillis());
139 //        
140 //    
141     
142 //    /** 查看历史任务实例 */
143 //    @Test
144 //    public void queryHistoricTaskInstanceTest() throws Exception 
145 //        HistoryService service = processEngine.getHistoryService();
146 //        HistoricTaskInstanceQuery htiq = service.createHistoricTaskInstanceQuery();
147 //        htiq.taskAssignee("李四");
148 //        List<HistoricTaskInstance> tasks = htiq.list();
149 //      
150 //        for (HistoricTaskInstance hti : tasks) 
151 //            System.out.print("pid:" + hti.getProcessInstanceId() + "，");
152 //            System.out.print("assignee:" + hti.getAssignee() + "，");
153 //            System.out.print("startTime:" + hti.getStartTime() + "，");
154 //            System.out.print("endTime:" + hti.getEndTime() + "，");
155 //            System.out.println("duration:" + hti.getDurationInMillis());
156 //        
157 //    
158     
159 //    /**查询当前人的个人任务*/
160 //    @Test
161 //    public void queryAssigneeTaskTest()
162 //        //与正在执行的任务管理相关的Service
163 //        TaskService service = processEngine.getTaskService();
164 //        //创建任务查询对象
165 //        TaskQuery query = service.createTaskQuery();
166 //        //指定个人任务查询，指定办理人
167 //        query.taskAssignee("王五");
168 //        List<Task> list = query.list();
169 //        if(list!=null && list.size()>0)
170 //            for(Task task:list)
171 //                System.out.println("任务ID:"+task.getId());
172 //                System.out.println("任务名称:"+task.getName());
173 //                System.out.println("任务的创建时间:"+task.getCreateTime());
174 //                System.out.println("任务的办理人:"+task.getAssignee());
175 //                System.out.println("流程实例ID："+task.getProcessInstanceId());
176 //                System.out.println("执行对象ID:"+task.getExecutionId());
177 //                System.out.println("流程定义ID:"+task.getProcessDefinitionId());
178 //            
179 //        
180 //    
181     
182 //    /**完成个人任务*/
183 //    @Test
184 //    public void completeTaskTest()
185 //        //任务ID
186 //        String taskId = "50002"; //        需改id
187 //        processEngine.getTaskService()
188 //                    .complete(taskId);
189 //        System.out.println("完成任务：任务ID："+taskId);
190 //    
191     
192     
193     
194 //    /** 删除流程定义 */
195 //    @Test
196 //    public void deleteProcessDefinition() 
197 //        // 使用部署ID，完成删除
198 //        String deploymentId = "27501";
199 //      
200 //        //不带级联的删除 只能删除没有启动的流程，如果流程启动，就会抛出异常
201 //        // processEngine.getRepositoryService().deleteDeployment(deploymentId);
202 //      
203 //        /**
204 //         * 级联删除 不管流程是否启动，都能可以删除
205 //         */
206 //        processEngine.getRepositoryService().deleteDeployment(deploymentId, true);
207 //        System.out.println("删除成功！");
208 //    
209     
210     
211     
212     
213 

分步骤测试：

 

 1     /** 部署流程定义 */
 2     @Test
 3     public void deploymentProcessDefinitionTest() 
 4         /**
 5          * RepositoryService是Activiti的仓库服务类,流程定义和部署对象相关的Service
 6          * 所谓的仓库指流程定义文档的两个文件：bpmn文件和流程图片
 7          */
 8         RepositoryService repositoryService = processEngine.getRepositoryService();
 9         // 创建一个部署对象DeploymentBuilder，用来定义流程部署的相关参数
10         DeploymentBuilder deploymentBuilder = repositoryService.createDeployment();
11         // 添加部署的名称
12         deploymentBuilder.name("holleworld");
13         // 添加hello.bpmn和hello.png
14         deploymentBuilder.addClasspathResource("org/holleworld/Leave.bpmn");
15         deploymentBuilder.addClasspathResource("org/holleworld/Leave.png");
16         // 部署流程定义
17         Deployment deployment = deploymentBuilder.deploy();
18   
19         System.out.println("部署ID：" + deployment.getId());//1
20         System.out.println("部署名称：" + deployment.getName());//activiti入门程序
21     

运行结果：

 1     /** 启动流程实例 */
 2     @Test
 3     public void startHelloProcessInstanceTest() 
 4         // 流程定义的key
 5         String processDefinitionKey = "leave";
 6         RuntimeService service = processEngine.getRuntimeService();
 7         /**
 8          * 使用流程定义的key启动流程实例，key对应hello.bpmn文件中id的属性值，
 9          * 使用key值启动，默认是按照最新版本的流程定义启动
10          */
11         ProcessInstance pi = service.startProcessInstanceByKey(processDefinitionKey);
12         System.out.println("流程实例ID:" + pi.getId());// 流程实例ID
13         // 流程定义ID:hello:1:4
14         System.out.println("流程定义ID:" + pi.getProcessDefinitionId());
15     

运行结果：

 1     /** 查看历史流程实例 */ 
 2     @Test
 3     public void queryHistoricProcessInstanceTest() throws Exception 
 4         HistoryService service = processEngine.getHistoryService();
 5       
 6         // 获取历史流程实例的查询对象
 7         HistoricProcessInstanceQuery hpiQuery = service.createHistoricProcessInstanceQuery();
 8         // 设置流程定义KEY
 9         hpiQuery.processDefinitionKey("leave");
10         // 分页条件
11         //hpiQuery.listPage(firstResult, maxResults);
12         // 排序
13         hpiQuery.orderByProcessInstanceStartTime().desc();
14       
15         // 执行查询
16         List<HistoricProcessInstance> hpis = hpiQuery.list();
17         // 遍历查看结果
18         for (HistoricProcessInstance hpi : hpis) 
19             System.out.print("pid:" + hpi.getId() + ",");
20             System.out.print("pdid:" + hpi.getProcessDefinitionId() + ",");
21             System.out.print("startTime:" + hpi.getStartTime() + ",");
22             System.out.print("endTime:" + hpi.getEndTime() + ",");
23             System.out.print("duration:" + hpi.getDurationInMillis() + ",");
24             System.out.println("vars:" + hpi.getProcessVariables());
25         
26       

运行结果：

 1     /** 查看历史活动实例 */
 2     @Test
 3     public void queryHistoricActivityInstanceTest() throws Exception 
 4         HistoryService service = processEngine.getHistoryService();
 5         HistoricActivityInstanceQuery haiq=service.createHistoricActivityInstanceQuery();
 6         //过滤条件
 7         haiq.processInstanceId("70001");
 8         // 分页条件
 9         //haiq.listPage(firstResult, maxResults);
10         //排序
11         haiq.orderByHistoricActivityInstanceEndTime().asc();
12         List<HistoricActivityInstance> hais = haiq.list();
13       
14         for (HistoricActivityInstance hai : hais) 
15             System.out.print("activitiId:" + hai.getActivityId() + "，");
16             System.out.print("name:" + hai.getActivityName() + "，");
17             System.out.print("type:" + hai.getActivityType() + "，");
18             System.out.print("pid:" + hai.getProcessInstanceId() + "，");
19             System.out.print("assignee:" + hai.getAssignee() + "，");
20             System.out.print("startTime:" + hai.getStartTime() + "，");
21             System.out.print("endTime:" + hai.getEndTime() + "，");
22             System.out.println("duration:" + hai.getDurationInMillis());
23         
24     

运行结果

 1     /**查询当前人的个人任务*/
 2     @Test
 3     public void queryAssigneeTaskTest()
 4         //与正在执行的任务管理相关的Service
 5         TaskService service = processEngine.getTaskService();
 6         //创建任务查询对象
 7         TaskQuery query = service.createTaskQuery();
 8         //指定个人任务查询，指定办理人
 9         query.taskAssignee("proposer");
10         List<Task> list = query.list();
11         if(list!=null && list.size()>0)
12             for(Task task:list)
13                 System.out.println("任务ID:"+task.getId());
14                 System.out.println("任务名称:"+task.getName());
15                 System.out.println("任务的创建时间:"+task.getCreateTime());
16                 System.out.println("任务的办理人:"+task.getAssignee());
17                 System.out.println("流程实例ID："+task.getProcessInstanceId());
18                 System.out.println("执行对象ID:"+task.getExecutionId());
19                 System.out.println("流程定义ID:"+task.getProcessDefinitionId());
20             
21         
22     

运行结果：

 1     /** 查看历史任务实例 */
 2     @Test
 3     public void queryHistoricTaskInstanceTest() throws Exception 
 4         HistoryService service = processEngine.getHistoryService();
 5         HistoricTaskInstanceQuery htiq = service.createHistoricTaskInstanceQuery();
 6 //        htiq.taskAssignee("null");
 7         List<HistoricTaskInstance> tasks = htiq.list();
 8       
 9         for (HistoricTaskInstance hti : tasks) 
10             System.out.print("pid:" + hti.getProcessInstanceId() + "，");
11             System.out.print("assignee:" + hti.getAssignee() + "，");
12             System.out.print("startTime:" + hti.getStartTime() + "，");
13             System.out.print("endTime:" + hti.getEndTime() + "，");
14             System.out.println("duration:" + hti.getDurationInMillis());
15         
16     

运行结果：

1     /**完成个人任务*/
2     @Test
3     public void completeTaskTest()
4         //任务ID
5         String taskId = "70004"; //        需改id
6         processEngine.getTaskService()
7                     .complete(taskId);
8         System.out.println("完成任务：任务ID："+taskId);
9     

运行结果：

 

原文地址：https://www.cnblogs.com/sucia-panda/p/6437943.html