package com.nova.sankuai.domain.entity;

import cn.hutool.http.HttpStatus;
import cn.hutool.json.JSONUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.annotation.TableId;
import com.nova.sankuai.domain.api.aizhudai.AiZhuDaiResponse;
import com.nova.sankuai.domain.api.huizhongzhidai.HuiZhongZhiDaiCommitResponse;
import com.nova.sankuai.domain.api.huizhongzhidai.HuiZhongZhiDaiHitResponse;
import com.nova.sankuai.domain.api.jinRiTouTiao.JinRiTouTiaoResponse;
import com.nova.sankuai.domain.api.jinxiushuke.JinXiuShuKeResponse;
import com.nova.sankuai.domain.api.jinxiushuke.JinXiuShuKeUtil;
import com.nova.sankuai.domain.api.jinzhanggui.JinZhangGuiResponse;
import com.nova.sankuai.domain.api.jinzhanggui.JinZhangGuiUtil;
import com.nova.sankuai.domain.api.minsheng.MinShengResponse;
import com.nova.sankuai.domain.api.nanjingmingtuo.NanJingMingTuoResp;
import com.nova.sankuai.domain.api.nanjingmingtuo.NanJingMingTuoUtil;
import com.nova.sankuai.domain.api.rongduoduo.RongDuoDuoResponse;
import com.nova.sankuai.domain.api.rongduoduo.RongDuoDuoUtil;
import com.nova.sankuai.domain.api.shanghaizhongzan.ShangHaiZhongZanResponse;
import com.nova.sankuai.domain.api.sujinsuo.SuJinSuoResponse;
import com.nova.sankuai.domain.api.tianshi.TianShiResponse;
import com.nova.sankuai.domain.api.tianshi.TianShiUtil;
import com.nova.sankuai.domain.api.xiamenzhongheyinhua.XiaMenZhongHeYinHuaResponse;
import com.nova.sankuai.domain.api.xinyeyoupin.XyypResponse;
import com.nova.sankuai.domain.api.yidai.YiDaiResponse;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;

import java.util.Date;
import java.util.List;
import java.util.Objects;
import java.util.Optional;

/**
 * @author weikangdi
 * @create 2021/11/12
 */
@Data
@ApiModel(value = "接口公司客户推送记录表")
@Slf4j
public class ApiCompanyRecord {

    public static final int SUCCESS = 1;

    public static final int FAIL = 0;

    @ApiModelProperty(value = "主键")
    @TableId
    private Long id;

    @ApiModelProperty(value = "接口公司id")
    private Long companyId;

    @ApiModelProperty(value = "客户记录id")
    private Long customerRecordId;

    @ApiModelProperty(value = "创建日期")
    private Date creationDate;

    @ApiModelProperty(value = "状态")
    private Integer status;

    @ApiModelProperty(value = "推送结果信息")
    private String message;

    @ApiModelProperty(value = "推送结果json")
    private String result;

    public ApiCompanyRecord(Long companyId, Long customerRecordId, String result) {
        this.companyId = companyId;
        this.customerRecordId = customerRecordId;
        this.result = result;
        this.creationDate = new Date();
    }

    public static ApiCompanyRecord getMinShengRecord(Long companyId, Long customerRecordId, String result) {
        ApiCompanyRecord apiCompanyRecord = new ApiCompanyRecord(companyId, customerRecordId, result);
        MinShengResponse response = JSONUtil.toBean(result, MinShengResponse.class);
        if (ApiCompanyRecord.SUCCESS == response.getResStatus()) {
            apiCompanyRecord.setStatus(ApiCompanyRecord.SUCCESS);
        } else {
            apiCompanyRecord.setStatus(ApiCompanyRecord.FAIL);
        }
        apiCompanyRecord.setMessage(response.getResMsg());
        return apiCompanyRecord;
    }

    public static ApiCompanyRecord getAiZhuDaiRecord(Long companyId, Long customerRecordId, String result) {
        ApiCompanyRecord apiCompanyRecord = new ApiCompanyRecord(companyId, customerRecordId, result);
        AiZhuDaiResponse response = JSONUtil.toBean(result, AiZhuDaiResponse.class);
        if (ApiCompanyRecord.SUCCESS == response.getCode()) {
            apiCompanyRecord.setStatus(ApiCompanyRecord.SUCCESS);
        } else {
            apiCompanyRecord.setStatus(ApiCompanyRecord.FAIL);
        }
        apiCompanyRecord.setMessage(response.getMessage());
        return apiCompanyRecord;
    }

    public static ApiCompanyRecord getXiaMenZhongHeYinHuaRecord(Long companyId, Long customerRecordId, String result) {
        ApiCompanyRecord apiCompanyRecord = new ApiCompanyRecord(companyId, customerRecordId, result);
        XiaMenZhongHeYinHuaResponse response = JSONUtil.toBean(result, XiaMenZhongHeYinHuaResponse.class);
        if (HttpStatus.HTTP_OK == response.getCode()) {
            apiCompanyRecord.setStatus(ApiCompanyRecord.SUCCESS);
        } else {
            apiCompanyRecord.setStatus(ApiCompanyRecord.FAIL);
        }
        apiCompanyRecord.setMessage(response.getMsg());
        return apiCompanyRecord;
    }

