package cn.ksource.core.util;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.InetAddress;
import java.net.URL;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

import org.apache.commons.lang.StringUtils;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.NameValuePair;
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.DefaultHttpClient;
import org.apache.http.message.BasicNameValuePair;
import org.apache.log4j.Logger;

public class HttpUtil {
	
	public final static Logger logger = Logger.getLogger(HttpUtil.class);
	
	/**
	 * use doGet() 
	 * 	通过Http Get协议访问网址，并返回内容
	 * @param strUrl
	 * @return
	 */
	@Deprecated
	public static String getContentForGet(String strUrl){
		try {
			// 创建url对象
			URL url = new URL(strUrl);
			// 打开url连接
			HttpURLConnection connection = (HttpURLConnection) url.openConnection();
			// 设置url请求方式 ‘get’ 或者 ‘post’
			connection.setRequestMethod("GET");
			// 发送
			BufferedReader in = new BufferedReader(new InputStreamReader(url.openStream()));
			StringBuffer buffer=new StringBuffer();
			int ch=0;
			while((ch=in.read())!=-1)
			buffer.append((char)ch);
			in.close();
			return buffer.toString();
		} catch (Exception e) {
			e.printStackTrace();
		}
		return "";
	}
	
	
	/**
	 * 使用Http Post协议访问URL
	 * @param url 要访问的URL
	 * @param params 参数
	 * @param charset 字符集
	 * @return
	 */
	public static String  doPostUseJsonParams(String url,Map<String, String> paramValues,HttpCharset charset) {
		DefaultHttpClient httpclient = new DefaultHttpClient();
		try {
			HttpPost httpost = new HttpPost(url);
			
			//===========================================================
			//数据以json格式传输，所以这里加了通用限制  by jiangxiaolei  2014-05-05
			Map<String,String> params = new HashMap<String,String>();
			params.put("params", JsonUtil.map2Json(paramValues));
			//===========================================================
			List <NameValuePair> nvps = new ArrayList <NameValuePair>();
			
			String param = "";
			if (params != null && !params.isEmpty()) {
				for (Iterator iterator = params.keySet().iterator(); iterator.hasNext();) {
					String key = (String)iterator.next();
					nvps.add(new BasicNameValuePair(key, params.get(key)));
					param += key + "=" + params.get(key) + ";";
				}
			}

			logger.info("Http Post :" + url+"\n" + param);
			
	        httpost.setEntity(new UrlEncodedFormEntity(nvps,charset.toString()));

	        HttpResponse response = httpclient.execute(httpost);
	        HttpEntity entity = response.getEntity();
	        BufferedReader in = new BufferedReader(new InputStreamReader(entity.getContent(),charset.toString()));
			StringBuffer buffer=new StringBuffer();
			int ch=0;
			while((ch=in.read())!=-1)
			buffer.append((char)ch);
			in.close();
			return buffer.toString();
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			httpclient.getConnectionManager().shutdown();
		}
		return "";
	}
	
	/**
	 * 使用Http Get协议访问URL
	 * @param url 要访问的URL，不带问号”？“
	 * @param params 参数
	 * @param charset 字符集
	 * @return
	 * @throws HttpRemoteException 
	 */
	public static String  doGetUseJsonParams(String url,Map<String, String> paramValues,HttpCharset charset) throws HttpRemoteException {
		DefaultHttpClient httpclient = new DefaultHttpClient();
		try {
			//===========================================================
			//数据以json格式传输，所以这里加了通用限制  by jiangxiaolei  2014-05-05
			Map<String,String> params = new HashMap<String,String>();
			params.put("params", JsonUtil.map2Json(paramValues));
			//===========================================================
			String param = "";
			if (params != null && !params.isEmpty()) {
				for (Iterator iterator = params.keySet().iterator(); iterator.hasNext();) {
					String key = (String)iterator.next();
					param += "&"+key +"=" + params.get(key);
				}
				param = StringUtils.removeStart(param, "&");
				param = "?"+param;
			}
			
			String myurl = url+param;
			
			logger.info("Http Get :" + myurl );
			
			HttpGet httpost = new HttpGet(myurl);
	        HttpResponse response = httpclient.execute(httpost);
	        HttpEntity entity = response.getEntity();
	        BufferedReader in = new BufferedReader(new InputStreamReader(entity.getContent(),charset.toString()));
			StringBuffer buffer=new StringBuffer();
			int ch=0;
			while((ch=in.read())!=-1)
			buffer.append((char)ch);
			in.close();
			return buffer.toString();
		} catch (Exception e) {
			e.printStackTrace();
			throw new HttpRemoteException(e.getMessage());
		} finally {
			httpclient.getConnectionManager().shutdown();
		}
	}
	
	
	/**
	 * 使用Http Post协议访问URL
	 * @param url 要访问的URL
	 * @param params 参数
	 * @param charset 字符集
	 * @return
	 */
	public static String  doPost(String url,Map<String, String> params,HttpCharset charset) {
		DefaultHttpClient httpclient = new DefaultHttpClient();
		try {
			HttpPost httpost = new HttpPost(url);
			
			List <NameValuePair> nvps = new ArrayList <NameValuePair>();
			
			String param = "";
			if (params != null && !params.isEmpty()) {
				for (Iterator iterator = params.keySet().iterator(); iterator.hasNext();) {
					String key = (String)iterator.next();
					nvps.add(new BasicNameValuePair(key, params.get(key)));
					param += key + "=" + params.get(key) + ";";
				}
			}

			logger.info("Http Post :" + url+"\n" + param);
			
	        httpost.setEntity(new UrlEncodedFormEntity(nvps,charset.toString()));

	        HttpResponse response = httpclient.execute(httpost);
	        HttpEntity entity = response.getEntity();
	        BufferedReader in = new BufferedReader(new InputStreamReader(entity.getContent(),charset.toString()));
			StringBuffer buffer=new StringBuffer();
			int ch=0;
			while((ch=in.read())!=-1)
			buffer.append((char)ch);
			in.close();
			return buffer.toString();
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			httpclient.getConnectionManager().shutdown();
		}
		return "";
	}
	
