package cn.iocoder.yudao.module.hrm.service.approval.listener; import cn.iocoder.yudao.module.bpm.api.event.BpmProcessInstanceStatusEvent; import cn.iocoder.yudao.module.hrm.dal.dataobject.approval.HrmLeaveApplicationDO; import cn.iocoder.yudao.module.hrm.dal.mysql.approval.HrmLeaveApplicationMapper; import cn.iocoder.yudao.module.hrm.enums.HrmAuditStatusEnum; import cn.iocoder.yudao.module.hrm.service.approval.HrmLeaveApplicationService; import cn.iocoder.yudao.module.hrm.util.HrmAuditStatusUtils; import jakarta.annotation.Resource; import lombok.extern.slf4j.Slf4j; import org.springframework.context.ApplicationListener; import org.springframework.stereotype.Component; /** * 请假申请审批的结果监听器实现类 * * @author 芋道源码 */ @Component @Slf4j public class HrmLeaveApplicationStatusListener implements ApplicationListener { @Resource private HrmLeaveApplicationService leaveApplicationService; @Resource private HrmLeaveApplicationMapper leaveApplicationMapper; @Override public void onApplicationEvent(BpmProcessInstanceStatusEvent event) { // 通过 businessKey 查询请假申请 Long applicationId; try { applicationId = Long.parseLong(event.getBusinessKey()); } catch (NumberFormatException e) { return; } HrmLeaveApplicationDO application = leaveApplicationMapper.selectById(applicationId); if (application == null) { return; } // 只有审批中状态的请假申请才处理 if (!HrmAuditStatusEnum.PROCESS.getStatus().equals(application.getStatus())) { log.warn("[onApplicationEvent] 请假申请({}) 不处于审批中状态,当前状态: {}", applicationId, application.getStatus()); return; } log.info("[onApplicationEvent] 请假申请({}) 审批状态更新: {}", applicationId, event.getStatus()); // 更新审批状态 Integer auditStatus = HrmAuditStatusUtils.convertBpmResultToAuditStatus(event.getStatus()); leaveApplicationService.updateLeaveApplicationAuditStatus(applicationId, auditStatus); } }