From f3614f7b27c66dd549d4a8e53cd9ba444b735bcb Mon Sep 17 00:00:00 2001 From: Derran Date: Thu, 30 Apr 2026 14:58:47 +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 --- .../handler/gmpi/GuildMemberProfitItemEventHandler.java | 3 ++- .../handler/virtualaccount/VirtualAccountEventHandler.java | 5 ++++- 2 files changed, 6 insertions(+), 2 deletions(-) diff --git a/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/gmpi/GuildMemberProfitItemEventHandler.java b/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/gmpi/GuildMemberProfitItemEventHandler.java index db04620..af084a2 100644 --- a/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/gmpi/GuildMemberProfitItemEventHandler.java +++ b/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/gmpi/GuildMemberProfitItemEventHandler.java @@ -37,7 +37,8 @@ public class GuildMemberProfitItemEventHandler extends BaseApplicationService { TradeTypeEnum.LINK_MIC_REWARD.equals(event.getTradeType()) || TradeTypeEnum.CHANNEL_GIFT_REWARD.equals(event.getTradeType()) || TradeTypeEnum.ONE_ON_ONE_VOICE.equals(event.getTradeType()) || - TradeTypeEnum.ONE_ON_ONE_VIDEO.equals(event.getTradeType())) { + TradeTypeEnum.ONE_ON_ONE_VIDEO.equals(event.getTradeType()) || + TradeTypeEnum.RECOMMEND_GIFT_REWARD.equals(event.getTradeType())) { RevenueReward revenueReward = revenueRewardDao.selectById(event.getRevenueRewardId()); if (IdentityTypeEnum.INDIVIDUAL.equals(revenueReward.getIdentityType())) { LiveMatchmaker liveMatchmaker = liveMatchmakerQueryService.queryByUserId(revenueReward.getUserId()); diff --git a/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/virtualaccount/VirtualAccountEventHandler.java b/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/virtualaccount/VirtualAccountEventHandler.java index bb4828e..8023734 100644 --- a/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/virtualaccount/VirtualAccountEventHandler.java +++ b/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/virtualaccount/VirtualAccountEventHandler.java @@ -24,6 +24,7 @@ import com.qniao.das.domian.aggregate.recommendationrelation.entity.Recommendati import com.qniao.dau.domain.aggregate.livematchmaker.entity.LiveMatchmaker; import com.qniao.dau.domian.aggregate.lmar.constant.LiveMatchmakerTypeEnum; import com.qniao.domain.BaseApplicationService; +import com.qniao.domain.BaseDomainEvent; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Component; @@ -32,6 +33,7 @@ import javax.annotation.Resource; import java.math.BigDecimal; import java.math.RoundingMode; import java.util.Collections; +import java.util.List; import java.util.Objects; @Component @@ -103,7 +105,8 @@ public class VirtualAccountEventHandler extends BaseApplicationService { WalletAccountRecord walletAccountRecord = WalletAccountRecord.build(TradeTypeEnum.RECOMMEND_GIFT_REWARD, revenue, true, originalBalance, walletAccount.getTotalBalance()); walletAccount.setRecordList(Collections.singletonList(walletAccountRecord)); - acquireRevenueRewardDomainService.handle(revenueReward, walletAccount); + List eventList = acquireRevenueRewardDomainService.handle(revenueReward, walletAccount); + this.sendEvent(eventList); } } }