红娘直播任务

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;
     }
 }