應(yīng)用Activiti流程跟蹤監(jiān)控圖路徑線和節(jié)點(diǎn)高亮顯示

[應(yīng)用]Activiti流程跟蹤監(jiān)控圖路徑線和節(jié)點(diǎn)高亮顯示流程圖高亮顯示繼承的方式擴(kuò)展它的畫圖類。閑話少說我們切入正題。由于這是公司完整項(xiàng)目上的一個(gè)小模塊，而最近公司不再做進(jìn)一步的開發(fā)，只希望對(duì)大家有所協(xié)助。。。1，先曬一下，我做出來的效果。2，詳細(xì)實(shí)現(xiàn)步驟:,Action/**經(jīng)過指定的流程實(shí)例id生成流程監(jiān)控圖*@parammapping@paramform@paramrequest@paramresponse@return*/publicActionForwardinstanceDiagram(ActionMappingmapping,ActionFormform,HttpServletRequestrequest,HttpServletResponseresponse){/**ID*/StringinstanceId=StringUtils.trimToEmpty(request.getParameter("instanceId"));//設(shè)置頁面不緩存response.setHeader("Pragma","No-cache");response.setHeader("Cache-Control","no-cache");response.setDateHeader("Expires",0);try{HistoricProcessInstancehistoricProcessInstance=historyService.createHistoricProcessInstanceQuery().processInstanceId(instanceId).singleResult();if(historicProcessInstance==null){thrownewRuntimeException("取得流程圖異樣!");}else{BpmnModelbpmnModel=repositoryService.getBpmnModel(historicProcessInstance.getProcessDefinitionId());List<HistoricActivityInstance>activityInstances=historyService.createHistoricActivityInstanceQuery().processInstanceId(instanceId).orderByHistoricActivityInstanceId().asc()取得流程走過的節(jié)點(diǎn)，并依據(jù)節(jié)點(diǎn)生成先后挨次排序List<String>activitiIds=newArrayList<String>();List<String>flowIds=newArrayList<String>();List<String>currentFlowIds=newArrayList<String>();ProcessDefinitionEntityprocessDefinition=(ProcessDefinitionEntity)((RepositoryServiceImpl)repositoryService).getDeployedProcessDefinition(historicProcessInstance.getProcessDefinitionId());flowIds=flowMoniService.getHighLightedFlows(processDefinition,activityInstances);currentFlowIds=flowMoniService.getCurrentHighLightedFlows(processDefinition,activityInstances);for(HistoricActivityInstancehai:activityInstances){activitiIds.add(hai.getActivityId());}List<Map<String,Boolean>>highLightedActivities=flowMoniService.getHighLightedActivities(processDefinition,activityInstances);ProcessEngineImpldefaultProcessEngine=(ProcessEngineImpl)ProcessEngines.getDefaultProcessEngine();Context.setProcessEngineConfiguration(defaultProcessEngine.getProcessEngineConfiguration());Context.setProcessEngineConfiguration(processEngineFactoryBean.getProcessEngineConfiguration());InputStreamimageStream=BlazerProcessDiagramGenerator.generateDiagram2(bpmnModel,"png",highLightedActivities,flowIds,currentFlowIds);response.setContentType("image/png");OutputStreamos=response.getOutputStream();intbytesRead=0;byte[]buffer=newbyte[8192];while((bytesRead=imageStream.read(buffer,0,8192))!=-1){os.write(buffer,0,bytesRead);}os.close();imageStream.close();}}catch(Exceptione){logger.error("e);thrownewRuntimeException("取得流程圖異樣!");}returnnull;},Serviceid繼續(xù)加強(qiáng))@OverridepublicList<String>getHighLightedFlows(ProcessDefinitionEntityprocessDefinitionEntity,List<HistoricActivityInstance>historicActivityInstances){List<String>highFlowsnewArrayList<String>();//flowIdfor(inti=0;i<historicActivityInstances.size()1;i++){//ActivityImplactivityImpl=processDefinitionEntity.findActivity(historicActivityInstances.get(i).getActivityId());//信息List<ActivityImpl>sameStartTimeNodes=newArrayList<ActivityImpl>();//ActivityImplsameActivityImpl1=processDefinitionEntity.findActivity(historicActivityInstances.get(i+1).getActivityId());//將后面第一個(gè)節(jié)點(diǎn)放在時(shí)間相同節(jié)點(diǎn)的集合里sameStartTimeNodes.add(sameActivityImpl1);for(intj=i+1;j<historicActivityInstances.size()-1;j++){HistoricActivityInstanceactivityImpl1=historicActivityInstances.get(j);//后續(xù)第一個(gè)節(jié)點(diǎn)HistoricActivityInstanceactivityImpl2=historicActivityInstances.get(j+1);//后續(xù)第二個(gè)節(jié)點(diǎn)if(activityImpl1.getStartTime().equals(activityImpl2.getStartTime())){//一個(gè)節(jié)點(diǎn)和第二個(gè)節(jié)點(diǎn)開頭時(shí)間相同保存ActivityImplsameActivityImpl2=processDefinitionEntity.findActivity(activityImpl2.getActivityId());sameStartTimeNodes.add(sameActivityImpl2);else{//break;}}List<PvmTransition>pvmTransitions=activityImpl.getOutgoingTransitions();//去的線for(PvmTransitionpvmTransitionpvmTransitions){//行遍歷ActivityImplpvmActivityImpl=(ActivityImpl)pvmTransition.getDestination();//假若取出的線的目標(biāo)節(jié)點(diǎn)進(jìn)行高亮顯示if(sameStartTimeNodes.contains(pvmActivityImpl)){highFlows.add(pvmTransition.getId());}}}returnhighFlows;}@OverridepublicList<Map<String,Boolean>>getHighLightedActivities(ProcessDefinitionEntityprocessDefinition,List<HistoricActivityInstance>historicActivityInstances){List<Map<String,Boolean>>highLightedActivities=newArrayList<Map<String,Boolean>>();intactivityCount=historicActivityInstances.size();Map<String,Boolean>activityMap=newHashMap<String,Boolean>();activityMap.put(historicActivityInstances.get(historicActivityInstances.size()-1).getActivityId(),true);highLightedActivities.add(activityMap);booleanfindCurrActivity=true;//是否查詢并發(fā)任務(wù)節(jié)點(diǎn)for(intjactivityCount2;j0;j--){//推斷前面節(jié)點(diǎn)是否與Map<String,Boolean>activityMap2=newHashMap<String,Boolean>();HistoricActivityInstanceactivityImpl1=historicActivityInstances.get(j);//if(findCurrActivity){HistoricActivityInstanceactivityImpl2=historicActivityInstances.get(j+1);//當(dāng)前節(jié)點(diǎn)if(activityImpl1.getStartTime().equals(activityImpl2.getStartTime())){Stringtype=activityImpl1.getActivityType();//排除系統(tǒng)自動(dòng)執(zhí)行節(jié)點(diǎn)if("userTask".equals(type)||"endEvent".equals(type)){activityMap2.put(activityImpl1.getActivityId(),false);}else{activityMap2.put(activityImpl1.getActivityId(),false);}}else{activityMap2.put(activityImpl1.getActivityId(),false);findCurrActivity=false;}highLightedActivities.add(activityMap2);}else{activityMap2.put(activityImpl1.getAct