如何實現Activiti的分支條件的自定義配置(轉)

時間  2019-11-06
標籤 如何 實現 activiti 分支 條件 自定義 配置 简体版
原文   原文鏈接

如何實現Activiti的分支條件的自定義配置

博客分類：
 

1、Activiti的流程分支條件的侷限java

Activiti的流程分支條件目前是採用腳本判斷方式，而且須要在流程定義中進行分支條件的設定，以下圖所示：node



 

Xml代碼   收藏代碼
  1. <sequenceFlow id="flow2" sourceRef="exclusiveGw" targetRef="theTask1">  
  2.   <conditionExpression xsi:type="tFormalExpression">${input == 1}</conditionExpression>  
  3. </sequenceFlow>  
  4. <sequenceFlow id="flow3" sourceRef="exclusiveGw" targetRef="theTask2">  
  5.   <conditionExpression xsi:type="tFormalExpression">${input == 2}</conditionExpression>  
  6. </sequenceFlow>  
  7. <sequenceFlow id="flow4" sourceRef="exclusiveGw" targetRef="theTask3">  
  8.   <conditionExpression xsi:type="tFormalExpression">${input == 3}</conditionExpression>  
  9. </sequenceFlow>  

 

 

從上面的定義能夠看到，流程的分支條件存在如下兩個致命的侷限性：spring

1．分支條件須要在流程定義（XML）中設定，這要求流程定義必須由開發人員來設計及編寫apache

2．分支條件比較簡單，通常爲boolean表達式，表達式裏的爲單變量的判斷處理。json

 

以上兩個侷限性限制了流程的分支判斷處理必須由開發人員來設定，而國內的大部分的流程應用都要求是普通的業務人員便可處理，或者是由有必定計算機基礎的人員來設置處理。這要求咱們對流程的條件設置提出了更高的要求，上一節咱們經過修改Activiti的流程定義的XML中的分支條件表達式，同時刷新流程定義的引擎緩存，以下的代碼就是基於這種方式：緩存

 

Java代碼   收藏代碼
  1. JsonNode jsonObject=objectMapper.readTree(configJson);  
  2.   JsonNode configsNode=jsonObject.get("configs");  
  3.               
  4.   BpmSolution bpmSolution=bpmSolutionManager.get(solId);  
  5.   BpmDef bpmDef=bpmDefManager.getLatestBpmByKey(bpmSolution.getDefKey(), ContextUtil.getCurrentTenantId());  
  6.             ActProcessDef processDef=actRepService.getProcessDef(bpmDef.getActDefId());  
  7.             String processDefXml=actRepService.getBpmnXmlByDeployId(bpmDef.getActDepId());  
  8.               
  9.             System.out.println("xml:"+processDefXml);  
  10.               
  11.             ActNodeDef sourceNode=processDef.getNodesMap().get(nodeId);  
  12.             ByteArrayInputStream is=new ByteArrayInputStream(processDefXml.getBytes());  
  13.               
  14.             Map<String,String> map = new HashMap<String,String>();    
  15.             map.put("bpm","http://www.omg.org/spec/BPMN/20100524/MODEL");    
  16.             map.put("xsi","http://www.omg.org/spec/BPMN/20100524/MODEL");    
  17.             SAXReader saxReader = new SAXReader();    
  18.             saxReader.getDocumentFactory().setXPathNamespaceURIs(map);    
  19.             Document doc = saxReader.read(is);    
  20.                   
  21.             //Document doc=Dom4jUtil.load(is, "UTF-8");  
  22.             Element rootEl=doc.getRootElement();  
  23.               
  24.             if(configsNode!=){  
  25.                 //取得分支條件列表  
  26.                 JsonNode configs=configsNode.get("conditions");  
  27.                 if(configs!=){  
  28.                     Iterator<JsonNode> it=configs.elements();  
  29.                     while(it.hasNext()){  
  30.                         ObjectNode config=(ObjectNode)it.next();  
  31.                         String tmpNodeId=config.get("nodeId").textValue();  
  32.                         String tmpCondition=config.get("condition").textValue();  
  33.                           
  34.                         Element seqFlow=(Element)rootEl.selectSingleNode("/bpm:definitions/bpm:process/bpm:sequenceFlow[@sourceRef='"  
  35.                         +sourceNode.getNodeId()+"' and @targetRef='"+tmpNodeId+"']");  
  36.                         if(seqFlow==) continue;  
  37.                           
  38.                         Element conditionExpress=(Element)seqFlow.selectSingleNode("bpm:conditionExpression");  
  39.                         if(conditionExpress==){  
  40.                             conditionExpress=seqFlow.addElement("conditionExpression");  
  41.                             conditionExpress.addAttribute("xsi:type", "tFormalExpression");  
  42.                         }else{  
  43.                             conditionExpress.clearContent();  
  44.                         }  
  45.                         conditionExpress.addCDATA(tmpCondition);  
  46.                           
  47.                     }  
  48.                 }  
  49.             }  
  50.             //修改流程定義的XML，而且清空該流程定義的緩存  
  51.             actRepService.doModifyXmlAndClearCache(bpmDef.getActDefId(),bpmDef.getActDepId(), doc.asXML());  

 

 

 

