芋道框架审批流自动化实践从手动同步到事件驱动的优雅升级审批流程在企业应用中无处不在但很多开发者仍然陷在手动更新业务状态的泥潭中。每次审批结果变更都需要在Controller回调、定时任务或消息队列中编写重复的状态同步代码不仅增加了维护成本还容易因遗漏导致数据不一致。芋道框架的BpmUtil工具类与事件监听机制为我们提供了一种更优雅的解决方案。1. 传统审批流实现的痛点分析在常规审批流开发中我们通常会遇到以下几个典型问题代码耦合度高审批结果处理逻辑分散在多个Controller或Service中状态同步不可靠网络超时或异常可能导致业务状态与审批状态不一致维护成本大每次流程调整都需要修改多处状态同步代码扩展性差新增审批类型时需要重复编写相似的状态同步逻辑// 典型的手动状态同步代码示例 PostMapping(/approve/callback) public CommonResultBoolean approveCallback(RequestBody ApproveCallbackVO vo) { // 查询业务数据 BusinessDO business businessMapper.selectById(vo.getBusinessId()); // 更新状态 business.setStatus(vo.getApproved() ? 3 : 4); businessMapper.updateById(business); // 可能还需要处理其他关联状态... return success(true); }这种模式最大的问题在于审批逻辑与业务逻辑高度耦合任何流程变更都需要修改业务代码。2. 芋道框架审批流核心组件解析芋道框架提供了一套完整的审批流解决方案其中两个核心组件特别值得关注2.1 BpmUtil工具类BpmUtil是审批流操作的入口类主要提供以下关键功能方法名功能描述参数说明submitToBpm提交审批流程业务编号、流程定义KEYgetProcessInstance获取流程实例详情流程实例IDcancelProcess取消审批流程流程实例ID// 使用BpmUtil提交审批的典型示例 String processInstanceId bpmUtil.submitToBpm( businessNumber, // 业务编号 project-approve // 流程定义KEY );2.2 审批状态事件监听机制芋道框架内置了审批状态变更的事件发布机制开发者可以通过实现BpmProcessInstanceStatusEventListener来监听审批结果Component public class ProjectApprovalListener extends BpmProcessInstanceStatusEventListener { Resource private ProjectService projectService; Override protected String getProcessDefinitionKey() { return project-approve; // 只处理特定流程的事件 } Override protected void onEvent(BpmProcessInstanceStatusEvent event) { // 根据审批结果更新业务状态 projectService.updateStatus( event.getBusinessKey(), // 业务编号 convertStatus(event.getStatus()) // 状态转换 ); } private Integer convertStatus(Integer bpmStatus) { switch (bpmStatus) { case 2: return 3; // 审批通过→业务已通过 case 3: return 4; // 审批驳回→业务已驳回 case 4: return 1; // 审批取消→业务草稿 default: return null; } } }3. 完整实现方案与最佳实践3.1 数据库设计要点审批流相关的业务表需要包含以下关键字段ALTER TABLE biz_project ADD ( process_instance_id VARCHAR2(64), -- 流程实例ID status NUMBER(2) DEFAULT 1, -- 业务状态1-草稿 2-审批中 3-已通过 4-已驳回 submit_batch_no VARCHAR2(32) -- 提交批次号可选 );提示process_instance_id建议建立索引便于通过流程实例ID反查业务数据3.2 审批提交服务实现审批提交服务需要完成以下关键操作生成唯一的业务批次号可选通过BpmUtil发起审批流程批量更新业务数据的流程实例ID和状态Service RequiredArgsConstructor public class ProjectApprovalServiceImpl implements ProjectApprovalService { private final BpmUtil bpmUtil; private final ProjectMapper projectMapper; Override Transactional public void submitApproval(ListLong projectIds) { // 1. 生成批次号 String batchNo PJ- System.currentTimeMillis(); // 2. 发起审批流程 String processInstanceId bpmUtil.submitToBpm( batchNo, project-approve ); // 3. 更新业务数据 projectMapper.updateBatch( new LambdaUpdateWrapperProjectDO() .in(ProjectDO::getId, projectIds) .set(ProjectDO::getProcessInstanceId, processInstanceId) .set(ProjectDO::getStatus, 2) // 审批中 .set(ProjectDO::getSubmitBatchNo, batchNo) ); } }3.3 状态同步的防重处理在高并发场景下需要考虑事件重复处理的问题。可以通过以下方式增强可靠性在业务表中增加last_approve_time字段在监听器中实现幂等处理逻辑Override protected void onEvent(BpmProcessInstanceStatusEvent event) { ProjectDO project projectMapper.selectByProcessInstanceId(event.getId()); if (project null || project.getLastApproveTime() ! null project.getLastApproveTime().after(event.getEventTime())) { return; // 已处理过更晚的事件 } // 更新状态 projectMapper.updateById(new ProjectDO() .setId(project.getId()) .setStatus(convertStatus(event.getStatus())) .setLastApproveTime(event.getEventTime()) ); }4. 高级应用场景与性能优化4.1 多级审批的状态映射对于复杂的多级审批流程可以设计更精细的状态映射策略private Integer convertMultiLevelStatus(BpmProcessInstanceStatusEvent event) { switch (event.getStatus()) { case 2: // 通过 return event.getApprovalLevel() 1 ? 3 : 5; // 一级通过→3二级通过→5 case 3: // 驳回 return event.getApprovalLevel() 1 ? 1 : 4; // 一级驳回→草稿二级驳回→4 // ...其他状态处理 } }4.2 批量审批的性能优化当需要处理大批量审批时可以采用以下优化策略使用MyBatis的批量更新代替循环单条更新对审批结果进行本地缓存减少数据库查询采用异步方式处理后续业务逻辑Async Override public void handleMassApproval(ListString processInstanceIds) { // 1. 批量查询业务数据 MapString, ProjectDO projectMap projectMapper .selectListByProcessInstanceIds(processInstanceIds) .stream() .collect(Collectors.toMap(ProjectDO::getProcessInstanceId, p - p)); // 2. 批量更新状态 ListProjectDO updates processInstanceIds.stream() .map(id - new ProjectDO() .setId(projectMap.get(id).getId()) .setStatus(3) .setUpdateTime(LocalDateTime.now())) .collect(Collectors.toList()); projectMapper.updateBatch(updates); }4.3 审批链路的可视化追踪为了便于问题排查可以增加审批操作的审计日志Aspect Component RequiredArgsConstructor public class ApprovalLogAspect { private final ApprovalLogMapper logMapper; Around(execution(* com.yudao.module.bpm..*.*(..))) public Object logAround(ProceedingJoinPoint joinPoint) throws Throwable { long start System.currentTimeMillis(); try { Object result joinPoint.proceed(); logMapper.insert(new ApprovalLogDO() .setProcessInstanceId(getProcessInstanceId(joinPoint)) .setOperation(joinPoint.getSignature().getName()) .setStatus(SUCCESS) .setCostTime(System.currentTimeMillis() - start)); return result; } catch (Exception e) { logMapper.insert(new ApprovalLogDO() .setProcessInstanceId(getProcessInstanceId(joinPoint)) .setOperation(joinPoint.getSignature().getName()) .setStatus(FAILED) .setErrorMsg(e.getMessage())); throw e; } } }在实际项目中使用这套方案后审批流相关代码量减少了约60%状态不一致的问题几乎不再出现。特别是在处理跨系统审批时事件驱动的方式展现出了明显的优势——业务系统只需要关注自己需要处理的审批类型完全不需要了解具体的审批流程实现。
别再手动改状态了！用芋道框架的BpmUtil和监听器，优雅实现审批状态自动同步
芋道框架审批流自动化实践从手动同步到事件驱动的优雅升级审批流程在企业应用中无处不在但很多开发者仍然陷在手动更新业务状态的泥潭中。每次审批结果变更都需要在Controller回调、定时任务或消息队列中编写重复的状态同步代码不仅增加了维护成本还容易因遗漏导致数据不一致。芋道框架的BpmUtil工具类与事件监听机制为我们提供了一种更优雅的解决方案。1. 传统审批流实现的痛点分析在常规审批流开发中我们通常会遇到以下几个典型问题代码耦合度高审批结果处理逻辑分散在多个Controller或Service中状态同步不可靠网络超时或异常可能导致业务状态与审批状态不一致维护成本大每次流程调整都需要修改多处状态同步代码扩展性差新增审批类型时需要重复编写相似的状态同步逻辑// 典型的手动状态同步代码示例 PostMapping(/approve/callback) public CommonResultBoolean approveCallback(RequestBody ApproveCallbackVO vo) { // 查询业务数据 BusinessDO business businessMapper.selectById(vo.getBusinessId()); // 更新状态 business.setStatus(vo.getApproved() ? 3 : 4); businessMapper.updateById(business); // 可能还需要处理其他关联状态... return success(true); }这种模式最大的问题在于审批逻辑与业务逻辑高度耦合任何流程变更都需要修改业务代码。2. 芋道框架审批流核心组件解析芋道框架提供了一套完整的审批流解决方案其中两个核心组件特别值得关注2.1 BpmUtil工具类BpmUtil是审批流操作的入口类主要提供以下关键功能方法名功能描述参数说明submitToBpm提交审批流程业务编号、流程定义KEYgetProcessInstance获取流程实例详情流程实例IDcancelProcess取消审批流程流程实例ID// 使用BpmUtil提交审批的典型示例 String processInstanceId bpmUtil.submitToBpm( businessNumber, // 业务编号 project-approve // 流程定义KEY );2.2 审批状态事件监听机制芋道框架内置了审批状态变更的事件发布机制开发者可以通过实现BpmProcessInstanceStatusEventListener来监听审批结果Component public class ProjectApprovalListener extends BpmProcessInstanceStatusEventListener { Resource private ProjectService projectService; Override protected String getProcessDefinitionKey() { return project-approve; // 只处理特定流程的事件 } Override protected void onEvent(BpmProcessInstanceStatusEvent event) { // 根据审批结果更新业务状态 projectService.updateStatus( event.getBusinessKey(), // 业务编号 convertStatus(event.getStatus()) // 状态转换 ); } private Integer convertStatus(Integer bpmStatus) { switch (bpmStatus) { case 2: return 3; // 审批通过→业务已通过 case 3: return 4; // 审批驳回→业务已驳回 case 4: return 1; // 审批取消→业务草稿 default: return null; } } }3. 完整实现方案与最佳实践3.1 数据库设计要点审批流相关的业务表需要包含以下关键字段ALTER TABLE biz_project ADD ( process_instance_id VARCHAR2(64), -- 流程实例ID status NUMBER(2) DEFAULT 1, -- 业务状态1-草稿 2-审批中 3-已通过 4-已驳回 submit_batch_no VARCHAR2(32) -- 提交批次号可选 );提示process_instance_id建议建立索引便于通过流程实例ID反查业务数据3.2 审批提交服务实现审批提交服务需要完成以下关键操作生成唯一的业务批次号可选通过BpmUtil发起审批流程批量更新业务数据的流程实例ID和状态Service RequiredArgsConstructor public class ProjectApprovalServiceImpl implements ProjectApprovalService { private final BpmUtil bpmUtil; private final ProjectMapper projectMapper; Override Transactional public void submitApproval(ListLong projectIds) { // 1. 生成批次号 String batchNo PJ- System.currentTimeMillis(); // 2. 发起审批流程 String processInstanceId bpmUtil.submitToBpm( batchNo, project-approve ); // 3. 更新业务数据 projectMapper.updateBatch( new LambdaUpdateWrapperProjectDO() .in(ProjectDO::getId, projectIds) .set(ProjectDO::getProcessInstanceId, processInstanceId) .set(ProjectDO::getStatus, 2) // 审批中 .set(ProjectDO::getSubmitBatchNo, batchNo) ); } }3.3 状态同步的防重处理在高并发场景下需要考虑事件重复处理的问题。可以通过以下方式增强可靠性在业务表中增加last_approve_time字段在监听器中实现幂等处理逻辑Override protected void onEvent(BpmProcessInstanceStatusEvent event) { ProjectDO project projectMapper.selectByProcessInstanceId(event.getId()); if (project null || project.getLastApproveTime() ! null project.getLastApproveTime().after(event.getEventTime())) { return; // 已处理过更晚的事件 } // 更新状态 projectMapper.updateById(new ProjectDO() .setId(project.getId()) .setStatus(convertStatus(event.getStatus())) .setLastApproveTime(event.getEventTime()) ); }4. 高级应用场景与性能优化4.1 多级审批的状态映射对于复杂的多级审批流程可以设计更精细的状态映射策略private Integer convertMultiLevelStatus(BpmProcessInstanceStatusEvent event) { switch (event.getStatus()) { case 2: // 通过 return event.getApprovalLevel() 1 ? 3 : 5; // 一级通过→3二级通过→5 case 3: // 驳回 return event.getApprovalLevel() 1 ? 1 : 4; // 一级驳回→草稿二级驳回→4 // ...其他状态处理 } }4.2 批量审批的性能优化当需要处理大批量审批时可以采用以下优化策略使用MyBatis的批量更新代替循环单条更新对审批结果进行本地缓存减少数据库查询采用异步方式处理后续业务逻辑Async Override public void handleMassApproval(ListString processInstanceIds) { // 1. 批量查询业务数据 MapString, ProjectDO projectMap projectMapper .selectListByProcessInstanceIds(processInstanceIds) .stream() .collect(Collectors.toMap(ProjectDO::getProcessInstanceId, p - p)); // 2. 批量更新状态 ListProjectDO updates processInstanceIds.stream() .map(id - new ProjectDO() .setId(projectMap.get(id).getId()) .setStatus(3) .setUpdateTime(LocalDateTime.now())) .collect(Collectors.toList()); projectMapper.updateBatch(updates); }4.3 审批链路的可视化追踪为了便于问题排查可以增加审批操作的审计日志Aspect Component RequiredArgsConstructor public class ApprovalLogAspect { private final ApprovalLogMapper logMapper; Around(execution(* com.yudao.module.bpm..*.*(..))) public Object logAround(ProceedingJoinPoint joinPoint) throws Throwable { long start System.currentTimeMillis(); try { Object result joinPoint.proceed(); logMapper.insert(new ApprovalLogDO() .setProcessInstanceId(getProcessInstanceId(joinPoint)) .setOperation(joinPoint.getSignature().getName()) .setStatus(SUCCESS) .setCostTime(System.currentTimeMillis() - start)); return result; } catch (Exception e) { logMapper.insert(new ApprovalLogDO() .setProcessInstanceId(getProcessInstanceId(joinPoint)) .setOperation(joinPoint.getSignature().getName()) .setStatus(FAILED) .setErrorMsg(e.getMessage())); throw e; } } }在实际项目中使用这套方案后审批流相关代码量减少了约60%状态不一致的问题几乎不再出现。特别是在处理跨系统审批时事件驱动的方式展现出了明显的优势——业务系统只需要关注自己需要处理的审批类型完全不需要了解具体的审批流程实现。
