Activiti工作流引擎使用,基于工作流的阳台管理体系规划

二. 提前还款流程

2.6 Eclipse Designer存在的问题

这个插件有一个很讨厌的Bug一直未修复,安装了插件后Eclipse的复制和粘帖快捷键会被更换为(Ctrl+Insert、Shift+Insert);Bug描述请见:

  • Activit
    Forums中报告的Bug

  • Jira的登记

所以最后我们只能单独开一个安装了Eclipse
Designer的Eclipse专门用来设计流程图,这样就不影响正常使用Eclipse
JAVAEE了。

2.3.3 如何选择

建议使用startProcessInstanceByKey,特殊情况需要使用以往的版本选择使用startProcessInstanceById

❹ 运营代扣还款金额, 结清借款

4.使用单元测试

单元测试均使用Spring的AbstractTransactionalJUnit4SpringContextTests作为SuperClass,并且在测试类添加:

@ContextConfiguration(locations = { "/applicationContext-test.xml"})
@RunWith(SpringJUnit4ClassRunner.class)

?

虽然Activiti也提供了测试的一些超类,但是感觉不好用,所以自己封装了一些方法。

代码请转移:

2.2 使用引擎提供的Form还是自定义业务Form

❶ 用户联系客户服务人员,提交申请, 包括借款信息, 手持身份证照片,
银行卡信息等

1.1 我与工作流引擎

在第一家公司工作的时候主要任务就是开发OA系统,当然基本都是有工作流的支持,不过当时使用的工作流引擎是公司一些牛人开发的(据说是用一个开源的引擎修改的),名称叫CoreFlow;功能相对Activiti来说比较弱,但是能满足日常的使用,当然也有不少的问题所以后来我们只能修改引擎的代码打补丁。

现在是我工作的第二家公司,因为要开发ERP、OA等系统需要使用工作流,在项目调研阶段我先搜索资料选择使用哪个开源工作流引擎,最终确定了Activiti5并基于公司的架构做了一些DEMO。

2.3 业务和流程的关联方式

这个问题在群里面很多人都问过,这也是我刚刚开始迷惑的地方;

后来看了以下API发现RuntimeService有两个方法:

  1. 一些通用的activiti流程,
    如一步操作即创建后只需要一步完成操作, 两步流程 –
    创建后一步审核一步操作等, 不同的业务会使用相同的流程.

  2. 在activiti流程相同的情况下,
    不同的业务的步骤其处理人/组则不同

  3. 不同业务流程的实际代码开发应该简洁,
    和工作流引擎解耦, 即实际的开 发人员
    在不了解工作流引擎具体工作原理的情况下可以进行迅速的开发, 并
    只需要关注具体 的业务需求

5.1 未签收(Task)

此类任务针对于把Task分配给一个角色时,例如部门领导,因为部门领导角色可以指定多个人所以需要先签收再办理,术语:抢占式

对应的API查询:

/**
 * 获取未签收的任务查询对象
 * @param userId    用户ID
 */
@Transactional(readOnly = true)
publicTaskQuery createUnsignedTaskQuery(String userId) {
    TaskQuery taskCandidateUserQuery = taskService.createTaskQuery().processDefinitionKey(getProcessDefKey())
            .taskCandidateUser(userId);
    returntaskCandidateUserQuery;
}

?

6.UI及截图

结合实际业务描述一个业务从开始到结束的过程,对于迷惑的同学看完豁然开朗了;这里使用请假作为例子。

持续的重构包括:

1.2 Activiti与JBPM5?

对于Activiti、jBPM4、jBPM5我们应该如何选择,在InfoQ上有一篇文章写的很好,从大的层面比较各个引擎之间的差异,请参考文章:纵观jBPM:从jBPM3到jBPM5以及Activiti5

2.6 Eclipse Designer存在的问题

这个插件有一个很讨厌的Bug一直未修复,安装了插件后Eclipse的复制和粘帖快捷键会被更换为(Ctrl+Insert、Shift+Insert);Bug描述请见:

  • Activit
    Forums中报告的Bug

  • Jira的登记

所以最后我们只能单独开一个安装了Eclipse
Designer的Eclipse专门用来设计流程图,这样就不影响正常使用Eclipse
JAVAEE了。

一. 借款人银行卡信息修改

5.4 已完成(HistoricProcessInstance)

已经结束的流程实例。

从表ACT_HI_PROCINST中查询数据。

/**
 * 获取已经完成的流程实例查询对象
 * @param userId    用户ID
 */
@Transactional(readOnly = true)
publicHistoricProcessInstanceQuery createFinishedProcessInstanceQuery(String userId) {
    HistoricProcessInstanceQuery finishedQuery = historyService.createHistoricProcessInstanceQuery()
            .processDefinitionKey(getProcessDefKey()).finished();
    returnfinishedQuery;
}

 

?

4.1 验证流程图设计是否正确

代码请转移:

➤ 数据库设计 和RequestService对底层数据操作的封装

2.4 同步用户数据

这个问题也是比较多的人询问过,Activiti支持对任务分配到:指定人、指定组、两者组合,而这些人和组的信息都保存在ACT_ID..表中,有自己的用户和组(角色)管理让很多人不知所措了;原因是因为每个系统都会存在一个权限管理模块(维护:用户、部门、角色、授权),不知道该怎么和Activiti同步。

2.2.2 自定义业务Form

这种方式应该是大家用的最多的了,因为一般的业务系统业务逻辑都会比较复杂,而且数据库中很多表都会有依赖关系,表单中有很多状态判断。