【說明】app

 

1．基於這種方式容易出錯，由於流程的分支條件寫回流程定義的XML是比較容易出問題的，同時不清楚人員填寫什麼條件回XML文件中。ide

2．對於Jsaas中的一個流程定義可用於多個流程解決方案中使用配置不一樣的條件不太適合，由於一個流程定義是同樣，但可能會分支的條件設置不同。this

 

 

基於以上的要求，爲此咱們對Activiti進行擴展，以使得咱們能夠容許流程引擎在分支判斷處理中，執行咱們的條件設置，其原理以下：spa



 

當流程引擎跳至分支條件判斷處理時，可讓它執行咱們的腳本設置條件，條件知足時，則跳至咱們的設置的目標節點，從而實現干預流程引擎自己的執行方式，爲了避免影響Activiti的原的運行機制，咱們仍是保留其舊的執行判斷方式。

 

 

2、Activiti的擴展點

Activiti的流程擴展是比較靈活的，咱們經過改寫這個ExclusiveGateway的節點的行爲方法便可，其實現方法以下：

Java代碼   收藏代碼
  1. package com.redxun.bpm.activiti.ext;  
  2. import java.util.Iterator;  
  3. import javax.annotation.Resource;  
  4. import org.activiti.engine.impl.bpmn.behavior.ExclusiveGatewayActivityBehavior;  
  5. import org.activiti.engine.impl.pvm.PvmTransition;  
  6. import org.activiti.engine.impl.pvm.delegate.ActivityExecution;  
  7. import org.apache.commons.lang.StringUtils;  
  8. import org.slf4j.Logger;  
  9. import org.slf4j.LoggerFactory;  
  10.   
  11. import com.redxun.bpm.core.entity.config.ExclusiveGatewayConfig;  
  12. import com.redxun.bpm.core.entity.config.NodeExecuteScript;  
  13. import com.redxun.bpm.core.manager.BpmNodeSetManager;  
  14. import com.redxun.core.script.GroovyEngine;  
  15. import com.sun.star.uno.RuntimeException;  
  16. /** 
  17.  * 對網關的條件判斷，優先使用擴展的配置 
  18.  * @author keitch 
  19.  * 
  20.  */  
  21. @SuppressWarnings("serial")  
  22. public class ExclusiveGatewayActivityBehaviorExt extends ExclusiveGatewayActivityBehavior{  
  23.       
  24.     protected static Logger log = LoggerFactory.getLogger(ExclusiveGatewayActivityBehaviorExt.class);  
  25.       
  26.     //節點的設置管理器  
  27.     @Resource  
  28.     BpmNodeSetManager bpmNodeSetManager;  
  29.     //腳本引擎  
  30.     @Resource GroovyEngine groovyEngine;  
  31.       
  32.     @Override  
  33.     protected void leave(ActivityExecution execution) {  
  34.         log.debug("enter ExclusiveGatewayActivityBehaviorExt=======================");  
  35.         if (log.isDebugEnabled()) {  
  36.             log.debug("Leaving activity '{}'", execution.getActivity().getId());  
  37.          }  
  38.         String solId=(String)execution.getVariable("solId");  
  39.         String nodeId=execution.getActivity().getId();  
  40.         log.debug("solid is {} and nodeId is {}",solId,nodeId);  
  41.           
  42.         if(StringUtils.isNotEmpty(solId)&& StringUtils.isNotBlank(nodeId)){  
  43.             ExclusiveGatewayConfig configs=bpmNodeSetManager.getExclusiveGatewayConfig(solId, nodeId);  
  44.             for(NodeExecuteScript script:configs.getConditions()){  
  45.                 String destNodeId=script.getNodeId();  
  46.                 String condition=script.getCondition();  
  47.                 log.debug("dest node:{}, condition is {}",destNodeId,condition);  
  48.                 //執行腳本引擎  
  49.                 Object boolVal=groovyEngine.executeScripts(condition, execution.getVariables());  
  50.                 if(boolVal instanceof Boolean){  
  51.                     Boolean returnVal=(Boolean)boolVal;//符合條件  
  52.                     if(returnVal==true){  
  53.                         //找到符合條件的目標節點而且進行跳轉  
  54.                         Iterator<PvmTransition> transitionIterator = execution.getActivity().getOutgoingTransitions().iterator();  
  55.                         while (transitionIterator.hasNext()) {  
  56.                               PvmTransition seqFlow = transitionIterator.next();  
  57.                               if(destNodeId.equals(seqFlow.getDestination().getId())){  
  58.                                   execution.take(seqFlow);  
  59.                                   return;  
  60.                               }  
  61.                         }  
  62.                     }  
  63.                 }else{  
  64.                     throw new RuntimeException("表達式:\n "+condition+"\n返回值不爲布爾值(true or false)");  
  65.                 }  
  66.             }  
  67.         }  
  68.         //執行父類的寫法，以使其仍是能夠支持舊式的在跳出線上寫條件的作法    
  69.         super.leave(execution);  
  70.           
  71.     }  
  72. }  

 

