/**
 *@Title: HttpClientBean.java
 *@Package com.nis.util.httpclient 
 *@Description TODO
 *@author dell
 *@date 2016年11月7日 下午2:36:26
 *@version  版本号
 */
package com.nis.util.httpclient;

import java.io.IOException;
import java.net.SocketTimeoutException;
import java.net.URI;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Set;

import javax.servlet.http.HttpServletRequest;

import org.apache.http.HttpStatus;
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.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.utils.URIBuilder;
import org.apache.http.conn.ConnectTimeoutException;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.DefaultHttpRequestRetryHandler;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.util.EntityUtils;
import org.apache.log4j.Logger;
import org.springframework.web.servlet.support.RequestContext;

import com.alibaba.fastjson.JSON;
import com.nis.exceptions.MaatConvertException;
import com.nis.util.Encodes;

/**
 * @ClassName: HttpClientBean.java 
 * @Description: TODO
 * @author (dell)
 * @date 2016年11月7日 下午2:36:26
 * @version V1.0
 */
public class HttpClientUtil {
	protected static Logger logger = Logger.getLogger(HttpClientUtil.class);
	 /** 
     * 处理get请求. 
     * @param url  请求路径 
     * @return  json 
	 * @throws IOException 
	 * @throws ClientProtocolException 
     */  
    public static String get(String url) throws ClientProtocolException, IOException{  
        //实例化httpclient  
        CloseableHttpClient httpclient = HttpClients.createDefault();  
        //实例化get方法  
        HttpGet httpget = new HttpGet(url);   
        //请求结果  
        CloseableHttpResponse response = null;  
        String content ="";
        try {  
            //执行get方法  
            response = httpclient.execute(httpget);  
            if(response.getStatusLine().getStatusCode()==HttpStatus.SC_OK){  
                content = EntityUtils.toString(response.getEntity(),"utf-8");
                logger.debug("获取消息成功，相应内容如下： " + content);
            }  
        } catch (ClientProtocolException e) {  
            e.printStackTrace();  
        } catch (IOException e) {  
            e.printStackTrace();  
        }  
                logger.info("dashboard图表数据请求路径:"+url);
        return content;  
    }  
    
