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 ab33c54..59d9005 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 @@ -87,6 +87,7 @@ public class RewardApplicationService extends BaseApplicationService { private MatchmakerNoviceTaskProgressQueryService matchmakerNoviceTaskProgressQueryService; @Resource private FranchiseFeeProfitManagementAggregate franchiseFeeProfitManagementAggregate; + /** * 获得红娘推荐奖励 新政策 */ @@ -241,9 +242,9 @@ public class RewardApplicationService extends BaseApplicationService { } public void handleStoreRecommendMatchmakerFee(Long orgId, - String serviceProviderName, - BigDecimal franchiseFee, - RewardTypeEnum rewardType) { + String serviceProviderName, + BigDecimal franchiseFee, + RewardTypeEnum rewardType) { //服务商管理费 RewardConfig rewardConfig = rewardConfigQueryService.queryByRewardType(rewardType); RevenueReward revenueReward = revenueRewardQueryService.queryByOrgId(orgId); @@ -258,7 +259,16 @@ public class RewardApplicationService extends BaseApplicationService { revenueReward.setRecordList(Collections.singletonList(revenueRewardRecord)); //计算本次回本金额 revenueReward.handleRevenueReward(revenue); - revenueRewardAggregate.save(revenueReward); + + //钱包信息 + WalletAccount walletAccount = walletAccountQueryService.queryByType(orgId, IdentityTypeEnum.ORGANIZATION); + BigDecimal originalBalance = walletAccount.getTotalBalance(); + walletAccount.setAvailableBalance(walletAccount.getAvailableBalance().add(revenue)); + walletAccount.setTotalBalance(walletAccount.getAvailableBalance().add(walletAccount.getFrozenBalance())); + WalletAccountRecord record = WalletAccountRecord.build(TradeTypeEnum.MATCHMAKER_JOIN_RECOMMEND_FEE, revenue, true, originalBalance, walletAccount.getTotalBalance()); + walletAccount.setRecordList(Collections.singletonList(record)); + acquireRevenueRewardDomainService.handle(revenueReward, walletAccount); + //配置回本数据 RevenueRewardRecoveredRecord recoveredRecord = RevenueRewardRecoveredRecord.build(revenueReward.getId(), revenueRewardRecord.getId()); revenueRewardRecoveredRecordDao.insert(recoveredRecord);