From 6a0baf02bb1cc4b7d1d0e9d796ead2218ed9c824 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Thu, 13 Jun 2024 15:48:56 +0800
Subject: [PATCH] 星级矩阵

---
 src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java |   26 ++++++++++++++++++++++----
 1 files changed, 22 insertions(+), 4 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java
index bd152c4..83c7abc 100644
--- a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java
@@ -218,8 +218,12 @@
 
         //如果添加的为右节点,那么进入判断
         if(DbMemberNode.STATE_TWO == dbMemberNode.getLeftRight()){
+            //更新父节点的右节点
+            dbMemberNodeOld.setRightNode(dbMemberNode.getId());
+            dbMemberNodeMapper.updateById(dbMemberNodeOld);
+
             //父节点为右节点,那么进入判断,父节点是否有上级节点
-            int leftRight = ObjectUtil.isEmpty(dbMemberNodeOld.getLeftNode()) ? 1 : 2;
+            int leftRight = ObjectUtil.isEmpty(dbMemberNodeOld.getLeftRight()) ? 1 : dbMemberNodeOld.getLeftRight();
             if(DbMemberNode.STATE_TWO == leftRight){
                 if(ObjectUtil.isEmpty(dbMemberNodeOld.getParentNode())){
                     return;
@@ -239,6 +243,9 @@
                 return;
             }
         }else{
+            //更新父节点的左节点
+            dbMemberNodeOld.setLeftNode(dbMemberNode.getId());
+            dbMemberNodeMapper.updateById(dbMemberNodeOld);
             //如果添加的为左节点,那么没人出局
             return;
         }
@@ -250,10 +257,12 @@
      */
     public void memberNodeNext(DbMemberNode dbMemberNodeRoot) {
         log.info("进入复投");
+
         DataDictionaryCustom inviteNumDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                 DataDictionaryEnum.INVITE_NUM.getType(),
                 DataDictionaryEnum.INVITE_NUM.getCode()
         );
+
         int inviteNum = Integer.parseInt(inviteNumDic.getValue());
 
         Long memberId = dbMemberNodeRoot.getMemberId();
@@ -268,6 +277,9 @@
         if(inviteNum > dappMemberEntities.size()){
             return;
         }
+        //任何星级的原来节点都要出局
+        dbMemberNodeRoot.setWorkState(DbMemberNode.STATE_TWO);
+        dbMemberNodeMapper.updateById(dbMemberNodeRoot);
         //任何星级,10轮,收益本金都返回
         Integer countFund = dbMemberNodeRoot.getCountFund();
         //收益
@@ -275,9 +287,6 @@
         if(10 == countFund){//任何星级,10轮,收益本金都返回
             BigDecimal add = dbMemberNodeRoot.getAmount().add(perkAmount);
             perkSevenTeen(memberId,add,countFund);
-
-            dbMemberNodeRoot.setWorkState(DbMemberNode.STATE_TWO);
-            dbMemberNodeMapper.updateById(dbMemberNodeRoot);
 
             return;
         }else{
@@ -373,6 +382,15 @@
         }
         dbMemberNode.setWorkState(1);
         dbMemberNodeMapper.insert(dbMemberNode);
+
+        if(ObjectUtil.isNotEmpty(dbMemberNodeOld)){
+            if(dbMemberNode.getLeftRight() == 1){
+                dbMemberNodeOld.setLeftNode(dbMemberNode.getId());
+            }else{
+                dbMemberNodeOld.setRightNode(dbMemberNode.getId());
+            }
+            dbMemberNodeMapper.updateById(dbMemberNodeOld);
+        }
     }
 
 

--
Gitblit v1.9.1