activiti02

二级审批流程的实现

1.设计一个二级审批流程

2.创建三个不同用户组为流程参与者

3.参与者协同完成流程

second_approve.bpmn 设计

对应xml文件如下

<?xml version="1.0" encoding="UTF-8"?>
<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC" xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI" typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="http://www.activiti.org/test">
  <process id="LeaveProcess" name="请假流程" isExecutable="true">
    <startEvent id="startevent" name="开始"></startEvent>
    <userTask id="submitform" name="填写请假申请">
      <extensionElements>
        <activiti:formProperty id="message" name="申请信息" type="string" required="true"></activiti:formProperty>
        <activiti:formProperty id="name" name="申请人姓名" type="string" required="true"></activiti:formProperty>
        <activiti:formProperty id="submitTime" name="提交时间" type="date" datePattern="yyyy-MM-dd" required="true"></activiti:formProperty>
        <activiti:formProperty id="submitType" name="确认申请" type="string" required="true"></activiti:formProperty>
      </extensionElements>
    </userTask>
    <sequenceFlow id="flow1" sourceRef="startevent" targetRef="submitform"></sequenceFlow>
    <exclusiveGateway id="decideSubmit" name="提交或取消"></exclusiveGateway>
    <sequenceFlow id="flow2" sourceRef="submitform" targetRef="decideSubmit"></sequenceFlow>
    <userTask id="ZG_approve" name="部门主管审批">
      <extensionElements>
        <activiti:formProperty id="ZGapprove" name="主管审批结果" type="string" required="true"></activiti:formProperty>
        <activiti:formProperty id="ZGmessage" name="主管备注" type="string" required="true"></activiti:formProperty>
      </extensionElements>
    </userTask>
    <sequenceFlow id="flow3" sourceRef="decideSubmit" targetRef="ZG_approve">
      <conditionExpression xsi:type="tFormalExpression"><![CDATA[${submitType=="y" || submitType=="Y"}]]></conditionExpression>
    </sequenceFlow>
    <exclusiveGateway id="decideZGapprove" name="主管审批校验"></exclusiveGateway>
    <sequenceFlow id="flow4" sourceRef="ZG_approve" targetRef="decideZGapprove"></sequenceFlow>
    <userTask id="ZJL_approve" name="总经理审批">
      <extensionElements>
        <activiti:formProperty id="ZJLapprove" name="总经理审批结果" type="string" required="true"></activiti:formProperty>
        <activiti:formProperty id="ZJLmessage" name="总经理备注" type="string" required="true"></activiti:formProperty>
      </extensionElements>
    </userTask>
    <sequenceFlow id="flow5" sourceRef="decideZGapprove" targetRef="ZJL_approve">
      <conditionExpression xsi:type="tFormalExpression"><![CDATA[${ZGapprove=="y" || ZGapprove=="Y"}]]></conditionExpression>
    </sequenceFlow>
    <exclusiveGateway id="decideZJLapprove" name="总经理审批校验"></exclusiveGateway>
    <sequenceFlow id="flow6" sourceRef="ZJL_approve" targetRef="decideZJLapprove"></sequenceFlow>
    <endEvent id="endevent" name="结束"></endEvent>
    <sequenceFlow id="flow7" sourceRef="decideZJLapprove" targetRef="endevent">
      <conditionExpression xsi:type="tFormalExpression"><![CDATA[${ZJLapprove=="y" || ZJLapprove=="Y"}]]></conditionExpression>
    </sequenceFlow>
    <endEvent id="endeventCancel" name="取消"></endEvent>
    <sequenceFlow id="flow8" sourceRef="decideSubmit" targetRef="endeventCancel">
      <conditionExpression xsi:type="tFormalExpression"><![CDATA[${submitType=="n" || submitType=="N"}]]></conditionExpression>
    </sequenceFlow>
    <sequenceFlow id="flow9" sourceRef="decideZGapprove" targetRef="submitform">
      <conditionExpression xsi:type="tFormalExpression"><![CDATA[${ZGapprove=="n" || ZGapprove=="N"}]]></conditionExpression>
    </sequenceFlow>
    <sequenceFlow id="flow10" sourceRef="decideZJLapprove" targetRef="submitform">
      <conditionExpression xsi:type="tFormalExpression"><![CDATA[${ZJLapprove=="n" || ZJLapprove=="N"}]]></conditionExpression>
    </sequenceFlow>
  </process>
  <bpmndi:BPMNDiagram id="BPMNDiagram_LeaveProcess">
    <bpmndi:BPMNPlane bpmnElement="LeaveProcess" id="BPMNPlane_LeaveProcess">
      <bpmndi:BPMNShape bpmnElement="startevent" id="BPMNShape_startevent">
        <omgdc:Bounds height="35.0" width="35.0" x="65.0" y="279.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="submitform" id="BPMNShape_submitform">
        <omgdc:Bounds height="55.0" width="105.0" x="145.0" y="269.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="decideSubmit" id="BPMNShape_decideSubmit">
        <omgdc:Bounds height="40.0" width="40.0" x="295.0" y="277.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="ZG_approve" id="BPMNShape_ZG_approve">
        <omgdc:Bounds height="55.0" width="105.0" x="380.0" y="270.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="decideZGapprove" id="BPMNShape_decideZGapprove">
        <omgdc:Bounds height="40.0" width="40.0" x="530.0" y="278.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="ZJL_approve" id="BPMNShape_ZJL_approve">
        <omgdc:Bounds height="55.0" width="105.0" x="615.0" y="271.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="decideZJLapprove" id="BPMNShape_decideZJLapprove">
        <omgdc:Bounds height="40.0" width="40.0" x="765.0" y="279.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="endevent" id="BPMNShape_endevent">
        <omgdc:Bounds height="35.0" width="35.0" x="850.0" y="282.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="endeventCancel" id="BPMNShape_endeventCancel">
        <omgdc:Bounds height="35.0" width="35.0" x="395.0" y="329.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNEdge bpmnElement="flow1" id="BPMNEdge_flow1">
        <omgdi:waypoint x="100.0" y="296.0"></omgdi:waypoint>
        <omgdi:waypoint x="145.0" y="296.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="flow2" id="BPMNEdge_flow2">
        <omgdi:waypoint x="250.0" y="296.0"></omgdi:waypoint>
        <omgdi:waypoint x="295.0" y="297.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="flow3" id="BPMNEdge_flow3">
        <omgdi:waypoint x="335.0" y="297.0"></omgdi:waypoint>
        <omgdi:waypoint x="380.0" y="297.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="flow4" id="BPMNEdge_flow4">
        <omgdi:waypoint x="485.0" y="297.0"></omgdi:waypoint>
        <omgdi:waypoint x="530.0" y="298.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="flow5" id="BPMNEdge_flow5">
        <omgdi:waypoint x="570.0" y="298.0"></omgdi:waypoint>
        <omgdi:waypoint x="615.0" y="298.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="flow6" id="BPMNEdge_flow6">
        <omgdi:waypoint x="720.0" y="298.0"></omgdi:waypoint>
        <omgdi:waypoint x="765.0" y="299.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="flow7" id="BPMNEdge_flow7">
        <omgdi:waypoint x="805.0" y="299.0"></omgdi:waypoint>
        <omgdi:waypoint x="850.0" y="299.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="flow8" id="BPMNEdge_flow8">
        <omgdi:waypoint x="315.0" y="317.0"></omgdi:waypoint>
        <omgdi:waypoint x="315.0" y="346.0"></omgdi:waypoint>
        <omgdi:waypoint x="395.0" y="346.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="flow9" id="BPMNEdge_flow9">
        <omgdi:waypoint x="550.0" y="318.0"></omgdi:waypoint>
        <omgdi:waypoint x="549.0" y="382.0"></omgdi:waypoint>
        <omgdi:waypoint x="397.0" y="382.0"></omgdi:waypoint>
        <omgdi:waypoint x="197.0" y="382.0"></omgdi:waypoint>
        <omgdi:waypoint x="197.0" y="324.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="flow10" id="BPMNEdge_flow10">
        <omgdi:waypoint x="785.0" y="279.0"></omgdi:waypoint>
        <omgdi:waypoint x="784.0" y="222.0"></omgdi:waypoint>
        <omgdi:waypoint x="505.0" y="222.0"></omgdi:waypoint>
        <omgdi:waypoint x="197.0" y="222.0"></omgdi:waypoint>
        <omgdi:waypoint x="197.0" y="269.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
    </bpmndi:BPMNPlane>
  </bpmndi:BPMNDiagram>
