package com.paic.pmit.core.util;

import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Set;

import org.apache.commons.httpclient.HttpStatus;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.NameValuePair;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.util.EntityUtils;
import org.apache.log4j.Logger;

import com.paic.pafa.app.biz.service.BusinessServiceException;
import com.paic.pmit.core.biz.service.impl.AbstractInvokeGroovy;


/**
 * 模擬Http請求
 * @author:EX-WANGYIDE001
 * @date:2016-10-1上午10:29:18
 *--------------------
 *修改記錄,含日期,作者,修改內容
 */
public class public_equipment_HttpClientUtils extends AbstractInvokeGroovy  {

	Logger logger = Logger.getLogger(this.getClass());
	
	/**
	 * 傳送http請求
	 * @author:EX-WANGYIDE001
	 * @date:2016-10-1上午10:29:14
	 * @param url 請求URL
	 * @param parameter	請求引數
	 * @param requestCharset 編碼格式
	 * @return
	 * @throws BusinessServiceException
	 */
	public String sendHttpRequest(String url, Map<String, String> parameter, String requestCharset) throws BusinessServiceException {
		logger.info("處理Http請求:"+url);
		long start = System.currentTimeMillis(); 
		String result = null;
		CloseableHttpClient http = null;
		try {
			//建立HttpClient
			//HttpHost proxy = new HttpHost("10.36.232.126",8080);代理
			RequestConfig config = RequestConfig.custom().setConnectTimeout(5000).setSocketTimeout(60000).build();
			HttpClientBuilder builder = HttpClientBuilder.create();
			http = builder.build();
			//http = createSSLClientDefault();
			//post請求
			HttpPost httpPost = new HttpPost(url);
			httpPost.setConfig(config);
			//引數佇列
			httpPost.setEntity(new UrlEncodedFormEntity(parameterConvert(parameter),requestCharset));
			//執行請求
			HttpResponse response = http.execute(httpPost);
			//響應處理
			int httpStatus = response.getStatusLine().getStatusCode();
			if (httpStatus == HttpStatus.SC_OK){
				HttpEntity entity = response.getEntity();
				if(entity != null){
					result = EntityUtils.toString(entity, requestCharset);
					logger.info("返回引數："+result);
				}
			}else{
				throw new BusinessServiceException("服務方介面響應異常, httpStatus: " + httpStatus);
			}
		} catch (UnsupportedEncodingException e) {
			logger.error("http請求引數處理異常",e);
			throw new BusinessServiceException("http請求引數處理異常");
		} catch (ClientProtocolException e) {
			logger.error("http請求發生HTTP異常",e);
			throw new RuntimeException("http請求發生HTTP異常");
		} catch (IOException e) {
			logger.error("http請求發生IO異常",e);
			throw new RuntimeException("http請求發生IO異常");
		} finally{
			logger.info("耗時: " + (System.currentTimeMillis() - start) + " 毫秒");
			if(http!=null){
				try {
					http.close();
				} catch (IOException e) {
					logger.error("釋放資源  close error:"+e);
				}
			}
		}
		return result;
	}
	
	/**
	 * 轉換引數
	 * @author:EX-WANGYIDE001
	 * @date:2016-10-1下午2:59:37
	 * @param parameter
	 * @return
	 */
	private List<NameValuePair> parameterConvert(Map<String,String> parameter){
		List<NameValuePair> results = new ArrayList<NameValuePair>(parameter.size());
		Set<Entry<String, String>> entrySet = parameter.entrySet();
		for (Iterator<Entry<String, String>> iter = entrySet.iterator(); iter.hasNext();) {
			Entry<String, String> entry = iter.next();
			results.add(new BasicNameValuePair(entry.getKey(),entry.getValue()));
		}
		return results;
	}
	
	/**
	 * 處理Https請求證書
	 * @author:EX-WANGYIDE001
	 * @date:2016-10-1下午3:50:34
	 * @return
	 *//*
	private CloseableHttpClient createSSLClientDefault(){
		try {
             SSLContext sslContext = new SSLContextBuilder().loadTrustMaterial(null, new TrustStrategy() {
                 //信任所有證書
                 public boolean isTrusted(X509Certificate[] chain, String authType) throws CertificateException {
                     return true;
                 }
             }).build();
             SSLConnectionSocketFactory sslFactory = new SSLConnectionSocketFactory(sslContext);
             return HttpClients.custom().setSSLSocketFactory(sslFactory).build();
         } catch (Exception e) {
        	 logger.error("處理Https證書異常",e);
         }
         return  HttpClients.createDefault();
	}*/
	
	/**
	 * 測試方法
	 * @author:EX-WANGYIDE001
	 * @date:2016-10-2上午9:58:51
	 * @param args
	 * @throws Exception
	 *//*
	public static void main(String args[]) throws Exception {
		
		public_equipment_HttpClientUtils http = new public_equipment_HttpClientUtils();
		Map<String,String> parameter = new HashMap<String,String>();
		parameter.put("credentials", "123456123");
		http.sendHttpRequest("測試地址", parameter, "UTF-8");
		
		
	}*/
	
	
	
}