項目地址：https://gitee.com/lwj/flowable.git 分支flowable-base
視頻講解地址 https://www.bilibili.com/video/av79328344
監聽器
任務監聽器 針對userTask節點
事件監聽器 針對任意節點
由于實際情況下我們會在節點會動態調用業務系統的接口去改變業務單據的狀態或者做一些業務處理。如果每次都去新建一個監聽器這樣勢必就非常的繁瑣也不好維護，那么我們該如何做才能達到動態調用的效果呢？接下來小學生一步步的實現這個統一的功能。
一、定義統一的任務監聽器

@Scope @Component(value = "taskBusinessCallListener") public class TaskBusinessCallListener extends BusinessCallListener implements TaskListener {/*** rest接口*/private FixedValue restUrl;/*** 參數 多個的話用分號隔開 實例 userCode:00004737;status:1*/private FixedValue params;@Overridepublic void notify(DelegateTask delegateTask) {String processInstanceId = delegateTask.getProcessInstanceId();String restUrlStr = null, paramsStr = null;if (restUrl != null) {restUrlStr = restUrl.getExpressionText();}if (params != null) {paramsStr = params.getExpressionText();}//執行回調//TODO 臨時處理restUrlStr = "http://127.0.0.1:8989/rest/leave/updateLeaveStatus";paramsStr = "status:1";this.callBack(processInstanceId, restUrlStr, paramsStr);} }

FixedValue restUrl 介紹我們配置的field字段，表示要請求的resturl，這里注意接收字段一定要用FixedValue才能接收到。

二、調用接口

public void callBack(String pocessInstanceId, String restUrl, String params) {String paramsJson = null;try {Map<String, Object> paramMap = new HashMap<String, Object>();ProcessInstance processInstance = runtimeService.createProcessInstanceQuery().processInstanceId(pocessInstanceId).singleResult();paramMap.put("businessKey", processInstance.getBusinessKey());this.setParams(params, paramMap);paramsJson = JsonUtils.toJson(paramMap);//執行dubbo方法logger.info("開始調用業務系統接口" + restUrl + ",業務參數:" + paramsJson);restTemplate.postForObject(restUrl, paramsJson, String.class);} catch (Exception e) {logger.error("調用業務系統的方法失敗", e);}

三、配置監聽

總結

以上是生活随笔為你收集整理的工作流实战_23_flowable 任务监听器 事件监听器的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。