咱們經過繼續改寫了這個分支節點的跳出機制，而且經過腳本引擎來執行其條件分支的判斷處理，但流程引擎並不瞭解咱們擴展的類，這時咱們須要配置Activiti流程引擎的行爲動做工廠類，以下所示：

Java代碼   收藏代碼
  1. package com.redxun.bpm.activiti.ext;  
  2.   
  3. import org.activiti.bpmn.model.ExclusiveGateway;  
  4. import org.activiti.engine.impl.bpmn.behavior.ExclusiveGatewayActivityBehavior;  
  5. import org.activiti.engine.impl.bpmn.parser.factory.DefaultActivityBehaviorFactory;  
  6.   
  7. /** 
  8.  * 擴展缺省的流程節點默認工廠類，實現對Activiti節點的執行的默認行爲的更改 
  9.  * @author keitch 
  10.  * 
  11.  */  
  12. public class ActivityBehaviorFactoryExt extends DefaultActivityBehaviorFactory {  
  13.       
  14.     private ExclusiveGatewayActivityBehaviorExt exclusiveGatewayActivityBehaviorExt;  
  15.       
  16.     /** 
  17.      * 經過Spring容器注入新的分支條件行爲執行類 
  18.      * @param exclusiveGatewayActivityBehaviorExt 
  19.      */  
  20.     public void setExclusiveGatewayActivityBehaviorExt(ExclusiveGatewayActivityBehaviorExt exclusiveGatewayActivityBehaviorExt) {  
  21.         this.exclusiveGatewayActivityBehaviorExt = exclusiveGatewayActivityBehaviorExt;  
  22.     }  
  23.       
  24.     //重寫父類中的分支條件行爲執行類  
  25.     @Override  
  26.     public ExclusiveGatewayActivityBehavior createExclusiveGatewayActivityBehavior(ExclusiveGateway exclusiveGateway) {  
  27.         return exclusiveGatewayActivityBehaviorExt;  
  28.     }  
  29. }  

 

3、Activiti的Spring配置的更改

 

在Activiti的流程引擎配置中加入新的流程行爲動做執行工廠類。配置以下所示，注意activityBehaviorFactory的屬性配置：

Xml代碼   收藏代碼
  1. <bean id="processEngineConfiguration" class="org.activiti.spring.SpringProcessEngineConfiguration">  
  2.     <property name="dataSource" ref="dataSource" />  
  3.     <property name="transactionManager" ref="transactionManager" />  
  4.     <property name="databaseSchemaUpdate" value="true" />  
  5.     <property name="jobExecutorActivate" value="false" />  
  6.     <property name="enableDatabaseEventLogging" value="false" />  
  7.     <property name="databaseType" value="${db.type}" />  
  8.     <property name="idGenerator" ref="actIdGenerator"/>  
  9.     <property name="eventListeners">  
  10.       <list>  
  11.         <ref bean="globalEventListener"/>  
  12.       </list>  
  13.     </property>  
  14.     <property name="activityFontName" value="宋體"/>  
  15.     <property name="labelFontName" value="宋體"/>  
  16.     <!-- 用於更改流程節點的執行行爲 -->  
  17.     <property name="activityBehaviorFactory" ref="activityBehaviorFactoryExt"/>  
  18.   </bean>  
  19.     
  20.     
  21.   <bean id="activityBehaviorFactoryExt" class="com.redxun.bpm.activiti.ext.ActivityBehaviorFactoryExt">  
  22.     <property name="exclusiveGatewayActivityBehaviorExt" ref="exclusiveGatewayActivityBehaviorExt"/>  
  23.   </bean>  
  24.     
  25.   <bean id="exclusiveGatewayActivityBehaviorExt" class="com.redxun.bpm.activiti.ext.ExclusiveGatewayActivityBehaviorExt"/>  

 

 

經過以上方式擴展後，節點的分支設置能夠把條件表達式寫成如下方式，同時條件存於流程定義的外部表中:

 

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程