package com.ruoyi.system.event;

import com.ruoyi.payment.domain.event.PaymentSuccessEvent;
import com.ruoyi.payment.domain.model.PaymentOrder;
import com.ruoyi.payment.domain.model.PaymentTransaction;
import com.ruoyi.system.service.ISysTaskPaymentService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Component;

/**
 * 支付成功事件监听器
 * 将支付模块的事件回调转换为业务表更新
 */
@Component
public class PaymentSuccessEventListener {

    private static final Logger log = LoggerFactory.getLogger(PaymentSuccessEventListener.class);

    @Autowired
    private ISysTaskPaymentService taskPaymentService;

    /**
     * 监听 dryad-payment 的支付成功事件
     */
    @EventListener
    public void handlePaymentSuccess(PaymentSuccessEvent event) {
        PaymentOrder order = event.getOrder();
        PaymentTransaction transaction = event.getTransaction();

        String outTradeNo = order.getBizOrderId();
        String tradeNo = order.getChannelTradeNo();
        String channel = order.getChannel();
        String provider = "WECHAT";
        if ("ALIPAY".equalsIgnoreCase(channel)) {
            provider = "ALIPAY";
        }

        try {
            boolean success = taskPaymentService.handlePaymentCallback(outTradeNo, tradeNo, provider);
            if (success) {
                log.info("[事件监听] 业务支付更新成功: bizOrderId={}, tradeNo={}, provider={}", outTradeNo, tradeNo, provider);
            } else {
                log.warn("[事件监听] 业务支付更新失败: bizOrderId={}, tradeNo={}, provider={}", outTradeNo, tradeNo, provider);
            }
        } catch (Exception e) {
            log.error("[事件监听] 处理支付成功事件异常", e);
        }
    }
}