快捷導(dǎo)航

Activiti7通過代碼動(dòng)態(tài)生成工作流實(shí)現(xiàn)詳解

更新時(shí)間：2022年11月24日 09:50:46 作者：自由了

這篇文章主要為大家介紹了Activiti7通過代碼動(dòng)態(tài)生成工作流實(shí)現(xiàn)詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪

前言

最近項(xiàng)目有用到Activiti工作流，但是需求有點(diǎn)特殊，需要通過參數(shù)去生成BPMN圖，查閱了資料后，能實(shí)現(xiàn)簡單的工作流生成，那接下來看看如何通過代碼動(dòng)態(tài)生成工作流的吧。

一.設(shè)計(jì)思路

1.以普通的請假流程為例

(1)生成開始節(jié)點(diǎn)加第1個(gè)任務(wù)和調(diào)整申請任務(wù)(拒絕或者退回操作)以及其排他網(wǎng)關(guān)

(2)循環(huán)審批列表,生成第2至第N-1個(gè)任務(wù),并每個(gè)任務(wù)后都有1個(gè)排他網(wǎng)關(guān),用于連接調(diào)整申請任務(wù)

(3)最后1個(gè)節(jié)點(diǎn)，后面無排他任務(wù),故需要單獨(dú)處理

二.具體實(shí)現(xiàn)代碼

    List<String> roles=new ArrayList<>();
        roles.add("1508574");
        roles.add("13765234");
        roles.add("18834222");
        listMap.put("province",roles);
          for (String auditRole : processParamsDto.getAuditRoles()) {
        if (auditRole.equals(processParamsDto.getAuditRoles().get(0))) {
            //開始連線
            process.addFlowElement(createUserTask("task".concat("_").concat(auditRole), "審批".concat(auditRole), auditRole));
            process.addFlowElement(createSequenceFlow("start", "task".concat("_").concat(auditRole), null));
            //正常的 第一個(gè)網(wǎng)關(guān) process.addFlowElement(createExclusiveGateway("exclusiveGateWay".concat("_").concat(auditRole), "exclusiveGateWay".concat("_").concat(auditRole)));
            //第一個(gè)排他網(wǎng)關(guān)連線 任務(wù)->排他網(wǎng)關(guān)
            process.addFlowElement(createSequenceFlow("task".concat("_").concat(auditRole), "exclusiveGateWay".concat("_").concat(auditRole), null));
            //重新申請分支  創(chuàng)建重新申請任務(wù)
            process.addFlowElement(createUserTask("task".concat("_").concat("重新申請"), "指定人".concat("審批"), "${startBy}"));
            //申請網(wǎng)關(guān)->申請任務(wù)
            process.addFlowElement(createSequenceFlow("exclusiveGateWay".concat("_").concat(auditRole), "task".concat("_").concat("重新申請"), "${flag==false}"));
            //申請網(wǎng)關(guān)
            process.addFlowElement(createExclusiveGateway("exclusiveGateWay".concat("_").concat("重新申請"), "exclusiveGateWay".concat("_").concat("重新申請")));
            //申請任務(wù)->申請網(wǎng)關(guān)
            process.addFlowElement(createSequenceFlow("task".concat("_").concat("重新申請"),"exclusiveGateWay".concat("_").concat("重新申請"), null));
        } else if (!auditRole.equals(processParamsDto.getAuditRoles().get(processParamsDto.getAuditRoles().size() - 1))) {
            //創(chuàng)建排他網(wǎng)關(guān)  每個(gè)任務(wù)后都有一個(gè)排他網(wǎng)關(guān)
            //第二個(gè)任務(wù)至第size-1個(gè)任務(wù)
            process.addFlowElement(createUserTask("task".concat("_").concat(auditRole), "審批".concat(auditRole), auditRole));
            //第一個(gè)網(wǎng)關(guān)->第二個(gè)任務(wù)  任務(wù)之前的節(jié)點(diǎn) 網(wǎng)關(guān)->第二個(gè)任務(wù)....第N個(gè)任務(wù) true
            process.addFlowElement(createSequenceFlow("exclusiveGateWay".concat("_").concat(getPreAuditRole(auditRole,processParamsDto.getAuditRoles())), "task".concat("_").concat(auditRole), "${flag==true}"));
            //網(wǎng)關(guān)->申請任務(wù) false
            process.addFlowElement(createExclusiveGateway("exclusiveGateWay".concat("_").concat(auditRole), "exclusiveGateWay(當(dāng)前)".concat("_").concat(auditRole)));
            process.addFlowElement(createSequenceFlow("task".concat("_").concat(auditRole), "exclusiveGateWay".concat("_").concat(auditRole), null));
            //排他網(wǎng)關(guān)—>重新申請任務(wù)
            process.addFlowElement(createSequenceFlow("exclusiveGateWay".concat("_").concat(auditRole), "task".concat("_").concat("重新申請"),"#{flag==false}"));
        } else if (auditRole.equals(processParamsDto.getAuditRoles().get(processParamsDto.getAuditRoles().size() - 1))) {
            String lastNode=processParamsDto.getAuditRoles().get(processParamsDto.getAuditRoles().size() - 1);
            System.out.println("當(dāng)前節(jié)點(diǎn)"+lastNode);
            process.addFlowElement(createUserTask("task".concat(lastNode), "審批".concat(auditRole), auditRole));
            process.addFlowElement(createSequenceFlow("exclusiveGateWay".concat("_").concat(getPreAuditRole(auditRole,processParamsDto.getAuditRoles())),"task".concat(lastNode),"#{flag==true}"));
            process.addFlowElement(createEndEvent());
            process.addFlowElement(createSequenceFlow("task".concat(processParamsDto.getAuditRoles().get(processParamsDto.getAuditRoles().size() - 1)), "end", "${flag==true}"));     process.addFlowElement(createSequenceFlow("exclusiveGateWay".concat("_").concat("重新申請"), "end", "${flag==false}"));
  process.addFlowElement(createSequenceFlow("exclusiveGateWay".concat("_").concat("重新申請"), "task".concat("_").concat(processParamsDto.getAuditRoles().get(0)), "${flag==true}"));
        }
    }     
     new BpmnAutoLayout(model).execute();
    //定義并設(shè)置流程變量
    Map<String, Object> variables = new HashMap<>();
        variables.put("flag", 1 == 2);
    //deploy
    Deployment deployment = repositoryService.createDeployment().addBpmnModel("process/dynamic-model.bpmn", model).name("Dynamic process deployment").key("test_bpmn").deploy();
processEngine.getRuntimeService().startProcessInstanceByKey(processDefinition.getKey(), variables);
InputStream inputStreamXml = processEngine.getRepositoryService().getResourceAsStream(deployment.getId(), "process/dynamic-model.bpmn");
//保存到本地,方便查看生成后的文件
 FileUtils.copyInputStreamToFile(inputStreamXml, new File("D:\bpmn_data\process.bpmn.xml"));

三.注意事項(xiàng)

1.activiti-bpmn-layout.jar

//BPMN圖布局自動(dòng)調(diào)整需要添加
<dependency>
   <groupId>org.activiti</groupId>
   <artifactId>activiti-bpmn-layout</artifactId>
   <version>7.1.0.M4</version>
</dependency>

2.mxgraph-all.jar

//需要手動(dòng)添加,其自帶的mxgraph找不到方法,原因待確認(rèn),有時(shí)間去提個(gè)issue問問
<dependency>
   <groupId>com.mxgraph</groupId>
   <artifactId>mxgraph-all</artifactId>
   <version>4.2.2</version>
   <scope>system</scope>
</dependency>