package com.ju.util;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.OutputStream;

import java.io.OutputStreamWriter;

import java.io.PrintWriter;

import java.net.HttpURLConnection;

import java.net.URL;

import java.util.Map;

import javax.net.ssl.HostnameVerifier;

import javax.net.ssl.HttpsURLConnection;

import javax.net.ssl.SSLContext;

import javax.net.ssl.SSLSession;

import javax.net.ssl.TrustManager;

import net.sf.json.JSONObject;

import java.security.cert.X509Certificate;  

import javax.net.ssl.X509TrustManager;  

public class HttpPost {

    private final static HostnameVerifier DO_NOT_VERIFY = new HostnameVerifier() {

        public boolean verify(String hostname, SSLSession session) {

            return true;

        }

    };

    private static void trustAllHosts() {

        // Create a trust manager that does not validate certificate chains

        TrustManager[] trustAllCerts = new TrustManager[]{new X509TrustManager() {

            public java.security.cert.X509Certificate[] getAcceptedIssuers() {

                return new java.security.cert.X509Certificate[]{};

            }

            public void checkClientTrusted(X509Certificate[] chain, String authType) {

            }

            public void checkServerTrusted(X509Certificate[] chain, String authType) {

            }

        }};

        // Install the all-trusting trust manager

        try {

            SSLContext sc = SSLContext.getInstance("TLS");

            sc.init(null, trustAllCerts, new java.security.SecureRandom());

            HttpsURLConnection.setDefaultSSLSocketFactory(sc.getSocketFactory());

        } catch (Exception e) {

            e.printStackTrace();

        }

    }

    public static   String https(String url, Map<String, String> params) throws Exception {

        // 构建请求参数

                String result = "";

                PrintWriter out = null;

                BufferedReader in = null;

                String sendString = "";

                JSONObject json = JSONObject.fromObject(params);

                System.out.println("发送报文:" + json.toString());

                sendString = json.toString();

                System.out.println("ERP连接:" + url);

                System.out.println("发送给ERP信息:" + sendString);

                 try {

                     trustAllHosts();

                    URL url2 = new URL(url);

                    HttpsURLConnection urlCon = (HttpsURLConnection) url2.openConnection();

                    urlCon.setHostnameVerifier(DO_NOT_VERIFY);

                    urlCon.setDoOutput(true);

                    urlCon.setDoInput(true);

                    urlCon.setRequestMethod("POST");

                    urlCon.setRequestProperty("Content-type", "application/json;charset=UTF-8");

                    // 发送POST请求必须设置如下两行

                    urlCon.setDoOutput(true);

                    urlCon.setDoInput(true);

                    // 获取URLConnection对象对应的输出流

                    OutputStream os = urlCon.getOutputStream();

                    //参数是键值队  , 不以"?"开始

                    os.write(sendString.getBytes());

                    //os.write("googleTokenKey=&username=admin&password=5df5c29ae86331e1b5b526ad90d767e4".getBytes());

                    os.flush();

                    // 发送请求参数

                    //out.print(a);

                    // flush输出流的缓冲

                    //out.flush();

                    // 定义BufferedReader输入流来读取URL的响应

                    in = new BufferedReader(

new InputStreamReader(urlCon.getInputStream()));

                    String line;

                    while ((line = in.readLine()) != null) {

                        result += line;

                    }

                } catch (Exception e) {

                    e.printStackTrace();

                } finally {// 使用finally块来关闭输出流、输入流

                    try {

                        if (out != null) {

                            out.close();

                        }

                        if (in != null) {

                            in.close();

                        }

                    } catch (IOException ex) {

                        ex.printStackTrace();

                    }

                }

                return result;

    }

public static String http(String url, Map<String, String> reqMap) throws Exception {

        URL u = null;

        HttpURLConnection con = null;

        // 构建请求参数

        //StringBuffer sb = new StringBuffer();

        String sendString = "" ;

        //String tradeCode = params.get(ParamsConfig.keyTradeCode);

        JSONObject json = JSONObject.fromObject(reqMap);

        System.out.println("发送报文:"+json.toString());

        sendString = json.toString();

        /*if(tradeCode.equals(TradeCode.TRANS_WXAPP_PAY) || tradeCode.equals(TradeCode.TRANS_APP_QUERY)

                || tradeCode.equals(TradeCode.TRANS_TYPE_COLLECT) || tradeCode.equals(TradeCode.TRANS_TYPE_QUERY_COLLECT_TXN)){

            JSONObject json = JSONObject.fromObject(params);

            System.out.println("发送报文:"+json.toString());

            sendString = json.toString();

        } else {

            if (params != null) {

                for (Entry<String, String> e : params.entrySet()) {

                    sb.append(e.getKey());

                    sb.append("=");

                    sb.append(e.getValue());

                    sb.append("&");

                }

                sendString = sb.substring(0, sb.length() - 1);

            }

        }*/

        System.out.println("ERP连接:" + url);

        System.out.println("发送给ERP信息:" + sendString);

//        logger.info("ERP连接:" + url);

//        logger.info("发送给ERP信息:" + sb.toString());

        // 尝试发送请求

        try {

            u = new URL(url);

            con = (HttpURLConnection) u.openConnection();

            con.setRequestMethod("POST");

            con.setDoOutput(true);

            con.setDoInput(true);

            con.setUseCaches(false);

//            con.setConnectTimeout(300*1000);

//

//            con.setReadTimeout(300*1000);

            con.setRequestProperty("Content-Type",

                    "application/x-www-form-urlencoded");

            OutputStreamWriter osw = new OutputStreamWriter(con

                    .getOutputStream(), "UTF-8");

            osw.write(sendString);

            osw.flush();

            osw.close();

        } catch (Exception e) {

            e.printStackTrace();

            throw new Exception("与服务器连接发生错误:"+e.getMessage());

        } finally {

            if (con != null) {

                con.disconnect();

            }

        }

        // 读取返回内容

        StringBuffer buffer = new StringBuffer();

        try {

            BufferedReader br = new BufferedReader(new InputStreamReader(con

            .getInputStream(), "UTF-8"));

            String temp;

            while ((temp = br.readLine()) != null) {

                buffer.append(temp);

            }

        } catch (Exception e) {

            e.printStackTrace();

            throw new Exception("从服务器获取数据失败:"+e.getMessage());

        }

        return buffer.toString();

    }

}