flowable工作流--实操篇

简单介绍

本文通过申请发工资的业务场景来介绍使用工作流的全流程,包括画流程图,设置属性,以及代码编写
使用工作流大致分为四步
第一步:根据自己的业务画好流程图
第二步:设置流程图的属性和变量,保存模型
第三步:部署画好的流程图(发布)
第四步:根据业务和流程图写一些服务和监听器
这里主要介绍以下几个任务的使用
1.用户任务的分配和提交
2.服务任务的使用
3.中间信号捕捉事件的触发
4.排他网关的使用
5.通过设置流程变量,实现流程的不同流转

一、画流程图

申请发工资流程预览

二、设置流程信息

1.设置流程标识

设置流程的唯一标识为payrollApplication也就是模型KEY,后续部署和启动都会用到

2.设置流程变量

设置通过的流转条件为${approval==‘pass’}其中approval为变量名称,pass为变量值,工作流会自动解析表达式进行判断

设置不通过的流转条件为${approval==‘notPass’}

设置打款成功的流转条件为${payment == ‘success’}

设置打款失败的流转条件为${payment == ‘fail’}

3.设置信号定义和信号引用

主要用于接收银行打款处理通知,未通知会一直停留在中间信号接收事件节点上


设置信号引用为方才设置的信号定义

4.设置服务任务的实现类

设置事先写好的服务任务的实现类(下面有实现代码)

5.用户任务–通过变量设置审批人

设置审批人为${Assignee},通过设置变量Assignee,动态设置审批人

三、部署流程

四、使用流程

1.启动流程

启动流程实例并跟业务ID关联,并设置流程变量
1.processDefinitionKey 要启动的流程模型KEY (本次演示场景为payrollApplication)
2.businessKey 业务标识,跟流程进行关联,不需要可不填
3.variables 流程变量,启动流程时设置的变量,类型为Map,JSONObject也可以,不需要可不填 (本次场景是通过变量动态设置的代理人,所以需要在启动时设置变量Assignee,值为审批人ID,否则用户任务会因为没有指定处理人而报错)

     public string startProcessByBusinessKey(String processDefinitionKey, String businessKey , Map<String,Object> variables) {        // 启动流程实例        ProcessInstance instance = runtimeService.startProcessInstanceByKey(processDefinitionKey, businessKey, variables);        logger.debug("流程实例ID:{},流程定义ID:{},业务标识:{}", instance.getId(), instance.getProcessDefinitionId(), businessKey);        return instance.getId();    }

2.用户任务(财务审批)

businessKey为启动时设置的业务标识,不需要可不填
userId为启动流程时设置的流程变量Assignee的值
approval为审批结果值为pass或者notPass

    public String completeTaskByUserIdAndBusinessKey(String businessKey, String userId, String approval) {        // 获取流程实例ID        String processInstanceId = null;        // 需要处理的任务ID        String taskId = null;        // 查询该用户的所有任务        List<Task> taskList = taskService.createTaskQuery().taskAssignee(userId).orderByTaskCreateTime().desc().list();        if (null == taskList || taskList.isEmpty()) {            return "该用户没有分配任务!";        }                if (StringUtils.isBlank(businessKey)) {            // 有可能存在多个任务,实际需要根据业务特殊处理            taskId = taskList.get(0).getId();            // 获取流程实例ID            processInstanceId = taskList.get(0).getProcessInstanceId();        }else {            // 根据业务ID查找任务ID            for (Task task : taskList) {                // 获取流程实例ID                processInstanceId = task.getProcessInstanceId();                if (StringUtils.isNotBlank(processInstanceId)) {                    // 获取流程实例                    ProcessInstance processInstance = runtimeService.createProcessInstanceQuery().processInstanceId(processInstanceId).singleResult();                    // 流程实例                    if (null == processInstance) {                        return "未查询到正在运行的流程实例!";                    }                    // 流程实例关联的业务ID                    String processInstanceBusinessKey = processInstance.getBusinessKey();                    // 流程实例关联的业务ID和该用户的业务ID                    if (StringUtils.isNotBlank(processInstanceBusinessKey) && StringUtils.equals(processInstanceBusinessKey, businessKey)) {                        taskId = task.getId();                        break;                    }                }            }        }        if (StringUtils.isBlank(taskId)) {            return "未查询到关联该业务的任务!";        }                // 设置变量 设置流条件,告诉工作流下一步的流转节点 审批通过或未通过        JSONObject variables = new JSONObject();        variables.put("approval", approval);        runtimeService.setVariables(processInstanceId, variables);        // 提交任务        taskService.complete(taskId, null);        return "提交任务成功";    }

3.服务任务(银行处理)

BankPaymentTask 实现类必须实现JavaDelegate接口,工作流才会识别到

public class BankPaymentTask implements JavaDelegate, Serializable {    @Autowired    public RuntimeService runtimeService;    public static BankPaymentTask bankPaymentTask;    @PostConstruct //通过@PostConstruct实现初始化bean之前进行的操作    public void init() {        bankPaymentTask= this;        bankPaymentTask.runtimeService = this.runtimeService;    }    @Override    public void execute(DelegateExecution execution) {        // 获取流程实例变量        Map<String, Object> variables = runtimeService.getVariables(execution.getProcessInstanceId());        if (variables == null || variables.isEmpty()) {            log.error("variables不能为空!");            return;        }        if (variables.get("businessKey") == null) {            log.error("businessKey不能为空!");            return;        }                // 配合流程变量,使用http调用其他服务完成银行转账的操作        // JSONObject result = RestTemplateUtil.postForObject(paymentUrl, params, JSONObject.class);        // 设置流程变量JSONObject variables = new JSONObject();        variables.put("xxx", "xxx");        runtimeService.setVariables(execution.getProcessInstanceId(), variables);    }

4.中间信号捕获事件(等待银行处理结果回调)

工作流执行到当前节点会暂停,待银行打款操作结果回调之后,触发中间信号捕获事件信号,根据打款结果设置流程变量值,完成流程流转

        public String callback(String businessKey, String signaler, String payment) {        // 根据业务标识查询正在运行的流程实例        ProcessInstance processInstance = runtimeService.createProcessInstanceQuery().processInstanceBusinessKey(businessKey).singleResult();        if (processInstance == null) {            return "没有正在进行的任务!";        }        // 流程实例ID        String processInstanceId = processInstance.getId();        // 查找是否有等待触发的信号        // 流程执行流 流程执行流和流程实例的关系：流程执行流表示流程实例中具体地执行路径，流程实例是一次工作流业务的数据实体        Execution executions = runtimeService.createExecutionQuery().processInstanceId(processInstanceId)                .signalEventSubscriptionName(signaler).singleResult();        if (executions == null) {            return "未查询到该信号事件!";        }        logger.debug("executionsId:{},processInstanceId:{}", executions.getId(), processInstanceId);        // 设置变量 设置流条件,告诉工作流下一步的流转节点JSONObject variables = new JSONObject();// payment为success或者fail        variables.put("payment", payment);        runtimeService.setVariables(processInstanceId, variables);        // 发送触发信号        runtimeService.signalEventReceived(signaler, executions.getId());        return "触发信号接收成功";    }

来源地址：https://blog.csdn.net/weixin_43948460/article/details/128970508