package com.xc.utils.pay;

import com.alibaba.fastjson.JSONObject;
import com.xc.utils.PropertiesUtil;
import org.apache.commons.codec.digest.DigestUtils;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.HttpStatus;
import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.util.EntityUtils;

import java.text.SimpleDateFormat;
import java.util.*;

public class GpayUtil {

	//公户
	final static String UID = PropertiesUtil.getProperty("gpay.uid");
	final static String MCHID = PropertiesUtil.getProperty("gpay.mchid");
	final static String SECRET = PropertiesUtil.getProperty("gpay.secret");
	final static String ORDER_URL= PropertiesUtil.getProperty("gpay.url") + "/payapi/v3/orders";
	final static String NOTIFY_URL= PropertiesUtil.getProperty("gpay.notify.url");
	//私户
	final static String UID2 = PropertiesUtil.getProperty("gpay.uid2");
	final static String MCHID2 = PropertiesUtil.getProperty("gpay.mchid2");
	final static String SECRET2 = PropertiesUtil.getProperty("gpay.secret2");


	final static String shopid365 = PropertiesUtil.getProperty("gpay.shopid");
	final static String key365 = PropertiesUtil.getProperty("gpay.key");
	final static String return_url365 = PropertiesUtil.getProperty("gpay.return_url");
	final static String callback_url365 = PropertiesUtil.getProperty("gpay.callback_url");
	final static String url365 = PropertiesUtil.getProperty("gpay.url365");


//	public static void main(String[] args) {
//		Map<String, Object> map = new HashMap<String, Object>();
//		map.put("uid", UID);
//		map.put("mchid", MCHID);
//		map.put("mch_orderid", "test123456");
//		map.put("amount", "10.00");
//		map.put("channel", "300"); // 100 支付寶 200 微信 300 銀行卡； 開通請聯繫運營
//		map.put("notify_url", "http://0.0.0.0:8081/test/notify"); // 回調地址
//		map.put("return_url", "http://0.0.0.0:8081/test/return"); // 支付成功後跳轉地址
//		map.put("product_name", "商品1");
//		map.put("member_name", "會員1");
//		map.put("extra", "透傳");
//		map.put("timestamp", "2020-12-17 13:18:36");
//		// 签名
//		String sign = sign(map, SECRET);
//		JSONObject json = new JSONObject(map);
//		json.put("sign", sign);
//		// 下单
//		JSONObject response = doPost(ORDER_URL, json);
//		System.out.println("ORDER_URL: "+ORDER_URL);
//		System.out.println("response: "+response);
//		// 回调
//		String data = "{'tradeid':'5fc49d05e5bf59cbad7f92ec', 'uid':'5fc4843fe5bf59cbad7f8ff2', 'mchid':'5fc4843fe5bf59cbad7f8ff3', 'mch_orderid':'123','channel':'300', 'currency':'CNY', 'amount':'10.00', 'timestamp':'2020-11-30 15:20:41', 'extra':'透傳', 'status':'success', 'sign':'3a2ac4dfc1456c2301b2227d6b303045'}";
//		notify(data);
//	}

	public static void main(String[] args) {
//		JSONObject jb = gPay("19.00" , "778899" , "55555");
//		System.out.println(jb.getString("msg"));
//		JSONObject data = (JSONObject) jb.get("data");
//		JSONObject jbb = JSON.parseObject(data.getString("result"));
//		System.out.println(jbb.getString("url"));

//		JSONArray result = data.getJSONArray("result");
//		String url = (String)jb.get("result");
//		System.out.println(result);
//		String data = "{'tradeid':'5fdb22d04ff77f70fef29523', 'uid':'5fc5ae01ae8c2dea7a6eea55', 'mchid':'5fc5ae01ae8c2dea7a6eea56', 'mch_orderid':'778899','channel':'300',  'amount':'19.00', 'timestamp':'2020-12-17 17:20:17', 'extra':'extra', 'status':'success', 'sign':'2c87ce12af764362115f442b0a596cc2'}";
//		JSONObject json = JSONObject.parseObject(data);
//		Map<String, Object> map = (Map<String, Object>) json;
//		String sign = sign(map, SECRET);
//
		//回调
//		if (!map.get("sign").toString().equals(sign)) {
//			System.out.println("签名不一致:"+map.get("sign").toString());
//		}

//		notify365("{\"order_status\":4,\"amount\":\"110.00\",\"orderno\":\"21123\",\"seller_name\":\"200\",\"price\":\"6.56\",\"qty\":\"16.768292\",\"sign\":\"D55BF386C8E1DC24151B014E915DCB70\",\"buyer_name\":\"无\"}");

//		gPay365("130.00","202012241515","测试12241514","1211");
	}

	public static JSONObject gPay(String amount , String ordersn , String phone){
		Map<String, Object> map = new HashMap();
		map.put("uid", UID);
		map.put("mchid", MCHID);
		map.put("mch_orderid", ordersn);
		map.put("amount", amount);
		map.put("channel", "300");
		map.put("notify_url", NOTIFY_URL);
		map.put("member_name", phone);
		map.put("extra", "extra");
		map.put("timestamp", generateTime());
		// 签名
		String sign = sign(map, SECRET);
		JSONObject json = new JSONObject(map);
		json.put("sign", sign);
//		System.out.println("uid:" + UID);
//		System.out.println("mchid:" + MCHID);
//		System.out.println("notify_url:" + NOTIFY_URL);
//		System.out.println("SECRET:" + SECRET);
		// 下单
		JSONObject response = doPost(ORDER_URL, json);
		return response;
	}

