import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.URI;
import java.security.KeyStore;
import java.security.cert.CertificateException;
import java.security.cert.X509Certificate;
import java.util.ArrayList;
import java.util.HashMap;
 
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;

import javax.net.ssl.SSLContext;

import org.apache.http.HttpEntity;
import org.apache.http.HttpHost;
import org.apache.http.HttpStatus;
import org.apache.http.NameValuePair;
import org.apache.http.auth.AuthScope;
import org.apache.http.auth.Credentials;
 
import org.apache.http.auth.UsernamePasswordCredentials;
import org.apache.http.client.CredentialsProvider;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
 
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.utils.URIBuilder;
import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
import org.apache.http.conn.ssl.SSLContexts;
import org.apache.http.conn.ssl.TrustStrategy;
import org.apache.http.impl.client.BasicCredentialsProvider;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.protocol.HTTP;
import org.apache.http.util.EntityUtils;


/**
 * @author sprinng
 * @Description jdk >=1.7 相容http https
 *
 */
public class HttpUtils {

    private static CloseableHttpClient httpClientBuilder=null;
    
    /**
     *    http 和 https 
     * @param useProxy 是否使用代理
     * @param needCert 是否需要證書
     * @return
     */
    private static CloseableHttpClient createSSLClientDefault(boolean useProxy,boolean needCert) {
        SSLConnectionSocketFactory sslsf = null;
        try {
            if(needCert){
                InputStream instream = new FileInputStream(new File("D:/cert/client.p12"));
                InputStream instream1 = new FileInputStream(new File("D:/cert/tbb.jks"));
                KeyStore keyStore = KeyStore.getInstance("PKCS12");
                KeyStore trustStore = KeyStore.getInstance("JKS");
                try {
                    //設定客戶端證書
                    keyStore.load(instream, "12345678".toCharArray());
                    //設定伺服器證書
                    trustStore.load(instream1, "12345678".toCharArray());
                } catch (Exception e) {
                    ECommonUtil.getLog().error("匯入證書錯誤" + e);
                } finally {
                    if (instream != null) {
                        instream.close();
                    }
                    if (instream1 != null) {
                        instream1.close();
                    }
                }
                SSLContext sslContext = SSLContexts.custom().loadTrustMaterial(trustStore).loadKeyMaterial(keyStore, "12345678".toCharArray()).build();
                sslsf = new SSLConnectionSocketFactory(sslContext,SSLConnectionSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER);
            }else{
                SSLContext sslContext = SSLContexts.custom().loadTrustMaterial(null, new TrustStrategy() {
                    @Override
                    public boolean isTrusted(X509Certificate[] chain, String authType)
                            throws CertificateException {
                        return true;
                    }
                }).build();
                sslsf = new SSLConnectionSocketFactory(sslContext,new String []{"TLSv1.2"}, null,SSLConnectionSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER);
            }
            if(useProxy){
                CredentialsProvider credsProvider = new BasicCredentialsProvider();
                AuthScope authScope = new AuthScope(PropertiesUtil.properties.getProperty("proxy_host"),Integer.parseInt(PropertiesUtil.properties.getProperty("proxy_port")));
                Credentials credentials = new  UsernamePasswordCredentials(PropertiesUtil.properties.getProperty("proxy_user"), PropertiesUtil.properties.getProperty("proxy_password"));
                credsProvider.setCredentials(authScope, credentials);
                httpClientBuilder= HttpClients.custom().setSSLSocketFactory(sslsf).setDefaultCredentialsProvider(credsProvider).build();
            }else{
                httpClientBuilder= HttpClients.custom().setSSLSocketFactory(sslsf).build();
            }
            return httpClientBuilder;
        } catch (Exception e) {
            ECommonUtil.getLog().error("建立https匯入證書錯誤"+e);
        }
        return HttpClients.createDefault();
    }

