From 6593bc3adac90c5a234a1b63e3fb2c5826846a13 Mon Sep 17 00:00:00 2001
From: Derran <zhangpengjie@qniao.cn>
Date: Mon, 28 Apr 2025 15:19:30 +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       | 18 ++++++++++++++----
 1 file changed, 14 insertions(+), 4 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 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);