package com.nova.sankuai.domain.api.tongbao;

import com.alibaba.fastjson.JSON;
import com.nova.sankuai.domain.api.yinsheng.SerialGenerator;
import com.nova.sankuai.domain.entity.CustomerUser;
import com.nova.sankuai.security.HttpClientUtil;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.apache.tomcat.util.codec.binary.Base64;

import javax.crypto.Cipher;
import java.security.KeyFactory;
import java.security.PublicKey;
import java.security.spec.X509EncodedKeySpec;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;

@Data
@Slf4j
public class TBUtil {

    /**
     * 日期格式化模板
     */
    private static ThreadLocal<SimpleDateFormat> dateFormatFactory = ThreadLocal.withInitial(() -> new SimpleDateFormat("yyyyMMddHHmmssSSS"));


    public static final String url = "http://api.mixuannet.cn/api/order/create";
    public static final String h5url = "https://h5.mixuannet.cn/#/login";
    public static final String payAmt = "3.2";
    public static final String appkey = "daodaohuanianka";
    public static final String publicKey = "MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQCU9dKONZdLK2nKvtNHGq3xzNou93GKDW/e9kX9K4f1hyif5612GdxbVUq+CaOkgChtqfcAbvrefbelRxJmr0Ujvv55BlpBGGxxtbMtI+B9EbceTseEzRj47BOIjIGgSlNC8V5J+QJJRzij/8tQK8p9oQzT25yqGGzkUOQjwp2PxwIDAQAB";

    /**
     * 数字签名，密钥算法
     */
    private static final String RSA_KEY_ALGORITHM = "RSA";

    /**
     * 公钥加密
     *
     * @param data      加密前的字符串
     * @param publicKey 公钥
     * @return 加密后的字符串
     * @throws Exception
     */
    public static String encryptByPubKey(String data, String publicKey) throws Exception {
        byte[] pubKey = decodeBase64(publicKey);
        byte[] enSign = encryptByPubKey(data.getBytes(), pubKey);
        return Base64.encodeBase64String(enSign);
    }

    /**
     * 密钥转成byte[]
     *
     * @param key
     * @return
     */
    public static byte[] decodeBase64(String key) {
        return Base64.decodeBase64(key);
    }

    /**
     * 公钥加密
     *
     * @param data   待加密数据
     * @param pubKey 公钥
     * @return
     * @throws Exception
     */
    public static byte[] encryptByPubKey(byte[] data, byte[] pubKey) throws Exception {
        X509EncodedKeySpec x509KeySpec = new X509EncodedKeySpec(pubKey);
        KeyFactory keyFactory = KeyFactory.getInstance(RSA_KEY_ALGORITHM);
        PublicKey publicKey = keyFactory.generatePublic(x509KeySpec);
        Cipher cipher = Cipher.getInstance(keyFactory.getAlgorithm());
        cipher.init(Cipher.ENCRYPT_MODE, publicKey);
        return cipher.doFinal(data);
    }


    public static String getJsonString(String timestamp,String payAmt,String channelUserId,String serialNo){
        HashMap<String, String> map = new HashMap<>();
        map.put("timestamp",timestamp);
        map.put("payAmt",payAmt);
        map.put("channelUserId",channelUserId);
        map.put("serialNo",serialNo);
        return JSON.toJSONString(map);
    }

    public static String getJsonString(String sign,String appkey){
        HashMap<String, String> map = new HashMap<>();
        map.put("sign",sign);
        map.put("appkey",appkey);
        return JSON.toJSONString(map);
    }

    /**
     * 生成规则 17位日期毫秒数 + 消息类型（10) + 随机数补齐32位
     *
     */
    public static String getOrder() {
        StringBuilder sb = new StringBuilder();
        sb.append(dateFormatFactory.get().format(new Date())).append("10")
                .append(SerialGenerator.generateRandomSerial(29 - sb.length()));
        return sb.toString();
    }


    public static TBResposeInfo createOrder(CustomerUser customerUser,String serialNo){
        String channelUserId = customerUser.getPhone();

        //传输数据
        String dateString = TBUtil.getJsonString(System.currentTimeMillis() + "", TBUtil.payAmt, channelUserId, serialNo);
        String result = "" ;
        try {
            String sign = TBUtil.encryptByPubKey(dateString, TBUtil.publicKey);
            String jsonString = TBUtil.getJsonString(sign, appkey);
            result = HttpClientUtil.getInstance().postJsonData(TBUtil.url, jsonString);
            log.info("通宝会员权益:通宝返回：{}", result);
        } catch (Exception e) {
            log.error("通宝会员权益:调用第三方接口失败",e);
            e.printStackTrace();
            return null;
        }
        try {
            TBRespose tbRespose = JSON.parseObject(result, TBRespose.class);
            if (!"200".equals(tbRespose.getCode())) {
                log.error("通宝会员权益:创建订单失败",tbRespose.toString());
                return null;
            }else {
                return tbRespose.getInfo();
            }
        }catch (Exception e){
            log.error("通宝会员权益:JSON转换失败",e);
            return null;
        }
    }

    public static String getH5Url(String orderNumber,CustomerUser customerUser){
        //返回给前端H5请求地址
        String h5url = TBUtil.h5url + "?oId=" + orderNumber + "&cId=" + customerUser.getPhone() + "&qd=" + TBUtil.appkey + "&ts=" + System.currentTimeMillis();
        return h5url;
    }

}