package com.vci.rmip.code.client.codeapply.Apply410.utils;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.nacos.shaded.com.google.gson.JsonObject;
import com.vci.rmip.code.client.codeapply.Apply410.object.R;

import org.apache.commons.lang.StringUtils;
import org.apache.http.*;
import org.apache.http.client.ClientProtocolException;
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.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
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.net.URISyntaxException;
import java.util.ArrayList;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;

public class HttpUtil {
	private static final CloseableHttpClient httpclient = HttpClients.createDefault();

	/**
	 * 发送HttpGet请求
	 * @param url
	 * @return
	 */
	public static String sendGet(String url) {

		HttpGet httpget = new HttpGet(url);
		CloseableHttpResponse response = null;
		try {
			response = httpclient.execute(httpget);
		} catch (IOException e1) {
			e1.printStackTrace();
		}
		String result = null;
		try {
			HttpEntity entity = response.getEntity();
			if (entity != null) {
				result = EntityUtils.toString(entity);
			}
		} catch (ParseException | IOException e) {
			e.printStackTrace();
		} finally {
			try {
				response.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
		return result;
	}

	/**
	 * 发送HttpGet带参请求
	 * @param url
	 * @param params
	 * @return
	 */
	public static R sendGet(String url, Map<String, String> params, Map<String,String> headers) {
		R r=new R();
		// 获取连接客户端工具
		CloseableHttpClient httpClient = HttpClients.createDefault();
		String entityStr = null;
		CloseableHttpResponse response = null;
		try {
			/*
			 * 由于GET请求的参数都是拼装在URL地址后方，所以我们要构建一个URL，带参数
			 */
			URIBuilder uriBuilder = new URIBuilder(url);
			/** 第一种添加参数的形式 */
        /*uriBuilder.addParameter("name", "root");
        uriBuilder.addParameter("password", "123456");*/
			/** 第二种添加参数的形式 */
			List<NameValuePair> list = new LinkedList<>();
			//设置头部
			for(Map.Entry<String,String> entry:params.entrySet()){
				BasicNameValuePair param1 = new BasicNameValuePair(entry.getKey(), entry.getValue());
				list.add(param1);
			}
			uriBuilder.setParameters(list);
			// 根据带参数的URI对象构建GET请求对象
			HttpGet httpGet = new HttpGet(uriBuilder.build());
			/*
			 * 添加请求头信息
			 */
			if(headers!=null&&headers.size()>0) {
				for (Map.Entry<String, String> entry : headers.entrySet()) {
					httpGet.addHeader(entry.getKey(), entry.getValue());
				}
			}
			// 执行请求
			response = httpClient.execute(httpGet);
			// 获得响应的实体对象
			HttpEntity entity = response.getEntity();
			// 使用Apache提供的工具类进行转换成字符串
			entityStr = EntityUtils.toString(entity, "UTF-8");
			if(StringUtils.isNotBlank(entityStr)){
				r = JSONObject.toJavaObject(JSONObject.parseObject(entityStr), R.class);
			}
		} catch (ClientProtocolException e) {
			System.err.println("Http协议出现问题");
			e.printStackTrace();
		} catch (ParseException e) {
			System.err.println("解析错误");
			e.printStackTrace();
		} catch (URISyntaxException e) {
			System.err.println("URI解析异常");
			e.printStackTrace();
		} catch (IOException e) {
			System.err.println("IO异常");
			e.printStackTrace();
		} finally {
			// 释放连接
			if (null != response) {
				try {
					response.close();
					httpClient.close();
				} catch (IOException e) {
					System.err.println("释放连接出错");
					e.printStackTrace();
				}
			}
		}
		return r;
	}
	/**
	 * 发送HttpGet带参请求
	 * @param url
	 * @param header
	 * @return
	 */
	public static String sendGet(String url, Map<String, String> header) {
		HttpGet httpGet = new HttpGet(url);


		//设置头部
		for(Map.Entry entry:header.entrySet()){
//            System.out.println(entry.getKey()+ "###########" + entry.getValue());
			httpGet.setHeader(entry.getKey().toString(),entry.getValue().toString());
		}
//        System.out.println(jsonObject.toString());


//        HttpGet httpget = new HttpGet(url);
		CloseableHttpResponse response = null;
		try {
			response = httpclient.execute(httpGet);
		} catch (IOException e1) {
			e1.printStackTrace();
		}
		String result = null;
		try {
			HttpEntity entity = response.getEntity();
			if (entity != null) {
				result = EntityUtils.toString(entity);
			}
		} catch (ParseException | IOException e) {
			e.printStackTrace();
		} finally {
			try {
				response.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
		return result;
	}
	/**
	 * 发送HttpPost请求，参数为map
	 * @param url
	 * @param jsonDataStr
	 * @return
	 */
	public static R sendPost(String url, String jsonDataStr,Map<String,String> headers) {
		R r=new R();
//        JsonObject formparams = new JsonObject();
//        for (Map.Entry<String, String> entry : map.entrySet()) {
//            formparams.add(entry.getKey(), entry.getValue();
//        }
		//json 格式
        //UrlEncodedFormEntity entity = new UrlEncodedFormEntity(jsonDataStr, Consts.UTF_8);
//        System.out.println(jsonObject.toString());
		StringEntity entity = new StringEntity(jsonDataStr, Consts.UTF_8);
		HttpPost httppost = new HttpPost(url);
		/*
		 * 添加请求头信息
		 */
		if(headers!=null&&headers.size()>0) {
			for (Map.Entry<String, String> entry : headers.entrySet()) {
				httppost.addHeader(entry.getKey(), entry.getValue());
			}
		}
		httppost.setEntity(entity);
		CloseableHttpResponse response = null;
		try {
			response = httpclient.execute(httppost);
		} catch (IOException e) {
			e.printStackTrace();
		}
		HttpEntity entity1 = response.getEntity();
		String result = null;
		try {
			result = EntityUtils.toString(entity1, "UTF-8");
			// 使用Apache提供的工具类进行转换成字符串
			if(StringUtils.isNotBlank(result)){
				r = JSONObject.toJavaObject(JSONObject.parseObject(result), R.class);
			}
		} catch (ParseException | IOException e) {
			e.printStackTrace();
		}
		return r;
	}
	/**
	 * 发送HttpPost请求，参数为map
	 * @param url
	 * @param map
	 * @return
	 */
	public static R sendPost(String url, Map<String,String> map,Map<String,String> headers) {
		R r=new R();
//        JsonObject formparams = new JsonObject();
//        for (Map.Entry<String, String> entry : map.entrySet()) {
//            formparams.add(entry.getKey(), entry.getValue();
//        }
		//json 格式
//        UrlEncodedFormEntity entity = new UrlEncodedFormEntity(formparams, Consts.UTF_8);

		JsonObject jsonObject = new JsonObject();
		for(Map.Entry entry:map.entrySet()){
//            System.out.println(entry.getKey()+ "###########" + entry.getValue());
			jsonObject.addProperty(entry.getKey().toString(),entry.getValue().toString());
		}
//        System.out.println(jsonObject.toString());
		StringEntity entity = new StringEntity(jsonObject.toString(), Consts.UTF_8);
		HttpPost httppost = new HttpPost(url);
		/*
		 * 添加请求头信息
		 */
		if(headers!=null&&headers.size()>0) {
			for (Map.Entry<String, String> entry : headers.entrySet()) {
				httppost.addHeader(entry.getKey(), entry.getValue());
			}
		}
		httppost.setEntity(entity);
		CloseableHttpResponse response = null;
		try {
			response = httpclient.execute(httppost);
		} catch (IOException e) {
			e.printStackTrace();
		}
		HttpEntity entity1 = response.getEntity();
		String result = null;
		try {
			result = EntityUtils.toString(entity1, "UTF-8");
			// 使用Apache提供的工具类进行转换成字符串
			if(StringUtils.isNotBlank(result)){
				r = JSONObject.toJavaObject(JSONObject.parseObject(result), R.class);
			}
		} catch (ParseException | IOException e) {
			e.printStackTrace();
		}
		return r;
	}
	/**
	 * 发送HttpPost请求，参数为map
	 * @param url
	 * @param map
	 * @return
	 */
	public static String sendPost(String url, Map<String,String> map) {
//        JsonObject formparams = new JsonObject();
//        for (Map.Entry<String, String> entry : map.entrySet()) {
//            formparams.add(entry.getKey(), entry.getValue();
//        }
		//json 格式
//        UrlEncodedFormEntity entity = new UrlEncodedFormEntity(formparams, Consts.UTF_8);
		JsonObject jsonObject = new JsonObject();
		for(Map.Entry entry:map.entrySet()){
//            System.out.println(entry.getKey()+ "###########" + entry.getValue());
			jsonObject.addProperty(entry.getKey().toString(),entry.getValue().toString());
		}
//        System.out.println(jsonObject.toString());
		StringEntity entity = new StringEntity(jsonObject.toString(), Consts.UTF_8);
		HttpPost httppost = new HttpPost(url);
		httppost.setEntity(entity);
		CloseableHttpResponse response = null;
		try {
			response = httpclient.execute(httppost);
		} catch (IOException e) {
			e.printStackTrace();
		}
		HttpEntity entity1 = response.getEntity();
		String result = null;
		try {
			result = EntityUtils.toString(entity1);
		} catch (ParseException | IOException e) {
			e.printStackTrace();
		}
		return result;
	}
	/**
	 * 发送HttpPost请求，参数为map
	 * @param url
	 * @param dataMap
	 * @return
	 */
	public static String sendFormPost(String url, Map<String,String> dataMap, Map<String,String> headers) {
		String result = null;
		try {

			//json 格式
			List<NameValuePair> nvps = new ArrayList<>();
//
			HttpPost httppost = new HttpPost(url);
			if (dataMap != null && dataMap.size() > 0) {
				for (Map.Entry<String, String> entry : dataMap.entrySet()) {
					nvps.add(new BasicNameValuePair(entry.getKey(), entry.getValue()));
				}
			}
			/*
			 * 添加请求头信息
			 */
			if (headers != null && headers.size() > 0) {
				for (Map.Entry<String, String> entry : headers.entrySet()) {
					httppost.addHeader(entry.getKey(), entry.getValue());
				}
			}
			httppost.setEntity(new UrlEncodedFormEntity(nvps, "utf-8")); //将参数传入post方法中
			//httppost.setEntity(entity);
			CloseableHttpResponse response = null;
			response = httpclient.execute(httppost);
			HttpEntity entity1 = response.getEntity();

			result = EntityUtils.toString(entity1, "UTF-8");
			// 使用Apache提供的工具类进行转换成字符串
			if (StringUtils.isNotBlank(result)) {
				return result;
			}
		}catch (Throwable e){
			e.printStackTrace();;
		}
		return result;
	}
	/**
	 * 发送不带参数的HttpPost请求
	 * @param url
	 * @return
	 */
	public static String sendPost(String url) {
		HttpPost httppost = new HttpPost(url);
		CloseableHttpResponse response = null;
		try {
			response = httpclient.execute(httppost);
		} catch (IOException e) {
			e.printStackTrace();
		}
		HttpEntity entity = response.getEntity();
		String result = null;
		try {
			result = EntityUtils.toString(entity);
		} catch (ParseException | IOException e) {
			e.printStackTrace();
		}
		return result;
	}


}