Activiti5小试牛刀demo流程

demo流程目标：刚接触Activiti5，先大致了解下Activiti5的架构，熟悉下开发流程

搭建开发环境

首先给MyEclipse安装Activiti Designer插件，下载网址http://www.activiti.org/designer/archived/
当然也可以在线安装，网址http://www.activiti.org/designer/update
有可能因为版本不兼容安装不上，不过也不要紧，只是小试牛刀，并不影响demo流程的开发，后面会介绍Web版流程设计器

此外，新建一个java project，然后把activiti-explorer\WEB-INF\lib下面的jar包全部导入

设计示例流程

如果已经按安装好了Activiti Designer插件，直接使用就可以了，如果安装失败，先临时下载一个流程的定义文件，参考网址：http://yiyiboy2010.iteye.com/blog/1530924

编写测试代码

工程的代码结构如下：

测试的代码

import java.util.List;

import org.activiti.engine.HistoryService;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngineConfiguration;
import org.activiti.engine.RepositoryService;
import org.activiti.engine.RuntimeService;
import org.activiti.engine.TaskService;
import org.activiti.engine.history.HistoricProcessInstance;
import org.activiti.engine.task.Task;

public class Test {

    // 本流程模拟的是某公司2012年实习生招聘流程
    // 张三来参加该招聘流程，公司相关负责人负责处理流程
    public static void main(String[] args) {
        // 加载配置文件
        ProcessEngine processEngine = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource("activiti.cfg.xml").buildProcessEngine();
        RepositoryService repositoryService = processEngine.getRepositoryService();
        repositoryService.createDeployment().addClasspathResource("resources/diagrams/Interview.bpmn20.xml").deploy();
        RuntimeService runtimeService = processEngine.getRuntimeService();
        String processId = runtimeService.startProcessInstanceByKey("Interview").getId();

        TaskService taskService = processEngine.getTaskService();
        HistoryService historyService = processEngine.getHistoryService();
        // 得到笔试的流程
        System.out.println("***************笔试流程开始***************");
        List<Task> tasks = taskService.createTaskQuery().taskCandidateGroup("人力资源部").list();
        for (Task task : tasks) {
            System.out.println("人力资源部的任务：name:" + task.getName() + ",id:" + task.getId());
            taskService.claim(task.getId(), "张三");

        }
        System.out.println("张三的任务数量：" + taskService.createTaskQuery().taskAssignee("张三").count());
        tasks = taskService.createTaskQuery().taskAssignee("张三").list();
        for (Task task : tasks) {
            System.out.println("张三的任务：name:" + task.getName() + ",id:" + task.getId());
            taskService.complete(task.getId());
        }
        System.out.println("张三的任务数量：" + taskService.createTaskQuery().taskAssignee("张三").count());
        System.out.println("***************笔试流程结束***************");

        System.out.println("***************一面流程开始***************");
        tasks = taskService.createTaskQuery().taskCandidateGroup("技术部").list();
        for (Task task : tasks) {
            System.out.println("技术部的任务：name:" + task.getName() + ",id:" + task.getId());
            taskService.claim(task.getId(), "李四");
        }
        System.out.println("李四的任务数量：" + taskService.createTaskQuery().taskAssignee("李四").count());
        for (Task task : tasks) {
            System.out.println("李四的任务：name:" + task.getName() + ",id:" + task.getId());
            taskService.complete(task.getId());
        }
        System.out.println("李四的任务数量：" + taskService.createTaskQuery().taskAssignee("李四").count());
        System.out.println("***************一面流程结束***************");

        System.out.println("***************二面流程开始***************");
        tasks = taskService.createTaskQuery().taskCandidateGroup("技术部").list();
        for (Task task : tasks) {
            System.out.println("技术部的任务：name:" + task.getName() + ",id:" + task.getId());
            taskService.claim(task.getId(), "李四");
        }
        System.out.println("李四的任务数量：" + taskService.createTaskQuery().taskAssignee("李四").count());
        for (Task task : tasks) {
            System.out.println("李四的任务：name:" + task.getName() + ",id:" + task.getId());
            taskService.complete(task.getId());
        }
        System.out.println("李四的任务数量：" + taskService.createTaskQuery().taskAssignee("李四").count());
        System.out.println("***************二面流程结束***************");

        System.out.println("***************HR面流程开始***************");
        tasks = taskService.createTaskQuery().taskCandidateGroup("人力资源部").list();
        for (Task task : tasks) {
            System.out.println("技术部的任务：name:" + task.getName() + ",id:" + task.getId());
            taskService.claim(task.getId(), "李四");
        }
        System.out.println("李四的任务数量：" + taskService.createTaskQuery().taskAssignee("李四").count());
        for (Task task : tasks) {
            System.out.println("李四的任务：name:" + task.getName() + ",id:" + task.getId());
            taskService.complete(task.getId());
        }
        System.out.println("李四的任务数量：" + taskService.createTaskQuery().taskAssignee("李四").count());
        System.out.println("***************HR面流程结束***************");

        System.out.println("***************录用流程开始***************");
        tasks = taskService.createTaskQuery().taskCandidateGroup("人力资源部").list();
        for (Task task : tasks) {
            System.out.println("技术部的任务：name:" + task.getName() + ",id:" + task.getId());
            taskService.claim(task.getId(), "李四");
        }
        System.out.println("李四的任务数量：" + taskService.createTaskQuery().taskAssignee("李四").count());
        for (Task task : tasks) {
            System.out.println("李四的任务：name:" + task.getName() + ",id:" + task.getId());
            taskService.complete(task.getId());
        }
        System.out.println("李四的任务数量：" + taskService.createTaskQuery().taskAssignee("李四").count());
        System.out.println("***************录用流程结束***************");

        HistoricProcessInstance historicProcessInstance = historyService.createHistoricProcessInstanceQuery().processInstanceId(processId).singleResult();
        System.out.println("流程结束时间：" + historicProcessInstance.getEndTime());
        System.exit(0);
    }
}

参考网址：http://yiyiboy2010.iteye.com/blog/1530924

这里需要特别说明的是，测试的代码编写好之后，如果要运行，必须有一个Activiti的数据库环境，修改activiti.cfg.xml如下：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.springframework.org/schema/beans   http://www.springframework.org/schema/beans/spring-beans.xsd">
    <bean id="processEngineConfiguration"
        class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">
        <property name="databaseSchemaUpdate" value="true" />
        <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/activiti5" />
        <property name="jdbcDriver" value="com.mysql.jdbc.Driver" />
        <property name="jdbcUsername" value="root" />
        <property name="jdbcPassword" value="admin" />
        <property name="jobExecutorActivate" value="true" />
    </bean>
</beans>

到这里，demo流程就可以跑起来了，不出意外的话，测试代码都可以正常运行

<script type="text/javascript"> $(function () { $('pre.prettyprint code').each(function () { var lines = $(this).text().split('\n').length; var $numbering = $('<ul/>').addClass('pre-numbering').hide(); $(this).addClass('has-numbering').parent().append($numbering); for (i = 1; i <= lines; i++) { $numbering.append($('<li/>').text(i)); }; $numbering.fadeIn(1700); }); }); </script>