package com.nova.sankuai.service.impl;

import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.nova.sankuai.domain.api.aliyunIP.AliyunUtil;
import com.nova.sankuai.domain.api.aliyunIP.CustomerIpInfo;
import com.nova.sankuai.domain.api.hengyidai.response.HyGetOrderStatusResponse;
import com.nova.sankuai.domain.api.zhongzan.RbResponse;
import com.nova.sankuai.domain.dto.CapitalInfoDto;
import com.nova.sankuai.domain.dto.CapitalInfoPageDto;
import com.nova.sankuai.domain.entity.*;
import com.nova.sankuai.domain.enums.CapitalShowPageTypeEnum;
import com.nova.sankuai.domain.enums.CustomerInfoStatusEnum;
import com.nova.sankuai.domain.enums.capitalInfo.*;
import com.nova.sankuai.domain.vo.*;
import com.nova.sankuai.domain.vo.capitalresult.CapitalInfoAppVo;
import com.nova.sankuai.domain.vo.capitalresult.CapitalInfoVo;
import com.nova.sankuai.domain.vo.capitalresult.OrderExamineShowVo;
import com.nova.sankuai.infra.config.CommonException;
import com.nova.sankuai.infra.mapper.*;
import com.nova.sankuai.infra.utils.PageUtil;
import com.nova.sankuai.infra.utils.UserUtil;
import com.nova.sankuai.infra.utils.qinghuayoupin.QingHuaYouPinUtil;
import com.nova.sankuai.security.UserDetail;
import com.nova.sankuai.service.*;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.jetbrains.annotations.NotNull;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;

import javax.servlet.http.HttpServletRequest;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.time.LocalDate;
import java.time.ZoneId;
import java.time.format.DateTimeFormatter;
import java.util.*;
import java.util.stream.Collectors;

/**
 * @author weikangdi 2022/4/29
 */
@Service
@AllArgsConstructor
@Slf4j
public class CapitalInfoServiceImpl extends ServiceImpl<CapitalInfoMapper, CapitalInfo> implements ICapitalInfoService {

    private final CapitalInfoMapper capitalInfoMapper;

    private final PageUtil pageUtil;

    private final ICustomerCapitalResultService customerCapitalResultService;

    private final CustomerMapper customerMapper;

    private final CustomerCapitalResultMapper customerCapitalResultMapper;

    private final ICityService cityService;

    private final AliyunUtil aliyunUtil;

    private final CustomerUserMapper customerUserMapper;

    private final LoanSupermarketMapper loanSupermarketMapper;

    private final HttpServletRequest request;

    private final IChannelInfoService channelInfoService;

//    private final ProvinceMapper provinceMapper;
    private final IPlatformCapitalService platformCapitalService;
    private final QingHuaYouPinUtil qingHuaYouPinUtil;

    @Override
    public IPage<CapitalInfoVo> pageModel(CapitalInfoPageDto pageDto) {
        Page page = pageUtil.getPage(pageDto);
        return capitalInfoMapper.pageModel(page, pageDto);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void edit(CapitalInfoDto capitalInfoDto) {
        CapitalInfo capitalInfo = getById(capitalInfoDto.getId());
        if (capitalInfo == null) {
            throw new CommonException("该资方信息不存在");
        }
        capitalInfo.setEnableFlag(capitalInfoDto.getEnableFlag());
        capitalInfo.setIconUrl(capitalInfoDto.getIconUrl());
        capitalInfo.setLastUpdatedDate(new Date());
        capitalInfo.setName(capitalInfoDto.getName());
        capitalInfo.setIsShowPage(capitalInfoDto.getIsShowPage());
        capitalInfo.setSeq(capitalInfoDto.getSeq());
        capitalInfo.setFundType(capitalInfoDto.getFundType());
        capitalInfo.setAutoPush(capitalInfoDto.getAutoPush());
        capitalInfo.setPageDisplayType(capitalInfoDto.getPageDisplayType());
        capitalInfo.setCityLimit(capitalInfoDto.getCityLimit());
        capitalInfo.setAgeLowerLimit(capitalInfoDto.getAgeLowerLimit());
        capitalInfo.setAgeUpperLimit(capitalInfoDto.getAgeUpperLimit());
        capitalInfo.setMarriageLimit(capitalInfoDto.getMarriageLimit());
        capitalInfo.setSesameLimit(capitalInfoDto.getSesameLimit());
        capitalInfo.setSocialSecurityLimit(capitalInfoDto.getSocialSecurityLimit());
        capitalInfo.setProvidentFundLimit(capitalInfoDto.getProvidentFundLimit());
        capitalInfo.setHouseLimit(capitalInfoDto.getHouseLimit());
        capitalInfo.setCarLimit(capitalInfoDto.getCarLimit());
        capitalInfo.setPolicyLimit(capitalInfoDto.getPolicyLimit());
        capitalInfo.setCreditCardLimit(capitalInfoDto.getCreditCardLimit());
        capitalInfo.setAmountLowerLimit(capitalInfoDto.getAmountLowerLimit());
        capitalInfo.setAmountUpperLimit(capitalInfoDto.getAmountUpperLimit());
        capitalInfo.setMonthlyIncomeLimit(capitalInfoDto.getMonthlyIncomeLimit());
        capitalInfo.setEducationLimit(capitalInfoDto.getEducationLimit());
        capitalInfo.setIsCollion(capitalInfoDto.getIsCollion());
        capitalInfo.setChannelConfig(capitalInfoDto.getChannelConfig());
        capitalInfo.setChannelIds(capitalInfoDto.getChannelIds());
        capitalInfo.setIsPopUp(capitalInfoDto.getIsPopUp());
        capitalInfo.setAuditSwitch(capitalInfoDto.getAuditSwitch());

        // 于2022-10-24新增：是否一直显示
        capitalInfo.setAlwayShow(capitalInfoDto.getAlwayShow());
        // 新增 完
        // 于2024-1-29新增：公司名称
        capitalInfo.setCompany(capitalInfoDto.getCompany());
        // 新增 完
        capitalInfo.setIsTopView(capitalInfoDto.getIsTopView());

        capitalInfo.setCollionMode(capitalInfoDto.getCollionMode());

        capitalInfo.setIosLink(capitalInfoDto.getIosLink());
        capitalInfo.setAndroidLink(capitalInfoDto.getAndroidLink());

        //ab新增于2024-10-16  参与 H5 匹配资金方 1是 0否
        capitalInfo.setH5Match(capitalInfoDto.getH5Match());

        capitalInfo.setExternalSwitch(capitalInfoDto.getExternalSwitch());
        capitalInfo.setAcquisitionSwitch(capitalInfoDto.getAcquisitionSwitch());

        updateById(capitalInfo);
    }

    /**
     * 获取资方列表
     * @return
     */
    @Override
    public List<CapitalInfoAppVo> getCapitalList() {
        List<CapitalInfoAppVo> result = new ArrayList<>();
        CustomerUser customerUser = customerCapitalResultService.checkUser(request);
        Customer customer = customerMapper.getLatestCustomerRecord(customerUser.getPhone());
        List<CustomerCapitalResult> capitalResultList = new ArrayList<>();
        if (customer != null) {
            capitalResultList = customerCapitalResultService.lambdaQuery()
                    .eq(CustomerCapitalResult::getCustomerUserId, customerUser.getId())
                    .eq(CustomerCapitalResult::getCustomerRecordId, customer.getId()).list();
        }
        if (capitalResultList == null || capitalResultList.isEmpty()) {
            return result;
        }
        List<Long> idList = capitalResultList.stream().map(CustomerCapitalResult::getCapitalInfoId).collect(Collectors.toList());
        List<CapitalInfo> capitalInfoList = capitalInfoMapper.selectBatchIds(idList);

        if (capitalInfoList.isEmpty()) {
            return result;
        }

        // 于2022-10-24新增：是否一直显示
        // 获取当前日期
        String todayStr = LocalDate.now().atStartOfDay().atZone(ZoneId.systemDefault()).format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));
        // 修改 完

