红娘直播任务

dating-agency-mall-server/src/main/java/com/qniao/dam/domain/service/virtualaccount/CostGiftRewardDomainService.java

@@ -1,5 +1,6 @@
 package com.qniao.dam.domain.service.virtualaccount;
 
+import cn.hutool.core.collection.CollUtil;
 import com.qniao.dam.domain.aggregate.order.OrderAggregate;
 import com.qniao.dam.domain.aggregate.order.entity.Order;
 import com.qniao.dam.domain.aggregate.revenuereward.RevenueRewardAggregate;
@@ -9,7 +10,9 @@ import com.qniao.dam.domain.aggregate.virtualaccount.VirtualAccountAggregate;
 import com.qniao.dam.domain.aggregate.virtualaccount.entity.VirtualAccount;
 import com.qniao.dam.domain.aggregate.walletaccount.WalletAccountAggregate;
 import com.qniao.dam.domain.aggregate.walletaccount.entity.WalletAccount;
+import com.qniao.dam.domian.aggregate.revenuereward.event.RevenueRewardRecordCreatedEvent;
 import com.qniao.domain.BaseDomainEvent;
+import com.qniao.framework.utils.TypeConvertUtils;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -53,6 +56,12 @@ public class CostGiftRewardDomainService {
             });
             walletAccountAggregate.save(walletAccount);
         }
+
+        if (CollUtil.isNotEmpty(revenueReward.getRecordList())){
+            revenueReward.getRecordList().forEach(record -> {
+                eventList.add(TypeConvertUtils.convert(record, RevenueRewardRecordCreatedEvent.class));
+            });
+        }
         return eventList;
     }