Activiti7工作流引擎进阶

作者: 阿杰_96c5 | 来源:发表于2020-03-09 20:51 被阅读0次

流程实例关联 businessKey(业务表单ID)

在查询流程实例时,通过 businessKey(业务标识 )关联查询业务系统的请假单表,查询出请假天
数等信息。

/**
 * 启动流程实例时,添加进businessKey
 * 本质: act_ru_execution表中的businessKey的字段要存入业务标识
 */
public class BusinessKeyAdd {
    public static void main(String[] args) {
        // 1.得到ProcessEngine对象
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();

        // 2.得到RuntimeService
        RuntimeService runtimeService = processEngine.getRuntimeService();

        // 3. 启动流程实例,同时还要指定业务标识 businessKey.它本身就是请假单的ID
        // 第一个参数: 是指流程定义Key
        // 第二个参数: 业务标识businessKey
        ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("holiday", "1001");

        // 4.输出processInstance相关属性
        System.out.println("businessKey: " + processInstance.getBusinessKey());

    }
}

全部流程实例挂起与激活

操作流程定义为挂起状态,该流程定义下边所有的流程实例全部暂停:
流程定义为挂起状态该流程定义将不允许启动新的流程实例,同时该流程定义下所有的流程实例将
全部挂起暂停执行。

/**
 * 全部流程实例挂起与激活
 */
public class SuspendProcessInstance {
    public static void main(String[] args) {
        // 1.得到ProcessEngine对象
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        
        // 2.得到RepositoryService
        RepositoryService repositoryService = processEngine.getRepositoryService();

        // 3.查询流程定义的对象
        ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery()
                .processDefinitionKey("holiday")
                .singleResult();

        // 4.得到当前流程定义实例是否都为暂停状态
        boolean suspended = processDefinition.isSuspended();

        // 5.判断
        if(suspended){
            // 说明是暂停,就可以激活操作
            repositoryService.activateProcessDefinitionById(processDefinition.getId(),true,null);
            System.out.println("实例: " + processDefinition.getId() + "已激活");
        }else{
            repositoryService.suspendProcessDefinitionById(processDefinition.getId(),true,null);
            System.out.println("实例: " + processDefinition.getId() + "已挂起");
        }
    }
}

单个流程实例挂起与激活

操作流程实例对象,针对单个流程执行挂起操作,某个流程实例挂起则此流程不再继续执行,完成
该流程实例的当前任务将报异常。

*
 * 单个流程实例挂起与激活
 */
public class SuspendProcessInstance2 {
    public static void main(String[] args) {
        // 1.得到ProcessEngine对象
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        
        // 2.RuntimeService
        RuntimeService runtimeService = processEngine.getRuntimeService();

        // 3.查询流程实例的对象
        ProcessInstance processInstance = runtimeService.createProcessInstanceQuery()
                .processDefinitionKey("holiday")
                .processInstanceBusinessKey("1001")
                .singleResult();


        // 4.得到当前流程实例是否都为暂停状态
        boolean suspended = processInstance.isSuspended();

        // 5.判断
        if(suspended){
            // 说明是暂停,就可以激活操作
            runtimeService.activateProcessInstanceById(processInstance.getId());

            System.out.println("实例: " + processInstance.getId() + "已激活");
        }else{
            runtimeService.suspendProcessInstanceById(processInstance.getId());;
            System.out.println("实例: " + processInstance.getId() + "已挂起");
        }
    }
}

用UEL表达式添加节点负责人

讲bpmn流程文件中节点的assignee 使用UEL表达式赋值(${assignee0})

/**
 * 用UEL表达式添加节点负责人
 */
public class AssigneeUEL {

    public static void main(String[] args) {
        // 1.得到ProcessEngine对象
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();

        // 2.得到RuntimeService对象
        RuntimeService runtimeService = processEngine.getRuntimeService();

        // 3.设置assignee的取值 用户可以在界面上设置流程的执行人
        Map<String,Object> map = new HashMap<String,Object>();
        map.put("assignee0","zhangsan");
        map.put("assignee1","lisi");
        map.put("assignee2","wangwu");

        // 4.启动流程实例,同时还要设置流程定义的assignee的值
        ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("holiday2", "map");

        // 5. 输出
        System.out.println(processEngine.getName());

    }
}

监听器分配

任务监听器是发生对应的任务相关事件时执行自定义 java 逻辑或表达式。

1.png

Create:任务创建后触发
Assignment:任务分配后触发
Delete:任务完成后触发
All:所有事件发生都触发

使用监听器分配执行人

定义任务监听类,且类必须实现 org.activiti.engine.delegate.TaskListener 接口

public class MyTaskListener implements TaskListener {
    @Override
    public void notify(DelegateTask delegateTask) {
        //这里指定任务负责人
        delegateTask.setAssignee("张三");
    }
}

使用 Global 变量控制流程

流程程定义

在部门经理审核前设置流程变量,变量值为请假单信息(包括请假天数),部门经理审核后可以根据
流程变量的值决定流程走向。

2.png

