SpringBoot集成Activiti之在線設(shè)計(jì)器

流程設(shè)計(jì)是工作流的入口，開發(fā)者可以通過eclipse插件等來設(shè)計(jì)流程，但是用戶并不會(huì)使用。所以可以在線設(shè)計(jì)的流程才是我們想要的，幸好activiti提供了在線設(shè)計(jì)功能，我們只需要把它集成到我們項(xiàng)目中就行了。

最終效果

image.png

集成Actviti

添加依賴

pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.1.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.walle</groupId>
    <artifactId>activity-service</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>activity-service</name>
    <description>Demo project for Spring Boot</description>

    <properties>
        <java.version>1.8</java.version>
        <spring-boot-admin.version>2.1.1</spring-boot-admin.version>
        <spring-cloud.version>Greenwich.RC2</spring-cloud.version>
        <activiti.version>5.22.0</activiti.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>1.3.2</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-sleuth</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-zipkin</artifactId>
        </dependency>

        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <scope>runtime</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
            <version>1.1.10</version>
        </dependency>
        <!-- Activiti 啟動(dòng)器 -->
        <dependency>
            <groupId>org.activiti</groupId>
            <artifactId>activiti-spring-boot-starter-basic</artifactId>
            <version>${activiti.version}</version>
        </dependency>
        <!-- Activiti 流程圖 -->
        <dependency>
            <groupId>org.activiti</groupId>
            <artifactId>activiti-diagram-rest</artifactId>
            <version>${activiti.version}</version>
        </dependency>
        <!-- Activiti 在線設(shè)計(jì) -->
        <dependency>
            <groupId>org.activiti</groupId>
            <artifactId>activiti-modeler</artifactId>
            <version>${activiti.version}</version>
        </dependency>
        <dependency>
            <groupId>com.ctrip.framework.apollo</groupId>
            <artifactId>apollo-client</artifactId>
            <version>1.2.0</version>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>com.walle</groupId>
            <artifactId>common-service</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <!-- swagger2 -->
        <dependency>
            <groupId>io.springfox</groupId>
            <artifactId>springfox-swagger2</artifactId>
            <version>2.8.0</version>
        </dependency>
        <dependency>
            <groupId>io.springfox</groupId>
            <artifactId>springfox-swagger-ui</artifactId>
            <version>2.8.0</version>
        </dependency>
    </dependencies>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
            <dependency>
                <groupId>de.codecentric</groupId>
                <artifactId>spring-boot-admin-dependencies</artifactId>
                <version>${spring-boot-admin.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

    <repositories>
        <repository>
            <id>spring-milestones</id>
            <name>Spring Milestones</name>
            <url>https://repo.spring.io/milestone</url>
        </repository>
    </repositories>

</project>

下載Activiti源碼包

下載地址：https://www.activiti.org/get-started

解壓下載的源碼包后我們看到目錄結(jié)構(gòu)如下

1547090999141.png

創(chuàng)建數(shù)據(jù)庫

在activiti-5.22.0/database/create 文件夾中找到對(duì)應(yīng)數(shù)據(jù)庫的sql文件 然后創(chuàng)建相關(guān)數(shù)據(jù)庫。數(shù)據(jù)庫表說明

另外，為了方便管理模型，我們才創(chuàng)建業(yè)務(wù)表來管理模型SQL如下

CREATE TABLE `ts_business_define` (
  `business_id` int(11) NOT NULL AUTO_INCREMENT COMMENT '主鍵',
  `business_code` varchar(100) DEFAULT NULL COMMENT '業(yè)務(wù)代碼',
  `business_name` varchar(255) DEFAULT NULL COMMENT '業(yè)務(wù)名稱',
  `proc_def_id` varchar(64) DEFAULT NULL COMMENT '流程定義ID',
  `model_id` varchar(64) DEFAULT NULL COMMENT '模型ID',
  `delete_status` int(11) DEFAULT '0' COMMENT '刪除標(biāo)記0=正常1=已刪除',
  `create_by` bigint(20) DEFAULT '0' COMMENT '創(chuàng)建人',
  `create_byname` varchar(50) DEFAULT '0' COMMENT '創(chuàng)建人姓名',
  `create_time` datetime DEFAULT NULL COMMENT '創(chuàng)建時(shí)間',
  `modify_by` bigint(20) DEFAULT NULL COMMENT '修改人',
  `modify_byname` varchar(50) DEFAULT NULL COMMENT '修改人姓名',
  `modify_time` datetime DEFAULT NULL COMMENT '修改時(shí)間',
  PRIMARY KEY (`business_id`)
) ENGINE=InnoDB AUTO_INCREMENT=0 DEFAULT CHARSET=utf8mb4;

導(dǎo)入靜態(tài)文件

將activiti-5.22.0/war/activiti-explorer.war解壓

1547097974975.png

將文件夾內(nèi) diagram-viewer,editor-app,modeler.html拷貝到項(xiàng)目中resource/public目錄下如圖

1547098070832.png

這里需要修改editor-app/app-cfg.js 來設(shè)置項(xiàng)目跟路徑 我們?cè)O(shè)置為空就可以