	public static JSONObject gPay2(String amount , String ordersn , String phone){
		Map<String, Object> map = new HashMap();
		map.put("uid", UID2);
		map.put("mchid", MCHID2);
		map.put("mch_orderid", ordersn);
		map.put("amount", amount);
		map.put("channel", "300");
		map.put("notify_url", NOTIFY_URL);
		map.put("member_name", phone);
		map.put("extra", "extra");
		map.put("timestamp", generateTime());
		// 签名
		String sign = sign(map, SECRET2);
		JSONObject json = new JSONObject(map);
		json.put("sign", sign);
		// 下单
		JSONObject response = doPost(ORDER_URL, json);
//		System.out.println(response.toString());
		return response;
	}

	// sign
	public static String sign(Map<String, Object> map, String signKey) {
		if (map == null) {
			return null;
		}
		List<String> keyList = new ArrayList<>(map.keySet());
		Collections.sort(keyList);
		StringBuffer sb = new StringBuffer();
		for (int i = 0; i < keyList.size(); i++) {
			String key = keyList.get(i);
			Object value = map.get(key);
			if (key.equals("sign") || value.equals("")) {
				continue;
			}
			sb.append(key + "=" + value + "&");
		}
		String signStr = sb.substring(0, sb.length() - 1) + signKey;
//		System.out.println("before sign: " + signStr);
		String md5Str = DigestUtils.md5Hex(signStr);
//		System.out.println("after sign: " + md5Str);
		return md5Str;
	}

	// http request
	public static JSONObject doPost(String url, JSONObject jsonObject) {
		HttpClient client = HttpClientBuilder.create().build();
		HttpPost post = new HttpPost(url);
		JSONObject response = null;
		try {
			StringEntity s = new StringEntity(jsonObject.toString(), "utf-8");
			s.setContentType("application/json;utf-8");
			post.setEntity(s);
			HttpResponse res = client.execute(post);
			HttpEntity entity = res.getEntity();
			String result = EntityUtils.toString(entity);
			response = JSONObject.parseObject(result);
			if (res.getStatusLine().getStatusCode() != HttpStatus.SC_OK) {
				throw new Error(response.toJSONString());
			}
		} catch (Exception e) {
			throw new RuntimeException(e);
		}
		return response;
	}


	// 回调通知
	public String notify(String data) {
		System.out.println(data);
		JSONObject json = JSONObject.parseObject(data);
		Map<String, Object> map = (Map<String, Object>) json;
		System.out.println(json.toString());
		System.out.println(map.toString());
		// 验证签名
		String sign = sign(map, SECRET);
		if (!map.get("sign").toString().equals(sign)) {
			System.out.println("签名不一致:"+map.get("sign").toString());
			return "签名不一致";
		}
		String amount = map.get("amount").toString();
		String orderSn = map.get("mch_orderid").toString();
		String tradeid = map.get("tradeid").toString();
		System.out.println(amount +"@" + orderSn +"@"+ tradeid);
		try {
		}catch (Exception e){
			return "fail";
		}
		// TODO: timestamp, 如回调超时N小时后，是否处理依据具体业务
		return "success";
	}

	public static String generateTime() {
		return (new SimpleDateFormat("yyyy-MM-dd HH:mm:ss")).format(new Date());
	}




	/*--------- pay365 相关接口Start------------ */

	// 回调通知  验证签名
	public static String notify365(String data) {
		JSONObject json = JSONObject.parseObject(data);
		Map<String, Object> map = (Map<String, Object>) json;
		// 验证签名
		return getPay365Sign(map, key365);
	}


	public static JSONObject gPay365(String amount,String ordersn , String phone,String userid){
		Map<String, Object> map = new HashMap();
		map.put("amount", amount); // 金额
		map.put("kyc_name", phone); // 姓名 -
		map.put("orderno", ordersn); // 订单号 mch_orderid
		map.put("shopid", shopid365);  // 商户id
		map.put("exid", userid);  //买家id
		map.put("return_url", return_url365); //订单完成后跳转地址
		map.put("callback_url",callback_url365);  //异步回调地址
		// 签名
		String sign = getPay365Sign(map, key365);
		map.put("sign", sign);
		JSONObject json = new JSONObject(map);
		JSONObject response  = doPost(url365, json);
		return response;
	}


	public static String getPay365Sign(Map<String ,Object> $params , String key){
		String $signData = ksort($params);
		$signData = $signData+"&key="+key;
		$signData = DigestUtils.md5Hex($signData);
		$signData = $signData.toUpperCase();
		return  $signData ;
	}

	public static String ksort(Map<String, Object> map)  {
		List<String> keyList = new ArrayList<>(map.keySet());
		Collections.sort(keyList);
		StringBuffer sb = new StringBuffer();
		for (int i = 0; i < keyList.size(); i++) {
			String key = keyList.get(i);
			Object value = map.get(key);
			if (key.equals("sign")) {
				continue;
			}
			sb.append(key + "=" + value + "&");
		}
		return  sb.toString().substring(0, sb.toString().length() - 1) ;

	}



	/*--------- pay365 相关接口end ------------ */
}