Skip to content

C
cash-loan-flow-boss
Commit 44f27804 authored by 王向伟's avatar 王向伟
Browse files
Options

添加风控数据接口

parent 685353ae
Hide whitespace changes
Inline Side-by-side
Showing with 129 additions and 43 deletions
src/main/java/cn/quantgroup/cashloanflowboss/api/customer/entity/CustomerInfo.java
View file @ 44f27804
......@@ -80,7 +80,7 @@ public class CustomerInfo {
@Data
class RiskInfo{
public class RiskInfo{
private String key;
private String name;
private String value;
......
src/main/java/cn/quantgroup/cashloanflowboss/api/customer/service/impl/CustomerService.java
View file @ 44f27804
......@@ -2,8 +2,11 @@ package cn.quantgroup.cashloanflowboss.api.customer.service.impl;
import cn.quantgroup.cashloanflowboss.api.customer.entity.CustomerInfo;
import cn.quantgroup.cashloanflowboss.api.customer.service.ICustomerService;
import cn.quantgroup.cashloanflowboss.component.route.ServiceRoute;
import cn.quantgroup.cashloanflowboss.core.base.ServiceResult;
import cn.quantgroup.cashloanflowboss.spi.clf.entity.ClfOrderMapping;
import cn.quantgroup.cashloanflowboss.spi.clf.repository.ClfOrderMappingRepository;
import cn.quantgroup.cashloanflowboss.spi.spiderCenter.SpiderCenter;
import cn.quantgroup.cashloanflowboss.spi.user.service.UserSysService;
import cn.quantgroup.user.retbean.*;
import cn.quantgroup.user.vo.UserSysResult;
......@@ -13,7 +16,9 @@ import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Objects;
/**
......@@ -26,73 +31,121 @@ public class CustomerService implements ICustomerService {
@Autowired
private UserSysService userSysService;
@Autowired
private ServiceRoute serviceRoute;
@Autowired
private ClfOrderMappingRepository clfOrderMappingRepository;
@Autowired
private SpiderCenter spiderCenter;
@Override
public CustomerInfo getCustomerInfo(String phoneNo, String channelOrderNo) {
String logPre = "CustomerService.getCustomerInfo";
log.info("{} 查询客户信息 phoneNo={},channelOrderNo={}",logPre,phoneNo,channelOrderNo);
log.info("{} 查询客户信息 phoneNo={},channelOrderNo={}", logPre, phoneNo, channelOrderNo);
if(StringUtils.isAllBlank(phoneNo,channelOrderNo)){
log.error("{} 查询客户信息失败 参数为空phoneNo={},channelOrderNo={}",logPre,phoneNo,channelOrderNo);
if (StringUtils.isAllBlank(phoneNo, channelOrderNo)) {
log.error("{} 查询客户信息失败 参数为空phoneNo={},channelOrderNo={}", logPre, phoneNo, channelOrderNo);
return null;
}
Long userId = getUserId(phoneNo, channelOrderNo);
if(userId == null){
if (userId == null) {
return null;
}
UserSysResult<XUser> xUserResult = userSysService.getService().findUserByUserId(userId);
if(!xUserResult.isSuccess()){
log.error("{} 查询用户信息失败 userId={} userResult={}",logPre,userId,xUserResult);
if (!xUserResult.isSuccess()) {
log.error("{} 查询用户信息失败 userId={} userResult={}", logPre, userId, xUserResult);
return null;
}
CustomerInfo info = new CustomerInfo();
populateUser(info,xUserResult.getData());
populateUser(info, xUserResult.getData());
UserSysResult<XUserDetail> userDetailResult = userSysService.getService().findUserDetailByUserId(userId);
if(!userDetailResult.isSuccess()){
log.error("{} 查询用户详细信息失败 userId={} userDetailResult={}",logPre,userId,userDetailResult);
if (!userDetailResult.isSuccess()) {
log.error("{} 查询用户详细信息失败 userId={} userDetailResult={}", logPre, userId, userDetailResult);
return null;
}
populateDetail(info,userDetailResult.getData());
populateDetail(info, userDetailResult.getData());
UserSysResult<XUserExtInfo> userExtInfoResult = userSysService.getService().findUserExtInfoByUserId(userId);
if(!userExtInfoResult.isSuccess()){
log.error("{} 查询用户扩展信息失败 userId={} userExtInfoResult={}",logPre,userId,userExtInfoResult);
if (!userExtInfoResult.isSuccess()) {
log.error("{} 查询用户扩展信息失败 userId={} userExtInfoResult={}", logPre, userId, userExtInfoResult);
return null;
}
populateExtInfo(info,userExtInfoResult.getData());
populateExtInfo(info, userExtInfoResult.getData());
UserSysResult<List<XContact>> contactsResult = userSysService.getService().findContactsByUserId(userId);
if(!contactsResult.isSuccess()){
log.error("{} 查询用户紧急联系人失败 userId={} contactsResult={}",logPre,userId,contactsResult);
if (!contactsResult.isSuccess()) {
log.error("{} 查询用户紧急联系人失败 userId={} contactsResult={}", logPre, userId, contactsResult);
return null;
}
populateContact(info,contactsResult.getData());
populateContact(info, contactsResult.getData());
UserSysResult<XAddress> addressResult = userSysService.getService().findAddressByUserId(userId);
if(!addressResult.isSuccess()){
log.error("{}查询用户地址失败 userId={} addressResult={}",logPre,userId,addressResult);
if (!addressResult.isSuccess()) {
log.error("{}查询用户地址失败 userId={} addressResult={}", logPre, userId, addressResult);
return null;
}
populateAddress(info,addressResult.getData());
populateAddress(info, addressResult.getData());
Map<String, Object> param = getParam(channelOrderNo);
ServiceResult<List<CustomerInfo.RiskInfo>> riskInfoData = spiderCenter.getRiskInfoData(param);
if (!riskInfoData.isSuccess()) {
log.error("{}查询风控信息失败 channelOrderNo={} riskInfoData={}", logPre, channelOrderNo, riskInfoData);
return null;
}
info.setRiskInfoList(riskInfoData.getData());
return info;
}
private Map<String, Object> getParam(String channelOrderNo) {
String logPre = "CustomerService.getParam";
//优先使用渠道订单号查询userId
if (StringUtils.isBlank(channelOrderNo)) {
log.error("{} 查询客户信息失败 参数为空 channelOrderNo={}", logPre, channelOrderNo);
return null;
}
ClfOrderMapping orderMapping = clfOrderMappingRepository.findByChannelOrderNoLastOne(channelOrderNo);
if (orderMapping == null) {
log.error("{} 查询客户信息失败 未查到对应的order_mapping channelOrderNo={}", logPre, channelOrderNo);
return null;
}
Map<String,Object> param = new HashMap<>();
List<String> middleStageChannel = serviceRoute.getMiddleStageChannel();
if(middleStageChannel.contains(orderMapping.getRegisteredFrom().toString())){
param.put("type",2);
}else {
param.put("type",1);
}
Long qgUserId = orderMapping.getQgUserId();
UserSysResult<XUser> userByUserId = userSysService.getService().findUserByUserId(qgUserId);
if (!userByUserId.isSuccess()) {
log.error("{} 查询用户信息失败 userId={} userResult={}", logPre, qgUserId, userByUserId);
return null;
}
param.put("uuid",userByUserId.getData().getUuid());
param.put("channelId",userByUserId.getData().getRegisteredFrom());
param.put("applyNo",orderMapping.getApplyNo());
return param;
}
private void populateAddress(CustomerInfo info, XAddress xAddress) {
String logStr = "CustomerService.populateAddress";
log.info("{} xAddress 填充客户信息 xAddress={}",logStr,xAddress);
if(Objects.isNull(xAddress)){
log.error("{} xAddress填充客户地址失败 xAddress为空",logStr);
log.info("{} xAddress 填充客户信息 xAddress={}", logStr, xAddress);
if (Objects.isNull(xAddress)) {
log.error("{} xAddress填充客户地址失败 xAddress为空", logStr);
return;
}
info.setAddress(xAddress.getAddress());
......@@ -101,13 +154,13 @@ public class CustomerService implements ICustomerService {
private void populateContact(CustomerInfo info, List<XContact> contacts) {
String logStr = "CustomerService.populateContact";
log.info("{} contacts填充客户信息 contacts={}",logStr,contacts);
if(CollectionUtils.isEmpty(contacts)){
log.error("{} contacts填充客户紧急联系人失败 contacts为空",logStr);
log.info("{} contacts填充客户信息 contacts={}", logStr, contacts);
if (CollectionUtils.isEmpty(contacts)) {
log.error("{} contacts填充客户紧急联系人失败 contacts为空", logStr);
return;
}
if(contacts.size() != 2){
log.error("{} 紧急联系人个数错误 contacts={}",logStr,contacts);
if (contacts.size() != 2) {
log.error("{} 紧急联系人个数错误 contacts={}", logStr, contacts);
return;
}
info.setContactNameA(contacts.get(0).getName());
......@@ -122,9 +175,9 @@ public class CustomerService implements ICustomerService {
private void populateExtInfo(CustomerInfo info, XUserExtInfo xUserExtInfo) {
String logStr = "CustomerService.populateExtInfo";
log.info("{} xUserExtInfo填充客户信息 xUserExtInfo={}",logStr,xUserExtInfo);
if(Objects.isNull(xUserExtInfo)){
log.error("{} xUserExtInfo填充客户扩展信息失败 xUserExtInfo为空",logStr);
log.info("{} xUserExtInfo填充客户信息 xUserExtInfo={}", logStr, xUserExtInfo);
if (Objects.isNull(xUserExtInfo)) {
log.error("{} xUserExtInfo填充客户扩展信息失败 xUserExtInfo为空", logStr);
return;
}
......@@ -141,9 +194,9 @@ public class CustomerService implements ICustomerService {
private void populateDetail(CustomerInfo info, XUserDetail xUserDetail) {
String logStr = "CustomerService.populateDetail";
log.info("{} xUser填充客户信息 xUser={}",logStr,xUserDetail);
if(Objects.isNull(xUserDetail)){
log.error("{} xUserDetail填充客户信息失败 xUserDetail为空",logStr);
log.info("{} xUser填充客户信息 xUser={}", logStr, xUserDetail);
if (Objects.isNull(xUserDetail)) {
log.error("{} xUserDetail填充客户信息失败 xUserDetail为空", logStr);
return;
}
info.setName(xUserDetail.getName());
......@@ -154,9 +207,9 @@ public class CustomerService implements ICustomerService {
private void populateUser(CustomerInfo info, XUser xUser) {
String logStr = "CustomerService.populateUser";
log.info("{} xUser填充客户信息 xUser={}",logStr,xUser);
if(Objects.isNull(xUser)){
log.error("{} xUser填充客户信息失败 xUser为空",logStr);
log.info("{} xUser填充客户信息 xUser={}", logStr, xUser);
if (Objects.isNull(xUser)) {
log.error("{} xUser填充客户信息失败 xUser为空", logStr);
return;
}
info.setUserId(xUser.getId());
......@@ -168,19 +221,19 @@ public class CustomerService implements ICustomerService {
private Long getUserId(String phoneNo, String channelOrderNo) {
String logPre = "CustomerService.getUserId";
//优先使用渠道订单号查询userId
if(StringUtils.isNotBlank(channelOrderNo)){
//优先使用渠道订单号查询userId
if (StringUtils.isNotBlank(channelOrderNo)) {
ClfOrderMapping orderMapping = clfOrderMappingRepository.findByChannelOrderNoLastOne(channelOrderNo);
if(orderMapping == null){
log.error("{} 查询客户信息失败 未查到对应的order_mapping channelOrderNo={}",logPre,channelOrderNo);
if (orderMapping == null) {
log.error("{} 查询客户信息失败 未查到对应的order_mapping channelOrderNo={}", logPre, channelOrderNo);
return null;
}
return orderMapping.getQgUserId();
} else {
UserSysResult<XUser> user =
userSysService.getService().findUserByPhoneNo(phoneNo);
if(!user.isSuccess()){
log.error("{} 查询客户信息失败 phoneNo={},result={}",logPre,phoneNo,user);
if (!user.isSuccess()) {
log.error("{} 查询客户信息失败 phoneNo={},result={}", logPre, phoneNo, user);
return null;
}
return user.getData().getId();
......
src/main/java/cn/quantgroup/cashloanflowboss/spi/spiderCenter/SpiderCenter.java 0 → 100644
View file @ 44f27804
package cn.quantgroup.cashloanflowboss.spi.spiderCenter;
import cn.quantgroup.cashloanflowboss.api.customer.entity.CustomerInfo;
import cn.quantgroup.cashloanflowboss.core.base.ServiceResult;
import org.springframework.cloud.netflix.feign.FeignClient;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestParam;
import java.util.List;
import java.util.Map;
/**
* @author Wang Xiangwei
* @version 2020/7/22
*/
@Component
@FeignClient(name = "OPCenter", url = "${spider.api-host}", fallback = SpiderCenter.Fallback.class)
public interface SpiderCenter {
@PostMapping(value = "/spider-center/middle_office/ex/import/check_risk_info_data", consumes = "application/x-www-form-urlencoded")
ServiceResult<List<CustomerInfo.RiskInfo>> getRiskInfoData(@RequestParam Map paramMap);
@Component
class Fallback implements SpiderCenter {
@Override
public ServiceResult<List<CustomerInfo.RiskInfo>> getRiskInfoData(Map paramMap) {
return ServiceResult.buildFial();
}
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment