红娘直播任务

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

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<BaseDomainEvent> eventList = acquireRevenueRewardDomainService.handle(revenueReward, walletAccount);
+                        this.sendEvent(eventList);
                     }
                 }
             }