package com.everyday.word.controller.client.user;

import com.everyday.word.dto.QQUserInfo;
import com.everyday.word.entity.SystemEnum;
import com.everyday.word.entity.config.SystemConfigKeyEnum;
import com.everyday.word.entity.user.IdentityType;
import com.everyday.word.entity.user.User;
import com.everyday.word.entity.user.UserAuth;
import com.everyday.word.exception.SMSException;
import com.everyday.word.factory.user.UserFactory;
import com.everyday.word.service.inter.SMSService;
import com.everyday.word.service.inter.config.SystemConfigService;
import com.everyday.word.service.inter.user.UserService;
import com.everyday.word.utils.AliyunOneKeyLoginUtil;
import com.everyday.word.vo.AcceptData;
import com.everyday.word.vo.user.UserInfoVO;
import com.google.gson.Gson;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.yeshi.utils.JsonUtil;
import org.yeshi.utils.StringUtil;
import org.yeshi.utils.entity.wx.WeiXinUser;
import org.yeshi.utils.wx.WXAppLoginUtil;

import javax.annotation.Resource;
import javax.servlet.http.HttpSession;
import java.util.List;

/**
 * @author hxh
 * @title: UserController
 * @description:
 * @date 2025/2/7 15:59
 */
@Controller
@RequestMapping("api/user/login")
public class LoginController {

    @Resource
    private SMSService smsService;

    @Resource
    private UserService userService;

    @Resource
    private SystemConfigService systemConfigService;

    private final Gson gson = JsonUtil.getSimpleGson();

    private UserInfoVO getUserInfoVO(Long uid) {
        User user = userService.selectUser(uid);
        if (user == null) {
            return null;
        }
        List<UserAuth> authList = userService.listUserAuth(uid);
        return UserFactory.createVO(user, authList);
    }


    private User loginByPhone(String phone, SystemEnum system) {
        User user = userService.loginByPhone(phone, system);
        if (user == null) {
            // 注册
            userService.register(UserFactory.createAuth(phone, system));
        }
        user = userService.loginByPhone(phone, system);
        return user;
    }

    /**
     * @return java.lang.String
     * @author hxh
     * @description 电话号码登录
     * @date 11:28 2025/2/13
     * @param: acceptData
     * @param: phone
     * @param: vcode
     * @param: accessToken 一键登录的Token
     * @param: session
     **/
    @ResponseBody
    @RequestMapping("phone")
    public String phoneLogin(AcceptData acceptData, String phone, String vcode, HttpSession session) {
        // 电话号码登录
        if (StringUtil.isNullOrEmpty(phone)) {
            return JsonUtil.loadFalseResult("电话号码不能为空");
        }
        if (StringUtil.isNullOrEmpty(vcode)) {
            return JsonUtil.loadFalseResult("验证码不能为空");
        }
        // 验证验证码
        String cacheCode = smsService.getVerifyCode(acceptData.getSystem(), phone, 1);
        if (!vcode.equalsIgnoreCase(cacheCode)) {
            return JsonUtil.loadFalseResult("验证码错误");
        }

        User user = loginByPhone(phone, acceptData.getSystem());
        if (user == null) {
            return JsonUtil.loadFalseResult("登录失败");
        }
        return JsonUtil.loadTrueResult(gson.toJson(getUserInfoVO(user.getId())));
    }

    @ResponseBody
    @RequestMapping("sendVerifyCode")
    public String sendSms(AcceptData acceptData, String phone, Long uid, HttpSession session) {
        try {
            if (phone.contains("**") && uid != null && uid > 0) {
                UserAuth userAuth = userService.selectUserAuth(uid, IdentityType.PHONE);
                if (userAuth == null) {
                    return JsonUtil.loadFalseResult(2, "用户不存在/未绑定手机号");
                }
                phone = userAuth.getIdentifier();
            }

            if (!StringUtil.isMobile(phone)) {
                return JsonUtil.loadFalseResult(4, "电话号码格式不正确");
            }
            smsService.sendVerifyCode(acceptData.getSystem(), phone, 6, 1);
            return JsonUtil.loadTrueResult("发送成功");
        } catch (SMSException e) {
            return JsonUtil.loadFalseResult(e.getCode(), e.getMsg());
        }
    }


    /**
     * @return java.lang.String
     * @author hxh
     * @description 一键登录
     * @date 16:09 2025/2/7
     * @param: acceptData
     * @param: token
     * @param: session
     **/
    @ResponseBody
    @RequestMapping("one_key")
    public String oneKeyLogin(AcceptData acceptData, String token, HttpSession session) {
        String phone = AliyunOneKeyLoginUtil.getMobile(token, "");
        if (StringUtil.isNullOrEmpty(phone)) {
            return JsonUtil.loadFalseResult("手机号获取失败");
        }
        User user = loginByPhone(phone, acceptData.getSystem());
        if (user == null) {
            return JsonUtil.loadFalseResult("登录失败");
        }
        return JsonUtil.loadTrueResult(gson.toJson(getUserInfoVO(user.getId())));
    }


    private WeiXinUser getWeiXinUserByCode(String code, SystemEnum system) {
        String wxAppId = systemConfigService.getValueCache(SystemConfigKeyEnum.wxAppId, system);
        String wxAppSecret = systemConfigService.getValueCache(SystemConfigKeyEnum.wxAppSecret, system);
        if (StringUtil.isNullOrEmpty(wxAppId) || StringUtil.isNullOrEmpty(wxAppSecret)) {
            return null;
        }
        return WXAppLoginUtil.getWeiXinUser(code, wxAppId, wxAppSecret);
    }


    @ResponseBody
    @RequestMapping("wx")
    public String wxLogin(AcceptData acceptData, String code, HttpSession session) {
        if (StringUtil.isNullOrEmpty(code)) {
            return JsonUtil.loadFalseResult("微信授权码未上传");
        }
        WeiXinUser weiXinUser = getWeiXinUserByCode(code, acceptData.getSystem());
        if (weiXinUser == null) {
            return JsonUtil.loadFalseResult("微信授权失败");
        }
        User user = userService.loginByWX(weiXinUser, acceptData.getSystem());
        if (user == null) {
            userService.register(UserFactory.createAuth(weiXinUser, acceptData.getSystem()));
            user = userService.loginByWX(weiXinUser, acceptData.getSystem());
        }
        if (user == null) {
            return JsonUtil.loadFalseResult("登录失败");
        }
        return JsonUtil.loadTrueResult(gson.toJson(getUserInfoVO(user.getId())));
    }

    @ResponseBody
    @RequestMapping("qq")
    public String qqLogin(AcceptData acceptData, QQUserInfo qqUserInfo, HttpSession session) {
        if (StringUtil.isNullOrEmpty(qqUserInfo.getOpenid())) {
            return JsonUtil.loadFalseResult("QQ授权码未上传");
        }
        UserAuth userAuth = UserFactory.createAuth(qqUserInfo, acceptData.getSystem());
        User user = userService.loginByQQ(qqUserInfo.getOpenid(), acceptData.getSystem());
        if (user == null) {
            userService.register(userAuth);
            user = userService.loginByQQ(qqUserInfo.getOpenid(), acceptData.getSystem());
        }
        if (user == null) {
            return JsonUtil.loadFalseResult("登录失败");
        }
        return JsonUtil.loadTrueResult(gson.toJson(getUserInfoVO(user.getId())));
    }


}