Activiti子流程扩展标签

绝地灬酷狼 2023-05-22 06:59 42阅读 0赞

项目地址：[activiti-workflow][]  
子流程（Sub-process）是一个包含其他节点，网关，事件等等的节点。 它自己就是一个流程，同时是更大流程的一部分。 子流程只能包含一个空开始事件， 不能使用其他类型的开始事件。  
图形标记  
子流程显示为标准的节点，圆角矩形。 这时子流程是折叠的，只显示名称和一个加号标记， 展示了高级别的流程总览：  
![在这里插入图片描述][20200416193420215.png]  
• 内嵌子流程：定义在主流程内部  
• 事务子流程：事件子流程是由事件触发的子流程。 事件子流程可以添加到流程级别或任意子流程级别。用于触发事件子流程的事件是使用开始事件配置的。 为此，事件子流程是不支持空开始事件的。 事件子流程可以被消息事件，错误事件，信号事件，定时器事件，或补偿事件触发。 开始事件的订阅在包含事件子流程的作用域（流程实例或子流程）创建时就会创建。当使用事件子流程时，事件是完全由它添加的子流程处理的。 当使用边界事件时，事件由父流程处理。  
• 调用活动（子流程）：关联外部一个独立的流程  
使用  
以调用活动为例：  
先创建一个被调用的子流程信用管理流程  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NzU4MDc0_size_16_color_FFFFFF_t_70]  
创建主流程订单流程  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NzU4MDc0_size_16_color_FFFFFF_t_70 1]  
在子流程中可以设置入参和出参  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NzU4MDc0_size_16_color_FFFFFF_t_70 2]  
设置参数  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NzU4MDc0_size_16_color_FFFFFF_t_70 3]  
这里的源可以设置为是取主流程的那个流程变量，目标是子流程定义的变量名称，源表达可以没有。  
源码分析  
//子流程对象

public class CallActivity extends Activity { 
        protected String calledElement;
        //是否使用主流程变量
        protected boolean inheritVariables;
        //入参
        protected List<IOParameter> inParameters = new ArrayList();
        //出参
        protected List<IOParameter> outParameters = new ArrayList();
        //业务Key
        protected String businessKey;
        //是否使用主流程业务key
        protected boolean inheritBusinessKey;
    }

在官方提供的画布中是没有提供inheritVariables和inheritBusinessKey的设置的，需要自定义扩展。  
activiti每次操作都会通过ProcessDefinitionUtil.getProcess(String processDefinitionId)将整个流程封装为一个链路，每个节点有关联的入口和出口。  
最终通过一系列的调用会执行到这里org.activiti.bpmn.converter.BpmnXMLConverter\#convertToBpmnModel  
通过层层调用到达org.activiti.bpmn.converter.BaseBpmnXMLConverter\#convertXMLToElement，这里主要是将BPMN文件解析为对应类型的对象，比如userTask标签对应的是UserTask对象。  
而BaseBpmnXMLConverter的convertXMLToElement是一个抽象方法，activiti是如何确认执行哪一个子类。  
看org.activiti.bpmn.converter.BpmnXMLConverter\#convertToBpmnModel

if (activeProcess != null) { 
         //获取具体执行的子类，这里的xtr.getLocalName()为标签名
         BaseBpmnXMLConverter converter = convertersToBpmnMap.get(xtr.getLocalName());
         converter.convertToBpmnModel(xtr, model, activeProcess, activeSubProcessList);
     }

这里主要的就是convertersToBpmnMap了，在BpmnXMLConverter类里有

protected static Map<String, BaseBpmnXMLConverter> convertersToBpmnMap = new HashMap<String, BaseBpmnXMLConverter>();
    static { 
        // events
        addConverter(new EndEventXMLConverter());
        addConverter(new StartEventXMLConverter());
        // tasks
        addConverter(new BusinessRuleTaskXMLConverter());
        addConverter(new ManualTaskXMLConverter());
        addConverter(new ReceiveTaskXMLConverter());
        addConverter(new ScriptTaskXMLConverter());
        addConverter(new ServiceTaskXMLConverter());
        addConverter(new SendTaskXMLConverter());
        addConverter(new UserTaskXMLConverter());
        addConverter(new TaskXMLConverter());
        addConverter(new CallActivityXMLConverter());
        // gateways
        addConverter(new EventGatewayXMLConverter());
        addConverter(new ExclusiveGatewayXMLConverter());
        addConverter(new InclusiveGatewayXMLConverter());
        addConverter(new ParallelGatewayXMLConverter());
        addConverter(new ComplexGatewayXMLConverter());
        // connectors
        addConverter(new SequenceFlowXMLConverter());
        // catch, throw and boundary event
        addConverter(new CatchEventXMLConverter());
        addConverter(new ThrowEventXMLConverter());
        addConverter(new BoundaryEventXMLConverter());
        // artifacts
        addConverter(new TextAnnotationXMLConverter());
        addConverter(new AssociationXMLConverter());
        // data store reference
        addConverter(new DataStoreReferenceXMLConverter());
        // data objects
        addConverter(new ValuedDataObjectXMLConverter(), StringDataObject.class);
        addConverter(new ValuedDataObjectXMLConverter(), BooleanDataObject.class);
        addConverter(new ValuedDataObjectXMLConverter(), IntegerDataObject.class);
        addConverter(new ValuedDataObjectXMLConverter(), LongDataObject.class);
        addConverter(new ValuedDataObjectXMLConverter(), DoubleDataObject.class);
        addConverter(new ValuedDataObjectXMLConverter(), DateDataObject.class);
        // Alfresco types
        addConverter(new AlfrescoStartEventXMLConverter());
        addConverter(new AlfrescoUserTaskXMLConverter());
      }
    public static void addConverter(BaseBpmnXMLConverter converter) { 
        addConverter(converter, converter.getBpmnElementType());
     } 
    public static void addConverter(BaseBpmnXMLConverter converter, Class<? extends BaseElement> elementType) { 
        convertersToBpmnMap.put(converter.getXMLElementName(), converter);
        convertersToXMLMap.put(elementType, converter);
     }

