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.taohuihua.TaoHuiHuaCheckResponse;
|
import com.nova.sankuai.domain.api.taohuihua.TaoHuiHuaRegisterResponse;
|
import com.nova.sankuai.domain.api.taohuihua.TaoHuiHuaUtil;
|
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.TaoHuiHuaPushResultVo;
|
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.ITaoHuiHuaService;
|
import lombok.AllArgsConstructor;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.stereotype.Service;
|
|
/**
|
* @Author Lilinhong
|
* @Date 2022/7/27 16:47
|
*/
|
@Service
|
@AllArgsConstructor
|
public class TaoHuiHuaServiceImpl implements ITaoHuiHuaService {
|
|
private static final Logger log = LoggerFactory.getLogger("capitalLogger");
|
|
private final TaoHuiHuaUtil taoHuiHuaUtil;
|
|
private final ICapitalResultCommonService capitalResultCommonService;
|
|
private final CustomerCapitalResultMapper capitalResultMapper;
|
|
private final CustomerMapper customerMapper;
|
|
|
@Override
|
public CustomerCapitalResult checkCustomerByTaoHuiHua(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 {
|
TaoHuiHuaCheckResponse taoHuiHuaCheckResponse = taoHuiHuaUtil.checkUser(customer.getPhone(), customer.getOs(), customer.getDeviceBrand(), customer.getDeviceOsVersion(), customer.getSystemModel());
|
if (taoHuiHuaCheckResponse == null) {
|
log.error("日志编号：" + logNumber + "淘惠花错误，撞库对接返回为空");
|
throw new CommonException("淘惠花错误，撞库对接失败");
|
} else {
|
if (1 == taoHuiHuaCheckResponse.getStatus()) {
|
log.info("日志编号：" + logNumber + "淘惠花，撞库对接信息:{}", taoHuiHuaCheckResponse.toString());
|
capitalResult.setCheckResult(CustomerCapitalResult.CHECK_SUCCESS);
|
} else {
|
log.error("日志编号：" + logNumber + "淘惠花错误，撞库对接失败:{}", taoHuiHuaCheckResponse.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
|
public TaoHuiHuaPushResultVo pushCustomerByTaoHuiHua(CapitalInfo capitalInfo, CustomerUser customerUser, boolean isNotCheckResult) {
|
String logNumber = IdUtil.randomUUID();
|
log.info("日志编号：" + logNumber + "淘惠花对接流程开始");
|
TaoHuiHuaPushResultVo taoHuiHuaPushResultVo = new TaoHuiHuaPushResultVo();
|
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.TAO_HUI_HUA.getCode()));
|
if (capitalResult == null) {
|
log.info("日志编号：" + logNumber + "淘惠花资方对接结果不存在");
|
throw new CommonException("资方对接结果不存在");
|
}
|
if (CustomerCapitalResult.CHECK_SUCCESS.equals(capitalResult.getCheckResult())) {
|
taoHuiHuaPushResultVo.setCheckResult(true);
|
} else {
|
taoHuiHuaPushResultVo.setCheckResult(false);
|
}
|
String url = null;
|
TaoHuiHuaRegisterResponse register = null;
|
log.info("日志编号：" + logNumber + ",用户手机号：" + customer.getPhone() + ",淘惠花数据推送开始");
|
try {
|
register = taoHuiHuaUtil.register(customer.getPhone(), customer.getOs(), customer.getDeviceBrand(), customer.getDeviceOsVersion(), customer.getSystemModel());
|
if (register != null) {
|
// if (CapitalApprovalResultEnum.APPROVAL_SUCCESS.getCode().equals(capitalResult.getApprovalResult()) && register.getUrl() != null) {
|
// log.info("日志编号：" + logNumber + ",用户手机号：" + customer.getPhone() + ",淘惠花数据返回地址为：" + register.getUrl());
|
// url = register.getUrl();
|
// }
|
// 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() + ",淘惠花数据返回地址为：" + register.getUrl());
|
url = register.getUrl();
|
}
|
}
|
// 完
|
log.info("日志编号：" + logNumber + "资方结果id：" + capitalResult.getId() + "淘惠花授权申请返回结果" + register.toString());
|
if (1 == register.getResult()) {
|
capitalResult.setApprovalResult(CapitalApprovalResultEnum.APPROVAL_SUCCESS.getCode());
|
} else {
|
capitalResult.setApprovalResult(CapitalApprovalResultEnum.APPROVAL_REQUEST_FAIL.getCode());
|
log.error("日志编号：" + logNumber + "资方结果id：" + capitalResult.getId() + "淘惠花授权申请失败" + register.toString());
|
}
|
} else {
|
log.error("日志编号：" + logNumber + "资方结果id：" + capitalResult.getId() + "淘惠花授权申请返回结果为空");
|
throw new CommonException("授权申请返回结果为空");
|
}
|
} catch (Exception e) {
|
log.error("日志编号：" + logNumber + "资方结果id：" + capitalResult.getId() + "淘惠花授权申请失败", e);
|
throw new CommonException("请求异常");
|
}
|
log.info("日志编号：" + logNumber + "资方结果id：" + capitalResult.getId() + "淘惠花数据推送结束");
|
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() + ",淘惠花数据返回地址为：" + url);
|
taoHuiHuaPushResultVo.setUrl(url);
|
}
|
/*else if (CapitalApprovalResultEnum.APPROVAL_SUCCESS.getCode().equals(capitalResult.getApprovalResult())) {
|
if (register != null && register.getUrl() != null) {
|
taoHuiHuaPushResultVo.setUrl(register.getUrl());
|
}
|
}*/
|
else {
|
// 2022-11-29新增：不需要判断ApprovalResult为1
|
if (isNotCheckResult) {
|
if (register != null && register.getUrl() != null) {
|
taoHuiHuaPushResultVo.setUrl(register.getUrl());
|
}
|
} else {
|
if (CapitalApprovalResultEnum.APPROVAL_SUCCESS.getCode().equals(capitalResult.getApprovalResult())) {
|
if (register != null && register.getUrl() != null) {
|
taoHuiHuaPushResultVo.setUrl(register.getUrl());
|
}
|
}
|
}
|
// 完
|
}
|
log.info("日志编号：" + logNumber + ",用户手机号：" + customer.getPhone() + ",淘惠花对接流程结束");
|
return taoHuiHuaPushResultVo;
|
}
|
}
|
