package com.wondertek.util;

import cn.hutool.http.HttpRequest;
import cn.hutool.http.HttpResponse;
import cn.hutool.http.HttpUtil;
import cn.hutool.json.JSONUtil;
import lombok.extern.slf4j.Slf4j;

import org.apache.commons.lang3.StringUtils;
import org.apache.http.NameValuePair;
import org.apache.http.client.HttpClient;
import org.apache.http.client.ResponseHandler;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.impl.client.BasicResponseHandler;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.impl.conn.tsccm.ThreadSafeClientConnManager;

import java.nio.charset.Charset;
import java.text.MessageFormat;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.TimeUnit;

@SuppressWarnings("deprecation")
@Slf4j
public class HttpClientUtils {
    private static HttpClient httpClient = null;

    /**
     * 生产HttpClient实例
     * 公开，静态的工厂方法，需要使用时才去创建该单体
     *
     * @return
     */
    public static HttpClient getHttpClient() {
        if (httpClient == null) {
            httpClient = new DefaultHttpClient(new ThreadSafeClientConnManager());
        }
        return httpClient;
    }

    /**
     * POST方式调用
     *
     * @param url
     * @param obj 参数为实体类对象
     * @return 响应字符串
     * @throws java.io.UnsupportedEncodingException
     */
    public static String executeByPOST(String url, Object obj) {
        log.info("启动http请求，url:{},发送内容:{}", url, JSONUtil.toJsonStr(obj));
        try {
            HttpResponse execute = HttpRequest.post(url).body(JSONUtil.toJsonStr(obj)).timeout(10000).execute();
            if (execute.isOk()) {
                String body = execute.body();
                log.info("完成执行http请求，url:{},出参:{}", url, body);
                return body;
            } else {
                log.info("完成执行http请求，url:{},出参:{}", url, execute.body());
            }
        } catch (Exception e) {
            log.error("完成执行http请求,url:{},异常:请求体:{},错误信息:{}", url, obj,e.getMessage());

        }
        return null;
    }


    /**
     * POST方式调用
     *
     * @param url
     * @param obj 参数为实体类对象
     * @return 响应字符串
     * @throws java.io.UnsupportedEncodingException
     */
    public static String executeByPOST(String url, String obj) {
        log.info("启动http请求，url:{},发送内容:{}", url, obj);
        try {
            HttpResponse execute = HttpRequest.post(url).body(obj).timeout(10000).execute();
            if (execute.isOk()) {
                String body = execute.body();
                log.info("完成执行http请求，url:{},出参:{}", url, body);
                return body;
            } else {
                log.info("完成执行http请求，url:{},出参:{}", url, execute.body());
            }
        } catch (Exception e) {
            log.error("完成执行http请求,url:{},异常:请求体:{},错误信息:{}", url, obj,e.getMessage());
        }
        return null;
    }

    public static Map<String,String> executeByPOST(String info,String url, String obj) {
        log.info(info+"===>启动http请求，url:{},发送内容:{}", url, obj);
        Map<String,String> resMap= new HashMap<>();
        try {
            HttpResponse execute = HttpRequest.post(url).body(obj).timeout(10000).execute();
            if (execute.isOk()) {
                String body = execute.body();
                log.info(info+"===>完成执行http请求，url:{},出参:{}", url, body);
                resMap.put("data",body);
                resMap.put("code","200");
            } else {
                log.info(info+"===>完成执行http请求，url:{},出参:{}", url, execute.body());
                resMap.put("data",execute.body());
                resMap.put("code","500");
            }
        } catch (Exception e) {
            log.error("完成执行http请求,url:{},异常:请求体:{},错误信息:{}", url, obj,e.getMessage());
        }
        return null;
    }

    public static String executeByPUT(String url, String obj) {
        log.info("启动http请求，url:{},发送内容:{}", url, obj);
        try {
            HttpResponse execute = HttpRequest.put(url).body(obj).timeout(10000).execute();
            if (execute.isOk()) {
                String body = execute.body();
                log.info("完成执行http请求，url:{},出参:{}", url, body);
                return body;
            } else {
                log.info("完成执行http请求，url:{},出参:{}", url, execute.body());
            }
        } catch (Exception e) {
            log.error("完成执行http请求,url:{},异常:请求体:{},错误信息:{}", url, obj,e.getMessage());
        }
        return null;
    }

