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

import cn.hutool.crypto.digest.MD5;
import cn.hutool.http.HttpResponse;
import cn.hutool.http.HttpUtil;
import com.alibaba.fastjson.JSON;
import com.nova.sankuai.infra.mapper.CustomerMapper;
import com.nova.sankuai.service.ICustomerUserService;
import lombok.Getter;
import lombok.Setter;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.util.Objects;

/**
 * @author Gmw
 * @date 2022年5月19日
 */
@Getter
@Setter
@Component
public class YiBeiUtil {

    /**
     * 撞库接口
     */
    @Value("${yibei.config.check-user-url}")
    private String checkUserUrl;

    /**
     * 正式传参接口
     */
    @Value("${yibei.config.register-url}")
    private String registerUrl;

    /**
     * 渠道编码
     */
    @Value("${yibei.config.channel-code}")
    private String channelCode;

    /**
     * 回调接口使用到的
     */
    @Value("${yibei.config.sign-key}")
    private String signKey;

    /**
     * 用户渠道来源(固定参数)
     */
    public static final String channelSource = "BSB00001";


    @Resource
    ICustomerUserService customerUserService;

    @Resource
    CustomerMapper customerMapper;

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

    /**
     * 撞库接口
     *
     * @param phone 手机号
     * @return
     */
    public YiBeiCheckUserResponseVO checkUser(String phone) {
        MD5 md5 = MD5.create();
        String phoneMd5 = md5.digestHex(phone);
        String sign = md5.digestHex(String.format("phoneMd5=%s&channelCode=%s", phoneMd5, channelCode));
        String body = JSON.toJSONString(new YiBeiCheckUserDTO(phoneMd5, channelCode, sign));
        log.info("易贝分期撞库请求, phone={}, body={}", phone, body);
        HttpResponse response = HttpUtil.createPost(checkUserUrl)
                .header("Content-Type", "application/json")
                .body(body)
                .execute();
        if (response == null) {
            log.error("易贝分期撞库请求失败");
            return null;
        }
        YiBeiCheckUserResponseVO vo = null;
        try {
            vo = JSON.parseObject(response.body(), YiBeiCheckUserResponseVO.class);
            boolean flag = Objects.equals(vo.getStatus(), 1) // 接口返回成功
                    && Objects.equals(vo.getData().getFilterResult(), 1); // 新用户
            if (flag) {
                log.info("易贝分期撞库请求成功, phone={}", phone);
            } else {
                log.info("易贝分期撞库请求失败, phone={}, resp={}", phone, response.body());
                return null;
            }
            return vo;
        } catch (Exception e) {
            log.info("易贝分期撞库返回转换失败, phone={}, resp={}", phone, response);
            return null;
        }
    }

    public YiBeiRegisterResponseVO register(YiBeiRegisterDTO registerDTO) {
        MD5 md5 = MD5.create();
        String sign = md5.digestHex(String.format("phone=%s&channelCode=%s", registerDTO.getPhone(), channelCode));
        registerDTO.setSign(sign);
        registerDTO.setChannelCode(channelCode);
        registerDTO.setChannelSource(channelSource);
        String body = JSON.toJSONString(registerDTO);
        log.info("易贝分期注册请求, param={}", body);
        HttpResponse response = HttpUtil.createPost(registerUrl)
                .header("Content-Type", "application/json")
                .body(body)
                .execute();
        if (response == null) {
            log.error("易贝分期联登请求失败");
            return null;
        }
        YiBeiRegisterResponseVO yiBeiRegisterResponseVO = null;
        try {
            yiBeiRegisterResponseVO = JSON.parseObject(response.body(), YiBeiRegisterResponseVO.class);
            if (yiBeiRegisterResponseVO != null && yiBeiRegisterResponseVO.getStatus() != null && yiBeiRegisterResponseVO.getData() != null) {
                log.info("易贝分期联登返回转换数据为,{}", yiBeiRegisterResponseVO.toString());
                return yiBeiRegisterResponseVO;
            }
        } catch (Exception e) {
            log.info("易贝分期联登返回转换失败,{}", response.body());
            return null;
        }
        log.info("易贝分期联登返回失败,{}", yiBeiRegisterResponseVO);
        return null;
    }

}