package com.nova.sankuai.service.impl;
|
|
import cn.hutool.core.util.IdUtil;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
import com.nova.sankuai.domain.api.xiaobaiyouka.XiaoBaiYouKaCheckUserResponse;
|
import com.nova.sankuai.domain.api.xiaobaiyouka.XiaoBaiYouKaRegisterResponse;
|
import com.nova.sankuai.domain.api.xiaobaiyouka.XiaoBaiYouKaUtil;
|
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.enums.capitalInfo.CapitalResultStatusEnum;
|
import com.nova.sankuai.domain.vo.capitalresult.XiaoBaiYouKaPushResultVo;
|
import com.nova.sankuai.infra.config.CommonException;
|
import com.nova.sankuai.infra.mapper.CustomerCapitalResultMapper;
|
import com.nova.sankuai.infra.mapper.CustomerMapper;
|
import com.nova.sankuai.service.ICapitalResultCommonService;
|
import com.nova.sankuai.service.IXiaoBaiYouKaService;
|
import lombok.AllArgsConstructor;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.stereotype.Service;
|
|
/**
|
* @Author Lilinhong
|
* @Date 2022/7/26 9:40
|
*/
|
@Service
|
@AllArgsConstructor
|
public class XiaoBaiYouKaServiceImpl implements IXiaoBaiYouKaService {
|
|
private final ICapitalResultCommonService capitalResultCommonService;
|
|
private final CustomerCapitalResultMapper capitalResultMapper;
|
|
private static final Logger log = LoggerFactory.getLogger("capitalLogger");
|
|
private final XiaoBaiYouKaUtil xiaoBaiYouKaUtil;
|
|
private final CustomerMapper customerMapper;
|
|
|
@Override
|
public CustomerCapitalResult checkCustomerByXiaoBaiYouKa(CapitalInfo capitalInfo, Customer customer, CustomerUser customerUser, String logNumber) {
|
log.info("日志编号：" + logNumber + "小白优卡撞库开始");
|
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 {
|
XiaoBaiYouKaCheckUserResponse xiaoBaiYouKaCheckUserResponse = xiaoBaiYouKaUtil.checkUser(customerUser);
|
if (xiaoBaiYouKaCheckUserResponse == null) {
|
log.error("日志编号：" + logNumber + "小白优卡错误，撞库对接返回为空");
|
throw new CommonException("小白优卡错误，撞库对接失败");
|
} else {
|
if ("0".equals(xiaoBaiYouKaCheckUserResponse.getResult())) {
|
log.info("日志编号：" + logNumber + "小白优卡，撞库对接信息:{}", xiaoBaiYouKaCheckUserResponse.toString());
|
capitalResult.setCheckResult(CustomerCapitalResult.CHECK_SUCCESS);
|
} else {
|
log.error("日志编号：" + logNumber + "小白优卡错误，撞库对接失败:{}", xiaoBaiYouKaCheckUserResponse.toString());
|
capitalResult.setCheckResult(CustomerCapitalResult.CHECK_FAIL);
|
}
|
}
|
} catch (Exception e) {
|
capitalResult.setCheckResult(CustomerCapitalResult.CHECK_FAIL);
|
log.error("日志编号：" + logNumber + "小白优卡错误，撞库接口异常:", e);
|
}
|
capitalResultMapper.insert(capitalResult);
|
log.info("日志编号：" + logNumber + "小白优卡撞库结束");
|
return capitalResult;
|
}
|
|
@Override
|
/**
|
* 于2022-11-29新增：
|
* @param isNotCheckResult 若为true则不需要判断approval_result或check_result为1
|
* @return
|
*/
|
public XiaoBaiYouKaPushResultVo pushCustomerByXiaoBaiYouKa(CapitalInfo capitalInfo, CustomerUser customerUser, boolean isNotCheckResult) {
|
String logNumber = IdUtil.randomUUID();
|
log.info("日志编号：" + logNumber + "小白优卡对接流程开始");
|
XiaoBaiYouKaPushResultVo xiaoBaiYouKaPushResultVo = new XiaoBaiYouKaPushResultVo();
|
Customer customer = customerMapper.getLatestCustomerRecord(customerUser.getPhone());
|
CustomerCapitalResult capitalResult = capitalResultMapper.selectOne(new LambdaQueryWrapper<CustomerCapitalResult>()
|
.eq(CustomerCapitalResult::getCustomerUserId, customerUser.getId())
|
.eq(CustomerCapitalResult::getCustomerRecordId, customer.getId())
|
.eq(CustomerCapitalResult::getCapitalInfoCode, CapitalInfoTypeCodeEnum.XIAO_BAI_YOU_KA.getCode()));
|
if (capitalResult == null) {
|
log.info("日志编号：" + logNumber + "小白优卡资方对接结果不存在");
|
throw new CommonException("资方对接结果不存在");
|
}
|
if (CustomerCapitalResult.CHECK_SUCCESS.equals(capitalResult.getCheckResult())) {
|
xiaoBaiYouKaPushResultVo.setCheckResult(true);
|
} else {
|
xiaoBaiYouKaPushResultVo.setCheckResult(false);
|
}
|
String url = null;
|
XiaoBaiYouKaRegisterResponse register = null;
|
log.info("日志编号：" + logNumber + ",用户手机号：" + customer.getPhone() + ",小白优卡数据推送开始");
|
try {
|
register = xiaoBaiYouKaUtil.register(customerUser);
|
if (register != null) {
|
// 2022-11-29新增：不需要判断ApprovalResult为1
|
if (isNotCheckResult) {
|
if (register.getUrl() != null) {
|
url = register.getUrl();
|
}
|
} else {
|
if (CapitalApprovalResultEnum.APPROVAL_SUCCESS.getCode().equals(capitalResult.getApprovalResult()) && register.getUrl() != null) {
|
log.info("日志编号：" + logNumber + ",用户手机号：" + customer.getPhone() + "," + capitalInfo.getName() + "小白优卡数据返回地址为：" + register.getUrl());
|
url = register.getUrl();
|
}
|
}
|
// 完
|
|
log.info("日志编号：" + logNumber + ",用户手机号：" + customer.getPhone() + ",小白优卡授权申请返回结果" + register.toString());
|
if ("0".equals(register.getResult())) {
|
capitalResult.setApprovalResult(CapitalApprovalResultEnum.APPROVAL_SUCCESS.getCode());
|
} else {
|
capitalResult.setApprovalResult(CapitalApprovalResultEnum.APPROVAL_REQUEST_FAIL.getCode());
|
log.error("日志编号：" + logNumber + ",用户手机号：" + customer.getPhone() + ",小白优卡授权申请失败" + register.toString());
|
}
|
} else {
|
log.error("日志编号：" + logNumber + ",用户手机号：" + customer.getPhone() + ",小白优卡授权申请返回结果为空");
|
capitalResult.setApprovalResult(CapitalApprovalResultEnum.APPROVAL_REQUEST_FAIL.getCode());
|
}
|
} catch (Exception e) {
|
log.error("日志编号：" + logNumber + ",用户手机号：" + customer.getPhone() + ",小白优卡授权申请失败", e);
|
throw new CommonException("请求异常");
|
}
|
if (CapitalResultStatusEnum.CHECK.getCode().equals(capitalResult.getStatus())
|
&& CustomerCapitalResult.CHECK_SUCCESS.equals(capitalResult.getCheckResult())) {
|
capitalResult.setStatus(CapitalResultStatusEnum.APPLY.getCode());
|
LambdaUpdateWrapper<CustomerCapitalResult> wrapper = capitalResultCommonService.getWrapper(capitalInfo, capitalResult);
|
capitalResultMapper.update(null,wrapper);
|
log.info("日志编号：" + logNumber + ",用户手机号：" + customer.getPhone() + ",小白优卡数据推送结束");
|
}
|
if (url != null) {
|
log.info("日志编号：" + logNumber + ",用户手机号：" + customer.getPhone() + "," + capitalInfo.getName() + "联登数据返回地址为：" + url);
|
xiaoBaiYouKaPushResultVo.setUrl(url);
|
}
|
// else if (CapitalApprovalResultEnum.APPROVAL_SUCCESS.getCode().equals(capitalResult.getApprovalResult())) {
|
// if (register != null && register.getUrl() != null) {
|
// xiaoBaiYouKaPushResultVo.setUrl(register.getUrl());
|
// }
|
else {
|
// 2022-11-29新增：不需要判断ApprovalResult为1
|
if (isNotCheckResult) {
|
if (register != null && register.getUrl() != null) {
|
xiaoBaiYouKaPushResultVo.setUrl(register.getUrl());
|
}
|
} else {
|
if (CapitalApprovalResultEnum.APPROVAL_SUCCESS.getCode().equals(capitalResult.getApprovalResult())) {
|
if (register != null && register.getUrl() != null) {
|
xiaoBaiYouKaPushResultVo.setUrl(register.getUrl());
|
}
|
}
|
}
|
// 完
|
}
|
log.info("日志编号：" + logNumber + ",用户手机号：" + customer.getPhone() + ",小白优卡对接流程结束");
|
return xiaoBaiYouKaPushResultVo;
|
}
|
}
|
