工作流(Workflow)，就是“业务过程的部分或整体在计算机应用环境下的自动化”，它主要解决的是“使在多个参与者之间按照某种预定义的规则传递文档、信息或任务的过程自动进行，从而实现某个预期的业务目标，或者促使此目标的实现”。
工作流管理系统(Workflow Management System, WfMS)是一个软件系统，它完成工作量的定义和管理，并按照在系统中预先定义好的工作流规则进行工作流实例的执行。工作流管理系统不是企业的业务系统，而是为企业的业务系统的运行提供了一个软件的支撑环境。
工作流管理联盟(WfMC，Workflow Management Coalition)给出的关于工作流管理系统的定义是：工作流管理系统是一个软件系统，它通过执行经过计算的流程定义去支持一批专门设定的业务流程。工作流管理系统被用来定义、管理、和执行工作流程。
工作流管理系统的目标：管理工作的流程以确保工作在正确的时间被期望的人员所执行——在自动化进行的业务过程中插入人工的执行和干预。
Activiti5是由Alfresco软件在2010年5月17日发布的业务流程管理（BPM）框架，它是覆盖了业务流程管理、工作流、服务协作等领域的一个开源的、灵活的、易扩展的可执行流程语言框架。
Activiti基于Apache许可的开源BPM平台，创始人Tom Baeyens是JBoss jBPM的项目架构师，它特色是提供了eclipse插件，开发人员可以通过插件直接绘画出业务流程图。
ProcessEngine对象，这是Activiti工作的核心。负责生成流程运行时的各种实例及数据、监控和管理流程的运行。
业务流程建模与标注（Business Process Model and Notation，BPMN) ，描述流程的基本符号，包括这些图元如何组合成一个业务流程图（Business Process Diagram）。
Activiti的后台是有数据库的支持，所有的表都以ACT_开头。 第二部分是表示表的用途的两个字母标识。 用途也和服务的API对应。
ACT_RE_*：'RE’表示repository。 这个前缀的表包含了流程定义和流程静态资源 （图片，规则，等等）。ACT_RU_*：'RU’表示runtime。 这些运行时的表，包含流程实例，任务，变量，异步任务，等运行中的数据。 Activiti只在流程实例执行过程中保存这些数据， 在流程结束时就会删除这些记录。 这样运行时表可以一直很小速度很快。ACT_ID_*：'ID’表示identity。 这些表包含身份信息，比如用户，组等等。ACT_HI_*：'HI’表示history。 这些表包含历史数据，比如历史流程实例， 变量，任务等等。ACT_GE_*：通用数据， 用于不同场景下，如存放资源文件。Activiti核心配置文件，配置流程引擎创建工具的基本参数和数据库连接池参数。 定义数据库配置参数：
jdbcUrl: 数据库的JDBC URL。jdbcDriver: 对应不同数据库类型的驱动。jdbcUsername: 连接数据库的用户名。jdbcPassword: 连接数据库的密码。基于JDBC参数配置的数据库连接 会使用默认的MyBatis连接池。 下面的参数可以用来配置连接池（来自MyBatis参数）：jdbcMaxActiveConnections: 连接池中处于被使用状态的连接的最大值。默认为10。jdbcMaxIdleConnections: 连接池中处于空闲状态的连接的最大值。jdbcMaxCheckoutTime: 连接被取出使用的最长时间，超过时间会被强制回收。 默认为20000（20秒）。jdbcMaxWaitTime: 这是一个底层配置，让连接池可以在长时间无法获得连接时， 打印一条日志，并重新尝试获取一个连接。（避免因为错误配置导致沉默的操作失败）。 默认为20000（20秒）。示例 也可以使用javax.sql.DataSource。 （比如，Apache Commons的DBCP）：
日志的配置文件，Activiti操作数据库的时候，整合的日志文件
可以通过纯java代码初始化数据库 在Activiti中，在创建核心的流程引擎对象时会自动建表。如果程序正常执行，mysql会自动建库，然后创建23张表。
在Actiiti5中定制流程必定会操作到数据库，如果都像上面那样写一大段代码会非常麻烦，所以我们可以把数据库连接配置写入配置文件。
一个类似spring结构的配置文件，清空内容后改名为activiti.cfg.xml，用来做流程引擎的相关配置。
按照上面代码配置ProcessEngineConfiguration对象，主要定义数据库的连接配置和建表策略，配置文件代码如下： Java代码如下： createProcessEngineConfigurationFromResource的参数值为我们添加的配置文件activiti.cfg.xml的名称，执行java代码，流程引擎对象创建成功运行后数据库会自动建表。
idea的创建流程
在前面看到了两种创建ProcessEngine（流程引擎）的方式，而这里要简化很多，调用ProcessEngines的getDefaultProceeEngine方法时会自动加载classpath下名为activiti.cfg.xml文件。
可以产生RepositoryService RepositoryService repositoryService = process.getRepositoryService(); 可以产生RuntimeService RuntimeService runtimeService = process.getRuntimeService(); 可以产生TaskService TaskService taskService = process.getTaskService(); 可以产生HistoryService HistoryService historyService = process.getHistoryService();各个Service的作用：
service作用RepositoryService管理流程定义RuntimeService执行管理，包括启动、推进、删除流程实例等操作TaskService任务管理HistoryService历史管理(执行完的数据的管理)IdentityService组织机构管理FormService一个可选服务，任务表单管理ManagerService是Activiti的仓库服务类。所谓的仓库指流程定义文档的两个文件：bpmn文件和流程图片。
产生方式 RepositoryService repositoryService = process.getRepositoryService(); 可以产生DeploymentBuilder，用来定义流程部署的相关参数 DeploymentBuilder deployment = repositoryService.createDeployment(); 删除流程定义 repositoryService.deleteDeployment(deploymentId);是activiti的流程执行服务类。可以从这个服务类中获取很多关于流程执行相关的信息。
是activiti的任务服务类。可以从这个类中获取任务的信息。
是activiti的查询历史信息的类。在一个流程执行完成后，这个对象为我们提供查询历史信息。
流程定义类。可以从这里获得资源文件等。
代表流程定义的执行实例。如范冰冰请了一天的假，她就必须发出一个流程实例的申请。一个流程实例包括了所有的运行节点。我们可以利用这个对象来了解当前流程实例的进度等信息。流程实例就表示一个流程从开始到结束的最大的流程分支，即一个流程中流程实例只有一个。
Activiti用这个对象去描述流程执行的每一个节点。在没有并发的情况下，Execution就是同ProcessInstance。流程按照流程定义的规则执行一次的过程，就可以表示执行对象Execution。
如图为ProcessInstance的源代码： 从源代码中可以看出ProcessInstance就是Execution。但在现实意义上有所区别： 在单线流程中，如上图的贷款流程，ProcessInstance与Execution是一致的。 这个例子有一个特点：wire money(汇钱)和archive(存档)是并发执行的。 这个时候，总线路代表ProcessInstance，而分线路中每个活动代表Execution。
总结：
一个流程中，执行对象可以存在多个，但是流程实例只能有一个。当流程按照规则只执行一次的时候，那么流程实例就是执行对象。这里使用RepositoryService部署流程定义 addClasspathResource表示从类路径下加载资源文件，一次只能加载一个文件
这里使用RuntimeService启动流程实例
这里使用TaskService完成任务的查询
这里使用TaskService完成任务的办理
BPMN 2.0根节点是definitions节点。 这个元素中，可以定义多个流程定义（不过我们建议每个文件只包含一个流程定义，可以简化开发过程中的维护难度）。
一个空的流程定义看起来像下面这样。注意，definitions元素 最少也要包含xmlns 和 targetNamespace的声明。 targetNamespace可以是任意值，它用来对流程实例进行分类。 说明：流程定义文档有两部分组成：
bpmn文件流程规则文件。在部署后，每次系统启动时都会被解析，把内容封装成流程定义放入项目缓存中。Activiti框架结合这个xml文件自动管理流程，流程的执行就是按照bpmn文件定义的规则执行的，bpmn文件是给计算机执行用的。
展示流程图的图片在系统里需要展示流程的进展图片，图片是给用户看的。
存储流程定义相关的部署信息，即流程定义文档的存放地。
每部署一次就会增加两条记录，一条是关于bpmn规则文件的，一条是图片的（如果部署时只指定了bpmn一个文件，activiti会在部署时解析bpmn文件内容自动生成流程图）。两个文件不是很大，都是以二进制形式存储在数据库中。
压缩成zip格式的文件，使用zip的输入流用作部署流程定义
程定义和部署对象相关的Service都是RepositoryService。
创建流程定义查询对象，可以在ProcessDefinitionQuery上设置查询的相关参数
调用ProcessDefinitionQuery对象的list方法，执行查询，获得符合条件的流程定义列表
由运行结果可以看出： Key和Name的值为：bpmn文件process节点的id和name的属性值
key属性被用来区别不同的流程定义。
带有特定key的流程定义第一次部署时，version为1。之后每次部署都会在当前最高版本号上加1
Id的值的生成规则为:{processDefinitionKey}:{processDefinitionVersion}:{generated-id}, 这里的generated-id是一个自动生成的唯一的数字
重复部署一次，deploymentId的值以一定的形式变化 规则act_ge_property表生成
查询出流程定义文档。主要查的是图片，用于显示流程用。
deploymentId为流程部署IDresourceName为act_ge_bytearray表中NAME_列的值使用repositoryService的getDeploymentResourceNames方法可以获取指定部署下得所有文件的名称使用repositoryService的getResourceAsStream方法传入部署ID和资源图片名称可以获取部署下指定名称文件的输入流最后的有关IO流的操作，使用FileUtils工具的copyInputStreamToFile方法完成流程流程到文件的拷贝，将资源文件以流的形式输出到指定文件夹下当流程实例产生后会在act_ru_execution表中产生一条数据，代表正在执行的流程对象 需要理解的字段：
ID_：正在执行的流程对象的IDPROCE_INST_ID_：流程实例IDPROCE_DEF_ID：流程定义的IDACT_ID_：执行到的任务节点ID在流程流程实例的历史表中也会产生一条数据 需要理解的字段：
ID_：正在执行的流程对象的IDPROCE_INST_ID_：流程实例IDPROCE_DEF_ID：流程定义的IDACT_ID_：执行到的任务节点IDSTART_TIME_：流程开始的时间END_TIME_：流程结束时间流程实例启动后act_ru_task表中会有一条数据 需要理解的字段：
ID_：任务 IDEXECUTION_ID_：正在执行的流程对象IDPROC_INST_ID：流程实例的IDPROC_DEF_ID_：流程定义IDNAME：当前任务节点的名称TASK_DEF_KEY：当前任务节点的IDCREATE_TIME：任务节点的创建时间ASSIGNEE：当前任务的分配人任务的历史表中会有一条数据 需要理解的字段同上
所有活动历史表里面会有数据
在activiti任务中，主要分为两大类查询任务（个人任务和组任务）：
确切指定了办理者的任务，这个任务将成为指定者的私有任务，即个人任务。无法指定具体的某一个人来办理的任务，可以把任务分配给几个人或者一到 多个小组，让这个范围内的用户可以选择性（如有空余时间时）来办理这类任务，即组任务。在流程执行的过程中，创建的流程实例ID在整个过程中都不会变，当流程结束后，流程实例将会在正在执行的执行对象表中（act_ru_execution）被删除。
因为是查询流程实例，所以先获取runtimeService创建流程实例查询对象，设置实例ID过滤参数由于一个流程实例ID只对应一个实例，使用singleResult执行查询返回一个唯一的结果，如果结果数量大于1，则抛出异常判断指定ID的实例是否存在，如果结果为空，则代表流程结束，实例在正在执行的执行对象表中已被删除，转换成历史数据。流程变量在整个工作流中扮演很重要的作用。例如：请假流程中有请假天数、请假原因等一些参数都为流程变量的范围。
流程变量的作用域范围是只对应一个流程实例。也就是说各个流程实例的流程变量是不相互影响的。流程实例结束完成以后流程变量还保存在数据库中（存放到流程变量的历史表中）。
历史的流程变量查询，指定流程变量的名称，查询act_hi_varinst表（也可以针对，流程实例ID，执行对象ID，任务ID查询）
如图是从官网列出来的流程变量的类型： 从图中可以看出包括了大部分封装类型和Date、String和实现了Serializable接口的类的类型。
使用流程变量，设置连线需要的流程变量的名称message，并设置流程变量的值，流程会按照指定的连线完成任务。
流程变量如果只有一个，则可以不使用流程变量设置codition的名称。
如果有多个，则需要使用流程变量设置codition的名称。message表示流程变量的名称，‘不重要’表示流程变量的值，${}中间的内容要使用boolean类型的表达式，用来判断应该执行的连线。
接收任务是一个简单任务，它会等待对应消息的到达。 当前，官方只实现了这个任务的java语义。 当流程达到接收任务，流程状态会保存到数据库中。
在任务创建后，意味着流程会进入等待状态， 直到引擎接收了一个特定的消息， 这会触发流程穿过接收任务继续执行。
当前任务（一般指机器自动完成，但需要耗费一定时间的工作）完成后，向后推移流程，可以调用runtimeService.signal(executionId)，传递接收执行对象的id。
1.流程图中任务节点的配置 2.测试代码
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); //部署流程定义，启动流程实例 @Test public void testTask() throws Exception { // 1 发布流程 InputStream inputStreamBpmn = this.getClass().getResourceAsStream("taskProcess.bpmn"); InputStream inputStreamPng = this.getClass().getResourceAsStream("taskProcess.png"); processEngine.getRepositoryService()// .createDeployment()// .addInputStream("userTask.bpmn", inputStreamBpmn)// .addInputStream("userTask.png", inputStreamPng)// .deploy(); // 2 启动流程 //启动流程实例的同时，设置流程变量 ProcessInstance pi = processEngine.getRuntimeService()// .startProcessInstanceByKey("taskProcess"); System.out.println("pid:" + pi.getId()); } //查询我的个人任务列表 @Test public void findMyTaskList(){ String userId = "张三丰"; List<Task> list = processEngine.getTaskService()// .createTaskQuery()// .taskAssignee(userId)//指定个人任务查询 .list(); for(Task task:list ){ System.out.println("id="+task.getId()); System.out.println("name="+task.getName()); System.out.println("assinee="+task.getAssignee()); System.out.println("createTime="+task.getCreateTime()); System.out.println("executionId="+task.getExecutionId()); } } //完成任务 @Test public void completeTask(){ String taskId = "3209"; processEngine.getTaskService()// .complete(taskId);// System.out.println("完成任务"); } 张三丰是个人任务的办理人但是这样分配任务的办理人不够灵活，因为项目开发中任务的办理人不要放置XML文件中。1.流程图中任务节点的配置 2.测试代码
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); //部署流程定义，启动流程实例 @Test public void testTask() throws Exception { // 1 发布流程 InputStream inputStreamBpmn = this.getClass().getResourceAsStream("taskProcess.bpmn"); InputStream inputStreamPng = this.getClass().getResourceAsStream("taskProcess.png"); processEngine.getRepositoryService()// .createDeployment()// .addInputStream("userTask.bpmn", inputStreamBpmn)// .addInputStream("userTask.png", inputStreamPng)// .deploy(); // 2 启动流程 //启动流程实例的同时，设置流程变量 Map<String, Object> variables = new HashMap<String, Object>(); variables.put("userID", "张翠三"); ProcessInstance pi = processEngine.getRuntimeService()// .startProcessInstanceByKey("taskProcess",variables); System.out.println("pid:" + pi.getId()); } //查询我的个人任务列表 @Test public void findMyTaskList(){ String userId = "张翠三"; List<Task> list = processEngine.getTaskService()// .createTaskQuery()// .taskAssignee(userId)//指定个人任务查询 .list(); for(Task task:list ){ System.out.println("id="+task.getId()); System.out.println("name="+task.getName()); System.out.println("assinee="+task.getAssignee()); System.out.println("createTime="+task.getCreateTime()); System.out.println("executionId="+task.getExecutionId()); } } //完成任务 @Test public void completeTask(){ String taskId = "3209"; processEngine.getTaskService()// .complete(taskId);// System.out.println("完成任务"); } 张翠山是个人任务的办理人在开发中，可以在页面中指定下一个任务的办理人，通过流程变量设置下一个任务的办理人1.流程图中任务节点的配置 此时流程图的XML文件，如图： 2.TaskListenerImpl类，用来设置任务的办理人
一定要实现TaskListener接口
public class TaskListenerImpl implements TaskListener { /**指定个人任务和组任务的办理人*/ @Override public void notify(DelegateTask delegateTask) { String assignee = "张无忌"; //指定个人任务 delegateTask.setAssignee(assignee); } }3.测试代码
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); //部署流程定义，启动流程实例 @Test public void testTask() throws Exception { // 1 发布流程 InputStream inputStreamBpmn = this.getClass().getResourceAsStream("taskProcess.bpmn"); InputStream inputStreamPng = this.getClass().getResourceAsStream("taskProcess.png"); processEngine.getRepositoryService()// .createDeployment()// .addInputStream("userTask.bpmn", inputStreamBpmn)// .addInputStream("userTask.png", inputStreamPng)// .deploy(); // 2 启动流程 ProcessInstance pi = processEngine.getRuntimeService()// .startProcessInstanceByKey("taskProcess"); System.out.println("pid:" + pi.getId()); } //查询我的个人任务列表 @Test public void findMyTaskList(){ String userId = "张无忌"; List<Task> list = processEngine.getTaskService()// .createTaskQuery()// .taskAssignee(userId)//指定个人任务查询 .list(); for(Task task:list ){ System.out.println("id="+task.getId()); System.out.println("name="+task.getName()); System.out.println("assinee="+task.getAssignee()); System.out.println("createTime="+task.getCreateTime()); System.out.println("executionId="+task.getExecutionId()); } } //完成任务 @Test public void completeTask(){ String taskId = "3408"; processEngine.getTaskService()// .complete(taskId);// System.out.println("完成任务"); } //可以分配个人任务从一个人到另一个人（认领任务） @Test public void setAssigneeTask(){ //任务ID String taskId = "3408"; //指定认领的办理者 String userId = "周芷若"; processEngine.getTaskService()// .setAssignee(taskId, userId); } 在类中使用delegateTask.setAssignee(assignee)的方式分配个人任务的办理人，此时张无忌是下一个任务的办理人通过processEngine.getTaskService().setAssignee(taskId, userId)将个人任务从一个人分配给另一个人，此时张无忌不再是下一个任务的办理人，而换成了周芷若在开发中，可以将每一个任务的办理人规定好，例如张三的领导是李四，李四的领导是王五，这样张三提交任务，就可以查询出张三的领导是李四，通过类的方式设置下一个任务的办理人1.流程图中任务节点的配置 2.测试代码
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); //部署流程定义，启动流程实例 @Test public void testTask() throws Exception { // 1 发布流程 InputStream inputStreamBpmn = this.getClass().getResourceAsStream("taskProcess.bpmn"); InputStream inputStreamPng = this.getClass().getResourceAsStream("taskProcess.png"); processEngine.getRepositoryService()// .createDeployment()// .addInputStream("userTask.bpmn", inputStreamBpmn)// .addInputStream("userTask.png", inputStreamPng)// .deploy(); // 2 启动流程 ProcessInstance pi = processEngine.getRuntimeService()// .startProcessInstanceByKey("taskProcess"); System.out.println("pid:" + pi.getId()); } //3 查询我的个人任务列表 @Test public void findMyTaskList(){ String userId = "小A"; List<Task> list = processEngine.getTaskService()// .createTaskQuery()// .taskAssignee(userId)//指定个人任务查询 .list(); for(Task task:list ){ System.out.println("id="+task.getId()); System.out.println("name="+task.getName()); System.out.println("assinee="+task.getAssignee()); System.out.println("createTime="+task.getCreateTime()); System.out.println("executionId="+task.getExecutionId()); } } //4 查询组任务列表 @Test public void findGroupList(){ String userId = "小A"; List<Task> list = processEngine.getTaskService()// .createTaskQuery()// .taskCandidateUser(userId)//指定组任务查询 .list(); for(Task task:list ){ System.out.println("id="+task.getId()); System.out.println("name="+task.getName()); System.out.println("assinee="+task.getAssignee()); System.out.println("createTime ="+task.getCreateTime()); System.out.println("executionId="+task.getExecutionId()); System.out.println("##################################"); } } //5 查询组任务成员列表 @Test public void findGroupUser(){ String taskId = "3709"; List<IdentityLink> list = processEngine.getTaskService()// .getIdentityLinksForTask(taskId); //List<IdentityLink> list = processEngine.getRuntimeService()// // .getIdentityLinksForProcessInstance(instanceId); for(IdentityLink identityLink:list ){ System.out.println("userId="+identityLink.getUserId()); System.out.println("taskId="+identityLink.getTaskId()); System.out.println("piId="+identityLink.getProcessInstanceId()); System.out.println("######################"); } } //6 查询组任务成员历史列表 @Test public void findGroupHisUser(){ String taskId = "3709"; List<HistoricIdentityLink> list = processEngine.getHistoryService()// .getHistoricIdentityLinksForTask(taskId); // List<HistoricIdentityLink> list = processEngine.getHistoryService()// // .getHistoricIdentityLinksForProcessInstance(processInstanceId); for(HistoricIdentityLink identityLink:list ){ System.out.println("userId="+identityLink.getUserId()); System.out.println("taskId="+identityLink.getTaskId()); System.out.println("piId="+identityLink.getProcessInstanceId()); System.out.println("######################"); } } //完成任务 @Test public void completeTask(){ String taskId = "3709"; processEngine.getTaskService()// .complete(taskId);// System.out.println("完成任务"); } 小A，小B，小C，小D是组任务的办理人但是这样分配组任务的办理人不够灵活，因为项目开发中任务的办理人不要放置XML文件中。act_ru_identitylink表存放任务的办理人，包括个人任务和组任务，表示正在执行的任务act_hi_identitylink表存放任务的办理人，包括个人任务和组任务，表示历史任务个人任务和组任务的区别：
如果是个人任务TYPE的类型表示participant（参与者）如果是组任务TYPE的类型表示candidate（候选者）和participant（参与者）1.流程图中任务节点的配置 2.测试代码
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); //部署流程定义，启动流程实例 @Test public void testTask() throws Exception { // 1 发布流程 InputStream inputStreamBpmn = this.getClass().getResourceAsStream("taskProcess.bpmn"); InputStream inputStreamPng = this.getClass().getResourceAsStream("taskProcess.png"); processEngine.getRepositoryService()// .createDeployment()// .addInputStream("userTask.bpmn", inputStreamBpmn)// .addInputStream("userTask.png", inputStreamPng)// .deploy(); // 2 启动流程 //启动流程实例，同时设置流程变量，用来指定组任务的办理人 Map<String, Object> variables = new HashMap<String, Object>(); variables.put("userIDs", "大大,小小,中中"); ProcessInstance pi = processEngine.getRuntimeService()// .startProcessInstanceByKey("taskProcess",variables); System.out.println("pid:" + pi.getId()); } //查询我的个人任务列表 @Test public void findMyTaskList(){ String userId = "大大"; List<Task> list = processEngine.getTaskService()// .createTaskQuery()// .taskAssignee(userId)//指定个人任务查询 .list(); for(Task task:list ){ System.out.println("id="+task.getId()); System.out.println("name="+task.getName()); System.out.println("assinee="+task.getAssignee()); System.out.println("assinee="+task.getCreateTime()); System.out.println("executionId="+task.getExecutionId()); } } //查询组任务列表 @Test public void findGroupList(){ String userId = "大大"; List<Task> list = processEngine.getTaskService()// .createTaskQuery()// .taskCandidateUser(userId)//指定组任务查询 .list(); for(Task task:list ){ System.out.println("id="+task.getId()); System.out.println("name="+task.getName()); System.out.println("assinee="+task.getAssignee()); System.out.println("assinee="+task.getCreateTime()); System.out.println("executionId="+task.getExecutionId()); System.out.println("##################################"); } } //查询组任务成员列表 @Test public void findGroupUser(){ String taskId = "3709"; List<IdentityLink> list = processEngine.getTaskService()// .getIdentityLinksForTask(taskId); for(IdentityLink identityLink:list ){ System.out.println("userId="+identityLink.getUserId()); System.out.println("taskId="+identityLink.getTaskId()); System.out.println("piId="+identityLink.getProcessInstanceId()); System.out.println("######################"); } } //查询组任务成员历史列表 @Test public void findGroupHisUser(){ String taskId = "3709"; List<HistoricIdentityLink> list = processEngine.getHistoryService()// .getHistoricIdentityLinksForTask(taskId); for(HistoricIdentityLink identityLink:list ){ System.out.println("userId="+identityLink.getUserId()); System.out.println("taskId="+identityLink.getTaskId()); System.out.println("piId="+identityLink.getProcessInstanceId()); System.out.println("######################"); } } //完成任务 @Test public void completeTask(){ String taskId = "3709"; processEngine.getTaskService()// .complete(taskId);// System.out.println("完成任务"); } 大大，中中，小小是组任务的办理人在开发中，可以在页面中指定下一个组任务的办理人，通过流程变量设置下一个任务的办理人1.流程图中任务节点的配置 此时流程图的XML文件，如图： 2.TaskListenerImpl类，用来设置任务的办理人
public class TaskListenerImpl implements TaskListener { /**指定个人任务和组任务的办理人*/ @Override public void notify(DelegateTask delegateTask) { String userId1 = "孙悟空"; String userId2 = "猪八戒"; //指定组任务 delegateTask.addCandidateUser(userId1); delegateTask.addCandidateUser(userId2); } } 3：测试代码 ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine(); //部署流程定义，启动流程实例 @Test public void testTask() throws Exception { // 1 发布流程 InputStream inputStreamBpmn = this.getClass().getResourceAsStream("taskProcess.bpmn"); InputStream inputStreamPng = this.getClass().getResourceAsStream("taskProcess.png"); processEngine.getRepositoryService()// .createDeployment()// .addInputStream("userTask.bpmn", inputStreamBpmn)// .addInputStream("userTask.png", inputStreamPng)// .deploy(); // 2 启动流程 ProcessInstance pi = processEngine.getRuntimeService()// .startProcessInstanceByKey("taskProcess"); System.out.println("pid:" + pi.getId()); } //查询我的个人任务列表 @Test public void findMyTaskList(){ String userId = "孙悟空"; List<Task> list = processEngine.getTaskService()// .createTaskQuery()// .taskAssignee(userId)//指定个人任务查询 .list(); for(Task task:list ){ System.out.println("id="+task.getId()); System.out.println("name="+task.getName()); System.out.println("assinee="+task.getAssignee()); System.out.println("assinee="+task.getCreateTime()); System.out.println("executionId="+task.getExecutionId()); } } //查询组任务列表 @Test public void findGroupList(){ String userId = "孙悟空"; List<Task> list = processEngine.getTaskService()// .createTaskQuery()// .taskCandidateUser(userId)//指定组任务查询 .list(); for(Task task:list ){ System.out.println("id="+task.getId()); System.out.println("name="+task.getName()); System.out.println("assinee="+task.getAssignee()); System.out.println("assinee="+task.getCreateTime()); System.out.println("executionId="+task.getExecutionId()); System.out.println("##################################"); } } //查询组任务成员列表 @Test public void findGroupUser(){ String taskId = "4008"; List<IdentityLink> list = processEngine.getTaskService()// .getIdentityLinksForTask(taskId); for(IdentityLink identityLink:list ){ System.out.println("userId="+identityLink.getUserId()); System.out.println("taskId="+identityLink.getTaskId()); System.out.println("piId="+identityLink.getProcessInstanceId()); System.out.println("######################"); } } //查询组任务成员历史列表 @Test public void findGroupHisUser(){ String taskId = "4008"; List<HistoricIdentityLink> list = processEngine.getHistoryService()// .getHistoricIdentityLinksForTask(taskId); for(HistoricIdentityLink identityLink:list ){ System.out.println("userId="+identityLink.getUserId()); System.out.println("taskId="+identityLink.getTaskId()); System.out.println("piId="+identityLink.getProcessInstanceId()); System.out.println("######################"); } } //完成任务 @Test public void completeTask(){ String taskId = "4008"; processEngine.getTaskService()// .complete(taskId);// System.out.println("完成任务"); } //将组任务分配给个人任务（认领任务） @Test public void claimTask(){ String taskId = "4008"; //个人任务的办理人 String userId = "如来"; processEngine.getTaskService().claim(taskId, userId); } //可以分配个人任务回退到组任务，（前提之前是个组任务） @Test public void setAssigneeTask(){ //任务ID String taskId = "4008"; processEngine.getTaskService()// .setAssignee(taskId, null); } //向组任务中添加成员 @Test public void addUser(){ String taskId = "4008"; String userId = "沙和尚"; processEngine.getTaskService().addCandidateUser(taskId, userId); } //向组任务中删除成员 @Test public void removeUser(){ String taskId = "4008"; String userId = "沙和尚"; processEngine.getTaskService().deleteCandidateUser(taskId, userId); } 在类中使用delegateTask.addCandidateUser (userId);的方式分配组任务的办理人，此时孙悟空和猪八戒是下一个任务的办理人。通过processEngine.getTaskService().claim (taskId, userId);将组任务分配给个人任务，也叫认领任务，即指定某个人去办理这个任务，此时由如来去办理任务。addCandidateUser()即向组任务添加成员，deleteCandidateUser()即删除组任务的成员。在开发中，可以将每一个任务的办理人规定好，例如张三的领导是李四和王五，这样张三提交任务，由李四或者王五去查询组任务，可以看到对应张三的申请，李四或王五再通过认领任务（claim）的方式，由某个人去完成这个任务。在act_ru_execution表中存在BUSINESS_KEY_，这个业务键会伴随这个流程实例的一生，所以一般用来存储与业务相关的数据，一般会是与流程实例相对应的数据。 在开启流程的时候存入业务键，这里存入的是订单ID，对应的是一张订单表，而这个流程则是订单流程，所以两两相互对应。
ProcessInstance pi = runtimeService.startProcessInstanceByKey("OrderFlow", orderId+"");通过流程实例获得业务键，注意流程实例和业务键是一一对应的。
ProcessInstance pi =pq.processInstanceId(task.getProcessInstanceId()).singleResult(); pi.getBusinessKey()；