快捷導(dǎo)航

Springboot整合Flowable6.x導(dǎo)出bpmn20的步驟詳解

更新時間：2023年04月19日 08:30:13 作者：soft1314

這篇文章主要介紹了Springboot整合Flowable6.x導(dǎo)出bpmn20,Flowable流程引擎可用于部署B(yǎng)PMN 2.0流程定義，可以十分靈活地加入你的應(yīng)用/服務(wù)/構(gòu)架，本文給出兩種從flowable導(dǎo)出流程定義bpmn20.xml的方式，需要的朋友可以參考下

BPMN2.0（Business Process Model and Notation）是一套業(yè)務(wù)流程模型與符號建模標準，以XML為載體，以符號可視化業(yè)務(wù)，支持精準的執(zhí)行語義來描述元素的操作。
Flowable誕生于Activiti，是一個使用Java編寫的輕量級業(yè)務(wù)流程引擎。Flowable流程引擎可用于部署B(yǎng)PMN 2.0流程定義，可以十分靈活地加入你的應(yīng)用/服務(wù)/構(gòu)架。

本文給出兩種從flowable導(dǎo)出流程定義bpmn20.xml的方式。

導(dǎo)入Maven依賴

        <dependency>
            <groupId>org.flowable</groupId>
            <artifactId>flowable-spring-boot-starter-basic</artifactId>
            <version>6.4.1</version>
        </dependency>
        <dependency>
            <groupId>org.flowable</groupId>
            <artifactId>flowable-json-converter</artifactId>
            <version>6.4.1</version>
        </dependency>

從流程模型導(dǎo)出流程定義bpmn20.xml

通過流程編輯器制作的流程模型（如下圖所示），可以通過模型ID（Model.id），調(diào)用flowable 的 RepositoryService 來生成bpmn20.xml。

@Service
public class MyModelServiceImpl implements MyModelService {
    @Autowired
    private RepositoryService repositoryService;

    /**
     * 通過模型ID，生成模型BPMN20.xml
     * @param guid 模型id,即model.id
     * @return
     * @throws Exception
     */
    @Override
    public ResultDTO genXml(String guid) throws Exception {
        /**通過ID獲取模型 **/
        Model modelData = repositoryService.getModel(guid);
        byte[] bytes = repositoryService.getModelEditorSource(modelData.getId());
        if (bytes == null) {
            return ResultDTO.failureCustom("模型數(shù)據(jù)為空，請先設(shè)計流程并成功保存，再進行發(fā)布。");
        }
        JsonNode modelNode = new ObjectMapper().readTree(bytes);
        BpmnModel model = new BpmnJsonConverter().convertToBpmnModel(modelNode);
        if (model.getProcesses().size() == 0) {
            return ResultDTO.failureCustom("數(shù)據(jù)模型不符要求，請至少設(shè)計一條主線流程。");
        }
        /** 設(shè)置名稱 **/
        model.getMainProcess().setName(modelData.getName());
        /** 設(shè)置 targetNamespace **/
        if(StringUtils.isNotBlank(modelData.getCategory())) {
            model.setTargetNamespace(modelData.getCategory());
        }
        byte[] bpmnBytes = new BpmnXMLConverter().convertToXML(model);
        String xml = new String(bpmnBytes, "UTF-8");
        return ResultDTO.success(xml);
    }
}

運行效果如下：

{% asset_img res1.gif 導(dǎo)出效果 %}

從流程定義導(dǎo)出流程定義bpmn20.xml

對于flowable已經(jīng)部署的流程，可根據(jù)流程定義（ProcessDefinition.id），調(diào)用flowable 的RepositoryService來導(dǎo)出其bpmn20.xml。

@RestController
@Slf4j
public class ProcessController {
    @Autowired
    private MyProcessService processService;
    
    /**
     * 通過processDefinition.id和resType導(dǎo)出流程XML或圖片資源
     * @param id processDefinition.id
     * @param resType 取值 “image/png”或“text/xml”
     * @param response
     * @throws Exception
     */
    @GetMapping(value = "/res/exp")
    @ApiOperation("通過processDefinition.id和resType導(dǎo)出流程XML或圖片資源")
    public void resourceRead(@RequestParam("id") String id,@RequestParam("resType") String resType, HttpServletResponse response) throws Exception {
        /** resType取值 “image/png”或“text/xml” **/
        InputStream resourceAsStream = processService.resourceRead(id,resType);
        byte[] b = new byte[1024];
        int len = -1;
        while ((len = resourceAsStream.read(b, 0, 1024)) != -1) {
            response.getOutputStream().write(b, 0, len);
        }
    }
}

@Service
public class MyProcessServiceImpl implements MyProcessService {
    @Autowired
    private RepositoryService repositoryService;
    
    @Override
    public InputStream resourceRead(String id, String resType) throws Exception {
        ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().processDefinitionId(id).singleResult();
        String resourceName = "";
        if (resType.equals("image/png")) {
            resourceName = processDefinition.getDiagramResourceName();
        } else if (resType.equals("text/xml")) {
            resourceName = processDefinition.getResourceName();
        }
        InputStream resourceAsStream = repositoryService.getResourceAsStream(processDefinition.getDeploymentId(), resourceName);
        return resourceAsStream;
    }
}

運行效果如下：