From 8a8cb6fbb9fc744a10faffee1b83145f7d013e60 Mon Sep 17 00:00:00 2001 From: Derran Date: Thu, 30 Apr 2026 14:17:52 +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/SettleOneOnOneRtcDomainService.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) 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());