新的请假流程定义的部署

 // 新的请假流程定义的部署
    public static void main(String[] args) {
        // 1.得到ProcessEngine对象
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();

        // 2.得到RepositoryService对象
        RepositoryService repositoryService = processEngine.getRepositoryService();

        // 3.部署
        Deployment deploy = repositoryService.createDeployment()
                .addClasspathResource("diagram/holiday4.bpmn")
                .addClasspathResource("diagram/holiday4.png")
                .name("请假流程流程变量")
                .deploy();
        System.out.println(deploy.getId());
        System.out.println(deploy.getName());
    }

启动流程实例,同时还要设置流程变量的值

// 启动流程实例,同时还要设置流程变量的值
public static void main(String[] args) {

    // 1.得到ProcessEngine对象
    ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();

    // 2.得到RunService对象
    RuntimeService runtimeService = processEngine.getRuntimeService();

    // 3.流程定义的key问题
    HashMap<String, Object> map = new HashMap<String, Object>();
    Holiday holiday = new Holiday();
    holiday.setNum(1F);
    map.put("holiday",holiday);

    // 4.启动流程实例,并设置流程变量
    ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("myProcess_1", map);

    // 5.输出实例信息
    System.out.println(processInstance.getName());
    System.out.println(processInstance.getProcessDefinitionId());
}

完成任务

// 完成任务 zhangsan -> lisi -->zhaoliu
public static void main(String[] args) {

    // 1. 得到ProcessEngine
    ProcessEngine processEngine =  ProcessEngines.getDefaultProcessEngine();

    // 2.得到TaskService对象
    TaskService taskService = processEngine.getTaskService();

    // 3.查询当前用户是否有任务
    Task task = taskService.createTaskQuery()
            .processDefinitionKey("myProcess_1")
            .taskAssignee("zhaoliu")
            .singleResult();
    // 4. 判断task != null,说明当前用户有任务
    if(task != null){
        taskService.complete(task.getId());
        System.out.println("任务执行完毕");
    }

}

完成任务时设置流程变量的值

// 完成任务 zhangsan -> lisi -->zhaoliu
public static void main(String[] args) {

    // 1. 得到ProcessEngine
    ProcessEngine processEngine =  ProcessEngines.getDefaultProcessEngine();

    // 2.得到TaskService对象
    TaskService taskService = processEngine.getTaskService();

    // 3.查询当前用户是否有任务
    Task task = taskService.createTaskQuery()
            .processDefinitionKey("myProcess_1")
            .taskAssignee("zhaoliu")
            .singleResult();

    // 初始化一些参数
    HashMap<String, Object> map = new HashMap<String, Object>();
    Holiday holiday = new Holiday();
    holiday.setNum(5F);
    map.put("holiday",holiday);
    // 4. 判断task != null,说明当前用户有任务
    if(task != null){
        taskService.complete(task.getId(), map); // 完成任务时设置流程变量的值
        System.out.println("任务执行完毕");
    }

}

通过当前流程实例设置流程变量的值

通过流程实例 id 设置全局变量,该流程实例必须未执行完成。

// 通过流程实例 id 设置全局变量
public static void main(String[] args) {

    // 1.得到ProcessEngine对象
    ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();

    // 2.得到RunService对象
    RuntimeService runtimeService = processEngine.getRuntimeService();

    // 3.流程定义的key问题
   // HashMap<String, Object> map = new HashMap<String, Object>();
    Holiday holiday = new Holiday();
    holiday.setNum(1F);
   // map.put("holiday",holiday);

    // 4.通过实例ID置流程变量
    // 第一个参数:流程实例id
    // 第二个参数:流程变量名
    // 第三个参数:流程变量名所对应的值
    runtimeService.setVariable("2501","holiday",holiday);
    
    //一次设置多个值
    //runtimeService.setVariables(executionId, variables)

}

通过当前任务设置设置流程变量的值

public void setGlobalVariableByTaskId(){
    
    //当前待办任务id
    String taskId="1404";
    TaskService taskService = processEngine.getTaskService();
    Holiday holiday = new Holiday();
    holiday.setNum(3f);
    
    //通过任务设置流程变量
    taskService.setVariable(taskId, "holiday", holiday);
    
    //一次设置多个值
    //taskService.setVariables(taskId, variables)
}

设置 local 流程变量

任务办理时设置

任务办理时设置 local 流程变量,当前运行的流程实例只能在该任务结束前使用,任务结束该变量无
法在当前流程实例使用,可以通过查询历史任务查询。

public void completTask() {

    //任务id
    String taskId = "";
    TaskService taskService = processEngine.getTaskService();

    // 定义流程变量
    Holiday holiday = new Holiday ();
    holiday.setNum(3f);

    // 定义流程变量
    Map<String, Object> variables = new HashMap<String, Object>();

    //变量名是holiday,变量值是holiday对象
    variables.put("holiday", holiday);

    // 设置local变量,作用域为该任务
    taskService. setVariablesLocal(tasked, variables );
    taskService.complete(taskId);
}

通过当前任务设置

public void setLocalVariableByTaskId(){
    
    //当前待办任务id
    String taskId="1404";
    TaskService taskService = processEngine.getTaskService();
    Holiday holiday = new Holiday ();
    holiday.setNum(3f);
    
    //通过任务设置流程变量
    taskService.setVariableLocal(taskId, "holiday", holiday);
    
    //一次设置多个值
    //taskService.setVariablesLocal(taskId, variables)
}

注意:
任务 id 必须是当前待办任务 id,act_ru_task 中存在。