例如我们的系统适用jQuery
UI作为UI,有很多javascript代码,页面的很多操作需要特殊处理(例如:多个选项的互斥、每个节点根据类型和操作人显示不同的按钮);基本每个公司都有一套自己的UI风格,要保持多个系统的操作习惯一致只能使用自定义表单才能满足。

基础框架代码设计

6.3.1 当前节点定位JS

Java代码请移步:

Javascript思路:先通过Ajax获取当前节点的坐标,在指定位置添加红色边框,然后加载图片。

代码移步:

6.3.1 当前节点定位JS

Java代码请移步:

Javascript思路:先通过Ajax获取当前节点的坐标,在指定位置添加红色边框,然后加载图片。

代码移步:

3.
实现该业务涉及的具体步骤的操作processor类(如审批或和其他系统对接,
完成实际的业务),

6.3 流程跟踪

图片方式显示当前节点:

图片 1

列表形式显示流程流转过程:

图片 2

5.4 已完成(HistoricProcessInstance)

已经结束的流程实例。

从表ACT_HI_PROCINST中查询数据。

?

1
2
3
4
5
6
7
8
9
10
/**
 *
获取已经完成的流程实例查询对象
 *
@param userId    用户ID
 */
@Transactional(readOnly
=
true)
public
HistoricProcessInstanceQuery createFinishedProcessInstanceQuery(String userId) {
    HistoricProcessInstanceQuery
finishedQuery = historyService.createHistoricProcessInstanceQuery()
            .processDefinitionKey(getProcessDefKey()).finished();
    return
finishedQuery;
}

图片 3

4.2 业务对象和流程关联测试

代码请转移:

4.2 业务对象和流程关联测试

代码请转移:

对于互联网金融平台来说,重要的业务尤其是涉及资金业务相关操作时都有必要有相关的审批流程.同时在流程的流转过程中需要和各个业务系统进行交互,完成真正的业务处理,
并记录这个过程中所有人的操作以及每一步操作时所涉及数据快照,以便于内外部审计和问题的追溯.

2.1.2.2 使用Ant脚本打包Zip文件

这也是我们采用的办法,你可以手动选择xml和png打包成zip格式的文件,也可以像我们一样采用ant
target的方式打包这两个文件。

<?xml version="1.0" encoding="UTF-8"?>
<project name="foo">

    <property name="workflow.definition" value="foo-common-core/src/main/resources/diagrams" />
    <property name="workflow.deployments" value="foo-common-core/src/main/resources/deployments" />

<target name="workflow.package.oa.leave">
        <echo>打包流程定义及流程图::OA-请假</echo>
        <zip destfile="${workflow.deployments}/oa/leave.zip" basedir="${workflow.definition}/oa/leave" update="true"
            includes="*.xml,*.png" />
    </target>
</project>

这样当修改流程定义文件后只要运行ant命令就可以打包了:

ant workflow.package.oa.leave

现在部署bar或者zip文件查看流程图图片就不是乱码了,而是你的压缩包里面的png文件。

9.3 获取流程发起人

如果在启动流程的时候调用了下面的代码:

?

1
identityService.setAuthenticatedUserId(currentUserId);

引擎会记录启动人,即在ACT_HI_PROINST表的START_USER_ID字段,可以通过下面的代码获取。

?

1
2
HistoricProcessInstance
hi = historyService.createHistoricProcessInstanceQuery().singleResult();
hi.getStartUserId();

☞设计通用的底层数据来支持不同的业务

6.UI及截图

结合实际业务描述一个业务从开始到结束的过程,对于迷惑的同学看完豁然开朗了;这里使用请假作为例子。

8.结束

之前就想写这篇文章,现在终于完成了,花费了几个小时,希望能节省你几天的时间。

请读者仔细阅读Activiti的用户手册和Javadoc。

如果有什么疑问或者对于功能的实现有更好的办法欢迎提出、分享。

由于这样一个运营管理系统涉及到各种不同的业务数据.
如借款人信息相关涉及借款ID, 银行卡信息等; 如出借人信息则涉及用户ID,
电话号码等; 而对于资金相关如提前还款则涉及到提前还款日期, 还款金额等.
所以一套支撑不同具体业务的流程数据表结构也是非常重要.

2.初次使用遇到问题收集

因为Activiti刚刚退出不久所以资料比较空缺,中文资料更是少的可怜,所以开始的时候一头雾水(虽然之前用过工作流,但是感觉差距很多),而且官方的手册还不是很全面;所以我把我在学习使用的过程遇到的一些疑问都罗列出来分享给大家;以下几点是我遇到和想到的,如果你还有什么疑问可以在评论中和我交流再补充。

2.5.1 我们的方式

可能你会惊讶,因为我们没有使用Activiti
Modeler,我们认为用Viso已经能表达流程图的意思了,而且项目经理也是技术出身,和开发人员也容易沟通。

目前这个项目是第一个使用Activiti的,开始我们在需求调研阶段使用Viso设计流程图,利用泳道流程图设计和客户沟通,确定后由负责流程的开发人员用Eclipse
Designer设计得到bpmn20.xml,最后部署。

➤ 根据业务需要提供ASync的processor处理基类, 因为实际应用中发现,
一些业务的处理(如批量)需要一段时间的执行才能完成,
而异步处理基类则完成基础实现, 并由相应子类去实现虚函数即可.

2.3 业务和流程的关联方式

这个问题在群里面很多人都问过,这也是我刚刚开始迷惑的地方;

后来看了以下API发现RuntimeService有两个方法:

5.1 未签收(Task)

此类任务针对于把Task分配给一个角色时,例如部门领导,因为部门领导角色可以指定多个人所以需要先签收再办理,术语:抢占式

对应的API查询:

?

