package com.nova.sankuai.service.impl;

import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.nova.sankuai.domain.api.huizhixin.Base64Utils;
import com.nova.sankuai.domain.api.huizhixin.EncryptResponse;
import com.nova.sankuai.domain.api.huizhixin.HzxResponse;
import com.nova.sankuai.domain.api.huizhixin.HzxUtil;
import com.nova.sankuai.domain.api.huizhixin.vo.*;
import com.nova.sankuai.domain.entity.*;
import com.nova.sankuai.domain.enums.CallbackSourceEnum;
import com.nova.sankuai.domain.enums.capitalInfo.CapitalApprovalResultEnum;
import com.nova.sankuai.infra.config.CommonException;
import com.nova.sankuai.infra.mapper.CallbackInfoMapper;
import com.nova.sankuai.infra.mapper.CustomerCapitalResultMapper;
import com.nova.sankuai.infra.mapper.CustomerMapper;
import com.nova.sankuai.infra.mapper.CustomerUserMapper;
import com.nova.sankuai.infra.utils.RsaSecretUtils;
import com.nova.sankuai.service.ICityService;
import com.nova.sankuai.service.ICustomerCapitalResultService;
import com.nova.sankuai.service.ICustomerUserService;
import com.nova.sankuai.service.IHzxService;
import org.apache.commons.lang.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.stream.Collectors;

/**
 * 汇智信ServiceImpl
 */
@Service
public class HzxServiceImpl implements IHzxService {

    private final HzxUtil hzxUtil;

    private final RsaSecretUtils rsaSecretUtils;

    public final static ObjectMapper OBJECT_MAPPER = new ObjectMapper();

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

    @Resource
    ICustomerCapitalResultService customerCapitalResultService;

    @Resource
    ICustomerUserService customerUserService;

    @Resource
    CustomerMapper customerMapper;

    @Resource
    private CustomerUserMapper customerUserMapper;

    @Resource
    private CallbackInfoMapper callbackInfoMapper;

    @Resource
    private ICityService cityService;

    @Resource
    private CustomerCapitalResultMapper capitalResultMapper;

    /**
     * 己方私钥base64
     */
    @Value("${hzx.self.private}")
    private String privateKeyBase64;

    /**
     * 对方公钥base64
     */
    @Value("${hzx.other.public}")
    private String publicKeyBase64;

    /**
     * 产品号
     */
    @Value("${hzx.product_cid}")
    private String productCid;

    public HzxServiceImpl(HzxUtil hzxUtil, RsaSecretUtils rsaSecretUtils) {
        this.hzxUtil = hzxUtil;
        this.rsaSecretUtils = rsaSecretUtils;
    }

//    /**
//     * 前置检测接口
//     *
//     * @param vo
//     */
//    @Override
//    public HzxResponse<HzxResponseData> checkUser(CheckUserVo vo) {
//        HzxResponse<HzxResponseData> hzxResponseDataHzxResponse = this.hzxUtil.checkUser(vo.getId(), vo.getPhone(), vo.getName());
//        return hzxResponseDataHzxResponse;
//    }
//
//    @Override
//    public HzxResponse apply() {
//        String orderNo = SerialGenerator.getOrder();
//        log.info("订单号：{}",orderNo);
//        HzxResponse apply = hzxUtil.apply(orderNo, productCid);
//        return apply;
//    }
//
//    @Override
//    public HzxGetResponse getUrl() {
//        String appid= "20220518200025772106363467429863";
//        HzxGetResponse partnerUrl = hzxUtil.getPartnerUrl(appid, null);
//        return partnerUrl;
//    }

