package com.nova.sankuai.infra.utils.zcy;
|
|
import cn.hutool.core.util.IdUtil;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.nova.sankuai.domain.api.zcy.ZcyResponse;
|
import com.nova.sankuai.domain.dto.zcy.CustomerZcyDto;
|
import com.nova.sankuai.domain.entity.Customer;
|
import com.nova.sankuai.domain.entity.CustomerZcy;
|
import com.nova.sankuai.infra.utils.eshidai.EsdUtil;
|
import com.nova.sankuai.infra.utils.hht.HhtUtil;
|
import com.nova.sankuai.infra.utils.hjqb.HjqbUtil;
|
import com.nova.sankuai.infra.utils.ryh.RyhUtil;
|
import com.nova.sankuai.infra.utils.syh.SyhUtil;
|
import com.nova.sankuai.infra.utils.zhd.ZhdUtil;
|
import com.nova.sankuai.service.ICustomerZcyService;
|
import lombok.RequiredArgsConstructor;
|
import org.apache.commons.lang.StringUtils;
|
import org.jetbrains.annotations.NotNull;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.stereotype.Component;
|
|
import java.util.Objects;
|
import java.util.concurrent.CompletableFuture;
|
import java.util.concurrent.ExecutorService;
|
import java.util.concurrent.Executors;
|
|
@Component
|
@RequiredArgsConstructor
|
public class ZcyUtil {
|
|
private static final Logger log = LoggerFactory.getLogger("capitalLogger");
|
private final ICustomerZcyService customerZcyService;
|
private final SyhUtil syhUtil;
|
private final HhtUtil hhtUtil;
|
private final ZhdUtil zhdUtil;
|
private final RyhUtil ryhUtil;
|
private final HjqbUtil hjqbUtil;
|
private final EsdUtil esdUtil;
|
|
public ZcyResponse callback(CustomerZcyDto body) {
|
String logNumber = IdUtil.randomUUID();
|
try {
|
if (Objects.isNull(body)) {
|
ZcyResponse resp = getZcyResponse(400, "请求体为空");
|
log.error("日志编号：{} 中诚易数据入库失败，错误原因：随易花资方回调请求体为空!", logNumber);
|
return resp;
|
}
|
// 获取电话
|
String phone = body.getPhone();
|
|
// 判断数据库是否有数据，有数据，则说明以前有推送过来过
|
CustomerZcy customer = customerZcyService.getOne(new LambdaQueryWrapper<CustomerZcy>().eq(CustomerZcy::getPhone, phone));
|
if (!Objects.isNull(customer)) {
|
ZcyResponse resp = getZcyResponse(400, "电话号码为" + phone + " 已推送过数据!");
|
log.error("日志编号：{} 手机号为:{} 中诚易数据入库失败，传入参数:{} 错误原因：已推送过数据!", logNumber, phone, body);
|
return resp;
|
}
|
|
// 开始录入数据
|
CustomerZcy customerZcy = new CustomerZcy();
|
BeanUtils.copyProperties(body, customerZcy);
|
customerZcyService.save(customerZcy);
|
|
// 异步进行推送和进件操作
|
ExecutorService executor = Executors.newFixedThreadPool(1);
|
CompletableFuture.supplyAsync(() -> {
|
Customer cust = new Customer();
|
BeanUtils.copyProperties(body, cust);
|
|
// 推送和进件数据到随易花
|
boolean succ = syhUtil.zcyPushToSyh(cust, logNumber);
|
if (succ) {// 推送成功，开始进件
|
syhUtil.zcyIncomeToSyh(cust, logNumber);
|
}
|
|
// 推送和进件数据到好汇推
|
boolean succHht = hhtUtil.zcyPushToHht(cust, logNumber);
|
if (succHht) {
|
hhtUtil.zcyIncomeToHht(cust, logNumber);
|
}
|
|
// 推送和进件数据到助贷
|
boolean succZhd = zhdUtil.zcyPushToZhd(cust, logNumber);
|
if (succZhd) {
|
zhdUtil.zcyIncomeToZhd(cust, logNumber);
|
}
|
|
// 推送和进件数据到任意花
|
boolean succRyh = ryhUtil.zcyPushToRyh(cust, logNumber);
|
if (succRyh){
|
ryhUtil.zcyIncomeToRyh(cust, logNumber);
|
}
|
|
// 推送和进件数据到慧借钱包
|
boolean succHjqb = hjqbUtil.zcyPushToHjqb(cust, logNumber);
|
if (succHjqb){
|
hjqbUtil.zcyIncomeToHjqb(cust, logNumber);
|
}
|
// 推送和进件数据到e时贷
|
boolean succEsd = esdUtil.zcyPushToEsd(cust, logNumber);
|
if (succEsd){
|
esdUtil.zcyIncomeToEsd(cust, logNumber);
|
}
|
return true;
|
}, executor);
|
|
ZcyResponse resp = getZcyResponse(200, "成功!");
|
log.info("日志编号：{} 手机号为:{} 中诚易数据入库成功", logNumber, phone);
|
return resp;
|
} catch (Exception e) {
|
ZcyResponse resp = getZcyResponse(500, e.getMessage());
|
log.error("日志编号：{} 中诚易数据入库失败，传入参数:{} 错误原因：{}", logNumber, body, e);
|
return resp;
|
}
|
}
|
|
@NotNull
|
private ZcyResponse getZcyResponse(Integer code, String msg) {
|
ZcyResponse resp = new ZcyResponse();
|
resp.setCode(code);
|
resp.setMsg(msg);
|
return resp;
|
}
|
|
|
}
|
