1:工做流的概念css
说明:
1) 假设:这两张图就是华谊兄弟的请假流程图
2) 图的组成部分:
A. 人物:范冰冰 冯小刚 王中军
B. 事件(动做):请假、批准、不批准html
工做流(Workflow),就是“业务过程的部分或总体在计算机应用环境下的自动化”,它主要解决的是“使在多个参与者之间按照某种预约义的规则传递文档、信息或任务的过程自动进行,从而实现某个预期的业务目标,或者促使此目标的实现”。
工做流管理系统(Workflow Management System, WfMS)是一个软件系统,它完成工做量的定义和管理,并按照在系统中预先定义好的工做流规则进行工做流实例的执行。工做流管理系统不是企业的业务系统,而是为企业的业务系统的运行提供了一个软件的支撑环境。
工做流管理联盟(WfMC,Workflow Management Coalition)给出的关于工做流管理系统的定义是:工做流管理系统是一个软件系统,它经过执行通过计算的流程定义去支持一批专门设定的业务流程。工做流管理系统被用来定义、管理、和执行工做流程。
工做流管理系统的目标:管理工做的流程以确保工做在正确的时间被指望的人员所执行——在自动化进行的业务过程当中插入人工的执行和干预。
3:Activiti介绍
Activiti5是由Alfresco软件在2010年5月17日发布的业务流程管理(BPM)框架,它是覆盖了业务流程管理、工做流、服务协做等领域的一个开源的、灵活的、易扩展的可执行流程语言框架。Activiti基于Apache许可的开源BPM平台,创始人Tom Baeyens是JBoss jBPM的项目架构师,它特点是提供了eclipse插件,开发人员能够经过插件直接绘画出业务
流程图。
java
3.1:工做流引擎
ProcessEngine对象,这是Activiti工做的核心。负责生成流程运行时的各类实例及数据、监控和管理流程的运行。
3.2:BPMN
业务流程建模与标注(Business Process Model and Notation,BPMN) ,描述流程的基本符号,包括这些图元如何组合成一个业务流程图(Business Process Diagram)mysql
3.3:数据库(先了解后看)
Activiti数据库支持:
Activiti的后台是有数据库的支持,全部的表都以ACT_开头。 第二部分是表示表的用途的两个字母标识。 用途也和服务的API对应。
ACT_RE_*: ‘RE’表示repository。 这个前缀的表包含了流程定义和流程静态资源 (图片,规则,等等)。
ACT_RU_*: ‘RU’表示runtime。 这些运行时的表,包含流程实例,任务,变量,异步任务,等运行中的数据。 Activiti只在流程实例执行过程当中保存这些数据, 在流程结束时就会删除这些记录。 这样运行时表能够一直很小速度很快。
ACT_ID_*: ‘ID’表示identity。 这些表包含身份信息,好比用户,组等等。
ACT_HI_*: ‘HI’表示history。 这些表包含历史数据,好比历史流程实例, 变量,任务等等。
ACT_GE_*: 通用数据, 用于不一样场景下,如存放资源文件。spring
表结构操做:
3.3.1:资源库流程规则表
1) act_re_deployment 部署信息表
2) act_re_model 流程设计模型部署表
3) act_re_procdef 流程定义数据表
3.3.2:运行时数据库表
1) act_ru_execution 运行时流程执行实例表
2) act_ru_identitylink 运行时流程人员表,主要存储任务节点与参与者的相关信息
3) act_ru_task 运行时任务节点表
4) act_ru_variable 运行时流程变量数据表
3.3.3:历史数据库表
1) act_hi_actinst 历史节点表
2) act_hi_attachment 历史附件表
3) act_ih_comment 历史意见表
4) act_hi_identitylink 历史流程人员表
5) act_hi_detail 历史详情表,提供历史变量的查询
6) act_hi_procinst 历史流程实例表
7) act_hi_taskinst 历史任务实例表
8) act_hi_varinst 历史变量表
3.3.4:组织机构表
1) act_id_group 用户组信息表
2) act_id_info 用户扩展信息表
3) act_id_membership 用户与用户组对应信息表
4) act_id_user 用户信息表
这四张表很常见,基本的组织机构管理,关于用户认证方面建议仍是本身开发一套,组件自带的功能太简单,使用中有不少需求难以知足
3.3.5:通用数据表
1) act_ge_bytearray 二进制数据表
2) act_ge_property 属性数据表存储整个流程引擎级别的数据,初始化表结构时,会默认插入三条记录,
3.4:activiti.cfg.xml(activiti的配置文件)
Activiti核心配置文件,配置流程引擎建立工具的基本参数和数据库链接池参数。
定义数据库配置参数:
jdbcUrl: 数据库的JDBC URL。
jdbcDriver: 对应不一样数据库类型的驱动。
jdbcUsername: 链接数据库的用户名。
jdbcPassword: 链接数据库的密码。
基于JDBC参数配置的数据库链接 会使用默认的MyBatis链接池。 下面的参数能够用来配置链接池(来自MyBatis参数):
jdbcMaxActiveConnections: 链接池中处于被使用状态的链接的最大值。默认为10。
jdbcMaxIdleConnections: 链接池中处于空闲状态的链接的最大值。
jdbcMaxCheckoutTime: 链接被取出使用的最长时间,超过期间会被强制回收。 默认为20000(20秒)。
jdbcMaxWaitTime: 这是一个底层配置,让链接池能够在长时间没法得到链接时, 打印一条日志,并从新尝试获取一个链接。(避免由于错误配置致使沉默的操做失败)。 默认为20000(20秒)。
示例数据库配置:
sql
也可使用javax.sql.DataSource。 (好比,Apache Commons的DBCP):
3.5:logging.properties(日志处理)
日志的配置文件,Activiti操做数据库的时候,整合的日志文件
4:准备环境
4.1:activiti5 软件环境
1) JDK1.6或者更高版本
2) 支持的数据库有:h2, mysql, oracle, postgres, mssql, db2等。
3) 支持activiti5运行的jar包
4) 开发环境为Eclipse3.7或者以上版本,myeclipse为8.6版本
4.2:相关资源下载
1) JDK能够到sun的官网下载
http://www.oracle.com/technetwork/java/javase/downloads/index.html
2) 数据库,例如:mysql能够在官网上下载。
http://www.mysql.com
3) activiti也能够到Activiti官方网站下载获得。
http://activiti.org/download.html
4) Eclipse3.7或者MyEclipse8.6也能够到相应的网站上得到下载。
4.3:安装流程设计器(eclipse插件)
4.3.1:安装方式一
在有网络的状况下,安装流程设计器步骤以下:
1) 打开 Help -> Install New Software. 在以下面板中:
2) 在以下Install界面板中,点击Add按钮:
配置新装插件的地址和名称数据库
3) 而后填入下列字段
Name: Activiti BPMN 2.0 designer
Location: http://activiti.org/designer/update/
4) 回到Install界面,在面板正中列表中把全部展现出来的项目都勾上:
5) 点击复选框
在Detail部分记得选中 “Contact all updates sites..” , 由于它会检查全部当前安装所须要的插件并能够被Eclipse下载.编程
6) 安装完之后,点击新建工程new->Other…打开面板,若是看到下图内容:
说明安装成功了。
4.3.2:安装方式二
在没有网络的状况下,安装流程设计器步骤以下:
1) 解压老师发给你们的 压缩包
2) 把压缩包中的内容放入eclipse根目录的dropins文件夹下
3) 重启eclipse,点击新建工程new->Other…打开面板,若是看到下图内容:
说明安装成功了
4.4:对流程设计器的使用说明
打开菜单Windows->Preferences->Activiti->Save下流程流程图片的生成方式:
虽然流程引擎在单独部署bpmn文件时会自动生成图片,但在实际开发过程当中,自动生成的图片会致使和BPMN中的坐标有出入,在实际项目中展现流程当前位置图会有问题。
所在完成以上配置后,会由咱们本身来管理流程图片。在发布流程时把流程规则文件和流程图片一块儿上传就好了。
4.5:准备Activiti5开发环境
4.5.1:添加Activiti5的jar包
在activiti-5.13->wars目录下是一些示例项目,解压activiti-rest项目,导入activiti-rest目录中WEB-INF\lib下全部包。添加到classpath中。
因为咱们使用的是Mysql数据库,Mysql数据库的连接驱动Activiti官方包中并无提供,须要咱们本身导入。手动导入mysql-connector-java.jar,添加到classpath下。
4.5.2:初始化数据库
在Activiti中,在建立核心的流程引擎对象时会自动建表。若是程序正常执行,mysql会自动建库,而后建立23张表。缓存
4.5.3:添加并制定配置文件
在Actiiti5中定制流程一定会操做到数据库,若是都像上面那样写一大段代码会很是麻烦,因此咱们能够把数据库链接配置写入配置文件。
在Activiti5的官方示例中并无现成的配置文件,因此先得找到activiti-rest\WEB-INF\classes下有:网络
4.5.3.1:activiti-context.xml :
一个相似spring结构的配置文件,清空内容后更名为activiti.cfg.xml,用来作流程引擎的相关配置。
按照上面代码配置ProcessEngineConfiguration对象,主要定义数据库的链接配置和建表策略,配置文件代码以下:
Java代码以下:
createProcessEngineConfigurationFromResource的参数值为咱们添加的配置文件activiti.cfg.xml的名称,执行java代码,流程引擎对象建立成功运行后数据库会自动建表。
/**使用代码建立工做流须要的23张表*/ @Test public void createTable(){ ProcessEngineConfiguration processEngineConfiguration = ProcessEngineConfiguration.createStandaloneProcessEngineConfiguration(); //链接数据库的配置 processEngineConfiguration.setJdbcDriver("com.mysql.jdbc.Driver"); processEngineConfiguration.setJdbcUrl("jdbc:mysql://localhost:3306/shareniu?useUnicode=true&characterEncoding=utf8"); processEngineConfiguration.setJdbcUsername("root"); processEngineConfiguration.setJdbcPassword("root"); /** public static final String DB_SCHEMA_UPDATE_FALSE = "false";不能自动建立表,须要表存在 public static final String DB_SCHEMA_UPDATE_CREATE_DROP = "create-drop";先删除表再建立表 public static final String DB_SCHEMA_UPDATE_TRUE = "true";若是表不存在,自动建立表 */ processEngineConfiguration.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE); //工做流的核心对象,ProcessEnginee对象 ProcessEngine processEngine = processEngineConfiguration.buildProcessEngine(); System.out.println("processEngine:"+processEngine); } /**使用配置文件建立工做流须要的23张表*/ @Test public void createTable_2(){ // ProcessEngineConfiguration processEngineConfiguration = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource("activiti.cfg.xml"); // //工做流的核心对象,ProcessEnginee对象 // ProcessEngine processEngine = processEngineConfiguration.buildProcessEngine(); ProcessEngine processEngine = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource("activiti.cfg.xml") // .buildProcessEngine(); System.out.println("processEngine:"+processEngine); }
4.5.3.2:log4j.properties 日志配置文件
把两个文件放入resource目录下便可。
5:核心API
5.1:ProcessEngine
说明:
1) 在Activiti中最核心的类,其余的类都是由他而来。
2) 产生方式:
在前面看到了两种建立ProcessEngine(流程引擎)的方式,而这里要简化不少,调用ProcessEngines的getDefaultProceeEngine方法时会自动加载classpath下名为activiti.cfg.xml文件。
3) 能够产生RepositoryService
4) 能够产生RuntimeService
5) 能够产生TaskService
各个Service的做用:
RepositoryService 管理流程定义
RuntimeService 执行管理,包括启动、推动、删除流程实例等操做
TaskService 任务管理
HistoryService 历史管理(执行完的数据的管理)
IdentityService 组织机构管理
FormService 一个可选服务,任务表单管理
ManagerService
5.2:RepositoryService
是Activiti的仓库服务类。所谓的仓库指流程定义文档的两个文件:bpmn文件和流程图片。
1) 产生方式
2) 能够产生DeploymentBuilder,用来定义流程部署的相关参数
3) 删除流程定义
5.3:RuntimeService
是activiti的流程执行服务类。能够从这个服务类中获取不少关于流程执行相关的信息。
5.4:TaskService
是activiti的任务服务类。能够从这个类中获取任务的信息。
5.5:HistoryService
是activiti的查询历史信息的类。在一个流程执行完成后,这个对象为咱们提供查询历史信息。
5.6:ProcessDefinition
流程定义类。能够从这里得到资源文件等。
5.7:ProcessInstance
表明流程定义的执行实例。如范冰冰请了一天的假,她就必须发出一个流程实例的申请。一个流程实例包括了全部的运行节点。咱们能够利用这个对象来了解当前流程实例的进度等信息。流程实例就表示一个流程从开始到结束的最大的流程分支,即一个流程中流程实例只有一个。
5.8:Execution
Activiti用这个对象去描述流程执行的每个节点。在没有并发的状况下,Execution就是同ProcessInstance。流程按照流程定义的规则执行一次的过程,就能够表示执行对象Execution。
如图为ProcessInstance的源代码:
从源代码中能够看出ProcessInstance就是Execution。但在现实意义上有所区别:
在单线流程中,如上图的贷款流程,ProcessInstance与Execution是一致的。
这个例子有一个特色:wire money(汇钱)和archive(存档)是并发执行的。 这个时候,总线路表明ProcessInstance,而分线路中每一个活动表明Execution。
总结:
* 一个流程中,执行对象能够存在多个,可是流程实例只能有一个。
* 当流程按照规则只执行一次的时候,那么流程实例就是执行对象。
6:HelloWorld程序(模拟流程的执行)
6.1:流程图:
6.2:部署流程定义
这里使用RepositoryService部署流程定义
addClasspathResource表示从类路径下加载资源文件,一次只能加载一个文件
6.3:启动流程实例
这里使用RuntimeService启动流程实例
6.4:查看个人我的任务
这里使用TaskService完成任务的查询
6.5:完成个人我的任务
这里使用TaskService完成任务的办理
7:管理流程定义
7.1:设计流程定义文档
7.1.1:流程图
7.1.2:bpmn文件
BPMN 2.0根节点是definitions节点。 这个元素中,能够定义多个流程定义(不过咱们建议每一个文件只包含一个流程定义, 能够简化开发过程当中的维护难度)。 一个空的流程定义看起来像下面这样。注意,definitions元素 最少也要包含xmlns 和 targetNamespace的声明。 targetNamespace能够是任意值,它用来对流程实例进行分类。
说明:流程定义文档有两部分组成:
1) bpmn文件
流程规则文件。在部署后,每次系统启动时都会被解析,把内容封装成流程定义放入项目缓存中。Activiti框架结合这个xml文件自动管理流程,流程的执行就是按照bpmn文件定义的规则执行的,bpmn文件是给计算机执行用的。
2) 展现流程图的图片
在系统里须要展现流程的进展图片,图片是给用户看的。
7.2:部署流程定义(classpath路径加载文件)
说明:
1) 先获取流程引擎对象:在建立时会自动加载classpath下的activiti.cfg.xml
2) 首先得到默认的流程引擎,经过流程引擎获取了一个RepositoryService对象(仓库对象)
3) 由仓库的服务对象产生一个部署对象配置对象,用来封装部署操做的相关配置。
4) 这是一个链式编程,在部署配置对象中设置显示名,上传流程定义规则文件
5) 向数据库表中存放流程定义的规则信息。
6) 这一步在数据库中将操做三张表:
a) act_re_deployment(部署对象表)
存放流程定义的显示名和部署时间,每部署一次增长一条记录。
Deployment deployment = processEngine.getRepositoryService()//
.createDeployment().name(“入门程序”)//
.addClasspathResource(“hello/helloworld.bpmn”)// 从classpath的资源中加载,一次只能加载一个文件
// .addClasspathResource(“diagrams/helloworld.png”)//
// 从classpath的资源中加载,一次只能加载一个文件
.deploy();
b) act_re_procdef(流程定义表)
存放流程定义的属性信息,部署每一个新的流程定义都会在这张表中增长一条记录。
注意:当流程定义的key相同的状况下,使用的是版本升级
对应的封装类:
public interface ProcessDefinition {
String getId(); String getCategory(); String getName(); String getKey(); String getDescription(); int getVersion(); String getResourceName(); String getDeploymentId(); String getDiagramResourceName(); boolean hasStartFormKey(); boolean isSuspended(); }
代码的操做:
/* 查询流程定义 /
@Test public void findProcessDefinition() { List<ProcessDefinition> list = processEngine.getRepositoryService()// 与流程定义和部署对象相关的Service .createProcessDefinitionQuery()// 建立一个流程定义的查询 /** 指定查询条件,where条件 */ // .deploymentId(deploymentId)//使用部署对象ID查询 // .processDefinitionId(processDefinitionId)//使用流程定义ID查询 // .processDefinitionKey(processDefinitionKey)//使用流程定义的key查询 // .processDefinitionNameLike(processDefinitionNameLike)//使用流程定义的名称模糊查询 /** 排序 */ .orderByProcessDefinitionVersion().asc()// 按照版本的升序排列 // .orderByProcessDefinitionName().desc()//按照流程定义的名称降序排列 /** 返回的结果集 */ .list();// 返回一个集合列表,封装流程定义 // .singleResult();//返回唯一结果集 // .count();//返回结果集数量 // .listPage(firstResult, maxResults);//分页查询 if (list != null && list.size() > 0) { for (ProcessDefinition pd : list) { System.out.println("流程定义ID:" + pd.getId());// 流程定义的key+版本+随机生成数 System.out.println("流程定义的名称:" + pd.getName());// 对应helloworld.bpmn文件中的name属性值 System.out.println("流程定义的key:" + pd.getKey());// 对应helloworld.bpmn文件中的id属性值 System.out.println("流程定义的版本:" + pd.getVersion());// 当流程定义的key值相同的相同下,版本升级,默认1 System.out.println("资源名称bpmn文件:" + pd.getResourceName()); System.out.println("资源名称png文件:" + pd.getDiagramResourceName()); System.out.println("部署对象ID:" + pd.getDeploymentId()); System.out .println("#########################################################"); } } }
程序的输出:
流程定义ID:helloworld:1:4
流程定义的名称:helloworldProcess
流程定义的key:helloworld
流程定义的版本:1
资源名称bpmn文件:hello/helloworld.bpmn
资源名称png文件:hello/helloworld.helloworld.png
部署对象ID:1
c) act_ge_bytearray(资源文件表)
存储流程定义相关的部署信息。即流程定义文档的存放地。每部署一次就会增长两条记录,一条是关于bpmn规则文件的,一条是图片的(若是部署时只指定了bpmn一个文件,activiti会在部署时解析bpmn文件内容自动生成流程图)。两个文件不是很大,都是以二进制形式存储在数据库中。
7.3:部署流程定义(zip格式文件)
将
压缩成zip格式的文件,使用zip的输入流用做部署流程定义
7.4:查看流程定义
查询流程定义的信息
结果:
再部署一次运行结果为:
能够看到流程定义的key值相同的状况下,版本是从1开始逐次升级的
流程定义的Id是【key:版本:生成ID】
说明:
1) 流程定义和部署对象相关的Service都是RepositoryService。
2) 建立流程定义查询对象,能够在ProcessDefinitionQuery上设置查询的相关参数
3) 调用ProcessDefinitionQuery对象的list方法,执行查询,得到符合条件的流程定义列表
4) 由运行结果能够看出:
Key和Name的值为:bpmn文件process节点的id和name的属性值
5) key属性被用来区别不一样的流程定义。
6) 带有特定key的流程定义第一次部署时,version为1。以后每次部署都会在当前最高版本号上加1
7) Id的值的生成规则为:{processDefinitionKey}:{processDefinitionVersion}:{generated-id}, 这里的generated-id是一个自动生成的惟一的数字
8) 重复部署一次,deploymentId的值以必定的形式变化
规则act_ge_property表生成
7.5:删除流程定义
删除部署到activiti中的流程定义。
说明:
1) 由于删除的是流程定义,而流程定义的部署是属于仓库服务的,因此应该先获得RepositoryService
2) 若是该流程定义下没有正在运行的流程,则能够用普通删除。若是是有关联的信息,用级联删除。项目开发中使用级联删除的状况比较多,删除操做通常只开放给超级管理员使用。
7.6:获取流程定义文档的资源(查看流程图附件)
查询出流程定义文档。主要查的是图片,用于显示流程用。
说明:
1) deploymentId为流程部署ID
2) resourceName为act_ge_bytearray表中NAME_列的值
3) 使用repositoryService的getDeploymentResourceNames方法能够获取指定部署下得全部文件的名称
4) 使用repositoryService的getResourceAsStream方法传入部署ID和资源图片名称能够获取部署下指定名称文件的输入流
5) 最后的有关IO流的操做,使用FileUtils工具的copyInputStreamToFile方法完成流程流程到文件的拷贝,将资源文件以流的形式输出到指定文件夹下
7.7:附加功能:查询最新版本的流程定义
Key value保存 key 为key value为流程定义
代码:
/*附加功能:查询最新版本的流程定义*/
@Test
public void findLastVersionProcessDefinition(){
List<ProcessDefinition> list = processEngine.getRepositoryService()// .createProcessDefinitionQuery()// .orderByProcessDefinitionVersion().asc()//使用流程定义的版本升序排列 .list(); /** * Map<String,ProcessDefinition> map集合的key:流程定义的key map集合的value:流程定义的对象 map集合的特色:当map集合key值相同的状况下,后一次的值将替换前一次的值 */ Map<String, ProcessDefinition> map = new LinkedHashMap<String, ProcessDefinition>(); if(list!=null && list.size()>0){ for(ProcessDefinition pd:list){ map.put(pd.getKey(), pd); } } List<ProcessDefinition> pdList = new ArrayList<ProcessDefinition>(map.values()); if(pdList!=null && pdList.size()>0){ for(ProcessDefinition pd:pdList){ System.out.println("流程定义ID:"+pd.getId());//流程定义的key+版本+随机生成数 System.out.println("流程定义的名称:"+pd.getName());//对应helloworld.bpmn文件中的name属性值 System.out.println("流程定义的key:"+pd.getKey());//对应helloworld.bpmn文件中的id属性值 System.out.println("流程定义的版本:"+pd.getVersion());//当流程定义的key值相同的相同下,版本升级,默认1 System.out.println("资源名称bpmn文件:"+pd.getResourceName()); System.out.println("资源名称png文件:"+pd.getDiagramResourceName()); System.out.println("部署对象ID:"+pd.getDeploymentId()); System.out.println("#########################################################"); } } }
7.8:附加功能:删除流程定义(删除key相同的全部不一样版本的流程定义)
@Test
public void deleteProcessDefinitionByKey() { // 流程定义的key String processDefinitionKey = "helloworld"; // 先使用流程定义的key查询流程定义,查询出全部的版本 List<ProcessDefinition> list = processEngine.getRepositoryService()// .createProcessDefinitionQuery()// .processDefinitionKey(processDefinitionKey).list();// // 遍历,获取每一个流程定义的部署ID if (list != null && list.size() > 0) { for(ProcessDefinition pd:list){ //获取部署ID String deploymentId = pd.getDeploymentId(); processEngine.getRepositoryService()// .deleteDeployment(deploymentId, true); } } }
7.9:总结
Deployment 部署对象
一、一次部署的多个文件的信息。对于不须要的流程能够删除和修改。
二、对应的表:
act_re_deployment:部署对象表
act_re_procdef:流程定义表
act_ge_bytearray:资源文件表
act_ge_property:主键生成策略表
ProcessDefinition 流程定义
一、解析.bpmn后获得的流程定义规则的信息,工做流系统就是按照流程定义的规则执行的。
8:流程实例、任务的执行
8.1:流程图
8.2:部署流程定义
8.3:启动流程实例
说明:
1) 操做数据库的act_ru_execution表,若是是用户任务节点,同时也会在act_ru_task添加一条记录
act_ru_execution表,#正在执行的执行对象表 任务结束的以前只有 一个 变化的字段是act_id
8.4:查询个人我的任务
@Test public void findMyPersonalTask(){ String assignee = "王五"; List<Task> list = processEngine.getTaskService()//与正在执行的任务管理相关的Service .createTaskQuery()//建立任务查询对象 /**查询条件(where部分)*/ .taskAssignee(assignee)//指定我的任务查询,指定办理人 // .taskCandidateUser(candidateUser)//组任务的办理人查询 // .processDefinitionId(processDefinitionId)//使用流程定义ID查询 // .processInstanceId(processInstanceId)//使用流程实例ID查询 // .executionId(executionId)//使用执行对象ID查询 /**排序*/ .orderByTaskCreateTime().asc()//使用建立时间的升序排列 /**返回结果集*/ // .singleResult()//返回唯一结果集 // .count()//返回结果集的数量 // .listPage(firstResult, maxResults);//分页查询 .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()); System.out.println("########################################################"); } } }
输出:
任务ID:504
任务名称:提交申请
任务的建立时间:Sat Aug 09 08:50:20 CST 2014
任务的办理人:张三
流程实例ID:501
执行对象ID:501
流程定义ID:helloworld:1:404
接口:
public interface Task { int DEFAULT_PRIORITY = 50; String getId(); String getName(); void setName(String name); String getDescription(); void setDescription(String description); int getPriority(); void setPriority(int priority); String getOwner(); void setOwner(String owner); String getAssignee(); void setAssignee(String assignee); DelegationState getDelegationState(); void setDelegationState(DelegationState delegationState); String getProcessInstanceId(); String getExecutionId(); String getProcessDefinitionId(); Date getCreateTime(); String getTaskDefinitionKey(); Date getDueDate(); void setDueDate(Date dueDate); void delegate(String userId); void setParentTaskId(String parentTaskId); String getParentTaskId(); boolean isSuspended(); Map<String, Object> getTaskLocalVariables(); Map<String, Object> getProcessVariables(); }
说明:
1) 由于是任务查询,因此从processEngine中应该获得TaskService
2) 使用TaskService获取到任务查询对象TaskQuery
3) 为查询对象添加查询过滤条件,使用taskAssignee指定任务的办理者(即查询指定用户的代办任务),同时能够添加分页排序等过滤条件
4) 调用list方法执行查询,返回办理者为指定用户的任务列表
5) 任务ID、名称、办理人、建立时间能够从act_ru_task表中查到。
6) Execution与ProcessInstance见5.6和5.7章节的介绍。在这种状况下,ProcessInstance至关于Execution
7) 若是assignee属性为部门经理,结果为空。由于如今流程只到了”填写请假申请”阶段,后面的任务尚未执行,即在数据库中没有部门经理能够办理的任务,因此查询不到。
8) 一个Task节点和Execution节点是1对1的状况,在task对象中使用Execution_来表示他们之间的关系
9) 任务ID在数据库表act_ru_task中对应“ID_”列
附加:
在activiti任务中,主要分为两大类查询任务(我的任务和组任务):
1.确切指定了办理者的任务,这个任务将成为指定者的私有任务,即我的任务。
2.没法指定具体的某一我的来办理的任务,能够把任务分配给几我的或者一到 多个小组,让这个范围内的用户能够选择性(若有空余时间时)来办理这类任务,即组任务。
先知道我的任务的查询和办理,组任务的操做后面讲
8.5:办理任务
说明:
1) 是办理任务,因此从ProcessEngine获得的是TaskService。
2) 当执行完这段代码,再以员工的身份去执行查询的时候,会发现这个时候已经没有数据了,由于正在执行的任务中没有数据。
3) 对于执行完的任务,activiti将从act_ru_task表中删除该任务,下一个任务会被插入进来。
4) 以”部门经理”的身份进行查询,能够查到结果。由于流程执行到部门经理审批这个节点了。
5) 再执行办理任务代码,执行完之后以”部门经理”身份进行查询,没有结果。
6) 重复第3和4步直到流程执行完。
act_ru_task表:
8.6:查询流程状态(判断流程正在执行,仍是结束)
/* 查询流程状态(判断流程正在执行,仍是结束) /
@Test
public void isProcessEnd() { String processInstanceId = "501"; ProcessInstance pi = processEngine.getRuntimeService()// 表示正在执行的流程实例和执行对象 .createProcessInstanceQuery()// 建立流程实例查询 .processInstanceId(processInstanceId)// 使用流程实例ID查询 .singleResult(); if (pi == null) { System.out.println("流程已经结束"); } else { System.out.println("流程没有结束"); } }
在流程执行的过程当中,建立的流程实例ID在整个过程当中都不会变,当流程结束后,流程实例将会在正在执行的执行对象表中(act_ru_execution)被删除 说明:
1) 由于是查询流程实例,因此先获取runtimeService
2) 建立流程实例查询对象,设置实例ID过滤参数
3) 因为一个流程实例ID只对应一个实例,使用singleResult执行查询返回一个惟一的结果,若是结果数量大于1,则抛出异常
4) 判断指定ID的实例是否存在,若是结果为空,则表明流程结束,实例在正在执行的执行对象表中已被删除,转换成历史数据。
8.7:附加功能:查询历史任务(后面讲)
/*查询历史任务(后面讲)/
@Test
public void findHistoryTask(){
String taskAssignee = "张三"; List<HistoricTaskInstance> list = processEngine.getHistoryService()//与历史数据(历史表)相关的Service .createHistoricTaskInstanceQuery()//建立历史任务实例查询 .taskAssignee(taskAssignee)//指定历史任务的办理人 .list(); if(list!=null && list.size()>0){ for(HistoricTaskInstance hti:list){ System.out.println(hti.getId()+" "+hti.getName()+" "+hti.getProcessInstanceId()+" "+hti.getStartTime()+" "+hti.getEndTime()+" "+hti.getDurationInMillis()); System.out.println("################################"); } } }
表《HistoricTaskInstance》
8.8:附加功能:查询历史流程实例(后面讲)
8.9:总结
Execution 执行对象
按流程定义的规则执行一次的过程.
对应的表:
act_ru_execution: 正在执行的信息
act_hi_procinst:已经执行完的历史流程实例信息
act_hi_actinst:存放历史全部完成的活动
ProcessInstance 流程实例
特指流程从开始到结束的那个最大的执行分支,一个执行的流程中,流程实例只有1个。
注意
(1)若是是单例流程,执行对象ID就是流程实例ID
(2)若是一个流程有分支和聚合,那么执行对象ID和流程实例ID就不相同
(3)一个流程中,流程实例只有1个,执行对象能够存在多个。
Task 任务
执行到某任务环节时生成的任务信息。
对应的表:
act_ru_task:正在执行的任务信息
act_hi_taskinst:已经执行完的历史任务信息
9:流程变量
9.1:流程图
流程变量在整个工做流中扮演很重要的做用。例如:请假流程中有请假天数、请假缘由等一些参数都为流程变量的范围。流程变量的做用域范围是只对应一个流程实例。也就是说各个流程实例的流程变量是不相互影响的。流程实例结束完成之后流程变量还保存在数据库中。
例如:
即:
9.2:部署流程定义
说明:
• 输入流加载资源文件的3种方式
9.3:启动流程实例
9.4:设置流程变量
说明:
1) 流程变量的做用域就是流程实例,因此只要设置就好了,不用管在哪一个阶段设置
2) 基本类型设置流程变量,在taskService中使用任务ID,定义流程变量的名称,设置流程变量的值。
3) Javabean类型设置流程变量,须要这个javabean实现了Serializable接口
4) 设置流程变量的时候,向act_ru_variable这个表添加数据
9.5:获取流程变量
说明:
1) 流程变量的获取针对流程实例(即1个流程),每一个流程实例获取的流程变量时不一样的
2) 使用基本类型获取流程变量,在taskService中使用任务ID,流程变量的名称,获取流程变量的值。
3) Javabean类型设置获取流程变量,除了须要这个javabean实现了Serializable接口外,还要求流程变量对象的属性不能发生变化,不然抛出异常。
解决方案,在javabean对象中添加:
private static final long serialVersionUID = 6757393795687480331L;
9.6:模拟流程变量的设置和获取的场景
说明:
1) RuntimeService对象能够设置流程变量和获取流程变量
2) TaskService对象能够设置流程变量和获取流程变量
3) 流程实例启动的时候能够设置流程变量
4) 任务办理完成的时候能够设置流程变量
5) 流程变量能够经过名称/值的形式设置单个流程变量
6) 流程变量能够经过Map集合,同时设置多个流程变量
Map集合的key表示流程变量的名称
Map集合的value表示流程变量的值
9.7:查询历史的流程变量
说明:
1)历史的流程变量查询,指定流程变量的名称,查询act_hi_varinst表(也能够针对,流程实例ID,执行对象ID,任务ID查询)
9.8:流程变量的支持的类型
如图是从官网列出来的流程变量的类型:
从图中能够看出包括了大部分封装类型和Date、String和实现了Serializable接口的类的类型。
9.9:总结
• 1:流程变量
在流程执行或者任务执行的过程当中,用于设置和获取变量,使用流程变量在流程传递的过程当中传递业务参数。
对应的表:
act_ru_variable:正在执行的流程变量表
act_hi_varinst:流程变量历史表
• 2:扩展知识:setVariable和setVariableLocal的区别
setVariable:设置流程变量的时候,流程变量名称相同的时候,后一次的值替换前一次的值,并且能够看到TASK_ID的字段不会存听任务ID的值
setVariableLocal:
1:设置流程变量的时候,针对当前活动的节点设置流程变量,若是一个流程中存在2个活动节点,对每一个活动节点都设置流程变量,即便流程变量的名称相同,后一次的版本的值也不会替换前一次版本的值,它会使用不一样的任务ID做为标识,存放2个流程变量值,并且能够看到TASK_ID的字段会存听任务ID的值
例如act_hi_varinst 表的数据:不一样的任务节点,即便流程变量名称相同,存放的值也是不一样的。
如图:
2:还有,使用setVariableLocal说明流程变量绑定了当前的任务,当流程继续执行时,下个任务获取不到这个流程变量(由于正在执行的流程变量中没有这个数据),全部查询正在执行的任务时不能查询到咱们须要的数据,此时须要查询历史的流程变量。
10:流程执行历史记录
10.1:查询历史流程实例
查找按照某个流程定义的规则一共执行了多少次流程
10.2:查询历史活动
某一次流程的执行一共经历了多少个活动
10.3:查询历史任务
某一次流程的执行一共经历了多少个任务
10.4:查询历史流程变量
某一次流程的执行一共设置的流程变量
10.5:总结 因为数据库中保存着历史信息以及正在运行的流程实例信息,在实际项目中对已完成任务的查看频率远不及对代办和可接任务的查看,因此在activiti采用分开管理,把正在运行的交给RuntimeService、TaskService管理,而历史数据交给HistoryService来管理。 这样作的好处在于,加快流程执行的速度,由于正在执行的流程的表中数据不会很大