ACTIVITI.CONFIG = {
    // 'contextRoot' : '/activiti-explorer/service',
    'contextRoot' : '',
};

導(dǎo)入模型相關(guān)操作Controller

解壓activiti-5.22.0\libs\activiti-modeler-5.22.0-sources.jar，將StencilsetRestResource.java，

ModelEditorJsonRestResource.java，ModelSaveRestResource.java三個(gè)文件拷貝到controller目錄

下載漢化文件

漢化文件，下載文件并放在resource目錄下

禁用登錄驗(yàn)證

Activiti中自動(dòng)集成了security的權(quán)限驗(yàn)證，當(dāng)我們?cè)L問接口的時(shí)候會(huì)彈出登錄界面，所以我們需要禁用掉登錄驗(yàn)證

在啟動(dòng)類中添加注解

@SpringBootApplication
@EnableAutoConfiguration(exclude = {
        org.activiti.spring.boot.SecurityAutoConfiguration.class,               org.springframework.boot.autoconfigure.security.servlet.SecurityAutoConfiguration.class
})
public class ActivityServiceApplication {

    public static void main(String[] args) {
        SpringApplication.run(ActivityServiceApplication.class, args);
    }

}

創(chuàng)建模型

到此為止，我們的集成工作就基本完成了，我們可以通過瀏覽器訪問http://localhost:8080/model/create

就可以新建一個(gè)模型了如圖

1547100441136.png

模型管理

通過以上集成我們可以創(chuàng)建一個(gè)新的模型，然后我們會(huì)獲取到一個(gè)模型ID 然后根據(jù)ID我們可以部署流程之類，現(xiàn)在我們通過一些簡單的改造，來實(shí)現(xiàn)頁面上對(duì)模型的操作和部署，并且和我們的業(yè)務(wù)關(guān)聯(lián)起來。

業(yè)務(wù)關(guān)聯(lián)模型

我們可以看到，模型管理界面的地址是http://localhost:8080/modeler.html?modelId=120005，這里需要一個(gè)模型ID的參數(shù)，我們可以把模型ID和業(yè)務(wù)定義關(guān)聯(lián)起來，代碼如下

    @Autowired
    private RepositoryService repositoryService;

    @Autowired
    private BusinessDefineService businessDefineService;

    @PostMapping("getModelId")
    public ResultResponse getModel(Long businessId, HttpServletRequest request, HttpServletResponse response) {
        try {
            BusinessDefine businessDefine = businessDefineService.getById(businessId);
            String modelId = businessDefine.getModelId();
            if (StringUtils.isBlank(modelId)) {
                modelId = createModel(businessId);
            }
            return ResultResponse.ofSuccess(modelId);
        } catch (Exception e) {
            log.error("",e);
            return ResultResponse.ofError(e.getMessage());
        }
    }

    public String createModel(Long businessId) {
        try {
            String modelName = "modelName";
            String modelKey = "modelKey";
            String description = "description";

            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();

            RepositoryService repositoryService = processEngine.getRepositoryService();

            ObjectMapper objectMapper = new ObjectMapper();
            ObjectNode editorNode = objectMapper.createObjectNode();
            editorNode.put("id", "canvas");
            editorNode.put("resourceId", "canvas");
            ObjectNode stencilSetNode = objectMapper.createObjectNode();
            stencilSetNode.put("namespace", "http://b3mn.org/stencilset/bpmn2.0#");
            editorNode.put("stencilset", stencilSetNode);
            Model modelData = repositoryService.newModel();

            ObjectNode modelObjectNode = objectMapper.createObjectNode();
            modelObjectNode.put(ModelDataJsonConstants.MODEL_NAME, modelName);
            modelObjectNode.put(ModelDataJsonConstants.MODEL_REVISION, 1);
            modelObjectNode.put(ModelDataJsonConstants.MODEL_DESCRIPTION, description);
            modelData.setMetaInfo(modelObjectNode.toString());
            modelData.setName(modelName);
            modelData.setKey(modelKey);

            //保存模型
            repositoryService.saveModel(modelData);
            repositoryService.addModelEditorSource(modelData.getId(), editorNode.toString().getBytes("utf-8"));

            BusinessDefine businessDefine = businessDefineService.getById(businessId);
            businessDefine.setModelId(modelData.getId());
            businessDefineService.update(businessDefine);
            return modelData.getId();
        } catch (Exception e) {
            return null;
        }
    }

