<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd"> <html><head><meta http-equiv="Cont

  1. 云栖社区>
  2. 博客>
  3. 正文

<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd"> <html><head><meta http-equiv="Cont

攻城师10946 浏览587
展开阅读全文

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流程就可以跑起来了,不出意外的话,测试代码都可以正常运行

网友评论

登录后评论
0/500
评论
攻城师10946
+ 关注