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

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.nova.sankuai.domain.entity.CapitalInfo;
import com.nova.sankuai.domain.enums.capitalInfo.CapitalTypeEnum;
import com.nova.sankuai.infra.constants.Constants;
import com.nova.sankuai.infra.utils.RsaSecretUtils;
import com.nova.sankuai.security.HttpClientUtil;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import org.springframework.util.DigestUtils;

import java.util.Objects;

//import com.nova.sankuai.infra.utils.zhxyp.ZhxypUtil;

/**
 * @Author Lilinhong
 * @Date 2022/6/12 20:46
 */
@Component
public class ChannelUnionAutoUtil {

    /**
     * 随易花
     */
    @Value("${syh.domain}")
    private String syhPath;

//    @Autowired
//    private ZhxypUtil zhxypUtil;

    private static final Logger logger = LoggerFactory.getLogger("capitalLogger");

    public ChannelUnionCollisionResponse getCollision(String capitalName, String publicKeyBase64, String url, String appId,
                                                      String phone, String idCard, String name, String cityName, String channelCode) {
        // 判断是否 随易花，是，则判断是否城市为空，为空则不撞库
        if (Constants.SYHCAPITALNAME.equals(capitalName) && StringUtils.isBlank(cityName)) {
            logger.info("手机号为：" + phone + "," + capitalName + " 因为城市为空撞库失败!");
            return null;
        }

        JSONObject param = new JSONObject();
        JSONObject body = new JSONObject();

        String phoneMd5 = DigestUtils.md5DigestAsHex(phone.getBytes());
        if (Constants.SYHCAPITALNAME.equals(capitalName) || "好汇推".equals(capitalName) || "助贷".equals(capitalName)
                || "任意花".equals(capitalName) || "慧借".equals(capitalName) || "e时贷".equals(capitalName)
                || "商城-本APP".equals(capitalName)
        ) {// 随易花或好汇推
//            body.put("city", cityName.replace("市", ""));
//            body.put("mobileMd5", phoneMd5);
//            body.put("mobile", phone);
//            body.put("channelCode", channelCode);
//            logger.info("手机号为：" + phone + "," + capitalName + " 撞库网址:" + syhPath + "/jinjian/ctl/hd360/hd/checkMobileMd5 撞库原始参数:{}" , body);
            // 默认为撞库成功
            logger.info("手机号为：" + phone + "," + capitalName + "初始撞库成功}");
            ChannelUnionCollisionResponse channelUnionCollisionResponse = new ChannelUnionCollisionResponse();
            channelUnionCollisionResponse.setCode(200);
            return channelUnionCollisionResponse;
        } else {
            param.put("phoneMd5", phoneMd5);

            if (StringUtils.isNotEmpty(idCard)) {
                String idCardMd5 = DigestUtils.md5DigestAsHex(idCard.getBytes());
                param.put("idCardMd5", idCardMd5);
            }
            if (StringUtils.isNotEmpty(name)) {
                String nameMd5 = DigestUtils.md5DigestAsHex(name.getBytes());
                param.put("nameMd5", nameMd5);
            }

            String base64 = null;
            try {
                byte[] bytes = RsaSecretUtils.publicEncrypt(param.toJSONString().getBytes(), publicKeyBase64);
                base64 = RsaSecretUtils.byte2Base64(bytes);
                logger.info("手机号为：" + phone + "," + capitalName + "撞库原始加密参数:{}", base64);
            } catch (Exception e) {
                logger.info("手机号为：" + phone + "," + capitalName + "撞库原始加密参数失败");
                e.printStackTrace();
                return null;
            }
            body.put("appId", appId);
            body.put("data", base64);
            logger.info("手机号为：" + phone + "," + capitalName + "撞库原始参数:{}", param);
        }

        String result = null;
        try {
            if ("优点分期".equals(capitalName)) {
                //优点分期是php语言，使用postJsonData（）方法会导致对方收不到请求，此方法能够发送请求
                result = HttpClientUtil.doPost(url + "/api/v1/unionLogin/unionCheckUser", body.toJSONString());
                logger.info("手机号为：" + phone + "," + capitalName + "撞库原始返回参数:{}", result);
            } else if (Constants.SYHCAPITALNAME.equals(capitalName)) {// 随易花撞库
                result = HttpClientUtil.getInstance().syhPostJsonData(syhPath + "/jinjian/ctl/hd360/hd/checkMobileMd5", body.toJSONString());
                logger.info("手机号为：" + phone + "," + capitalName + "撞库原始返回参数:{}", result);
            } else if ("大象花呗".equals(capitalName)) {
                result = HttpClientUtil.getInstance().postJsonData(url + "/openapi/duplicate/kadana/checkuser", body.toJSONString());
                logger.info("手机号为：" + phone + "," + capitalName + "撞库原始返回参数:{}", result);
//            } else if ("商城-本APP".equals(capitalName)) {
//                result = zhxypUtil.check(idCard, phone, name);
//                logger.info("手机号为：" + phone + "," + capitalName + "撞库原始返回参数:{}", result);

            } else {
                result = HttpClientUtil.getInstance().postJsonData(url + "/api/v1/unionLogin/unionCheckUser", body.toJSONString());
                logger.info("手机号为：" + phone + "," + capitalName + "撞库原始返回参数:{}", result);
            }
        } catch (Exception e) {
            logger.info("手机号为：" + phone + "," + capitalName + "撞库原始返回参数失败");
            e.printStackTrace();
            return null;
        }
        if (org.apache.commons.lang.StringUtils.isEmpty(result)) {
            logger.error("手机号为：" + phone + "," + capitalName + "撞库失败");
            return null;
        }
        ChannelUnionCollisionResponse channelUnionCollisionResponse = null;
        try {
            channelUnionCollisionResponse = JSON.parseObject(result, ChannelUnionCollisionResponse.class);
            return channelUnionCollisionResponse;
        } catch (Exception e) {
            logger.info("手机号为：" + phone + "," + capitalName + "撞库原始返回参数转换失败");
            e.printStackTrace();
            return null;
        }
    }