    public static String executeByDELETE(String url, String obj) {
        log.info("启动http请求，url:{},发送内容:{}", url, obj);
        try {
            HttpResponse execute = HttpRequest.delete(url).body(obj).timeout(10000).execute();
            if (execute.isOk()) {
                String body = execute.body();
                log.info("完成执行http请求，url:{},出参:{}", url, body);
                return body;
            } else {
                log.info("完成执行http请求，url:{},出参:{}", url, execute.body());
            }
        } catch (Exception e) {
            log.error("完成执行http请求,url:{},异常:请求体:{},错误信息:{}", url, obj,e.getMessage());
        }
        return null;
    }


    /**
     * POST方式调用
     *
     * @param url
     * @param params 参数为NameValuePair键值对对象
     * @return 响应字符串
     * @throws java.io.UnsupportedEncodingException
     */
    public static String executeByPOST(String url, List<NameValuePair> params) {
        HttpClient httpclient = getHttpClient();

        HttpPost post = new HttpPost(url);
        RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(30000).setSocketTimeout(180000).build();
        post.setConfig(requestConfig);

        ResponseHandler<String> responseHandler = new BasicResponseHandler();
        String responseJson = null;
        try {
            if (params != null) {
                post.setEntity(new UrlEncodedFormEntity(params));
            }
            responseJson = httpclient.execute(post, responseHandler);
            log.info("HttpClient POST请求结果：" + responseJson);
        } catch (Exception e) {
            log.info("HttpClient POST请求异常：" + e.getMessage());
        } finally {
            httpclient.getConnectionManager().closeExpiredConnections();
            httpclient.getConnectionManager().closeIdleConnections(30, TimeUnit.SECONDS);
        }
        return responseJson;
    }


    /**
     * POST方式调用
     *
     * @param url
     * @param xml 请求Json字符串
     * @param headerMap 自定义头
     * @return 响应字符串
     * @throws java.io.UnsupportedEncodingException
     */
    public static String executeByPOST(String url, String xml, Map<String,String> headerMap) {
        log.info("启动http请求，url:{},发送内容:{},请求头：{}", url, xml, JSONUtil.toJsonStr(headerMap));
        try {
            HttpRequest request = HttpRequest.post(url);
            if(null != headerMap) {
                request.headerMap(headerMap, true);
            }
            HttpResponse execute = request.body(xml).timeout(10000).execute();
            String body = execute.body();
            log.info("完成执行http请求，url:{},出参:{}", url, body);
            return body;
        } catch (Exception e) {
            log.error("完成执行http请求,url:{},异常:请求体:{},错误信息:{}", url, xml,e.getMessage());
            throw e;
        }
    }

    public static String executeByGET(String url, Object[] params) {
        HttpClient httpclient = getHttpClient();

        String messages = MessageFormat.format(url, params);

        HttpGet get = new HttpGet(messages);
        RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(30000).setSocketTimeout(180000).build();
        get.setConfig(requestConfig);
        ResponseHandler<String> responseHandler = new BasicResponseHandler();
        String responseJson = null;
        try {
            responseJson = httpclient.execute(get, responseHandler);
        } catch (Exception e) {
            log.info("HttpClient GET请求异常，url:{},error:{}", messages, e.getMessage());
        } finally {
            httpclient.getConnectionManager().closeExpiredConnections();
            httpclient.getConnectionManager().closeIdleConnections(30, TimeUnit.SECONDS);
        }
        return responseJson;
    }



    public static String executeByGET(String url) {

        String responseBody = null;
        try {
            log.info(">>>HTTP get请求，请求URL：" + url);
            HttpRequest httpGet = HttpUtil.createGet(url);
            httpGet.setConnectionTimeout(2000).setReadTimeout(5000);
            HttpResponse response = httpGet.execute();
            response.charset(Charset.defaultCharset());
            if (response.isOk()) {
                responseBody = response.body();
                if (StringUtils.isNotBlank(responseBody)) {
                    log.info(">>>HTTP get请求,请求成功" + ",请求结果长度:" + responseBody.length());
                }
            }
        } catch (Exception e) {
            log.warn("HTTP get请求URL:" + url + ",请求异常:" + e.getMessage());
        }
        return responseBody;

        /*
         * HttpClient httpclient = getHttpClient();
         *
         * HttpParams params = httpClient.getParams();
         * params.setParameter(ClientPNames.HANDLE_REDIRECTS, false);
         *
         * HttpGet get = new HttpGet(url);
         * RequestConfig requestConfig =
         * RequestConfig.custom().setConnectTimeout(2000).setSocketTimeout(5000).build()
         * ;
         * get.setConfig(requestConfig);
         * ResponseHandler<String> responseHandler = new BasicResponseHandler();
         * String responseJson = null;
         * try {
         * responseJson = httpclient.execute(get, responseHandler);
         * log.info(">>>HttpClient请求URL:"+url+ ",请求结果长度:"+ responseJson.length());
         * } catch (Exception e) {
         * log.warn("HttpClient请求URL:"+url+",请求异常:" + e.getMessage());
         * } finally {
         * httpclient.getConnectionManager().closeExpiredConnections();
         * httpclient.getConnectionManager().closeIdleConnections(30, TimeUnit.SECONDS);
         * }
         * return responseJson;
         */
    }

