package com.project.common.utils;

import cn.hutool.http.HttpUtil;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.project.common.exception.base.BaseException;
import com.project.common.utils.http.HttpUtils;
import com.project.common.vo.UserWxPhoneInfoVO;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.CommandLineRunner;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Component;
import java.util.*;
import java.util.concurrent.TimeUnit;

import static com.project.common.constant.WechatConstants.*;


@Component
@Slf4j
public class WeChatUtils implements CommandLineRunner {

    @Override
    public void run(String... args) throws Exception {
        getAccessToken();
    }

    private static StringRedisTemplate stringRedisTemplate;

    @Autowired
    public void setStringRedisTemplate(StringRedisTemplate stringRedisTemplate) {
        WeChatUtils.stringRedisTemplate = stringRedisTemplate;
    }

    private static String appid;

    private static String secret;

    @Value("${pay.wx.xcx.appid}")
    public void setAppid(String appid) {
        this.appid = appid;
    }

    @Value("${pay.wx.xcx.secret}")
    public void setSecret(String secret) {
        this.secret = secret;
    }


    /**
     * 刷新access_token
     */
    public static void refreshAccessToken() {
        String url = WEIXIN_ACCESS_TOKEN_URL + "?grant_type=client_credential&appid=" + appid + "&secret=" + secret;
        try {
            //向微信发送请求
            String result = HttpUtils.sendGet(url, null);
            //将获取的结果转化为JSONObject
            JSONObject re = JSON.parseObject(result);
            String accessToken = re.getString("access_token");
            //设置access_token的生命周期为1小时
            int expires_in = 3600;
            if (StringUtils.isNotBlank(accessToken)) {
                stringRedisTemplate
                        .opsForValue()
                        .set(appid + ":access_token", accessToken, expires_in, TimeUnit.SECONDS);
            }
        } catch (Exception e) {
            log.error("getAccess_token ERROR, appid = " + appid, e);
        }
    }

    /**
     * 获取微信公众号access_token
     * @return
     */
    public static String getAccessToken()
    {
        String accessToken = stringRedisTemplate.opsForValue().get(appid + ":access_token");
        if (StringUtils.isBlank(accessToken)) {
            String url = WEIXIN_ACCESS_TOKEN_URL + "?grant_type=client_credential&appid=" + appid + "&secret=" + secret;
            try {
                //向微信发送请求
                String result = HttpUtils.sendGet(url, null);
                //将获取的结果转化为JSONObject
                JSONObject re = JSON.parseObject(result);
                accessToken = re.getString("access_token");
                //设置access_token的生命周期为1小时
                int expires_in = 3600;
                if (StringUtils.isNotBlank(re.getString("expires_in"))) {
                    expires_in = re.getIntValue("expires_in");
                }
                if (StringUtils.isNotBlank(accessToken)) {
                    stringRedisTemplate
                            .opsForValue()
                            .set(appid + ":access_token", accessToken, expires_in, TimeUnit.SECONDS);
                }
            } catch (Exception e) {
                log.error("getAccess_token ERROR, appid = " + appid, e);
            }
        }
        return accessToken;
    }

    /**
     * 获取微信用户信息
     *
     * @param accessToken 用户的access_token
     * @param openid 用户的openid
     * @return 包含用户信息的Map
     * @throws Exception
     */
    public static Map<String, String> getUserInfo(String accessToken, String openid) throws Exception
    {
        String url = USER_INFO_URL + "?access_token=" + accessToken + "&openid=" + openid + "&lang=zh_CN";
        String result  = HttpUtils.sendGet(url, null);
        JSONObject jsonObject = JSON.parseObject(result);
        System.out.println(jsonObject.toString());
        String unionid = jsonObject.getString("unionid");
        String nickname = jsonObject.getString("nickname");
        String avatar = jsonObject.getString("headimgurl");
        String phoneNumber = jsonObject.getString("phoneNumber"); // 获取用户手机号需要用户在小程序内进行授权
        Map<String, String> map = new HashMap<>();
        map.put("unionId", unionid);
        map.put("nickname", nickname);
        map.put("avatar", avatar);
        map.put("phoneNumber", phoneNumber);
        return map;
    }



    /**
     * 获取用户手机号
     * @return
     */
    public static String getUserPhone(String accessToken, String code)
    {
        String phone = "";
        String urlPath = WEIXIN_GET_USERPHONENUMBER_URL + accessToken;
        try {
            Map<String, String> headerMap = new HashMap<>();
            headerMap.put("content-type", "application/json");
            Map<String, Object> dataMap = new HashMap<>();
            dataMap.put("code", code);
            String result = HttpUtils.callPostServices(urlPath, dataMap, headerMap);
            JSONObject re = JSON.parseObject(result);
            if (re.getString("errmsg").equals("ok")) {
                String resultStr = re.getString("phone_info");
                UserWxPhoneInfoVO phoneInfoVO = JSONObject.parseObject(resultStr, UserWxPhoneInfoVO.class);
                if (phoneInfoVO != null) {
                    phone = phoneInfoVO.getPhoneNumber();
                }
            } else {
                log.error("getUserPhone ERROR " + re.getString("errmsg"));
                stringRedisTemplate.delete(appid + ":access_token");
            }
        } catch (Exception e) {
            log.error("getUserPhone ERROR, accessToken = " + accessToken, e);
        }
        return phone;
    }


    /**
     * 获取用户小程序openID
     * @param code
     * @return
     */
    public static String getOpenId(String code)
    {
        //通过小程序端的code获取openid
        StringBuilder urlPath = new StringBuilder(WEIXIN_JSCODE2SESSION_URL);
        urlPath.append(String.format("?appid=%s", appid));
        urlPath.append(String.format("&secret=%s", secret));
        urlPath.append(String.format("&js_code=%s", code));
        urlPath.append(String.format("&grant_type=%s", "authorization_code"));
        //向微信发送请求
        String result = HttpUtils.sendGet(urlPath.toString(), null);
        //将获取的结果转化为JSONObject
        JSONObject object = JSON.parseObject(result);
        if(object != null && StringUtils.isNotBlank(object.getString("openid"))){
            result = object.getString("openid");
        }else{
            throw new BaseException("获取用户openid失败！");
        }
        return result;
    }



    /**
     * 小程序授权获取openID和unionID
     *
     * @return
     */
    public static Map<String, String> oauth2GetUnion(String code) {

        //通过小程序端的code获取openid
        StringBuilder urlPath = new StringBuilder(WEIXIN_JSCODE2SESSION_URL);
        urlPath.append(String.format("?appid=%s", appid));
        urlPath.append(String.format("&secret=%s", secret));
        urlPath.append(String.format("&js_code=%s", code));
        urlPath.append(String.format("&grant_type=%s", "authorization_code"));
        //向微信发送请求
        String resultStr = HttpUtils.sendGet(urlPath.toString(), null);

        Map<String, String> result = new HashMap<>();
        //将获取的结果转化为JSONObject
        JSONObject object = JSON.parseObject(resultStr);
        if(object != null && StringUtils.isNotBlank(object.getString("openid"))){
            result.put("wxOpenid", object.getString("openid"));
            result.put("unionId", object.getString("unionid"));
            result.put("sessionKey", object.getString("session_key"));
        }else{
            throw new BaseException("获取用户openid失败！");
        }
        return result;

    }


}