红娘直播任务

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

@@ -1,6 +1,7 @@
 package com.qniao.dam.domain.service.virtualaccount;
 
 import cn.hutool.core.collection.CollUtil;
+import com.qniao.dam.domain.aggregate.revenuereward.RevenueRewardAggregate;
 import com.qniao.dam.domain.aggregate.revenuereward.entity.RevenueReward;
 import com.qniao.dam.domain.aggregate.virtualaccount.VirtualAccountAggregate;
 import com.qniao.dam.domain.aggregate.virtualaccount.entity.VirtualAccount;
@@ -24,6 +25,8 @@ public class SettleOneOnOneRtcDomainService {
     private VirtualAccountAggregate virtualAccountAggregate;
     @Resource
     private WalletAccountAggregate walletAccountAggregate;
+    @Resource
+    private RevenueRewardAggregate revenueRewardAggregate;
 
     @Transactional(rollbackFor = Exception.class)
     public List<BaseDomainEvent> handle(VirtualAccount virtualAccount,
@@ -32,7 +35,7 @@ public class SettleOneOnOneRtcDomainService {
         List<BaseDomainEvent> eventList = new ArrayList<>();
         virtualAccountAggregate.edit(virtualAccount);
         if (Objects.nonNull(walletAccount)) {
-            walletAccountAggregate.save(walletAccount);
+            revenueRewardAggregate.save(revenueReward);
 
             walletAccount.getRecordList().forEach(record -> {
                 record.setAssociateId(revenueReward.getRecordList().get(0).getId());