package com.nova.sankuai.service.impl;

import cn.hutool.json.JSONUtil;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.nova.sankuai.domain.api.hengyidai.response.HyGetOrderStatusResponse;
import com.nova.sankuai.domain.dto.qinghuayoupin.RepayPlan;
import com.nova.sankuai.domain.dto.qinghuayoupin.RepayPlanDTO;
import com.nova.sankuai.domain.entity.CustomerCapitalResult;
import com.nova.sankuai.domain.enums.capitalInfo.CapitalApprovalResultEnum;
import com.nova.sankuai.infra.mapper.CustomerCapitalResultMapper;
import com.nova.sankuai.infra.utils.qinghuayoupin.QhypUtil;
import com.nova.sankuai.service.IQingHuaService;
import lombok.AllArgsConstructor;
import lombok.RequiredArgsConstructor;
import org.apache.http.util.TextUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;

import java.lang.reflect.Type;
import java.math.BigDecimal;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Objects;

@Service
@RequiredArgsConstructor
public class QingHuaServiceImpl implements IQingHuaService {
    private final CustomerCapitalResultMapper capitalResultMapper;
    @Value("${rongbei.qingHuaYouPin.privateKeySelf}")
    private String privateKeySelf;
    @Value("${rongbei.qingHuaYouPin.publicKey}")
    private String publicKey;
    private static final Logger log = LoggerFactory.getLogger("capitalLogger");

    @Override
    public String orderStatusPush(Map<String,Object> params) {
        //解密deskey
        String result = QhypUtil.decryptDataFromQh(params, (String) params.get("signature"),(String)params.get("data"),publicKey,privateKeySelf);
        Map<String, Object> resultMap = JSONUtil.parseObj(result).toBean(Map.class);
        String orderStatus = (String) resultMap.get("orderState");
        String loanSuccessTime = (String) resultMap.get("loanSuccessTime");
        String rejectReason = (String) resultMap.get("rejectReason");
        String freezeDay = (String) resultMap.get("freezeDay");
        String partnerOrderNo = (String) resultMap.get("partnerOrderNo");
        String orderId = (String) resultMap.get("orderId");
        String logNumber = (String) resultMap.get("logNumber");
        JSONObject object = new JSONObject();
        try {
            if (!TextUtils.isEmpty(orderStatus) && !TextUtils.isEmpty(partnerOrderNo)) {
                CustomerCapitalResult capitalResult = capitalResultMapper.selectOne(Wrappers.<CustomerCapitalResult>lambdaQuery()
                        .eq(CustomerCapitalResult::getCreditNo,partnerOrderNo));
                if (capitalResult != null) {
                    capitalResult.setApprovalResult(CapitalApprovalResultEnum.APPROVAL_LOAN.getCode());
                    if (!Objects.equals(orderStatus, capitalResult.getThirdOrderStatus())) {
                        if ("LOAN_FAIL".equals(orderStatus)){
                            capitalResult.setThirdOrderStatus(HyGetOrderStatusResponse.STATUS_LOAN_APPLY_FAIL);
                        }else if ("LOANING".equals(orderStatus)){
                            capitalResult.setThirdOrderStatus(HyGetOrderStatusResponse.STATUS_SIGN_SUCCESS);
                        }else if ("LOAN_PASS".equals(orderStatus)){
                            capitalResult.setThirdOrderStatus(HyGetOrderStatusResponse.STATUS_LOAN_APPLY_SUCCESS);
                        }else if ("CLEAR".equals(orderStatus)){
                            capitalResult.setThirdOrderStatus(HyGetOrderStatusResponse.STATUS_REPAY_CLEAN_NORMAL);
                        }
                        capitalResultMapper.update(null, Wrappers.<CustomerCapitalResult>lambdaUpdate()
                                .set(CustomerCapitalResult::getThirdOrderStatus, capitalResult.getThirdOrderStatus())
                                .eq(CustomerCapitalResult::getId, capitalResult.getId()));
                    }
                }
                object.put("code", 200);
                object.put("msg", "成功");
                return QhypUtil.respEncrypt("1000", "订单状态回调接口成功", "","","","", publicKey, privateKeySelf,(String) params.get("desKey"));
            }
        } catch (Exception e) {
            e.printStackTrace();
            log.error("日志编号：" + logNumber + "订单状态回调接口异常:{}", e);
        }
        return QhypUtil.respEncrypt("1001", "订单状态回调接口失败", "","","","", publicKey, privateKeySelf, (String) params.get("desKey"));
    }

