package com.nova.sankuai.service.impl;
|
|
import cn.hutool.core.util.IdUtil;
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.nova.sankuai.domain.api.hengyidai.HySignUtil;
|
import com.nova.sankuai.domain.api.hengyidai.HyUtil;
|
import com.nova.sankuai.domain.api.hengyidai.callback.HyPushLoanStatusDto;
|
import com.nova.sankuai.domain.api.hengyidai.callback.HyPushRepayDto;
|
import com.nova.sankuai.domain.api.hengyidai.callback.HyPushRepayPlanDto;
|
import com.nova.sankuai.domain.api.hengyidai.dto.HyConfirmDto;
|
import com.nova.sankuai.domain.api.hengyidai.dto.HyGetContractsDto;
|
import com.nova.sankuai.domain.api.hengyidai.dto.HyGetRepayUrlDto;
|
import com.nova.sankuai.domain.api.hengyidai.dto.HyGetSignUrlDto;
|
import com.nova.sankuai.domain.api.hengyidai.response.*;
|
import com.nova.sankuai.domain.dto.capitalflow.*;
|
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.CustomerUserBusinessTypeEnum;
|
import com.nova.sankuai.domain.enums.capitalInfo.CapitalApprovalResultEnum;
|
import com.nova.sankuai.domain.enums.capitalInfo.CapitalResultSourceCodeEnum;
|
import com.nova.sankuai.domain.enums.capitalInfo.CapitalResultStatusEnum;
|
import com.nova.sankuai.domain.enums.customerinfo.UseOfLoanEnum;
|
import com.nova.sankuai.domain.enums.yixin.YiXinHomeRelationEnum;
|
import com.nova.sankuai.domain.vo.capitalflow.*;
|
import com.nova.sankuai.domain.vo.capitalresult.HengYiDaiPushResultVo;
|
import com.nova.sankuai.infra.config.CommonException;
|
import com.nova.sankuai.infra.constants.ResultCode;
|
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.ConstantsUtil;
|
import com.nova.sankuai.infra.utils.ResultJson;
|
import com.nova.sankuai.service.ICapitalResultCommonService;
|
import com.nova.sankuai.service.IHengYiDaiService;
|
import lombok.AllArgsConstructor;
|
import org.apache.http.util.TextUtils;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.util.DigestUtils;
|
|
import java.util.*;
|
|
@Service
|
@AllArgsConstructor
|
public class HengYiDaiServiceImpl implements IHengYiDaiService {
|
|
private final HySignUtil hySignUtil;
|
|
private final HyUtil hyUtil;
|
|
private final ICapitalResultCommonService capitalResultCommonService;
|
|
private final CustomerCapitalResultMapper capitalResultMapper;
|
|
private final CustomerMapper customerMapper;
|
|
private final CustomerUserMapper customerUserMapper;
|
|
private static final Logger log = LoggerFactory.getLogger("capitalLogger");
|
|
@Override
|
public String pushAuditResult(String param, String logNumber) {
|
JSONObject object = new JSONObject();
|
try {
|
if (!TextUtils.isEmpty(param)) {
|
Map<String, Object> map = hySignUtil.parseRequest(param);
|
log.info("日志编号：" + logNumber + "审核结果回调接口:{}", map.toString());
|
if (!TextUtils.isEmpty(map.get("data").toString())) {
|
HyGetAuditResultResponse result = JSON.parseObject(map.get("data").toString(), HyGetAuditResultResponse.class);
|
CustomerCapitalResult capitalResult = capitalResultMapper.selectOne(Wrappers.<CustomerCapitalResult>lambdaQuery()
|
.eq(CustomerCapitalResult::getCreditNo, result.getOrderNo()));
|
if (capitalResult != null) {
|
updateResultByAudit(capitalResult, result);
|
}
|
object.put("code", 200);
|
object.put("msg", "成功");
|
return object.toJSONString();
|
}
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
log.error("日志编号：" + logNumber + "审核结果回调接口异常:{}", e);
|
}
|
object.put("code", 1001);
|
object.put("msg", "参数错误");
|
return object.toJSONString();
|
}
|
|
private CustomerCapitalResult updateResultByAudit(CustomerCapitalResult capitalResult, HyGetAuditResultResponse param) {
|
if (CapitalApprovalResultEnum.APPROVAL_WAIT.getCode().equals(capitalResult.getApprovalResult())) {
|
LambdaUpdateWrapper<CustomerCapitalResult> wrapper = Wrappers.<CustomerCapitalResult>lambdaUpdate()
|
.set(CustomerCapitalResult::getLastUpdatedDate, new Date())
|
.set(CustomerCapitalResult::getCreditApplyTime, param.getAuditTime())
|
.set(CustomerCapitalResult::getThirdOrderStatus, param.getStatus())
|
.eq(CustomerCapitalResult::getId, capitalResult.getId());
|
if (HyGetOrderStatusResponse.STATUS_AUDIT_SUCCESS.equals(param.getStatus())) {
|
capitalResult.setApprovalResult(CapitalApprovalResultEnum.APPROVAL_SUCCESS.getCode());
|
if (param.getAuditAmount() != null) {
|
Double amount = Double.valueOf(param.getAuditAmount()) / 100;
|
wrapper.set(CustomerCapitalResult::getTotalCredit, amount);
|
}
|
wrapper.set(CustomerCapitalResult::getPeriods, param.getAuditPeriodNum());
|
wrapper.set(CustomerCapitalResult::getApprovalTermUnit, param.getAuditPeriodNumUnit());
|
} else if (HyGetOrderStatusResponse.STATUS_AUDIT_FAIL.equals(param.getStatus())) {
|
capitalResult.setApprovalResult(CapitalApprovalResultEnum.APPROVAL_REFUSE.getCode());
|
wrapper.set(CustomerCapitalResult::getFailedReason, param.getRejectReasons());
|
}
|
wrapper.set(CustomerCapitalResult::getApprovalResult, capitalResult.getApprovalResult());
|
capitalResultMapper.update(null, wrapper);
|
}
|
return capitalResult;
|
}
|
|
|
@Override
|
public String pushLoanStatus(String param, String logNumber) {
|
JSONObject object = new JSONObject();
|
try {
|
if (!TextUtils.isEmpty(param)) {
|
Map<String, Object> map = hySignUtil.parseRequest(param);
|
log.info("日志编号：" + logNumber + "订单状态回调接口:{}", map.toString());
|
if (!TextUtils.isEmpty(map.get("data").toString())) {
|
HyPushLoanStatusDto result = JSON.parseObject(map.get("data").toString(), HyPushLoanStatusDto.class);
|
CustomerCapitalResult capitalResult = capitalResultMapper.selectOne(Wrappers.<CustomerCapitalResult>lambdaQuery()
|
.eq(CustomerCapitalResult::getCreditNo, result.getOrderNo()));
|
if (capitalResult != null) {
|
if (!Objects.equals(result.getStatus(), capitalResult.getThirdOrderStatus())) {
|
capitalResult.setThirdOrderStatus(result.getStatus());
|
capitalResultMapper.update(null, Wrappers.<CustomerCapitalResult>lambdaUpdate()
|
.set(CustomerCapitalResult::getThirdOrderStatus, capitalResult.getThirdOrderStatus())
|
.eq(CustomerCapitalResult::getId, capitalResult.getId()));
|
}
|
}
|
object.put("code", 200);
|
object.put("msg", "成功");
|
return object.toJSONString();
|
}
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
log.error("日志编号：" + logNumber + "订单状态回调接口异常:{}", e);
|
}
|
object.put("code", 1001);
|
object.put("msg", "参数错误");
|
return object.toJSONString();
|
}
|
|
|
@Override
|
public String pushRepayResult(String param, String logNumber) {
|
JSONObject object = new JSONObject();
|
try {
|
if (!TextUtils.isEmpty(param)) {
|
Map<String, Object> map = hySignUtil.parseRequest(param);
|
log.info("日志编号：" + logNumber + "还款结果回调接口:{}", map.toString());
|
if (!TextUtils.isEmpty(map.get("data").toString())) {
|
HyPushRepayDto parseObject = JSON.parseObject(map.get("data").toString(), HyPushRepayDto.class);
|
System.out.println(parseObject);
|
object.put("code", 200);
|
object.put("msg", "成功");
|
return object.toJSONString();
|
}
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
log.error("日志编号：" + logNumber + "还款结果回调接口异常:{}", e);
|
}
|
object.put("code", 1001);
|
object.put("msg", "参数错误");
|
return object.toJSONString();
|
}
|
|
|
@Override
|
public String pushRepayPlan(String param, String logNumber) {
|
JSONObject object = new JSONObject();
|
try {
|
if (!TextUtils.isEmpty(param)) {
|
Map<String, Object> map = hySignUtil.parseRequest(param);
|
log.info("日志编号：" + logNumber + "还款计划回调接口:{}", map.toString());
|
if (!TextUtils.isEmpty(map.get("data").toString())) {
|
HyPushRepayPlanDto parseObject = JSON.parseObject(map.get("data").toString(), HyPushRepayPlanDto.class);
|
object.put("code", 200);
|
object.put("msg", "成功");
|
return object.toJSONString();
|
}
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
log.error("日志编号：" + logNumber + "还款计划回调接口异常:{}", e);
|
}
|
object.put("code", 1001);
|
object.put("msg", "参数错误");
|
return object.toJSONString();
|
}
|
|
/**
|
* 校验恒易贷请求是否成功
|
*
|
* @param response
|
* @return
|
* @throws CommonException
|
*/
|
private boolean checkHydResponse(HyResponse response) throws CommonException {
|
if (response != null) {
|
if (response.isSuccess()) {
|
return true;
|
} else {
|
return false;
|
}
|
} else {
|
throw new CommonException("请求返回值为空");
|
}
|
}
|
|
/**
|
* 校验恒易贷请求业务数据是否为空
|
*
|
* @param response
|
* @return
|
* @throws CommonException
|
*/
|
private boolean checkHydResponseData(HyResponse response) throws CommonException {
|
if (response != null) {
|
if (response.isSuccess()) {
|
if (response.getData() != null) {
|
return true;
|
} else {
|
throw new CommonException("请求业务数据为空");
|
}
|
} else {
|
throw new CommonException("请求响应状态失败");
|
}
|
} else {
|
throw new CommonException("请求返回值为空");
|
}
|
}
|
|
@Override
|
public CustomerCapitalResult checkCustomerByHengYiDai(CapitalInfo capitalInfo, Customer customer, CustomerUser customerUser, String logNumber) {
|
log.info("日志编号：" + logNumber + capitalInfo.getName() + "撞库接口开始");
|
CustomerCapitalResult capitalResult = CustomerCapitalResult.initResult(capitalInfo, customerUser.getId(), customer.getId());
|
capitalResult.setStatus(CapitalResultStatusEnum.CHECK.getCode());
|
CustomerCapitalResult filterResult = capitalResultCommonService.filterCustomer(customer, capitalInfo, capitalResult, logNumber);
|
if (filterResult != null) {
|
log.info("日志编号：" + logNumber + capitalInfo.getName() + "撞库时不满足资方信息筛选条件，撞库失败");
|
return filterResult;
|
}
|
try {
|
String idCardMd5 = DigestUtils.md5DigestAsHex(customer.getIdCard().getBytes());
|
HyResponse<HyCollisionLibraryResponse> response = hyUtil.checkUser(idCardMd5, log, logNumber);
|
if (checkHydResponseData(response)) {
|
HyCollisionLibraryResponse data = response.getData();
|
if (HyCollisionLibraryResponse.CAN_LOAN.equals(data.getIsCanLoan())) {
|
log.info("日志编号：" + logNumber + capitalInfo.getName() + "撞库对接信息:{}", response.toString());
|
capitalResult.setCheckResult(CustomerCapitalResult.CHECK_SUCCESS);
|
} else {
|
log.info("日志编号：" + logNumber + capitalInfo.getName() + "撞库对接信息:{}", response.toString());
|
capitalResult.setCheckResult(CustomerCapitalResult.CHECK_FAIL);
|
}
|
}
|
} catch (CommonException e) {
|
capitalResult.setCheckResult(CustomerCapitalResult.CHECK_FAIL);
|
log.error("日志编号：" + logNumber + capitalInfo.getName() + "初筛接口撞库失败" + e.getMessage());
|
} catch (Exception e) {
|
capitalResult.setCheckResult(CustomerCapitalResult.CHECK_FAIL);
|
log.error("日志编号：" + logNumber + capitalInfo.getName() + "初筛接口撞库失败", e);
|
}
|
if (CustomerUserBusinessTypeEnum.RONG_YI_TUI.getCode().equals(customerUser.getBusinessType())) {
|
capitalResult.setCapitalResultSourceCode(CapitalResultSourceCodeEnum.RONG_YI_TUI.getCode());
|
}
|
capitalResultMapper.insert(capitalResult);
|
log.info("日志编号：" + logNumber + capitalInfo.getName() + "撞库结束");
|
return capitalResult;
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public HengYiDaiPushResultVo pushCustomerByHengYiDai(CapitalInfo capitalInfo, CustomerUser customerUser) {
|
String logNumber = IdUtil.randomUUID();
|
log.info("日志编号：" + logNumber + capitalInfo.getName() + "对接流程开始");
|
HengYiDaiPushResultVo pushResultVo = new HengYiDaiPushResultVo();
|
Customer customer = customerMapper.getLatestCustomerRecord(customerUser.getPhone());
|
CustomerCapitalResult capitalResult = capitalResultMapper.selectOne(Wrappers.<CustomerCapitalResult>lambdaQuery()
|
.eq(CustomerCapitalResult::getCustomerUserId, customerUser.getId())
|
.eq(CustomerCapitalResult::getCustomerRecordId, customer.getId())
|
.eq(CustomerCapitalResult::getCapitalInfoCode, capitalInfo.getCode()));
|
if (capitalResult == null) {
|
throw new CommonException("资方对接结果不存在");
|
}
|
if (CustomerCapitalResult.CHECK_SUCCESS.equals(capitalResult.getCheckResult())) {
|
pushResultVo.setCheckResult(true);
|
} else {
|
pushResultVo.setCheckResult(false);
|
}
|
pushResultVo.setCapitalResultId(capitalResult.getId());
|
if (CapitalResultStatusEnum.CHECK.getCode().equals(capitalResult.getStatus())
|
&& CustomerCapitalResult.CHECK_SUCCESS.equals(capitalResult.getCheckResult())) {
|
log.info("日志编号：" + logNumber + capitalInfo.getName() + "数据推送开始");
|
capitalResult.setStatus(CapitalResultStatusEnum.APPLY.getCode());
|
try {
|
String creditNo = ConstantsUtil.getCreditNo();
|
boolean filter = filterCustomerByHengYidai(customer, capitalInfo, logNumber);
|
if (!filter) {
|
capitalResult.setApprovalResult(CapitalApprovalResultEnum.APPROVAL_REQUEST_FAIL.getCode());
|
capitalResult.setThirdOrderStatus(HyGetOrderStatusResponse.STATUS_AUDIT_FAIL);
|
} else {
|
HyResponse response = hyUtil.pushPhaseOne(customer, creditNo, log, logNumber);
|
if (checkHydResponse(response)) {
|
log.info("日志编号：" + logNumber + capitalInfo.getName() + "进件申请返回结果" + response.toString());
|
customerUserMapper.update(null, Wrappers.<CustomerUser>lambdaUpdate()
|
.set(CustomerUser::getCreditNo, capitalResult.getCreditNo())
|
.eq(CustomerUser::getId, customerUser.getId()));
|
capitalResult.setApprovalResult(CapitalApprovalResultEnum.APPROVAL_WAIT.getCode());
|
capitalResult.setThirdOrderStatus(HyGetOrderStatusResponse.STATUS_AUDIT_WAIT);
|
} else {
|
capitalResult.setApprovalResult(CapitalApprovalResultEnum.APPROVAL_REQUEST_FAIL.getCode());
|
capitalResult.setThirdOrderStatus(HyGetOrderStatusResponse.STATUS_AUDIT_FAIL);
|
log.error("日志编号：" + logNumber + capitalInfo.getName() + "进件申请被拒绝" + response.toString());
|
}
|
}
|
LambdaUpdateWrapper<CustomerCapitalResult> wrapper = capitalResultCommonService.getWrapper(capitalInfo, capitalResult);
|
wrapper.set(CustomerCapitalResult::getThirdOrderStatus, capitalResult.getThirdOrderStatus());
|
wrapper.set(CustomerCapitalResult::getCreditNo, creditNo);
|
capitalResultMapper.update(null, wrapper);
|
Integer pageType = HyGetOrderStatusResponse.parsePageType(capitalResult.getThirdOrderStatus());
|
pushResultVo.setPageType(pageType);
|
pushResultVo.setThirdStatus(capitalResult.getThirdOrderStatus());
|
log.info("日志编号：" + logNumber + capitalInfo.getName() + "数据推送结束");
|
return pushResultVo;
|
} catch (CommonException e) {
|
log.error("日志编号：" + logNumber + capitalInfo.getName() + "进件申请请求失败" + e.getMessage());
|
} catch (Exception e) {
|
log.error("日志编号：" + logNumber + capitalInfo.getName() + "进件申请请求失败", e);
|
}
|
throw new CommonException("推送数据异常");
|
} else {
|
try {
|
if (CapitalApprovalResultEnum.APPROVAL_SUCCESS.getCode().equals(capitalResult.getApprovalResult())) {
|
HyResponse<HyGetOrderStatusResponse> response = hyUtil.getOrderStatus(capitalResult.getCreditNo(), log, logNumber);
|
if (checkHydResponseData(response)) {
|
Integer status = response.getData().getStatus();
|
if (!status.equals(capitalResult.getThirdOrderStatus())) {
|
capitalResult.setThirdOrderStatus(status);
|
capitalResultMapper.update(null, Wrappers.<CustomerCapitalResult>lambdaUpdate()
|
.set(CustomerCapitalResult::getThirdOrderStatus, status)
|
.set(CustomerCapitalResult::getLastUpdatedDate, new Date())
|
.eq(CustomerCapitalResult::getId, capitalResult.getId()));
|
}
|
}
|
} else {
|
HyResponse<HyGetAuditResultResponse> response = hyUtil.getAuditResult(capitalResult.getCreditNo(), log, logNumber);
|
if (checkHydResponseData(response)) {
|
HyGetAuditResultResponse data = response.getData();
|
capitalResult = updateResultByAudit(capitalResult, data);
|
}
|
}
|
Integer pageType = HyGetOrderStatusResponse.parsePageType(capitalResult.getThirdOrderStatus());
|
pushResultVo.setPageType(pageType);
|
pushResultVo.setThirdStatus(capitalResult.getThirdOrderStatus());
|
return pushResultVo;
|
} catch (CommonException e) {
|
log.error("日志编号：" + logNumber + capitalInfo.getName() + "获取订单状态失败" + e.getMessage());
|
} catch (Exception e) {
|
log.error("日志编号：" + logNumber + capitalInfo.getName() + "获取订单状态失败", e);
|
}
|
throw new CommonException("获取订单状态异常");
|
}
|
}
|
|
@Override
|
public boolean filterCustomerByHengYidai(Customer customer, CapitalInfo capitalInfo, String logNumber) {
|
boolean filter = true;
|
if (YiXinHomeRelationEnum.BROTHERS.getCode().equals(customer.getRelationship())) {
|
log.error("日志编号：" + logNumber + capitalInfo.getName() + "进件申请不满足条件，第一联系人为兄弟姐妹");
|
filter = false;
|
}
|
//过滤COS任性贷消费，LEA租赁，LRT土地租金，REN租房,OTH其他消费 等借款用途
|
if (UseOfLoanEnum.Loan_21.getCode().equals(customer.getUseOfLoan()) || UseOfLoanEnum.Loan_22.getCode().equals(customer.getUseOfLoan())
|
|| UseOfLoanEnum.Loan_20.getCode().equals(customer.getUseOfLoan()) || UseOfLoanEnum.Loan_13.getCode().equals(customer.getUseOfLoan())
|
|| UseOfLoanEnum.Loan_12.getCode().equals(customer.getUseOfLoan())) {
|
log.error("日志编号：" + logNumber + capitalInfo.getName() + "进件申请不满足条件，借款用途不在可选范围内" + customer.getUseOfLoan());
|
filter = false;
|
}
|
return filter;
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public ResultJson<CapitalGetSignUrlVo> capitalGetSignUrl(CapitalGetSignUrlDto paramDto, CapitalInfo capitalInfo) {
|
String logNumber = IdUtil.randomUUID();
|
log.info("日志编号：" + logNumber + capitalInfo.getName() + "获取绑卡/签约链接开始");
|
CustomerCapitalResult capitalResult = capitalResultMapper.selectById(paramDto.getCapitalResultId());
|
if (capitalResult == null) {
|
throw new CommonException("资方对接结果不存在");
|
}
|
try {
|
HyGetSignUrlDto hyGetSignUrlDto = new HyGetSignUrlDto(capitalResult.getCreditNo(), paramDto.getReturnUrl());
|
HyResponse<HyGetSignUrlResponse> response = hyUtil.getSignUrl(hyGetSignUrlDto, log, logNumber);
|
if (checkHydResponseData(response)) {
|
CapitalGetSignUrlVo signUrlVo = new CapitalGetSignUrlVo();
|
signUrlVo.setUrl(response.getData().getUrl());
|
return ResultJson.ok(signUrlVo);
|
}
|
} catch (CommonException e) {
|
log.error("日志编号：" + logNumber + capitalInfo.getName() + "获取绑卡/签约链接失败" + e.getMessage());
|
} catch (Exception e) {
|
log.error("日志编号：" + logNumber + capitalInfo.getName() + "获取绑卡/签约链接失败", e);
|
}
|
return ResultJson.failure(ResultCode.SERVER_ERROR, "获取绑卡/签约链接失败");
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public ResultJson<CapitalLoanTrialVo> capitalLoanTrial(CapitalBaseParamDto paramDto, CapitalInfo capitalInfo) {
|
String logNumber = IdUtil.randomUUID();
|
log.info("日志编号：" + logNumber + capitalInfo.getName() + "借款试算开始");
|
CustomerCapitalResult capitalResult = capitalResultMapper.selectById(paramDto.getCapitalResultId());
|
if (capitalResult == null) {
|
throw new CommonException("资方对接结果不存在");
|
}
|
try {
|
HyResponse<HyGetTrialInfoResponse> response = hyUtil.getTrialInfo(capitalResult.getCreditNo(), log, logNumber);
|
if (checkHydResponseData(response)) {
|
CapitalLoanTrialVo capitalLoanTrialVo = HyGetTrialInfoResponse.parseVo(response.getData());
|
double value = Double.parseDouble(capitalResult.getTotalCredit());
|
capitalLoanTrialVo.setActualAmount((long) (int) value * 100);
|
capitalLoanTrialVo.setPeriodNum(Integer.valueOf(capitalResult.getPeriods()));
|
return ResultJson.ok(capitalLoanTrialVo);
|
}
|
} catch (CommonException e) {
|
log.error("日志编号：" + logNumber + capitalInfo.getName() + "借款试算失败" + e.getMessage());
|
} catch (Exception e) {
|
log.error("日志编号：" + logNumber + capitalInfo.getName() + "借款试算失败", e);
|
}
|
return ResultJson.failure(ResultCode.SERVER_ERROR, "借款试算失败");
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public ResultJson<CapitalConfirmLoanVo> capitalConfirmLoan(CapitalConfirmLoanDto paramDto, CapitalInfo capitalInfo) {
|
String logNumber = IdUtil.randomUUID();
|
log.info("日志编号：" + logNumber + capitalInfo.getName() + "确认借款开始");
|
CustomerCapitalResult capitalResult = capitalResultMapper.selectById(paramDto.getCapitalResultId());
|
if (capitalResult == null) {
|
throw new CommonException("资方对接结果不存在");
|
}
|
try {
|
HyConfirmDto hyConfirmDto = new HyConfirmDto(capitalResult.getCreditNo(), paramDto);
|
HyResponse confirm = hyUtil.confirm(hyConfirmDto, log, logNumber);
|
if (checkHydResponse(confirm)) {
|
Date date = new Date();
|
capitalResultMapper.update(null, Wrappers.<CustomerCapitalResult>lambdaUpdate()
|
.set(CustomerCapitalResult::getLoanAmount, paramDto.getApplyAmount())
|
.set(CustomerCapitalResult::getLastUpdatedDate, date)
|
.set(CustomerCapitalResult::getLoanApplyDate, date)
|
.eq(CustomerCapitalResult::getId, capitalResult.getId()));
|
return ResultJson.ok(new CapitalConfirmLoanVo(true));
|
} else {
|
return ResultJson.ok(new CapitalConfirmLoanVo(false));
|
}
|
} catch (CommonException e) {
|
log.error("日志编号：" + logNumber + capitalInfo.getName() + "确认借款失败" + e.getMessage());
|
} catch (Exception e) {
|
log.error("日志编号：" + logNumber + capitalInfo.getName() + "确认借款失败", e);
|
}
|
return ResultJson.failure(ResultCode.SERVER_ERROR, "确认借款失败");
|
}
|
|
@Override
|
public ResultJson<CapitalGetRepayUrlVo> capitalGetRepayUrl(CapitalGetRepayUrlDto paramDto, CapitalInfo capitalInfo) {
|
String logNumber = IdUtil.randomUUID();
|
log.info("日志编号：" + logNumber + capitalInfo.getName() + "获取还款页面开始");
|
CustomerCapitalResult capitalResult = capitalResultMapper.selectById(paramDto.getCapitalResultId());
|
if (capitalResult == null) {
|
throw new CommonException("资方对接结果不存在");
|
}
|
try {
|
HyGetRepayUrlDto hyGetRepayUrlDto = new HyGetRepayUrlDto(capitalResult.getCreditNo(), paramDto.getReturnUrl());
|
HyResponse<HyGetRepayUrlResponse> response = hyUtil.getRepayUrl(hyGetRepayUrlDto, log, logNumber);
|
if (checkHydResponseData(response)) {
|
CapitalGetRepayUrlVo repayUrlVo = new CapitalGetRepayUrlVo();
|
repayUrlVo.setUrl(response.getData().getUrl());
|
return ResultJson.ok(repayUrlVo);
|
}
|
} catch (CommonException e) {
|
log.error("日志编号：" + logNumber + capitalInfo.getName() + "获取还款页面失败" + e.getMessage());
|
} catch (Exception e) {
|
log.error("日志编号：" + logNumber + capitalInfo.getName() + "获取还款页面失败", e);
|
}
|
return ResultJson.failure(ResultCode.SERVER_ERROR, "获取还款页面失败");
|
}
|
|
@Override
|
public ResultJson<CapitalRepayPlanVo> capitalRepayPlan(CapitalBaseParamDto paramDto, CapitalInfo capitalInfo) {
|
String logNumber = IdUtil.randomUUID();
|
log.info("日志编号：" + logNumber + capitalInfo.getName() + "获取还款计划开始");
|
CustomerCapitalResult capitalResult = capitalResultMapper.selectById(paramDto.getCapitalResultId());
|
if (capitalResult == null) {
|
throw new CommonException("资方对接结果不存在");
|
}
|
try {
|
if (HyGetOrderStatusResponse.STATUS_SIGN_SUCCESS.equals(capitalResult.getThirdOrderStatus()) || HyGetOrderStatusResponse.STATUS_LOAN_APPLY_FAIL.equals(capitalResult.getThirdOrderStatus())) {
|
return ResultJson.ok(null);
|
}
|
HyResponse<List<HyGetRepayPlanResponse>> response = hyUtil.getRepayPlan(capitalResult.getCreditNo(), log, logNumber);
|
if (checkHydResponseData(response)) {
|
List<HyGetRepayPlanResponse> data = response.getData();
|
if (data == null || data.isEmpty()) {
|
return ResultJson.ok(null);
|
}
|
CapitalRepayPlanVo repayPlanVo = new CapitalRepayPlanVo();
|
repayPlanVo.setLoanAmount(capitalResult.getLoanAmount());
|
repayPlanVo.setLoanApplyDate(capitalResult.getLoanApplyDate());
|
List<CapitalRepayPlanDetailVo> detailVos = new ArrayList<>();
|
boolean clean = true;
|
Integer status = 0;
|
for (HyGetRepayPlanResponse repayPlan : data) {
|
CapitalRepayPlanDetailVo detailVo = repayPlan.parseVo();
|
if (repayPlanVo.getTotalPeriodNum() == null) {
|
repayPlanVo.setTotalPeriodNum(repayPlan.getTotalPeriodNum());
|
}
|
if (!HyGetRepayPlanResponse.STATUS_REPAID.equals(repayPlan.getStatus())) {
|
clean = false;
|
}
|
if (status == 0 && HyGetRepayPlanResponse.STATUS_OVERDUE.equals(repayPlan.getStatus())) {
|
status = 1;
|
}
|
detailVos.add(detailVo);
|
}
|
if (clean) {
|
status = 2;
|
}
|
repayPlanVo.setStatus(status);
|
repayPlanVo.setRepayDetails(detailVos);
|
return ResultJson.ok(repayPlanVo);
|
}
|
|
} catch (CommonException e) {
|
log.error("日志编号：" + logNumber + capitalInfo.getName() + "获取还款计划失败" + e.getMessage());
|
} catch (Exception e) {
|
log.error("日志编号：" + logNumber + capitalInfo.getName() + "获取还款计划失败", e);
|
}
|
return ResultJson.failure(ResultCode.SERVER_ERROR, "获取还款计划失败");
|
}
|
|
@Override
|
public ResultJson<List<CapitalContractsVo>> capitalContracts(CapitalContractsDto paramDto, CapitalInfo capitalInfo) {
|
String logNumber = IdUtil.randomUUID();
|
log.info("日志编号：" + logNumber + capitalInfo.getName() + "获取协议链接开始");
|
CustomerCapitalResult capitalResult = capitalResultMapper.selectById(paramDto.getCapitalResultId());
|
if (capitalResult == null) {
|
throw new CommonException("资方对接结果不存在");
|
}
|
try {
|
HyGetContractsDto hyGetContractsDto = new HyGetContractsDto();
|
if (CapitalContractsDto.TYPE_ALL.equals(paramDto.getType())) {
|
hyGetContractsDto.setContractTypeList(Arrays.asList(1, 2, 3, 4));
|
} else {
|
hyGetContractsDto.setContractTypeList(Collections.singletonList(paramDto.getType()));
|
}
|
hyGetContractsDto.setOrderNo(capitalResult.getCreditNo());
|
HyResponse<Map<String, String>> response = hyUtil.getContracts(hyGetContractsDto, log, logNumber);
|
if (checkHydResponseData(response)) {
|
List<CapitalContractsVo> contractsVos = new ArrayList<>();
|
Map<String, String> data = response.getData();
|
for (Map.Entry<String, String> entry : data.entrySet()) {
|
CapitalContractsVo contractsVo = new CapitalContractsVo();
|
contractsVo.setType(Integer.valueOf(entry.getKey()));
|
contractsVo.setUrl(entry.getValue());
|
contractsVos.add(contractsVo);
|
}
|
return ResultJson.ok(contractsVos);
|
}
|
} catch (CommonException e) {
|
log.error("日志编号：" + logNumber + capitalInfo.getName() + "获取协议链接失败" + e.getMessage());
|
} catch (Exception e) {
|
log.error("日志编号：" + logNumber + capitalInfo.getName() + "获取协议链接失败", e);
|
}
|
return ResultJson.failure(ResultCode.SERVER_ERROR, "获取协议链接失败");
|
}
|
}
|
