From 9cf47e10044ecb29669dec48d8b649b4fb46898f Mon Sep 17 00:00:00 2001
From: Hentua <wangdoubleone@gmail.com>
Date: Sun, 04 Jun 2023 00:51:54 +0800
Subject: [PATCH] fix

---
 src/main/java/cc/mrbird/febs/mall/service/impl/MemberProfitServiceImpl.java |   28 +++++++++++++++++++---------
 1 files changed, 19 insertions(+), 9 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/mall/service/impl/MemberProfitServiceImpl.java b/src/main/java/cc/mrbird/febs/mall/service/impl/MemberProfitServiceImpl.java
index dca2275..d087269 100644
--- a/src/main/java/cc/mrbird/febs/mall/service/impl/MemberProfitServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/mall/service/impl/MemberProfitServiceImpl.java
@@ -38,6 +38,7 @@
     private final DataDictionaryCustomMapper dataDictionaryCustomMapper;
 
     private final MallSystemSettingMapper mallSystemSettingMapper;
+    private final IAdminMallMemberService adminMallMemberService;
 
     /**
      * 直推收益
@@ -141,7 +142,7 @@
                     continue;
                 }
 
-                List<MallMember> mallMembers = mallMemberMapper.selectParentMemberList(StrUtil.split(parentMember.getReferrerIds(), ','), parentMember.getReferrerId(), 2);
+                List<MallMember> mallMembers = adminMallMemberService.findParentMemberList(StrUtil.split(parentMember.getReferrerIds(), ','), 2, true);
                 if (CollUtil.isEmpty(mallMembers)) {
                     continue;
                 }
@@ -152,10 +153,10 @@
                         break;
                     }
 
-                    if (index != 2) {
+                    if (index == 2) {
                         indirectPerDic = indirectPerTwoDic;
                     }
-                    BigDecimal doubleParentProfit = profit.multiply(new BigDecimal(indirectPerDic.getValue()));
+                    BigDecimal doubleParentProfit = amount.multiply(new BigDecimal(indirectPerDic.getValue()).divide(new BigDecimal(100), 2, RoundingMode.HALF_UP));
                     changeScoreAndCommission(mallMember.getId(), doubleParentProfit, MoneyFlowTypeEnum.DIRECT_BONUS.getValue(), orderInfo.getOrderNo());
                     index++;
                 }
@@ -168,7 +169,7 @@
             }
 
             List<String> parents = StrUtil.split(parentMember.getReferrerIds(), ',');
-            List<MallMember> members = mallMemberMapper.selectByInviteIds(parents);
+            List<MallMember> members = adminMallMemberService.findParentMemberList(parents, null, true);
             if (CollUtil.isEmpty(members)) {
                 return;
             }
@@ -340,8 +341,15 @@
             return;
         }
 
+        BigDecimal bonus = BigDecimal.ZERO;
+        if (AccountLevelEnums.VVIP.getLevel().equals(type)) {
+            bonus = systemSetting.getAgentBonus();
+        } else {
+            bonus = systemSetting.getPartnerBonus();
+        }
+
         // 代理
-        BigDecimal waitToBonus = systemSetting.getAgentBonus().multiply(new BigDecimal(dic.getValue()).divide(hundred, 2, RoundingMode.HALF_UP));
+        BigDecimal waitToBonus = bonus.multiply(new BigDecimal(dic.getValue()).divide(hundred, 2, RoundingMode.HALF_UP));
 
         // 代理
         List<MallMember> mallMembers = mallMemberMapper.selectAgentOrPartnetMemberList(type);
@@ -356,9 +364,9 @@
         });
 
         if (type.equals(AccountLevelEnums.VVIP.getLevel())) {
-            changeSystemBonus(null, waitToBonus,null);
+            changeSystemBonus(null, waitToBonus.negate(),null);
         } else {
-            changeSystemBonus(null, null, waitToBonus);
+            changeSystemBonus(null, null, waitToBonus.negate());
         }
 
         bonusRecord(waitToBonus, type, null, null);
@@ -432,7 +440,7 @@
             }
 
             memberList.add(item);
-            levelMemberMap.put(item.getLevel(), memberList);
+            levelMemberMap.put(level, memberList);
         });
 
         if (levelMemberMap.isEmpty()) {
@@ -456,7 +464,9 @@
             totalBonus = totalBonus.add(levelBonus);
         }
 
-        changeSystemBonus(totalBonus, null, null);
+        changeSystemBonus(totalBonus.negate(), null, null);
+
+        bonusRecord(totalBonus, 1, null, null);
         log.info("###全网分红执行--end--###");
     }
 

--
Gitblit v1.9.1