</definitions>

新建springboot工程

引入依赖

 <dependencies>

        <dependency>
            <groupId>org.activiti</groupId>
            <artifactId>activiti-engine</artifactId>
            <version>6.0.0</version>
        </dependency>

        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.11</version>
            <scope>test</scope>
        </dependency>
 
        <dependency>
            <groupId>ch.qos.logback</groupId>
            <artifactId>logback-classic</artifactId>
            <version>1.1.11</version>
        </dependency>
 
        <dependency>
            <groupId>com.google.guava</groupId>
            <artifactId>guava</artifactId>
            <version>23.0</version>
        </dependency>
 
        <!-- h2内存级数据库 -->
        <dependency>
            <groupId>com.h2database</groupId>
            <artifactId>h2</artifactId>
            <version>1.3.176</version>
        </dependency>
    </dependencies>

简化logback输出，logback.xml

<?xml version="1.0" encoding="UTF-8"?>
<configuration>
    <!--定义日志文件的存储地址 勿在 LogBack 的配置中使用相对路径-->
    <property name="LOG_HOME" value="/home/tomcatlog/logs/agent" />
    <property name="plain" value="%msg%n" />

    <!-- 控制台输出 -->
    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
        <encoder>
            <pattern>${plain}</pattern>
        </encoder>
    </appender>

    <!-- 按照每天生成日志文件 -->
    <appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
        <file>${LOG_HOME}/agent.log</file>
        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
            <!--日志文件输出的文件名 -->
            <fileNamePattern>${LOG_HOME}/agent.%d{yyyy-MM-dd}.log
            </fileNamePattern>
            <!--日志文件保留天数 -->
            <maxHistory>30</maxHistory>
        </rollingPolicy>
        <encoder>
            <!--格式化输出：%d表示日期，%thread表示线程名，%-5level：级别从左显示5个字符宽度%msg：日志消息，%n是换行符 -->
            <pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{80} - %msg%n
            </pattern>
        </encoder>
    </appender>

    <logger name="jdbc.sqlonly" level="OFF" />
    <logger name="jdbc.resultsettable" level="OFF" />
    <logger name="jdbc.sqltiming" level="erroe" />
    <logger name="jdbc.audit" level="error" />
    <logger name="jdbc.connection" level="error" />
    <logger name="jdbc.resultset" level="error" />
    <logger name="root">
        <level value="ERROR"/>
    </logger>
    <logger name="com.imooc">
        <level value="DEBUG"/>
    </logger>

    <!-- 日志输出级别 -->
    <root level="info"><!-- ERROR、WARN、INFO、DEBUG -->
        <appender-ref ref="STDOUT" />
        <appender-ref ref="FILE" />
    </root>
