package cn.iocoder.yudao.module.vehicle.service.application.listener;

import cn.iocoder.yudao.module.bpm.api.event.BpmProcessInstanceStatusEvent;
import cn.iocoder.yudao.module.bpm.api.event.BpmProcessInstanceStatusEventListener;
import cn.iocoder.yudao.module.vehicle.service.application.VehicleApplicationService;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

/**
 * 用车申请审批状态监听器
 *
 * <p>监听 BPM 流程实例状态变更，把审批结果回写到用车申请，申请人可在列表中看到审批结果
 */
@Component
@Slf4j
public class VehicleApplicationStatusListener extends BpmProcessInstanceStatusEventListener {

    /** 用车审批流程定义 key（BPM 中发布流程时必须使用该 key） */
    private static final String PROCESS_DEFINITION_KEY = "vehicle_application_approve";

    @Resource
    private VehicleApplicationService applicationService;

    @Override
    protected String getProcessDefinitionKey() {
        return PROCESS_DEFINITION_KEY;
    }

    @Override
    protected void onEvent(BpmProcessInstanceStatusEvent event) {
        Long applicationId;
        try {
            applicationId = Long.parseLong(event.getBusinessKey());
        } catch (NumberFormatException e) {
            log.warn("[onEvent] businessKey({}) 不是有效的用车申请编号", event.getBusinessKey());
            return;
        }
        log.info("[onEvent] 收到用车审批事件，applicationId={}, status={}", applicationId, event.getStatus());
        try {
            applicationService.updateApplicationAuditStatus(applicationId, event.getStatus());
        } catch (Exception e) {
            log.error("[onEvent] 回写用车申请审批状态失败，applicationId={}", applicationId, e);
        }
    }

}