jBPM与业务系统集成-通过定制Task Instance等方式实现

Posted 2021-05-15 AlexanderHu

最近在jBPM的咨询/培训中，客户经常问到这么一个问题：jBoss jBPM很好，可是它只能为我们提供一个工作流引擎、一个业务流转的机制，但它不能替我们处理业务问题、管理业务数据，如何才能将已开发好的特定业务系统和jBPM流程引擎结合在一起运行呢？

把jBPM流程系统和客户业务系统整合在一起，归根到底其实就是将流程运行过程中的任务实例（task instance）和业务实例（business instance）关联起来，有两种方法：

1. 在业务系统中保存任务实例的引用，系统以业务为主导，能够从一笔业务办理中获取它在流程中的位置等上下文数据。

2. 在jBPM流程系统中保存业务实例的引用，系统以流程为主导，通过工作流的任务列表向用户提供业务任务，根据流程的任务实例的附加数据获取其绑定的具体业务数据。

一般情况下，我推荐方法1，因为它对工作流系统的没有侵入，只需要修改业务系统，在业务表中加入一个列保存task instance ID即可，这个步骤一般在业务系统设计阶段预先构架好。

但是，在业务系统已经定型等情况下，要将已有的业务系统加入工作流程管理中，而且不侵入之，方法1明显的就不合适了，那么如何实现方法2呢？还是有两种思路：

    1. 将业务系统的引用作为流程/任务实例的变量（process/task instance varialbes）保存在jBPM系统中，那么通过流程/任务实例即可根据其绑定的业务引用变量查询业务实例数据。我们知道jBPM的变量系统是可以保存任何可序列化的对象的，所以我们甚至可以将整个业务实例的java object保存在jBPM工作流系统中（这样做可能比较疯狂，因为数据库存取二进制数据以及对象的序列/反序列化都是很影响效率的）。

    2. 这是jBPM官方推荐的一种思路，修改jBPM TaskInstance数据库表！没错，就是修改jBPM的原始表结构、扩展它的源代码。请注意我用的是扩展，因为这不会修改任何jBPM的源码，而只是扩展之，这也是应用开源软件的一个好习惯：不要修改它的源代码，而是尽量利用它提供的机制去“扩展”出你需要的功能。

    思路2的核心：首先在TaskInstance表中加一列，例如"BIZ_ID"，用来保存业务系统的引用，诸如“订单ID”、“合同号”……
    接着创造一个自定义的TaskInstance类，同时创建它的hbm描述文件（不要说你不懂hibernate哦，那神仙也没辙了），二者都需要继承jBPM原始的TaskInstance定义，例如：

1. public class CTaskInstance extends TaskInstance {
3.     private static final long serialVersionUID = 1270139435455649329L;
5.     protected String bizid;
7.     public CTaskInstance() {
8.     }
10.     public CTaskInstance(String taskName) {
11.         this.name = taskName;
12.     }
14.     public CTaskInstance(String taskName, String actorId) {
15.         this.name = taskName;
16.         this.actorId = actorId;
17.     }
19.     public String getBizid() {
20.         return bizid;
21.     }
23.     public void setBizid(String bizid) {
24.         this.bizid = bizid;
25.     }
27. }

1. <?xml version="1.0"?>
2. <!DOCTYPE hibernate-mapping PUBLIC
3.       "-//Hibernate/Hibernate Mapping DTD 3.0//EN"
4.           "http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd">
6. <hibernate-mapping auto-import="false" default-access="field">
7.     <subclass name="org.jbpm.customer.ctaskinstance.CTaskInstance"
8.         discriminator-value="C"
9.         extends="org.jbpm.taskmgmt.exe.TaskInstance">
10.         <property name="bizid" column="BIZID_" />
11.     </subclass>
12. </hibernate-mapping>

    接下来你觉得该做什么呢？没错，将这个持久化类型的描述加入jBPM的hibernate.cfg.xml中，具体不表。
    这时候，架构师们都会问：那如何让jBPM系统知道我们自定义的任务实例，并且在流程运行时使用的是它而非原始的任务实例呢？所以，我们需要替换jbpm.cfg.xml中的 jbpm.task.instance.factory属性配置，将这个任务实例工厂替换为我们自己的实现，这下全明白了吧。
    自定义任务实例工厂需要实现 org.jbpm.taskmgmt.TaskInstanceFactory接口，例如：

1. public class CTaskInstanceFactoryImpl implements TaskInstanceFactory {
2. 
   
3.     private static final long serialVersionUID = 1L;
4. 
   
5.     public TaskInstance createTaskInstance(ExecutionContext executionContext) {
6.         CTaskInstance ctaskin = new CTaskInstance();
7.         ctaskin
8.                 .setBizid(new Date(System.currentTimeMillis())
9.                         + "_U bizid here");
10.         return ctaskin;
11.     }
12. 
    
13. }

    此时，有经验的看官还会有疑问：那么在哪将我们的业务数据ID插入自定义任务实例呢？还是两条路供选择:-)

    1. 参见上面 TaskInstanceFactory的实现：可以在createTaskInstance时，设置业务数据ID，提示：可以通过ExecutionContext对象从流程实例变量中取得业务数据ID，从而满足更加灵活的场景，当然你需要预先在流程实例中设置这个变量。
    2. 可以通过编写/设置task controller来为每个customer task instance在start和end时设置业务数据ID，同样的，数据可以来自于流程实例预先绑定的变量。

    那么，当我们的customer task instance在持久化提交时，业务数据ID即可随自定义任务实例对象存入数据库。
    在官方的user guide(3.2.3版本)中有这样一段描述来简单的说明如何为业务扩展任务实例，供各位看官参考： 

12.10. Customizing task instances

Task instances can be customized. The easiest way to do this is to create a subclass of TaskInstance. Then create a org.jbpm.taskmgmt.TaskInstanceFactory implementation and configure it by setting the configuration property jbpm.task.instance.factory to the fully qualified class name in the jbpm.cfg.xml. If you use a subclass of TaskInstance, also create a hibernate mapping file for the subclass (using the hibernate extends="org.jbpm.taskmgmt.exe.TaskInstance"). Then add that mapping file to the list of mapping files in the hibernate.cfg.xml

欢迎转载，请注明作者：胡奇