package com.nova.sankuai.service.impl;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.nova.sankuai.domain.api.doudouqian.*;
|
import com.nova.sankuai.domain.dto.DdqBindCardDto;
|
import com.nova.sankuai.domain.entity.CapitalInfo;
|
import com.nova.sankuai.domain.entity.Customer;
|
import com.nova.sankuai.domain.entity.CustomerCapitalResult;
|
import com.nova.sankuai.domain.entity.CustomerUser;
|
import com.nova.sankuai.domain.enums.capitalInfo.CapitalApprovalResultEnum;
|
import com.nova.sankuai.domain.enums.capitalInfo.CapitalInfoTypeCodeEnum;
|
import com.nova.sankuai.domain.vo.DdqBindCardVo;
|
import com.nova.sankuai.domain.vo.DdqPopupVo;
|
import com.nova.sankuai.domain.vo.DdqSupportBankVo;
|
import com.nova.sankuai.infra.config.CommonException;
|
import com.nova.sankuai.infra.mapper.CapitalInfoMapper;
|
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.MessageSendUtil;
|
import com.nova.sankuai.service.ICapitalResultCommonService;
|
import com.nova.sankuai.service.IDouDouQianService;
|
import lombok.AllArgsConstructor;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.stereotype.Service;
|
|
import javax.servlet.http.HttpServletRequest;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Objects;
|
|
/**
|
* @author weikangdi
|
* @create 2022/7/28
|
*/
|
@Service
|
@AllArgsConstructor
|
public class DouDouQianServiceImpl implements IDouDouQianService {
|
|
private final DdqUtil ddqUtil;
|
|
private final CustomerMapper customerMapper;
|
|
private final ICapitalResultCommonService capitalResultCommonService;
|
|
private final CustomerCapitalResultMapper capitalResultMapper;
|
|
private final CustomerUserMapper customerUserMapper;
|
|
private final CapitalInfoMapper capitalInfoMapper;
|
|
private final MessageSendUtil messageSendUtil;
|
|
private static final Logger log = LoggerFactory.getLogger("capitalLogger");
|
|
@Override
|
public List<DdqSupportBankVo> getSupportBankList(HttpServletRequest request) {
|
List<DdqSupportBankVo> result = new ArrayList<>();
|
CustomerUser customerUser = capitalResultCommonService.checkUser(request);
|
BankListVo bankList = ddqUtil.getBankList(customerUser.getPhone());
|
if (bankList != null) {
|
for (BankListVo.BackVo bank : bankList.getBanks()) {
|
DdqSupportBankVo supportBankVo = new DdqSupportBankVo();
|
supportBankVo.setBankCode(bank.getBankAbbr());
|
supportBankVo.setBankName(bank.getBankName());
|
result.add(supportBankVo);
|
}
|
return result;
|
}
|
throw new CommonException("获取支持银行卡列表失败");
|
}
|
|
@Override
|
public DdqBindCardVo bindCardByDDQ(DdqBindCardDto bindCardDto, HttpServletRequest request) {
|
Customer customer = customerMapper.getLatestCustomerRecord(bindCardDto.getPhone());
|
if (customer == null) {
|
throw new CommonException("申请记录不存在");
|
}
|
BankCardCheckVo checkVo = ddqUtil.bankCardCheck(bindCardDto);
|
if (checkVo != null) {
|
customerMapper.update(null, Wrappers.<Customer>lambdaUpdate()
|
.set(Customer::getCardNo, bindCardDto.getCardNo())
|
.set(Customer::getBankName, bindCardDto.getBankName())
|
.set(Customer::getBankCode, bindCardDto.getBankCode())
|
.set(Customer::getBankPhoneNo, bindCardDto.getBankPhoneNo())
|
.set(Customer::getBankCardName, bindCardDto.getBankCardName())
|
.eq(Customer::getId, customer.getId()));
|
DdqBindCardVo bindCardVo = new DdqBindCardVo();
|
if (BankCardCheckVo.NEED_VERIFY_CODE.equals(checkVo.getNeedVerify())) {
|
bindCardVo.setNeedVerify(true);
|
return bindCardVo;
|
} else if (BankCardCheckVo.NOT_NEED_VERIFY_CODE.equals(checkVo.getNeedVerify())) {
|
CustomerUser customerUser = capitalResultCommonService.checkUser(request);
|
capitalResultMapper.update(null, Wrappers.<CustomerCapitalResult>lambdaUpdate()
|
.set(CustomerCapitalResult::getHasBindCard, 1)
|
.set(CustomerCapitalResult::getBankName, bindCardDto.getBankName())
|
.set(CustomerCapitalResult::getBankCardNo, bindCardDto.getCardNo())
|
.set(CustomerCapitalResult::getBankCode, bindCardDto.getBankCode())
|
.set(CustomerCapitalResult::getBankPhoneNo, bindCardDto.getBankPhoneNo())
|
.set(CustomerCapitalResult::getBankCardName, bindCardDto.getBankCardName())
|
.eq(CustomerCapitalResult::getCustomerUserId, customerUser.getId())
|
.eq(CustomerCapitalResult::getCustomerRecordId, customer.getId())
|
.eq(CustomerCapitalResult::getCapitalInfoCode, CapitalInfoTypeCodeEnum.DOU_DOU_QIAN.getCode()));
|
bindCardVo.setNeedVerify(false);
|
return bindCardVo;
|
}
|
}
|
throw new CommonException("银行卡绑定异常");
|
}
|
|
@Override
|
public boolean bindCardConfirmByDDQ(DdqBindCardDto bindCardDto, HttpServletRequest request) {
|
Customer customer = customerMapper.getLatestCustomerRecord(bindCardDto.getPhone());
|
if (customer == null) {
|
throw new CommonException("申请记录不存在");
|
}
|
BindCardVo bindCardVo = ddqUtil.bindCard(bindCardDto);
|
if (bindCardVo != null) {
|
CustomerUser customerUser = capitalResultCommonService.checkUser(request);
|
capitalResultMapper.update(null, Wrappers.<CustomerCapitalResult>lambdaUpdate()
|
.set(CustomerCapitalResult::getHasBindCard, 1)
|
.set(CustomerCapitalResult::getBankName, bindCardDto.getBankName())
|
.set(CustomerCapitalResult::getBankCardNo, bindCardDto.getCardNo())
|
.set(CustomerCapitalResult::getBankCode, bindCardDto.getBankCode())
|
.set(CustomerCapitalResult::getBankPhoneNo, bindCardDto.getBankPhoneNo())
|
.set(CustomerCapitalResult::getBankCardName, bindCardDto.getBankCardName())
|
.eq(CustomerCapitalResult::getCustomerUserId, customerUser.getId())
|
.eq(CustomerCapitalResult::getCustomerRecordId, customer.getId())
|
.eq(CustomerCapitalResult::getCapitalInfoCode, CapitalInfoTypeCodeEnum.DOU_DOU_QIAN.getCode()));
|
return true;
|
}
|
return false;
|
}
|
|
@Override
|
public boolean bindCard(DdqBindCardDto bindCardDto, HttpServletRequest request) {
|
Customer customer = customerMapper.getLatestCustomerRecord(bindCardDto.getPhone());
|
if (customer == null) {
|
throw new CommonException("申请记录不存在");
|
}
|
CustomerUser customerUser = capitalResultCommonService.checkUser(request);
|
capitalResultMapper.update(null, Wrappers.<CustomerCapitalResult>lambdaUpdate()
|
.set(CustomerCapitalResult::getHasBindCard, 1)
|
.set(CustomerCapitalResult::getBankName, bindCardDto.getBankName())
|
.set(CustomerCapitalResult::getBankCardNo, bindCardDto.getCardNo())
|
.set(CustomerCapitalResult::getBankCode, bindCardDto.getBankCode())
|
.set(CustomerCapitalResult::getBankPhoneNo, bindCardDto.getBankPhoneNo())
|
.set(CustomerCapitalResult::getBankCardName, bindCardDto.getBankCardName())
|
.eq(CustomerCapitalResult::getCustomerUserId, customerUser.getId())
|
.eq(CustomerCapitalResult::getCustomerRecordId, customer.getId())
|
.eq(CustomerCapitalResult::getCapitalInfoCode, CapitalInfoTypeCodeEnum.DOU_DOU_QIAN.getCode()));
|
return true;
|
}
|
|
@Override
|
public String pushAuditResult(String param, String logNumber) {
|
JSONObject response = new JSONObject();
|
try {
|
String request = ddqUtil.parseRequest(param);
|
log.info("日志编号：" + logNumber + "豆豆钱授信结果回调解密参数 -> {}", request);
|
AuditResultVo auditResultVo = JSON.parseObject(request, AuditResultVo.class);
|
if (auditResultVo != null) {
|
AuditResultDetailVo auditResultDetailVo = JSON.parseObject(auditResultVo.getData(), AuditResultDetailVo.class);
|
CustomerUser customerUser = customerUserMapper.selectOne(Wrappers.<CustomerUser>lambdaQuery()
|
.eq(CustomerUser::getPhone, auditResultVo.getMobile()));
|
if (customerUser == null) {
|
throw new CommonException("用户不存在");
|
}
|
Customer customer = customerMapper.getLatestCustomerRecord(auditResultVo.getMobile());
|
if (customer == null) {
|
throw new CommonException("申请记录不存在");
|
}
|
CustomerCapitalResult capitalResult = capitalResultMapper.selectOne(Wrappers.<CustomerCapitalResult>lambdaQuery()
|
.eq(CustomerCapitalResult::getCustomerUserId, customerUser.getId())
|
.eq(CustomerCapitalResult::getCustomerRecordId, customer.getId())
|
.eq(CustomerCapitalResult::getCapitalInfoCode, CapitalInfoTypeCodeEnum.DOU_DOU_QIAN.getCode()));
|
if (capitalResult == null) {
|
throw new CommonException("授信记录不存在");
|
}
|
CapitalInfo capitalInfo = capitalInfoMapper.selectById(capitalResult.getCapitalInfoId());
|
if (capitalInfo == null) {
|
throw new CommonException("对接产品不存在");
|
}
|
if (CapitalApprovalResultEnum.APPROVAL_WAIT.getCode().equals(capitalResult.getApprovalResult())) {
|
if (AuditResultDetailVo.STATUS_SUCCESS.equals(auditResultDetailVo.getStatus())) {
|
capitalResultMapper.update(null, Wrappers.<CustomerCapitalResult>lambdaUpdate()
|
.set(CustomerCapitalResult::getTotalCredit, auditResultDetailVo.getApprovalAmount())
|
.set(CustomerCapitalResult::getApprovalResult, CapitalApprovalResultEnum.APPROVAL_SUCCESS.getCode())
|
.set(CustomerCapitalResult::getCreditApplyTime, auditResultDetailVo.getProcessTime())
|
.set(CustomerCapitalResult::getLastUpdatedDate, new Date())
|
.set(CustomerCapitalResult::getPopupDdq, 0)
|
.set(CustomerCapitalResult::getPeriods, auditResultDetailVo.getApprovalTerm())
|
.eq(CustomerCapitalResult::getId, capitalResult.getId()));
|
//授信通过后给用户发送短信
|
try {
|
String content = String.format("【%s】恭喜您，您的授信已通过，额度%s元。请尽快登录APP使用额度，避免额度过期",
|
capitalInfo.getName(),
|
auditResultDetailVo.getApprovalAmount());
|
messageSendUtil.sendMessage(auditResultVo.getMobile(), content);
|
log.info("日志编号：" + logNumber + "手机号" + auditResultVo.getMobile() + "豆豆钱授信通知短信已发送");
|
} catch (Exception e) {
|
log.error("豆豆钱授信通过后给用户发送短信异常", e);
|
}
|
} else if (AuditResultDetailVo.STATUS_FAIL.equals(auditResultDetailVo.getStatus())) {
|
capitalResultMapper.update(null, Wrappers.<CustomerCapitalResult>lambdaUpdate()
|
.set(CustomerCapitalResult::getApprovalResult, CapitalApprovalResultEnum.APPROVAL_REFUSE.getCode())
|
.set(CustomerCapitalResult::getCreditApplyTime, auditResultDetailVo.getProcessTime())
|
.eq(CustomerCapitalResult::getId, capitalResult.getId()));
|
}
|
}
|
response.put("status", DdqResponse.STATUS_SUCCESS);
|
return response.toJSONString();
|
}
|
} catch (CommonException e) {
|
log.error("豆豆钱授信结果回调失败:" + e.getCode());
|
response.put("msg", e.getCode());
|
} catch (Exception e) {
|
log.error("豆豆钱授信结果回调失败:", e);
|
response.put("msg", "解密失败");
|
}
|
response.put("status", DdqResponse.STATUS_REQUEST_EXCEPTION);
|
return response.toJSONString();
|
}
|
|
@Override
|
public DdqPopupVo getPopupByDdq(HttpServletRequest request) {
|
DdqPopupVo ddqPopupVo = new DdqPopupVo();
|
ddqPopupVo.setIsPopUp(0);
|
CustomerUser customerUser = capitalResultCommonService.checkUser(request);
|
if (customerUser == null) {
|
throw new CommonException("用户不存在");
|
}
|
Customer customer = customerMapper.getLatestCustomerRecord(customerUser.getPhone());
|
if (customer != null) {
|
/*CustomerCapitalResult capitalResult = capitalResultMapper.selectOne(Wrappers.<CustomerCapitalResult>lambdaQuery()
|
.eq(CustomerCapitalResult::getCustomerUserId, customerUser.getId())
|
.eq(CustomerCapitalResult::getCustomerRecordId, customer.getId())
|
.eq(CustomerCapitalResult::getApprovalResult, CapitalApprovalResultEnum.APPROVAL_SUCCESS.getCode())
|
.eq(CustomerCapitalResult::getPopupDdq, 0)
|
.eq(CustomerCapitalResult::getCapitalInfoCode, CapitalInfoTypeCodeEnum.DOU_DOU_QIAN.getCode()));*/
|
CustomerCapitalResult capitalResult = null;
|
List<Integer> popupDdq = new ArrayList<>();
|
popupDdq.add(0);
|
popupDdq.add(1);
|
List<CustomerCapitalResult> list = capitalResultMapper.selectList(Wrappers.<CustomerCapitalResult>lambdaQuery()
|
.eq(CustomerCapitalResult::getCustomerUserId, customerUser.getId())
|
.eq(CustomerCapitalResult::getCustomerRecordId, customer.getId())
|
.in(CustomerCapitalResult::getPopupDdq, popupDdq));
|
// 根据获取到的capitalId来排序
|
if (list != null) {
|
// 若是只有一个，则不进行排序等操作
|
if (list.size() == 1) {
|
capitalResult = list.get(0);
|
// 判断popupDdq是否为1，为1的话，遇把capitalResult赋值为空
|
if (1 == capitalResult.getPopupDdq()) {
|
capitalResult = null;
|
}
|
} else {
|
List<Long> crList = new ArrayList();
|
// 判断是否已弹出两个
|
int limitCheck = 0;
|
for (CustomerCapitalResult cr : list) {
|
Integer pd = cr.getPopupDdq();
|
if (Objects.isNull(pd)) {
|
continue;
|
}
|
if (pd == 1) {
|
limitCheck++;
|
}
|
}
|
|
if (limitCheck >= 2) {
|
return ddqPopupVo;
|
}
|
|
for (CustomerCapitalResult cr : list) {
|
Long capitalInfoId = cr.getCapitalInfoId();
|
if (!Objects.isNull(capitalInfoId) && 0 == cr.getPopupDdq().intValue()) {
|
crList.add(capitalInfoId);
|
}
|
}
|
if (crList != null && crList.size() > 0) {
|
List<CapitalInfo> capitalInfos = capitalInfoMapper.selectList(Wrappers.<CapitalInfo>lambdaQuery()
|
.in(CapitalInfo::getId, crList)
|
.orderByAsc(CapitalInfo::getSeq)
|
);
|
if (capitalInfos != null && capitalInfos.size() > 0) {
|
List<CustomerCapitalResult> result = new ArrayList();
|
for (CapitalInfo ci : capitalInfos) {
|
if (result != null && result.size() >= 2) {
|
break;
|
}
|
for (CustomerCapitalResult ccr : list) {
|
Long infoId = ccr.getCapitalInfoId();
|
if (Objects.isNull(infoId)) {
|
continue;
|
}
|
if (ci.getId().intValue() == infoId.intValue()) {
|
result.add(ccr);
|
break;
|
}
|
}
|
}
|
if (result != null && result.size() > 0) {
|
capitalResult = result.get(0);
|
}
|
}
|
}
|
}
|
|
}
|
|
if (capitalResult != null) {
|
ddqPopupVo.setIsPopUp(1);
|
ddqPopupVo.setCapitalResultId(capitalResult.getId());
|
ddqPopupVo.setId(capitalResult.getCapitalInfoId());
|
ddqPopupVo.setUrl(capitalResult.getNotificationUrl());
|
capitalResultMapper.update(null, Wrappers.<CustomerCapitalResult>lambdaUpdate()
|
.set(CustomerCapitalResult::getPopupDdq, 1)
|
.eq(CustomerCapitalResult::getId, capitalResult.getId()));
|
}
|
}
|
return ddqPopupVo;
|
}
|
}
|
