Commit 9e29dde6 authored by 王向伟's avatar 王向伟

用户信息查询修改逻辑

parent 068cee67
...@@ -245,7 +245,7 @@ public class OrderServiceImpl implements IOrderService { ...@@ -245,7 +245,7 @@ public class OrderServiceImpl implements IOrderService {
result.setValue("请求参数为空"); result.setValue("请求参数为空");
return result; return result;
} else if (orderParam > 1) { } else if (orderParam > 1) {
result.setValue("只能选择一个参数进行查询"); result.setValue("只能使用渠道号和渠道订单号组合查询");
return result; return result;
} }
......
...@@ -161,24 +161,26 @@ public class UserServiceImpl implements IUserService { ...@@ -161,24 +161,26 @@ public class UserServiceImpl implements IUserService {
//通过userId查询 //通过userId查询
if (Objects.nonNull(userQueryParam.getUserId())) { if (Objects.nonNull(userQueryParam.getUserId())) {
log.info("{} 通过userId查询 userId={}", LOG_PRE, userQueryParam.getUserId()); log.info("{} 通过userId查询 userId={}", LOG_PRE, userQueryParam.getUserId());
UserSysResult<XUser> userByUserId = userSdk.getService().findUserByUserId(userQueryParam.getUserId());
UserSysResult<XUserDetail> userDetailByUserId = userSdk.getService().findUserDetailByUserId(userQueryParam.getUserId()); UserSysResult<XUserDetail> userDetailByUserId = userSdk.getService().findUserDetailByUserId(userQueryParam.getUserId());
return getUserBasicInfoResult(userDetailByUserId); return getUserBasicInfoResult(userByUserId, userDetailByUserId);
} }
if (StringUtils.isNotBlank(userQueryParam.getPhoneNo())) { if (StringUtils.isNotBlank(userQueryParam.getPhoneNo())) {
log.info("{} 通过phoneNo查询 phoneNo={}", LOG_PRE, userQueryParam.getPhoneNo()); log.info("{} 通过phoneNo查询 phoneNo={}", LOG_PRE, userQueryParam.getPhoneNo());
UserSysResult<XUser> userByPhoneNo = userSdk.getService().findUserByPhoneNo(userQueryParam.getPhoneNo());
UserSysResult<XUserDetail> userDetailByPhone = userSdk.getService().findUserDetailByPhone(userQueryParam.getPhoneNo()); UserSysResult<XUserDetail> userDetailByPhone = userSdk.getService().findUserDetailByPhone(userQueryParam.getPhoneNo());
return getUserBasicInfoResult(userDetailByPhone); return getUserBasicInfoResult(userByPhoneNo, userDetailByPhone);
} }
if (StringUtils.isNotBlank(userQueryParam.getUuid())) { if (StringUtils.isNotBlank(userQueryParam.getUuid())) {
log.info("{} 通过uuid查询 uuid={}", LOG_PRE, userQueryParam.getUuid()); log.info("{} 通过uuid查询 uuid={}", LOG_PRE, userQueryParam.getUuid());
UserSysResult<XUserFullInfo> userFullInfoByUuid = userSdk.getService().findUserFullInfoByUuid(userQueryParam.getUuid()); UserSysResult<XUser> xUserByUuid = userSdk.getService().findUserByUuid(userQueryParam.getUuid());
Object jsonResultData = getJsonResultData(userFullInfoByUuid); Object jsonResultData = getJsonResultData(xUserByUuid);
if (jsonResultData instanceof XUserFullInfo) { if (jsonResultData instanceof XUserFullInfo) {
XUserFullInfo xUserFullInfo = (XUserFullInfo) jsonResultData; XUserFullInfo xUserFullInfo = (XUserFullInfo) jsonResultData;
UserSysResult<XUserDetail> userDetailByPhone = userSdk.getService().findUserDetailByPhone(xUserFullInfo.getPhoneNo()); UserSysResult<XUserDetail> userDetailByPhone = userSdk.getService().findUserDetailByPhone(xUserFullInfo.getPhoneNo());
return getUserBasicInfoResult(userDetailByPhone); return getUserBasicInfoResult(xUserByUuid, userDetailByPhone);
} else { } else {
return (JsonResult) jsonResultData; return (JsonResult) jsonResultData;
} }
...@@ -249,26 +251,30 @@ public class UserServiceImpl implements IUserService { ...@@ -249,26 +251,30 @@ public class UserServiceImpl implements IUserService {
} }
private JsonResult getUserBasicInfoResult(UserSysResult userSysResult) { private JsonResult getUserBasicInfoResult(UserSysResult<XUser> xUserUserSysResult, UserSysResult<XUserDetail> detailUserSysResult) {
Object data = getJsonResultData(userSysResult); Object detailUser = getJsonResultData(detailUserSysResult);
Object xUserData = getJsonResultData(xUserUserSysResult);
UserBasicInfo userBasicInfo = new UserBasicInfo(); UserBasicInfo userBasicInfo = new UserBasicInfo();
if (data instanceof XUserDetail) {
XUserDetail userDetail = (XUserDetail) data; if (Objects.isNull(xUserData)) {
String createAt = DateUtil.format(userDetail.getCreatedAt(), DateUtil.DATE_FORMAT_1); log.error(" 用户不存在 userSysResult={}", xUserData);
return JsonResult.buildErrorStateResult("用户不存在", xUserData);
}
if (xUserData instanceof XUser) {
XUser xUser = (XUser) xUserData;
userBasicInfo.setUserId(xUser.getId());
userBasicInfo.setPhoneNo(DesensitizeUtil.phoneMark(xUser.getPhoneNo()));
String createAt = DateUtil.format(xUser.getCreatedAt(), DateUtil.DATE_FORMAT_1);
userBasicInfo.setCreatedAt(createAt); userBasicInfo.setCreatedAt(createAt);
Boolean enable = xUser.getEnable();
userBasicInfo.setStatus(enable == null ? "未知" : (enable ? "正常" : "封禁"));
}
if (detailUser instanceof XUserDetail) {
XUserDetail userDetail = (XUserDetail) detailUser;
userBasicInfo.setGender(userDetail.getGender().getName()); userBasicInfo.setGender(userDetail.getGender().getName());
userBasicInfo.setIdNo(DesensitizeUtil.idNoMark(userDetail.getIdNo())); userBasicInfo.setIdNo(DesensitizeUtil.idNoMark(userDetail.getIdNo()));
userBasicInfo.setName(userDetail.getName()); userBasicInfo.setName(userDetail.getName());
userBasicInfo.setPhoneNo(DesensitizeUtil.phoneMark(userDetail.getPhoneNo()));
userBasicInfo.setUserId(userDetail.getUserId());
UserSysResult<XUser> userByUserId = userSdk.getService().findUserByUserId(userDetail.getUserId());
if (userByUserId != null && userByUserId.isSuccess()) {
Boolean enable = userByUserId.getData().getEnable();
userBasicInfo.setStatus(enable == null ? "未知" : (enable ? "正常" : "封禁"));
}
} else {
return (JsonResult) data;
} }
return JsonResult.buildSuccessResult(null, userBasicInfo); return JsonResult.buildSuccessResult(null, userBasicInfo);
} }
...@@ -287,10 +293,7 @@ public class UserServiceImpl implements IUserService { ...@@ -287,10 +293,7 @@ public class UserServiceImpl implements IUserService {
return JsonResult.buildErrorStateResult("查询用户失败", userSysResult.getData()); return JsonResult.buildErrorStateResult("查询用户失败", userSysResult.getData());
} }
if(Objects.isNull(userSysResult.getData())){
log.error("{} 用户不存在 userSysResult={}", logPre, userSysResult);
return JsonResult.buildErrorStateResult("用户不存在", userSysResult.getData());
}
return userSysResult.getData(); return userSysResult.getData();
} }
...@@ -360,7 +363,7 @@ public class UserServiceImpl implements IUserService { ...@@ -360,7 +363,7 @@ public class UserServiceImpl implements IUserService {
result.setValue("参数不能为空"); result.setValue("参数不能为空");
return result; return result;
} else if (orderParam + userParam > 1) { } else if (orderParam + userParam > 1) {
result.setValue("只能选择一个参数进行查询"); result.setValue("只能使用渠道号和渠道订单号组合查询");
return result; return result;
} }
...@@ -376,7 +379,7 @@ public class UserServiceImpl implements IUserService { ...@@ -376,7 +379,7 @@ public class UserServiceImpl implements IUserService {
result.setValue("2"); result.setValue("2");
return result; return result;
} }
result.setValue("只能选择一个参数进行查询"); result.setValue("只能使用渠道号和渠道订单号组合查询");
return result; return result;
} }
...@@ -496,7 +499,7 @@ public class UserServiceImpl implements IUserService { ...@@ -496,7 +499,7 @@ public class UserServiceImpl implements IUserService {
log.info("{} 订单参数查询用户信息 orderQueryParam={}", logPre, orderQueryParam); log.info("{} 订单参数查询用户信息 orderQueryParam={}", logPre, orderQueryParam);
//渠道订单号需要有渠道号 //渠道订单号需要有渠道号
boolean channelParam = StringUtils.isNotBlank(orderQueryParam.getChannelOrderNo()) && Objects.nonNull(orderQueryParam.getChannelId()); boolean channelParam = StringUtils.isNotBlank(orderQueryParam.getChannelOrderNo()) && Objects.nonNull(orderQueryParam.getChannelId());
if(channelParam){ if (channelParam) {
//通过ka获得userId然后通过userId查询 //通过ka获得userId然后通过userId查询
JsonResult<LoanOrderMapping> orderMapping = kaService.findOrderMapping(orderQueryParam); JsonResult<LoanOrderMapping> orderMapping = kaService.findOrderMapping(orderQueryParam);
if (!orderMapping.isSuccess()) { if (!orderMapping.isSuccess()) {
...@@ -504,11 +507,12 @@ public class UserServiceImpl implements IUserService { ...@@ -504,11 +507,12 @@ public class UserServiceImpl implements IUserService {
return JsonResult.buildErrorStateResult("查询失败", null); return JsonResult.buildErrorStateResult("查询失败", null);
} }
if (Objects.isNull(orderMapping.getData())) { if (Objects.isNull(orderMapping.getData())) {
return JsonResult.buildErrorStateResult("无数据,请用其他参数查询", null); return JsonResult.buildErrorStateResult("请确认搜索条件后再查询", null);
} }
Long qgUserId = orderMapping.getData().getQgUserId(); Long qgUserId = orderMapping.getData().getQgUserId();
UserSysResult<XUser> userByUserId = userSdk.getService().findUserByUserId(qgUserId);
UserSysResult<XUserDetail> userDetailByUserId = userSdk.getService().findUserDetailByUserId(qgUserId); UserSysResult<XUserDetail> userDetailByUserId = userSdk.getService().findUserDetailByUserId(qgUserId);
return getUserBasicInfoResult(userDetailByUserId); return getUserBasicInfoResult(userByUserId,userDetailByUserId);
} }
if (Objects.nonNull(orderQueryParam.getLoanId()) || if (Objects.nonNull(orderQueryParam.getLoanId()) ||
StringUtils.isNotBlank(orderQueryParam.getApplyOrderNo())) { StringUtils.isNotBlank(orderQueryParam.getApplyOrderNo())) {
...@@ -519,17 +523,18 @@ public class UserServiceImpl implements IUserService { ...@@ -519,17 +523,18 @@ public class UserServiceImpl implements IUserService {
applyOrderQuery.setLoanId(loanId); applyOrderQuery.setLoanId(loanId);
//申请订单查询 //申请订单查询
JsonResult<List<ApplyOrder>> applyOrders = xyqbService.findApplyOrders(applyOrderQuery); JsonResult<List<ApplyOrder>> applyOrders = xyqbService.findApplyOrders(applyOrderQuery);
if(!applyOrders.isSuccess()){ if (!applyOrders.isSuccess()) {
log.error("{} 获得申请订单失败 applyOrderQuery={} result={}",logPre,applyOrderQuery,applyOrders); log.error("{} 获得申请订单失败 applyOrderQuery={} result={}", logPre, applyOrderQuery, applyOrders);
return JsonResult.buildErrorStateResult("查询失败", null); return JsonResult.buildErrorStateResult("查询失败", null);
} }
if(CollectionUtils.isEmpty(applyOrders.getData())){ if (CollectionUtils.isEmpty(applyOrders.getData())) {
return JsonResult.buildErrorStateResult("无数据,请用其他参数查询", null); return JsonResult.buildErrorStateResult("请确认搜索条件后再查询", null);
} }
Long userId = applyOrders.getData().get(0).getUserId(); Long userId = applyOrders.getData().get(0).getUserId();
UserSysResult<XUser> userByUserId = userSdk.getService().findUserByUserId(userId);
UserSysResult<XUserDetail> userDetailByUserId = userSdk.getService().findUserDetailByUserId(userId); UserSysResult<XUserDetail> userDetailByUserId = userSdk.getService().findUserDetailByUserId(userId);
return getUserBasicInfoResult(userDetailByUserId); return getUserBasicInfoResult(userByUserId,userDetailByUserId);
} }
//走到这里申请订单号和借款订单号都为空, 渠道订单号和渠道号至少一个为空 //走到这里申请订单号和借款订单号都为空, 渠道订单号和渠道号至少一个为空
......
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