From 65e7a6b7b8d48db0649b2c48bdea43d22ec5afc3 Mon Sep 17 00:00:00 2001 From: Derran Date: Mon, 6 Jan 2025 16:39:43 +0800 Subject: [PATCH] =?UTF-8?q?=E7=BA=A2=E5=A8=98=E7=BB=AD=E8=B4=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../MarriageBountyOrderEventHandle.java | 27 ++++++++++--------- 1 file changed, 15 insertions(+), 12 deletions(-) diff --git a/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/marriagebounty/MarriageBountyOrderEventHandle.java b/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/marriagebounty/MarriageBountyOrderEventHandle.java index d982a7f..67a18cc 100644 --- a/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/marriagebounty/MarriageBountyOrderEventHandle.java +++ b/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); }