首页 > 工作流 > 工作流Activiti5入门(上)

工作流Activiti5入门(上)

刚工作的时候曾经用Activiti5,但由于当时介于水平,对Activiti5并没有很深的理解,而且知识也没有形成一个体系,前一段时间偶然发现传智播客公布了一个关于Activiti5的教学视频,自己跟着看了一下,感觉有很多收获,所以打算写几篇博文,整理一下,以供将来如有需要的话可以查阅,今天记下学习的前一部分,称为Activiti5上。

一. Activiti5开发环境搭建和配置

1. 开发环境搭建

Activiti5开发一个工作流系统,首先肯定是要搭建环境的,关于搭建环境老夫窃以为这篇文章:http://www.zhengmenbb.com/archives/98.htm,写的很不错,这篇文章不仅写了怎么搭建环境,还有一个小小的例子,大家可以先看一下,看了这篇文章,我相信大家搭建好环境不是问题,因为就是装一个插件而已,很简单。

2. 配置

现在的任何框架几乎都要和spring相整合,否则几乎可以说是玩不转,所以我们的Activiti5要想流行起来也不能例外,下面我们先看看他们怎么整合的。
spring的整合肯定要引入spring的jar包,这个老夫默认大家都会了,如果不会的话,我相信也不会看到这篇文章,至于Activiti5要引入那些jar文件,可以参考这个

(1). 部分pom文件


    <dependency>
      <groupId>org.activiti</groupId>
      <artifactId>activiti-engine</artifactId>
      <version>5.11</version>
    </dependency>
    <dependency>
      <groupId>org.activiti</groupId>
      <artifactId>activiti-spring</artifactId>
      <version>5.11</version>
    </dependency>

我们可以先把最基本的引入,如果不够肯定会报classnotfoundexception,到时候我们就知道缺少哪个了,老夫的原则是能少引入绝不多引入,原因一是怕冲突,二是文件大小和启动速度

(2). 和spring集成的配置文件activiti.cfg.xml


<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:context="http://www.springframework.org/schema/context" xmlns:tx="http://www.springframework.org/schema/tx"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd
http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd">

	<bean id="processEngineConfiguration" class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">
		<!-- 连接数据的配置 -->
		<property name="jdbcDriver" value="com.mysql.jdbc.Driver"></property>
		<property name="jdbcUrl" value="jdbc:mysql://localhost:3306/itcast0711activiti?useUnicode=true&amp;characterEncoding=utf8"></property>
		<property name="jdbcUsername" value="root"></property>
		<property name="jdbcPassword" value="root"></property>
		<!-- 没有表创建表 -->
		<property name="databaseSchemaUpdate" value="true"></property>
	</bean>

</beans>

这个集成文件简单吧?对,就是这么简单,至于spring等其他的配置文件啊,log的配置文件就不多说了,接下来我们要开始Activiti5的实战:开始写代码。

二. Activiti5实战

Activiti5实战,所以第一步肯定是画图,但装好了环境之后,其实上面那篇文章是有怎么画图的,所以画图这个就先讲怎么花了,大家可以画一个最简单的练手,本文作为一个入门教程,也不会涉及到那些复杂的图,所以第一步,咱直接开始启动流程定义。

因为Activiti5所有的操作都和ProcessEngine相关,所以所有的操作都和ProcessEngine相关,我们就先获取这个对象,当做第0步吧:


	ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();

1. 部署流程定义

部署流程定义,有两种,1. 从zip部署,也就是把我们的流程图压缩成zip,然后上传到项目的根目录,部署流程。

(1). 从zip部署


	/**部署流程定义(从zip)*/
	@Test
	public void deploymentProcessDefinition_zip(){
		InputStream in = this.getClass().getClassLoader().getResourceAsStream("diagrams/helloworld.zip");
		ZipInputStream zipInputStream = new ZipInputStream(in);
		Deployment deployment = processEngine.getRepositoryService()//与流程定义和部署对象相关的Service
						.createDeployment()//创建一个部署对象
						.name("流程定义")//添加部署的名称
						.addZipInputStream(zipInputStream)//指定zip格式的文件完成部署
						.deploy();//完成部署
		System.out.println("部署ID:"+deployment.getId());//
		System.out.println("部署名称:"+deployment.getName());//
	}

(2). 从资源文件


	/**部署流程定义(从classpath)*/
	@Test
	public void deploymentProcessDefinition_classpath(){
		Deployment deployment = processEngine.getRepositoryService()//与流程定义和部署对象相关的Service
						.createDeployment()//创建一个部署对象
						.name("流程定义")//添加部署的名称
						.addClasspathResource("diagrams/helloworld.bpmn")//从classpath的资源中加载,一次只能加载一个文件
						.addClasspathResource("diagrams/helloworld.png")//从classpath的资源中加载,一次只能加载一个文件
						.deploy();//完成部署
		System.out.println("部署ID:"+deployment.getId());//
		System.out.println("部署名称:"+deployment.getName());//
	}

2. 启动流程实例

