package com.changhong.epc.form.tool;

import com.changhong.epc.constter.base.BaseConst;
import com.iemsoft.framework.cloud.core.tools.JSONTool;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.ParseException;
import org.apache.http.client.HttpClient;
import org.apache.http.client.config.RequestConfig;
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.conn.HttpHostConnectException;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.util.EntityUtils;

import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.concurrent.TimeoutException;


/**
 * @ClassName: HttpClientTool
 * @Description: TODO[后台发送请求工具类]
 * @author [九鼎联合科技]
 * @date 2017年2月27日 下午5:19:57
 */
public class HttpClientTool<T> {
	
	static Log log = LogFactory.getLog(HttpClientTool.class);
	
	public static final String COOKIE_KEY = "Cookie";
	
	public static final String APPLICATION_JSON = "application/json;charset=utf-8";
	/**
	 * 访问url
	 */
	private String url;
	
	private HttpClient httpClient;
	
	private Map<String, Object> params;
	
	private HttpEntity bodyInfos;
	
	private Map<String, ? extends Object> cookie;
	
	private RequestConfig requestConfig;
	
	private Class<T> resultClazz;
	
	private boolean resultArray;
	
	public HttpClientTool(String url) {
		this.url = url;
		this.httpClient = HttpClients.createDefault();
	}
	
	public HttpClientTool() {
		
	}
	
	
	public Class<T> getResultClazz() {
		return resultClazz;
	}

	public HttpClientTool<T> setResultClazz(Class<T> resultClazz) {
		this.resultClazz = resultClazz;
		return this;
	}

	public boolean isResultArray() {
		return resultArray;
	}

	public HttpClientTool<T> setResultArray(boolean resultArray) {
		this.resultArray = resultArray;
		return this;
	}

	/**
	 * get请求待更新
	 * @Title: sendGet
	 
	 * @param @param requestJson
	 * @param @return    设定文件
	 * @return String    返回类型
	 * @throws
	 */
	public T sendGet(){
		HttpGet httpGet = new HttpGet(url);
		if(null != requestConfig){
			httpGet.setConfig(requestConfig);
		}

		if(null != cookie){
			httpGet.setHeader(COOKIE_KEY, mapToStrByCookie(cookie));
		}
		try {
			HttpResponse response = this.httpClient.execute(httpGet);
			return httpEntityToStr(response.getEntity());
		} catch (Exception e) {
			log.error(e.getMessage(), e);
			return null;
		}
	}
	
	
	/**
	 * @throws TimeoutException 
	 * 发送post请求
	 * @Title: sendPost
	 
	 * @param @param requestJson
	 * @param @return    设定文件
	 * @return String    返回类型
	 * @throws
	 */
	public T sendPost() throws TimeoutException{
		log.debug(String.format("开始发送post请求:%s", url));
		
		HttpPost httpPost = new HttpPost(url);
		setHttpEntity(httpPost);
//		RequestConfig requestConfig = RequestConfig.custom().setConnectionRequestTimeout(50000)
//				.setConnectionRequestTimeout(10000).setSocketTimeout(50000).build();
		if(null != cookie){
			httpPost.setHeader(COOKIE_KEY, mapToStrByCookie(cookie));
		}
		if(null != requestConfig){
			httpPost.setConfig(requestConfig);
		}
		try {
			long begin = System.currentTimeMillis();
			HttpResponse response = this.httpClient.execute(httpPost);
			log.debug("请求时间:"+ (System.currentTimeMillis() - begin));
			T obj ;
			obj = httpEntityToStr(response.getEntity());
			log.debug(String.format("响应返回值为:%s", JSONTool.toJson(obj)));
			return obj;
	
		}catch (HttpHostConnectException hhe){
			log.error(hhe.getMessage(), hhe);
			throw new TimeoutException(hhe.getMessage());
		}catch (Exception e) {
			log.error(e.getMessage(), e);
			throw new TimeoutException(e.getMessage());
		}
	}

	/*
	 * 获得httpEntity
	 */
	private void setHttpEntity(HttpPost httpPost){
		if(bodyInfos == null) {
			return;
		}
		httpPost.setEntity(bodyInfos);
	}
	