這里我們進(jìn)行了一下判斷，業(yè)務(wù)是否關(guān)聯(lián)了模型，如果關(guān)聯(lián)返回模型ID 如果沒關(guān)聯(lián)，創(chuàng)建一個(gè)新的模型并返回Id并關(guān)聯(lián)業(yè)務(wù)

部署模型

通過業(yè)務(wù)定義獲取模型，然后部署模型

/**
     * 根據(jù)Model部署流程
     */
    @PostMapping(value = "deploy")
    public ResultResponse deploy(Long businessId) {
        try {

            BusinessDefine businessDefine = businessDefineService.getById(businessId);
            if (StringUtils.isBlank(businessDefine.getModelId())) {
                throw new SystemException("請(qǐng)先設(shè)計(jì)模型");
            }
            Model modelData = repositoryService.getModel(businessDefine.getModelId());
            ObjectNode modelNode = (ObjectNode) new ObjectMapper().readTree(repositoryService.getModelEditorSource(modelData.getId()));
            byte[] bpmnBytes = null;
            BpmnModel model = new BpmnJsonConverter().convertToBpmnModel(modelNode);
            bpmnBytes = new BpmnXMLConverter().convertToXML(model);
            String processName = modelData.getName() + ".bpmn20.xml";
            Deployment deployment = repositoryService.createDeployment().name(modelData.getName()).addString(processName, new String(bpmnBytes, "UTF-8")).deploy();
            ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().deploymentId(deployment.getId()).singleResult();
            businessDefine.setProcDefId(processDefinition.getId());
            businessDefineService.update(businessDefine);
            return ResultResponse.ofSuccess();
        } catch (Exception e) {
            log.error("部署模型", e.getMessage(), e);
            return ResultResponse.ofError(e.getMessage());
        }
    }

導(dǎo)出流程

 /**
     * 導(dǎo)出model的xml文件
     */
    @GetMapping(value = "export")
    public void export(Long businessId, HttpServletResponse response) {
        try {
            BusinessDefine businessDefine = businessDefineService.getById(businessId);
            if (StringUtils.isBlank(businessDefine.getModelId())) {
                throw new SystemException("請(qǐng)先設(shè)計(jì)模型");
            }
            String modelId = businessDefine.getModelId();
            Model modelData = repositoryService.getModel(modelId);
            BpmnJsonConverter jsonConverter = new BpmnJsonConverter();
            JsonNode editorNode = new ObjectMapper().readTree(repositoryService.getModelEditorSource(modelData.getId()));
            BpmnModel bpmnModel = jsonConverter.convertToBpmnModel(editorNode);
            BpmnXMLConverter xmlConverter = new BpmnXMLConverter();
            byte[] bpmnBytes = xmlConverter.convertToXML(bpmnModel);

            ByteArrayInputStream in = new ByteArrayInputStream(bpmnBytes);
            OutputStream outputStream = response.getOutputStream();
            IOUtils.copy(in, outputStream);
            String filename = bpmnModel.getMainProcess().getId() + ".bpmn.xml";
            response.setHeader("content-type", "application/octet-stream");
            response.setContentType("application/octet-stream;charset=UTF-8");
            response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(filename,"utf-8") );
            outputStream.flush();
            outputStream.close();
        } catch (Exception e) {
            log.error("導(dǎo)出model的xml文件失?。簕}",e.getMessage(), e);
        }
    }