当流程实例部署完成之后,肯定是开始启动流程了,下面我们就开始启动流程


	/**启动流程实例*/
	@Test
	public void startProcessInstance(){
		//流程定义的key
		String processDefinitionKey = "helloworld";
		ProcessInstance pi = processEngine.getRuntimeService()//与正在执行的流程实例和执行对象相关的Service
						.startProcessInstanceByKey(processDefinitionKey);//使用流程定义的key启动流程实例,key对应helloworld.bpmn文件中id的属性值,使用key值启动,默认是按照最新版本的流程定义启动
		System.out.println("流程实例ID:"+pi.getId());//流程实例ID    101
		System.out.println("流程定义ID:"+pi.getProcessDefinitionId());//流程定义ID   helloworld:1:4
	}

其中helloworld就是我们画的流程图的名字,启动流程实例之后,肯定是要查询我的任务了,所以接下来查询的任务

3. 查询我的任务

查询我的任务,分好几种,一种是我们在画图的时候,直接把这个任务就分配到某个人,另一种是分配到一个组,就是只要这个组有这个权限,那么都可以获取这个任务,还有一个是我们画图的时候什么都不指定,到流程执行到这个的时候动态指定,后两个先不说,我们先说第一个


	/**查询当前人的个人任务*/
	@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("########################################################");
			}
		}
	}

查询我的任务之后我们,肯定要认领任务,然后完成任务,所以接下来就是这一步

4. 认领和完成任务


	/**完成我的任务*/
	@Test
	public void completeMyPersonalTask(){
		//任务ID
		String taskId = "1202";
		processEngine.getTaskService()//与正在执行的任务管理相关的Service
					.complete(taskId);
		System.out.println("完成任务:任务ID:"+taskId);
	}

完成了我们自己的任务之后,流程就会按照流程图标记的那样,往后走,那么我们怎么知道这个流程什么时候结束呢?下面我们就要查询流程的状态

5. 流程状态查询


	/**查询流程状态(判断流程正在执行,还是结束)*/
	@Test
	public void isProcessEnd(){
		String processInstanceId = "1001";
		ProcessInstance pi = processEngine.getRuntimeService()//表示正在执行的流程实例和执行对象
						.createProcessInstanceQuery()//创建流程实例查询
						.processInstanceId(processInstanceId)//使用流程实例ID查询
						.singleResult();
		if(pi==null){
			System.out.println("流程已经结束");
		}
		else{
			System.out.println("流程没有结束");
		}
	}

6. 删除流程定义

我们在部署启动了流程定义之后,某些流程可能会由于各种各样的原因,导致流程无效,那么这个时候如果我们想删除该流程实例,那么这么做


	/**附加功能:删除流程定义(删除key相同的所有不同版本的流程定义)*/
	@Test
	public void deleteProcessDefinitionByKey(){
		//流程定义的key
		String processDefinitionKey = "helloworld";
		//先使用流程定义的key查询流程定义,查询出所有的版本
		List<ProcessDefinition> list = processEngine.getRepositoryService()//
						.createProcessDefinitionQuery()//
						.processDefinitionKey(processDefinitionKey)//使用流程定义的key查询
						.list();
		//遍历,获取每个流程定义的部署ID
		if(list!=null && list.size()>0){
			for(ProcessDefinition pd:list){
				//获取部署ID
				String deploymentId = pd.getDeploymentId();
				processEngine.getRepositoryService()//
							.deleteDeployment(deploymentId, true);
			}
		}
	}

或者也可以这么删除


	/**删除流程定义*/
	@Test
	public void deleteProcessDefinition(){
		//使用部署ID,完成删除
		String deploymentId = "601";
		/**
		 * 不带级联的删除
		 *    只能删除没有启动的流程,如果流程启动,就会抛出异常
		 */
//		processEngine.getRepositoryService()//
//						.deleteDeployment(deploymentId);
		
		/**
		 * 级联删除
		 * 	  不管流程是否启动,都能可以删除
		 */
		processEngine.getRepositoryService()//
						.deleteDeployment(deploymentId, true);
		System.out.println("删除成功!");
	}

7. 查询流程定义

在我们的正式系统中,每次肯定不会只有一个流程,我们想看看系统中有多少流程,可以这么做


	/**查询流程定义*/
	@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("#########################################################");
			}
		}			
	}

好了,这就是我们的上,介绍了一些最基本的功能,其实写完之后发现,应该写一下画图的,因为代码就是根据画图来的,所以画图可以说是Activiti5最最重要的基本功,不过算了,这个就留给大家自学吧,在接下来的下篇中,我会介绍一些算是更高级也是非常经常用到的一些功能的。

分享到:
作 者: BridgeLi,http://www.bridgeli.cn/
原文链接:https://www.bridgeli.cn/archives/197
版权声明:非特殊声明均为本站原创作品,转载时请注明作者和原文链接。
分类: 工作流 标签: ,
  1. 2015年8月14日15:20 | #1

    手动点赞

  1. 本文目前尚无任何 trackbacks 和 pingbacks.