可以看到初始类是就设置了convertersToBpmnMap，而且addConverter方法还是静态的，不是笔者我们去扩展。  
上面说到activiti提供的画布不满足需求，所以我们要做的事，在activiti讲bpmn转为对象时搞一些事情。调用子流程的转换是在CallActivityXMLConverter中完成的。

@Override
      protected BaseElement convertXMLToElement(XMLStreamReader xtr, BpmnModel model) throws Exception { 
        CallActivity callActivity = new CallActivity();
        BpmnXMLUtil.addXMLLocation(callActivity, xtr);
        callActivity.setCalledElement(xtr.getAttributeValue(null, ATTRIBUTE_CALL_ACTIVITY_CALLEDELEMENT));
        callActivity.setBusinessKey(xtr.getAttributeValue(ACTIVITI_EXTENSIONS_NAMESPACE, ATTRIBUTE_CALL_ACTIVITY_BUSINESS_KEY));
        //从bpmn中不去InheritBusinessKey的值
        callActivity.setInheritBusinessKey(Boolean.parseBoolean(xtr.getAttributeValue(
            ACTIVITI_EXTENSIONS_NAMESPACE, ATTRIBUTE_CALL_ACTIVITY_INHERIT_BUSINESS_KEY)));
        //从bpmn中不去InheritVariables的值
        callActivity.setInheritVariables(Boolean.valueOf(xtr.getAttributeValue(ACTIVITI_EXTENSIONS_NAMESPACE, ATTRIBUTE_CALL_ACTIVITY_INHERITVARIABLES)));
        parseChildElements(getXMLElementName(), callActivity, childParserMap, model, xtr);
        return callActivity;
      }

看到这里我们就可以重写这里convertXMLToElement方法手动给设值。

/** * 调用子流程自定义转换 * @author lhj */
    public class CustomCallActivityXMLConverter extends CallActivityXMLConverter { 
       /** * 重写转换方法，手动赋值 */
      @Override
      protected BaseElement convertXMLToElement(XMLStreamReader xtr, BpmnModel model) throws Exception { 
        CallActivity callActivity = new CallActivity();
        BpmnXMLUtil.addXMLLocation(callActivity, xtr);
        callActivity.setCalledElement(xtr.getAttributeValue(null, ATTRIBUTE_CALL_ACTIVITY_CALLEDELEMENT));
        callActivity.setBusinessKey(xtr.getAttributeValue(ACTIVITI_EXTENSIONS_NAMESPACE, ATTRIBUTE_CALL_ACTIVITY_BUSINESS_KEY));
        callActivity.setInheritBusinessKey(Boolean.TRUE);
        callActivity.setInheritVariables(Boolean.TRUE);
        parseChildElements(getXMLElementName(), callActivity, childParserMap, model, xtr);
        return callActivity;
      }
    }

在activiti的配置类中为convertersToBpmnMap重新赋值。

@Component
    public class WorkflowConfigurationConfigurer implements ProcessEngineConfigurationConfigurer { 
        @Autowired
        private WorkflowEventListener workflowEventListener;
        @Override
        public void configure(SpringProcessEngineConfiguration processEngineConfiguration) { 
            //配置全局监听器
            List<ActivitiEventListener> eventListeners =new ArrayList<>();
            eventListeners.add(workflowEventListener);
            processEngineConfiguration.setEventListeners(eventListeners);
            BpmnXMLConverter.addConverter(new CustomCallActivityXMLConverter());
        }
    }

到此，子流程就可以使用主流程的变量和业务Key。

[activiti-workflow]: https://github.com/heartlhj/activiti-workflow.git
[20200416193420215.png]: /images/20230521/6566f700e5124c28b614e5a63b51f120.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NzU4MDc0_size_16_color_FFFFFF_t_70]: /images/20230521/bdd872c5bdf44a4dae90b27d601da865.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NzU4MDc0_size_16_color_FFFFFF_t_70 1]: /images/20230521/5f97070d8f4f43798edb103b26eed6a9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NzU4MDc0_size_16_color_FFFFFF_t_70 2]: /images/20230521/c92ad43bfac04aa3990584e9b935147e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NzU4MDc0_size_16_color_FFFFFF_t_70 3]: /images/20230521/bf89005af4ae4904bc70c0da197e16d6.png