    /**
     * 标注：联登处理
     */
    public ChannelUnionAutoResponse getAuto(CapitalInfo capitalinfo, String publicKeyBase64, String url, String appId, String phone, String idCard, String name) {
        if(capitalinfo==null ){
            logger.error("资方信息为空");
            return null;
        }
        JSONObject param = new JSONObject();
        JSONObject body = new JSONObject();
        param.put("phone", phone);
        // 如果只撞库不联登这种不需要推送其它信息
        if(!Objects.equals(capitalinfo.getType(), CapitalTypeEnum.UNION_HALF.getCode())){// 非 面向产品方撞库不联登模式，对接我们文档,只推送電話號碼
            if (StringUtils.isNotEmpty(idCard)) {
                param.put("idCard", idCard);
            }
            if (StringUtils.isNotEmpty(name)) {
                param.put("name", name);
            }
        }
        String capitalName = capitalinfo.getName();
        logger.info("手机号为：" + phone + "," + capitalName + "联登原始参数:{}", param);
        String base64 = null;
        try {
            byte[] bytes = RsaSecretUtils.publicEncrypt(param.toJSONString().getBytes(), publicKeyBase64);
            base64 = RsaSecretUtils.byte2Base64(bytes);
            logger.info("手机号为：" + phone + "," + capitalName + "联登原始加密参数:{}", base64);
        } catch (Exception e) {
            logger.info("手机号为：" + phone + "," + capitalName + "联登原始加密参数失败");
            e.printStackTrace();
            return null;
        }
        body.put("appId", appId);
        body.put("data", base64);
        String result = null;
        try {
            if ("优点分期".equals(capitalName)) {
                //优点分期是php语言，使用postJsonData（）方法会导致对方收不到请求，此方法能够发送请求
                result = HttpClientUtil.doPost(url + "/api/v1/unionLogin/unionRegister", body.toJSONString());
                logger.info("手机号为：" + phone + "," + capitalName + "撞库原始返回参数:{}", result);
            } else if (Objects.equals("大象花呗",capitalName)) {
                result = HttpClientUtil.getInstance().postJsonData(url + "/openapi/unionlogin/kadana/getredirecturl", body.toJSONString());
                logger.info("手机号为：" + phone + "," + capitalName + "联登原始返回参数:{}", result);
            } else {
                result = HttpClientUtil.getInstance().postJsonData(url + "/api/v1/unionLogin/unionRegister", body.toJSONString());
                logger.info("手机号为：" + phone + "," + capitalName + "联登原始返回参数:{}", result);
            }
        } catch (Exception e) {
            logger.info("手机号为：" + phone + "," + capitalName + "联登原始返回参数失败");
            e.printStackTrace();
            return null;
        }
        if (org.apache.commons.lang.StringUtils.isEmpty(result)) {
            logger.error("手机号为：" + phone + "," + capitalName + "联登失败");
            return null;
        }
        ChannelUnionAutoResponse channelUnionAutoResponse = null;
        try {
            channelUnionAutoResponse = JSON.parseObject(result, ChannelUnionAutoResponse.class);
            return channelUnionAutoResponse;
        } catch (Exception e) {
            logger.info("手机号为：" + phone + "," + capitalName + "联登原始返回参数转换失败");
            e.printStackTrace();
            return null;
        }
    }
}