From 3bedd3c903582a2dfdc2ef27b3fea1be126796ef Mon Sep 17 00:00:00 2001 From: Derran Date: Fri, 25 Apr 2025 16:31:06 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E6=94=BF=E7=AD=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../reward/RewardApplicationService.java | 27 ++++++++++++++++--- 1 file changed, 24 insertions(+), 3 deletions(-) diff --git a/dating-agency-mall-server/src/main/java/com/qniao/dam/application/service/reward/RewardApplicationService.java b/dating-agency-mall-server/src/main/java/com/qniao/dam/application/service/reward/RewardApplicationService.java index 1f61cc0..27a6abb 100644 --- a/dating-agency-mall-server/src/main/java/com/qniao/dam/application/service/reward/RewardApplicationService.java +++ b/dating-agency-mall-server/src/main/java/com/qniao/dam/application/service/reward/RewardApplicationService.java @@ -174,11 +174,23 @@ public class RewardApplicationService extends BaseApplicationService { //未回本 拿100% 20%推荐费+50%门店费用+ 30%回本补贴 handleStoreRecommendMatchmakerFee(store.getOrgId(), dto.getReceiveUserName(), rewardAmount, RewardTypeEnum.OPERATING_RECOMMEND_50); handleStoreRecommendMatchmakerFee(store.getOrgId(), dto.getReceiveUserName(), rewardAmount, RewardTypeEnum.PAYBACK_SUBSIDY_30); + + //发送事件 检查是否满足回本要求 + RevenueRewardUpdatedEvent storeReEvent = new RevenueRewardUpdatedEvent(storeRevenueReward.getId()); + this.sendEvent(storeReEvent); } else { //回本后 拿70% 20%推荐费+50%门店费用 handleStoreRecommendMatchmakerFee(store.getOrgId(), dto.getReceiveUserName(), rewardAmount, RewardTypeEnum.OPERATING_RECOMMEND_50); + //发送事件 检查是否满足回本要求 + RevenueRewardUpdatedEvent storeReEvent = new RevenueRewardUpdatedEvent(storeRevenueReward.getId()); + this.sendEvent(storeReEvent); + //区域分润 handleStoreRecommendMatchmakerFee(store.getOperationCenterOrgId(), dto.getReceiveUserName(), rewardAmount, RewardTypeEnum.SERVICE_PROVIDER_MANAGEMENT_FEE); + //发送事件 检查是否满足回本要求 + RevenueReward OperationCenterRevenueReward = revenueRewardQueryService.queryByOrgId(store.getOrgId()); + RevenueRewardUpdatedEvent OperationCenterReEvent = new RevenueRewardUpdatedEvent(OperationCenterRevenueReward.getId()); + this.sendEvent(OperationCenterReEvent); } } else { //红娘推荐的话 @@ -194,11 +206,22 @@ public class RewardApplicationService extends BaseApplicationService { //未回本 门店拿50% + 30%回本补贴 handleStoreRecommendMatchmakerFee(store.getOrgId(), dto.getReceiveUserName(), rewardAmount, RewardTypeEnum.OPERATING_RECOMMEND_50); handleStoreRecommendMatchmakerFee(store.getOrgId(), dto.getReceiveUserName(), rewardAmount, RewardTypeEnum.PAYBACK_SUBSIDY_30); + //发送事件 检查是否满足回本要求 + RevenueRewardUpdatedEvent storeReEvent = new RevenueRewardUpdatedEvent(storeRevenueReward.getId()); + this.sendEvent(storeReEvent); } else { //已回本 门店拿50% handleStoreRecommendMatchmakerFee(store.getOrgId(), dto.getReceiveUserName(), rewardAmount, RewardTypeEnum.OPERATING_RECOMMEND_50); + //发送事件 检查是否满足回本要求 + RevenueRewardUpdatedEvent storeReEvent = new RevenueRewardUpdatedEvent(storeRevenueReward.getId()); + this.sendEvent(storeReEvent); + //区域分润 handleStoreRecommendMatchmakerFee(store.getOperationCenterOrgId(), dto.getReceiveUserName(), rewardAmount, RewardTypeEnum.SERVICE_PROVIDER_MANAGEMENT_FEE); + //发送事件 检查是否满足回本要求 + RevenueReward OperationCenterRevenueReward = revenueRewardQueryService.queryByOrgId(store.getOrgId()); + RevenueRewardUpdatedEvent OperationCenterReEvent = new RevenueRewardUpdatedEvent(OperationCenterRevenueReward.getId()); + this.sendEvent(OperationCenterReEvent); } } else { // 红娘未完成 记录到 入驻费分佣管理中 @@ -207,6 +230,7 @@ public class RewardApplicationService extends BaseApplicationService { dto.getAssociateOrderId()); franchiseFeeProfitManagementAggregate.create(franchiseFeeProfitManagement); + //发送事件，通知新手任务 MatchmakerInvitedMQ matchmakerInvitedMQ = new MatchmakerInvitedMQ(); matchmakerInvitedMQ.setInitiatorMatchmakerUserId(dto.getInitiatorUserId()); matchmakerInvitedMQ.setReceiveMatchmakerType(dto.getMatchmakerType()); @@ -242,9 +266,6 @@ public class RewardApplicationService extends BaseApplicationService { if (revenueReward.getAllRecoveryRequirement()) { revenueRewardApplicationService.pipeLineRevenue(orgId, revenueRewardRecord, TradeSceneEnum.OFFLINE); } - //发送事件 检查是否满足回本要求 - RevenueRewardUpdatedEvent reEvent = new RevenueRewardUpdatedEvent(revenueReward.getId()); - this.sendEvent(reEvent); }