activiti6 查看流程图
activiti6 查看流程图 根据processInstanceId查询
大家大概看一眼吧 我就记录一下 勿喷！
Controller
@GetMapping("/getFlow")
@ApiOperation(value = "流程图", httpMethod = "GET", notes = "流程图")
public void getFlow(String processInstanceId, HttpServletResponse response) {
ProcessinstanceService.getActiviti(processInstanceId, response);
}
Service
public void getActiviti(String processInstanceId, HttpServletResponse response) {
response.setHeader("Pragma", "No-cache");
response.setHeader("Cache-Control", "no-cache");
response.setDateHeader("Expires", 0);
JbpmProcessinstanceService.log.info("[开始]-获取流程图像");
InputStream imageStream = null;
try {
//获取历史流程实例
HistoricProcessInstance historicProcessInstance = historyService.createHistoricProcessInstanceQuery()
.processInstanceId(processInstanceId).singleResult();
if (historicProcessInstance == null) {
imageStream = Thread.currentThread().getContextClassLoader().getResourceAsStream("noimage.png");
response.setContentType("image/png");
OutputStream os = response.getOutputStream();
int bytesRead = 0;
byte[] buffer = new byte[8192];
while ((bytesRead = imageStream.read(buffer, 0, 8192)) != -1) {
os.write(buffer, 0, bytesRead);
}
os.close();
imageStream.close();
} else {
JbpmProcessinstanceService.log.info("获取流程实例ID[" + processInstanceId + "]对应的历史流程实例");
//获取流程定义
ProcessDefinitionEntity processDefinitionEntity = (ProcessDefinitionEntity) ((RepositoryServiceImpl) repositoryService)
.getDeployedProcessDefinition(historicProcessInstance.getProcessDefinitionId());
// 获取流程历史中已执行节点，并按照节点在流程中执行先后顺序排序
List<HistoricActivityInstance> historicActivityInstanceAllList = historyService.createHistoricActivityInstanceQuery()
.processInstanceId(processInstanceId).orderByHistoricActivityInstanceId().asc().list();
// 已执行的节点ID集合
List<String> executedActivityIdList = new ArrayList<String>();
//驳回后已执行节点集合
List<String> rejectExecutedActivityIdList = new ArrayList<String>();
int index = 1;
//logger.info("获取已经执行的节点ID");
List<HistoricActivityInstance> historicActivityInstanceList = new ArrayList<>();
for (int i = 0; i < historicActivityInstanceAllList.size(); i++) {
//如果是调整节点，则只显示调整后执行的节点
if ("adjust".equals(historicActivityInstanceAllList.get(i).getActivityId())) {
for (int j = i; j < historicActivityInstanceAllList.size(); j++) {
rejectExecutedActivityIdList.add(historicActivityInstanceAllList.get(j).getActivityId());
historicActivityInstanceList.add(historicActivityInstanceAllList.get(j));
}
} else {
executedActivityIdList.add(historicActivityInstanceAllList.get(i).getActivityId());
}
JbpmProcessinstanceService.log.info("第[" + index + "]个已执行节点=" + historicActivityInstanceAllList.get(i).getActivityId() + " : " + historicActivityInstanceAllList.get(i).getActivityName());
index++;
}
BpmnModel bpmnModel = repositoryService.getBpmnModel(historicProcessInstance.getProcessDefinitionId());
//最终使用的集合
List<HistoricActivityInstance> resultHistoricActivityInstanceList = null;
List<String> resultExecutedActivityIdList = null;
if (rejectExecutedActivityIdList != null && rejectExecutedActivityIdList.size() > 0) {
resultHistoricActivityInstanceList = historicActivityInstanceList;
resultExecutedActivityIdList = rejectExecutedActivityIdList;
} else {
resultHistoricActivityInstanceList = historicActivityInstanceAllList;
resultExecutedActivityIdList = executedActivityIdList;
}
// 已执行的线集合
List<String> flowIds = getHighLightedFlows(bpmnModel, processDefinitionEntity, resultHistoricActivityInstanceList);
// 获取流程图图像字符流
ProcessDiagramGenerator pec = processEngine.getProcessEngineConfiguration().getProcessDiagramGenerator();
//配置字体
imageStream = pec.generateDiagram(bpmnModel, "png", resultExecutedActivityIdList, flowIds, "宋体", "宋体", "宋体", null, 2.0);
response.setContentType("image/png");
OutputStream os = response.getOutputStream();
int bytesRead = 0;
byte[] buffer = new byte[8192];
while ((bytesRead = imageStream.read(buffer, 0, 8192)) != -1) {
os.write(buffer, 0, bytesRead);
}
os.close();
imageStream.close();
}
JbpmProcessinstanceService.log.info("[完成]-获取流程图图像");
} catch (Exception e) {
e.printStackTrace();
} finally {
if (imageStream != null) {
try {
imageStream.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
/**
* @return java.util.List<java.lang.String>
* @Desc 高亮显示
* @Param [bpmnModel, processDefinitionEntity, historicActivityInstances]
* @Date
* @Author ler.mu
**/
public List<String> getHighLightedFlows(BpmnModel bpmnModel, ProcessDefinitionEntity processDefinitionEntity, List<HistoricActivityInstance> historicActivityInstances) {
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); //24小时制
List<String> highFlows = new ArrayList<String>();// 用以保存高亮的线flowId
for (int i = 0; i < historicActivityInstances.size() - 1; i++) {
// 对历史流程节点进行遍历
// 得到节点定义的详细信息
FlowNode activityImpl = (FlowNode) bpmnModel.getMainProcess().getFlowElement(historicActivityInstances.get(i).getActivityId());
List<FlowNode> sameStartTimeNodes = new ArrayList<FlowNode>();// 用以保存后续开始时间相同的节点
FlowNode sameActivityImpl1 = null;
HistoricActivityInstance activityImpl_ = historicActivityInstances.get(i);// 第一个节点
HistoricActivityInstance activityImp2_;
for (int k = i + 1; k <= historicActivityInstances.size() - 1; k++) {
activityImp2_ = historicActivityInstances.get(k);// 后续第1个节点
if ("userTask".equals(activityImpl_.getActivityType()) && "userTask".equals(activityImp2_.getActivityType()) &&
df.format(activityImpl_.getStartTime()).equals(df.format(activityImp2_.getStartTime()))) //都是usertask，且主节点与后续节点的开始时间相同，说明不是真实的后继节点
{
} else {
sameActivityImpl1 = (FlowNode) bpmnModel.getMainProcess().getFlowElement(historicActivityInstances.get(k).getActivityId());//找到紧跟在后面的一个节点
break;
}
}
sameStartTimeNodes.add(sameActivityImpl1); // 将后面第一个节点放在时间相同节点的集合里
for (int j = i + 1; j < historicActivityInstances.size() - 1; j++) {
HistoricActivityInstance activityImpl1 = historicActivityInstances.get(j);// 后续第一个节点
HistoricActivityInstance activityImpl2 = historicActivityInstances.get(j + 1);// 后续第二个节点
if (df.format(activityImpl1.getStartTime()).equals(df.format(activityImpl2.getStartTime()))) {// 如果第一个节点和第二个节点开始时间相同保存
FlowNode sameActivityImpl2 = (FlowNode) bpmnModel.getMainProcess().getFlowElement(activityImpl2.getActivityId());
sameStartTimeNodes.add(sameActivityImpl2);
} else {// 有不相同跳出循环
break;
}
}
List<SequenceFlow> pvmTransitions = activityImpl.getOutgoingFlows(); // 取出节点的所有出去的线
for (SequenceFlow pvmTransition : pvmTransitions) {// 对所有的线进行遍历
FlowNode pvmActivityImpl = (FlowNode) bpmnModel.getMainProcess().getFlowElement(pvmTransition.getTargetRef());// 如果取出的线的目标节点存在时间相同的节点里，保存该线的id，进行高亮显示
if (sameStartTimeNodes.contains(pvmActivityImpl)) {
highFlows.add(pvmTransition.getId());
}
}
}
return highFlows;
}