    /**
     * 
     * @param url 請求地址
     * @param map 請求引數 
     * @param res 返回結果
     * @param timeOut 超時時間(min)
     * @param useProxy 是否使用代理
     * @return
     * @throws Exception
     */
    public static String get(String url,Map<String,String> map, String res, int timeOut, boolean useProxy, boolean needCert) throws Exception{
        RequestConfig config = null; CloseableHttpClient httpClient=null; CloseableHttpResponse response=null;
        if(httpClientBuilder==null){
            httpClient= HttpUtils.createSSLClientDefault(useProxy,needCert);
        }else{
            httpClient=httpClientBuilder;
        }
        URIBuilder uriBuilder=new URIBuilder(url);
        for (Entry<String, String> entry : map.entrySet()) {
            uriBuilder=uriBuilder.setParameter(entry.getKey(),entry.getValue());
        }
        URI uri=uriBuilder.build();
        HttpGet httpGet=new HttpGet(uri);
        try {
            if(useProxy){
                HttpHost proxy = new HttpHost(PropertiesUtil.properties.getProperty("proxy_host"), Integer.parseInt(PropertiesUtil.properties.getProperty("proxy_port")),"http");
                config = RequestConfig.custom().setProxy(proxy).setConnectTimeout(timeOut * 1000 * 60).build();
            }else{
                config = RequestConfig.custom().setConnectTimeout(timeOut * 1000 * 60).build();  
            }
            
            httpGet.setConfig(config);
            ECommonUtil.getLog().info("執行get請求" + httpGet.getRequestLine());
            response = httpClient.execute(httpGet);  
            HttpEntity entity = response.getEntity();  
            if (entity != null) {  
                ECommonUtil.getLog().info("響應狀態:"+ response.getStatusLine()); 
                String rStr=EntityUtils.toString(entity,"UTF-8");
                ECommonUtil.getLog().info("響應內容:" + rStr);
                if(HttpStatus.SC_OK==response.getStatusLine().getStatusCode()){
                    res=rStr;
                }
                EntityUtils.consume(entity);  
            }
        }catch (Exception e) {
            ECommonUtil.getLog().info("http請求錯誤"+e);
            throw e;
        }finally{
            if(httpGet!=null){
                httpGet.releaseConnection();
            }
            if(response!=null){
                response.close();
            }
            if(httpClient!=null){
                httpClient.close();
            }
        }
        return res;
    }
    
    /**
     * 
     * @param url 請求地址
     * @param params 請求引數
     * @param res 返回結果
     * @param timeOut 超時時間(min) 
     * @param useProxy 是否使用代理
     * @param needCert 是否使用證書
     * @return
     * @throws Exception
     */
    @SuppressWarnings({ "deprecation", "unused" })
    private static String post(String url, List<NameValuePair> params, String res, int timeOut, boolean useProxy, boolean needCert) throws Exception {
        RequestConfig config = null;CloseableHttpClient httpClient=null; CloseableHttpResponse response=null;
        if(httpClientBuilder==null){
            httpClient= HttpUtils.createSSLClientDefault(useProxy,needCert);
        }else{
            httpClient=httpClientBuilder;
        }
        HttpPost httpPost = new HttpPost(url);
        if(useProxy){
            HttpHost proxy = new HttpHost(PropertiesUtil.properties.getProperty("proxy_host"), Integer.parseInt(PropertiesUtil.properties.getProperty("proxy_port")),"http");
            config = RequestConfig.custom().setProxy(proxy).setConnectTimeout(timeOut * 1000 * 60).build();  
        }else{
            config = RequestConfig.custom().setConnectTimeout(timeOut * 1000 * 60).build();  
        }
        httpPost.setConfig(config);
        // 設定型別
        httpPost.setEntity(new UrlEncodedFormEntity(params, HTTP.UTF_8));
        try {
            response = httpClient.execute(httpPost);
            if(302 == response.getStatusLine().getStatusCode()){
                ECommonUtil.getLog().info(response.getLastHeader("Location").getValue());
                post(response.getLastHeader("Location").getValue(), params, res, timeOut, useProxy,needCert);
            }
            HttpEntity entity = response.getEntity();
            res = EntityUtils.toString(entity, "UTF-8");
            ECommonUtil.getLog().info(res);
            EntityUtils.consume(entity);
        } catch (IOException e) {
            ECommonUtil.getLog().info("請求異常"+e);
            e.printStackTrace();
        } finally {
            if (response != null) {
                response.close();
            }
            if (httpPost != null) {
                httpPost.releaseConnection();
            }
            if (httpClient != null) {
                httpClient.close();
            }
        }
        return res;
    }
    
    public static void main(String[] args) throws Exception {
        //-----------post----------------
        List<NameValuePair> params = new ArrayList<NameValuePair>();
        params.add(new BasicNameValuePair("req", "{\"method\":\"checkMobile\",\"timestamp\":\"A100000000000001\",\"channelCode\":\"A1\",\"queryType\":\"1\",\"telephone\":\"15301929770\"}"));
//        HttpUtilsDemo.post("http://www.baidu.com", params,"",5,true);
//        HttpUtilsDemo.post("https://localhost/spdbSjptServer/service.cgi", params, "" , 5 ,false);
//        HttpUtilsDemo.post("http://localhost:7070/spdbSjptServer/service.cgi", params, "" , 5 ,false);
        //-----------get------------------
        String method = "{\"method\":\"checkMobile\",\"timestamp\":\"A100000000000001\",\"channelCode\":\"A1\",\"queryType\":\"1\",\"telephone\":\"15301929770\"}";
        Map<String, String> map = new HashMap<String, String>();
        map.put("req", method);
//        HttpUtilsDemo.get("https://localhost/spdbSjptServer/service.cgi", map,"",5,false);
        HttpUtils.get("http://localhost:7070/spdbSjptServer/service.cgi", map, "", 5, false,false);
//        HttpUtilsDemo.get("https://localhost/spdbSjptServer/service.cgi", map, "", 5, false,true);
//        HttpUtilsDemo.get("http://www.baidu.com", map, "", 5, true,false);
         }
    
}