概述
Activiti在5.15以后的版本后,增加了统一的事件入口,不需要再像以前那样,监听流程的事件时,在流程定义的BPMN文件中为每个节点及流程增加以下的配置,以实现监听事件的做法,这种做法导致我们发布流程时,需要对bpmn文件进行设置,非常不方便,若调整其XML或Class类名或包名,都需要对BPMN文件重新修改并且发布,难度可想而知。
为了规避这种问题,我们重新引入统一监控机制,其思路来自Activiti的开发指导文件,如下:
http://www.activiti.org/userguide/index.html#eventDispatcherConfiguration
构建Activiti的事件分发器
统一事件处理,有利于为流程与业务的结合提供统一入口的处理,同进为后续的流程扩展提供了便利,包括任务人员的指派、会签的计算、流程回退的处理、流程日志等提供数据的切入口,所以通过构建我们的事件监听器就显得非常重要了。
定义的全局事件监听器的入口
package com.redxun.bpm.activiti.listener; import java.util.HashMap; import java.util.Map; import org.activiti.engine.delegate.event.ActivitiEvent; import org.activiti.engine.delegate.event.ActivitiEventListener; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import com.redxun.saweb.util.WebAppUtil; /** * Activiti的全局事件监听器,即所有事件均需要在这里统一分发处理 * @author csx * @copyright http://www.redxun.cn * */ public class GlobalEventListener implements ActivitiEventListener{ /** * 日志处理器 */ public final static Log logger=LogFactory.getLog(GlobalEventListener.class); //事件及事件的处理器 //private Map<String,EventHandler> handlers=new HashMap<String, EventHandler>(); //更换为以下模式,可以防止Spring容器启动时,ProcessEngine尚未创建,而业务类中又使用了这个引用 private Map<String,String> handlers=new HashMap<String, String>(); @Override public void onEvent(ActivitiEvent event) { String eventType=event.getType().name(); logger.debug("envent type is ========>" + eventType); //根据事件的类型ID,找到对应的事件处理器 String eventHandlerBeanId=handlers.get(eventType); if(eventHandlerBeanId!=null){ EventHandler handler=(EventHandler)WebAppUtil.getBean(eventHandlerBeanId); handler.handle(event); } } @Override public boolean isFailOnException() { return false; } public Map<String, String> getHandlers() { return handlers; } public void setHandlers(Map<String, String> handlers) { this.handlers = handlers; } }
如何把全局监听加至Activiti的配置中去
<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="jobExecutorActivate" value="false" /> <property name="enableDatabaseEventLogging" value="false" /> <property name="databaseType" value="${db.type}" /> <property name="idGenerator" ref="actIdGenerator"/> <property name="eventListeners"> <list> <ref bean="globalEventListener"/> </list> </property> <property name="activityFontName" value="黑体"/> <property name="labelFontName" value="黑体"/> <!-- 用于更改流程节点的执行行为 --> <property name="activityBehaviorFactory" ref="activityBehaviorFactoryExt"/> </bean> <bean id="globalEventListener" class="com.redxun.bpm.activiti.listener.GlobalEventListener"> <property name="handlers"> <map> <entry key="TASK_CREATED" value="taskCreateListener"/> <entry key="TASK_COMPLETED" value="taskCompleteListener"/> <entry key="TASK_ASSIGNED" value="taskAssignedListener"/> <entry key="PROCESS_COMPLETED" value="processCompleteListener"/> <entry key="ACTIVITY_STARTED" value="activityStartedListener"/> <entry key="ACTIVITY_COMPLETED" value="activityCompletedListener"/> <entry key="ACTIVITY_SIGNALED" value="activitySignaledListener"/> </map> </property> </bean>
定义自己的事件处理器接口
/** * Activiti的事件处理器 * @author csx * */ public interface EventHandler { /** * 事件处理器 * @param event */ public void handle(ActivitiEvent event); }
实现自己的任务监控处理
package com.redxun.bpm.activiti.listener; import java.util.Arrays; import java.util.Collection; import java.util.Date; import java.util.Map; import javax.annotation.Resource; import org.activiti.engine.delegate.event.ActivitiEvent; import org.activiti.engine.delegate.event.ActivitiEventType; import org.activiti.engine.delegate.event.impl.ActivitiEntityEventImpl; import org.activiti.engine.delegate.event.impl.ActivitiEventBuilder; import org.activiti.engine.impl.context.Context; import org.activiti.engine.impl.persistence.entity.TaskEntity; import org.apache.commons.lang.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import com.redxun.bpm.activiti.util.ProcessHandleHelper; import com.redxun.bpm.core.entity.BpmDestNode; import com.redxun.bpm.core.entity.BpmNodeJump; import com.redxun.bpm.core.entity.BpmRuPath; import com.redxun.bpm.core.entity.IExecutionCmd; import com.redxun.bpm.core.entity.ProcessStartCmd; import com.redxun.bpm.core.entity.config.BpmEventConfig; import com.redxun.bpm.core.entity.config.UserTaskConfig; import com.redxun.bpm.core.identity.service.BpmIdentityCalService; import com.redxun.bpm.core.identity.service.IdentityTypeService; import com.redxun.bpm.core.manager.BpmInstManager; import com.redxun.bpm.core.manager.BpmNodeJumpManager; import com.redxun.bpm.core.manager.BpmNodeSetManager; import com.redxun.bpm.core.manager.BpmRuPathManager; import com.redxun.bpm.core.manager.BpmTaskManager; import com.redxun.bpm.enums.TaskEventType; import com.redxun.core.script.GroovyEngine; import com.redxun.org.api.model.IdentityInfo; import com.redxun.saweb.context.ContextUtil; /** * 任务创建监听器 * 主要用来执行人员分配,事件执行等 * @author csx * */ public class TaskCreateListener implements EventHandler{ private static Log logger=LogFactory.getLog(TaskCreateListener.class); @Resource private IdentityTypeService identityTypeService; @Resource BpmIdentityCalService bpmIdentityCalService; @Resource BpmNodeSetManager bpmNodeSetManager; @Resource GroovyEngine groovyEngine; @Resource BpmTaskManager bpmTaskManager; @Resource BpmRuPathManager bpmRuPathManager; @Resource BpmInstManager bpmInstManager; @Resource private BpmNodeJumpManager bpmNodeJumpManager; public void executeScript(TaskEntity taskEntity){ String solId=(String) taskEntity.getVariable("solId"); //处理事件 UserTaskConfig userTaskConfig=bpmNodeSetManager.getTaskConfig(solId, taskEntity.getTaskDefinitionKey()); if(userTaskConfig.getEvents().size()>0){ BpmEventConfig bpmEventConfig=null; for(BpmEventConfig eventConfig:userTaskConfig.getEvents()){ if(TaskEventType.TASK_CREATED.name().equals(eventConfig.getEventKey())){ bpmEventConfig=eventConfig; break; } } //执行脚本 if(bpmEventConfig!=null && StringUtils.isNotEmpty(bpmEventConfig.getScript())){ logger.debug("===================execute the script in task create listener:"+bpmEventConfig.getScript()); Map<String,Object> vars=taskEntity.getVariables(); //把任务实体变量放置进来 vars.put("taskEntity", taskEntity); vars.put("taskId", taskEntity.getId()); groovyEngine.executeScripts(bpmEventConfig.getScript(),vars); } } } @Override public void handle(ActivitiEvent event) { ActivitiEntityEventImpl eventImpl=(ActivitiEntityEventImpl)event; TaskEntity taskEntity=(TaskEntity)eventImpl.getEntity(); logger.debug("create task is "+taskEntity.getName()+" key is:"+taskEntity.getTaskDefinitionKey()); logger.debug("enter the task create listener ---->" + event.getType().name()); //执行任务的标题处理 String processSubject=(String)taskEntity.getVariable("processSubject"); String solId=(String)taskEntity.getVariable("solId"); taskEntity.setDescription(processSubject); taskEntity.setSolId(solId); taskEntity.setTenantId(ContextUtil.getCurrentTenantId()); //记录跳转的信息 createNodeJump(taskEntity); //执行事件的处理 executeScript(taskEntity); //是否已经对任务进行了人员分配 boolean isAssigned=false; //检查是否为会签任务,若是,则先从变量中获得执行人员 String multiInstance=(String)taskEntity.getExecution().getActivity().getProperty("multiInstance"); //是否为回退的处理,并且回退的节点不是会签节点,则 BpmRuPath backRuPath=ProcessHandleHelper.getBackPath(); if(backRuPath!=null && StringUtils.isEmpty(multiInstance)){ if("userTask".equals(backRuPath.getNodeType())){ taskEntity.setAssignee(backRuPath.getAssignee()); isAssigned=true; }else{//查找其子结点上的执行人员 BpmRuPath nodePath= bpmRuPathManager.getByParentIdNodeId(backRuPath.getPathId(),taskEntity.getTaskDefinitionKey()); if(nodePath!=null && StringUtils.isNotEmpty(nodePath.getAssignee())){ taskEntity.setAssignee(nodePath.getAssignee()); isAssigned=true; } } } //已经分配,则不从配置数据中获取人员数据 if(isAssigned){ publishAssignEvent(taskEntity); return; } if(StringUtils.isNotEmpty(multiInstance)){ Integer loopCounter=(Integer)taskEntity.getExecution().getVariable("loopCounter"); String signUserIds=(String)taskEntity.getExecution().getVariable("signUserIds_"+taskEntity.getTaskDefinitionKey()); //优先从变量中取 String assignee=getUserIds(signUserIds,loopCounter); if(StringUtils.isNotEmpty(assignee)){ isAssigned=true; taskEntity.setAssignee(assignee); taskEntity.setOwner(assignee); Date expiretime=(Date)taskEntity.getExecution().getVariable("expiretime_"+taskEntity.getTaskDefinitionKey()); Integer priority=(Integer)taskEntity.getExecution().getVariable("priority_"+taskEntity.getTaskDefinitionKey()); taskEntity.setDueDate(expiretime); taskEntity.setPriority(priority); } } //已经分配,则不从配置数据中获取人员数据 if(isAssigned){ publishAssignEvent(taskEntity); return; } //从线程中获得人员列表映射(即从页面中传过来的人员配置) //优先使用页面中的人员配置 IExecutionCmd processNextCmd=ProcessHandleHelper.getProcessCmd(); if(processNextCmd!=null){ BpmDestNode bpmDestNode=processNextCmd.getNodeUserMap().get(taskEntity.getTaskDefinitionKey()); if(bpmDestNode!=null && StringUtils.isNotEmpty(bpmDestNode.getUserIds())){ String[]uIds=bpmDestNode.getUserIds().split(","); isAssigned=true; if(uIds.length==1){ taskEntity.setAssignee(uIds[0]); taskEntity.setOwner(uIds[0]); }else{ taskEntity.addCandidateUsers(Arrays.asList(uIds)); } taskEntity.setPriority(bpmDestNode.getPriority()); taskEntity.setDueDate(bpmDestNode.getExpireTime()); } } //已经分配,则不从配置数据中获取人员数据 if(isAssigned){ publishAssignEvent(taskEntity); return; } //取得人员配置的信息列表 Collection<IdentityInfo> idInfoList=bpmIdentityCalService.calNodeUsersOrGroups(taskEntity.getProcessDefinitionId(), taskEntity.getTaskDefinitionKey(),taskEntity.getVariables()); if(idInfoList.size()==1){ IdentityInfo identityInfo=idInfoList.iterator().next(); if(IdentityInfo.IDENTIFY_TYPE_USER.equals(identityInfo.getIdentityType())){ taskEntity.setAssignee(identityInfo.getIdentityInfoId()); taskEntity.setOwner(identityInfo.getIdentityInfoId()); }else{ taskEntity.addCandidateGroup(identityInfo.getIdentityInfoId()); } isAssigned=true; }else{ if(idInfoList.size()>0){ isAssigned=true; } for(IdentityInfo info:idInfoList){ if(IdentityInfo.IDENTIFY_TYPE_USER.equals(info.getIdentityType())){ taskEntity.addCandidateUser(info.getIdentityInfoId()); }else{ taskEntity.addCandidateGroup(info.getIdentityInfoId()); } } } if(isAssigned){ publishAssignEvent(taskEntity); } } /** * 发布任务分配事件 * @param taskEntity */ public void publishAssignEvent(TaskEntity taskEntity){ if (StringUtils.isNotEmpty(taskEntity.getAssignee())) { Context.getProcessEngineConfiguration().getEventDispatcher().dispatchEvent( ActivitiEventBuilder.createEntityEvent(ActivitiEventType.TASK_ASSIGNED, taskEntity)); } } private String getUserIds(String userIds,Integer index){ String[] uIds=userIds.split("[,]"); if(index<uIds.length){ return uIds[index]; } return null; } private void createNodeJump(TaskEntity taskEntity){ BpmNodeJump nodeJump=new BpmNodeJump(); nodeJump.setActDefId(taskEntity.getProcessDefinitionId()); nodeJump.setActInstId(taskEntity.getProcessInstanceId()); nodeJump.setTaskId(taskEntity.getId()); nodeJump.setCreateTime(taskEntity.getCreateTime()); //获得任务的创建时间 nodeJump.setNodeName(taskEntity.getName()); nodeJump.setNodeId(taskEntity.getTaskDefinitionKey()); nodeJump.setHandlerId(ContextUtil.getCurrentUserId()); IExecutionCmd cmd=ProcessHandleHelper.getProcessCmd(); nodeJump.setCheckStatus(BpmNodeJump.JUMP_TYPE_UNHANDLE); nodeJump.setRemark("无"); if(cmd instanceof ProcessStartCmd){ bpmNodeJumpManager.create(nodeJump); }else{ bpmNodeJumpManager.create(nodeJump); } } }
【说明】
我们通过在监听这个事件,完成了很多activiti没有处理的数据,如创建执行路径,为后续的任务回退进行做准备,进行任务的人员分配处理等。
访问效果如:
http://www.redxun.cn:8020/saweb/login.jsp
相关推荐
5. **事件和信号**:讨论了流程中的事件触发和信号传递,包括边界事件、中间事件和全局信号的使用场景。 6. **服务调用**:介绍了如何集成外部服务,如Web服务或企业应用,以实现流程中的业务逻辑。 7. **用户和组...
监听器配置是工作流开发中的一个重要部分,它允许开发者为特定的事件定义监听器,比如执行监听器、任务监听器、事件监听器和全局事件监听器,这些监听器可以用来触发自定义的行为或逻辑。 在workflow-service部分,...
Activiti提供了丰富的历史数据查询接口,可以获取到每个任务的完成时间、处理人、耗时等信息,便于后期的统计和审计。 在具体实践中,我们还需要考虑异常处理、日志记录、权限控制等细节。例如,通过AOP(面向切面...
7. **事件与信号**:说明如何在流程中使用事件和信号来处理异步通信和流程间的交互,如边界事件、中间事件和全局信号。 8. **表单与用户界面**:讨论如何集成自定义表单和用户界面,以提供友好的流程交互体验。可能...
Activiti引擎内部如何处理信号事件,以及如何触发任务的完成和流程的推进,都可以在源码中找到答案。通过阅读Activiti的相关API和内部实现,开发者可以更好地定制和扩展流程行为。 六、工具支持 Activiti提供了...
同时,利用 Activiti 的事件和监听器机制,可以实现在特定时刻自动处理变量,增强流程的灵活性。 通过以上知识点,我们可以看到流程变量在 Activiti 中的重要作用,它是流程实例中数据流动的桥梁,连接了流程的不同...
- ACT_RU_EVENT_SUBSCR(监听信息表):记录事件订阅信息,用于触发事件。 - ACT_RU_EXECUTION(运行时流程执行实例表):存储运行时流程执行实例的信息。 - ACT_RU_IDENTITYLINK(运行时流程人员表):记录任务节点...
8. **ACT_RU_EVENT_SUBSCR**:事件订阅表,用于记录对流程事件的监听。 9. **ACT_RU_IDENTITYLINK**:身份链接表,关联用户或组与任务或流程实例。 10. **ACT_RU_JOB**:调度作业表,包含定时任务和消息任务的详细...
19. 监听信息表(ACT_RU_EVENT_SUBSCR):记录流程中的事件监听信息。 20. 运行时流程执行实例表(ACT_RU_EXECUTION):存储运行时的流程执行实例信息。 21. 运行时流程人员表(ACT_RU_IDENTITYLINK):主要存储...
2. **部署监听器**: 将监听器部署到Activiti引擎中,可以将监听器配置在流程定义的特定节点上,或者全局应用。 3. **前端交互**: 前端获取流程实例的当前状态,根据状态信息更新图形节点的颜色。这可能涉及到与后端...
手册将详细解释如何使用中断和非中断边界事件、事件子流程以及全局和本地信号。这些功能使得流程能够在不同情况下灵活响应,并与其他系统集成。 在任务处理上,Flowable提供了用户任务、服务任务、脚本任务等多种...
流程全局消息与信号 2. 执行监听器 3. 用户任务节点 任务监听器 4. 表单配置 5. 任务配置 6. 多实例任务 7. 流转条件 4. 内置常用 `camunda` ,`flowable`,`activiti` 解析文件 5. 自定义左侧元素栏 `platte...
- ReceiveTask用于等待外部事件触发,常用于并行处理或同步场景。 12. **设置任务处理人** - 设置任务处理人的方式多样,可以指定用户、通过变量、监听器或其他方式实现。 13. **任务认领与回退** - 认领任务是...
│ 11-附录1.JS中局部变量和全局变量区别 │ d( L, Z2 p" ] ├─众筹项目-第05天《Atcrowdfunding》) A% ]3 K. N. T& e) [7 J │ ├─代码 │ ├─笔记 │ └─视频2 @8 e5 L% ~) b6 _) f. H: i │ 1-用户管理模块-...
用户可以通过拖拽节点、连接线来构建流程,这涉及到SVG渲染和事件处理。 6. **BPMN 2.0标准**:BPMVue可能遵循BPMN(Business Process Model and Notation)2.0标准,这是一种国际通用的业务流程建模语言。理解BPMN...