1
2
3
4
5
6
7
8
9
10
/**
 *
获取未签收的任务查询对象
 *
@param userId    用户ID
 */
@Transactional(readOnly
=
true)
public
TaskQuery createUnsignedTaskQuery(String userId) {
    TaskQuery
taskCandidateUserQuery = taskService.createTaskQuery().processDefinitionKey(getProcessDefKey())
            .taskCandidateUser(userId);
    return
taskCandidateUserQuery;
}

一个好的设计不是一步到位的设计,
而是一个循序渐进的过程以及不断重构的过程.
但是非常重要的一点就是在一开始能够根据当前的需求以及所能预见的需求进行设计,
并且在这个基础框架代码上开发要更加便利和简洁.

5.5 查询时和业务关联

提示:之前在业务对象添加了PROCESS_INSTANCE_ID字段

思路:现在可以利用这个字段查询了,不管是Task还是ProcessInstance都可以得到流程实例ID,可以根据流程实例ID查询实体然后把流程对象设置到实体的一个属性中由Action或者Controller输出到前台。

代码请参考:

2.4.1 建议处理方式

Activiti有一个IdentityService接口,通过这个接口可以操控Activiti的ACT_ID_*表的数据,一般的做法是用业务系统的权限管理模块维护用户数据,当进行CRUD操作的时候在原有业务逻辑后面添加同步到Activiti的代码;例如添加一个用户时同步Activiti
User的代码片段:

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849
/** * 保存用户信息 并且同步用户信息到activiti的identity.User,同时设置角色 * @param user * @param roleIds */public void saveUser(User user, List<Long> roleIds, boolean synToActiviti) { accountManager.saveEntity(user); String userId = user.getId().toString();   if (synToActiviti) {      List<org.activiti.engine.identity.User> activitiUsers = identityService.createUserQuery().userId(userId).list();       if (activitiUsers.size() == 1) {          //更新信息         org.activiti.engine.identity.User activitiUser = activitiUsers.get(0);          activitiUser.setFirstName(user.getName());           activitiUser.setLastName("");          activitiUser.setPassword(user.getPassword());            activitiUser.setEmail(user.getEmail());          identityService.saveUser(activitiUser);             // 删除用户的membership          List<Group> activitiGroups = identityService.createGroupQuery().groupMember(userId).list();            for (Group group : activitiGroups) {                identityService.deleteMembership(userId, group.getId());          }            // 添加membership          for (Long roleId : roleIds) {               Role role = roleManager.getEntity(roleId);                identityService.createMembership(userId, role.getEnName());           }        } else {         org.activiti.engine.identity.User newUser = identityService.newUser(userId);          newUser.setFirstName(user.getName());            newUser.setLastName("");           newUser.setPassword(user.getPassword());         newUser.setEmail(user.getEmail());           identityService.saveUser(newUser);          // 添加membership          for (Long roleId : roleIds) {               Role role = roleManager.getEntity(roleId);                identityService.createMembership(userId, role.getEnName());           }        }    } }

view
rawAccountServiceImpl.java hosted
with ❤ by GitHub

删除操作也和这个类似!

不管从业务系统维护用户还是从Activiti维护,肯定要确定一方,然后CRUD的时候同步到对方,如果需要同步多个子系统那么可以再调用WebService实现。

为了解决 #2 的问题,
则需要用服务进行封装, 抽象出一些接口以及基类的实 现, 并
应用一些常见的设计模式(工厂模式)和java的特性(反射).

2.1 部署流程图后中文乱码

乱码是一直缠绕着国人的问题,之前各个技术、工具出现乱码的问题写过很多文章,这里也不例外……,Activiti的乱码问题在流程图中。

流程图的乱码如下图所示:

图片 4

解决办法有两种:

9.2 自动设置任务办理人

下面的代码是利用initiator功能,设置一个名称(不是变量而是变量名)到启动事件上,并且在启动流程时调用一些下面的方法:

?

1
identityService.setAuthenticatedUserId(currentUserId);

其中currentUserId表示当前用户,也就是启动流程的人,配置如下所示:

?

1
2
<startevent
id
="startevent1"
name
="Start"
activiti:initiator
="applyUserId"></startevent>
<usertask
id
="reportBack"
name
="销假"
activiti:assignee
="${applyUserId}"></usertask>

这样流程启动之后如果任务流转至”销假”节点则会自动把任务分配给启动流程的人。

☞ 基础框架代码的设计

2.3.3 如何选择

建议使用startProcessInstanceByKey,特殊情况需要使用以往的版本选择使用startProcessInstanceById

7.开启Logger

  1. 添加log4j的jar
  2. 设置log4j.logger.java.sql=DEBUG

Activiti中提供便捷的查询类, 如: ProcessInstanceQuery, TaskQuery.
其同时支持按照Process和Task相应的属性数据进行查询,
和Request/Snapshot以及property有很大的相似之处,
借鉴并根据实际情况实现自己的RequestQuery类, 支持各类复杂查询, 如:
按照指定的property的name和value查询, 支持or的查询等。

2.1.1 修改源代码方式

修改源码

org.activiti.engine.impl.bpmn.diagram.ProcessDiagramCanvas

在构造方法

public ProcessDiagramCanvas(int width, int height)

中有一行代码是设置字体的,默认是用 Arial 字体,这就是乱码产生的原因,把字改为本地的中文字体即可,例如:

Font font = new Font("WenQuanYi Micro Hei", Font.BOLD, 11);

当然如果你有配置文件读取工具那么可以设置在*.properties文件中,我就是这么做的:

Font font = new Font(PropertyFileUtil.get("activiti.diagram.canvas.font"), Font.BOLD, 11);

1.简单介工作流引擎与Activiti

对于工作流引擎的解释请参考百度百科:工作流引擎

❺ 生成还款结清证明

4.1 验证流程图设计是否正确

代码请转移:

6.2 流程状态

图片 5

图片 6

2.3.2 startProcessInstanceById

javadoc对其说明:

startProcessInstanceById(String processDefinitionId, String businessKey, Map variables) 
          Starts a new process instance in the exactly specified version of the process definition with the given id.

 

processDefinitionId:这个参数的值可以通过repositoryService.createProcessDefinitionQuery()方法查询,对应数据库:ACT_RE_PROCDEF;每次部署一次流程定义就会添加一条数据,同名的版本号累加。

特别说明: 此可以指定不同版本的流程定义,让用户多一层选择。

5.5 查询时和业务关联

提示:之前在业务对象添加了PROCESS_INSTANCE_ID字段

思路:现在可以利用这个字段查询了,不管是Task还是ProcessInstance都可以得到流程实例ID,可以根据流程实例ID查询实体然后把流程对象设置到实体的一个属性中由Action或者Controller输出到前台。

代码请参考:

这样或者那样的疑惑或者斗争,

2.2.2 自定义业务Form

这种方式应该是大家用的最多的了,因为一般的业务系统业务逻辑都会比较复杂,而且数据库中很多表都会有依赖关系,表单中有很多状态判断。

例如我们的系统适用jQuery
UI作为UI,有很多javascript代码,页面的很多操作需要特殊处理(例如:多个选项的互斥、每个节点根据类型和操作人显示不同的按钮);基本每个公司都有一套自己的UI风格,要保持多个系统的操作习惯一致只能使用自定义表单才能满足。

6.1 单独一个列表负责申请

这样的好处是申请和流程办理分离开处理,列表显示未启动流程的请假记录(数据库PROCESS_INSTANCE_ID为空)。

申请界面的截图:

图片 7

如上所说, 这样的一个数据设计必须能够满足:

2.4.1 建议处理方式

Activiti有一个IdentityService接口,通过这个接口可以操控Activiti的ACT_ID_*表的数据,一般的做法是用业务系统的权限管理模块维护用户数据,当进行CRUD操作的时候在原有业务逻辑后面添加同步到Activiti的代码;例如添加一个用户时同步Activiti
User的代码片段:

/**
 * 保存用户信息 并且同步用户信息到activiti的identity.User,同时设置角色
 * @param user
 * @param roleIds
 */
public void saveUser(User user, List<Long> roleIds, boolean synToActiviti) {
    accountManager.saveEntity(user);
    String userId = user.getId().toString();

    if (synToActiviti) {
        List<org.activiti.engine.identity.User> activitiUsers = identityService.createUserQuery().userId(userId).list();
        if (activitiUsers.size() == 1) {
            //更新信息
            org.activiti.engine.identity.User activitiUser = activitiUsers.get(0);
            activitiUser.setFirstName(user.getName());
            activitiUser.setLastName("");
            activitiUser.setPassword(user.getPassword());
            activitiUser.setEmail(user.getEmail());
            identityService.saveUser(activitiUser);

            // 删除用户的membership
            List<Group> activitiGroups = identityService.createGroupQuery().groupMember(userId).list();
            for (Group group : activitiGroups) {
                identityService.deleteMembership(userId, group.getId());
            }

            // 添加membership
            for (Long roleId : roleIds) {
                Role role = roleManager.getEntity(roleId);
                identityService.createMembership(userId, role.getEnName());
            }

        } else {
            org.activiti.engine.identity.User newUser = identityService.newUser(userId);
            newUser.setFirstName(user.getName());
            newUser.setLastName("");
            newUser.setPassword(user.getPassword());
            newUser.setEmail(user.getEmail());
            identityService.saveUser(newUser);

            // 添加membership
            for (Long roleId : roleIds) {
                Role role = roleManager.getEntity(roleId);
                identityService.createMembership(userId, role.getEnName());
            }
        }
    }

}

 

删除操作也和这个类似!

不管从业务系统维护用户还是从Activiti维护,肯定要确定一方,然后CRUD的时候同步到对方,如果需要同步多个子系统那么可以再调用WebService实现。

1.3 Activiti资料

  • 官网:

  • 下载:

  • 版本:Activiti的版本是从5开始的,因为Activiti是使用jBPM4的源码;版本发布:两个月发布一次。

  • Eclipse Plugin: 

  • Activit中文群:236540304

原标题:基于工作流的平台管理系统设计

1.简单介工作流引擎与Activiti

对于工作流引擎的解释请参考百度百科:工作流引擎

2.初次使用遇到问题收集

因为Activiti刚刚退出不久所以资料比较空缺,中文资料更是少的可怜,所以开始的时候一头雾水(虽然之前用过工作流,但是感觉差距很多),而且官方的手册还不是很全面;所以我把我在学习使用的过程遇到的一些疑问都罗列出来分享给大家;以下几点是我遇到和想到的,如果你还有什么疑问可以在评论中和我交流再补充。

图片 8

3.配置

5.3 运行中(ProcessInstance)

说白了就是没有结束的流程,所有参与过的人都应该可以看到这个实例,但是Activiti的API没有可以通过用户查询的方法,这个只能自己用hack的方式处理了,我目前还没有处理。

从表ACT_RU_EXECUTION中查询数据。

对应的API查询:

?

1
2
3
4
5
6
7
8
9
10
/**
 *
获取未经完成的流程实例查询对象
 *
@param userId    用户ID
 */
@Transactional(readOnly
=
true)
public
ProcessInstanceQuery createUnFinishedProcessInstanceQuery(String userId) {
    ProcessInstanceQuery
unfinishedQuery = runtimeService.createProcessInstanceQuery().processDefinitionKey(getProcessDefKey())
            .active();
    return
unfinishedQuery;
}

❷ 申请提交系统后, 由风控进行审核

2.1.2 使用压缩包方式部署

Activiti支持部署*.bpmn20.xml、bar、zip格式的流程定义。

使用Activit Deisigner工具设计流程图的时候会有三个类型的文件:

  • .activiti设计工具使用的文件

  • .bpmn20.xml设计工具自动根据.activiti文件生成的xml文件

  • .png流程图图片

解决办法就是把xml文件和图片文件同时部署,因为在单独部署xml文件的时候Activiti会自动生成一张流程图的图片文件,但是这样在使用的时候坐标和图片对应不起来……

所以把xml和图片同时部署的时候Activiti自动关联xml和图片,当需要获取图片的时候直接返回部署时压缩包里面的图片文件,而不是Activiti自动生成的图片文件

2.1 部署流程图后中文乱码

乱码是一直缠绕着国人的问题,之前各个技术、工具出现乱码的问题写过很多文章,这里也不例外……,Activiti的乱码问题在流程图中。

流程图的乱码如下图所示:

图片 9

解决办法有两种:

Activiti的数据库版本的自动升级. 当我们升级activiti的版本时,
其实我们只需要更新JAR的版本号, 而不用关心起底层数据库是否需要升级,
activiti在其表中会记录数据库scheme的版本号,
启动时会自动判断并根据需要自动更新数据库. 这也是非常值得借鉴的地方,
尤其是当这个模块被多个系统所使用时。

3.1 集成Spring

对于和Spring的集成Activiti做的不错,简单配置一些Bean代理即可实现,但是有两个和事务相关的地方要提示:

  • 配置processEngineConfiguration的时候属性transactionManager要使用和业务功能的同一个事务管理Bean,否则事务不同步。

  • 对于实现了org.activiti.engine.delegate包中的接口的类需要被事务控制的实现类需要被Spring代理,并且添加事务的Annotation或者在xml中配置,例如:

    /**
     * 创建缴费流程的时候自动创建实体
     *
     * @author HenryYan
     */
    @Service
    @Transactional
    publicclass CreatePaymentProcessListener implementsExecutionListener {
       ....
    }
    

?

初始的场景和需求包括:

5.各种状态的任务查询以及和业务对象关联

我们目前分为4中状态:未签收、办理中、运行中、已完成。

查询到任务或者流程实例后要显示在页面,这个时候需要添加业务数据,最终结果就是业务和流程的并集,请参考6.2

5.2 办理中(Task)

此类任务数据类源有两种:

  • 签收后的,5.1中签收后就应该为办理中状态

  • 节点指定的是具体到一个人,而不是角色

对应的API查询:

?

1
2
3
4
5
6
7
8
9
/**
 *
获取正在处理的任务查询对象
 *
@param userId    用户ID
 */
@Transactional(readOnly
=
true)
public
TaskQuery createTodoTaskQuery(String userId) {
    TaskQuery
taskAssigneeQuery = taskService.createTaskQuery().processDefinitionKey(getProcessDefKey()).taskAssignee(userId);
    return
taskAssigneeQuery;
}

图片 10

6.2 流程状态

图片 11

9.1 手动设置任务办理人

?

1
<usertask
id
="hrAudit"
name
="人事审批"
activiti:assignee
="${hrUserId}"></usertask>

动态指定任务办理人是群里面询问比较多的问题之一,其实就是一层窗户纸,只要在任务完成的时候传递activiti:assignee属性中的变量即可。


Map<String, Object> variables = new HashMap<String,
Object>();

variables.put(“hrUserId”, hrUserId);

taskService.complete(taskId, variables);


☞ 选择合适的工作流引擎

2.3.1 startProcessInstanceByKey

javadoc对其说明:

startProcessInstanceByKey(String processDefinitionKey, Map variabes) 
          Starts a new process instance in the latest version of the process definition with the given key

 

其中businessKey就是业务ID,例如要申请请假,那么先填写登记信息,然后(保存+启动流程),因为请假是单独设计的数据表,所以保存后得到实体ID就可以把它传给processInstanceBusinessKey方法启动流程。当需要根据businessKey查询流程的时候就可以通过API查询:

runtimeService.createProcessInstanceQuery().processInstanceBusinessKey(processInstanceBusinessKey, processDefinitionKey);

 

议数据库冗余设计:在业务表设计的时候添加一列:PROCESS_INSTANCE_ID varchar2(64),在流程启动之后把流程ID更新到业务表中,这样不管从业务还是流程都可以查询到对方!

特别说明: 此方法启动时自动选择最新版本的流程定义。

2.3.1 startProcessInstanceByKey

javadoc对其说明:

startProcessInstanceByKey(String processDefinitionKey, Map variables) 
          Starts a new process instance in the latest version of the process definition with the given key

其中businessKey就是业务ID,例如要申请请假,那么先填写登记信息,然后(保存+启动流程),因为请假是单独设计的数据表,所以保存后得到实体ID就可以把它传给processInstanceBusinessKey方法启动流程。当需要根据businessKey查询流程的时候就可以通过API查询:

?

1
runtimeService.createProcessInstanceQuery().processInstanceBusinessKey(processInstanceBusinessKey,
processDefinitionKey)

建议数据库冗余设计:在业务表设计的时候添加一列:PROCESS_INSTANCE_ID
varchar2(64)
,在流程启动之后把流程ID更新到业务表中,这样不管从业务还是流程都可以查询到对方!

特别说明: 此方法启动时自动选择最新版本的流程定义。

➤ 最近, 另外一个项目其应用到的场景和这个系统有类似之处,
其独立于该业务管理平台. 在这种情况下, 将该工作流相关的模块进行公共化,
以JAR包的形式提供, 使得另外一个系统的开发能够短期内达到同样的效果

5.3 运行中(ProcessInstance)

说白了就是没有结束的流程,所有参与过的人都应该可以看到这个实例,但是Activiti的API没有可以通过用户查询的方法,这个只能自己用hack的方式处理了,我目前还没有处理。

从表ACT_RU_EXECUTION中查询数据。

对应的API查询:

/**
 * 获取未经完成的流程实例查询对象
 * @param userId    用户ID
 */
@Transactional(readOnly = true)
publicProcessInstanceQuery createUnFinishedProcessInstanceQuery(String userId) {
    ProcessInstanceQuery unfinishedQuery = runtimeService.createProcessInstanceQuery().processDefinitionKey(getProcessDefKey())
            .active();
    returnunfinishedQuery;
}

?

2.5 流程图设计工具用什么

Activiti提供了两个流程设计工具,但是面向对象不同。

  • Activiti
    Modeler,面向业务人员,使用开源的BPMN设计工具Signavio,使用BPMN描述业务流程图

  • Eclipse
    Designer,面向开发人员,Eclipse的插件,可以让开发人员定制每个节点的属性(ID、Name、Listener、Attr等)

对于一个类似涉及到审批以及执行具体业务的系统, 基于简单的状态控制的设计,
或者自行开发类工作流引擎轮子的做法都是不合适.
所以一个开源并且被广泛使用的工作流引擎是一个正确而且必须的选择. Activiti
工作流引擎由于其轻量级, 易用性等优点目前在业界被广泛使用.
其工作流的状态机和外部系统的连接只需要通过一个ID进行关联即可,
即activiti的business key. (如下图)

8.结束

之前就想写这篇文章,现在终于完成了,花费了几个小时,希望能节省你几天的时间。

请读者仔细阅读Activiti的用户手册和Javadoc。

来自:

6.3 流程跟踪

图片方式显示当前节点:

图片 12

列表形式显示流程流转过程:

图片 13

➤RequestQuery支持统一的查询入口对业务流程数据进行查询

5.2 办理中(Task)

此类任务数据类源有两种:

  • 签收后的,5.1中签收后就应该为办理中状态

  • 节点指定的是具体到一个人,而不是角色

对应的API查询:

/**
 * 获取正在处理的任务查询对象
 * @param userId    用户ID
 */
@Transactional(readOnly = true)
publicTaskQuery createTodoTaskQuery(String userId) {
    TaskQuery taskAssigneeQuery = taskService.createTaskQuery().processDefinitionKey(getProcessDefKey()).taskAssignee(userId);
    returntaskAssigneeQuery;
}

?

1.2 Activiti与JBPM5?

对于Activiti、jBPM4、jBPM5我们应该如何选择,在InfoQ上有一篇文章写的很好,从大的层面比较各个引擎之间的差异,请参考文章:纵观jBPM:从jBPM3到jBPM5以及Activiti5

图片 14

1.3 Activiti资料

  • 官网:

  • 下载:

  • 版本:Activiti的版本是从5开始的,因为Activiti是使用jBPM4的源码;版本发布:两个月发布一次。

  • Eclipse Plugin: 

  • Activit中文群:5435716

9.动态指定任务办理人

演进过程

2.2.1 引擎提供的Form

定义表单的方式在每个Task标签中定义extensionElementsactiviti:formProperty即可,到达这个节点的时候可以通过API读取表单元素。

Activiti官方的例子使用的就是在流程定义中设置每一个节点显示什么样的表单哪些字段需要显示、哪些字段只读、哪些字段必填。

但是这种方式仅仅适用于比较简单的流程,对于稍微复杂或者页面需要业务逻辑的判断的情况就不适用了。

对于数据的保存都是在引擎的表中,不利于和其他表的关联、对整个系统的规划也不利!

10. 任务代办

很多人问“Owner”属性为什么是空的,什么时候用?要了解它的作用首先要了解“代办”。

代办的概念可以用下面的一句话概括:

你领导接到一个任务,让你代办,你办理完成后任务还是回归到你的领导,事情是你做的,功劳是你领导的,此乃代办也!

看到这个单元测试你就明白什么是代办:ProcessTestDelegateTask

最好把activiti-study这个项目下载下来导入到Eclipse中运行一下:

原创文章,转载请注明:转载自:工作流引擎Activiti使用总结

下图为基本的架构设计

2.2 使用引擎提供的Form还是自定义业务Form

2.1.2 使用压缩包方式部署

Activiti支持部署*.bpmn20.xml、bar、zip格式的流程定义。

使用Activit Deisigner工具设计流程图的时候会有三个类型的文件:

  • .activiti设计工具使用的文件

  • .bpmn20.xml设计工具自动根据.activiti文件生成的xml文件

  • .png流程图图片

解决办法就是把xml文件和图片文件同时部署,因为在单独部署xml文件的时候Activiti会自动生成一张流程图的图片文件,但是这样在使用的时候坐标和图片对应不起来……

所以把xml和图片同时部署的时候Activiti自动关联xml和图片,当需要获取图片的时候直接返回部署时压缩包里面的图片文件,而不是Activiti自动生成的图片文件

责任编辑:

Activiti工作流引擎使用

4.使用单元测试

单元测试均使用Spring的AbstractTransactionalJUnit4SpringContextTests作为SuperClass,并且在测试类添加:

?

1
2
@ContextConfiguration(locations
= {
"/applicationContext-test.xml"
})
@RunWith(SpringJUnit4ClassRunner.class)

虽然Activiti也提供了测试的一些超类,但是感觉不好用,所以自己封装了一些方法。

代码请转移:

➤可配置化的根据业务类型(Request Type)
和配置(process_cfg)在运行时动态设置流程相应的处理人/组

2.5 流程图设计工具用什么

Activiti提供了两个流程设计工具,但是面向对象不同。

  • Activiti
    Modeler,面向业务人员,使用开源的BPMN设计工具Signavio,使用BPMN描述业务流程图

  • Eclipse
    Designer,面向开发人员,Eclipse的插件,可以让开发人员定制每个节点的属性(ID、Name、Listener、Attr等)

2.1.2.2 使用Ant脚本打包Zip文件

这也是我们采用的办法,你可以手动选择xml和png打包成zip格式的文件,也可以像我们一样采用ant
target的方式打包这两个文件。

123456789101112
<?xml version="1.0" encoding="UTF-8"?><project name="foo">     <property name="workflow.definition" value="foo-common-core/src/main/resources/diagrams" />    <property name="workflow.deployments" value="foo-common-core/src/main/resources/deployments" /> <target name="workflow.package.oa.leave">     <echo>打包流程定义及流程图::OA-请假</echo>        <zip destfile="${workflow.deployments}/oa/leave.zip" basedir="${workflow.definition}/oa/leave" update="true"            includes="*.xml,*.png" /> </target></project>

view
rawbuild.xml hosted
with ❤ by GitHub

这样当修改流程定义文件后只要运行ant命令就可以打包了:

ant workflow.package.oa.leave

现在部署bar或者zip文件查看流程图图片就不是乱码了,而是你的压缩包里面的png文件。

◆✦以下对第二、三点进行展开✦◆

2.1.2.1 使用工具打包Bar文件

右键项目名称然后点击“Create deployment
artifacts”,会在src目录中创建deployment文件夹,里面包含*.bar文件.

2.1.2.1 使用工具打包Bar文件

在“Package Explorer”视图中右键项目名称然后点击“Create deployment
artifacts”,会在src目录中创建deployment文件夹,里面包含*.bar文件.

发起流程的主要原因是用户希望按照合同进行提前还款. 流程关键步骤为:

6.1 单独一个列表负责申请

这样的好处是申请和流程办理分离开处理,列表显示未启动流程的请假记录(数据库PROCESS_INSTANCE_ID为空)。

申请界面的截图:

图片 15

3.配置

➤ WorkflowService对工作流引擎的封装

7.开启Logger

  1. 添加log4j的jar
  2. 设置log4j.logger.java.sql=DEBUG

2.3.2 startProcessInstanceById

javadoc对其说明:

startProcessInstanceById(String processDefinitionId, String businessKey, Map variables) 
          Starts a new process instance in the exactly specified version of the process definition with the given id.

processDefinitionId:这个参数的值可以通过repositoryService.createProcessDefinitionQuery()方法查询,对应数据库:ACT_RE_PROCDEF;每次部署一次流程定义就会添加一条数据,同名的版本号累加。

特别说明: 此可以指定不同版本的流程定义,让用户多一层选择。

基于这样的框架完成基础代码后,
最终对于一个实现具体业务的开发人员来说, 其实
现一个业务流程代码主要包括:

2.5.1 我们的方式

可能你会惊讶,因为我们没有使用Activiti
Modeler,我们认为用Viso已经能表达流程图的意思了,而且项目经理也是技术出身,和开发人员也容易沟通。

目前这个项目是第一个使用Activiti的,开始我们在需求调研阶段使用Viso设计流程图,利用泳道流程图设计和客户沟通,确定后由负责流程的开发人员用Eclipse
Designer设计得到bpmn20.xml,最后部署。

2.2.1 引擎提供的Form

定义表单的方式在每个Task标签中定义extensionElementsactiviti:formProperty即可,到达这个节点的时候可以通过API读取表单元素。

Activiti官方的例子使用的就是在流程定义中设置每一个节点显示什么样的表单哪些字段需要显示、哪些字段只读、哪些字段必填。

但是这种方式仅仅适用于比较简单的流程,对于稍微复杂或者页面需要业务逻辑的判断的情况就不适用了。

对于数据的保存都是在引擎的表中,不利于和其他表的关联、对整个系统的规划也不利!

哪一种实现更好?

1.1 我与工作流引擎

在第一家公司工作的时候主要任务就是开发OA系统,当然基本都是有工作流的支持,不过当时使用的工作流引擎是公司一些牛人开发的(据说是用一个开源的引擎修改的),名称叫CoreFlow;功能相对Activiti来说比较弱,但是能满足日常的使用,当然也有不少的问题所以后来我们只能修改引擎的代码打补丁。

现在是我工作的第二家公司,因为要开发ERP、OA等系统需要使用工作流,在项目调研阶段我先搜索资料选择使用哪个开源工作流引擎,最终确定了Activiti5并基于公司的架构做了一些DEMO。

数据库设计

3.1 集成Spring

对于和Spring的集成Activiti做的不错,简单配置一些Bean代理即可实现,但是有两个和事务相关的地方要提示:

  • 配置processEngineConfiguration的时候属性transactionManager要使用和业务功能的同一个事务管理Bean,否则事务不同步。

  • 对于实现了org.activiti.engine.delegate包中的接口的类需要被事务控制的实现类需要被Spring代理,并且添加事务的Annotation或者在xml中配置,例如:

?

1
2
3
4
5
6
7
8
9
10
/**
 *
创建缴费流程的时候自动创建实体
 *
 *
@author HenryYan
 */
@Service
@Transactional
public
class

CreatePaymentProcessListener
implements
ExecutionListener {
   ....
}
  1. 将流程涉及的processor和对应的业务类型,
    流程名, 流程步骤进行注册绑定

2.1.1 修改源代码方式

修改源码

org.activiti.engine.impl.bpmn.diagram.ProcessDiagramCanvas

在构造方法

public ProcessDiagramCanvas(int width, int height)

中有一行代码是设置字体的,默认是用Arial字体,这就是乱码产生的原因,把字改为本地的中文字体即可,例如:

?

1
Font
font =
new
Font(
"WenQuanYi
Micro Hei"
,
Font.BOLD,
11);

当然如果你有配置文件读取工具那么可以设置在*.properties文件中,我就是这么做的:

?

1
Font
font =
new
Font(PropertyFileUtil.get(
"activiti.diagram.canvas.font"),
Font.BOLD,
11);

5.12版本开始支持设置字体名称,在引擎中添加如下设置,在生成图片时即可使用微软雅黑设置图片中的文字。

?

1
<property
name
="activityFontName"
value
="微软雅黑"></property>

该流程发起原因主要是由于借款人银行卡变更原因需要修改. 流程关键步骤为:

5.各种状态的任务查询以及和业务对象关联

我们目前分为4中状态:未签收、办理中、运行中、已完成。

查询到任务或者流程实例后要显示在页面,这个时候需要添加业务数据,最终结果就是业务和流程的并集,请参考6.2

  1. 能够满足不同的业务域的需求, 如出借, 借款, 资金相关的具体业务数据

  2. 能够记录每一步的操作审批或业务执行结果, 同时记录相关的数据快照

2.4 同步用户数据

这个问题也是比较多的人询问过,Activiti支持对任务分配到:指定人、指定组、两者组合,而这些人和组的信息都保存在ACT_ID..表中,有自己的用户和组(角色)管理让很多人不知所措了;原因是因为每个系统都会存在一个权限管理模块(维护:用户、部门、角色、授权),不知道该怎么和Activiti同步。

❸ 运营部门进行修改操

正如上面曾说到, 对于一个系统设计, 不可能一步到位,
在最初时要抓住最需要解决的问题, 比如在这个系统开始阶段,
最核心的设计包括:

Property表里是否需要需要用不同的字段(LONG_VALUE,
TEXT_VALUE, DOUBLE_VALUE等)存不同类型的值;还是直接都存成字符串,
在代码中再根据需要转成Long, Double等?当然两种实现都是可行的,
并且各有优缺点,
并且个人觉得存在不同的字段上优点更大一些(主要体现在查询效率),
但是如何更加的让自己信服?
在看activiti的文档时发现外部的业务数据以Map的方式存在activiti的数据库中,
那么activiti的设计者一样会碰到同样的问题.
通过查看源代码以及其数据库设计, 发现其将数据存入不同的字段.
但是在我的设计中, 我并没有完全照搬Activiti的处理方式, 比如:
我没有为布尔类型加单独的字段,
而是以0或者1的方式存入LONG_VALUE里。

◆✦下面为两个典型的业务流程✦◆

❶ 借款人联系客服人员, 提交申请

为了解决#1的问题,
则需要定义出流程–步骤—业务(请求类型)—处理人/组 的配置 关系,
并在流程流转时自动设置, 而不是在流程描述文件 (bpmn)里 指定

(注: 为了说明方便, 已经简化和修改相关步骤, 和点融实际操作不一致)

这里举几个例子

图片 16返回搜狐,查看更多

在平台的实际运营中, 有各种各样的业务需要处理, 包括借款人, 出借人,
资金等等, 同时还涉及到各个不同的业务部门,
而且流程的流转操作人员和部门也随着公司业务的发展而不同的调整.
设计一个基础的流程框架和实现基础代码, 形成简洁的开发模式是该系统的关键.
因此整个系统的设计涉及到以下主要几个方面:

别人的系统是如何实现的?

图片 17

❷ 运营生成提前还款说明书, 其包括详细金额数据

公共化工作流模块:

在设计和实现该系统时会有

一个Request代表某一个人发起的请求, Snapshot代表这个流程的每一步操作.
Property则分别为Request的Snapshot的具体的数据,
当其REQUEST_ID非空SNAPSHOT_ID为空时表示其为REQUEST的属性(SNAPSHOT同理),
即用户发起请求所带入的数据. 如: 用户信息修改:
PROPERTY则包括NAME(KEY)为USER_ID(用户唯一ID),
ATTACHMENT(用户手持身份证照片), EMAIL(修改项)等相应的值. 而对于SNAPSHOT,
则记录对应审核以及操作的信息,
其对应的PROPERTY则保存了对某个数据修改前后的值.

  1. 实现一个创建Request的页面,
    用于录入业务数据

  2. 实现一个Request详细页面, 用于展示详情,
    包括操作历史, 和业务操作按钮

所以, 基于具体的业务进行数据表的设计是不合适的, 且无法扩展.
常见的设计为基于Key-Value的设计,
而key则是各个不同业务系统涉及到的metadata. 如USER_ID(用户ID),
LOAN_ID(借款ID)等等. 设计概述如下:

借鉴Activiti的源代码

➤将各种处理类(业务处理类, 流程处理人/组分配处理类, 通知处理类)
通过RegisterService的统一注册管理,
并且支持应用对于特定的流程实现特定的处理类来替代默认的处理类

❸ 借款人确认, 通过客服服务人员上传签字照片