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); } } }