`
lynnlysh
  • 浏览: 178876 次
  • 性别: Icon_minigender_2
  • 来自: 天津
社区版块
存档分类
最新评论

activiti 并发任务实例流程图的显示

阅读更多
1.写在前面:
activiti中并发后的活动任务节点通过runtimeService.getActiveActivityIds(String proInstId)得到。
这个方法在Activiti的doc文档中介绍的不对,它错把参数写成了executionId,而事实上,一个流程实例(对应流程实例编号ProInstId)在运行中通过并发节点产生多个执行任务(对应执行编号executionId)。
2.关键代码:
ProcessInstanceAction.java
public class ProcessInstanceAction extends BaseAction {
  private List<ActivityImpl> actImpls = new ArrayList<ActivityImpl>();

    public List<ActivityImpl> getActImpls() {
        return actImpls;
    }

    public void setActImpls(List<ActivityImpl> actImpls) {
        this.actImpls = actImpls;
    }
    /**
     * 显示流程图
     * 
     * @return
     * @throws Exception
     */
    public String getProcessPic() throws Exception {
        // String taskId =
        // "2901";//getRequest().getParameter("taskId");3016,552,3020
        String procDefId = getRequest().getParameter("procDefId");
        ProcessDefinition procDef = repositoryService
                .createProcessDefinitionQuery().processDefinitionId(procDefId)
                .singleResult();
        String diagramResourceName = procDef.getDiagramResourceName();
        InputStream imageStream = repositoryService.getResourceAsStream(procDef
                .getDeploymentId(), diagramResourceName);
        getRequest().setAttribute("inputStream", imageStream);
        return SUCCESS;
    }

    /**
     * 获取跟踪信息
     * 
     * @return
     * @throws Exception
     */
    public String getProcessMap() throws Exception {
        String procDefId = getRequest().getParameter("procDefId");
        String proInstId = getRequest().getParameter("procInstId");
        ProcessDefinition processDefinition = repositoryService
                .createProcessDefinitionQuery().processDefinitionId(procDefId)
                .singleResult();

        ProcessDefinitionImpl pdImpl = (ProcessDefinitionImpl) processDefinition;
        String processDefinitionId = pdImpl.getId();// 流程标识

        ProcessDefinitionEntity def = (ProcessDefinitionEntity) ((RepositoryServiceImpl) repositoryService)
                .getDeployedProcessDefinition(processDefinitionId);

        List<ActivityImpl> activitiList = def.getActivities();// 获得当前任务的所有节点

        /**获取活动任务start**/

        List<String> ActiveActivityIds = runtimeService
                .getActiveActivityIds(proInstId);//获取将被执行的活动节点
        for (String activeId : ActiveActivityIds) {

            for (ActivityImpl activityImpl : activitiList) {
                String id = activityImpl.getId();
                if (activityImpl.isScope()) {//判断节点是否为subProcess
                    if (activityImpl.getActivities().size() > 1) {
                        List<ActivityImpl> subAcList = activityImpl
                                .getActivities();
                        for (ActivityImpl subActImpl : subAcList) {
                            String subid = subActImpl.getId();
                            if (activeId.equals(subid)) {// 获得执行到的活动节点
                                actImpls.add(subActImpl);
                                break;
                            }
                        }
                    }

                }
                if (activeId.equals(id)) {// 获得执行到的活动节点

                    actImpls.add(activityImpl);
                }
            }
        }
        /**获取活动任务end**/
       
        getRequest().setAttribute("procDefId", procDefId);
        /**这个参数通过前台的showImg.jsp传给getProcessPic.action获取流程图**/

        return SUCCESS;
    }
}


pic.jsp
<%@page import="java.io.InputStream"%>
<%@page import="org.activiti.engine.impl.*"%>
<%@page import="org.activiti.engine.impl.pvm.*"%>
<%@page import="org.activiti.engine.impl.pvm.process.*"%>
<%@page import="org.activiti.engine.repository.*"%>
<%@page import="org.activiti.engine.*"%>
<%@ page language="java" contentType="text/html; charset=UTF-8"
    pageEncoding="UTF-8"%>

<%
	
	InputStream is = (InputStream)request.getAttribute("inputStream");
	
	byte[] b = new byte[1024];
	int len = -1;
	while((len = is.read(b, 0, 1024)) != -1) {
		response.getOutputStream().write(b, 0, len);
		// 防止异常:getOutputStream() has already been called for this response
		out.clear();
		out = pageContext.pushBody();
	}	

%>

showImg.jsp
<%@page import="java.io.InputStream"%>
<%@page import="org.activiti.engine.impl.*"%>
<%@page import="org.activiti.engine.impl.pvm.*"%>
<%@page import="org.activiti.engine.impl.pvm.process.*"%>
<%@page import="org.activiti.engine.repository.*"%>
<%@page import="org.activiti.engine.*"%>
<%@ page language="java" pageEncoding="UTF-8"%>
<%@ taglib prefix="s" uri="/struts-tags"%>
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">

<html>
<head>
	<title></title>
</head>
<body>
	<div >
		<img src="getProcessPic.action?procDefId=${procDefId}" style="position:absolute; left:0px; top:0px;">
	<s:iterator value="actImpls"> 	
 		<!-- 给执行的节点加框 -->
 		<div style="position:absolute; border:2px solid red;left:${x-1 }px;top:${y-1 }px;width:${width }px;height:${height }px;"></div>
 		</s:iterator>
 	</div>

</body>
</html>

另附:环境配置struts+activiti+spring:
struts.xml
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE struts PUBLIC
"-//Apache Software Foundation//DTD Struts Configuration 2.0//EN"
"http://struts.apache.org/dtds/struts-2.0.dtd">
<struts>
	<constant name="struts.objectFactory.spring.autoWire" value="name" />
	<constant name="struts.objectFactory" value="spring" />
	<package name="default" extends="struts-default">
	<action name="getProcessPic" class="processInstanceAction" method="getProcessPic">
			<result name = "success" >/incident/pic.jsp</result>
		</action>
		<action name="getProcessMap" class="processInstanceAction" method="getProcessMap">
			<result name = "success" >/incident/showImg.jsp</result>
		</action>
</package>
</struts>


applicationContext.xml
<?xml version="1.0" encoding="UTF-8"?>

<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">

  <context:component-scan base-package="org.activiti.spring.test.jpa"/>

  <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
    <property name="driverClassName" value="com.mysql.jdbc.Driver" />
    <property name="url" value="jdbc:mysql://localhost:3306/acitivitiexample?autoReconnect=true" />
    <property name="username" value="root" />
    <property name="password" value="root" />
    <property name="defaultAutoCommit" value="false" />
  </bean>
  
  <tx:annotation-driven transaction-manager="transactionManager" proxy-target-class="false"/>
  <bean id="transactionManager" class="org.springframework.orm.jpa.JpaTransactionManager">
    <property name="entityManagerFactory" ref="entityManagerFactory"/>
  </bean>
  
  <bean id="entityManagerFactory" class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean">
    <property name="dataSource" ref="dataSource"/>
     <property name="persistenceXmlLocation">
      <value>classpath:/jpa/persistence.xml</value>
    </property>
    <property name="jpaVendorAdapter">
      <bean class="org.springframework.orm.jpa.vendor.OpenJpaVendorAdapter">
        <property name="databasePlatform" value="org.apache.openjpa.jdbc.sql.MySQLDictionary" />
      </bean>
    </property>
  </bean>
  
  <bean id="incidentBean" class="jpa.IncidentBean">
  </bean>
  
  <bean id="processEngineConfiguration" class="org.activiti.spring.SpringProcessEngineConfiguration">
    <property name="dataSource" ref="dataSource" />
    <property name="transactionManager" ref="transactionManager" />
    <property name="databaseSchemaUpdate" value="true" />
    <property name="jpaEntityManagerFactory" ref="entityManagerFactory" />
    <property name="jpaHandleTransaction" value="false" />
    <property name="jpaCloseEntityManager" value="false" />
    <property name="jobExecutorActivate" value="true" />
    <property name="mailServerPort" value="25" /> 
   </bean>
  
  <bean id="processEngine" class="org.activiti.spring.ProcessEngineFactoryBean">
    <property name="processEngineConfiguration" ref="processEngineConfiguration" />
  </bean>
  
  <bean id="repositoryService" factory-bean="processEngine" factory-method="getRepositoryService" />
  <bean id="runtimeService" factory-bean="processEngine" factory-method="getRuntimeService" />
  <bean id="taskService" factory-bean="processEngine" factory-method="getTaskService" />
  <bean id="historyService" factory-bean="processEngine" factory-method="getHistoryService" />
  <bean id="managementService" factory-bean="processEngine" factory-method="getManagementService" />
  <bean id="identityService" factory-bean="processEngine" factory-method="getIdentityService" />
  <bean id="formService" factory-bean="processEngine"
		factory-method="getFormService" />
   <bean id="processInstanceAction" class="action.ProcessInstanceAction"
		scope="prototype">
		<property name="runtimeService" ref="runtimeService"></property>
		<property name="taskService" ref="taskService"></property>
		<property name="formService" ref="formService"></property>
		<property name="identityService" ref="identityService"></property>
		<property name="incidentBean" ref="incidentBean"></property>
		<property name="repositoryService" ref="repositoryService"></property>
  </bean>
 </beans>

***********************分割线*********************
秋天该多好,若你尚在场……
分享到:
评论
2 楼 u014133453 2019-01-18  
引用
引用
引用
引用
引用
1 楼 BigBird2012 2011-11-12  
您好,看到您做的这个功能,您能把代码发给我一份吗?或者把您做出来的效果图发给我一个也行。我的Email 是 1755610380@qq.com

相关推荐

    Activiti如何动态获取流程图过程详解

    Activiti提供了动态获取流程图的功能,通过DefaultProcessDiagramGenerator类和repositoryService组件,可以根据流程定义id或流程实例id来绘制流程图。同时,高亮显示的节点可以通过runtimeService服务组件和...

    activiti工作流实例

    在这个实例中,我们可能会看到如何使用 Activiti 的 API 和相关工具创建 BPMN 流程图,包括启动流程、处理任务、信号和事件等。 首先,我们需要了解 Activiti 的核心概念: 1. **流程定义**:这是 BPMN 图形的代码...

    流程引擎(Flowable+Activiti)

    1. 流程模型:Flowable在BPMN 2.0标准的实现上更为完整,支持更多复杂的流程模型,如事件子流程、多实例任务等。 2. 社区与支持:Activiti有着更广泛的社区支持和丰富的文档,适合大型企业或项目,而Flowable则在...

    activiti工作流案例

    2. **流程图(Process Diagram)**:案例可能包含流程图,它们是BPMN符号的可视化表示,帮助用户理解流程的结构。你可以通过这些图表理解流程的流转逻辑,如任务如何分配、条件判断在哪里、如何处理并发任务等。 3....

    eclipse的activiti流程图插件.zip

    Activiti 插件支持 BPMN 2.0,允许用户创建复杂的流程图,包括任务、决策点、事件和并发流等元素。 3. **Eclipse IDE**:Eclipse 是一款强大的开放源代码集成开发环境,广泛用于Java应用开发,但也支持其他编程语言...

    activiti 5.16 流程管理 中文版

    - **流程图**:可视化流程图展示。 - **XML内容**:对应的BPMN XML文件。 - **启动一个流程实例**:通过代码启动流程实例。 - **任务列表**:展示当前待办任务。 - **领取任务**:用户领取任务。 - **完成任务**:...

    Activiti工作流之管理流程定义

    这些元素通过连线连接,形成一个完整的流程图。 **三、Activiti Designer** 为了方便流程设计,Activiti提供了一个名为Activiti Designer的Eclipse插件,允许开发者使用图形化界面设计流程。设计完成后,可以导出`....

    activiti工作流详细讲解和实例

    BPMN包括各种元素,如开始事件、结束事件、任务、网关、事件等,它们共同构建了一个完整的流程图。 2. **流程引擎**:Activiti引擎是系统的核心,负责执行流程实例。它可以解析并执行由建模工具生成的流程定义,...

    Springboot 整合activiti及使用案例

    3. **创建流程定义**:设计 BPMN 2.0 流程图,并将其保存为 `.bpmn` 文件。 4. **启动流程引擎**:在 SpringBoot 启动类或配置类中,配置并启动 Activiti 引擎。 5. **编写业务代码**:根据业务需求,编写与流程相关...

    Activiti工作流示例Activiti Demo(带完整源码)非常实用

    在描述中提到的"Canvas动画"是指Activiti提供的可视化建模工具,它允许开发者通过拖拽方式创建流程图,并以动画形式展示流程执行的过程,使得流程设计更加直观易懂。这种动态演示方式有助于开发者和业务人员更好地...

    Activiti-5.4中实现会签

    1. **配置多实例任务**:在BPMN 2.0流程图中,我们可以使用`miBody`元素来定义一个多实例任务。例如,使用`userTask`并添加`camunda:collection`和`camunda:elementVariable`属性来指定参与者的集合和每个参与者的...

    activiti流程管理的几个小例子

    2. **模型器(Modeler)**:Activiti 提供了一个可视化的模型器,让用户可以拖放元素来创建流程图。这使得非程序员也能设计和理解复杂的业务流程。 3. **部署(Deployment)**:流程定义完成后,需要部署到Activiti...

    activiti-5.22.0&Activiti-activiti-5.22.0.zip

    BPMN(Business Process Model and Notation)是一种图形化表示方法,使得非技术人员也能理解流程图。 2. **BPMN 2.0支持**: Activiti-5.22.0 遵循BPMN 2.0规范,这意味着它支持如任务、网关、事件、子流程等元素...

    activiti视频教程工作流实例(包括源码)-完成调整请假的处理

    它提供了丰富的符号集,如开始事件、结束事件、任务、网关和泳道等,使非技术人员也能理解流程图。Activiti支持BPMN 2.0,使得流程设计直观且易于理解。 3. **请假流程实例**: 这个教程可能涵盖了一个完整的请假...

    spring-activiti验证demo

    这些文件描述了流程的各个步骤,如用户任务、服务任务、并发分支、决策节点等。 2. **配置Spring整合**:在Spring配置文件中,你需要配置Activiti的bean,包括流程引擎、数据源、事务管理器等,以确保Spring和...

    Activiti5.4 用户指南-中文版

    用户可以通过 Activiti Designer 工具创建流程图,包括任务(Task)、网关(Gateway)、事件(Event)等元素,以直观地设计和理解业务流程。 2. **部署与执行**:流程定义完成后,可以通过 Activiti 的 API 或管理...

    Activiti5 用户手册 中文版

    1. 管理台:Activiti 提供了一个Web管理界面,用于监控和管理流程实例,查看流程图,以及进行其他管理操作。 2. 日志与调试:通过日志系统,可以跟踪和分析流程运行情况,辅助定位和解决问题。 八、最佳实践与案例 ...

    Activiti 学习笔记九:并行网关(parallelGateWay)

    1. 打开 Activiti 的流程设计器,选择“并行网关”元素,拖放到流程图中。 2. 连接网关:使用顺序流(Sequence Flow)连接并行网关与其他活动,定义流程的分支和汇聚路径。 3. 设置条件:如果需要,可以在顺序流上...

    activiti用户指南.zip

    1. 流程设计:使用 BPMN 工具(如 Activiti Modeler 或 Eclipse 插件)设计流程图,导出 BPMN XML 文件。 2. 部署流程:将 BPMN XML 文件部署到 Activiti 引擎,创建流程定义。 3. 启动流程:通过 API 或用户界面...

    Activiti7的开源项目,用于二次开发!

    - **流程可视化**:提供Web界面供用户设计和查看流程图,增强了用户体验。 - **任务管理**:提供任务分配、委托、完成等功能,支持多任务并发执行。 - **表单集成**:可与前端表单系统集成,实现业务数据的提交和...

Global site tag (gtag.js) - Google Analytics