	@SuppressWarnings({ "unchecked", "hiding" })
	private <T> T httpEntityToStr(HttpEntity httpEntity) throws InstantiationException, IllegalAccessException{
		log.debug("httpEntity.toString()"+httpEntity.toString());
		try {
			String json = EntityUtils.toString(httpEntity, BaseConst.PROJECT_CHARSET);
			if(resultArray){
				return (T) JSONTool.toList(json, resultClazz);
			}else{
				return (T) JSONTool.toObj(json, resultClazz);
			}
		} catch (ParseException | IOException e) {
			log.error(e.getMessage(), e);
			return (T) resultClazz.newInstance();
		}
	}
	
	private void setParam(){
		if(params == null || params.isEmpty()) {
			return ;
		}
		StringBuilder paramStr = new StringBuilder();
		boolean isOne = true;
		for (Map.Entry<String, ? extends Object> entrys : this.params.entrySet()) {
			Object val = entrys.getValue();
			if(val != null){
				if(isOne){
					paramStr.append('?');
					isOne = false;
				}else{
					paramStr.append('&');
				}
				if(val instanceof CharSequence || val instanceof Number){
					paramStr.append(entrys.getKey()).append('=').append(URLTool.encoder(val.toString()));
				}else {
					paramStr.append(entrys.getKey()).append('=').append(URLTool.encoder(JSONTool.toJson(val)));
					
				}
			}
		}
		if(paramStr.length() != 0){
			this.url = paramStr.insert(0, url).toString();
		}
	}

	private String mapToStrByCookie(Map<String, ? extends Object> cookies){
		StringBuilder str = new StringBuilder();
		for (Map.Entry<String, ? extends Object> eachCookie : cookies.entrySet()) {
			if(str.length() == 0){
				str.append(eachCookie.getKey()).append('=').append(
						eachCookie.getValue() instanceof String
						? 
						eachCookie.getValue() 
						:
						JSONTool.toJson(eachCookie.getValue()));
			}else{
				str.append(';').append(eachCookie.getKey()).append('=').append(
						eachCookie.getValue() instanceof String
						? 
						eachCookie.getValue() 
						:
						JSONTool.toJson(eachCookie.getValue()));
			}
		}
		return str.toString();
	}
	
	public void setCookie(Map<String, ? extends Object> cookie) {
		this.cookie = cookie;
	}

	public Object getBodyInfos() {
		return bodyInfos;
	}

	public void setBodyInfos(Object param) {
		if(param instanceof HttpEntity){
			this.bodyInfos = (HttpEntity) param;
		}else{
			StringEntity stringEntity = new StringEntity(JSONTool.toJson(param), BaseConst.PROJECT_CHARSET);
			stringEntity.setContentType(APPLICATION_JSON);
			this.bodyInfos = stringEntity;
		}
	}
	
	public static HttpEntity getUrlEntity(Map<String, Object> map){
        List<BasicNameValuePair> params=new ArrayList<>();
        for (Map.Entry<String, Object> entry : map.entrySet()) {
        	Object val = entry.getValue();
        	if(val != null){
	        	if(val instanceof Number || val instanceof CharSequence){
	            	params.add(new BasicNameValuePair(entry.getKey(), entry.getValue().toString()));
	        	}else{
	        		params.add(new BasicNameValuePair(entry.getKey(), JSONTool.toJson(entry.getValue())));
	        	}
        	}
		}
        try {
			return new UrlEncodedFormEntity(params, BaseConst.PROJECT_CHARSET);
		} catch (UnsupportedEncodingException e) {
			log.error(e.getMessage(), e);
			return null;
		}
	}

	public HttpClient getHttpClient() {
		return httpClient;
	}

	public void setHttpClient(HttpClient httpClient) {
		this.httpClient = httpClient;
	}

	public Map<String,Object> getParams() {
		return params;
	}

	public void setParams(Map<String,Object> params) {
		this.params = params;
		setParam();
	}

	public RequestConfig getRequestConfig() {
		return requestConfig;
	}

	public void setRequestConfig(RequestConfig requestConfig) {
		this.requestConfig = requestConfig;
	}

	public String getUrl() {
		return url;
	}

	public void setUrl(String url) {
		this.url = url;
	}
	
}