package com.mzl.flower.service.system;

import cn.binarywang.wx.miniapp.api.WxMaService;
import cn.binarywang.wx.miniapp.api.WxMaUserService;
import cn.binarywang.wx.miniapp.bean.WxMaJscode2SessionResult;
import cn.binarywang.wx.miniapp.config.WxMaConfig;
import cn.hutool.http.HttpUtil;
import com.google.gson.Gson;
import com.mzl.flower.base.cache.StringCacheClient;
import com.mzl.flower.config.WxMiniappProperties;
import com.mzl.flower.config.exception.ValidationException;
import com.mzl.flower.constant.Constants;
import com.mzl.flower.dto.request.CreateWechatUserDTO;
import com.mzl.flower.service.BaseService;
import lombok.extern.slf4j.Slf4j;
import me.chanjar.weixin.common.error.WxErrorException;
import me.chanjar.weixin.mp.config.WxMpConfigStorage;
import org.apache.commons.httpclient.HttpClient;
import org.apache.commons.httpclient.methods.GetMethod;
import org.apache.commons.httpclient.params.HttpClientParams;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.io.File;
import java.io.IOException;
import java.util.HashMap;
import java.util.Map;

@Service
@Transactional
@Slf4j
public class WeChatService extends BaseService {

    @Autowired
    private StringCacheClient cacheClient;

    @Autowired
    private WxMaService maService;

    @Autowired
    private WxMpConfigStorage wxMpConfigStorage;

    @Autowired
    private WxMiniappProperties wxMiniappProperties;

    @Autowired
    private Gson gson;

    /**
     * 小程序获取会话信息-花店端
     * @param code
     * @return
     * @throws WxErrorException
     */
    public WxMaJscode2SessionResult getWxMaSessionInfo(String code) throws WxErrorException {
        WxMaJscode2SessionResult result = maService.jsCode2SessionInfo(code);
        return result;
    }

    public void getWxMaUserPhone(String code) throws WxErrorException {
        WxMaUserService us = maService.getUserService();
        WxMaJscode2SessionResult session = us.getSessionInfo(code);
        //sessionKey, encryptedData, iv
        us.getPhoneNoInfo(session.getSessionKey(), "", "");
    }

    /**
     * 小程序获取openid
     * @param code
     * @return
     * @throws IOException
     */
    public Map<String, Object> getWechatOpenId(String code,String userType) throws IOException {
        if (StringUtils.isEmpty(code)) {
            throw new ValidationException("微信code为空");
        }
        String appId = null;
        String secret = null;
        if(Constants.USER_TYPE.customer.name().equals(userType)){
            WxMiniappProperties.Miniapp customer = wxMiniappProperties.getCustomer();
            appId = customer.getAppid();
            secret = customer.getSecret();
        }else if(Constants.USER_TYPE.partner.name().equals(userType)){
            WxMiniappProperties.Miniapp customer = wxMiniappProperties.getPartner();
            appId = customer.getAppid();
            secret = customer.getSecret();
        }else if(Constants.USER_TYPE.supplier.name().equals(userType)){
            WxMiniappProperties.Miniapp customer = wxMiniappProperties.getSupplier();
            appId = customer.getAppid();
            secret = customer.getSecret();
        }else{
            throw new ValidationException("用户类型不支持");
        }
        String param = "?grant_type=authorization_code&appid=" + appId + "&secret=" + secret + "&js_code=" + code;
        String url = "https://api.weixin.qq.com/sns/jscode2session" + param;

        HttpClient http = new HttpClient();
        http.getParams().setParameter(HttpClientParams.ALLOW_CIRCULAR_REDIRECTS, true);

        GetMethod get = new GetMethod(url);

        http.executeMethod(get);
        String json = get.getResponseBodyAsString();
        Map<String, Object> map = parseObject(json, Map.class);
        Object errcode = map.get("errcode");
        if(errcode != null){
            String errmsg = (String)map.get("errmsg");
            throw new ValidationException(errmsg);
        }

        return map;
    }

    /**
     * 获取公众号accessToken
     * @return
     */
    public String getGZHAccessToken(){
        String appId = wxMpConfigStorage.getAppId();
        String secret = wxMpConfigStorage.getSecret();

        return getAccessToken(appId, secret);
    }

    public String getAccessToken(String appId, String secret){
        if(StringUtils.isEmpty(appId) || StringUtils.isEmpty(secret)){
            return null;
        }
        String key = "WX_" + appId;
        String token = cacheClient.get(key);
        if(StringUtils.isEmpty(token)){
            Map<String, Object> map = getAccessTokenFromWeiXin(appId, secret);
            token = (String) map.get("access_token");
            Integer expiresIn = (Integer) map.get("expires_in");
            cacheClient.set(key, token, expiresIn - 100);
        }

        return token;
    }

    private Map<String, Object> getAccessTokenFromWeiXin(String appId, String secret){
        String url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=" + appId + "&secret=" + secret;
        try{
            HttpClient http = new HttpClient();
            GetMethod get = new GetMethod(url);
            http.executeMethod(get);
            String json = get.getResponseBodyAsString();
            Map<String, Object> map = parseObject(json, Map.class);
            Object errcode = map.get("errcode");
            if(errcode != null){
                String errmsg = (String)map.get("errmsg");
                log.error(errcode + ":" + errmsg);
                throw new ValidationException(errmsg);
            }

            return map;
        }catch (IOException e){
            log.error(e.getMessage(), e);
            throw new ValidationException(e.getMessage());
        }
    }
    public Map<String,Object> getuserphonenumber(CreateWechatUserDTO dto) {
        if (StringUtils.isEmpty(dto.getCode())) {
            throw new ValidationException("微信code为空");
        }

        String accessToken="";
        try {
            accessToken=maService.getAccessToken();
        } catch (WxErrorException e) {
            throw new RuntimeException(e);
        }

        if(StringUtils.isEmpty(accessToken)){
            accessToken=getAccessToken(
                    wxMiniappProperties.getCustomer().getAppid(),
                    wxMiniappProperties.getCustomer().getSecret());
            if(StringUtils.isEmpty(accessToken)){
                throw new ValidationException("获取微信AccessToken失败");
            }
        }


        String url = "https://api.weixin.qq.com/wxa/business/getuserphonenumber?access_token="+ accessToken;
        try{
            Map<String,Object> params=new HashMap<String,Object>();
            params.put("code",dto.getCode());
            String result = HttpUtil.post(url, gson.toJson(params));
            System.out.println(result);
            Map<String,Object> resultMap=gson.fromJson(result,Map.class);
            if(!resultMap.get("errmsg").equals("ok")){
                String errmsg = (String)resultMap.get("errmsg");
                log.error(resultMap.get("errcode") + ":" + errmsg);
                throw new ValidationException(errmsg);
            }
            return resultMap;
        }catch (Exception e){
            log.error(e.getMessage(), e);
            throw new ValidationException(e.getMessage());
        }
    }
}