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>
***********************分割线*********************
秋天该多好,若你尚在场……
分享到:
相关推荐
Activiti提供了动态获取流程图的功能,通过DefaultProcessDiagramGenerator类和repositoryService组件,可以根据流程定义id或流程实例id来绘制流程图。同时,高亮显示的节点可以通过runtimeService服务组件和...
在这个实例中,我们可能会看到如何使用 Activiti 的 API 和相关工具创建 BPMN 流程图,包括启动流程、处理任务、信号和事件等。 首先,我们需要了解 Activiti 的核心概念: 1. **流程定义**:这是 BPMN 图形的代码...
1. 流程模型:Flowable在BPMN 2.0标准的实现上更为完整,支持更多复杂的流程模型,如事件子流程、多实例任务等。 2. 社区与支持:Activiti有着更广泛的社区支持和丰富的文档,适合大型企业或项目,而Flowable则在...
2. **流程图(Process Diagram)**:案例可能包含流程图,它们是BPMN符号的可视化表示,帮助用户理解流程的结构。你可以通过这些图表理解流程的流转逻辑,如任务如何分配、条件判断在哪里、如何处理并发任务等。 3....
Activiti 插件支持 BPMN 2.0,允许用户创建复杂的流程图,包括任务、决策点、事件和并发流等元素。 3. **Eclipse IDE**:Eclipse 是一款强大的开放源代码集成开发环境,广泛用于Java应用开发,但也支持其他编程语言...
- **流程图**:可视化流程图展示。 - **XML内容**:对应的BPMN XML文件。 - **启动一个流程实例**:通过代码启动流程实例。 - **任务列表**:展示当前待办任务。 - **领取任务**:用户领取任务。 - **完成任务**:...
这些元素通过连线连接,形成一个完整的流程图。 **三、Activiti Designer** 为了方便流程设计,Activiti提供了一个名为Activiti Designer的Eclipse插件,允许开发者使用图形化界面设计流程。设计完成后,可以导出`....
BPMN包括各种元素,如开始事件、结束事件、任务、网关、事件等,它们共同构建了一个完整的流程图。 2. **流程引擎**:Activiti引擎是系统的核心,负责执行流程实例。它可以解析并执行由建模工具生成的流程定义,...
3. **创建流程定义**:设计 BPMN 2.0 流程图,并将其保存为 `.bpmn` 文件。 4. **启动流程引擎**:在 SpringBoot 启动类或配置类中,配置并启动 Activiti 引擎。 5. **编写业务代码**:根据业务需求,编写与流程相关...
在描述中提到的"Canvas动画"是指Activiti提供的可视化建模工具,它允许开发者通过拖拽方式创建流程图,并以动画形式展示流程执行的过程,使得流程设计更加直观易懂。这种动态演示方式有助于开发者和业务人员更好地...
1. **配置多实例任务**:在BPMN 2.0流程图中,我们可以使用`miBody`元素来定义一个多实例任务。例如,使用`userTask`并添加`camunda:collection`和`camunda:elementVariable`属性来指定参与者的集合和每个参与者的...
2. **模型器(Modeler)**:Activiti 提供了一个可视化的模型器,让用户可以拖放元素来创建流程图。这使得非程序员也能设计和理解复杂的业务流程。 3. **部署(Deployment)**:流程定义完成后,需要部署到Activiti...
BPMN(Business Process Model and Notation)是一种图形化表示方法,使得非技术人员也能理解流程图。 2. **BPMN 2.0支持**: Activiti-5.22.0 遵循BPMN 2.0规范,这意味着它支持如任务、网关、事件、子流程等元素...
它提供了丰富的符号集,如开始事件、结束事件、任务、网关和泳道等,使非技术人员也能理解流程图。Activiti支持BPMN 2.0,使得流程设计直观且易于理解。 3. **请假流程实例**: 这个教程可能涵盖了一个完整的请假...
这些文件描述了流程的各个步骤,如用户任务、服务任务、并发分支、决策节点等。 2. **配置Spring整合**:在Spring配置文件中,你需要配置Activiti的bean,包括流程引擎、数据源、事务管理器等,以确保Spring和...
用户可以通过 Activiti Designer 工具创建流程图,包括任务(Task)、网关(Gateway)、事件(Event)等元素,以直观地设计和理解业务流程。 2. **部署与执行**:流程定义完成后,可以通过 Activiti 的 API 或管理...
1. 管理台:Activiti 提供了一个Web管理界面,用于监控和管理流程实例,查看流程图,以及进行其他管理操作。 2. 日志与调试:通过日志系统,可以跟踪和分析流程运行情况,辅助定位和解决问题。 八、最佳实践与案例 ...
1. 打开 Activiti 的流程设计器,选择“并行网关”元素,拖放到流程图中。 2. 连接网关:使用顺序流(Sequence Flow)连接并行网关与其他活动,定义流程的分支和汇聚路径。 3. 设置条件:如果需要,可以在顺序流上...
- **流程可视化**:提供Web界面供用户设计和查看流程图,增强了用户体验。 - **任务管理**:提供任务分配、委托、完成等功能,支持多任务并发执行。 - **表单集成**:可与前端表单系统集成,实现业务数据的提交和...
1. 流程设计:使用 BPMN 工具(如 Activiti Modeler 或 Eclipse 插件)设计流程图,导出 BPMN XML 文件。 2. 部署流程:将 BPMN XML 文件部署到 Activiti 引擎,创建流程定义。 3. 启动流程:通过 API 或用户界面...