From 7cd5e4d9e5450aaf5617a1e69c14ceefb55c011b Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Thu, 24 Nov 2022 10:47:50 +0800
Subject: [PATCH] 20221117  挂机极差,以自己的等级为基准

---
 src/main/java/cc/mrbird/febs/dapp/service/impl/ApiIgtOnHookPlanServiceImpl.java |   45 ++++++++++++++++++++++++++++++++++++++-------
 1 files changed, 38 insertions(+), 7 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/dapp/service/impl/ApiIgtOnHookPlanServiceImpl.java b/src/main/java/cc/mrbird/febs/dapp/service/impl/ApiIgtOnHookPlanServiceImpl.java
index b2e4574..5e7f173 100644
--- a/src/main/java/cc/mrbird/febs/dapp/service/impl/ApiIgtOnHookPlanServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/dapp/service/impl/ApiIgtOnHookPlanServiceImpl.java
@@ -9,6 +9,7 @@
 import cc.mrbird.febs.dapp.dto.ApiStartDto;
 import cc.mrbird.febs.dapp.entity.*;
 import cc.mrbird.febs.dapp.enumerate.DataDictionaryEnum;
+import cc.mrbird.febs.dapp.enumerate.MemberLevelEnum;
 import cc.mrbird.febs.dapp.enumerate.MemberOnHookPlanEnum;
 import cc.mrbird.febs.dapp.mapper.*;
 import cc.mrbird.febs.dapp.service.ApiIgtOnHookPlanService;
@@ -191,13 +192,27 @@
 //                }
 //            }
 //        }
+
+        //根据上下级,筛选用户的级别
+        ArrayList<String> refererIdLisstUp = new ArrayList<>();
+//        String levelNext = MemberLevelEnum.LEVEL_MB.getType();
+        //自己挂机,初始级别即当前挂机人的级别
+        String levelNext = dappMemberEntity.getIdentity();
+        for(String inviteId : refererIdList){
+            DappMemberEntity dappMemberUp = dappMemberDao.selectMemberInfoByInviteId(inviteId);
+            String identityUp = dappMemberUp.getIdentity();
+            int compareLevelResult = MemberLevelEnum.LEVEL_MB.compareLevel(identityUp, levelNext);
+            if(0 < compareLevelResult){
+                levelNext = identityUp;
+                refererIdLisstUp.add(inviteId);
+            }
+        }
         //生成流水佣金和盈利分成和流水记录,返回剩余盈利
-        BigDecimal profitSharingTotal = dappWalletService.updateLSYJYLFC(refererIdList, totalProfit.multiply(new BigDecimal(0.4)),igtOnHookPlanOrder.getId());
-        //生成流水佣金和盈利分成和流水记录,返回盈利分成和流水佣金总共分成
-//        BigDecimal profitSharingTotal = dappWalletService.updateLSYJYLFC(refererIdList, totalProfit,igtOnHookPlanOrder.getId());
+        BigDecimal profitSharingTotal = dappWalletService.updateLSYJ(refererIdLisstUp, totalProfit,igtOnHookPlanOrder.getId());
+        BigDecimal profitFlowTotal = dappWalletService.updateYLFC(refererIdLisstUp, totalProfit,igtOnHookPlanOrder.getId());
         //平台分成
         //平台拿走35%盈利分成和流水佣金剩下的全部
-        BigDecimal systemAdd = totalProfit.multiply(new BigDecimal(0.4)).subtract(profitSharingTotal);
+        BigDecimal systemAdd = totalProfit.multiply(new BigDecimal(0.4)).subtract(profitSharingTotal).subtract(profitFlowTotal);
         BigDecimal systemTotal = dappWalletService.updatePTFC(memberId,systemAdd,igtOnHookPlanOrder.getId());
         //个人固定拿走60%
         totalProfit = totalProfit.multiply(new BigDecimal(0.6));
@@ -573,11 +588,27 @@
 //                }
 //            }
 //        }
+
+        //根据上下级,筛选用户的级别
+        ArrayList<String> refererIdLisstUp = new ArrayList<>();
+//        String levelNext = MemberLevelEnum.LEVEL_MB.getType();
+        //自己挂机,初始级别即当前挂机人的级别
+        String levelNext = dappMemberEntity.getIdentity();
+        for(String inviteId : refererIdList){
+            DappMemberEntity dappMemberUp = dappMemberDao.selectMemberInfoByInviteId(inviteId);
+            String identityUp = dappMemberUp.getIdentity();
+            int compareLevelResult = MemberLevelEnum.LEVEL_MB.compareLevel(identityUp, levelNext);
+            if(0 < compareLevelResult){
+                levelNext = identityUp;
+                refererIdLisstUp.add(inviteId);
+            }
+        }
         //生成流水佣金和盈利分成和流水记录,返回剩余盈利
-        BigDecimal profitSharingTotal = dappWalletService.updateLSYJYLFC(refererIdList, totalProfit.multiply(new BigDecimal(0.4)),igtOnHookPlanOrder.getId());
+        BigDecimal profitSharingTotal = dappWalletService.updateLSYJ(refererIdLisstUp, totalProfit,igtOnHookPlanOrder.getId());
+        BigDecimal profitFlowTotal = dappWalletService.updateYLFC(refererIdLisstUp, totalProfit,igtOnHookPlanOrder.getId());
         //平台分成
-        //平台拿走35%盈利分成和流水佣金剩下的全部
-        BigDecimal systemAdd = totalProfit.multiply(new BigDecimal(0.4)).subtract(profitSharingTotal);
+        //平台拿走40% - 盈利分成和流水佣金剩下的全部
+        BigDecimal systemAdd = totalProfit.multiply(new BigDecimal(0.4)).subtract(profitSharingTotal).subtract(profitFlowTotal);
         BigDecimal systemTotal = dappWalletService.updatePTFC(memberId,systemAdd,igtOnHookPlanOrder.getId());
         //个人固定拿走60%
         totalProfit = totalProfit.multiply(new BigDecimal(0.6));

--
Gitblit v1.9.1