diff --git a/dating-agency-mall-server/src/main/java/com/qniao/dam/domain/service/virtualaccount/CostGiftRewardDomainService.java b/dating-agency-mall-server/src/main/java/com/qniao/dam/domain/service/virtualaccount/CostGiftRewardDomainService.java index 9ec14db..a6a82ee 100644 --- a/dating-agency-mall-server/src/main/java/com/qniao/dam/domain/service/virtualaccount/CostGiftRewardDomainService.java +++ b/dating-agency-mall-server/src/main/java/com/qniao/dam/domain/service/virtualaccount/CostGiftRewardDomainService.java @@ -90,6 +90,12 @@ public class CostGiftRewardDomainService { walletAccountAggregate.save(toWalletAccount); } + if (CollUtil.isNotEmpty(toWalletAccount.getRecordList())){ + toWalletAccount.getRecordList().forEach(record -> { + eventList.add(TypeConvertUtils.convert(record, RevenueRewardRecordCreatedEvent.class)); + }); + } + RevenueRewardAssociateOrderRecord anchorAssociateOrderRecord = RevenueRewardAssociateOrderRecord.build(order.getId(), order.getSettlementAmount()); anchorRevenueReward.getRecordList().get(0).setAssociateOrderRecordList(Collections.singletonList(anchorAssociateOrderRecord)); revenueRewardAggregate.save(anchorRevenueReward); @@ -100,6 +106,12 @@ public class CostGiftRewardDomainService { }); walletAccountAggregate.save(anchorWalletAccount); } + + if (CollUtil.isNotEmpty(anchorWalletAccount.getRecordList())){ + anchorWalletAccount.getRecordList().forEach(record -> { + eventList.add(TypeConvertUtils.convert(record, RevenueRewardRecordCreatedEvent.class)); + }); + } return eventList; } }