From 650748cc58d5fd7ed652f613cb4c97aaf1c077aa Mon Sep 17 00:00:00 2001
From: Derran <zhangpengjie@qniao.cn>
Date: Tue, 14 Jan 2025 17:25:47 +0800
Subject: [PATCH] =?UTF-8?q?=E6=8A=BD=E5=A5=96=E5=A5=96=E5=93=81=E6=B4=BB?=
 =?UTF-8?q?=E5=8A=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../handler/rpa/RafflePrizeActivityEventHandler.java          | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/rpa/RafflePrizeActivityEventHandler.java b/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/rpa/RafflePrizeActivityEventHandler.java
index f0aeb5e..2d0cef5 100644
--- a/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/rpa/RafflePrizeActivityEventHandler.java
+++ b/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);