</configuration>

resources引入second_approve.bpmn20.xml文件

新建启动类Main.class

创建流程引擎

部署流程定义文件

启动运行流程

处理流程任务

按照以上四步构建引动类，为了简化启动类，建议对每个方法进行重构，CTRL+ALT+M快捷键

package com.imooc.activiti.helloword;


import com.google.common.collect.Maps;
import org.activiti.engine.*;
import org.activiti.engine.form.FormProperty;
import org.activiti.engine.form.TaskFormData;
import org.activiti.engine.impl.form.DateFormType;
import org.activiti.engine.impl.form.StringFormType;
import org.activiti.engine.repository.Deployment;
import org.activiti.engine.repository.DeploymentBuilder;
import org.activiti.engine.repository.ProcessDefinition;
import org.activiti.engine.runtime.ProcessInstance;
import org.activiti.engine.task.Task;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
import java.util.Map;
import java.util.Scanner;

public class Main {

    private static final Logger LOGGER = LoggerFactory.getLogger(Main.class);

    public static void main(String[] args) throws ParseException {
        LOGGER.info("启动程序");
        //创建流程引擎
        ProcessEngine processEngine = getProcessEngine();

        //部署流程定义文件
        ProcessDefinition processDefinition = getProcessDefinition(processEngine);

        //启动运行流程
        ProcessInstance processInstance =getProcessInstance(processEngine, processDefinition);

        //处理流程任务
        Scanner scanner = new Scanner(System.in);
        while (processInstance != null && !processInstance.isEnded()) {   //判断流程不为空，且流程没有结束
            TaskService taskService = processEngine.getTaskService();
            List<Task> list = taskService.createTaskQuery().list();    //列出当前需要处理的任务
            LOGGER.info("待处理任务数量 [{}]", list.size());
            for (Task task : list) {

                LOGGER.info("待处理任务 [{}]", task.getName());
                Map<String, Object> variables = getStringObjectMap(processEngine, scanner, task);
                taskService.complete(task.getId(),variables);
                processInstance = processEngine.getRuntimeService().createProcessInstanceQuery()
                        .processInstanceId(processInstance.getId()).singleResult();
            }
        }
        scanner.close();
        LOGGER.info("结束程序");

    }
    //获取变量
    private static Map<String, Object> getStringObjectMap(ProcessEngine processEngine, Scanner scanner, Task task) throws ParseException {
        FormService formService = processEngine.getFormService();    //通过formService来获取form表单输入
        TaskFormData taskFormData = formService.getTaskFormData (task.getId());
        List<FormProperty> formProperties = taskFormData.getFormProperties();    //获取taskFormData的表单内容
        Map<String,Object> variables = Maps.newHashMap();    //这个Map键值对来存对应表单用户输入的内容
        for (FormProperty property : formProperties){   //property为表单中的内容
            String line = null;    //这里获取输入的信息
            if(StringFormType.class.isInstance(property.getType())){   //如果是String类型的话
                LOGGER.info("请输入 [{}] ?" , property.getName());    //输入form表单的某一项内容
                line = scanner.nextLine();
                variables.put(property.getId(),line);
            }else if(DateFormType.class.isInstance(property.getType())){   //如果是日期类型的话
                LOGGER.info("请输入 [{}] ? 格式为（yyyy-MM-dd）" , property.getName());    //输入form表单的某一项内容
                line = scanner.nextLine();
                SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");   //设置输入的日期格式
                Date date = dateFormat.parse(line);
                variables.put(property.getId(),date);
            }else{
                LOGGER.info("类型不支持 [{}]",property.getType());
            }
            LOGGER.info("您输入的内容是 [{}] " , line);
        }
        return variables;
    }