	/**
	 * 使用Http Get协议访问URL
	 * @param url 要访问的URL，不带问号”？“
	 * @param params 参数
	 * @param charset 字符集
	 * @return
	 * @throws HttpRemoteException 
	 */
	public static String  doGet(String url,Map<String, String> params,HttpCharset charset) throws HttpRemoteException {
		DefaultHttpClient httpclient = new DefaultHttpClient();
		try {
			String param = "";
			if (params != null && !params.isEmpty()) {
				for (Iterator iterator = params.keySet().iterator(); iterator.hasNext();) {
					String key = (String)iterator.next();
					param += "&"+key +"=" + params.get(key);
				}
				param = StringUtils.removeStart(param, "&");
				param = "?"+param;
			}
			
			String myurl = url+param;
			
			logger.info("Http Get :" + myurl);
			
			HttpGet httpost = new HttpGet(myurl);
	        HttpResponse response = httpclient.execute(httpost);
	        HttpEntity entity = response.getEntity();
	        BufferedReader in = new BufferedReader(new InputStreamReader(entity.getContent(),charset.toString()));
			StringBuffer buffer=new StringBuffer();
			int ch=0;
			while((ch=in.read())!=-1)
			buffer.append((char)ch);
			in.close();
			return buffer.toString();
		} catch (Exception e) {
			e.printStackTrace();
			throw new HttpRemoteException(e.getMessage());
		} finally {
			httpclient.getConnectionManager().shutdown();
		}
	}
	
	
	/**
	 * 以POST方式发送内容体
	 * @param targetUrl
	 * @param content
	 * @param charset
	 * @version V1.0.0
	 * @author 杨凯
	 * @date Feb 10, 2015 11:21:27 AM
	 */
	public static String doPost(String targetUrl,String content,HttpCharset charset){
		try { 
			// 建立连接 
			URL url = new URL(targetUrl); 
			HttpURLConnection httpConn = (HttpURLConnection) url.openConnection(); 
	
			// //设置连接属性 
			httpConn.setDoOutput(true);// 使用 URL 连接进行输出 
			httpConn.setDoInput(true);// 使用 URL 连接进行输入 
			httpConn.setUseCaches(false);// 忽略缓存 
			httpConn.setRequestMethod("POST");// 设置URL请求方法 
	
			 
			// 设置请求属性 
			// 获得数据字节数据，请求数据流的编码，必须和下面服务器端处理请求流的编码一致 
			byte[] requestStringBytes = content.getBytes(charset.toString()); 
			httpConn.setRequestProperty("Content-length", "" + requestStringBytes.length); 
			httpConn.setRequestProperty("Content-Type", "application/octet-stream"); 
			httpConn.setRequestProperty("Connection", "Keep-Alive");// 维持长连接 
			httpConn.setRequestProperty("Charset", "UTF-8"); 
			// 
//			String name = URLEncoder.encode("黄武艺", "utf-8"); 
//			httpConn.setRequestProperty("NAME", name); 
	
			 
			// 建立输出流，并写入数据 
			OutputStream outputStream = httpConn.getOutputStream(); 
			outputStream.write(requestStringBytes); 
			outputStream.close(); 
			// 获得响应状态 
			int responseCode = httpConn.getResponseCode(); 
	
			 
			if (HttpURLConnection.HTTP_OK == responseCode) {// 连接成功 
			// 当正确响应时处理数据 
			StringBuffer sb = new StringBuffer(); 
			String readLine; 
			BufferedReader responseReader; 
			// 处理响应流，必须与服务器响应流输出的编码一致 
			 responseReader = new BufferedReader(new InputStreamReader(httpConn.getInputStream(), charset.toString())); 
			while ((readLine = responseReader.readLine()) != null) { 
				sb.append(readLine).append("\n"); 
				} 
				responseReader.close(); 
				return sb.toString();
			} 
		} catch (Exception ex) { 
		ex.printStackTrace(); 
		} 

		 return "";
		} 
	
	public static void main(String[] args) {
		System.out.println(System.getProperties().getProperty("os.name"));
	}
	
}