package cn.iocoder.yudao.module.aftersales.service.compensation.listener;

import cn.iocoder.yudao.module.aftersales.dal.dataobject.compensation.AfterSaleCompensationDO;
import cn.iocoder.yudao.module.aftersales.dal.mysql.compensation.AfterSaleCompensationMapper;
import cn.iocoder.yudao.module.aftersales.enums.AfterSaleCompensationAuditStatusEnum;
import cn.iocoder.yudao.module.aftersales.service.compensation.AfterSaleCompensationService;
import cn.iocoder.yudao.module.bpm.api.event.BpmProcessInstanceStatusEvent;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.ApplicationListener;
import org.springframework.stereotype.Component;

/**
 * 赔付/服务补偿单审批的结果监听器实现类
 *
 * 通过 businessKey（赔付单ID）匹配，而不是固定的流程定义 Key，
 * 这样可以支持分类下任意 Key 的流程模型。
 */
@Component
@Slf4j
public class AfterSaleCompensationStatusListener implements ApplicationListener<BpmProcessInstanceStatusEvent> {

    @Resource
    private AfterSaleCompensationService compensationService;
    @Resource
    private AfterSaleCompensationMapper compensationMapper;

    @Override
    public void onApplicationEvent(BpmProcessInstanceStatusEvent event) {
        // 通过 businessKey 查询赔付单
        Long compensationId;
        try {
            compensationId = Long.parseLong(event.getBusinessKey());
        } catch (NumberFormatException e) {
            return; // businessKey 不是数字，忽略
        }

        AfterSaleCompensationDO compensation = compensationMapper.selectById(compensationId);
        if (compensation == null) {
            return; // 不是赔付单，忽略
        }

        // 只有审批中状态的赔付单才处理
        if (!AfterSaleCompensationAuditStatusEnum.PROCESS.getStatus().equals(compensation.getAuditStatus())) {
            log.warn("[onApplicationEvent] 赔付单({}) 不处于审批中状态，当前状态: {}", compensationId, compensation.getAuditStatus());
            return;
        }

        log.info("[onApplicationEvent] 赔付单({}) 审批状态更新: {}", compensationId, event.getStatus());
        // 更新审批状态
        compensationService.updateCompensationAuditStatus(compensationId, event.getStatus());
    }

}