    private static ProcessInstance getProcessInstance(ProcessEngine processEngine, ProcessDefinition processDefinition) {
        RuntimeService runtimeService = processEngine.getRuntimeService();
        ProcessInstance processInstance = runtimeService.startProcessInstanceById(processDefinition.getId());
        LOGGER.info("启动流程{}",processInstance.getProcessDefinitionKey());
        return processInstance;
    }

    private static ProcessDefinition getProcessDefinition(ProcessEngine processEngine) {
        RepositoryService repositoryService = processEngine.getRepositoryService();
        DeploymentBuilder deploymentBuilder = repositoryService.createDeployment();
        deploymentBuilder.addClasspathResource("second_approve.bpmn20.xml");
        Deployment deploy = deploymentBuilder.deploy();
        String id = deploy.getId();
        ProcessDefinition processDefinition = repositoryService
                .createProcessDefinitionQuery()
                .deploymentId(id)
                .singleResult();
        LOGGER.info("流程定义对象{}，流程定义id {}",processDefinition.getName(),processDefinition.getId());
        return processDefinition;
    }

    private static ProcessEngine getProcessEngine() {
        ProcessEngineConfiguration cfg = ProcessEngineConfiguration.createStandaloneInMemProcessEngineConfiguration();
        ProcessEngine processEngine = cfg.buildProcessEngine();
        String name = processEngine.getName();
        String version = ProcessEngine.VERSION;
        LOGGER.info("流程引擎名称{},版本{}",name,version);
        return processEngine;
    }


}

使用springboot打包

更新pom.xml

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.0.RELEASE</version>
        <relativePath/>
    </parent>


    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>   <!-- 基于plugin启动这个程序 -->
            </plugin>
        </plugins>
    </build>

在<dependencies></dependencies>中添加spring-boot的依赖

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter</artifactId>
    </dependency>

进入这个项目目录，然后输入  mvn package  ，就可以将项目打包：mvn package

target目录中，可以看到两个jar包：

直接使用以下指令来执行我们编译好的二级审批流程文件

java-jar xxxxxx.jar

将二级审批流程创建archetype脚手架

打开源码目录 Activiti-6.x oolingarchetypesactiviti-archetype-unittest

安装脚手架 mvn clean install

copy activiti-archetype-unittest2

修改pom.xml中的 artifactId

创建main/java与main/resources两个目录

修改Main.java中的package，后面路径改为 ${package}; package ${package}

修改 META-INF/maven/archetype-metadata.xml

 <?xml version="1.0" encoding="UTF-8"?>
  <archetype-descriptor name="activiti-archetype-unittest2">
    <fileSets>
      <fileSet filtered="true" packaged="true">   <!-- filtered是否过滤，packaged：是否经过包结构过滤 -->
        <directory>src/main/java</directory>
        <includes>
          <include>**/*.java</include>
       </includes>
      </fileSet>
     <fileSet filtered="false" packaged="false">
       <directory>src/main/resources</directory>   <!-- 资源目录下面的三个文件 -->
       <includes>
         <include>activiti.cfg.xml</include>
         <include>LeaveProcess.bpmn20.xml</include>
        <include>logback.xml</include>
      </includes>
   </fileSet>
   <fileSet filtered="true" packaged="true">
       <directory>src/test/java</directory>
      <includes>
        <include>**/*.java</include>
       </includes>
     </fileSet>
     <fileSet filtered="true" packaged="true">
       <directory>src/test/resources</directory>
       <includes>
        <include>second_approve.bpmn20.xml</include>
      </includes>
     </fileSet>
 
  </fileSets>
 </archetype-descriptor>

进入activiti-archetype-unittest2的路径下，执行 mvn clean install

在本地的maven仓库中已经创建好的脚手架

Create from archetype后Add Archetype

GroupId org.activiti

ArtifactId activiti-archetype-unittest2

Version 6.0.0

即可继续创建工程

完