package com.nova.sankuai.service.impl;
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.nova.sankuai.domain.api.channelUnion.ChannelUnionAutoUtil;
|
import com.nova.sankuai.domain.api.doudouqian.DdqUtil;
|
import com.nova.sankuai.domain.api.huizhixin.HzxUtil;
|
import com.nova.sankuai.domain.api.rongduoduo.RongDuoDuoUtil;
|
import com.nova.sankuai.domain.api.taojinhui.TjhUtil;
|
import com.nova.sankuai.domain.api.xinyeyoupin.XinYeYouPinUtil;
|
import com.nova.sankuai.domain.api.xinyongfei.XinYongFeiUtil;
|
import com.nova.sankuai.domain.api.yibeifenqi.YiBeiUtil;
|
import com.nova.sankuai.domain.api.yixin.YXUtil;
|
import com.nova.sankuai.domain.entity.Customer;
|
import com.nova.sankuai.domain.entity.CustomerCapitalResultVm;
|
import com.nova.sankuai.infra.mapper.*;
|
import com.nova.sankuai.infra.utils.ZzxfUtil;
|
import com.nova.sankuai.service.*;
|
import lombok.AllArgsConstructor;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.stereotype.Service;
|
|
/**
|
* @author weikangdi
|
* @create 2022/5/7
|
*/
|
@Service
|
@AllArgsConstructor
|
public class CustomerCapitalResultVmServiceImpl extends ServiceImpl<CustomerCapitalResultVmMapper, CustomerCapitalResultVm> implements ICustomerCapitalResultVmService {
|
|
private final CustomerMapper customerMapper;
|
|
private final YXUtil yxUtil;
|
|
private final CustomerCapitalResultVmMapper capitalResultMapper;
|
|
private final CapitalInfoMapper capitalInfoMapper;
|
|
private final CustomerUserMapper customerUserMapper;
|
|
private final XinYongFeiUtil xinYongFeiUtil;
|
|
private static final Logger log = LoggerFactory.getLogger("capitalLogger");
|
|
private final HzxUtil hzxUtil;
|
|
private final YiBeiUtil yiBeiUtil;
|
|
private final ZzxfUtil zzxfUtil;
|
|
private final TjhUtil tjhUtil;
|
|
private final XinYeYouPinUtil xinYeYouPinUtil;
|
|
private final ChannelUnionAutoUtil channelUnionAutoUtil;
|
private final DdqUtil doudouUtil;
|
|
private final UnionloginProductMapper unionloginProductMapper;
|
|
private final RongDuoDuoUtil rongDuoDuoUtil;
|
private final ICapitalResultCommonService capitalResultCommonService;
|
|
private final IHengYiDaiService hengYiDaiService;
|
|
private final IXiaoBaiYouKaService xiaoBaiYouKaService;
|
private final ITaoHuiHuaService taoHuiHuaService;
|
|
private final SmsTemplateMapper smsMapper;
|
|
@Override
|
public void collisionlibrary(Customer customer) {
|
/*String logNumber = IdUtil.randomUUID();
|
log.info("日志编号：" + logNumber + "资方列表-虚拟撞库开始");
|
try {
|
CustomerUser customerUser = customerUserMapper.selectOne(Wrappers.<CustomerUser>lambdaQuery()
|
.eq(CustomerUser::getPhone, customer.getPhone()));
|
if (customerUser == null) {
|
log.error("日志编号：" + logNumber + "资方列表-对应用户不存在");
|
}
|
List<CapitalInfo> result = capitalInfoMapper.selectList(Wrappers.<CapitalInfo>lambdaQuery()
|
.eq(CapitalInfo::getEnableFlag, 1));
|
List<CustomerCapitalResultVm> capitalResultList = lambdaQuery()
|
.eq(CustomerCapitalResultVm::getCustomerUserId, customerUser.getId())
|
.eq(CustomerCapitalResultVm::getCustomerRecordId, customer.getId()).list();
|
Map<String, List<CustomerCapitalResultVm>> collect = null;
|
if (capitalResultList != null && !capitalResultList.isEmpty()) {
|
collect = capitalResultList.stream().collect(Collectors.groupingBy(CustomerCapitalResultVm::getCapitalInfoCode));
|
}
|
for (CapitalInfo capitalInfo : result) {
|
int fundType = capitalInfo.getFundType().intValue();
|
if (fundType == 0) {// 只虚拟银行直贷撞库,线上贷款略过
|
continue;
|
}
|
if (collect != null && collect.get(capitalInfo.getCode()) != null && !collect.get(capitalInfo.getCode()).isEmpty()) {
|
continue;
|
}
|
if (CustomerUserBusinessTypeEnum.RONG_YI_TUI.getCode().equals(customerUser.getBusinessType())) {
|
if (!(CapitalInfoTypeCodeEnum.YI_XIN.getCode().equals(capitalInfo.getCode())
|
|| CapitalInfoTypeCodeEnum.XIAO_HUA_QIAN_BAO.getCode().equals(capitalInfo.getCode()))) {
|
continue;
|
}
|
}
|
// 虚拟撞库
|
vmCollisionlibrary(capitalInfo, customer, customerUser, logNumber);
|
}
|
|
} catch (Exception e) {
|
log.error("日志编号：" + logNumber + "资方列表批量虚拟撞库失败", e);
|
}
|
log.info("日志编号：" + logNumber + "资方列表-虚拟撞库结束");*/
|
}
|
|
/**
|
* 虚拟撞库
|
*/
|
/*@Transactional(rollbackFor = Exception.class)
|
public void vmCollisionlibrary(CapitalInfo capitalInfo, Customer
|
customer, CustomerUser customerUser, String logNumber) {
|
log.info("日志编号：" + logNumber + "虚拟撞库开始");
|
CustomerCapitalResult capitalResult = CustomerCapitalResult.initResult(capitalInfo, customerUser.getId(), customer.getId());
|
|
CustomerCapitalResult filterResult = capitalResultCommonService.filterCustomer(customer, capitalInfo, capitalResult, logNumber);
|
if (filterResult != null) {
|
log.info("日志编号：" + logNumber + capitalInfo.getName() + "虚拟撞库时不满足资方信息筛选条件，虚拟撞库失败");
|
return;
|
}
|
|
// 虚拟成功
|
capitalResult.setStatus(CapitalResultStatusEnum.APPLY.getCode());
|
capitalResult.setCheckResult(CustomerCapitalResult.CHECK_SUCCESS);
|
CustomerCapitalResultVm capitalResultVm = new CustomerCapitalResultVm();
|
BeanUtil.copyProperties(capitalResult, capitalResultVm, true);
|
capitalResultMapper.insert(capitalResultVm);
|
log.info("日志编号：" + logNumber + "虚拟撞库结束");
|
}*/
|
}
|
