package com.nuvole.util;

import cn.hutool.core.bean.BeanUtil;
import cn.hutool.http.HttpUtil;
import com.nuvole.common.domain.wx.PushMsg;
import com.nuvole.constants.ServiceConstants;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.httpclient.HttpClient;
import org.apache.commons.httpclient.HttpStatus;
import org.apache.commons.httpclient.methods.PostMethod;
import org.apache.commons.httpclient.params.HttpMethodParams;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpMethod;
import org.springframework.http.ResponseEntity;
import org.springframework.util.LinkedMultiValueMap;
import org.springframework.util.MultiValueMap;
import org.springframework.web.client.RestTemplate;

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

/**
 * @Description: 外网接口请求工具类（微信）
 * @Author: liujun
 * @Date: 2019-07-25 11:59
 **/
@Slf4j
public class WxCallUtil {

    /**
     * 获取临时登录凭证code
     *
     * @param jsCode
     * @return
     */
    public static String getOpenidSessionKey(String jsCode) {
        String url = ServiceConstants.SERVICE_JSCODE2SESSION_URL;
        Map<String, Object> paramMap = new HashMap<>(1);
        paramMap.put("jsCode", jsCode);
        return HttpUtil.get(url, paramMap);
    }

    /**
     * 获取AccessToken
     *
     * @return
     */
    public static String getAccessToken() {
        String url = ServiceConstants.SERVICE_TOKEN_URL;
        String result = HttpUtil.get(url);
        log.info("getAccessToken 返回值： {}", result);
        return result;
    }

    /**
     * 获取 jsapi_ticket
     *
     * @return
     */
    public static String getJsapTicket(String accessToken) {
        String url = ServiceConstants.SERVICE_JSAPITICKET_URL;
        Map<String, Object> paramMap = new HashMap<>(1);
        paramMap.put("accessToken", accessToken);
        return HttpUtil.get(url, paramMap);
    }

    /**
     * 微信公众号获取access_token
     *
     * @param code
     * @return
     */
    public static String getWechatAccessToken(String code) {
        String url = ServiceConstants.SERVICE_ACCESS_TOKEN_URL;
        Map<String, Object> paramMap = new HashMap<>(1);
        paramMap.put("code", code);
        return HttpUtil.get(url, paramMap);
    }

    /**
     * 微信公众号获取用户信息
     *
     * @param accessToken
     * @param openId
     * @return
     */
    public static String getWechatUserInfo(String accessToken, String openId) {
        String url = ServiceConstants.SERVICE_USERINFO_URL;
        Map<String, Object> paramMap = new HashMap<>(2);
        paramMap.put("accessToken", accessToken);
        paramMap.put("openId", openId);
        return HttpUtil.get(url, paramMap);
    }

    /**
     * 获取小程序码（前提是已发布）
     *
     * @param accessToken
     * @param scene
     * @param width
     * @param page
     * @return
     */
    public static byte[] getQRcode(String accessToken, String scene, int width, String page) {
        byte[] result = null;
        String url = ServiceConstants.SERVICE_WXACODEUNLIMIT_URL;
        if (false) {
            HttpClient client = new HttpClient();
            PostMethod method = new PostMethod(url);
            HttpMethodParams paramMap = new HttpMethodParams();
            paramMap.setParameter("accessToken", accessToken);
            paramMap.setParameter("scene", scene);
            paramMap.setParameter("width", width);
            paramMap.setParameter("page", page);
            method.setParams(paramMap);
            try {
                int statusCode = client.executeMethod(method);
                if (statusCode != HttpStatus.SC_OK) {
                    log.info("Method failed: " + method.getStatusLine());
                } else {
                    // 返回响应消息
                    result = method.getResponseBodyAsString().getBytes(method.getResponseCharSet());
                }
                method.releaseConnection();
            } catch (IOException e) {
                e.printStackTrace();
            }
        } else {
            RestTemplate rest = new RestTemplate();
            try {
                Map<String, Object> param = new HashMap<>();
                url = url + "?accessToken=" + accessToken + "&scene=" + scene + "&width=" + width + "&page=" + page;
                MultiValueMap<String, String> headers = new LinkedMultiValueMap<>();
                HttpEntity requestEntity = new HttpEntity(param, headers);
                ResponseEntity<byte[]> entity = rest.exchange(url, HttpMethod.POST, requestEntity, byte[].class,
                        new Object[0]);
                result = entity.getBody();
                /*BASE64Encoder encoder = new BASE64Encoder();
                String imageStr = encoder.encode(result);
                imageStr = HtmlUtils.htmlEscape(imageStr);
                BASE64Decoder decoder = new BASE64Decoder();
                result = decoder.decodeBuffer(imageStr);*/
            } catch (Exception e) {
                log.error("调用小程序生成微信永久小程序码URL接口异常", e);
            }
        }
        return result;
    }

    /**
     * 微信推送消息
     *
     * @param openId
     * @param formId
     * @param templateId
     * @param page
     * @param items
     */
    public static void push(String openId, String formId, String templateId, String page, List<String> items) {
        String url = ServiceConstants.SERVICE_TEMPLATE_SEND_URL;
        Map<String, Object> paramMap = new HashMap<>(5);
        paramMap.put("openId", openId);
        paramMap.put("formId", formId);
        paramMap.put("templateId", templateId);
        paramMap.put("page", page);
        paramMap.put("items", CommonUtil.listToString(items));
        HttpUtil.get(url, paramMap);
    }


    /* *
     * 微信小程序订阅消息推送
     *
     * @author lc
     * @date 2020/1/2 14:28
     */
    public static void pushSend(PushMsg pushMsg, String accessToken) {
        String url = ServiceConstants.SERVICE_SUBSCRIBER_SEND_URL;
        Map<String, Object> paramMap = BeanUtil.beanToMap(pushMsg);
        paramMap.put("accessToken", accessToken);
        HttpUtil.get(url, paramMap);
    }
}