package cn.iocoder.yudao.module.mes.service.wm.itemreceipt.listener;

import cn.iocoder.yudao.module.bpm.api.event.BpmProcessInstanceStatusEvent;
import cn.iocoder.yudao.module.mes.dal.dataobject.wm.itemreceipt.MesWmItemReceiptDO;
import cn.iocoder.yudao.module.mes.dal.mysql.wm.itemreceipt.MesWmItemReceiptMapper;
import cn.iocoder.yudao.module.mes.enums.wm.MesWmItemReceiptStatusEnum;
import cn.iocoder.yudao.module.mes.service.wm.itemreceipt.MesWmItemReceiptService;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Component;

/**
 * 采购入库单 BPM 审批状态监听器
 *
 * 监听 BPM 流程实例状态变更事件，更新采购入库单的审批状态
 */
@Component
@Slf4j
public class MesWmItemReceiptStatusListener {

    /**
     * BPM 分类编码：采购入库审批
     */
    public static final String ITEM_RECEIPT_APPROVE_CATEGORY_CODE = "item_receipt_approve";

    @Resource
    private MesWmItemReceiptService itemReceiptService;

    @Resource
    private MesWmItemReceiptMapper itemReceiptMapper;

    @EventListener
    public void onApplicationEvent(BpmProcessInstanceStatusEvent event) {
        // 1. 解析业务主键
        Long receiptId;
        try {
            receiptId = Long.parseLong(event.getBusinessKey());
        } catch (NumberFormatException e) {
            log.warn("[onApplicationEvent] 业务主键({}) 不是有效的入库单编号", event.getBusinessKey());
            return;
        }

        // 2. 校验入库单存在
        MesWmItemReceiptDO receipt = itemReceiptMapper.selectById(receiptId);
        if (receipt == null) {
            log.warn("[onApplicationEvent] 入库单({}) 不存在", receiptId);
            return;
        }

        // 3. 校验入库单状态为审批中
        if (!MesWmItemReceiptStatusEnum.APPROVING.getStatus().equals(receipt.getStatus())) {
            log.warn("[onApplicationEvent] 入库单({}) 不处于审批中状态，当前状态：{}", receiptId, receipt.getStatus());
            return;
        }

        // 4. 更新入库单审批状态
        itemReceiptService.updateItemReceiptAuditStatus(receiptId, event.getStatus());
        log.info("[onApplicationEvent] 入库单({}) 审批状态更新完成，BPM 状态：{}", receiptId, event.getStatus());
    }

}