package com.oying.modules.pc.product.events.handler;

import com.oying.modules.pc.product.domain.ProductAudit;
import com.oying.modules.pc.product.domain.enums.ProductAuditTypeEnum;
import com.oying.modules.pc.product.events.ProductAuditVerdictEvent;
import com.oying.modules.pc.product.service.ProductAuditService;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Component;

@Slf4j
@Component
@RequiredArgsConstructor
public class ProductAuditVerdictEventHandler {

    private final ProductAuditService productAuditService;
    private final ProductAuditVerdictAfterHandlerFactory handlerFactory;

    /**
     * 监听 ProductAuditVerdictEvent 事件
     */
    @EventListener
    public void handleProductAuditPassEvent(ProductAuditVerdictEvent event) {
        log.info("监听到商品审核事件: {}", event);
        try {
            ProductAudit productAudit = productAuditService.getById(event.getAuditId());
            ProductAuditTypeEnum auditType = ProductAuditTypeEnum.valueOf(productAudit.getType());
            ProductAuditVerdictHandler handler = handlerFactory.getHandler(auditType);
            handler.handle(productAudit);
            log.info("商品审核事件处理成功: auditId={}", event.getAuditId());
        } catch (Exception e) {
            log.error("处理商品审核事件时发生异常: auditId={}", event.getAuditId(), e);
            throw e;
        }
    }
}