From e832c0e8069aa0969e253095cc3be681b6ce5363 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Tue, 10 Jan 2023 18:10:09 +0800
Subject: [PATCH] 20221227 充值归集

---
 src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java |   31 +++++++++++++++++--------------
 1 files changed, 17 insertions(+), 14 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java b/src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java
index 73282bc..b4373f0 100644
--- a/src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java
@@ -194,8 +194,7 @@
                 MallMoneyFlowTypeEnum.MARKET_SUBSIDIES.getName()
         );
 
-//        memberWalletService.addBalance(subsidyAmount.setScale(4, BigDecimal.ROUND_DOWN),mallMember.getId());
-        memberWalletService.add(subsidyAmount.setScale(4, BigDecimal.ROUND_DOWN), mallMember.getId(), "balance");
+        memberWalletService.addBalance(subsidyAmount.setScale(2, BigDecimal.ROUND_DOWN),mallMember.getId());
 
         /**
          * 生成直推返利的流水记录
@@ -209,6 +208,9 @@
          *  2、返利对象:下单人的直推上级 10%,直推的直推 5%
          *  3、金额:补贴金额乘以分享奖励的比例
          */
+        if(StrUtil.isEmpty(mallMember.getReferrerId())){
+            return;
+        }
         //下单人的直推上级
         MallMember mallMemberOne = memberMapper.selectInfoByInviteId(mallMember.getReferrerId());
         //生成直推返利的流水记录
@@ -231,11 +233,7 @@
                     FlowTypeEnum.BALANCE.getValue(),
                     MallMoneyFlowTypeEnum.DIRECT_REWARD.getName()
             );
-
-//            memberWalletService.addBalance(directRewardAmount,mallMemberOne.getId());
-
-            memberWalletService.add(directRewardAmount, mallMemberOne.getId(), "balance");
-
+            memberWalletService.addBalance(directRewardAmount,mallMemberOne.getId());
             DataDictionaryCustom shareOneDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                     DataDictionaryEnum.LEVEL_ONE.getType(),
                     DataDictionaryEnum.LEVEL_ONE.getCode()
@@ -254,8 +252,11 @@
                     FlowTypeEnum.BALANCE.getValue(),
                     MallMoneyFlowTypeEnum.SHARE_REWARD_ONE.getName()
             );
-//            memberWalletService.addBalance(shareOneAmount,mallMemberOne.getId());
-            memberWalletService.add(shareOneAmount, mallMemberOne.getId(), "balance");
+            memberWalletService.addBalance(shareOneAmount,mallMemberOne.getId());
+        }
+
+        if(StrUtil.isEmpty(mallMemberOne.getReferrerId())){
+            return;
         }
         //下单人的直推上级的直推
         MallMember mallMemberTwo = memberMapper.selectInfoByInviteId(mallMemberOne.getReferrerId());
@@ -277,12 +278,16 @@
                     FlowTypeEnum.BALANCE.getValue(),
                     MallMoneyFlowTypeEnum.SHARE_REWARD_TWO.getName()
             );
-//            memberWalletService.addBalance(shareTwoAmount,mallMemberTwo.getId());
-            memberWalletService.add(shareTwoAmount, mallMemberTwo.getId(), "balance");
+            memberWalletService.addBalance(shareTwoAmount,mallMemberTwo.getId());
         }
         /**
          * 团队管理补贴
          */
+
+
+        if(StrUtil.isEmpty(mallMember.getReferrerIds())){
+            return;
+        }
         //下单人所有的上级
         String referrerIds = mallMember.getReferrerIds();
         List<String> refererIdList = StrUtil.split(referrerIds, ",", -1, true, true);
@@ -327,9 +332,7 @@
                             MallMoneyFlowTypeEnum.TEAM_REWARD.getName()
                     );
 
-//                    memberWalletService.addBalance(teamManageAmount,mallMemberUp.getId());
-
-                    memberWalletService.add(teamManageAmount, mallMemberUp.getId(), "balance");
+                    memberWalletService.addBalance(teamManageAmount,mallMemberUp.getId());
                 }
                 levelStart = levelUp;
             }

--
Gitblit v1.9.1