首先,idea下新创建一个project,结构如下:
使用activiti需要引入配置,另外还要有数据库,这里使用mysql,如下:
然后,需要配置数据源链接,便于activiti生成数据库表,打开数据库,创建一个空库做准备。
在resources目录下,新建activiti.cfg.xml,配置bean如下:
执行后,数据库中生成的表如下,默认会有24张:
接着,继续在resources目录下,新建activitiDemo.bpmn,使用一些基础的控件拖拽,做些简单配置,如下:
点击task控件,旁边会出现属性配置界面,需要设置Name和Assignee,如下:
点击底部可以切换界面和xml配置,从配置中,可以看到process节点,userTask等节点的具体属性,如下:
现在,可以编写用例,测试了,首先,需要用到的配置和属性如下:
String cfgName ="activiti.cfg.xml";
String taskId ="";
String assignee ="employee";
String process ="myProcess_1";
String deployName ="activitiDemo.bpmn";
第一步:读取配置初始化
@Test public void testCreateProcessEngineByCfgXml() { ProcessEngineConfiguration cfg = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource(cfgName); processEngine = cfg.buildProcessEngine(); logger.info("根据配置文件"+cfgName+"创建ProcessEngine成功"); }
第二步:发布
@Test
public void deployProcess() {
RepositoryService repositoryService =processEngine.getRepositoryService();
DeploymentBuilder builder = repositoryService.createDeployment();
builder.addClasspathResource(deployName);
builder.deploy();
logger.info("发布流程"+deployName+"成功");
}
第三步:启动
@Test
public void startProcess() {
RuntimeService runtimeService =processEngine.getRuntimeService();
//可根据id、key、message启动流程
runtimeService.startProcessInstanceByKey(process);
logger.info("启动流程"+process+"成功");
}
第四步:执行
@Test
public void queryExecTask() {
TaskService taskService =processEngine.getTaskService();
//根据assignee(代理人)查询任务
List tasks = taskService.createTaskQuery().taskAssignee(assignee).list();
Calendar calendar = Calendar.getInstance();
for (Task task : tasks) {
taskId= task.getId();
calendar.setTime(task.getCreateTime());
logger.info("查看任务:taskId:" +taskId +
",taskName:" + task.getName() +
",assignee:" + task.getAssignee() +
",createTime:" +sdf.format(calendar.getTime()));
handleTask();
}
}
@Test
public void handleTask() {
TaskService taskService =processEngine.getTaskService();
taskService.complete(taskId);
logger.info("执行任务taskId:" +taskId +" complete");
}
执行用例,打印出结果,执行任务时,程序筛选了employee组中的task,使用中需要留意多个task执行的顺序,log如下: