Activiti 6研究01 - 流程文件的手动导入

在某些场景下，需要进行流程定义文件的手动导入，此处分享一下我的大致流程及踩过的坑，希望对大家有所帮助。

1. 读入文件（此处以上传文件为例）

            InputStream fileInputStream = file.getInputStream();
            XMLInputFactory xif = XMLInputFactory.newInstance();
            InputStreamReader in = new InputStreamReader(fileInputStream, "UTF-8");
            XMLStreamReader xtr = xif.createXMLStreamReader(in);

2. 通过BpmnXMLConverter将xml内容转换为BpmnModel对象

            // 转为bpmnModel
            BpmnModel bpmnModel = new BpmnXMLConverter().convertToBpmnModel(xtr);

3. 建立Model，通过BpmnJsonConverter将BpmnXML对象转成Json对象并保存入仓库（若不需要建立Model，此步可跳过）

            Model model = createNewModel();
            ObjectNode objectNode = new BpmnJsonConverter().convertToJson(bpmnModel);
            repositoryService.addModelEditorSource(model.getId(), objectNode.toString().getBytes("utf-8"));

    /**
     * 创建新的模型
     *
     * @return
     */
    private Model createNewModel() {
        Model model = repositoryService.newModel();
        String modelKey = String.valueOf(CommonFunc.genID());
        ObjectNode modelNode = objectMapper.createObjectNode();
        modelNode.put(ModelDataJsonConstants.MODEL_NAME, modelKey);
        modelNode.put(ModelDataJsonConstants.MODEL_REVISION, 1);
        model.setName(modelKey);
        model.setKey(modelKey);
        model.setMetaInfo(modelNode.toString());
        repositoryService.saveModel(model);

        return model;
    }

4. 将BpmnModel发布。
   此处需特别注意：如果希望记录下原始文件名，切记以.bpmn20.xml为后缀，否则发布不成功（数据库中会发现act_re_deployment表中已有数据，对应的act_ge_bytearray表中，xml文件记录也已插入，但是act_re_procdef表中却没有数据。关键是还没有异常）。

            String srcFileName = file.getOriginalFilename();
            // 此处保存上传文件的原始文件名，但必须是以.bpmn20.xml结尾，否则无法产生流程数据且不报错。
            if (!srcFileName.endsWith(".bpmn20.xml"))
                srcFileName += ".bpmn20.xml";
            Deployment deployment = repositoryService.createDeployment()
                    .name(String.valueOf(userID))	// deployment名称，此处用于保存导入用户ID
                    .addBpmnModel(srcFileName, bpmnModel)
                    .enableDuplicateFiltering()
                    .deploy();

5. 若做了第3步，建议将DeploymentID与Model关联保存起来

            model = repositoryService.getModel(model.getId());
            model.setDeploymentId(deployment.getId());
            repositoryService.saveModel(model);

附导入流程文件完整代码段：

    @PostMapping("/ImportProcess")
    public void ImportProcess(@RequestAttribute("UserID") long userID, MultipartFile file) {
        if (file == null) {
            logger.error("No file upload.");
            throw new GlobalRuntimeException(ErrorInfo.NO_FILE_UPLOAD);
        }

        try {
            InputStream fileInputStream = file.getInputStream();
            XMLInputFactory xif = XMLInputFactory.newInstance();
            InputStreamReader in = new InputStreamReader(fileInputStream, "UTF-8");
            XMLStreamReader xtr = xif.createXMLStreamReader(in);
            // 转为bpmnModel
            BpmnModel bpmnModel = new BpmnXMLConverter().convertToBpmnModel(xtr);

            Model model = createNewModel();
            ObjectNode objectNode = new BpmnJsonConverter().convertToJson(bpmnModel);
            repositoryService.addModelEditorSource(model.getId(), objectNode.toString().getBytes("utf-8"));

            String srcFileName = file.getOriginalFilename();
            // 此处保存上传文件的原始文件名，但必须是以.bpmn20.xml结尾，否则无法产生流程数据且不报错。
            if (!srcFileName.endsWith(".bpmn20.xml"))
                srcFileName += ".bpmn20.xml";
            Deployment deployment = repositoryService.createDeployment()
                    .name(String.valueOf(userID))           // deployment名称，此处用于保存导入用户ID
                    .addBpmnModel(srcFileName, bpmnModel)
                    .enableDuplicateFiltering()
                    .deploy();

            model = repositoryService.getModel(model.getId());
            model.setDeploymentId(deployment.getId());
            repositoryService.saveModel(model);

            ProcessDefinition define = repositoryService.createProcessDefinitionQuery()
                    .deploymentId(deployment.getId())
                    .singleResult();
            logger.debug("Import process: {} - {}, deploy id: {}", define.getId(), define.getKey(), define.getDeploymentId());
        } catch (Exception ex) {
            logger.error("Import process has exception.\n", ex);
            throw new GlobalRuntimeException(ErrorInfo.IMPORT_PROCESS);
        }
    }