Skip to content

K
ka-code-generator
Commit e786cdd5 authored by 王向伟's avatar 王向伟
Browse files
Options

EventHandler代码格式化

parent 5339af9b
Hide whitespace changes
Inline Side-by-side
Showing with 357 additions and 385 deletions
src/main/resources/templates/code-generator/eventhandler/EventHandler.ftl
View file @ e786cdd5
...@@ -46,465 +46,437 @@ import java.util.*; ...@@ -46,465 +46,437 @@ import java.util.*;
@Service @Service
@Slf4j @Slf4j
public class ${prefix}EventHandler extends AbstractEventHandler implements IEventHandler { public class ${prefix}EventHandler extends AbstractEventHandler implements IEventHandler {
@Autowired @Autowired
private ILoanOrderMappingService orderMappingService; private ILoanOrderMappingService orderMappingService;
@Autowired @Autowired
private IUserMappingService userMappingService; private IUserMappingService userMappingService;
@Autowired @Autowired
private LoanMappingService loanMappingService; private LoanMappingService loanMappingService;
@Autowired @Autowired
private IRepayFlowNoMappingRepository repayFlowNoMappingRepository; private IRepayFlowNoMappingRepository repayFlowNoMappingRepository;
@Resource(name = "standardApplicationMoService") @Resource(name = "standardApplicationMoService")
private StandardApplicationService standardApplicationService; private StandardApplicationService standardApplicationService;
@Override @Override
public void creditSuccessPublish(CreditSuccessEvent creditSuccEvent) { public void creditSuccessPublish(CreditSuccessEvent creditSuccEvent) {
String logPrefix = "[notify][handler][creditSuccEvent]"; String logPrefix = "[notify][handler][creditSuccEvent]";
log.info("{},不处理进件同步成功事件,消息内容:{}", logPrefix, creditSuccEvent); log.info("{},不处理进件同步成功事件,消息内容:{}", logPrefix, creditSuccEvent);
} }
@Override @Override
public void auditRejectPublish(AuditRejectEvent auditRejectEvent) { public void auditRejectPublish(AuditRejectEvent auditRejectEvent) {
String logPrefix = "[${prefix}EventHandler][auditRejectPublish]"; String logPrefix = "[${prefix}EventHandler][auditRejectPublish]";
log.info("{},${prefix},审核拒绝事件,消息内容:{}", logPrefix, auditRejectEvent); log.info("{},${prefix},审核拒绝事件,消息内容:{}", logPrefix, auditRejectEvent);
QuotaNoticeExtraDto extraDto = auditRejectEvent.getQueueNotice(); QuotaNoticeExtraDto extraDto = auditRejectEvent.getQueueNotice();
Long channelId = auditRejectEvent.getChannelId(); Long channelId = auditRejectEvent.getChannelId();
KANoticeType noticeType = auditRejectEvent.getNoticeType(); KANoticeType noticeType = auditRejectEvent.getNoticeType();
String applyNo = extraDto.getData().getApplyNo(); String applyNo = extraDto.getData().getApplyNo();
String channelOrderNo = auditRejectEvent.getChannelOrderNo(); String channelOrderNo = auditRejectEvent.getChannelOrderNo();
Long nextApplyTime = auditRejectEvent.getNextApplyTime(); Long nextApplyTime = auditRejectEvent.getNextApplyTime();
String reason = auditRejectEvent.getReason(); String reason = auditRejectEvent.getReason();
String callbackUrl = getOrderCallbackUrl(channelId, noticeType); String callbackUrl = getOrderCallbackUrl(channelId, noticeType);
if (StringUtils.isEmpty(callbackUrl)) { if (StringUtils.isEmpty(callbackUrl)) {
log.error("{},回调地址无配置,channelId:{},applyNo:{},noticeType:{}", logPrefix, channelId, applyNo, noticeType.name()); log.error("{},回调地址无配置,channelId:{},applyNo:{},noticeType:{}", logPrefix, channelId, applyNo, noticeType.name());
throw new CommonBizException("回调地址无配置"); throw new CommonBizException("回调地址无配置");
} }
LoanOrderMapping orderMapping = getOrderMapping(channelOrderNo, channelId); LoanOrderMapping orderMapping = getOrderMapping(channelOrderNo, channelId);
Long userId = orderMapping.getQgUserId(); Long userId = orderMapping.getQgUserId();
UserMapping userMapping = getUserMapping(userId, channelId); UserMapping userMapping = getUserMapping(userId, channelId);
String channelUserId = userMapping.getChannelUserId(); String channelUserId = userMapping.getChannelUserId();
Map Map<String, String> callbackParam = new HashMap<>();
<String, String> callbackParam = new HashMap<>(); QueueNotice queueNotice = new QueueNotice(noticeType, extraDto);
QueueNotice queueNotice = new QueueNotice(noticeType, extraDto); publishTask(callbackParam, callbackUrl, queueNotice);
publishTask(callbackParam, callbackUrl, queueNotice); }
}
@Override @Override
public void auditPassPublish(AuditPassEvent auditPassEvent) { public void auditPassPublish(AuditPassEvent auditPassEvent) {
String logPrefix = "[${prefix}EventHandler][auditPassPublish]"; String logPrefix = "[${prefix}EventHandler][auditPassPublish]";
log.info("{},审核通过事件,消息内容:{}", logPrefix, auditPassEvent); log.info("{},审核通过事件,消息内容:{}", logPrefix, auditPassEvent);
QuotaNoticeExtraDto extraDto = auditPassEvent.getQueueNotice(); QuotaNoticeExtraDto extraDto = auditPassEvent.getQueueNotice();
Long channelId = auditPassEvent.getChannelId(); Long channelId = auditPassEvent.getChannelId();
KANoticeType noticeType = auditPassEvent.getNoticeType(); KANoticeType noticeType = auditPassEvent.getNoticeType();
String applyNo = extraDto.getData().getApplyNo(); String applyNo = extraDto.getData().getApplyNo();
String channelOrderNo = auditPassEvent.getChannelOrderNo(); String channelOrderNo = auditPassEvent.getChannelOrderNo();
String callbackUrl = getOrderCallbackUrl(channelId, noticeType); String callbackUrl = getOrderCallbackUrl(channelId, noticeType);
if (StringUtils.isEmpty(callbackUrl)) { if (StringUtils.isEmpty(callbackUrl)) {
log.error("{},回调地址无配置,channelId:{},applyNo:{},noticeType:{}", logPrefix, channelId, applyNo, noticeType.name()); log.error("{},回调地址无配置,channelId:{},applyNo:{},noticeType:{}", logPrefix, channelId, applyNo, noticeType.name());
throw new CommonBizException("回调地址无配置"); throw new CommonBizException("回调地址无配置");
} }
LoanOrderMapping orderMapping = getOrderMapping(channelOrderNo, channelId); LoanOrderMapping orderMapping = getOrderMapping(channelOrderNo, channelId);
Long userId = orderMapping.getQgUserId(); Long userId = orderMapping.getQgUserId();
UserMapping userMapping = getUserMapping(userId, channelId); UserMapping userMapping = getUserMapping(userId, channelId);
String channelUserId = userMapping.getChannelUserId(); String channelUserId = userMapping.getChannelUserId();
ChannelOrder channelOrderQueryCreditStatus = ChannelOrder.builder()
.channelOrderNo(channelOrderNo)
.channelId(channelId)
.build();
ServiceResult
<QueryCreditStatusResponseModel> creditStatus =
standardApplicationService.queryCreditStatus(channelOrderQueryCreditStatus);
log.info("{} 授信结果查询返回信息 creditStatus={}，orderNo={}", logPrefix, creditStatus, channelOrderNo);
QueryCreditStatusResponseModel creditInfo;
if (Objects.isNull(creditStatus) || !creditStatus.isSuccess() || Objects.isNull(creditInfo =
creditStatus.getData())) {
log.error("{},审批通过推送,查询授信结果失败或无数据,orderNo={},applyNo={}", logPrefix, channelOrderNo, applyNo);
throw new CommonBizException("审批推送,查询授信结果失败或无数据");
}
ChannelOrder channelOrderQueryCreditStatus = ChannelOrder.builder()
.channelOrderNo(channelOrderNo)
.channelId(channelId)
.build();
ServiceResult<QueryCreditStatusResponseModel> creditStatus =
standardApplicationService.queryCreditStatus(channelOrderQueryCreditStatus);
log.info("{} 授信结果查询返回信息 creditStatus={}，orderNo={}", logPrefix, creditStatus, channelOrderNo);
QueryCreditStatusResponseModel creditInfo;
if (Objects.isNull(creditStatus) || !creditStatus.isSuccess() || Objects.isNull(creditInfo = creditStatus.getData())) {
log.error("{},审批通过推送,查询授信结果失败或无数据,orderNo={},applyNo={}", logPrefix, channelOrderNo, applyNo);
throw new CommonBizException("审批推送,查询授信结果失败或无数据");
}
Map
<String
, String> callbackParam = new HashMap<>();
QueueNotice queueNotice = new QueueNotice(noticeType, extraDto);
publishTask(callbackParam, callbackUrl, queueNotice); Map<String, String> callbackParam = new HashMap<>();
QueueNotice queueNotice = new QueueNotice(noticeType, extraDto);
publishTask(callbackParam, callbackUrl, queueNotice);
} }
@Override @Override
public void withdrawPublish(WithdrawEvent withdrawEvent) { public void withdrawPublish(WithdrawEvent withdrawEvent) {
String logPrefix = "[${prefix}EventHandler][withdrawPublish]"; String logPrefix = "[${prefix}EventHandler][withdrawPublish]";
log.info("{},不处理申请提现成功事件,消息内容:{}", logPrefix, withdrawEvent); log.info("{},不处理申请提现成功事件,消息内容:{}", logPrefix, withdrawEvent);
} }
@Override @Override
public void fundSuccessPublish(FundSuccessEvent fundSuccessEvent) { public void fundSuccessPublish(FundSuccessEvent fundSuccessEvent) {
String logPrefix = "[${prefix}EventHandler][fundSuccessPublish]"; String logPrefix = "[${prefix}EventHandler][fundSuccessPublish]";
log.info("{},放款成功事件,消息内容:{}", logPrefix, fundSuccessEvent); log.info("{},放款成功事件,消息内容:{}", logPrefix, fundSuccessEvent);
QuotaNoticeExtraDto extraDto = fundSuccessEvent.getQueueNotice(); QuotaNoticeExtraDto extraDto = fundSuccessEvent.getQueueNotice();
Long channelId = fundSuccessEvent.getChannelId(); Long channelId = fundSuccessEvent.getChannelId();
Long loanId = fundSuccessEvent.getLoanId(); Long loanId = fundSuccessEvent.getLoanId();
KANoticeType noticeType = fundSuccessEvent.getNoticeType(); KANoticeType noticeType = fundSuccessEvent.getNoticeType();
String applyNo = extraDto.getData().getApplyNo(); String applyNo = extraDto.getData().getApplyNo();
String channelOrderNo = fundSuccessEvent.getChannelOrderNo(); String channelOrderNo = fundSuccessEvent.getChannelOrderNo();
String callbackUrl = getOrderCallbackUrl(channelId, noticeType); String callbackUrl = getOrderCallbackUrl(channelId, noticeType);
if (StringUtils.isEmpty(callbackUrl)) { if (StringUtils.isEmpty(callbackUrl)) {
log.error("{},回调地址无配置,channelId:{},applyNo:{},noticeType:{}", logPrefix, channelId, applyNo, noticeType.name()); log.error("{},回调地址无配置,channelId:{},applyNo:{},noticeType:{}", logPrefix, channelId, applyNo, noticeType.name());
throw new CommonBizException("回调地址无配置"); throw new CommonBizException("回调地址无配置");
} }
LoanOrderMapping orderMapping = getOrderMapping(channelOrderNo, channelId);
Long userId = orderMapping.getQgUserId();
UserMapping userMapping = getUserMapping(userId, channelId); LoanOrderMapping orderMapping = getOrderMapping(channelOrderNo, channelId);
String channelUserId = userMapping.getChannelUserId(); Long userId = orderMapping.getQgUserId();
LoanMapping loanMapping = loanMappingService.findByLoanIdAndChannelId(loanId, channelId); UserMapping userMapping = getUserMapping(userId, channelId);
if (Objects.isNull(loanMapping)) { String channelUserId = userMapping.getChannelUserId();
log.error("{}通过loanId查询LoanMapping为空, loanId={}, channelId={}", logPrefix, loanId, channelId);
throw new CommonBizException("通过loanId查询LoanMapping为空");
}
String channelLoanNo = loanMapping.getChannelLoanNo(); LoanMapping loanMapping = loanMappingService.findByLoanIdAndChannelId(loanId, channelId);
if (Objects.isNull(loanMapping)) {
log.error("{}通过loanId查询LoanMapping为空, loanId={}, channelId={}", logPrefix, loanId, channelId);
throw new CommonBizException("通过loanId查询LoanMapping为空");
}
Map String channelLoanNo = loanMapping.getChannelLoanNo();
<String
, String> callbackParam = new HashMap<>();
QueueNotice queueNotice = new QueueNotice(noticeType, extraDto);
publishTask(callbackParam, callbackUrl, queueNotice); Map<String, String> callbackParam = new HashMap<>();
QueueNotice queueNotice = new QueueNotice(noticeType, extraDto);
publishTask(callbackParam, callbackUrl, queueNotice);
} }
@Override @Override
public void fundFailPublish(FundFailEvent fundFailEvent) { public void fundFailPublish(FundFailEvent fundFailEvent) {
String logPrefix = "[${prefix}EventHandler][fundFailPublish]"; String logPrefix = "[${prefix}EventHandler][fundFailPublish]";
log.info("{},放款失败事件,消息内容:{}", logPrefix, fundFailEvent); log.info("{},放款失败事件,消息内容:{}", logPrefix, fundFailEvent);
QuotaNoticeExtraDto extraDto = fundFailEvent.getQueueNotice(); QuotaNoticeExtraDto extraDto = fundFailEvent.getQueueNotice();
Long channelId = fundFailEvent.getChannelId(); Long channelId = fundFailEvent.getChannelId();
Long loanId = fundFailEvent.getLoanId(); Long loanId = fundFailEvent.getLoanId();
KANoticeType noticeType = fundFailEvent.getNoticeType(); KANoticeType noticeType = fundFailEvent.getNoticeType();
String applyNo = extraDto.getData().getApplyNo(); String applyNo = extraDto.getData().getApplyNo();
String channelOrderNo = fundFailEvent.getChannelOrderNo(); String channelOrderNo = fundFailEvent.getChannelOrderNo();
Long changeTime = fundFailEvent.getChangeTime(); Long changeTime = fundFailEvent.getChangeTime();
String reason = fundFailEvent.getReason(); String reason = fundFailEvent.getReason();
String callbackUrl = getOrderCallbackUrl(channelId, noticeType); String callbackUrl = getOrderCallbackUrl(channelId, noticeType);
if (StringUtils.isEmpty(callbackUrl)) { if (StringUtils.isEmpty(callbackUrl)) {
log.error("{},回调地址无配置,channelId:{},applyNo:{},noticeType:{}", logPrefix, channelId, applyNo, noticeType.name()); log.error("{},回调地址无配置,channelId:{},applyNo:{},noticeType:{}", logPrefix, channelId, applyNo, noticeType.name());
throw new CommonBizException("回调地址无配置"); throw new CommonBizException("回调地址无配置");
} }
LoanOrderMapping orderMapping = getOrderMapping(channelOrderNo, channelId); LoanOrderMapping orderMapping = getOrderMapping(channelOrderNo, channelId);
Long userId = orderMapping.getQgUserId(); Long userId = orderMapping.getQgUserId();
UserMapping userMapping = getUserMapping(userId, channelId); UserMapping userMapping = getUserMapping(userId, channelId);
String channelUserId = userMapping.getChannelUserId(); String channelUserId = userMapping.getChannelUserId();
LoanMapping loanMapping = loanMappingService.findByLoanIdAndChannelId(loanId, channelId); LoanMapping loanMapping = loanMappingService.findByLoanIdAndChannelId(loanId, channelId);
if (Objects.isNull(loanMapping)) { if (Objects.isNull(loanMapping)) {
log.error("{}通过loanId查询LoanMapping为空, loanId={}, channelId={}", logPrefix, loanId, channelId); log.error("{}通过loanId查询LoanMapping为空, loanId={}, channelId={}", logPrefix, loanId, channelId);
throw new CommonBizException("通过loanId查询LoanMapping为空"); throw new CommonBizException("通过loanId查询LoanMapping为空");
} }
String channelLoanNo = loanMapping.getChannelLoanNo(); String channelLoanNo = loanMapping.getChannelLoanNo();
Map Map<String, String> callbackParam = new HashMap<>();
<String QueueNotice queueNotice = new QueueNotice(noticeType, extraDto);
, String> callbackParam = new HashMap<>(); publishTask(callbackParam, callbackUrl, queueNotice);
QueueNotice queueNotice = new QueueNotice(noticeType, extraDto);
publishTask(callbackParam, callbackUrl, queueNotice);
} }
@Override @Override
public void cancelLoanPublish(CancelLoanEvent cancelLoanEvent) { public void cancelLoanPublish(CancelLoanEvent cancelLoanEvent) {
String logPrefix = "[${prefix}EventHandler][cancelLoanPublish]"; String logPrefix = "[${prefix}EventHandler][cancelLoanPublish]";
log.info("{},贷前关单事件,消息内容:{}", logPrefix, cancelLoanEvent); log.info("{},贷前关单事件,消息内容:{}", logPrefix, cancelLoanEvent);
QuotaNoticeExtraDto extraDto = cancelLoanEvent.getQueueNotice(); QuotaNoticeExtraDto extraDto = cancelLoanEvent.getQueueNotice();
Long channelId = cancelLoanEvent.getChannelId(); Long channelId = cancelLoanEvent.getChannelId();
String channelOrderNo = cancelLoanEvent.getChannelOrderNo(); String channelOrderNo = cancelLoanEvent.getChannelOrderNo();
Long closeTime = cancelLoanEvent.getChangeTime(); Long closeTime = cancelLoanEvent.getChangeTime();
KANoticeType noticeType = cancelLoanEvent.getNoticeType(); KANoticeType noticeType = cancelLoanEvent.getNoticeType();
String applyNo = extraDto.getData().getApplyNo(); String applyNo = extraDto.getData().getApplyNo();
String callbackUrl = getOrderCallbackUrl(channelId, noticeType); String callbackUrl = getOrderCallbackUrl(channelId, noticeType);
if (StringUtils.isEmpty(callbackUrl)) { if (StringUtils.isEmpty(callbackUrl)) {
log.error("{},回调地址无配置,channelId:{},applyNo:{},noticeType:{}", logPrefix, channelId, applyNo, noticeType.name()); log.error("{},回调地址无配置,channelId:{},applyNo:{},noticeType:{}", logPrefix, channelId, applyNo, noticeType.name());
throw new CommonBizException("回调地址无配置"); throw new CommonBizException("回调地址无配置");
} }
LoanOrderMapping orderMapping = getOrderMapping(channelOrderNo, channelId); LoanOrderMapping orderMapping = getOrderMapping(channelOrderNo, channelId);
Long userId = orderMapping.getQgUserId(); Long userId = orderMapping.getQgUserId();
UserMapping userMapping = getUserMapping(userId, channelId); UserMapping userMapping = getUserMapping(userId, channelId);
String channelUserId = userMapping.getChannelUserId(); String channelUserId = userMapping.getChannelUserId();
Map Map<String, String> callbackParam = new HashMap<>();
<String QueueNotice queueNotice = new QueueNotice(noticeType, extraDto);
, String> callbackParam = new HashMap<>(); publishTask(callbackParam, callbackUrl, queueNotice);
QueueNotice queueNotice = new QueueNotice(noticeType, extraDto);
publishTask(callbackParam, callbackUrl, queueNotice);
} }
@Override @Override
public void settleUpPublish(SettleUpEvent settleUpEvent) { public void settleUpPublish(SettleUpEvent settleUpEvent) {
String logPrefix = "[${prefix}EventHandler][settleUpPublish]"; String logPrefix = "[${prefix}EventHandler][settleUpPublish]";
log.info("{},结清事件,消息内容:{}", logPrefix, settleUpEvent); log.info("{},结清事件,消息内容:{}", logPrefix, settleUpEvent);
QuotaNoticeExtraDto extraDto = settleUpEvent.getQueueNotice(); QuotaNoticeExtraDto extraDto = settleUpEvent.getQueueNotice();
Long channelId = settleUpEvent.getChannelId(); Long channelId = settleUpEvent.getChannelId();
String channelOrderNo = settleUpEvent.getChannelOrderNo(); String channelOrderNo = settleUpEvent.getChannelOrderNo();
Long changeTime = settleUpEvent.getChangeTime(); Long changeTime = settleUpEvent.getChangeTime();
KANoticeType noticeType = settleUpEvent.getNoticeType(); KANoticeType noticeType = settleUpEvent.getNoticeType();
Long loanId = settleUpEvent.getLoanId(); Long loanId = settleUpEvent.getLoanId();
String applyNo = extraDto.getData().getApplyNo(); String applyNo = extraDto.getData().getApplyNo();
String callbackUrl = getOrderCallbackUrl(channelId, noticeType); String callbackUrl = getOrderCallbackUrl(channelId, noticeType);
if (StringUtils.isEmpty(callbackUrl)) { if (StringUtils.isEmpty(callbackUrl)) {
log.error("{},回调地址无配置,channelId:{},loanId:{},noticeType:{}", logPrefix, channelId, loanId, noticeType.name()); log.error("{},回调地址无配置,channelId:{},loanId:{},noticeType:{}", logPrefix, channelId, loanId, noticeType.name());
throw new CommonBizException("回调地址无配置"); throw new CommonBizException("回调地址无配置");
} }
LoanOrderMapping orderMapping = getOrderMapping(channelOrderNo, channelId); LoanOrderMapping orderMapping = getOrderMapping(channelOrderNo, channelId);
Long userId = orderMapping.getQgUserId(); Long userId = orderMapping.getQgUserId();
UserMapping userMapping = getUserMapping(userId, channelId); UserMapping userMapping = getUserMapping(userId, channelId);
String channelUserId = userMapping.getChannelUserId(); String channelUserId = userMapping.getChannelUserId();
Map Map<String, String> callbackParam = new HashMap<>();
<String QueueNotice queueNotice = new QueueNotice(noticeType, extraDto);
, String> callbackParam = new HashMap<>(); publishTask(callbackParam, callbackUrl, queueNotice);
QueueNotice queueNotice = new QueueNotice(noticeType, extraDto);
publishTask(callbackParam, callbackUrl, queueNotice);
processSettleUp(settleUpEvent); processSettleUp(settleUpEvent);
} }
@Override @Override
public void repaySuccessPublish(RepaySuccessEvent repaySuccessEvent) { public void repaySuccessPublish(RepaySuccessEvent repaySuccessEvent) {
String logPrefix = "[${prefix}EventHandler][repaySuccessPublish]"; String logPrefix = "[${prefix}EventHandler][repaySuccessPublish]";
log.info("{},还款成功事件,消息内容:{}", logPrefix, repaySuccessEvent); log.info("{},还款成功事件,消息内容:{}", logPrefix, repaySuccessEvent);
QuotaNoticeExtraDto extraDto = repaySuccessEvent.getQueueNotice(); QuotaNoticeExtraDto extraDto = repaySuccessEvent.getQueueNotice();
Long channelId = repaySuccessEvent.getChannelId(); Long channelId = repaySuccessEvent.getChannelId();
Long loanId = repaySuccessEvent.getLoanId(); Long loanId = repaySuccessEvent.getLoanId();
KANoticeType noticeType = repaySuccessEvent.getNoticeType(); KANoticeType noticeType = repaySuccessEvent.getNoticeType();
String applyNo = extraDto.getData().getApplyNo(); String applyNo = extraDto.getData().getApplyNo();
String channelOrderNo = repaySuccessEvent.getChannelOrderNo(); String channelOrderNo = repaySuccessEvent.getChannelOrderNo();
String businessFlowNo = repaySuccessEvent.getBusinessFlowNo(); String businessFlowNo = repaySuccessEvent.getBusinessFlowNo();
String callbackUrl = getOrderCallbackUrl(channelId, noticeType); String callbackUrl = getOrderCallbackUrl(channelId, noticeType);
if (StringUtils.isEmpty(callbackUrl)) { if (StringUtils.isEmpty(callbackUrl)) {
log.error("{},回调地址无配置,channelId:{},applyNo:{},noticeType:{}", logPrefix, channelId, applyNo, noticeType.name()); log.error("{},回调地址无配置,channelId:{},applyNo:{},noticeType:{}", logPrefix, channelId, applyNo, noticeType.name());
throw new CommonBizException("回调地址无配置"); throw new CommonBizException("回调地址无配置");
} }
LoanOrderMapping orderMapping = getOrderMapping(channelOrderNo, channelId); LoanOrderMapping orderMapping = getOrderMapping(channelOrderNo, channelId);
Long userId = orderMapping.getQgUserId(); Long userId = orderMapping.getQgUserId();
UserMapping userMapping = getUserMapping(userId, channelId); UserMapping userMapping = getUserMapping(userId, channelId);
String channelUserId = userMapping.getChannelUserId(); String channelUserId = userMapping.getChannelUserId();
// 查询借据信息 // 查询借据信息
LoanMapping loanMapping = loanMappingService.findByLoanIdAndChannelId(loanId, channelId); LoanMapping loanMapping = loanMappingService.findByLoanIdAndChannelId(loanId, channelId);
if (Objects.isNull(loanMapping)) { if (Objects.isNull(loanMapping)) {
log.error("{}通过loanId查询LoanMapping为空, loanId={}, channelId={}", logPrefix, loanId, channelId); log.error("{}通过loanId查询LoanMapping为空, loanId={}, channelId={}", logPrefix, loanId, channelId);
throw new CommonBizException("通过loanId查询LoanMapping为空"); throw new CommonBizException("通过loanId查询LoanMapping为空");
} }
String channelLoanNo = loanMapping.getChannelLoanNo(); String channelLoanNo = loanMapping.getChannelLoanNo();
// 查询渠道的还款流水号 // 查询渠道的还款流水号
String channelRepaymentNo = null; String channelRepaymentNo = null;
BigDecimal repaymentAmount = null; BigDecimal repaymentAmount = null;
RepayFlowNoMapping repayFlowNoMapping = repayFlowNoMappingRepository.findByXyqbRepayFlowNoOne(businessFlowNo); RepayFlowNoMapping repayFlowNoMapping = repayFlowNoMappingRepository.findByXyqbRepayFlowNoOne(businessFlowNo);
if (Objects.nonNull(repayFlowNoMapping)) { if (Objects.nonNull(repayFlowNoMapping)) {
channelRepaymentNo = repayFlowNoMapping.getChannelRepayFlowNo(); channelRepaymentNo = repayFlowNoMapping.getChannelRepayFlowNo();
repaymentAmount = new BigDecimal(repayFlowNoMapping.getRepayAmount()); repaymentAmount = new BigDecimal(repayFlowNoMapping.getRepayAmount());
} }
// 查询还款计划 // 查询还款计划
ServiceResult ServiceResult
<OrderRepaymentRepresentation> serviceResult = standardApplicationService.repaymentPlanQueryByCycleQuota(loanId); <OrderRepaymentRepresentation> serviceResult = standardApplicationService.repaymentPlanQueryByCycleQuota(loanId);
log.info("{} 查询还款计划结果 serviceResult={}，orderNo={}", logPrefix, serviceResult, channelOrderNo); log.info("{} 查询还款计划结果 serviceResult={}，orderNo={}", logPrefix, serviceResult, channelOrderNo);
if (Objects.isNull(serviceResult) || !serviceResult.isSuccess() || Objects.isNull(serviceResult.getData())) { if (Objects.isNull(serviceResult) || !serviceResult.isSuccess() || Objects.isNull(serviceResult.getData())) {
log.error("{},还款成功推送,查询还款计划返回错误或无数据,orderNo={},applyNo={}", logPrefix, channelOrderNo, applyNo); log.error("{},还款成功推送,查询还款计划返回错误或无数据,orderNo={},applyNo={}", logPrefix, channelOrderNo, applyNo);
throw new CommonBizException("还款成功,查询还款计划返回错误或无数据"); throw new CommonBizException("还款成功,查询还款计划返回错误或无数据");
} }
List List<RepaymentPlanItem> repaymentPlans = serviceResult.getData().getRepaymentPlans();
<RepaymentPlanItem> repaymentPlans = serviceResult.getData().getRepaymentPlans();
Map<String, String> callbackParam = new HashMap<>();
Map QueueNotice queueNotice = new QueueNotice(noticeType, extraDto);
<String publishTask(callbackParam, callbackUrl, queueNotice);
, String> callbackParam = new HashMap<>(); super.processRepay(repaySuccessEvent.getQueueNotice());
QueueNotice queueNotice = new QueueNotice(noticeType, extraDto); }
publishTask(callbackParam, callbackUrl, queueNotice);
super.processRepay(repaySuccessEvent.getQueueNotice()); @Override
} public void repayFailPublish(RepayFailEvent repayFailEvent) {
String logPrefix = "[${prefix}EventHandler][repayFailPublish]";
@Override log.info("{},还款失败事件,消息内容:{}", logPrefix, repayFailEvent);
public void repayFailPublish(RepayFailEvent repayFailEvent) { QuotaNoticeExtraDto extraDto = repayFailEvent.getQueueNotice();
String logPrefix = "[${prefix}EventHandler][repayFailPublish]"; String businessFlowNo = repayFailEvent.getBusinessFlowNo();
log.info("{},还款失败事件,消息内容:{}", logPrefix, repayFailEvent); String failMsg = repayFailEvent.getFailMsg();
QuotaNoticeExtraDto extraDto = repayFailEvent.getQueueNotice(); String channelOrderNo = repayFailEvent.getChannelOrderNo();
String businessFlowNo = repayFailEvent.getBusinessFlowNo(); Long channelId = repayFailEvent.getChannelId();
String failMsg = repayFailEvent.getFailMsg(); KANoticeType noticeType = repayFailEvent.getNoticeType();
String channelOrderNo = repayFailEvent.getChannelOrderNo(); String applyNo = extraDto.getData().getApplyNo();
Long channelId = repayFailEvent.getChannelId();
KANoticeType noticeType = repayFailEvent.getNoticeType(); String callbackUrl = getOrderCallbackUrl(channelId, noticeType);
String applyNo = extraDto.getData().getApplyNo(); if (StringUtils.isEmpty(callbackUrl)) {
log.error("{},回调地址无配置,channelId:{},applyNo:{},noticeType:{}", logPrefix, channelId, applyNo,noticeType.name());
String callbackUrl = getOrderCallbackUrl(channelId, noticeType);
if (StringUtils.isEmpty(callbackUrl)) {
log.error("{},回调地址无配置,channelId:{},applyNo:{},noticeType:{}", logPrefix, channelId, applyNo,
noticeType.name());
throw new CommonBizException("回调地址无配置"); throw new CommonBizException("回调地址无配置");
} }
LoanOrderMapping orderMapping = getOrderMapping(channelOrderNo, channelId); LoanOrderMapping orderMapping = getOrderMapping(channelOrderNo, channelId);
Long userId = orderMapping.getQgUserId(); Long userId = orderMapping.getQgUserId();
UserMapping userMapping = getUserMapping(userId, channelId); UserMapping userMapping = getUserMapping(userId, channelId);
String channelUserId = userMapping.getChannelUserId(); String channelUserId = userMapping.getChannelUserId();
// 根据核心系统还款流水号查询渠道的还款流水号 // 根据核心系统还款流水号查询渠道的还款流水号
String channelRepayFlowNo = null; String channelRepayFlowNo = null;
BigDecimal repaymentAmount = null; BigDecimal repaymentAmount = null;
RepayFlowNoMapping repayFlowNoMapping = RepayFlowNoMapping repayFlowNoMapping =
repayFlowNoMappingRepository.findByXyqbRepayFlowNoOne(businessFlowNo); repayFlowNoMappingRepository.findByXyqbRepayFlowNoOne(businessFlowNo);
if (Objects.nonNull(repayFlowNoMapping)) { if (Objects.nonNull(repayFlowNoMapping)) {
channelRepayFlowNo = repayFlowNoMapping.getChannelRepayFlowNo(); channelRepayFlowNo = repayFlowNoMapping.getChannelRepayFlowNo();
repaymentAmount = new BigDecimal(repayFlowNoMapping.getRepayAmount()); repaymentAmount = new BigDecimal(repayFlowNoMapping.getRepayAmount());
} }
Map Map<String, String> callbackParam = new HashMap<>();
<String QueueNotice queueNotice = new QueueNotice(noticeType, extraDto);
, String> callbackParam = new HashMap<>(); publishTask(callbackParam, callbackUrl, queueNotice);
QueueNotice queueNotice = new QueueNotice(noticeType, extraDto); super.processRepay(repayFailEvent.getQueueNotice());
publishTask(callbackParam, callbackUrl, queueNotice); }
super.processRepay(repayFailEvent.getQueueNotice());
}
@Override
public void cancelAfterLoanPublish(CancelAfterLoanEvent cancelAfterLoanEvent) {
@Override String logPrefix = "[${prefix}EventHandler][cancelAfterLoanPublish]";
public void cancelAfterLoanPublish(CancelAfterLoanEvent cancelAfterLoanEvent) { log.info("{},不处理贷后关单事件,消息内容:{}", logPrefix, cancelAfterLoanEvent);
String logPrefix = "[${prefix}EventHandler][cancelAfterLoanPublish]";
log.info("{},不处理贷后关单事件,消息内容:{}", logPrefix, cancelAfterLoanEvent); }
} @Override
public void dropCourseSuccessPublish(DropCourseSuccessEvent dropCourseSuccEvent) {
@Override String logPrefix = "[${prefix}EventHandler][dropCourseSuccessPublish]";
public void dropCourseSuccessPublish(DropCourseSuccessEvent dropCourseSuccEvent) { log.info("{},不处理退课事件,消息内容:{}", logPrefix, dropCourseSuccEvent);
String logPrefix = "[${prefix}EventHandler][dropCourseSuccessPublish]"; }
log.info("{},不处理退课事件,消息内容:{}", logPrefix, dropCourseSuccEvent);
} @Override
public void addBankCardPublish(AddBankCardEvent addBankCardEvent) {
@Override String logPrefix = "[${prefix}EventHandler][addBankCardEvent]";
public void addBankCardPublish(AddBankCardEvent addBankCardEvent) { log.info("{},不处理添加卡事件,消息内容:{}", logPrefix, addBankCardEvent);
String logPrefix = "[${prefix}EventHandler][addBankCardEvent]"; }
log.info("{},不处理添加卡事件,消息内容:{}", logPrefix, addBankCardEvent);
} @Override
public void bindCardPublish(BindCardEvent bindCardEvent) {
@Override String logPrefix = "[${prefix}EventHandler][bindCardEvent]";
public void bindCardPublish(BindCardEvent bindCardEvent) { log.info("{},不处理绑卡事件,消息内容:{}", logPrefix, bindCardEvent);
String logPrefix = "[${prefix}EventHandler][bindCardEvent]"; }
log.info("{},不处理绑卡事件,消息内容:{}", logPrefix, bindCardEvent);
} /**
* 根据channelOrderNo,channelId 查询出渠道授信订单
/** *
* 根据channelOrderNo,channelId 查询出渠道授信订单 * @param channelOrderNo
* * @param channelId
* @param channelOrderNo * @return
* @param channelId */
* @return private LoanOrderMapping getOrderMapping(String channelOrderNo, Long channelId) {
*/ LoanOrderMapping orderMapping = orderMappingService.findByChannelOrderNoAndRegisteredFromLastOne(channelOrderNo, channelId);
private LoanOrderMapping getOrderMapping(String channelOrderNo, Long channelId) { if (Objects.isNull(orderMapping)) {
LoanOrderMapping orderMapping =
orderMappingService.findByChannelOrderNoAndRegisteredFromLastOne(channelOrderNo, channelId);
if (Objects.isNull(orderMapping)) {
log.error("${prefix}渠道回调通知，查询授信订单为空, channelOrderNo={}, channelId={}", channelOrderNo, channelId); log.error("${prefix}渠道回调通知，查询授信订单为空, channelOrderNo={}, channelId={}", channelOrderNo, channelId);
throw new CommonBizException("查询授信订单为空"); throw new CommonBizException("查询授信订单为空");
} }
return orderMapping; return orderMapping;
} }
/** /**
* 根据userId,channelId 查询UserMapping * 根据userId,channelId 查询UserMapping
* *
* @param userId * @param userId
* @param channelId * @param channelId
* @return * @return
*/ */
private UserMapping getUserMapping(Long userId, Long channelId) { private UserMapping getUserMapping(Long userId, Long channelId) {
UserMapping userMapping = userMappingService.findByQgUserIdAndRegisteredFrom(userId, channelId); UserMapping userMapping = userMappingService.findByQgUserIdAndRegisteredFrom(userId, channelId);
if (Objects.isNull(userMapping)) { if (Objects.isNull(userMapping)) {
log.error("${prefix}渠道回调通知，通过qgUserId查询渠道用户id为空, qgUserId={}, channelId={}", userId, channelId); log.error("${prefix}渠道回调通知，通过qgUserId查询渠道用户id为空, qgUserId={}, channelId={}", userId, channelId);
throw new CommonBizException("通过qgUserId查询渠道用户id为空"); throw new CommonBizException("通过qgUserId查询渠道用户id为空");
} }
return userMapping; return userMapping;
} }
/** /**
* 发布任务 * 发布任务
* *
* @param paraMap * @param paraMap
* @param url * @param url
* @param queueNotice * @param queueNotice
*/ */
private void publishTask(Map private void publishTask(Map<String , String> paraMap, String url, QueueNotice queueNotice) {
<String log.info("[publishTask],发送消息内容:{},url地址:{},ka消息体:{}", paraMap, url, queueNotice);
, String> paraMap, String url, QueueNotice queueNotice) { HttpTaskBody taskBody = this.buildTaskBody(paraMap, url, queueNotice);
log.info("[publishTask],发送消息内容:{},url地址:{},ka消息体:{}", paraMap, url, queueNotice); log.info("[publishTask],taskBody:{}", taskBody);
HttpTaskBody taskBody = this.buildTaskBody(paraMap, url, queueNotice); AsyncTask asyncTask = super.buildPublishTask(BizAppId.CHANNEL_NOTIFY, queueNotice);
log.info("[publishTask],taskBody:{}", taskBody); log.info("[publishTask],asyncTask:{}", asyncTask);
AsyncTask asyncTask = super.buildPublishTask(BizAppId.CHANNEL_NOTIFY, queueNotice); asyncTask.setTaskBody(taskBody);
log.info("[publishTask],asyncTask:{}", asyncTask); super.publishAsyncTask(asyncTask, queueNotice);
asyncTask.setTaskBody(taskBody); }
super.publishAsyncTask(asyncTask, queueNotice);
} /**
* 构建推送TaskBody
/** *
* 构建推送TaskBody * @param paraMap
* * @param url
* @param paraMap * @param queueNotice
* @param url * @return
* @param queueNotice */
* @return private HttpTaskBody buildTaskBody(Map<String , String> paraMap, String url, QueueNotice queueNotice) {
*/ JSONObject jsonObject = new JSONObject();
private HttpTaskBody buildTaskBody(Map jsonObject.put("", "");
<String String assetRule = jsonObject.toJSONString();
, String> paraMap, String url, QueueNotice queueNotice) {
JSONObject jsonObject = new JSONObject(); Map<String , String> header = new HashMap<>(2);
jsonObject.put("", ""); header.put("Content-Type", "");
String assetRule = jsonObject.toJSONString(); HttpTaskBody taskBody = new HttpTaskBody();
taskBody.setHeaders(header);
Map taskBody.setUrl(url);
<String taskBody.setParams(paraMap);
, String> header = new HashMap<>(2); taskBody.setAssertRule(assetRule);
header.put("Content-Type", ""); taskBody.setQueueNotice(queueNotice);
HttpTaskBody taskBody = new HttpTaskBody(); return taskBody;
taskBody.setHeaders(header); }
taskBody.setUrl(url);
taskBody.setParams(paraMap);
taskBody.setAssertRule(assetRule); }
taskBody.setQueueNotice(queueNotice);
return taskBody;
}
}
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