package cn.iocoder.yudao.module.mes.service.wm.salesnotice.listener;
|
|
import cn.hutool.core.util.StrUtil;
|
import cn.iocoder.yudao.module.bpm.api.event.BpmProcessInstanceStatusEvent;
|
import cn.iocoder.yudao.module.mes.dal.dataobject.wm.salesnotice.MesWmSalesNoticeDO;
|
import cn.iocoder.yudao.module.mes.dal.mysql.wm.salesnotice.MesWmSalesNoticeMapper;
|
import cn.iocoder.yudao.module.mes.enums.wm.MesWmSalesNoticeStatusEnum;
|
import cn.iocoder.yudao.module.mes.service.wm.salesnotice.MesWmSalesNoticeService;
|
import jakarta.annotation.Resource;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.context.ApplicationListener;
|
import org.springframework.stereotype.Component;
|
|
/**
|
* 发货单审批结果监听器：通过 businessKey（发货单 ID）匹配，支持「发货审批」分类下任意流程模型。
|
*/
|
@Component
|
@Slf4j
|
public class MesWmSalesNoticeStatusListener implements ApplicationListener<BpmProcessInstanceStatusEvent> {
|
|
@Resource
|
private MesWmSalesNoticeService salesNoticeService;
|
@Resource
|
private MesWmSalesNoticeMapper salesNoticeMapper;
|
|
@Override
|
public void onApplicationEvent(BpmProcessInstanceStatusEvent event) {
|
// 只处理发货审批分类/流程 key 的事件，避免其它模块相同 businessKey 误触发
|
if (!StrUtil.equals(event.getProcessDefinitionKey(), "sales_delivery_approve")
|
&& !StrUtil.equals(event.getProcessDefinitionCategory(), "sales_delivery_approve")) {
|
return;
|
}
|
Long noticeId;
|
try {
|
noticeId = Long.parseLong(event.getBusinessKey());
|
} catch (NumberFormatException e) {
|
return;
|
}
|
MesWmSalesNoticeDO notice = salesNoticeMapper.selectById(noticeId);
|
if (notice == null
|
|| !MesWmSalesNoticeStatusEnum.APPROVING.getStatus().equals(notice.getStatus())) {
|
return; // 不是审批中的发货单，忽略
|
}
|
log.info("[onApplicationEvent] 发货单({}) 审批状态更新: {}", noticeId, event.getStatus());
|
salesNoticeService.updateSalesNoticeAuditStatus(noticeId, event.getStatus());
|
}
|
|
}
|
