Browse Source

新政策

master
张彭杰 11 months ago
parent
commit
3bedd3c903
1 changed files with 24 additions and 3 deletions
  1. 27
      dating-agency-mall-server/src/main/java/com/qniao/dam/application/service/reward/RewardApplicationService.java

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

Loading…
Cancel
Save