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

import cn.iocoder.yudao.framework.common.enums.UserTypeEnum;
import cn.iocoder.yudao.module.system.dal.dataobject.social.SocialUserBindDO;
import cn.iocoder.yudao.module.system.dal.dataobject.social.SocialUserDO;
import cn.iocoder.yudao.module.system.dal.mysql.social.SocialUserBindMapper;
import cn.iocoder.yudao.module.system.dal.mysql.social.SocialUserMapper;
import cn.iocoder.yudao.module.system.enums.social.SocialTypeEnum;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import me.chanjar.weixin.cp.api.WxCpService;
import me.chanjar.weixin.cp.bean.message.WxCpMessage;
import me.chanjar.weixin.cp.bean.message.WxCpMessageSendResult;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;

/**
 * 企业微信消息通知服务
 *
 * @author 超级管理员
 */
@Service
@Slf4j
public class WxCpNotifyService {

    @Resource
    private WxCpService wxCpService;

    @Resource
    private SocialUserBindMapper socialUserBindMapper;

    @Resource
    private SocialUserMapper socialUserMapper;

    /**
     * 发送登录通知消息到企业微信
     *
     * @param userId     系统用户 ID
     * @param username   用户登录名
     * @param loginType  登录方式（如：账号密码、短信、社交）
     */
    @Async
    public void sendLoginNotification(Long userId, String username, String loginType) {
        try {
            // 1. 查询用户绑定的企业微信
            String wxUserId = getWxUserId(userId);
            if (wxUserId == null) {
                log.info("[sendLoginNotification][用户({})未绑定企业微信，跳过通知]", userId);
                return;
            }

            // 2. 构造文本消息
            // 注意：不能用 TEXTCARD —— 企业微信要求 textcard 的 url 必填，
            // 留空会返回 41010 missing url，导致通知全部发送失败
            String time = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
            WxCpMessage message = WxCpMessage.TEXT()
                    .toUser(wxUserId)
                    .content(String.format(
                            "【登录通知】您的账号于 %s 通过「%s」方式登录系统。\n如非本人操作，请立即修改密码。",
                            time, loginType))
                    .build();

            // 3. 发送消息
            WxCpMessageSendResult result = wxCpService.getMessageService().send(message);
            if (result.getErrCode() == 0) {
                log.info("[sendLoginNotification][企业微信登录通知发送成功 userId={} wxUserId={}]", userId, wxUserId);
            } else {
                log.warn("[sendLoginNotification][企业微信登录通知发送失败 userId={} wxUserId={} errCode={} errMsg={}]",
                        userId, wxUserId, result.getErrCode(), result.getErrMsg());
            }
        } catch (Exception e) {
            log.error("[sendLoginNotification][企业微信登录通知发送异常 userId={}]", userId, e);
        }
    }

    /**
     * 发送普通文本消息到企业微信
     *
     * @param userId  系统用户 ID
     * @param content 消息内容
     */
    @Async
    public void sendTextMessage(Long userId, String content) {
        try {
            String wxUserId = getWxUserId(userId);
            if (wxUserId == null) {
                return;
            }

            WxCpMessage message = WxCpMessage.TEXT()
                    .toUser(wxUserId)
                    .content(content)
                    .build();

            WxCpMessageSendResult result = wxCpService.getMessageService().send(message);
            if (result.getErrCode() == 0) {
                log.info("[sendTextMessage][企业微信文本消息发送成功 userId={}]", userId);
            } else {
                log.warn("[sendTextMessage][企业微信文本消息发送失败 userId={} errCode={} errMsg={}]",
                        userId, result.getErrCode(), result.getErrMsg());
            }
        } catch (Exception e) {
            log.error("[sendTextMessage][企业微信文本消息发送异常 userId={}]", userId, e);
        }
    }

    /**
     * 根据系统用户 ID 获取企业微信 UserId
     *
     * @param userId 系统用户 ID
     * @return 企业微信 UserId（即 openid）
     */
    private String getWxUserId(Long userId) {
        // 1. 查绑定关系
        SocialUserBindDO bind = socialUserBindMapper.selectByUserIdAndUserTypeAndSocialType(
                userId, UserTypeEnum.ADMIN.getValue(), SocialTypeEnum.WECHAT_ENTERPRISE.getType());
        if (bind == null) {
            return null;
        }

        // 2. 查社交用户信息
        SocialUserDO socialUser = socialUserMapper.selectById(bind.getSocialUserId());
        if (socialUser == null) {
            return null;
        }

        return socialUser.getOpenid();
    }

}