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