Flowable增加流程转模型功能

1条回答

2019-07-03 12:40

	@Override
	public FlowModel convertToModel(String processId) throws UnsupportedEncodingException, XMLStreamException {
		ProcessDefinition processDefinition  = repositoryService.createProcessDefinitionQuery().processDefinitionId(processId).singleResult();
		InputStream bpmnStream = repositoryService.getResourceAsStream(processDefinition.getDeploymentId(),
				     processDefinition.getResourceName());
		XMLInputFactory xif = XMLInputFactory.newInstance();
		InputStreamReader in = new InputStreamReader(bpmnStream, "UTF-8");
		XMLStreamReader xtr = xif.createXMLStreamReader(in);
		BpmnModel bpmnModel = new BpmnXMLConverter().convertToBpmnModel(xtr);
		BpmnJsonConverter converter = new BpmnJsonConverter();
		ObjectNode modelNode = converter.convertToJson(bpmnModel);
		FlowModel modelData = new FlowModel();
		modelData.setModelKey(processDefinition.getKey());
		modelData.setName(processDefinition.getName());
		modelData.setVersion(Integer.parseInt(String.valueOf(repositoryService.createModelQuery().modelKey(processId).count()+1)));
		modelData.setModelType(1);
		modelData.setCreated(org.flowable.dmn.engine.impl.el.util.DateUtil.now());
		modelData.setLastUpdated(org.flowable.dmn.engine.impl.el.util.DateUtil.now());
		modelData.setCreatedBy("admin");
		modelData.setLastUpdatedBy("admin");
		modelData.setModelEditorJson(modelNode.toString());
		modelData.setTenantId("0000"); 
		modelData.setThumbnail(modelNode.toString().getBytes("utf-8"));
		modelData.setId(UUID.randomUUID().toString());
		save(modelData);
		return modelData;
	}

按上述代码实现模型转换，仅供参考。