From 4f2925f343401b81cdbafdb6c79501aae83ad421 Mon Sep 17 00:00:00 2001 From: Derran Date: Wed, 29 Apr 2026 18:29:59 +0800 Subject: [PATCH] =?UTF-8?q?=E7=BA=A2=E5=A8=98=E7=9B=B4=E6=92=AD=E4=BB=BB?= =?UTF-8?q?=E5=8A=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../virtualaccount/CostGiftRewardDomainService.java | 12 ++++++++++++ 1 file changed, 12 insertions(+) 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; } }