红娘续费

dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/marriagebounty/MarriageBountyOrderEventHandle.java

@@ -83,19 +83,22 @@ public class MarriageBountyOrderEventHandle extends BaseApplicationService {
     @Subscribe
     public void handle2(MarriageBountyOrderCreatedEvent event) {
         try {
-            MarriageInformation marriageInformation = marriageInformationDao.selectById(event.getMiId());
-            MarriageBountyOrder marriageBountyOrder = marriageBountyOrderDao.selectById(event.getId());
-            PointRewardCreatedMQ mq = new PointRewardCreatedMQ();
             Matchmaker matchmaker = matchmakerDao.selectById(event.getMatchmakerId());
-            mq.setOwnId(matchmaker.getUserId());
-            mq.setIdentityType(IdentityTypeEnum.INDIVIDUAL);
-            mq.setPointType(PointRewardConfigTypeEnum.INVITE_BOUNTY);
-            mq.setContent("邀请发榜：" + marriageInformation.getNickName() + "榜单");
-            mq.setIsIncome(true);
-            mq.setAssociateId(event.getId());
-            mq.setAmount(marriageBountyOrder.getPaidAmount());
-            // 发送mq事件
-            amqpTemplate.convertAndSend(MqExchange.POINT_REWARD_CREATED, null, mq);
+            //邀请红娘在有效期内才能拿到佣金+积分奖励
+            if (Objects.nonNull(matchmaker) && matchmaker.checkEnable()) {
+                MarriageInformation marriageInformation = marriageInformationDao.selectById(event.getMiId());
+                MarriageBountyOrder marriageBountyOrder = marriageBountyOrderDao.selectById(event.getId());
+                PointRewardCreatedMQ mq = new PointRewardCreatedMQ();
+                mq.setOwnId(matchmaker.getUserId());
+                mq.setIdentityType(IdentityTypeEnum.INDIVIDUAL);
+                mq.setPointType(PointRewardConfigTypeEnum.INVITE_BOUNTY);
+                mq.setContent("邀请发榜：" + marriageInformation.getNickName() + "榜单");
+                mq.setIsIncome(true);
+                mq.setAssociateId(event.getId());
+                mq.setAmount(marriageBountyOrder.getPaidAmount());
+                // 发送mq事件
+                amqpTemplate.convertAndSend(MqExchange.POINT_REWARD_CREATED, null, mq);
+            }
         } catch (Exception e) {
             log.error("悬赏招亲订单已创建事件处理异常", e);
         }