    public static ApiCompanyRecord getRongDuoDuoRecord(Long companyId, Long customerRecordId, String result) {
        ApiCompanyRecord apiCompanyRecord = new ApiCompanyRecord(companyId, customerRecordId, result);
        RongDuoDuoResponse response = RongDuoDuoUtil.getResponse(result);
        if (response != null && RongDuoDuoResponse.SUCCESS == response.getStatus()) {
            apiCompanyRecord.setStatus(ApiCompanyRecord.SUCCESS);
        } else {
            apiCompanyRecord.setStatus(ApiCompanyRecord.FAIL);
        }
        if (response != null) {
            apiCompanyRecord.setMessage(response.getMes());
        }
        return apiCompanyRecord;
    }

    public static ApiCompanyRecord getTianShiRecord(Long companyId, Long customerRecordId, Integer result) {
        ApiCompanyRecord apiCompanyRecord = new ApiCompanyRecord(companyId, customerRecordId, Integer.toString(result));
        TianShiResponse response = new TianShiResponse();
        response.setCode(result);
        if (TianShiResponse.SUCCESS == response.getCode()) {
            apiCompanyRecord.setStatus(ApiCompanyRecord.SUCCESS);
            apiCompanyRecord.setMessage(TianShiResponse.SUCCESS_MESSAGE);
        } else {
            apiCompanyRecord.setStatus(ApiCompanyRecord.FAIL);
            apiCompanyRecord.setMessage(TianShiUtil.getFailMessage(response.getCode()));
        }
        return apiCompanyRecord;
    }

    public static ApiCompanyRecord getJinXiuShuKeRecord(Long companyId, Long customerRecordId, String response) {
        ApiCompanyRecord apiCompanyRecord = new ApiCompanyRecord(companyId, customerRecordId, response);
        if ("success".equals(response)) {
            apiCompanyRecord.setStatus(ApiCompanyRecord.SUCCESS);
            apiCompanyRecord.setMessage("成功");
        } else {
            String code = "";
            try {
                JinXiuShuKeResponse toBean = JSONUtil.toBean(response, JinXiuShuKeResponse.class);
                code = toBean.getMsg();
            } catch (Exception e) {
                if (response.length() > 255) {
                    code = response.subSequence(0, 254).toString();
                } else {
                    code = response;
                }
            }
            apiCompanyRecord.setStatus(ApiCompanyRecord.FAIL);
            apiCompanyRecord.setMessage(JinXiuShuKeUtil.getFailMessage(code));
        }
        return apiCompanyRecord;
    }

    public static ApiCompanyRecord getSuJinSuoRecord(Long companyId, Long customerRecordId, String result) {
        ApiCompanyRecord apiCompanyRecord = new ApiCompanyRecord(companyId, customerRecordId, result);
        SuJinSuoResponse response = JSONUtil.toBean(result, SuJinSuoResponse.class);
        JSONObject jsonObject = JSONObject.parseObject(result);
        List susses = (List) jsonObject.getJSONObject("data").get("successIdList");
        if (susses.size() > 0) {
            apiCompanyRecord.setStatus(ApiCompanyRecord.SUCCESS);
        } else {
            apiCompanyRecord.setStatus(ApiCompanyRecord.FAIL);
        }
        apiCompanyRecord.setMessage(response.getMsg());
        return apiCompanyRecord;
    }

    public static ApiCompanyRecord getJinRiTouTiaoRecord(Long companyId, Long customerRecordId, String result) {
        ApiCompanyRecord apiCompanyRecord = new ApiCompanyRecord(companyId, customerRecordId, result);
        JinRiTouTiaoResponse response = JSONUtil.toBean(result, JinRiTouTiaoResponse.class);
        if (response.getErrno() == 0) {
            apiCompanyRecord.setStatus(ApiCompanyRecord.SUCCESS);
        } else {
            apiCompanyRecord.setStatus(ApiCompanyRecord.FAIL);
        }
        apiCompanyRecord.setMessage(response.getMsg());
        return apiCompanyRecord;
    }


    public static ApiCompanyRecord getHuiZhongZhiDai(Long companyId, Long customerRecordId, String response) {
        String code = "";
        String msg = "";
        try {
            JSONObject data = (JSONObject) JSONObject.parseObject(response).get("data");
            code = data.get("error_no").toString();
            msg = (String) data.get("error_info");
        } catch (Exception e) {
            try {
                HuiZhongZhiDaiHitResponse hitResponse = JSONObject.parseObject(response, HuiZhongZhiDaiHitResponse.class);
                code = hitResponse.getCode();
                msg = hitResponse.getMsg();
            } catch (Exception ex) {
                ApiCompanyRecord record = new ApiCompanyRecord(companyId, customerRecordId, response);
                record.setStatus(ApiCompanyRecord.FAIL);
                record.setMessage("解析惠众直贷响应失败，响应内容" + response);
                return record;
            }
        }
        ApiCompanyRecord record = new ApiCompanyRecord(companyId, customerRecordId, response);
        if (Integer.toString(HuiZhongZhiDaiCommitResponse.SUCCESS).equals(code)) {
            record.setStatus(ApiCompanyRecord.SUCCESS);
            record.setMessage(msg);
        } else {
            record.setStatus(ApiCompanyRecord.FAIL);
            record.setMessage(msg);
        }
        return record;
    }

