/**
 * 
 */
/**
 * @author Administrator
 *
 */
package com.nova.sankuai.infra.utils.baofu;

import com.alibaba.fastjson.JSON;
import com.nova.sankuai.domain.entity.PayRecord;
import com.nova.sankuai.infra.config.CommonException;
import com.nova.sankuai.infra.utils.baofu.http.*;
import com.nova.sankuai.service.IPayRecordService;
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.client.methods.HttpRequestBase;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.util.EntityUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.TransactionDefinition;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.support.DefaultTransactionDefinition;

import javax.annotation.Resource;
import java.io.UnsupportedEncodingException;
import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;

@Component
public class PayHttpUtil {

	private static final Logger log = LoggerFactory.getLogger("baofuLog");
	
	public String RequestForm(String Url,Map<String,String> Parms){
		if(Parms.isEmpty()){
			return  "参数不能为空！";
		}
		String PostParms = "";
		int PostItemTotal = Parms.keySet().size();
		int Itemp=0;
		for (String key : Parms.keySet()){
			PostParms += key + "="+Parms.get(key);
			Itemp++;
			if(Itemp<PostItemTotal){
				PostParms +="&";
			}
		}
		HttpSendModel httpSendModel = new HttpSendModel(Url + "?" + PostParms);
//		Log.Write("【请求全部参数】：" + Url + "?" + PostParms);
		String recordTypeStr = "";// 交易类型说明
		String recordType = "";// 交易类型
		if (Url.contains("/cutpayment/protocol/backTransRequest")) {
			String txnType = Parms.get("txn_type");// 交易类型
			if ("01".equals(txnType)) {
				recordTypeStr = "宝付支付预绑卡";
				recordType = "bp";
			} else if ("02".equals(txnType)) {
				recordTypeStr = "宝付支付确认绑卡";
				recordType = "bc";
			} else if ("05".equals(txnType)) {
				recordTypeStr = "宝付支付预支付";
				recordType = "bs";
			} else if ("06".equals(txnType)) {
				recordTypeStr = "宝付支付确认支付";
				recordType = "bf";
			}
		}
		log.info(recordTypeStr + "入参:{}", JSON.toJSONString(Parms));
		httpSendModel.setMethod(HttpMethod.POST);
		SimpleHttpResponse response = null;
		try {
			response = doRequest(httpSendModel, "utf-8");
			log.info(recordTypeStr + "返回结果:{}", response.getEntityString());
		} catch (Exception e) {
			String userId = Parms.get("user_id");
			if (userId != null) {
				PayRecord payRecord = new PayRecord();
				LocalDateTime payDate = LocalDateTime.now();
				payRecord.setPayDate(payDate);
				payRecord.setUserId(Long.parseLong(userId));
				payRecord.setPayType(recordType);
				payRecord.setPayStatus(3);
				payRecord.setPayError(e.getMessage());
				payRecord.setPayErrorCode("bf00001");
				payRecord.setOutTradeNo(Parms.get("msg_id"));
				payRecordImpl(payRecord);
			}

			log.error(recordTypeStr + "读取宝付服务器失败，请求全部参数:{}", Url + "?" + PostParms);
			throw new CommonException("服务器发生错误，错误码:bf00001");
		}
		return response.getEntityString();

	}
	
	public SimpleHttpResponse doRequest(HttpSendModel httpSendModel,
			String getCharSet) throws Exception {

		// 创建默认的httpClient客户端端
		SimpleHttpClient simpleHttpclient = new SimpleHttpClient();

		try {
			return doRequest(simpleHttpclient, httpSendModel, getCharSet);
		} finally {
			simpleHttpclient.getHttpclient().getConnectionManager().shutdown();
		}

	}

	/**
	 * @param httpSendModel
	 * @param getCharSet
	 * @return
	 * @throws Exception 
	 */
	public SimpleHttpResponse doRequest(
			SimpleHttpClient simpleHttpclient, HttpSendModel httpSendModel,
			String getCharSet) throws Exception {

		HttpRequestBase httpRequest = buildHttpRequest(httpSendModel);

		if (httpSendModel.getUrl().startsWith("https://")) {
			simpleHttpclient.enableSSL();
		}

		try {
			HttpResponse response = simpleHttpclient.getHttpclient().execute(
					httpRequest);
			int statusCode = response.getStatusLine().getStatusCode();

			if (isRequestSuccess(statusCode)) {
				return new SimpleHttpResponse(statusCode, EntityUtils.toString(
						response.getEntity(), getCharSet), null);
			} else {
				return new SimpleHttpResponse(statusCode, null, response
						.getStatusLine().getReasonPhrase());
			}

		} catch (Exception e) {
			e.printStackTrace();
			throw new Exception("http请求异常", e);
		}

	}

	/**
	 * @param httpSendModel
	 * @return
	 * @throws Exception 
	 */
	protected HttpRequestBase buildHttpRequest(
			HttpSendModel httpSendModel) throws Exception {
		HttpRequestBase httpRequest;
		if (httpSendModel.getMethod() == null) {
			throw new Exception("请求方式未设定");
		} else if (httpSendModel.getMethod() == HttpMethod.POST) {

			String url = httpSendModel.getUrl();
			String sendCharSet = httpSendModel.getCharSet();
			List<HttpFormParameter> params = httpSendModel.getParams();
			List<NameValuePair> qparams = new ArrayList<NameValuePair>();
			if (params != null && params.size() != 0) {

				for (HttpFormParameter param : params) {
					qparams.add(new BasicNameValuePair(param.getName(), param
							.getValue()));
				}

			}

			HttpPost httppost = new HttpPost(url);
			try {
				httppost.setEntity(new UrlEncodedFormEntity(qparams,
						sendCharSet));
			} catch (UnsupportedEncodingException e) {
				throw new Exception("构建post请求参数失败", e);
			}

			httpRequest = httppost;
		} else if (httpSendModel.getMethod() == HttpMethod.GET) {
			HttpGet httpget = new HttpGet(httpSendModel.buildGetRequestUrl());

			httpRequest = httpget;
		} else {
			throw new Exception("请求方式不支持：" + httpSendModel.getMethod());
		}

		return httpRequest;
	}

	/**
	 * 请求是否成功
	 * 
	 * @param statusCode
	 * @return
	 */
	public static boolean isRequestSuccess(int statusCode) {
		return statusCode == 200;
	}


	@Resource
	private PlatformTransactionManager transactionManager;// 引入 (平台)事务管理器，Spring 事务策略的核心。
	// 于2022-11-17号
	@Resource
	private IPayRecordService payRecordService;
	/**
	 * 于2022-11-18新增：录入支付记录表
	 */
	@Async
	public void payRecordImpl(PayRecord payRecord) {
		// 发起一个新事务
		DefaultTransactionDefinition def = new DefaultTransactionDefinition();
		def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW);//新发起一个事务
		TransactionStatus defStatus = transactionManager.getTransaction(def);// 获得事务状态
		payRecordService.save(payRecord);
		transactionManager.commit(defStatus);// 手动提交事务
	}
	
}