diff --git a/dating-agency-mall-server/src/main/java/com/qniao/dam/domain/service/virtualaccount/SettleOneOnOneRtcDomainService.java b/dating-agency-mall-server/src/main/java/com/qniao/dam/domain/service/virtualaccount/SettleOneOnOneRtcDomainService.java index d43a7a8..33f1fd6 100644 --- a/dating-agency-mall-server/src/main/java/com/qniao/dam/domain/service/virtualaccount/SettleOneOnOneRtcDomainService.java +++ b/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 handle(VirtualAccount virtualAccount, @@ -32,7 +35,7 @@ public class SettleOneOnOneRtcDomainService { List 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());