        // 2022-11-28新增：是否要判断撞库是否通过，1为是，null或0为否
        String isNotCollision = request.getParameter("isNotCollision");

        for (CapitalInfo capitalInfo : capitalInfoList) {

            // 于2022-10-24新增：若不为空表示不一直显示，判断是否等于当天日期，若不等于当天日期，是不显示
            if (capitalInfo.getAlwayShow() != null) {
                String alwayShowDateStr = capitalInfo.getAlwayShow();
                // 获取到第二天的时间
                SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
                Date date = null;

                String tomorowDateStr = null;// 第二天时间
                try {
                    date = simpleDateFormat.parse(alwayShowDateStr);
                    Calendar calendar = new GregorianCalendar();
                    calendar.setTime(date);
                    calendar.add(Calendar.DATE, 1);//1表示明天,-1表示昨天
                    date = calendar.getTime(); //这个时间就是明天
                    SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd");
                    tomorowDateStr = formatter.format(date);
                } catch (Exception ex) {

                }

                // 逻辑 当天25号操作的时候，录入表的值是25号，然后26也可以显示，但是27号以后就不可以显示了
                if (!todayStr.equals(capitalInfo.getAlwayShow())) {// 如果当前时间不等于数据表的，判断是否和第二天的时间相等
                    if (tomorowDateStr == null) {
                        continue;
                    } else {
                        if (!tomorowDateStr.equals(todayStr)) {// 若第二天的时间和当前时间也不相等，跳过
                            continue;
                        }
                    }
                }

            }
            // 修改 完

            CapitalInfoAppVo capitalInfoAppVo = new CapitalInfoAppVo();
            capitalInfoAppVo.setId(capitalInfo.getId());
            capitalInfoAppVo.setCode(capitalInfo.getCode());
            capitalInfoAppVo.setName(capitalInfo.getName());
            capitalInfoAppVo.setIconUrl(capitalInfo.getIconUrl());
            capitalInfoAppVo.setQuota(customerUser.getFirstQuota());
            capitalInfoAppVo.setFundType(capitalInfo.getFundType());

            // 于2022-11-28新增：联登模式
            capitalInfoAppVo.setCollionMode(capitalInfo.getCollionMode());

            CustomerCapitalResult capitalResult = capitalResultList.stream()
                    .filter(i -> capitalInfo.getId().equals(i.getCapitalInfoId())).findFirst().orElse(null);
            if (capitalResult != null) {
                // 2022-11-28修改：新增了  && !"1".equals(isNotCollision)，是否需要判断撞库通过，1为是
                if (CustomerCapitalResult.CHECK_FAIL.equals(capitalResult.getCheckResult()) && !"1".equals(isNotCollision)) {
                    continue;
                }
                if (CapitalResultStatusEnum.CHECK.getCode().equals(capitalResult.getStatus())) {
                    capitalInfoAppVo.setStatus(CapitalInfoStatusEnum.PREPARE_APPROVAL.getCode());
                } else if (Objects.equals(CapitalFundTypeEnum.BANK.getCode(), capitalInfo.getFundType()) && CapitalResultStatusEnum.APPLY.getCode().equals(capitalResult.getStatus())) {
                    capitalInfoAppVo.setStatus(CapitalInfoStatusEnum.FIRST_APPROVAL.getCode());
                } else {
                    List<String> sceneFlagList = capitalInfo.parseUseSceneFlagList();
                    if (sceneFlagList != null && sceneFlagList.contains(CapitalInfoUserSceneEnum.WITHOUT_APPROVAL_RESULT.getCode())) {
                        capitalInfoAppVo.setStatus(CapitalInfoStatusEnum.APPLY_PASS.getCode());
                    } else {
                        if (CapitalApprovalResultEnum.APPROVAL_SUCCESS.getCode().equals(capitalResult.getApprovalResult())) {
                            capitalInfoAppVo.setStatus(CapitalInfoStatusEnum.APPLY_PASS.getCode());
                            if (capitalResult.getTotalCredit() != null) {
                                Double value = Double.valueOf(capitalResult.getTotalCredit());
                                capitalInfoAppVo.setQuota(value.intValue());
                            }
                            if (CapitalInfoTypeCodeEnum.HENG_YI_DAI.getCode().equals(capitalInfo.getCode())) {
                                if (HyGetOrderStatusResponse.STATUS_ORDER_CANCEL.equals(capitalResult.getThirdOrderStatus()) ||
                                        HyGetOrderStatusResponse.STATUS_EMERGENCY_BACK.equals(capitalResult.getThirdOrderStatus())
                                ) {
                                    capitalInfoAppVo.setStatus(CapitalInfoStatusEnum.LOAN_FAIL.getCode());
                                }
                            }
                        } else {
                            capitalInfoAppVo.setStatus(CapitalInfoStatusEnum.APPLY_WAIT.getCode());
                        }
                    }
                }
                capitalInfoAppVo.setCapitalResultId(capitalResult.getId());
            } else {
                continue;
            }
            result.add(capitalInfoAppVo);
        }
        return result;
    }

    @Override
    public Integer orderExamineNum() {
        List<CapitalInfo> capitalInfos = capitalInfoMapper.selectList(new LambdaQueryWrapper<CapitalInfo>()
                .eq(CapitalInfo::getIsShowPage, 1)
                .eq(CapitalInfo::getDeleteFlag, 0)
                .eq(CapitalInfo::getEnableFlag, 1)
                .orderByAsc(CapitalInfo::getSeq)
        );
        if (capitalInfos == null || capitalInfos.isEmpty()) {
            return 0;
        } else {
            return capitalInfos.size();
        }
    }

    private List<OrderExamineShowVo> version3orderExamineShow(Customer customer, CustomerUser customerUser)  {
        List<OrderExamineShowVo> result = new ArrayList<>();
        List<CustomerCapitalResult> capitalResultList = new ArrayList<>();
        if (Objects.nonNull(customer)) {
            capitalResultList = customerCapitalResultService.lambdaQuery()
                    .eq(CustomerCapitalResult::getCustomerUserId, customerUser.getId())
                    .eq(CustomerCapitalResult::getCustomerRecordId, customer.getId())
                    .list();
        }
        if (CollectionUtils.isEmpty(capitalResultList)) return result;

        List<Long> idList = capitalResultList.stream().map(CustomerCapitalResult::getCapitalInfoId).collect(Collectors.toList());
        List<CapitalInfo> capitalInfoList = capitalInfoMapper.selectBatchIds(idList);

        if (CollectionUtils.isEmpty(capitalInfoList)) return result;

        //筛选启用的资方
        capitalInfoList = capitalInfoList.stream().filter(e -> e.getEnableFlag().equals(1)).collect(Collectors.toList());
        // 按照seq字段排序从小到大排序
        capitalInfoList = capitalInfoList.stream().sorted(Comparator.comparing(CapitalInfo::getSeq))
                .collect(Collectors.toList());

        // 于2022-10-24新增：是否一直显示
        // 获取当前日期
        String todayStr = LocalDate.now().atStartOfDay().atZone(ZoneId.systemDefault()).format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));
        // 修改 完

        for (CapitalInfo capitalInfo : capitalInfoList) {

            // 于2022-10-24新增：若不为空表示不一直显示，判断是否等于当天日期，若不等于当天日期，是不显示
            if (capitalInfo.getAlwayShow() != null) {
                String alwayShowDateStr = capitalInfo.getAlwayShow();
                // 获取到第二天的时间
                SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
                Date date;

                String tomorowDateStr = null;// 第二天时间
                try {
                    date = simpleDateFormat.parse(alwayShowDateStr);
                    Calendar calendar = new GregorianCalendar();
                    calendar.setTime(date);
                    calendar.add(Calendar.DATE, 1);//1表示明天,-1表示昨天
                    date = calendar.getTime(); //这个时间就是明天
                    SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd");
                    tomorowDateStr = formatter.format(date);
                } catch (Exception ex) {
                    log.error(ex.getMessage(), ex);
                }

                // 逻辑 当天25号操作的时候，录入表的值是25号，然后26也可以显示，但是27号以后就不可以显示了
                if (!todayStr.equals(capitalInfo.getAlwayShow())) {// 如果当前时间不等于数据表的，判断是否和第二天的时间相等
                    if (tomorowDateStr == null) {
                        continue;
                    } else {
                        if (!tomorowDateStr.equals(todayStr)) {// 若第二天的时间和当前时间也不相等，跳过
                            continue;
                        }
                    }
                }

            }
            // 修改 完

            CustomerCapitalResult capitalResult = capitalResultList.stream()
                    .filter(i -> capitalInfo.getId().equals(i.getCapitalInfoId())).findFirst().orElse(null);
            //撞库失败的跳过循环
            if (Objects.isNull(capitalResult) || Objects.equals(CustomerCapitalResult.CHECK_FAIL, capitalResult.getCheckResult()))
                continue;

            // 2023-12-1新增流程:当显示主界面顶部为是时，IsTopView值1
            // 1.1）资金类型=线上贷款   fundType 0
            // 1.2）自动推送＝启用  autoPush   0
            // 1.3）联登模式=非半流；collionMode 0
            // 1.4) 审批通过或审批中；
            OrderExamineShowVo vo = new OrderExamineShowVo();
            if (Objects.equals(capitalInfo.getIsTopView(), CapitalTopViewEnum.ENABLE.getCode()) &&
                    Objects.equals(capitalInfo.getFundType(), CapitalFundTypeEnum.ONLINE.getCode())
                    && Objects.equals(capitalInfo.getAutoPush(), CapitalAutoPushEnum.ENABLE.getCode() )  &&
                    Objects.equals(capitalInfo.getCollionMode(), CapitalCollionModeParamEnum.NOT_ENABLED.getCode())) {
                vo = getOrderExamineShowVo(customerUser, capitalInfo, capitalResult);
                if (Objects.equals(capitalResult.getApprovalResult(), CapitalApprovalResultEnum.APPROVAL_SUCCESS.getCode())){
                    vo.setApprovalResult(CapitalApprovalResultEnum.APPROVAL_SUCCESS.getCode());
                }else if (Objects.equals(capitalResult.getApprovalResult(), CapitalApprovalResultEnum.APPROVAL_WAIT.getCode())){
                    vo.setApprovalResult(CapitalApprovalResultEnum.APPROVAL_WAIT.getCode());
                }else if (Objects.equals(capitalResult.getApprovalResult(), CapitalApprovalResultEnum.APPROVAL_REFUSE.getCode())){
                    vo.setApprovalResult(CapitalApprovalResultEnum.APPROVAL_REFUSE.getCode());
                }

            }
            // 完
            else {
                if (Objects.equals(capitalInfo.getAutoPush(), CapitalAutoPushEnum.NOT_ENABLED.getCode())
                        && Objects.equals(capitalInfo.getIsTopView(), CapitalTopViewEnum.ENABLE.getCode())) { //判断 自动推送:不启用 置顶:启用
                     vo = getOrderExamineShowVo(customerUser, capitalInfo, capitalResult);
                } else if (Objects.equals(capitalInfo.getAutoPush(), CapitalAutoPushEnum.ENABLE.getCode())
                        && Objects.equals(capitalInfo.getIsTopView(), CapitalTopViewEnum.ENABLE.getCode())) { //判断 自动推送:启用 置顶:启用
                     vo = getOrderExamineShowVo(customerUser, capitalInfo, capitalResult);
                    if (Objects.equals(CapitalFundTypeEnum.ONLINE.getCode(), capitalInfo.getFundType())) {
                        if (capitalResult.getApprovalResult() == null || Objects.equals(capitalResult.getApprovalResult(), CapitalApprovalResultEnum.APPROVAL_WAIT.getCode())) {
                            vo.setApprovalResult(CapitalInfoStatusEnum.APPLY_WAIT.getCode());
                        } else if (Objects.equals(capitalResult.getApprovalResult(), CapitalApprovalResultEnum.APPROVAL_SUCCESS.getCode())) {
                            vo.setApprovalResult(CapitalInfoStatusEnum.APPLY_PASS.getCode());
                        } else {
                            vo.setApprovalResult(CapitalInfoStatusEnum.APPLY_REFUSE.getCode());
                        }
                    }
                }
            }

            if (capitalResult.getCapitalInfoId() == 4L &&  vo.getApprovalResult() == null && capitalResult.getApprovalResult() != null){
                RbResponse loanResult = qingHuaYouPinUtil.queryLoan(customerUser.getCreditNo());
                if (loanResult.getCode().equals("200")){
                    JSONObject loanJsonObject = loanResult.getData();
                    //判断今天是否是借款日
                    LocalDate now = LocalDate.now();
                    SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
                    String modifyTime = (String) loanJsonObject.get("modifyTime");
                    Date modifyDate = null;
                    try {
                        modifyDate = simpleDateFormat.parse(modifyTime);
                    } catch (ParseException e) {
                        log.error("日期转换异常{}",e);
                    }
                     if ("LOAN_PASS".equals(loanJsonObject.get("orderState"))){
                        RbResponse repayPlan = qingHuaYouPinUtil.queryRepayPlan(customerUser.getCreditNo());//查询还款计划
                        log.info("轻花资方查询今天是否是还款日修改状态"+customerUser.getCreditNo());
                        if (repayPlan.getCode().equals("200")) {
                            JSONObject jsonObject = repayPlan.getData();
                            JSONArray repayPlanList = jsonObject.getJSONArray("repayPlanList");
                            repayPlanList.sort(Comparator.comparing(repayPlan2 -> {
                                JSONObject plan = (JSONObject) repayPlan2;
                                String dateStr = plan.getStr("planRepayDate");
                                LocalDate date = LocalDate.parse(dateStr, DateTimeFormatter.ofPattern("yyyy-MM-dd"));
                                return date;
                            }));
                            //如果今天日期大于放款日，并且小于第一期的还款日，则显示待还款
                            if (now.isAfter(LocalDate.parse(simpleDateFormat.format(modifyDate))) && now.isBefore(LocalDate.parse(repayPlanList.getJSONObject(0).get("planRepayDate").toString()))){
                                vo.setApprovalResult(CapitalApprovalResultEnum.APPROVAL_REPAY.getCode());
                                vo.setThirdOrderStatus(HyGetOrderStatusResponse.STATUS_REPAY_FAIL);//待还款
                                result.add(vo);
                                return result;
                            }
                            log.info("轻花资方查询今天是还款日,{}",repayPlanList);
                            for (int i = 0; i < repayPlanList.size(); i++) {
                                JSONObject jsonObject1 = repayPlanList.getJSONObject(i);
                                String dateStr = (String) jsonObject1.get("planRepayDate");
                                try{
                                    long time = simpleDateFormat.parse((dateStr)).getTime();
                                    long doDayTime = simpleDateFormat.parse(now.toString()).getTime();
                                    if (doDayTime > time && !"REPAID".equals(jsonObject1.get("custRepayState"))){//逾期
                                        vo.setApprovalResult(CapitalApprovalResultEnum.APPROVAL_REPAY.getCode());
                                        vo.setThirdOrderStatus(HyGetOrderStatusResponse.STATUS_REPAY_OVER);
                                        break;
                                    }
                                }catch (ParseException e){
                                    log.error("时间转换异常{}",e);
                                }
                                //今天是否还款日
                                if (now.toString().equals(jsonObject1.get("planRepayDate"))){
                                    //已经还
                                    vo.setApprovalResult(CapitalApprovalResultEnum.APPROVAL_REPAY.getCode());
                                    if ("REPAID".equals(jsonObject1.get("custRepayState"))){
                                        vo.setThirdOrderStatus(HyGetOrderStatusResponse.STATUS_REPAY_SUCCESS);
                                    }else{//去还款
                                        vo.setThirdOrderStatus(HyGetOrderStatusResponse.STATUS_REPAY_FAIL);
                                    }
                                    break;
                                }else {
                                    SimpleDateFormat simpleDateFormat1 = new SimpleDateFormat("yyyy-MM");
                                    Date planRepay = null;
                                    try {
                                        planRepay = simpleDateFormat1.parse(dateStr);
                                    } catch (ParseException e) {
                                        log.error("时间转换异常{}",e);
                                    }
                                    String monthString = simpleDateFormat1.format(planRepay);
                                    if (now.toString().contains(monthString)){//不是还款日，但是还款月，走到这里说明没有逾期。已还款
                                        vo.setApprovalResult(CapitalApprovalResultEnum.APPROVAL_REPAY.getCode());
                                        vo.setThirdOrderStatus(HyGetOrderStatusResponse.STATUS_REPAY_SUCCESS);
                                        break;
                                    }
                                }
                            }

                        }
                    }else {
                         vo.setApprovalResult(capitalResult.getApprovalResult());
                     }
                }
                if (vo.getApprovalResult() == null){
                    vo.setApprovalResult(capitalResult.getApprovalResult());
                }
            }
            result.add(vo);
        }
        return result;
    }

    @NotNull
    private static OrderExamineShowVo getOrderExamineShowVo(CustomerUser customerUser, CapitalInfo capitalInfo, CustomerCapitalResult capitalResult) {
        OrderExamineShowVo vo = new OrderExamineShowVo();
        vo.setCustomerCapitalResultId(capitalResult.getId());
        vo.setCapitalName(capitalInfo.getName());
        vo.setTotalCredit(customerUser.getFirstQuota());
        vo.setCapitalFundType(capitalInfo.getFundType());
        vo.setCapitalCode(capitalInfo.getCode());
        vo.setCapitalId(capitalInfo.getId().intValue());
        vo.setAutoPush(capitalInfo.getAutoPush());
        vo.setThirdOrderStatus(capitalResult.getThirdOrderStatus());
        return vo;
    }

    @Override
    public OrderExamineShowResultVo orderExamineShow(UserDetail userDetail) {
        CustomerUser customerUser = customerCapitalResultService.checkUser(request);
        Customer customer = customerMapper.getLatestCustomerRecord(customerUser.getPhone());
        List<OrderExamineShowVo> orderExamineShowVos;
        if (customer != null) {
            // 于2022-11-21新增：是否只是app3.0
            String isVersion3 = request.getParameter("isVersion3");
            if ("1".equals(isVersion3)) {// app3.0开启逻辑
                orderExamineShowVos = version3orderExamineShow(customer, customerUser);
            } else {
                orderExamineShowVos = customerCapitalResultMapper.orderExamineShow(customerUser.getId(), customer.getId());
            }
            // 完

            List<OrderExamineShowVo> noAutoPushList = orderExamineShowVos.stream().filter(item -> Objects.equals(item.getAutoPush(), CapitalAutoPushEnum.NOT_ENABLED.getCode())).collect(Collectors.toList());
            List<OrderExamineShowVo> flag = orderExamineShowVos.stream().filter(item -> Objects.equals(item.getAutoPush(), CapitalAutoPushEnum.ENABLE.getCode())).collect(Collectors.toList());
            List<OrderExamineShowVo> yesAutoPushList = new ArrayList<>(1);
            if (!CollectionUtils.isEmpty(flag)) {
                yesAutoPushList.add(flag.get(0));
            }
            OrderExamineShowResultVo resultVo = new OrderExamineShowResultVo();
            resultVo.setNoAutoPushList(noAutoPushList);
            resultVo.setYesAutoPushList(yesAutoPushList);
            //贷超查询
            //List<LoanSupermarket> loanSupermarkets = loanSupermarketMapper.selectList(Wrappers.lambdaQuery(LoanSupermarket.class).eq(LoanSupermarket::getDeleteFlag, 0).eq(LoanSupermarket::getIsTopView, 1).eq(LoanSupermarket::getEnableFlag, 1).orderByDesc(LoanSupermarket::getSerialNumber));
            CustomerUser user = customerUserMapper.selectOne(Wrappers.lambdaQuery(CustomerUser.class).eq(CustomerUser::getPhone, userDetail.getPhone()));
            ChannelInfo channelInfo = channelInfoService.lambdaQuery().eq(ChannelInfo::getCode, user.getSourceChannel()).eq(ChannelInfo::getType, ChannelInfo.TYPE_IMPORT).one();
            List<LoanSupermarketVo> loanSupermarkets = loanSupermarketMapper.getSupermarketListOfChannel(channelInfo.getId());
            resultVo.setLoanSupermarkets(loanSupermarkets);
            return resultVo;
        }
        return null;
    }

    @Override
    public List<CapitalHomePageShowVo> capitalHomePageShow(UserDetail userDetail) {
        CustomerUser customerUser = customerUserMapper.selectOne(new LambdaQueryWrapper<CustomerUser>().eq(CustomerUser::getPhone, userDetail.getPhone()));
        Customer customer = customerMapper.getLatestCustomerRecord(customerUser.getPhone());
        if (customer == null) {
            return new ArrayList<>();
        }
        List<CustomerCapitalResult> list = customerCapitalResultService.list(new LambdaQueryWrapper<CustomerCapitalResult>()
                .eq(CustomerCapitalResult::getCustomerUserId, customerUser.getId())
                .eq(CustomerCapitalResult::getCustomerRecordId, customer.getId())
                .eq(CustomerCapitalResult::getCheckResult, 1));
        if (list == null || list.isEmpty()) {
            return new ArrayList<>();
        }
        List<String> codes = list.stream().map(CustomerCapitalResult::getCapitalInfoCode).collect(Collectors.toList());
        List<CapitalHomePageShowDbVo> capitalHomePageShowDbVos = capitalInfoMapper.capitalHomePageShow(codes);
        if (capitalHomePageShowDbVos == null || capitalHomePageShowDbVos.isEmpty()) {
            return new ArrayList<>();
        }
        CustomerIpInfo customerIpInfo = aliyunUtil.getCustomerIpInfo(request, customer.getPhone());
        ArrayList<CapitalHomePageShowVo> capitalHomePageShowVos = new ArrayList<>();
        log.info("customerIpInfo：{}", customerIpInfo.toString());
        log.info("getSysCityId：{}", customerIpInfo.getSysCityId());
        if (StringUtils.isEmpty(customerIpInfo.getSysCityId())) {
            capitalHomePageShowDbVos.stream().map(item -> {
                CapitalHomePageShowVo capitalHomePageShowVo = new CapitalHomePageShowVo();
                setCapitalHomePageShowVoInit(capitalHomePageShowVo);
                capitalHomePageShowVo.setId(item.getId());
                capitalHomePageShowVo.setName(item.getName());
                capitalHomePageShowVo.setFirstQuota(customerUser.getFirstQuota());
                String pageDisplayType = item.getPageDisplayType();
                String deliveryCity = item.getCityLimit();
                if (StringUtils.isNotEmpty(deliveryCity)) {
                    return item;
                }
                setCapitalHomePageShowVo(capitalHomePageShowVo, pageDisplayType);
                capitalHomePageShowVos.add(capitalHomePageShowVo);
                return item;
            }).collect(Collectors.toList());
        } else {
            City city = cityService.getOne(new LambdaQueryWrapper<City>().eq(City::getCityId, customerIpInfo.getSysCityId()));
            capitalHomePageShowDbVos.stream().map(item -> {
                CapitalHomePageShowVo capitalHomePageShowVo = new CapitalHomePageShowVo();
                capitalHomePageShowVo.setId(item.getId());
                capitalHomePageShowVo.setName(item.getName());
                capitalHomePageShowVo.setFirstQuota(customerUser.getFirstQuota());
                setCapitalHomePageShowVoInit(capitalHomePageShowVo);
                String pageDisplayType = item.getPageDisplayType();
                String deliveryCity = item.getCityLimit();
                log.info("deliveryCity：{}", deliveryCity);
                setCapitalHomePageShowVo(capitalHomePageShowVo, pageDisplayType);
                if (StringUtils.isNotEmpty(deliveryCity) && city != null && StringUtils.isNotEmpty(city.getCityId())) {
                    if (!deliveryCity.contains(city.getCityId()) && !deliveryCity.contains(city.getProvinceId())) {
                        capitalHomePageShowVo.setIsTimeLimit(0);
                        capitalHomePageShowVo.setIsFeatured(0);
                        capitalHomePageShowVo.setIsBankLine(0);
                    }
                }
                capitalHomePageShowVos.add(capitalHomePageShowVo);
                return item;
            }).collect(Collectors.toList());
        }
        return capitalHomePageShowVos;
    }

    @Override
    public List<IsNotificationVo> capitalNotificationShow(UserDetail userDetail) {
        //根据app登录用户的手机号，获取用户信息
        CustomerUser customerUser = customerUserMapper.selectOne(new LambdaQueryWrapper<CustomerUser>().eq(CustomerUser::getPhone, userDetail.getPhone()).eq(CustomerUser::getDeleteFlag, 0));
        //根据app登录用户的手机号获取申请贷款最新一条数据
        Customer customer = customerMapper.getLatestCustomerRecord(customerUser.getPhone());
        if (Objects.isNull(customer)) return null;
        if (Objects.equals(CustomerInfoStatusEnum.BASE_INFO.getCode(), customer.getStatus()) || Objects.isNull(customer.getStatus()))
            return null;
        //获取审批给登录用户和最新的申请贷款的审批列表
        List<CustomerCapitalResult> list = customerCapitalResultMapper.selectList(new LambdaQueryWrapper<CustomerCapitalResult>()
                .eq(CustomerCapitalResult::getCustomerUserId, customerUser.getId())
                .eq(CustomerCapitalResult::getCustomerRecordId, customer.getId())
                .eq(CustomerCapitalResult::getCheckResult, 1));
        if (CollectionUtils.isEmpty(list)) return null;
        //将资方审批列表的数据，以资方代码分组收集
        Map<String, List<CustomerCapitalResult>> capitalResultCollections = list.stream().collect(Collectors.groupingBy(CustomerCapitalResult::getCapitalInfoCode));
        //获取开启了线上贷款和联登的资方列表
        List<CapitalInfo> capitalInfos = capitalInfoMapper.selectList(new LambdaQueryWrapper<CapitalInfo>()
                .eq(CapitalInfo::getFundType, CapitalFundTypeEnum.ONLINE.getCode()).eq(CapitalInfo::getIsCollion, 1)
                .orderByAsc(CapitalInfo::getSeq));
        if (CollectionUtils.isEmpty(capitalInfos)) return null;
        //将资方列表以资方代码分组收集
        Map<String, List<CapitalInfo>> collect = capitalInfos.stream().collect(Collectors.groupingBy(CapitalInfo::getCode));
        List<CapitalInfo> capitalInfos1ist = new ArrayList<>();
        list.forEach(item -> {
            if (Objects.nonNull(item.getCapitalInfoCode()) && Objects.nonNull(collect.get(item.getCapitalInfoCode()))
                    && Objects.nonNull(collect.get(item.getCapitalInfoCode()).get(0))) {
                capitalInfos1ist.add(collect.get(item.getCapitalInfoCode()).get(0));
            }
        });
        if (CollectionUtils.isEmpty(capitalInfos1ist)) return null;
        //排序
        List<CapitalInfo> collectResult = capitalInfos1ist.stream().sorted(Comparator.comparing(CapitalInfo::getSeq)).collect(Collectors.toList());

        IsNotificationVo isNotificationVo = new IsNotificationVo();
        List<IsNotificationVo> isNotificationVos = new ArrayList<>();
        isNotificationVo.setId(collectResult.get(0).getId());
        isNotificationVo.setIsPopUp(collectResult.get(0).getIsPopUp());
//        if (Objects.equals(collectResult.get(0).getIsTopView(), CapitalTopViewEnum.ENABLE.getCode()) && Objects.equals(collectResult.get(0).getCollionMode(), CapitalCollionModeParamEnum.ENABLE.getCode())) {
//            isNotificationVo.setCollionMode(1);
//        } else {
//            isNotificationVo.setCollionMode(0);
//        }
        isNotificationVo.setCollionMode(collectResult.get(0).getCollionMode());
        if (capitalResultCollections != null && capitalResultCollections.get(collectResult.get(0).getCode()) != null
                && capitalResultCollections.get(collectResult.get(0).getCode()).get(0) != null) {
            isNotificationVo.setCapitalResultId((capitalResultCollections.get(collectResult.get(0).getCode()).get(0).getId().toString()));
        }
        isNotificationVos.add(isNotificationVo);
        List<CapitalInfo> returnNotifications = collectResult.stream().filter(i -> i.getIsPopUp() == 1).collect(Collectors.toList());
        if (returnNotifications.size() > 0) {
            if (!returnNotifications.get(0).getId().equals(isNotificationVo.getId())) {
                IsNotificationVo isNotification = new IsNotificationVo();
                isNotification.setId(returnNotifications.get(0).getId());
                isNotification.setIsPopUp(returnNotifications.get(0).getIsPopUp());
//                if (Objects.equals(returnNotifications.get(0).getIsTopView(), CapitalTopViewEnum.ENABLE.getCode()) && Objects.equals(returnNotifications.get(0).getCollionMode(), CapitalCollionModeParamEnum.ENABLE.getCode())) {
//                    isNotificationVo.setCollionMode(1);
//                } else {
//                    isNotificationVo.setCollionMode(0);
//                }
                isNotificationVo.setCollionMode(returnNotifications.get(0).getCollionMode());
                if (capitalResultCollections != null && capitalResultCollections.get(returnNotifications.get(0).getCode()) != null
                        && capitalResultCollections.get(returnNotifications.get(0).getCode()).get(0) != null) {
                    isNotification.setCapitalResultId(capitalResultCollections.get(returnNotifications.get(0).getCode()).get(0).getId().toString());
                }
                isNotificationVos.add(isNotification);
            } else if (returnNotifications.get(0).getId().equals(isNotificationVo.getId()) && returnNotifications.size() > 1) {
                IsNotificationVo isNotification = new IsNotificationVo();
                isNotification.setId(returnNotifications.get(1).getId());
                isNotification.setIsPopUp(returnNotifications.get(1).getIsPopUp());
//                if (Objects.equals(returnNotifications.get(1).getIsTopView(), CapitalTopViewEnum.ENABLE.getCode()) && Objects.equals(returnNotifications.get(1).getCollionMode(), CapitalCollionModeParamEnum.ENABLE.getCode())) {
//                    isNotificationVo.setCollionMode(1);
//                } else {
//                    isNotificationVo.setCollionMode(0);
//                }
                isNotificationVo.setCollionMode(returnNotifications.get(1).getCollionMode());
                if (capitalResultCollections != null && capitalResultCollections.get(returnNotifications.get(1).getCode()) != null
                        && capitalResultCollections.get(returnNotifications.get(1).getCode()).get(0) != null) {
                    isNotification.setCapitalResultId(capitalResultCollections.get(returnNotifications.get(1).getCode()).get(0).getId().toString());
                }
                isNotificationVos.add(isNotification);
            }
        }
        return isNotificationVos;
    }

    @Override
    public List<Object> findOrdinaryApplyData(UserDetail userDetail) {
        //查询该用户申请的贷款
        Customer customer = customerMapper.getLatestCustomerRecord(userDetail.getPhone());

        //拿到资方符合条件的资方信息    第一优先级 联登模式弹窗开关 0 非半流程  1 半流程
        // 1.1）资金类型=线上贷款
        //1.2）自动推送＝启用
        //1.3）联登模式=非半流；
        //1.4）审批通过；
        // 注：这个有撞库
        CapitalInfo first = baseMapper.selectOrdinaryApplyData(customer.getId(), CapitalAutoPushEnum.ENABLE.getCode(), 0, 1);
        //拿到资方符合条件的资方信息    第二优先级 联登模式弹窗开关 0 非半流程  1 半流程
//        2.1）资金类型=线上贷款
//        2.2）自动推送=不启用
//        2.3）联登模式=半流程
        // 注：这个有撞库
        CapitalInfo second = baseMapper.selectOrdinaryApplyData(customer.getId(), CapitalAutoPushEnum.NOT_ENABLED.getCode(), 1, null);
        //拿到贷超符合条件的贷超产品    第三优先级 third
        //List<LoanSupermarket> supermarketList = loanSupermarketMapper.selectList(Wrappers.lambdaQuery(LoanSupermarket.class).eq(LoanSupermarket::getOrdinarySwitch, 1).eq(LoanSupermarket::getEnableFlag, 1).orderByDesc(LoanSupermarket::getSerialNumber));
        LoanSupermarketVo third = null;
        CustomerUser user = customerUserMapper.selectOne(Wrappers.lambdaQuery(CustomerUser.class).eq(CustomerUser::getPhone, userDetail.getPhone()));
        ChannelInfo channelInfo = channelInfoService.lambdaQuery().eq(ChannelInfo::getCode, user.getSourceChannel()).eq(ChannelInfo::getType, ChannelInfo.TYPE_IMPORT).one();
        // 获取到对应的贷款超市
        List<LoanSupermarketVo> loanSupermarkets = loanSupermarketMapper.findOrdinaryApplyData(channelInfo.getId());
        if (!loanSupermarkets.isEmpty()) {
            third = loanSupermarkets.get(0);
//            if (first != null)
//            third.setCompany(channelInfo.getCo);
        }

        List<Object> result = new ArrayList<>();
        result.add(first);
        result.add(second);
        result.add(third);

        // 新增 第0优先级 2023-12-18，银行直贷
        // 先从非虚拟库中获取，没有再从虚拟库获取
        CapitalInfo zeroCapital = zero(customer, false);
        if (zeroCapital == null) {
            zeroCapital = zero(customer, true);
            if (zeroCapital != null) {
                result.add(zeroCapital);
            }
        } else {
            result.add(zeroCapital);
        }

//        List<CapitalInfo> fours = baseMapper.zeroPriorityVm(customer.getId());
//        if (fours != null && fours.size() > 0 && StringUtils.isNotBlank(customer.getCity())) {
//            for (CapitalInfo capitalInfo : fours) {
//                if (StringUtils.isNotBlank(capitalInfo.getCityLimit())) {
//                    String cityId = customer.getCity();
//                    City city = cityService.lambdaQuery().eq(City::getCityId, cityId).one();
//                    String deliveryCity = capitalInfo.getCityLimit();
//                    String provinceId = city.getProvinceId();
//                    if (!deliveryCity.contains(cityId) && !deliveryCity.equals(provinceId)
//                            && !deliveryCity.contains("," + provinceId + ",")
//                            && !deliveryCity.endsWith("," + provinceId)
//                            && !deliveryCity.contains(provinceId + ",")) {
//                        continue;
//                    }
//                    result.add(capitalInfo);
//                    break;
//                }
//            }
//        }

//        // 新增 第0优先级 2023-12-18，银行直贷
//        // 若居住省份不为空
//        // 注：这个也需要撞库
//        String liveProvince = customer.getLiveProvince();
//        if (StringUtils.isNotBlank(liveProvince)) {
//
//            // 获取省份ID
//            LambdaQueryWrapper<Province> wrapper = new LambdaQueryWrapper<>();
//            wrapper.eq(Province::getName, liveProvince);
//            Province pro = provinceMapper.selectOne(wrapper);
//            if (BeanUtil.isNotEmpty(pro)) {
//                String proId = pro.getProvinceId();
//
//                List<CapitalInfo> fours = baseMapper.zeroPriority(customer.getId());
//                if (fours != null && fours.size() > 0 && StringUtils.isNotBlank(proId)) {
//                    for (CapitalInfo info : fours) {
//                        String cityLimit = info.getCityLimit();
//                        if (StringUtils.isNotBlank(cityLimit)) {
//                            if (cityLimit.contains(proId)) {// 若包含
//                                result.add(info);
//                                break;
//                            }
//                        }
//                    }
//                }
//            }
//        }

        // 第0优先级 完
        return result;
    }

    /**
     * 第0优先级 2023-12-18，银行直贷
     * @param isZeroVm 是否从虚拟撞库中获取
     * @return
     */
    private CapitalInfo zero(Customer customer, boolean isZeroVm) {
        CapitalInfo capital = null;
        // 若居住城市不为空
        // 注：这个也需要撞库
        List<CapitalInfo> fours = isZeroVm ? baseMapper.zeroPriorityVm(customer.getId()) : baseMapper.zeroPriority(customer.getId());
        if (fours != null && fours.size() > 0) {
            for (CapitalInfo capitalInfo : fours) {
                if (capitalInfo.getId().intValue() == 36 || capitalInfo.getId().intValue() == 41 || capitalInfo.getId().intValue() == 22) {// 随易花或好汇推
                    // 查找该用户还有就是该capitalId下的有没有第三方平台推送过来的机构，有的话，替换机构logo，公司名称和产品名称
                    PlatformCapital pc = changeCapitalInfo(customer, capitalInfo);
                    if (Objects.isNull(pc)) {
                        capitalInfo = null;
                    }
                    capital = capitalInfo;
                    break;
                }
                if (StringUtils.isNotBlank(capitalInfo.getCityLimit()) && StringUtils.isNotBlank(customer.getCity())) {
                    String cityId = customer.getCity();
                    City city = cityService.lambdaQuery().eq(City::getCityId, cityId).one();
                    String deliveryCity = capitalInfo.getCityLimit();
                    String provinceId = city.getProvinceId();
                    if (!deliveryCity.contains(cityId) && !deliveryCity.equals(provinceId)
                            && !deliveryCity.contains("," + provinceId + ",")
                            && !deliveryCity.endsWith("," + provinceId)
                            && !deliveryCity.contains(provinceId + ",")) {
                        continue;
                    }
                    // 查找该用户还有就是该capitalId下的有没有第三方平台推送过来的机构，有的话，替换机构logo，公司名称和产品名称
//                    changeCapitalInfo(customer, capitalInfo);
                    capital = capitalInfo;
                    break;
                }
            }
        }
        return capital;
    }


    /**
     * 获取虚拟撞库资方列表
     */
    @Override
    public List<Object> findVmOrdinaryApplyData(UserDetail userDetail) {
        //查询该用户申请的贷款
        Customer customer = customerMapper.getLatestCustomerRecord(userDetail.getPhone());
        List<Object> result = new ArrayList<>();
        // 新增 第0优先级 2023-12-18，银行直贷
        // 若居住城市不为空
        // 注：这个也需要撞库
        /*List<CapitalInfo> fours = baseMapper.zeroPriorityVm(customer.getId());
        if (fours != null && fours.size() > 0) {
            for (CapitalInfo capitalInfo : fours) {
                if (StringUtils.isNotBlank(capitalInfo.getCityLimit())) {
                    String cityId = customer.getCity();
                    City city = cityService.lambdaQuery().eq(City::getCityId, cityId).one();
                    String deliveryCity = capitalInfo.getCityLimit();
                    String provinceId = city.getProvinceId();
                    if (!deliveryCity.contains(cityId) && !deliveryCity.equals(provinceId)
                            && !deliveryCity.contains("," + provinceId + ",")
                            && !deliveryCity.endsWith("," + provinceId)
                            && !deliveryCity.contains(provinceId + ",")) {
                        continue;
                    }
                    // 查找该用户还有就是该capitalId下的有没有第三方平台推送过来的机构，有的话，替换机构logo，公司名称和产品名称
                    changeCapitalInfo(customer, capitalInfo);
                    result.add(capitalInfo);
                    break;
                } else {
                    // 查找该用户还有就是该capitalId下的有没有第三方平台推送过来的机构，有的话，替换机构logo，公司名称和产品名称
                    changeCapitalInfo(customer, capitalInfo);
                    result.add(capitalInfo);
                    break;
                }
            }
        }*/
        CapitalInfo zeroCapital = zero(customer, true);

//        String liveProvince = customer.getLiveProvince();
//        if (StringUtils.isNotBlank(liveProvince)) {
//
//            // 获取省份ID
//            LambdaQueryWrapper<Province> wrapper = new LambdaQueryWrapper<>();
//            wrapper.eq(Province::getName, liveProvince);
//            Province pro = provinceMapper.selectOne(wrapper);
//            if (BeanUtil.isNotEmpty(pro)) {
//                String proId = pro.getProvinceId();
//
//                List<CapitalInfo> fours = baseMapper.zeroPriority(customer.getId());
//                if (fours != null && fours.size() > 0 && StringUtils.isNotBlank(proId)) {
//                    for (CapitalInfo info : fours) {
//                        String cityLimit = info.getCityLimit();
//                        if (StringUtils.isNotBlank(cityLimit)) {
//                            if (cityLimit.contains(proId)) {// 若包含
//                                result.add(info);
//                                break;
//                            }
//                        }
//                    }
//                }
//            }
//        }

        //拿到资方符合条件的资方信息    第一优先级 联登模式弹窗开关 0 非半流程  1 半流程
        // 1.1）资金类型=线上贷款
        //1.2）自动推送＝启用
        //1.3）联登模式=非半流；
        //1.4）审批通过；
        // 注：这个有撞库
        if (zeroCapital != null) {
            result.add(zeroCapital);
            result.add(null);
            result.add(null);
            result.add(null);
            return result;
        }
        CapitalInfo first = baseMapper.selectOrdinaryApplyDataVm(customer.getId(), CapitalAutoPushEnum.ENABLE.getCode(), 0, 1);
        if (first != null) {
            result.add(null);
            result.add(first);
            result.add(null);
            result.add(null);
            return result;
        }
        //拿到资方符合条件的资方信息    第二优先级 联登模式弹窗开关 0 非半流程  1 半流程
//        2.1）资金类型=线上贷款
//        2.2）自动推送=不启用
//        2.3）联登模式=半流程
        // 注：这个有撞库
        CapitalInfo second = baseMapper.selectOrdinaryApplyDataVm(customer.getId(), CapitalAutoPushEnum.NOT_ENABLED.getCode(), 1, null);
        if (second != null) {
            result.add(null);
            result.add(null);
            result.add(second);
            result.add(null);
            return result;
        }
        //拿到贷超符合条件的贷超产品    第三优先级 third
        //List<LoanSupermarket> supermarketList = loanSupermarketMapper.selectList(Wrappers.lambdaQuery(LoanSupermarket.class).eq(LoanSupermarket::getOrdinarySwitch, 1).eq(LoanSupermarket::getEnableFlag, 1).orderByDesc(LoanSupermarket::getSerialNumber));
        LoanSupermarketVo third = null;

        CustomerUser user = customerUserMapper.selectOne(Wrappers.lambdaQuery(CustomerUser.class).eq(CustomerUser::getPhone, userDetail.getPhone()));
        ChannelInfo channelInfo = channelInfoService.lambdaQuery().eq(ChannelInfo::getCode, user.getSourceChannel()).eq(ChannelInfo::getType, ChannelInfo.TYPE_IMPORT).one();
        // 获取到对应的贷款超市
        List<LoanSupermarketVo> loanSupermarkets = loanSupermarketMapper.findOrdinaryApplyData(channelInfo.getId());
        if (!loanSupermarkets.isEmpty()) {
            third = loanSupermarkets.get(0);
//            if (first != null)
//            third.setCompany(channelInfo.getCo);
        }
        result.add(null);
        result.add(null);
        result.add(null);
        result.add(third);
        return result;
    }

    /**
     * 银行直贷推送是否成功
     */
    @Override
    public Boolean pushIsSucc(HttpServletRequest request, Long capitalId) {
        String token = request.getHeader("Authorization");
        if (StringUtils.isBlank(token)) {
            throw new CommonException("用户Token为空！");
        }
        UserDetail user = UserUtil.getUser(token);
        if (Objects.isNull(user)) {
            throw new CommonException("用户Token无效！");
        }
        String phone = user.getPhone();
        if (StringUtils.isBlank(phone)) {
            throw new CommonException("用户Token无效！");
        }
        Customer customer = customerMapper.getLatestCustomerRecord(user.getPhone());
        if (Objects.isNull(user)) {
            throw new CommonException("用户不存在！");
        }
        LambdaQueryWrapper<PlatformCapital> wrapper = new LambdaQueryWrapper<>();
        wrapper.eq(PlatformCapital::getCustomerId, customer.getId());
        wrapper.eq(PlatformCapital::getCapitalId, capitalId);
        wrapper.last(" limit 1 ");
        PlatformCapital pc = platformCapitalService.getOne(wrapper);
        if (Objects.isNull(pc)) {
            return false;
        }
        return true;
    }

    @Override
    public List<PlatformCapital> findPlatformCapital(UserDetail userDetail) {
        String phone = userDetail.getPhone();
        if (StringUtils.isBlank(phone)) {
            throw new CommonException("用户Token无效！");
        }

        Customer customer = customerMapper.getLatestCustomerRecord(phone);
        if (Objects.isNull(customer)) {
            throw new CommonException("用户不存在！");
        }

        LambdaQueryWrapper<PlatformCapital> wr = new LambdaQueryWrapper<>();
        wr.eq(PlatformCapital::getCustomerId, customer.getId());
        wr.last(" limit 3 "); // 限制3条记录

        List<PlatformCapital> list = platformCapitalService.list(wr);
        return list;
    }

    @Override
    public List<Object> findAppOrdinaryApplyData(UserDetail userDetail) {
        //查询该用户申请的贷款
        Customer customer = customerMapper.getLatestCustomerRecord(userDetail.getPhone());

        //拿到资方符合条件的资方信息    第一优先级 联登模式弹窗开关 0 非半流程  1 半流程
        // 1.1）资金类型=线上贷款
        //1.2）自动推送＝启用
        //1.3）联登模式=非半流；
        //1.4）审批通过；
        // 注：这个有撞库
        CapitalInfo first = baseMapper.selectOrdinaryApplyData(customer.getId(), CapitalAutoPushEnum.ENABLE.getCode(), 0, 1);
        //拿到资方符合条件的资方信息    第二优先级 联登模式弹窗开关 0 非半流程  1 半流程
//        2.1）资金类型=线上贷款
//        2.2）自动推送=不启用
//        2.3）联登模式=半流程
        // 注：这个有撞库
        CapitalInfo second = baseMapper.selectOrdinaryApplyData(customer.getId(), CapitalAutoPushEnum.NOT_ENABLED.getCode(), 1, null);
        //拿到贷超符合条件的贷超产品    第三优先级 third
        //List<LoanSupermarket> supermarketList = loanSupermarketMapper.selectList(Wrappers.lambdaQuery(LoanSupermarket.class).eq(LoanSupermarket::getOrdinarySwitch, 1).eq(LoanSupermarket::getEnableFlag, 1).orderByDesc(LoanSupermarket::getSerialNumber));
        LoanSupermarketVo third = null;
        CustomerUser user = customerUserMapper.selectOne(Wrappers.lambdaQuery(CustomerUser.class).eq(CustomerUser::getPhone, userDetail.getPhone()));
        ChannelInfo channelInfo = channelInfoService.lambdaQuery().eq(ChannelInfo::getCode, user.getSourceChannel()).eq(ChannelInfo::getType, ChannelInfo.TYPE_IMPORT).one();
        // 获取到对应的贷款超市
        List<LoanSupermarketVo> loanSupermarkets = loanSupermarketMapper.findOrdinaryApplyData(channelInfo.getId());
        if (!loanSupermarkets.isEmpty()) {
            third = loanSupermarkets.get(0);
        }

        List<Object> result = new ArrayList<>();
        result.add(first);
        result.add(second);
        result.add(third);
        return result;
    }

    private PlatformCapital changeCapitalInfo(Customer customer, CapitalInfo capitalInfo) {
        LambdaQueryWrapper<PlatformCapital> wrapper = new LambdaQueryWrapper<>();
        wrapper.eq(PlatformCapital::getCustomerId, customer.getId());
        wrapper.eq(PlatformCapital::getCapitalId, capitalInfo.getId());
        wrapper.last(" limit 1 ");
        PlatformCapital pc = platformCapitalService.getOne(wrapper);
        if (Objects.isNull(pc)) {
            return pc;
        }
        capitalInfo.setCompany(pc.getCompanyName());
        capitalInfo.setName(pc.getProductName());
        capitalInfo.setIconUrl(pc.getLogoUrl());
        capitalInfo.setChannelIds(String.valueOf(pc.getId()));
        return pc;
    }

    public void setCapitalHomePageShowVoInit(CapitalHomePageShowVo capitalHomePageShowVo) {
        capitalHomePageShowVo.setIsTimeLimit(0);
        capitalHomePageShowVo.setIsFeatured(0);
        capitalHomePageShowVo.setIsBankLine(0);
    }

    public void setCapitalHomePageShowVo(CapitalHomePageShowVo capitalHomePageShowVo, String pageDisplayType) {
        if (StringUtils.isNotEmpty(pageDisplayType) && pageDisplayType.contains(CapitalShowPageTypeEnum.TIME_LIMIT.getCode())) {
            capitalHomePageShowVo.setIsTimeLimit(1);
        }
        if (StringUtils.isNotEmpty(pageDisplayType) && pageDisplayType.contains(CapitalShowPageTypeEnum.FEATURED.getCode())) {
            capitalHomePageShowVo.setIsFeatured(1);
        }
        if (StringUtils.isNotEmpty(pageDisplayType) && pageDisplayType.contains(CapitalShowPageTypeEnum.BANK_LINE.getCode())) {
            capitalHomePageShowVo.setIsBankLine(1);
        }
    }
}