    /**
     * 获取订单信息
     *
     * @param vo
     * @return
     */
    @Override
    public EncryptResponse orderInfo(RequestVo vo) {
        String content = vo.getContent();
        LoadApplyExtInfoVo loadApplyExtInfoVo = null;
        String data = null;
        try {
            // 解密密文
            data = new String(Objects.requireNonNull(RsaSecretUtils.privateDecrypt(Base64Utils.decode(content), this.privateKeyBase64)));
            loadApplyExtInfoVo = JSON.parseObject(data, LoadApplyExtInfoVo.class);
            log.info("汇智信调用接口信息:入参信息：{}",loadApplyExtInfoVo.toString());
        } catch (Exception e) {
            throw new CommonException("数据解密失败");
        }
        // 验签
        boolean signPass = RsaSecretUtils.rsaSignCheck(Base64Utils.decode(content), Base64Utils.decode(vo.getSign()), publicKeyBase64);
        log.info("获取订单验签：{}",signPass);
        if (!signPass){
            throw new CommonException("验签失败");
        }
        if (StringUtils.isEmpty(loadApplyExtInfoVo.getProductCid()) || !productCid.equals(loadApplyExtInfoVo.getProductCid())) {
            log.error("汇智信调用接口错误：产品号错误：{}", loadApplyExtInfoVo.getProductCid());
            throw new CommonException("产品号有误");
        }
        CustomerCapitalResult capitalResult = customerCapitalResultService.getOne(new LambdaQueryWrapper<CustomerCapitalResult>()
                .eq(CustomerCapitalResult::getCreditNo, loadApplyExtInfoVo.getApplyId()));
        if (capitalResult == null) {
            log.error("汇智信调用接口错误：不存在该产品");
            throw new CommonException("不存在该产品");
        }
        CustomerUser customerUser = customerUserMapper.getCustomerUser(capitalResult.getCustomerUserId());
        if (customerUser == null) {
            log.error("汇智信调用接口错误：用户不存在");
            throw new CommonException("用户不存在");
        }
        Customer latestCustomer = customerMapper.getLatestCustomerRecord(customerUser.getPhone());
        if (latestCustomer == null) {
            log.error("汇智信调用接口错误：用户不存在");
            throw new CommonException("用户不存在");
        }
        OrderInfoVo orderInfo = new OrderInfoVo();
        setOrderInfo(orderInfo, customerUser, latestCustomer, capitalResult);
        setOcrInfo(orderInfo, latestCustomer);
        setImageInfo(orderInfo, latestCustomer);
        List<City> citise = cityService.list();
        Map<String, List<City>> collectByCityId = citise.stream().collect(Collectors.groupingBy(City::getCityId));
        Map<String, List<City>> collectByCityName = citise.stream().collect(Collectors.groupingBy(City::getName));
        setLoanBefore(orderInfo, latestCustomer, collectByCityId, collectByCityName);
        setLoanInfo(orderInfo, latestCustomer);
        EncryptResponse response = new EncryptResponse();
        HzxResponse hzxResponse = new HzxResponse();
        hzxResponse.setCode("0000");
        hzxResponse.setMsg("成功");
        hzxResponse.setData(orderInfo);
        try {
            // 返回值加密
            byte[] encryptByte = RsaSecretUtils.publicEncrypt(OBJECT_MAPPER.writeValueAsBytes(hzxResponse), this.publicKeyBase64);
            // 返回值加签
            String signStr = RsaSecretUtils.rsaSign(encryptByte, privateKeyBase64);
            response.setContent(Base64Utils.encode(encryptByte));
            response.setSign(signStr);
        }catch (Exception e){
            throw new CommonException("数据加密失败");
        }
        log.info("返回信息为：{}",orderInfo.toString());
        customerCapitalResultService.update(Wrappers.<CustomerCapitalResult>lambdaUpdate()
                .set(CustomerCapitalResult::getApprovalResult, CapitalApprovalResultEnum.APPROVAL_SUCCESS.getCode())
                .eq(CustomerCapitalResult::getCreditNo,loadApplyExtInfoVo.getApplyId()));
        return response;

    }