    /** 
     * 处理post请求. 
     * @param url  请求路径 
     * @param params  参数 
     * @return  json 
     * @throws IOException 
     * @throws ClientProtocolException 
     */  
    public String post(String url,Map<String, String> params) throws ClientProtocolException, IOException{  
        //实例化httpClient  
        CloseableHttpClient httpclient = HttpClients.createDefault();  
        //实例化post方法  
        HttpPost httpPost = new HttpPost(url);   
        //处理参数  
        List<NameValuePair> nvps = new ArrayList <NameValuePair>();    
        Set<String> keySet = params.keySet();    
        for(String key : keySet) {    
            nvps.add(new BasicNameValuePair(key, params.get(key)));    
        }    
        //结果  
        CloseableHttpResponse response = null;  
        String content="";  
//        try {  
            //提交的参数  
            UrlEncodedFormEntity uefEntity  = new UrlEncodedFormEntity(nvps, "UTF-8");  
            //将参数给post方法  
            httpPost.setEntity(uefEntity);  
            //执行post方法  
            response = httpclient.execute(httpPost);  
//            if(response.getStatusLine().getStatusCode()==200){  
                content = EntityUtils.toString(response.getEntity(),"utf-8");  
//                System.out.println(content);  
//            }  
//        } catch (ClientProtocolException e) {  
//            e.printStackTrace();  
//        } catch (IOException e) {  
//            e.printStackTrace();  
//        }   
        return content;  
    }  
    
    
	/**
	 * http get 获取消息      
	 * @param destUrl 业务地址
	 * @param params 参数列表
	 * @return 查询结果数据json
	 */
	public static String getMsg(String destUrl, Map<String, Object> params, HttpServletRequest req) {
		RequestContext requestContext = new RequestContext(req);
		
		CloseableHttpResponse  response = null;
		String result = null;
		try {
			URIBuilder uriBuilder = new URIBuilder(destUrl);
			for (String param : params.keySet()) {
				uriBuilder.addParameter(param, params.get(param).toString());
			}
			HttpGet request = new HttpGet(uriBuilder.build());
			request.setConfig(requestConfig);
			URI uri = request.getURI();
			logger.info(uri);
			System.err.println(uri);
			response = getHttpClient().execute(request);
			int status = response.getStatusLine().getStatusCode();
			if (status ==  HttpStatus.SC_OK) {
				result = EntityUtils.toString(response.getEntity());
				//调用处理数据方法
//				result = galaxyMessageFormat(result);
				logger.debug("获取消息成功，相应内容如下： " + result);
				
			} else {
				throw new MaatConvertException(status+"");
			}
		} catch (SocketTimeoutException e) {
			logger.error("获取消息失败 ", e);
			throw new MaatConvertException(requestContext.getMessage("request_service_failed") + ":timeout");
		} catch (MaatConvertException e) {
			throw e;
		} catch (ConnectTimeoutException e) {
			logger.error("获取消息失败 ", e);
			throw new MaatConvertException(requestContext.getMessage("request_service_failed") + ":timeout");
		} catch (Exception e) {
			logger.error("获取消息失败 ", e);
			throw new MaatConvertException(requestContext.getMessage("request_service_failed"));
		} finally {
			try {
				if (response != null) {
					response.close();
				}
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
		return result;
	}
	
	/**
	 * 将接口的日志数据格式化包括 “null”,日期为“0”,特殊字符转义
	 * @param recv
	 * @return
	 */
	public static String galaxyMessageFormat(String recv){
		//数据为ipList ip地址接口 
/*		String recv="{\"status\":200,\"businessCode\":2000,\"reason\":\"\",\"msg\":\"\",\"fromuri\":\"\",\"logSource\":0,\"traceCode\":\"20\","+
				"\"data\":{\"pageNo\":1,\"pageSize\":20,\"count\":20,\"last\":1,\"list\":"+
				"[{\"cfgId\":1,\"foundTime\":\"2018-07-27 16:21:13\",\"recvTime\":"+
				"\"2018-07-27 16:21:13\",\"transProto\":\"IPv4\",\"addrType\":4,\"dIp\":\"10.0.6.200\",\"sIp\":\"10.0.6.201\","+
				"\"dPort\":80,\"sPort\":500,\"service\":16,\"entranceId\":1,\"deviceId\":1,\"direction\":0,\"streamDir\":0,\"capIp\":\"<sip:good_luck666@sip.1.com>1.1.1.1\",\"addrList\":\"<sip:good_luck666@sip.jumblo.com>1.1.1.1&quot;\n2.2.2.2\",\"userRegion\":\"1\",\"clientLocate\":\"China\"},{\"cfgId\":2,\"foundTime\":\"2018-07-27 16:21:13\",\"recvTime\":\"2018-07-27 16:21:13\",\"transProto\":\"IPv4\",\"addrType\":4,\"dIp\":\"10.0.6.200\",\"sIp\":\"10.0.6.201\",\"dPort\":80,\"sPort\":500,\"service\":16,\"entranceId\":2,\"deviceId\":2,\"direction\":0,\"streamDir\":0,\"capIp\":\"null\",\"addrList\":\"2.2.2.2\",\"userRegion\":\"2\",\"serverLocate\":\"China\",\"clientLocate\":\"China\"}]}}";
				*/			
    	  Map parse = JSON.parseObject(recv,Map.class);
    	  Map map = (Map) parse.get("data");
    	  List reslist=new ArrayList();
    	  List<Map<String,Object>> list= (List)map.get("list");
    	  if(list!=null&&list.size()>0){
    	  for (Map<String,Object> m : list) {
    		  Map recvMap = new HashMap();
    		  Iterator<Entry<String, Object>> iterator = m.entrySet().iterator();
    		  while(iterator.hasNext()){
    			  Entry<String, Object> next = iterator.next();
    			  String key = next.getKey().toString();
    			  Object value = next.getValue();
    			  //处理字段为“null”情况
				if(value!=null&&"null".equals(value)){
					value="";  
				}
				//处理时间字段为“0”情况
			  	if("foundTime".equals(key)||"recvTime".equals(key)){
			  		if(null!=value&&"0".equals(value)){
			  		value="";
			  		}
			  	}
    			  //处理特殊字符转义问题
    			  if(null!=value){
    			  	value = Encodes.escapeHtml(value.toString());
    			  }
    			  recvMap.put(key, value);
    		  }
    		  reslist.add(recvMap);
		}
    	  map.put("list", reslist);
    	  parse.put("data", map);
    	  recv = JSON.toJSONString(parse);
    }
    	  return recv;
}
	
	private static CloseableHttpClient httpClient = null;
	private static  RequestConfig requestConfig;
	public static final int  HTTP_SOCKET_TIMEOUT= 300000;
	public static final int  HTTP_CONNECT_TIMEOUT= 10000;
	public static final int HTTP_CONNECT_REQUEST_TIMEOUT = 50000;
	public static final int HTTP_CONNECT_RETRY_TIMES = 3;
	//http 连接池
	public static CloseableHttpClient getHttpClient() {
		if (httpClient == null) {
			//http 连接池管理 需后续实现
			PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager();
			// 将最大连接数增加到200
			cm.setMaxTotal(200);
		    // 将每个路由基础的连接增加到20
		    cm.setDefaultMaxPerRoute(20);
		    requestConfig = RequestConfig.custom()  
	                .setSocketTimeout( HTTP_SOCKET_TIMEOUT)
	                .setConnectTimeout( HTTP_CONNECT_TIMEOUT)
	                .setConnectionRequestTimeout( HTTP_CONNECT_REQUEST_TIMEOUT)
	                .build();
		    httpClient =  HttpClients.custom()
		    		.setConnectionManager(cm)
		    		.setDefaultRequestConfig(requestConfig)
		    		.setRetryHandler(new DefaultHttpRequestRetryHandler( HTTP_CONNECT_RETRY_TIMES, false))
		    		.build();
		}  
		return httpClient;
		
	}
    
    public static void main(String[] args) throws ClientProtocolException, IOException {  
    	HttpClientUtil hd = new HttpClientUtil();  
        hd.get("http://10.0.6.115:9200/_sql?sql=select * from dfipportlog-2016-09-07-15 limit 1 10");  
        Map<String,String> map = new HashMap();  
        map.put("id","1");  
        hd.post("http://localhost:8080/springMVC/menu/getChildren.do",map);  
        
    }  
  
}