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