    /**
     * 回调
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public CallbackVo callBack(RequestVo vo) {
        String data;
        Map paramMap;

        try {
            // 解密密文
            data = new String(Objects.requireNonNull(RsaSecretUtils.privateDecrypt(Base64Utils.decode(vo.getContent()), this.privateKeyBase64)));
            paramMap = JSON.parseObject(data, Map.class);
            System.out.println("data: "+data);
            System.out.println("map: "+paramMap);
            log.info("汇智信调用回调信息:入参信息：{}",paramMap);
        } catch (Exception e) {
            throw new CommonException("数据解密失败");
        }
        // 验签
        boolean signPass = RsaSecretUtils.rsaSignCheck(Base64Utils.decode(vo.getContent()), Base64Utils.decode(vo.getSign()), publicKeyBase64);
        log.info("获取订单验签：{}",signPass);
        if (!signPass){
            throw new CommonException("验签失败");
        }
        log.info("获取订单验签：{}",signPass);
        CustomerCapitalResult capitalResult = capitalResultMapper.selectOne(new QueryWrapper<CustomerCapitalResult>().eq("credit_no", paramMap.get("applyId")));
        if (Objects.isNull(capitalResult)){
            log.error("汇智信调用回调接口错误：订单不存在");
            throw new CommonException("订单不存在");
        }
        CallbackInfo callbackInfo = new CallbackInfo();
        callbackInfo.setCreditNo(capitalResult.getCreditNo());
        callbackInfo.setSource(CallbackSourceEnum.HZX.getCode());
        callbackInfoMapper.insert(callbackInfo);
        CallbackVo callbackVo = new CallbackVo();
        callbackVo.setCode(200);
        callbackVo.setMsg("成功");
        return callbackVo;
    }

    public void setOrderInfo(OrderInfoVo orderInfo, CustomerUser customerUser, Customer latestCustomer, CustomerCapitalResult capitalResult) {
        UserInfoVo userInfoVo = new UserInfoVo();
        userInfoVo.setUserSid(capitalResult.getCustomerUserId());
        userInfoVo.setApplyId(capitalResult.getCreditNo());
        userInfoVo.setPhone(customerUser.getPhone());
        userInfoVo.setIp(latestCustomer.getClientIp());
        if (StringUtils.isEmpty(latestCustomer.getClientIp())){
            userInfoVo.setIp("127.0.0.1");
        }
        userInfoVo.setRegTime(customerUser.getCreationDate());
        userInfoVo.setName(latestCustomer.getName());
        userInfoVo.setID(latestCustomer.getIdCard());
        orderInfo.setUserInfo(userInfoVo);
    }

    public void setOcrInfo(OrderInfoVo orderInfo, Customer latestCustomer) {
        OcrInfoVo ocrInfoVo = new OcrInfoVo();
        ocrInfoVo.setRace(latestCustomer.getNation());
        ocrInfoVo.setName(latestCustomer.getName());
        ocrInfoVo.setGender(latestCustomer.getSex());
        ocrInfoVo.setIdCardNumber(latestCustomer.getIdCard());
        ocrInfoVo.setAddress(latestCustomer.getAddress());
        if (!StringUtils.isEmpty(latestCustomer.getIdValidDateBegin())) {
            StringBuffer dateBegin = new StringBuffer(latestCustomer.getIdValidDateBegin());
            dateBegin.insert(6, ".");
            dateBegin.insert(4, ".");
            latestCustomer.setIdValidDateBegin(dateBegin.toString());
        }
        if (!StringUtils.isEmpty(latestCustomer.getIdValidDateEnd()) && !latestCustomer.getIdValidDateEnd().equals("长期")) {
            StringBuffer dateEnd = new StringBuffer(latestCustomer.getIdValidDateEnd());
            dateEnd.insert(6, ".");
            dateEnd.insert(4, ".");
            latestCustomer.setIdValidDateEnd(dateEnd.toString());
        }else{
            latestCustomer.setIdValidDateEnd("长期");
        }
        if ("1".equals(latestCustomer.getIdLongTerm())) {
            ocrInfoVo.setValidDate(latestCustomer.getIdValidDateBegin() + "-长期");
        } else {
            ocrInfoVo.setValidDate(latestCustomer.getIdValidDateBegin() + "-" + latestCustomer.getIdValidDateEnd());
        }
        ocrInfoVo.setIssuedBy(latestCustomer.getSignOrganization());
        HashMap<String, String> birthday = new HashMap<>();
        String year = "";
        String month = "";
        String day = "";
        if (!StringUtils.isEmpty(latestCustomer.getBirthday())) {
            year = latestCustomer.getBirthday().substring(0, 4);
            month = latestCustomer.getBirthday().substring(4, 6);
            day = latestCustomer.getBirthday().substring(6);
        }
        birthday.put("year", year);
        birthday.put("month", month);
        birthday.put("day", day);
        ocrInfoVo.setBirthday(birthday);
        orderInfo.setOcrInfo(ocrInfoVo);
    }

    public void setImageInfo(OrderInfoVo orderInfo, Customer latestCustomer) {
        ImageVo imageVo = new ImageVo();
        imageVo.setFront(latestCustomer.getIdCardFrontPath());
        imageVo.setBack(latestCustomer.getIdCardBackPath());
        imageVo.setImageBest(latestCustomer.getFacePhotoPath());
        orderInfo.setImage(imageVo);
    }

    public void setLoanBefore(OrderInfoVo orderInfo, Customer latestCustomer, Map<String, List<City>> collectByCityId, Map<String, List<City>> collectByCityName) {
        LoanBeforeVo loanBeforeVo = new LoanBeforeVo();
        hzxUtil.educationParse(loanBeforeVo,latestCustomer);
        hzxUtil.maritalStatusParse(loanBeforeVo,latestCustomer);
        loanBeforeVo.setProvinceName(latestCustomer.getLiveProvince());
        if (collectByCityId.get(latestCustomer.getCity()) != null) {
            loanBeforeVo.setProvinceCode(collectByCityId.get(latestCustomer.getCity()).get(0).getProvinceId());
            loanBeforeVo.setProvinceCode(collectByCityId.get(latestCustomer.getCity()).get(0).getCityId());
        }
        loanBeforeVo.setCityName(latestCustomer.getCityName());
        loanBeforeVo.setDistrictName(latestCustomer.getLiveArea());
        loanBeforeVo.setDetailAddress(latestCustomer.getAddress());
        loanBeforeVo.setCompany(latestCustomer.getCompanyName());
        loanBeforeVo.setCompanyProvinceName(latestCustomer.getCompanyProvince());
        loanBeforeVo.setCompanyCityName(latestCustomer.getCompanyCity());
        if (collectByCityName.get(latestCustomer.getCompanyCity()) != null) {
            loanBeforeVo.setCompanyProvinceCode(collectByCityName.get(latestCustomer.getCompanyCity()).get(0).getProvinceId());
            loanBeforeVo.setCompanyCityCode(collectByCityName.get(latestCustomer.getCompanyCity()).get(0).getCityId());
        }
        loanBeforeVo.setCompanyDistrictName(latestCustomer.getCompanyArea());
        loanBeforeVo.setCompanyDetailAddress(latestCustomer.getCompanyAddress());
        hzxUtil.industryParse(loanBeforeVo,latestCustomer);
        hzxUtil.positionParse(loanBeforeVo,latestCustomer);
        hzxUtil.monthlySalaryParse(loanBeforeVo,latestCustomer);
        hzxUtil.loanPurposeParse(loanBeforeVo,latestCustomer);
        loanBeforeVo.setEmail(latestCustomer.getEmail());
        loanBeforeVo.setFirstContactName(latestCustomer.getRelationshipName());
        loanBeforeVo.setFirstContactPhone(latestCustomer.getRelationshipPhone());
        //第一联系人关系
        hzxUtil.relationshipParse(loanBeforeVo,latestCustomer);
        loanBeforeVo.setSecondContactName(latestCustomer.getContactName());
        loanBeforeVo.setSecondContactPhone(latestCustomer.getContactPhone());
        //第二联系人关系
        hzxUtil.secondContactParse(loanBeforeVo,latestCustomer);
        orderInfo.setLoanBefore(loanBeforeVo);
    }

    public void setLoanInfo(OrderInfoVo orderInfo, Customer latestCustomer) {
        LoanVo loanVo = new LoanVo();
        hzxUtil.houseSituationParse(loanVo,latestCustomer);
        hzxUtil.loanOccupationParse(loanVo,latestCustomer);
        //职称
        loanVo.setPositionTitle(null);
        //职务
        hzxUtil.positionDutyParse(loanVo,latestCustomer);
        //单位性质
        hzxUtil.companyTypeParse(loanVo,latestCustomer);
        //还款来源
        loanVo.setRepaySource(null);
        //贷款用途
        hzxUtil.pullLoanPurposeParse(loanVo,latestCustomer);
        //负债总额
        loanVo.setDebtAmount("0");
        //负债情况
        loanVo.setDebtSituation(null);
        orderInfo.setLoan(loanVo);
    }


}