package cn.iocoder.yudao.module.wxcp.service.listener;

import cn.iocoder.yudao.module.system.enums.social.SocialTypeEnum;
import cn.iocoder.yudao.module.system.event.SocialLoginEvent;
import cn.iocoder.yudao.module.wxcp.service.notify.WxCpNotifyService;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import org.springframework.transaction.event.TransactionPhase;
import org.springframework.transaction.event.TransactionalEventListener;

/**
 * 企业微信登录事件监听器
 *
 * 监听社交登录成功事件，当登录方式为企业微信时，发送登录通知消息
 *
 * @author 超级管理员
 */
@Component
@Slf4j
public class WxCpLoginEventListener {

    @Resource
    private WxCpNotifyService wxCpNotifyService;

    /**
     * 监听社交登录事件
     *
     * 使用 AFTER_COMMIT：确保事务提交后再发送通知，
     * 否则异步线程查询绑定关系时会因事务未提交而查不到记录（首次自动注册场景尤其明显）
     * fallbackExecution = true：调用方无事务时也正常触发
     */
    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT, fallbackExecution = true)
    public void onSocialLogin(SocialLoginEvent event) {
        // 仅处理企业微信登录事件
        if (!SocialTypeEnum.WECHAT_ENTERPRISE.getType().equals(event.getSocialType())) {
            return;
        }

        log.info("[onSocialLogin][收到企业微信登录事件 userId={} username={}]",
                event.getUserId(), event.getUsername());

        // 发送企业微信登录通知
        wxCpNotifyService.sendLoginNotification(
                event.getUserId(),
                event.getUsername(),
                event.getLoginType());
    }

}