package tools;

import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.io.StringReader;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;
import java.net.URLConnection;
import java.util.List;
import java.util.Map;

import org.apache.commons.io.IOUtils;
import org.aspectj.weaver.ast.Call;
import org.dom4j.Document;
import org.dom4j.Element;
import org.dom4j.io.SAXReader;

public class HttpRequest {

	/**
	 * 向指定URL发送GET方法的请求
	 * 
	 * @param url
	 *            发送请求的URL
	 * @param param
	 *            请求参数，请求参数应该是 name1=value1&name2=value2 的形式。
	 * @return URL 所代表远程资源的响应结果
	 * @throws Exception
	 * @throws MalformedURLException
	 */
	/*
	 * public static String queryWebservice2(String url) throws
	 * MalformedURLException, Exception{ String xml = ""+
	 * "<?xml version=\"1.0\" encoding=\"utf-8\"?>"+
	 * "<soap:Envelope xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\" xmlns:soap=\"http://schemas.xmlsoap.org/soap/envelope/\">"
	 * + "<soap:Body>"+
	 * "<GetShipmentStatusByBillId xmlns=\"http://ShipmentStatus\">"+
	 * "<Freight>172-20966794</Freight>"+ "<Xquery>BA8EC</Xquery>"+
	 * "</GetShipmentStatusByBillId>"+ "</soap:Body>"+ "</soap:Envelope>";
	 * Client c = new Client(new URL(url)); Object[] o =
	 * c.invoke("GetShipmentStatusByBillId", new Object[]{xml}); if(o != null)
	 * return o[0].toString(); return null; }
	 */
	public static String queryWebservice(String url) {
		PrintWriter out = null;
		BufferedReader in = null;
		String result = "";
		System.out.println("start!");
		try {
			URL realUrl = new URL(url);
			// 打开和URL之间的连接
			URLConnection conn = realUrl.openConnection();
			HttpURLConnection httpConn = (HttpURLConnection) conn;
			httpConn.setDoInput(true);
			httpConn.setDoOutput(true);
			httpConn.setRequestMethod("POST");
			httpConn.setRequestProperty("Host", "10.50.3.66");
			// httpConn.setRequestProperty("Content-Type",
			// "application/soap+xml; charset=utf-8");
			httpConn.setRequestProperty("Connect-Type", "text/xml;charset=UTF-8");
			// httpConn.setRequestProperty("SOAPAction",
			// "http://ShipmentStatus/GetShipmentStatusByBillId");
			String data = "" + "<?xml version=\"1.0\" encoding=\"utf-8\"?>"
					+ "<soap:Envelope xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\" xmlns:soap=\"http://schemas.xmlsoap.org/soap/envelope/\">"
					+ "<soap:Body>" + "<GetShipmentStatusByBillId xmlns=\"http://ShipmentStatus\">"
					+ "<Freight>172-20966794</Freight>" + "<Xquery>BA8EC</Xquery>" + "</GetShipmentStatusByBillId>"
					+ "</soap:Body>" + "</soap:Envelope>";
			httpConn.setRequestProperty("Content-Length", data.length() + "");
			OutputStream out1 = httpConn.getOutputStream();
			out1.write(data.getBytes());
			System.out.println("response code:" + httpConn.getResponseCode());
			if (httpConn.getResponseCode() == 200) {
				// 获得输入流
				InputStream in1 = httpConn.getInputStream();
				// 使用输入流的缓冲区
				BufferedReader reader = new BufferedReader(new InputStreamReader(in1));
				StringBuffer sb = new StringBuffer();
				String line = null;
				// 读取输入流
				while ((line = reader.readLine()) != null) {
					sb.append(line);
				}
				/*
				 * //创建sax的读取器 SAXReader saxReader = new SAXReader(); //创建文档对象
				 * Document doc = saxReader.read(new
				 * StringReader(sb.toString())); //获得请求响应return元素 List<Element>
				 * eles = doc.selectNodes("//return"); for(Element ele : eles){
				 * System.out.println(ele.getText()); }
				 */
				return sb.toString();
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		System.out.println("end");
		return null;

	}

	public static String sendGet(String url, String param) {
		String result = "";
		BufferedReader in = null;
		try {
			String urlNameString = url;// + "?" + param;
			URL realUrl = new URL(urlNameString);
			// 打开和URL之间的连接
			URLConnection connection = realUrl.openConnection();
			// 设置通用的请求属性
			connection.setRequestProperty("accept", "*/*");
			connection.setRequestProperty("connection", "Keep-Alive");
			connection.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
			// 建立实际的连接
			connection.connect();
			// 获取所有响应头字段
			Map<String, List<String>> map = connection.getHeaderFields();
			// 遍历所有的响应头字段
			for (String key : map.keySet()) {
				System.out.println(key + "--->" + map.get(key));
			}
			// 定义 BufferedReader输入流来读取URL的响应
			in = new BufferedReader(new InputStreamReader(connection.getInputStream()));
			String line;
			while ((line = in.readLine()) != null) {
				result += line;
			}
		} catch (Exception e) {
			System.out.println("发送GET请求出现异常！" + e);
			e.printStackTrace();
		}
		// 使用finally块来关闭输入流
		finally {
			try {
				if (in != null) {
					in.close();
				}
			} catch (Exception e2) {
				e2.printStackTrace();
			}
		}
		return result;
	}

	public static String sendPost2(String url, String Params) {
		OutputStreamWriter out = null;
		BufferedReader reader = null;
		String response = "";
		try {
			URL httpUrl = null; // HTTP URL类 用这个类来创建连接
			// 创建URL
			httpUrl = new URL(url);
			// 建立连接
			HttpURLConnection conn = (HttpURLConnection) httpUrl.openConnection();
			conn.setRequestMethod("POST");
			conn.setRequestProperty("Content-Type", "application/json");
			conn.setRequestProperty("connection", "keep-alive");
			conn.setUseCaches(false);// 设置不要缓存
			conn.setInstanceFollowRedirects(true);
			conn.setDoOutput(true);
			conn.setDoInput(true);
			conn.connect();
			// POST请求
			out = new OutputStreamWriter(conn.getOutputStream());
			out.write(Params);
			out.flush();
			// 读取响应
			reader = new BufferedReader(new InputStreamReader(conn.getInputStream()));
			String lines;
			while ((lines = reader.readLine()) != null) {
				lines = new String(lines.getBytes(), "utf-8");
				response += lines;
			}
			reader.close();
			// 断开连接
			conn.disconnect();

		} catch (Exception e) {
			System.out.println("发送 POST 请求出现异常！" + e);
			e.printStackTrace();
		}
		// 使用finally块来关闭输出流、输入流
		finally {
			try {
				if (out != null) {
					out.close();
				}
				if (reader != null) {
					reader.close();
				}
			} catch (IOException ex) {
				ex.printStackTrace();
			}
		}

		return response;
	}

	/**
	 * 向指定 URL 发送POST方法的请求
	 * 
	 * @param url
	 *            发送请求的 URL
	 * @param param
	 *            请求参数，请求参数应该是 name1=value1&name2=value2 的形式。
	 * @return 所代表远程资源的响应结果
	 */
	public static String sendPost(String url, String param) {
		PrintWriter out = null;
		BufferedReader in = null;
		String result = "";
		try {
			URL realUrl = new URL(url);
			// 打开和URL之间的连接
			URLConnection conn = realUrl.openConnection();
			// 设置通用的请求属性
			conn.setRequestProperty("Origin", "chrome-extension://zejoelaoggembcahzgimdiliamlcdmfm");
			conn.setRequestProperty("User-Agent", "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_12_6) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/63.0.3239.84 Safari/537.36");
			conn.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
			conn.setRequestProperty("Accept", "*/*");
			conn.setRequestProperty("Accept-Encoding", "gzip,deflate,utf-8");
			conn.setRequestProperty("Accept-Language", "zh-CN,zh;q=0.9");
			
			
			//conn.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
			//conn.setRequestProperty("Cache-Control", "no-store, no-cache, must-revalidate, post-check=0, pre-check=0");
			//conn.setRequestProperty("Content-Encoding", "gzip");
			//conn.setRequestProperty("Content-Type", "text/html;charset=UTF-8");
			//conn.setRequestProperty("accept", "*/*");
			//conn.setRequestProperty("connection", "Keep-Alive");
			
			
			//conn.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
			// 发送POST请求必须设置如下两行
			conn.setDoOutput(true);
			conn.setDoInput(true);
			// 获取URLConnection对象对应的输出流
			out = new PrintWriter(conn.getOutputStream());
//			out = new OutputStreamWriter(conn.getOutputStream());
			// 发送请求参数
			out.print(param);
//			out.write(param);
			// flush输出流的缓冲
			out.flush();
			// 定义BufferedReader输入流来读取URL的响应
			in = new BufferedReader(new InputStreamReader(conn.getInputStream()));
//			in = conn.getInputStream();
			String line;
			/*byte buffer[] = new byte[1024];
			while(in.read(buffer) > 0)
			{
				result += new String(buffer, "UTF-8");
			}*/
			while ((line = in.readLine()) != null) {
				//System.out.println("hello");
				result += line;
			}
		} catch (Exception e) {
			System.out.println("发送 POST 请求出现异常！" + 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 sendPost3(String url,String Params){
        OutputStreamWriter out = null;
        BufferedReader reader = null;
        String response="";
        try {
            URL httpUrl = null; //HTTP URL类 用这个类来创建连接
            //创建URL
            httpUrl = new URL(url);
            //建立连接
            HttpURLConnection conn = (HttpURLConnection) httpUrl.openConnection();
            conn.setRequestMethod("POST");
            conn.setRequestProperty("Content-Type", "application/json");
            conn.setRequestProperty("connection", "keep-alive");
            conn.setUseCaches(false);//设置不要缓存
            conn.setInstanceFollowRedirects(true);
            conn.setDoOutput(true);
            conn.setDoInput(true);
            conn.connect();
            //POST请求
            out = new OutputStreamWriter(
                    conn.getOutputStream());
            out.write(Params);
            out.flush();
            //读取响应
            reader = new BufferedReader(new InputStreamReader(
                    conn.getInputStream()));
            String lines;
            while ((lines = reader.readLine()) != null) {
                lines = new String(lines.getBytes(), "utf-8");
                response+=lines;
            }
            reader.close();
            // 断开连接
            conn.disconnect();

        } catch (Exception e) {
        System.out.println("发送 POST 请求出现异常！"+e);
        e.printStackTrace();
        }
        //使用finally块来关闭输出流、输入流
        finally{
        try{
            if(out!=null){
                out.close();
            }
            if(reader!=null){
                reader.close();
            }
        }
        catch(IOException ex){
            ex.printStackTrace();
        }
    }

        return response;
    }
	
	
	   public static String doHttpPost(String URL, String xmlInfo) {
	        byte[] xmlData = xmlInfo.getBytes();
	        InputStream instr = null;
	        java.io.ByteArrayOutputStream out = null;
	        try {
	            URL url = new URL(URL);
	            URLConnection urlCon = url.openConnection();
	            urlCon.setDoOutput(true);
	            urlCon.setDoInput(true);
	            urlCon.setUseCaches(false);
	            urlCon.setRequestProperty("content-Type", "application/json");
	            urlCon.setRequestProperty("charset", "utf-8");
	            urlCon.setRequestProperty("Content-length",
	                    String.valueOf(xmlData.length));
	            System.out.println(String.valueOf(xmlData.length));
	            DataOutputStream printout = new DataOutputStream(
	                    urlCon.getOutputStream());
	            printout.write(xmlData);
	            printout.flush();
	            printout.close();
	            instr = urlCon.getInputStream();
	            byte[] bis = IOUtils.toByteArray(instr);
	            String ResponseString = new String(bis, "UTF-8");
	            if ((ResponseString == null) || ("".equals(ResponseString.trim()))) {
	                System.out.println("返回空");
	            }
	            System.out.println("返回数据为:" + ResponseString);
	            return ResponseString;

	        } catch (Exception e) {
	            e.printStackTrace();
	            return "0";
	        } finally {
	            try {
	                out.close();
	                instr.close();

	            } catch (Exception ex) {
	                return "0";
	            }
	        }
	    }
}