新政策

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