抽奖奖品活动

dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/rpa/RafflePrizeActivityEventHandler.java

@@ -2,6 +2,7 @@ package com.qniao.dam.application.handler.rpa;
 
 import com.google.common.eventbus.Subscribe;
 import com.qniao.dam.domain.aggregate.rpa.entity.RafflePrizeActivity;
+import com.qniao.dam.domain.aggregate.rpaw.RafflePrizeActivityWinningAggregate;
 import com.qniao.dam.domain.aggregate.rpaw.entity.RafflePrizeActivityWinning;
 import com.qniao.dam.domian.aggregate.matchmaker.event.MatchmakerFranchiseFeeRewardEvent;
 import com.qniao.dam.domian.aggregate.rpa.constant.RafflePrizeActivityConditionEnum;
@@ -23,6 +24,8 @@ public class RafflePrizeActivityEventHandler extends BaseApplicationService {
     private RafflePrizeActivityQueryService rafflePrizeActivityQueryService;
     @Resource
     private MatchmakerDao matchmakerDao;
+    @Resource
+    private RafflePrizeActivityWinningAggregate rafflePrizeActivityWinningAggregate;
 
     /**
      * 红娘邀请入驻奖励事件
@@ -44,6 +47,7 @@ public class RafflePrizeActivityEventHandler extends BaseApplicationService {
                 winning.setIsDraw(false);
                 winning.setMaxReward(event.getStayFranchiseFee().stripTrailingZeros().toPlainString());
                 winning.setRemark(matchmaker.getType().getDesc() + matchmaker.getName() + "邀请" + event.getReceiveLevel().getDesc() + event.getReceiveUserName() + "加盟,加盟费" + event.getFranchiseFee());
+                rafflePrizeActivityWinningAggregate.create(winning);
             }
         } catch (Exception e) {
             log.error("红娘邀请入驻奖励事件处理异常", e);