導(dǎo)入流程

通過xml導(dǎo)入流程會(huì)生成流程定義，但是不會(huì)創(chuàng)建模型，所以我們要通過流程定義創(chuàng)建模型

導(dǎo)入流程定義


    @PostMapping("import")
    public ResultResponse importXml(@RequestParam("file") MultipartFile file,Long businessId) {

        try {
            BusinessDefine businessDefine = businessDefineService.getById(businessId);
            InputStream fileInputStream = file.getInputStream();
            Deployment deployment = repositoryService.createDeployment()
                                    .addInputStream(businessDefine.getBusinessName() +".bpmn", fileInputStream)
                                    .deploy();
            ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().deploymentId(deployment.getId()).singleResult();
            String modelId = changeProcessToModel(processDefinition);
            businessDefine.setProcDefId(processDefinition.getId());
            businessDefine.setModelId(modelId);
            businessDefineService.update(businessDefine);
            return ResultResponse.ofSuccess();
        } catch (Exception e) {
            log.error("導(dǎo)入流程定義失敗:{}",e.getMessage(),e);
            return ResultResponse.ofError(e.getMessage());
        }
    }

通過流程生成模型


    /**
     * 流程轉(zhuǎn)化為可編輯模型
     *
     * @param processDefinition
     */

    public String changeProcessToModel(ProcessDefinition processDefinition) {

        Model modelData = repositoryService.newModel();
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        // 初始化Model
        ObjectMapper objectMapper = new ObjectMapper();
        ObjectNode modelObjectNode = objectMapper.createObjectNode();
        modelObjectNode.put(ModelDataJsonConstants.MODEL_NAME, processDefinition.getName());
        modelObjectNode.put(ModelDataJsonConstants.MODEL_REVISION, 1);
        modelObjectNode.put(ModelDataJsonConstants.MODEL_DESCRIPTION, processDefinition.getDescription());
        modelData.setMetaInfo(modelObjectNode.toString());
        modelData.setName(processDefinition.getName());
        modelData.setKey(processDefinition.getKey());

        // 保存模型
        repositoryService.saveModel(modelData);
        String deploymentId = processDefinition.getDeploymentId();
        String processDefineResourceName = null;
        // 通過deploymentId取得某個(gè)部署的資源的名稱
        List<String> resourceNames = processEngine.getRepositoryService().getDeploymentResourceNames(deploymentId);
        if (resourceNames != null && resourceNames.size() > 0) {
            for (String temp : resourceNames) {
                if (temp.indexOf(".bpmn") > 0) {
                    processDefineResourceName = temp;
                }
            }
        }
        InputStream bpmnStream = processEngine.getRepositoryService().getResourceAsStream(deploymentId, processDefineResourceName);
        createModelByInputStream(bpmnStream, modelData.getId());
        return modelData.getId();
    }

    public void createModelByInputStream(InputStream bpmnStream, String ModelID) {
        XMLInputFactory xif;
        InputStreamReader in = null;
        XMLStreamReader xtr = null;
        try {
            xif = XMLInputFactory.newFactory();
            in = new InputStreamReader(bpmnStream, "UTF-8");
            xtr = xif.createXMLStreamReader(in);
            BpmnModel bpmnModel = (new BpmnXMLConverter()).convertToBpmnModel(xtr);
            ObjectNode modelNode = new BpmnJsonConverter().convertToJson(bpmnModel);
            repositoryService.addModelEditorSource(ModelID, modelNode.toString().getBytes("UTF-8"));
        } catch (XMLStreamException e) {
            e.printStackTrace();
        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        } finally {
            if (xtr != null) {
                try {
                    xtr.close();
                } catch (XMLStreamException e) {
                    e.printStackTrace();
                }
            }
            if (in != null) {
                try {
                    in.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if (bpmnStream != null) {
                try {
                    bpmnStream.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }

完！

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點(diǎn)，簡書系信息發(fā)布平臺(tái)，僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容