    /** 仅限用于get请求，传递媒资id列表，其他格式未必适合
     * get请求传参，传入url和list数组
     * 如：http://localhost:8920/oes-csas-manage/es-operate/sync5?assetIds=20210261500049,20210261500053
     * @Param [url, assetIdList]
     * @return java.lang.String
     **/
    public static String executeByGET(String url, List<Long> assetIdList) {
        HttpClient httpclient = getHttpClient();
        StringBuilder buffer = new StringBuilder();
        for (Long assetId : assetIdList) {
            buffer.append(assetId).append(",");
        }
        String substring = buffer.substring(0, buffer.length()-1);
//        String messages = MessageFormat.format(url, substring);
        String messages = url+substring;
        log.info("get请求 messages = " + messages);
        HttpGet get = new HttpGet(messages);
        RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(30000).setSocketTimeout(180000).build();
        get.setConfig(requestConfig);
        ResponseHandler<String> responseHandler = new BasicResponseHandler();
        String responseJson = null;
        try {
            responseJson = httpclient.execute(get, responseHandler);
        } catch (Exception e) {
            log.info("HttpClient GET请求异常：" + e.getMessage());
        } finally {
            httpclient.getConnectionManager().closeExpiredConnections();
            httpclient.getConnectionManager().closeIdleConnections(30, TimeUnit.SECONDS);
        }
        return responseJson;
    }

    /**
     * 带cookie的get请求
     *
     * @param url 请求路径
     * @param cookie cookie
     * @return 请求结果
     */
    public static String executeByGET(String url, String cookie) {

        String responseBody = null;
        try {
            log.info(">>>带cookie的HTTP请求，请求URL：" + url);
            HttpRequest httpGet = HttpUtil.createGet(url);
            httpGet.cookie(cookie);
            httpGet.setConnectionTimeout(2000).setReadTimeout(5000);
            HttpResponse response = httpGet.execute();
            response.charset(Charset.defaultCharset());
            if (response.isOk()) {
                responseBody = response.body();
                if (StringUtils.isNotBlank(responseBody)) {
                    log.info(">>>带cookie的HTTP请求,请求成功" + ",请求结果长度:" + responseBody.length());
                }
            }
        } catch (Exception e) {
            log.warn("HttpClient请求URL:" + url + ",请求异常:" + e.getMessage());
        }
        return responseBody;

        /*
         * HttpClient httpclient = getHttpClient();
         *
         * HttpParams params = httpClient.getParams();
         * params.setParameter(ClientPNames.HANDLE_REDIRECTS, false);
         *
         * HttpGet get = new HttpGet(url);
         * RequestConfig requestConfig =
         * RequestConfig.custom().setConnectTimeout(2000).setSocketTimeout(5000).build()
         * ;
         * get.setConfig(requestConfig);
         * ResponseHandler<String> responseHandler = new BasicResponseHandler();
         * String responseJson = null;
         * try {
         * get.setHeader("Cookie",cookie);
         * responseJson = httpclient.execute(get, responseHandler);
         * log.info(">>>HttpClient请求URL:"+url+ ",请求结果长度:"+ responseJson.length());
         * } catch (Exception e) {
         * log.warn("HttpClient请求URL:"+url+",请求异常:" + e.getMessage());
         * } finally {
         * httpclient.getConnectionManager().closeExpiredConnections();
         * httpclient.getConnectionManager().closeIdleConnections(30, TimeUnit.SECONDS);
         * }
         * return responseJson;
         */
    }

}