Activiti Demo

BPMN

BPMN(Business Process Modeling Notation)是一个重要的工作流建模语言的规范。它利用标准的图元去描述真实的业务发生过程，保证相同的流程在不同的流程引擎得到的执行结果一致。

本demo中业务流程：用户发起请假，然后经理审批，如果请假时间比较短，请假完成，流程结束；如果请假超过3天，转给总经理审批，然后才能请假完成。

用到的BPMN图

业务流程图

activiti配置

    <dependency>
      <groupId>org.activiti</groupId>
      <artifactId>activiti-engine</artifactId>
      <version>${activiti-version}</version>
    </dependency>
    <dependency>
      <groupId>org.activiti</groupId>
      <artifactId>activiti-spring</artifactId>
      <version>${activiti-version}</version>
    </dependency>

创建数据库

本demo在本地运行，首先需要在本地数据库创建schema(此处为activiti-demo)。
然后运行以下代码，创建activiti引擎需要的25张表(acitivti提供了创建这些表需要的sql,也可以手动创建)

        ProcessEngineConfiguration processEngineConfiguration = ProcessEngineConfiguration.createStandaloneProcessEngineConfiguration();

        processEngineConfiguration.setJdbcDriver("com.mysql.jdbc.Driver");
        processEngineConfiguration.setJdbcUrl("jdbc:mysql://localhost:3306/activiti-demo?useUnicode=true&characterEncoding=utf8");
        processEngineConfiguration.setJdbcUsername("root");
        processEngineConfiguration.setJdbcPassword("root");

        processEngineConfiguration.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);
        ProcessEngine processEngine = processEngineConfiguration.buildProcessEngine();
        System.out.println("processEngine"+processEngine);

部署一个工作流程

    ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();

    @Test
    public void startDeployment(){
        Deployment deployment = processEngine.getRepositoryService()
                .createDeployment()
                .addClasspathResource("diagrams/VariableUsersDemo.bpmn")
                .addClasspathResource("diagrams/VariableUsersDemo.png")
                .deploy();
        System.out.println("Deploy deploy ID: " + deployment.getId());


    }
    

png文件可以不添加，只是用作用户查看流程。

开始一个流程实例

        public void startProcessInstance(){

        String deployKey = "variableProcess";

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

        variables.put("user","jianke");
        variables.put("manager","caohao");
        variables.put("boss","zhangqi");

        RuntimeService runtimeService = processEngine.getRuntimeService();
        ProcessInstance processInstance = runtimeService.startProcessInstanceByKey(deployKey, variables);
         String processInstanceID = processInstance.getId();
        System.out.println("流程实例ID: " + processInstanceID);



    }

variables保存一些该流程需要的变量，此处用来保存了一些人员信息，即何人发起，需要何人进行审批。
user,manager,boss这些字段是在流程图中设置的。

BPMN中设置人员信息

给该实例附加请假信息

        TaskService service = processEngine.getTaskService();
        List<Task> list = service.createTaskQuery().processInstanceId(processInstanceID).taskCandidateUser("jianke")
                .list();
        for(Task task:list){
            System.out.println("Task ID : " + task.getId() + "   " + task.getName());
            service.claim(task.getId(),"jianke"); //确定请假任务
            Leave leave = new Leave();
            leave.setName("jianke");
            leave.setContent("Go to Sleep");
            leave.setCreateTime(new Date());
            leave.setDays(5);
            service.setVariable(task.getId(), "info", leave); //添加请假信息
            service.complete(task.getId()); //完成请假，提交审批
        }

经理审批

        List<Task> list = service.createTaskQuery().processInstanceId(processInstanceID).taskCandidateUser("caohao")
                .list();   //搜索等待主管处理的任务
        for(Task task:list){
            System.out.println("Task ID : " + task.getId() + "   " + task.getName());
            service.claim(task.getId(), "caohao"); //主管接受任务
            Leave leave = (Leave)service.getVariable(task.getId(),"info");

            Map<String,Object> object = new HashMap<>();
            object.put("days", leave.getDays());
            service.complete(task.getId(), object);  //主管审批，并附带请假天数信息，交给引擎处理是否需要总经理审批
            System.out.println("complete!");
        }

在BPMN中添加是否总经理审批的判断：

BPMN中添加判断逻辑

总经理审批

            //操作流程同经理审批
        TaskService service = processEngine.getTaskService();
        List<Task> list = service.createTaskQuery().processInstanceId(processInstanceID).taskCandidateUser("zhangqi")
                .list();
        for(Task task:list){
            System.out.println("Task ID : " + task.getId() + "   " + task.getName());
            service.claim(task.getId(), "zhangqi");
            
              service.complete(task.getId());
            System.out.println("complete!");
        }

请假流程完成通知

public class endListener implements ExecutionListener {

    @Override
    public void notify(DelegateExecution delegateTask){
         //在此处进行请假完成后的操作，比较通知请假人，记录档案等
         
         
        System.out.println("Task End!");
    }

}

给结束节点添加通知的方法，在BPMN图中添加：

BPMN中添加通知

附上原码地址，大家一起学习探讨：
https://github.com/qixiaojian/activiti-demo.git