`
longgangbai
  • 浏览: 7348616 次
  • 性别: Icon_minigender_1
  • 来自: 上海
社区版块
存档分类
最新评论

工作流Activiti的学习总结（十）Activiti手动执行的应用(UserTask)

 
阅读更多

 工作流模拟某公司请假流程情景如下：
   1.开发人员请假流程，如果开发人员请假，如果请假天数小于3天，组长批准，人事批准即可请假。
   2.如果请假大约三天，需要项目经理或者产品经理批准，并且项目总监批准

 

流程图：

 

 

流程配置：

<?xml version="1.0" encoding="UTF-8"?>
<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC" xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI" typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="http://www.activiti.org/test">
  <process id="UserExecuteTask" name="UserExecuteTask">
    <startEvent id="startevent1" name="Start"></startEvent>
    <parallelGateway id="parallelgateway1" name="多种请假方式"></parallelGateway>
    <userTask id="servicetask1" name="项目经理同意" >
       <extensionElements>
          <activiti:taskListener event="complete" class="com.easyway.workflow.activiti.gateway.DeveloperManagerUserTaskListener"/>
       </extensionElements>
    </userTask>
    <userTask id="servicetask2" name="产品经理同意">
       <extensionElements>
          <activiti:taskListener event="complete" class="com.easyway.workflow.activiti.gateway.ProductManagerUserTaskListener"/>
       </extensionElements>
    </userTask>
    <userTask id="servicetask3" name="项目组长同意" >
          <extensionElements>
          <activiti:taskListener event="complete" class="com.easyway.workflow.activiti.gateway.TeamLeaderUserTaskListener"/>
       </extensionElements>
    </userTask>
    <parallelGateway id="parallelgateway2" name="First Join"></parallelGateway>
    <userTask id="servicetask4" name="项目总监同意" >
       <extensionElements>
          <activiti:taskListener event="complete" class="com.easyway.workflow.activiti.gateway.ProductBossUserTaskListener"/>
       </extensionElements>
    </userTask>
    <parallelGateway id="parallelgateway3" name="人事判断"></parallelGateway>
    <userTask id="servicetask5" name="人事部门同意" >
        <extensionElements>
           <activiti:taskListener event="complete"  class="com.easyway.workflow.activiti.gateway.HumanResouceUserTaskListener"/>
        </extensionElements>
    </userTask>
    <endEvent id="endevent1" name="End"></endEvent>
    <sequenceFlow id="flow1" name="" sourceRef="startevent1" targetRef="parallelgateway1"></sequenceFlow>
    <sequenceFlow id="flow2" name="" sourceRef="parallelgateway1" targetRef="servicetask1"></sequenceFlow>
    <sequenceFlow id="flow3" name="" sourceRef="parallelgateway1" targetRef="servicetask2"></sequenceFlow>
    <sequenceFlow id="flow4" name="" sourceRef="parallelgateway1" targetRef="servicetask3"></sequenceFlow>
    <sequenceFlow id="flow5" name="" sourceRef="servicetask1" targetRef="parallelgateway2"></sequenceFlow>
    <sequenceFlow id="flow6" name="" sourceRef="servicetask2" targetRef="parallelgateway2"></sequenceFlow>
    <sequenceFlow id="flow7" name="" sourceRef="servicetask3" targetRef="parallelgateway3"></sequenceFlow>
    <sequenceFlow id="flow8" name="" sourceRef="parallelgateway2" targetRef="servicetask4"></sequenceFlow>
    <sequenceFlow id="flow9" name="" sourceRef="servicetask4" targetRef="parallelgateway3"></sequenceFlow>
    <sequenceFlow id="flow10" name="" sourceRef="parallelgateway3" targetRef="servicetask5"></sequenceFlow>
    <sequenceFlow id="flow11" name="" sourceRef="servicetask5" targetRef="endevent1"></sequenceFlow>
  </process>
</definitions>

 

流程实现：

 

package com.easyway.workflow.activiti.gateway;


import java.util.logging.Logger;
/**
 * execute方法的参数DelegateExecution execution可以在流程中各个结点之间传递流程变量。 
 * <activiti:taskListener>元素的event属性，它一共包含三种事件："create"、"assignment"、"complete"，分别表示结点执行处理逻辑的时机为：在处理类实例化时、在结点处理逻辑被指派时、在结点处理逻辑执行完成时，可以根据自己的需要进行指定。 
  *上述流程定义中，4个任务结点对应的处理类
  *
  *<activiti:taskListener>元素的event属性，它一共包含三种事件："create"、"assignment"、"complete"，分别表示结点执行处理逻辑的时机为：在处理类实例化时、在结点处理逻辑被指派时、在结点处理逻辑执行完成时，可以根据自己的需要进行指定。 
  *
 *<userTask id="servicetask2" name="产品经理同意">
       <extensionElements>
          <activiti:taskListener event="complete" class="com.easyway.workflow.activiti.gateway.ProductManagerUserTaskListener"/>
       </extensionElements>
    </userTask>
 *
 *
 * 项目经理审批过程
 * @author longgangbai
 * 
 * 
 * 2011-12-17  下午07:45:47
 */
public class DeveloperManagerUserTaskListener implements TaskListener 
{

	private final Logger log = Logger.getLogger(DeveloperManagerUserTaskListener.class.getName());


	/* (non-Javadoc)
	 * @see org.activiti.engine.delegate.TaskListener#notify(org.activiti.engine.delegate.DelegateTask)
	 */
	@Override
	public void notify(DelegateTask delegateTask) {
		try {
			Thread.sleep(10000);
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		log.info("variavles=" + delegateTask.getVariables());
		delegateTask.setVariable("项目经理", "请假天数大约3天，同意请假。");
		log.info("项目经理，请假天数大约3天，同意请假。.");
		
	}
}

 

package com.easyway.workflow.activiti.gateway;


import java.util.logging.Logger;
/**
  * execute方法的参数DelegateExecution execution可以在流程中各个结点之间传递流程变量。 
 *
 *<activiti:taskListener>元素的event属性，它一共包含三种事件："create"、"assignment"、"complete"，分别表示结点执行处理逻辑的时机为：在处理类实例化时、在结点处理逻辑被指派时、在结点处理逻辑执行完成时，可以根据自己的需要进行指定。 

 *    <userTask id="servicetask5" name="人事部门同意" >
        <extensionElements>
           <activiti:taskListener event="complete"  class="com.easyway.workflow.activiti.gateway.HumanResouceUserTaskListener"/>
        </extensionElements>
    </userTask>
    
 * 人事部门审批过程
 * @author longgangbai
 * 
 * 2011-12-17  下午07:45:47
 */
public class HumanResouceUserTaskListener implements TaskListener {

	private final Logger log = Logger.getLogger(HumanResouceUserTaskListener.class.getName());


	/* (non-Javadoc)
	 * @see org.activiti.engine.delegate.TaskListener#notify(org.activiti.engine.delegate.DelegateTask)
	 */
	@Override
	public void notify(DelegateTask delegateTask) {
		try {
			Thread.sleep(10000);
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		log.info("variavles=" + delegateTask.getVariables());
		delegateTask.setVariable("人事部门", "请假天数大约3天，同意请假。");
		log.info("人事部门 ，请假天数大约3天，同意请假。");
		
	}
}

 

 

package com.easyway.workflow.activiti.gateway;


import java.util.logging.Logger;
/**
 *  execute方法的参数DelegateExecution execution可以在流程中各个结点之间传递流程变量。 
 *  
 *  <activiti:taskListener>元素的event属性，它一共包含三种事件："create"、"assignment"、"complete"，分别表示结点执行处理逻辑的时机为：在处理类实例化时、在结点处理逻辑被指派时、在结点处理逻辑执行完成时，可以根据自己的需要进行指定。 

 *  配置如下  
 *    <userTask id="servicetask4" name="项目总监同意" >
       <extensionElements>
          <activiti:taskListener event="complete" class="com.easyway.workflow.activiti.gateway.ProductBossUserTaskListener"/>
       </extensionElements>
    </userTask>
 *
 *
 * 项目总监审批过程
 * @author longgangbai
 * 
 * 2011-12-17  下午07:45:47
 */
public class ProductBossUserTaskListener implements TaskListener {

	private final Logger log = Logger.getLogger(ProductBossUserTaskListener.class.getName());


	/* (non-Javadoc)
	 * @see org.activiti.engine.delegate.TaskListener#notify(org.activiti.engine.delegate.DelegateTask)
	 */
	@Override
	public void notify(DelegateTask execution) {
		try {
			Thread.sleep(10000);
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		log.info("variavles=" + execution.getVariables());
		execution.setVariable("项目总监", "请假天数大约3天，同意请假。");
		log.info("项目总监,请假天数大约3天，同意请假。");		
		
	}
}

 

package com.easyway.workflow.activiti.gateway;


import java.util.logging.Logger;
/**
  * execute方法的参数DelegateExecution execution可以在流程中各个结点之间传递流程变量。
  * 
  * <activiti:taskListener>元素的event属性，它一共包含三种事件："create"、"assignment"、"complete"，分别表示结点执行处理逻辑的时机为：在处理类实例化时、在结点处理逻辑被指派时、在结点处理逻辑执行完成时，可以根据自己的需要进行指定。 

  * 
  * 配置如下 
 *    <userTask id="servicetask1" name="项目经理同意" >
       <extensionElements>
          <activiti:taskListener event="complete" class="com.easyway.workflow.activiti.gateway.DeveloperManagerUserTaskListener"/>
       </extensionElements>
    </userTask>
 * 产品经理审批过程
 * @author longgangbai
 * 
 * 2011-12-17  下午07:45:47
 */
public class ProductManagerUserTaskListener implements TaskListener {

	private final Logger log = Logger.getLogger(ProductManagerUserTaskListener.class.getName());


	/* (non-Javadoc)
	 * @see org.activiti.engine.delegate.TaskListener#notify(org.activiti.engine.delegate.DelegateTask)
	 */
	@Override
	public void notify(DelegateTask execution) {
		try {
			Thread.sleep(10000);
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		log.info("variavles=" + execution.getVariables());
		execution.setVariable("产品经理", "请假天数大约3天，同意请假。");
		log.info("产品经理,请假天数大约3天，同意请假。");	
		
	}
}

 

 

package com.easyway.workflow.activiti.gateway;


import java.util.logging.Logger;
/**
 * 
 * 
 * <activiti:taskListener>元素的event属性，它一共包含三种事件："create"、"assignment"、"complete"，分别表示结点执行处理逻辑的时机为：在处理类实例化时、在结点处理逻辑被指派时、在结点处理逻辑执行完成时，可以根据自己的需要进行指定。 
 * 
 * 
 * 配置如下：
 *     <userTask id="servicetask3" name="项目组长同意" >
          <extensionElements>
          <activiti:taskListener event="complete" class="com.easyway.workflow.activiti.gateway.TeamLeaderUserTaskListener"/>
       </extensionElements>
    </userTask>
    
 * 项目组长批准请假
 *    模拟当开发人员请假小于3天，组长比准
 * @author longgangbai
 * 
 * 2011-12-17  上午09:07:37
 */
public class TeamLeaderUserTaskListener implements TaskListener {

	private final Logger log = Logger.getLogger(TeamLeaderUserTaskListener.class.getName());


	/* (non-Javadoc)
	 * @see org.activiti.engine.delegate.TaskListener#notify(org.activiti.engine.delegate.DelegateTask)
	 */
	@Override
	public void notify(DelegateTask execution) {
		try {
			Thread.sleep(10000);
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		log.info("variavles=" + execution.getVariables());
		execution.setVariable("项目组长", "请假天数小于3天，同意请假。");
		log.info("项目组长,请假天数小于3天，同意请假。");
	}
}

 

package com.easyway.workflow.activiti.gateway;


import junit.framework.TestCase;
/**
 * 主要是在测试之前做一些初始化工作，主要包括流程引擎实例
 * 的构建，及其流程提供的基本服务。
 * 目的：让开发者熟悉工作流使用过程使用的几个步骤
 * 1.加载相关的工作流全局配置文件activiti.cfg.xml配置文件信息
 * 2.获取工作流相关的服务(RepositoryService，RuntimeService，
 *    TaskService，HistoryService，FormService，ManagementService，
 *    IdentityService等)
 * 2.加载工作流文件*.bpmn20.xml信息
 * 
 * 3.部署工作流
 *    部署工作流由多种方式，在以后会相继讲解
 * 
 * @author longgangbai
 * 
 * 2011-12-17  下午07:48:59
 */
public abstract class AbstractTest extends TestCase {

	private ProcessEngine processEngine;
	protected String deploymentId;
	protected RepositoryService repositoryService;
	protected RuntimeService runtimeService;
	protected TaskService taskService;
	protected FormService formService;
	protected HistoryService historyService;
	protected IdentityService identityService;
	protected ManagementService managementService;
	
	
	/**
	 * 测试用例开始初始化工作
	 * 1.创建相关的工作流程对象ProcessEngine
	 * 2.创建相关的服务
	 * 3.
	 */
	@Override
	protected void setUp() throws Exception {
		super.setUp();
		//由于ProcessEngine为线程安全性对象，整个项目可以共用一个
		if(processEngine==null) {
			//此处使用此种方法调用的activiti的配置文件为 classpath路径下的activiti.cfg.xml
			//采用的H2的数据库
			processEngine = ProcessEngines.getDefaultProcessEngine();
		}
		//获取工作流的各种服务信息
		repositoryService = processEngine.getRepositoryService();
		runtimeService = processEngine.getRuntimeService();
		taskService = processEngine.getTaskService();
		formService = processEngine.getFormService();
		historyService = processEngine.getHistoryService();
		identityService = processEngine.getIdentityService();
		managementService = processEngine.getManagementService();
		//调用扩展的初始化工作
		initialize();
		
	}
	
	/**
	 * test销毁方法
	 */
	@Override
	protected void tearDown() throws Exception {
		super.tearDown();
		destroy();
	}
	
	/**
	 * 便于子类的工作的初始化的扩展工作
	 * 
	 * 
	 * @throws Exception
	 */
	protected abstract void initialize() throws Exception;
	/**
	 * 便于子类的工作的销毁的扩展工作
	 * 
	 * @throws Exception
	 */
	protected abstract void destroy() throws Exception;
}

 

 

/**
package com.easyway.workflow.activiti.gateway;
import java.util.Date;
/**
 * 测试实例如下
 * 
 * @author longgangbai
 * 
 * 2011-12-18  上午12:00:03
 */
public class ParallelGatewayTest extends AbstractTest { 
	private String deploymentId; 
	private Date start = null; 
	private Date end = null; 

	@Override 
	protected void initialize() throws Exception { 
		deploymentId = repositoryService.createDeployment() 
		.addClasspathResource("diagrams/UserExecuteTask.bpmn20.xml") 
		.deploy().getId(); 
	} 

	@Override 
	protected void destroy() throws Exception { 
			repositoryService.deleteDeployment(deploymentId, true); 
	} 

	@Deployment 
	public void testUnbalancedForkJoin() { 
		//获取流程实例对象
		ProcessInstance pi = runtimeService.startProcessInstanceByKey("UserExecuteTask"); 
		//获取任务服务对象的查询
		TaskQuery query = taskService.createTaskQuery().processInstanceId(pi.getId()).orderByTaskName().asc(); 
	   //获取所有的任务
		List<Task> tasks = query.list(); 
		assertEquals(3, tasks.size()); 
		start = new Date(); 
	   
		for(Task task : tasks) {
			//执行任务
			taskService.complete(task.getId());
			System.out.println("name =+"+task.getName());
			end = new Date(); 
			System.out.println("" + (end.getTime()-start.getTime()) + "ms."); 
		} 
		//查询任务
		tasks = query.list(); 
		assertEquals(1, tasks.size()); 
		for(Task task : tasks) { 
			taskService.complete(task.getId()); 
			System.out.println("name =+"+task.getName());
			end = new Date(); 
			System.out.println("" + (end.getTime()-start.getTime()) + "ms."); 
		} 
		end = new Date(); 
		System.out.println("" + (end.getTime()-start.getTime()) + "ms."); 
	} 
}

 运行结果：

2011-12-18 13:15:29 org.activiti.engine.ProcessEngines initProcessEnginFromResource
信息: initializing process engine for resource jar:file:/C:/activiti-rest/activiti-cfg.jar!/activiti.cfg.xml
2011-12-18 13:15:32 org.activiti.engine.impl.ProcessEngineImpl <init>
信息: ProcessEngine default created
2011-12-18 13:15:32 org.activiti.engine.ProcessEngines initProcessEnginFromResource
信息: initialised process engine default
2011-12-18 13:15:32 org.activiti.engine.impl.jobexecutor.JobAcquisitionThread run
信息: JobAcquisitionThread starting to acquire jobs
2011-12-18 13:15:32 org.activiti.engine.impl.bpmn.deployer.BpmnDeployer deploy
信息: Processing resource diagrams/UserExecuteTask.bpmn20.xml
2011-12-18 13:15:33 org.activiti.engine.impl.bpmn.parser.BpmnParse parseDefinitionsAttributes
信息: XMLSchema currently not supported as typeLanguage
2011-12-18 13:15:33 org.activiti.engine.impl.bpmn.parser.BpmnParse parseDefinitionsAttributes
信息: XPath currently not supported as expressionLanguage
2011-12-18 13:15:43 com.easyway.workflow.activiti.gateway.ProductManagerUserTaskListener notify
信息: variavles={}
2011-12-18 13:15:43 com.easyway.workflow.activiti.gateway.ProductManagerUserTaskListener notify
信息: 产品经理,请假天数大约3天，同意请假。
name =+产品经理同意
10094ms.
2011-12-18 13:15:53 com.easyway.workflow.activiti.gateway.TeamLeaderUserTaskListener notify
信息: variavles={产品经理=请假天数大约3天，同意请假。}
2011-12-18 13:15:53 com.easyway.workflow.activiti.gateway.TeamLeaderUserTaskListener notify
信息: 项目组长,请假天数小于3天，同意请假。
name =+项目组长同意
20172ms.
2011-12-18 13:16:03 com.easyway.workflow.activiti.gateway.DeveloperManagerUserTaskListener notify
信息: variavles={项目组长=请假天数小于3天，同意请假。, 产品经理=请假天数大约3天，同意请假。}
2011-12-18 13:16:03 com.easyway.workflow.activiti.gateway.DeveloperManagerUserTaskListener notify
信息: 项目经理，请假天数大约3天，同意请假。.
name =+项目经理同意
30313ms.
2011-12-18 13:16:13 com.easyway.workflow.activiti.gateway.ProductBossUserTaskListener notify
信息: variavles={项目组长=请假天数小于3天，同意请假。, 项目经理=请假天数大约3天，同意请假。, 产品经理=请假天数大约3天，同意请假。}
2011-12-18 13:16:13 com.easyway.workflow.activiti.gateway.ProductBossUserTaskListener notify
信息: 项目总监,请假天数大约3天，同意请假。
name =+项目总监同意
40485ms.
40485ms.

 

分享到：
| 工作流Activiti的学习总结（九）Activiti手 ...
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    activiti学习思维导图

    Activiti 是一个开源的工作流和业务自动化引擎，广泛应用于企业级应用中，提供流程定义、执行、监控等功能。本资源包含的"activiti学习思维导图"是一份关于Activiti学习的综合指南，旨在帮助用户从基础到进阶地掌握...

    Activiti工作流课程.doc

    ### Activiti工作流知识点概述 #### 一、工作流概念及其重要性 - **定义**：工作流（Workflow）指的是“业务过程的部分或整体在计算机应用环境下的自动化”，旨在通过预定义规则自动化传递文档、信息或任务的过程，...

    Activiti 工作流 Eclipse插件

    Activiti 是一个开源的工作流引擎，它被广泛用于企业级应用程序中实现业务流程自动化。Eclipse 插件是开发者友好的工具，可以帮助用户在 Eclipse 开发环境中直接设计、调试和管理 Activiti 流程定义。这个名为 ...

    Activiti创建数据库表demo

    Activiti 是一个开源的工作流引擎，它主要用于自动化业务流程。这个"Activiti创建数据库表demo"是一个示例，旨在教你如何使用Activiti来创建和管理数据库表。在深入讲解之前，我们先了解一下Activiti的基本概念。 1...

    Activiti绘制图讲解 基于eclipse 个人总结文档

    在Activiti的工作流设计中，图形符号扮演着极其重要的角色，这些符号有助于清晰地展现流程的结构和逻辑。 **1. Start（启动）** - **没有触发器类型的开始流程**：表示流程的起点，通常用一个圆形来表示。 - **...

    Activiti入门之三--ORM框架MyBatis的基础及使用

    总结来说，这篇博文将带你了解如何在 Activiti 中集成 MyBatis，通过实例展示了如何编写 MyBatis 的配置、映射文件以及服务类，以便在工作流中执行复杂的数据库操作。这种方式提高了代码的可读性和维护性，同时利用...

    Activiti中文用户文档

    - **定义与功能**：Activiti是一款开源的工作流引擎，基于Java语言开发，主要用于实现业务流程管理（BPM），支持BPMN 2.0标准。通过Activiti，开发人员可以轻松地设计、部署和执行复杂的业务流程。 - **适用范围**...

    activitissm:springMVC-spring-mybits搭建的activiti工作流框架

    总结，构建一个基于SpringMVC-Spring-MyBatis的Activiti工作流框架，需要理解并熟练运用上述各组件，同时具备良好的软件设计思想，以便实现灵活、可维护的系统。通过这种方式，我们可以为企业提供一套高效、规范的...

    基于hap3.0简单工作流开发步骤

    通过理解这些基础知识，开发者可以更加高效地设计和实现自己的工作流应用。此外，文中还列举了一些常见的错误和解决策略，帮助开发者避免在开发过程中遇到的问题。希望这些内容能够对正在学习或使用HAP3.0框架的读者...

Magicbox
Global site tag (gtag.js) - Google Analytics