package com.mes.util;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.*;
import java.net.HttpURLConnection;
import java.net.URISyntaxException;
import java.net.URL;

public class HttpUtils {

    public static final Logger log =  LoggerFactory.getLogger(HttpUtils.class);
	/**
	 * HTTP请求，正确报文解析，并保存数据到生产记录数据
	 * @return 
	 * @throws URISyntaxException
	 */
    //http post请求
    public static String sendRequest(String urlParam) {
		String requestType = "POST";
        //根据接收内容返回数据结果
    	String ret = "";
    	log.info(urlParam);
        HttpURLConnection con = null;
        BufferedReader buffer = null;
        StringBuffer resultBuffer = null;
        try {
            URL url = new URL(urlParam);
            //得到连接对象
            con = (HttpURLConnection) url.openConnection();
            //设置请求类型
            con.setRequestMethod(requestType);
            //设置请求需要返回的数据类型和字符集类型
            con.setRequestProperty("Content-Type", "application/json;charset=GBK");  
            //允许写出
            con.setDoOutput(true);
            //允许读入
            con.setDoInput(true);
            //不使用缓存
            con.setUseCaches(false);
            //得到响应码
            int responseCode = con.getResponseCode();
            log.info("responseCode="+responseCode);
            if(responseCode == HttpURLConnection.HTTP_OK){
                //得到响应流
                InputStream inputStream = con.getInputStream();
                //将响应流转换成字符串
                resultBuffer = new StringBuffer();
                String line;
                buffer = new BufferedReader(new InputStreamReader(inputStream, "UTF-8"));
                while ((line = buffer.readLine()) != null) {
                    resultBuffer.append(line);
                }
                log.info(resultBuffer.toString());
                ret = resultBuffer.toString();
            }else {
            	//ret = String.valueOf(responseCode);
            	ret = "false";
            }
            con.disconnect();
        }catch(Exception e) {
        	//ret = false;
        	//log.info("e.toString()="+e.toString());
        	//return e.toString();
            //e.printStackTrace();
        	ret = "false";
        }
        return ret;
    }


    public static String sendPostRequest(String urlParam, String params) {
        String requestType = "POST";
        //根据接收内容返回数据结果
        String ret = "";
        log.info(urlParam);
        HttpURLConnection con = null;
        BufferedReader buffer = null;
        StringBuffer resultBuffer = null;
        try {
            URL url = new URL(urlParam);
            //得到连接对象
            con = (HttpURLConnection) url.openConnection();
            //设置请求类型
            con.setRequestMethod(requestType);
            //设置请求需要返回的数据类型和字符集类型
            con.setRequestProperty("Content-Type", "application/x-www-form-urlencoded;charset=GBK");
            //允许写出
            con.setDoOutput(true);
            //允许读入
            con.setDoInput(true);
            //不使用缓存
            con.setUseCaches(false);

            // 获取URLConnection对象对应的输出流
            OutputStreamWriter out = new OutputStreamWriter( con.getOutputStream(),"UTF-8");// utf-8编码
            // 发送请求参数
            out.write(params);

            //得到响应码
            int responseCode = con.getResponseCode();
            log.info("responseCode="+responseCode);
            if(responseCode == HttpURLConnection.HTTP_OK){
                //得到响应流
                InputStream inputStream = con.getInputStream();
                //将响应流转换成字符串
                resultBuffer = new StringBuffer();
                String line;
                buffer = new BufferedReader(new InputStreamReader(inputStream, "UTF-8"));
                while ((line = buffer.readLine()) != null) {
                    resultBuffer.append(line);
                }
                log.info(resultBuffer.toString());
                ret = resultBuffer.toString();
            }else {
                //ret = String.valueOf(responseCode);
                ret = "false";
            }
            con.disconnect();
        }catch(Exception e) {
            //ret = false;
            //log.info("e.toString()="+e.toString());
            //return e.toString();
            //e.printStackTrace();
            ret = "false";
        }
        return ret;
    }

    public static String sendPostRequestJson(String apiUrl, String jsonData) throws IOException {
        URL url = new URL(apiUrl);
        HttpURLConnection conn = (HttpURLConnection) url.openConnection();
        conn.setRequestMethod("POST");
        conn.setRequestProperty("Content-Type", "application/json");
        conn.setDoOutput(true);

        // 发送请求数据
        try (OutputStream os = conn.getOutputStream()) {
            byte[] input = jsonData.getBytes("utf-8");
            os.write(input, 0, input.length);
        }

        // 获取响应数据
        StringBuilder response = new StringBuilder();
        int responseCode = conn.getResponseCode();
//        System.out.println("Sending POST request to URL: " + apiUrl);
//        System.out.println("Post parameters: " + jsonData);
//        System.out.println("Response Code: " + responseCode);

        try (BufferedReader br = new BufferedReader(new InputStreamReader(conn.getInputStream(), "utf-8"))) {
            String responseLine;
            while ((responseLine = br.readLine()) != null) {
                response.append(responseLine.trim());
            }
        }

        conn.disconnect();
        return response.toString();
    }

	

}