    public static ApiCompanyRecord getYiDaiRecord(Long companyId, Long customerRecordId, String result) {
        ApiCompanyRecord apiCompanyRecord = new ApiCompanyRecord(companyId, customerRecordId, result);
        YiDaiResponse yiDaiResponse = JSONUtil.toBean(result, YiDaiResponse.class);
        if (YiDaiResponse.SUCCESS.equals(yiDaiResponse.getRetCode())) {
            apiCompanyRecord.setStatus(ApiCompanyRecord.SUCCESS);
            apiCompanyRecord.setMessage("成功");
        } else {
            apiCompanyRecord.setStatus(ApiCompanyRecord.FAIL);
            apiCompanyRecord.setMessage(yiDaiResponse.getRetDesc());
        }
        return apiCompanyRecord;
    }

    public static ApiCompanyRecord getShangHaiZhongZanRecord(Long companyId, Long customerRecordId, String result) {
        result = Optional.ofNullable(result).map(String::trim).orElse(null);
        ApiCompanyRecord apiCompanyRecord = new ApiCompanyRecord(companyId, customerRecordId, result);
        if (ShangHaiZhongZanResponse.SUCCESS.equals(result)) {
            apiCompanyRecord.setStatus(ApiCompanyRecord.SUCCESS);
            apiCompanyRecord.setMessage("成功");
        } else {
            apiCompanyRecord.setStatus(ApiCompanyRecord.FAIL);
            apiCompanyRecord.setMessage(result);
        }
        return apiCompanyRecord;
    }

    public static ApiCompanyRecord getNanJingMingTuoRecord(Long companyId, Long customerRecordId, String result) {
        result = Optional.ofNullable(result).orElse("{}");
        ApiCompanyRecord apiCompanyRecord = new ApiCompanyRecord(companyId, customerRecordId, result);
        NanJingMingTuoResp resp = JSON.parseObject(result, NanJingMingTuoResp.class);
        if (Objects.equals(NanJingMingTuoUtil.HIT_RESP_OK, resp.getCode())) {
            apiCompanyRecord.setStatus(ApiCompanyRecord.SUCCESS);
        } else {
            apiCompanyRecord.setStatus(ApiCompanyRecord.FAIL);
        }
        apiCompanyRecord.setMessage(resp.getMsg());
        return apiCompanyRecord;
    }

    public static ApiCompanyRecord getXinYeYouPinRecord(Long companyId, Long customerRecordId, String result) {
        ApiCompanyRecord apiCompanyRecord = new ApiCompanyRecord(companyId, customerRecordId, result);
        XyypResponse xyypResponse = JSONUtil.toBean(result, XyypResponse.class);
        Integer code = 200;
        if (xyypResponse.getCode().equals(code)) {
            apiCompanyRecord.setStatus(ApiCompanyRecord.SUCCESS);
        } else {
            apiCompanyRecord.setStatus(ApiCompanyRecord.FAIL);
        }
        apiCompanyRecord.setMessage(xyypResponse.getMsg());
        return apiCompanyRecord;
    }

    public static ApiCompanyRecord getDoudouMoneyRecord(Long companyId, Long customerRecordId, String msg, boolean ok) {
        ApiCompanyRecord apiCompanyRecord = new ApiCompanyRecord(companyId, customerRecordId, msg);
        apiCompanyRecord.setStatus(ok ? ApiCompanyRecord.SUCCESS : ApiCompanyRecord.FAIL);
        apiCompanyRecord.setMessage(msg);
        return apiCompanyRecord;
    }

    public static ApiCompanyRecord getJinZhangGuiRecord(Long companyId, Long customerRecordId, String response) {
        ApiCompanyRecord apiCompanyRecord = new ApiCompanyRecord(companyId, customerRecordId, response);
        JinZhangGuiResponse jinZhangGuiResponse = null;
        try {
            jinZhangGuiResponse = JSONObject.parseObject(response, JinZhangGuiResponse.class);
        } catch (Exception e) {
            log.error("金掌柜对接失败");
        }
        if (jinZhangGuiResponse != null && JinZhangGuiUtil.SUCCESS.equals(jinZhangGuiResponse.getErrno())) {
            apiCompanyRecord.setStatus(ApiCompanyRecord.SUCCESS);
            apiCompanyRecord.setMessage("成功");
        } else {
            String code = "";
            try {
                code = jinZhangGuiResponse.getMsg();
            } catch (Exception e) {
                if (response.length() > 255) {
                    code = response.subSequence(0, 254).toString();
                } else {
                    code = response;
                }
            }
            apiCompanyRecord.setStatus(ApiCompanyRecord.FAIL);
            apiCompanyRecord.setMessage(code);
        }
        return apiCompanyRecord;
    }
}