    @Override
    public String approvalPush(Map<String, Object> params) {
        String result = QhypUtil.decryptDataFromQh(params, (String) params.get("signature"),(String)params.get("data"),publicKey,privateKeySelf);
        Map<String, Object> resultMap = JSONUtil.parseObj(result).toBean(Map.class);
        String partnerOrderNo = (String) resultMap.get("partnerOrderNo");
        String auditStatus = (String) resultMap.get("approvalStatus");
        Integer amountInt = (Integer) resultMap.get("amount");
        BigDecimal amount = new BigDecimal(amountInt);
        String auditTime = resultMap.get("auditTime") == null ? "" : (String) resultMap.get("auditTime");
        String approvalRate =  resultMap.get("approvalRate") == null ? "" : String.valueOf(resultMap.get("approvalRate"));;
//        String approvalRate = "";
//        if (StringUtils.hasLength(approvalRateString)){
//            Integer approvalRateInt = Integer.parseInt(approvalRateString);
//             approvalRate = String.valueOf(approvalRateInt);
//        }
        String orderId = resultMap.get("orderId").equals(null) ? "" : (String) resultMap.get("orderId");
        String logNumber = (String) resultMap.get("logNumber");
        try {
            if (!TextUtils.isEmpty(partnerOrderNo)) {
                CustomerCapitalResult capitalResult = capitalResultMapper.selectOne(Wrappers.<CustomerCapitalResult>lambdaQuery()
                        .eq(CustomerCapitalResult::getCreditNo,partnerOrderNo));
                log.error("日志编号：" + logNumber + "审核结果回调接口capitalResult:{}", capitalResult);
                if (capitalResult != null) {
                    log.error("日志编号：" + logNumber + "审核结果回调接口查询成auditStatus:{}", auditStatus);
                    if ("AUDITING".equals(auditStatus)){
                        capitalResult.setApprovalResult(CapitalApprovalResultEnum.APPROVAL_WAIT.getCode());
                        capitalResult.setThirdOrderStatus(HyGetOrderStatusResponse.STATUS_AUDIT_WAIT);
                    }else if ("AUDIT_REJECT".equals(auditStatus)){
                        capitalResult.setApprovalResult(CapitalApprovalResultEnum.APPROVAL_REFUSE.getCode());
                        capitalResult.setThirdOrderStatus(HyGetOrderStatusResponse.STATUS_AUDIT_FAIL);
                    }else if ("AUDIT_PASS".equals(auditStatus)){
                        capitalResult.setApprovalResult(CapitalApprovalResultEnum.APPROVAL_SUCCESS.getCode());
                        capitalResult.setThirdOrderStatus(HyGetOrderStatusResponse.STATUS_AUDIT_SUCCESS);
                    }
                    capitalResult.setCreditApplyTime(auditTime);
                    capitalResult.setQuotaRate(approvalRate);
                    capitalResult.setTotalCredit(amount.toString());
                    capitalResultMapper.updateById(capitalResult);
                    return QhypUtil.respEncrypt("1000", "进件审批结果回调接口成功", "","","","", publicKey, privateKeySelf,(String) params.get("desKey"));
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
            log.error("日志编号：" + logNumber + "审核结果回调接口异常:{}", e);
        }
        return QhypUtil.respEncrypt("1001", "进件审批结果回调接口失败", "","","","", publicKey, privateKeySelf,(String) params.get("desKey"));
    }

    @Override
    public String pushRepayPlan(Map<String, Object> params) {
        JSONObject object = new JSONObject();
        object.put("code", 200);
        object.put("msg", "成功");
        return QhypUtil.respEncrypt("1000", "还款计划回调接口", "","","","", publicKey, privateKeySelf,(String) params.get("desKey"));
    }

    @Override
    public String pushRepayResult(Map<String, Object> params) {

        return QhypUtil.respEncrypt("1000", "还款结果推送回调接口成功", "","","","", publicKey, privateKeySelf,(String) params.get("desKey"));
    }

    @Override
    public String rightsStatusPush(Map<String, Object> params) {
        return QhypUtil.respEncrypt("1000", "权益扣费计划变更回调接口成功", "","","","", publicKey, privateKeySelf,(String) params.get("desKey"));
    }

}