From db250c3d66df6aec085ccb7001ef30938445d971 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Tue, 01 Nov 2022 11:43:37 +0800
Subject: [PATCH] 20221021

---
 src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java |  129 +++++++++++++++++++++++++++++++++++-------
 1 files changed, 106 insertions(+), 23 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java
index 1acda06..e843221 100644
--- a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java
@@ -28,6 +28,7 @@
 import cn.hutool.core.date.DateUnit;
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
 import cn.hutool.crypto.SecureUtil;
 import cn.hutool.json.JSONUtil;
 import com.baomidou.mybatisplus.core.conditions.Wrapper;
@@ -67,6 +68,7 @@
     private final DappMemberService dappMemberService;
     private final MemberCoinWithdrawDao memberCoinWithdrawDao;
     private final IgtOnHookPlanOrderItemDao igtOnHookPlanOrderItemdao;
+    private final DappBankDao dappBankDao;
 
     private final RedisTemplate<String, Object> redisTemplate;
 
@@ -602,9 +604,9 @@
         //提现次数
         DataDictionaryCustom withdrawTimesDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.WITHDRAW_TIMES.getType(), DataDictionaryEnum.WITHDRAW_TIMES.getCode());
         Integer withdrawTimes = Integer.parseInt(withdrawTimesDic.getValue());
-        Integer withdrawTimesReal = memberCoinWithdrawDao.selectByMemberIdAndCreateTime(memberIdOut,DateUtil.format(DateUtil.date(),"yyyy-MM-dd"));
+        Integer withdrawTimesReal = memberCoinWithdrawDao.selectByMemberIdAndCreateTime(memberIdOut,DateUtil.format(DateUtil.date(),"yyyy-MM-dd"),"Y");
         if(withdrawTimesReal >= withdrawTimes){
-            return new FebsResponse().fail().message(MessageSourceUtils.getString("member_err_004"));
+            return new FebsResponse().fail().message(MessageSourceUtils.getString("member_err_0016"));
         }
         //转出账户,余额减少,冻结增加
         Integer countOut = dappWalletCoinDao.addFrozenAndDelAvailableById(dappWalletCoinEntityOut.getId(), balance);
@@ -668,6 +670,12 @@
         if(BigDecimal.ZERO.compareTo(balance) >= 0){
             return new FebsResponse().fail().message(MessageSourceUtils.getString("balance_err_001"));
         }
+        DataDictionaryCustom withDrawDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.WITHDRAW_MAX.getType()
+                , DataDictionaryEnum.WITHDRAW_MAX.getCode());
+        BigDecimal withDrawMax = withDrawDic.getValue() == null ? new BigDecimal("100") : new BigDecimal(withDrawDic.getValue());
+        if(withDrawMax.compareTo(balance) > 0){
+            return new FebsResponse().fail().message(MessageSourceUtils.getString("balance_err_003"));
+        }
         DappWalletCoinEntity dappWalletCoinEntity = dappWalletCoinDao.selectByMemberId(memberId);
         BigDecimal availableAmount = dappWalletCoinEntity.getAvailableAmount();
         if(balance.compareTo(availableAmount) > 0){
@@ -698,8 +706,13 @@
             }
         }
         //(2)每24小时只能提现一次
-        Integer withdrawTimesReal = memberCoinWithdrawDao.selectByMemberIdAndCreateTime(memberId,DateUtil.format(DateUtil.date(),"yyyy-MM-dd"));
-        if(1 > withdrawTimesReal){
+        // 提现次数
+        DataDictionaryCustom withdrawOutTimesDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.WITHDRAW_OUT_TIMES.getType()
+                , DataDictionaryEnum.WITHDRAW_OUT_TIMES.getCode());
+        String withdrawOutTimesStr = withdrawOutTimesDic.getValue() == null ? "1" : withdrawOutTimesDic.getValue();
+        int withdrawOutTimes = Integer.parseInt(withdrawOutTimesStr);
+        Integer withdrawTimesReal = memberCoinWithdrawDao.selectByMemberIdAndCreateTime(memberId,DateUtil.format(DateUtil.date(),"yyyy-MM-dd"),"N");
+        if(withdrawOutTimes <= withdrawTimesReal){
             return new FebsResponse().fail().message(MessageSourceUtils.getString("member_err_0014"));
         }
 
@@ -711,13 +724,14 @@
         DataDictionaryCustom serviceFeeDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.SERVICE_FEE.getType(), DataDictionaryEnum.SERVICE_FEE.getCode());
         BigDecimal serviceFee = new BigDecimal(serviceFeeDic.getValue());
 
-        //转出账户生成一条内部转账记录
+        //转出账户生成一条记录
         MemberCoinWithdrawEntity memberCoinWithdrawEntity = new MemberCoinWithdrawEntity();
         memberCoinWithdrawEntity.setAddress(address);
         memberCoinWithdrawEntity.setAmount(balance);
         memberCoinWithdrawEntity.setFeeAmount(serviceFee);
         if(1 == apiTransferOutsideDto.getType()){
-            memberCoinWithdrawEntity.setTag("银行卡");
+            DappBank dappBank = dappBankDao.selectBankListByMemberIdAndBankNo(memberId, address);
+            memberCoinWithdrawEntity.setTag(dappBank.getMemberName()+"-银行卡");
             memberCoinWithdrawEntity.setSymbol("$");
         }else{
             memberCoinWithdrawEntity.setTag("钱包");
@@ -861,13 +875,15 @@
     public BigDecimal updateLSYJYLFC(List<String> refererIdList,BigDecimal totalProfit) {
         //计算盈利分成
         BigDecimal profitSharingTotal = BigDecimal.ZERO;
+        if(BigDecimal.ZERO.compareTo(totalProfit)>=0){
+            return profitSharingTotal;
+        }
         if(CollUtil.isNotEmpty(refererIdList)){
             String LEVEL_IB = isIdentity(refererIdList, DataDictionaryEnum.LEVEL_IB.getCode());
             if(!DataDictionaryEnum.LEVEL_IB.getCode().equals(LEVEL_IB)){
                 BigDecimal multiply = totalProfit.multiply(getProfitSharing(DataDictionaryEnum.LEVEL_IB.getCode()));
                 DappMemberEntity dappMemberEntityLEVEL_IB = dappMemberDao.selectMemberInfoByInviteId(LEVEL_IB);
-
-                dappWalletCoinDao.addTotalAndaddAvailableById(dappMemberEntityLEVEL_IB.getId(),multiply);
+                dappWalletCoinDao.addTotalAndaddAvailableByMemberId(dappMemberEntityLEVEL_IB.getId(),multiply);
                 DappAccountMoneyChangeEntity dappAccountMoneyChangeEntity = new DappAccountMoneyChangeEntity(
                         dappMemberEntityLEVEL_IB.getId(), multiply, "盈利分成", 8);
                 dappAccountMoneyChangeDao.insert(dappAccountMoneyChangeEntity);
@@ -884,7 +900,7 @@
 
                 multiply = totalProfit.multiply(multiply);
                 DappMemberEntity dappMemberEntityLEVEL_FIB = dappMemberDao.selectMemberInfoByInviteId(LEVEL_FIB);
-                dappWalletCoinDao.addTotalAndaddAvailableById(dappMemberEntityLEVEL_FIB.getId(),multiply);
+                dappWalletCoinDao.addTotalAndaddAvailableByMemberId(dappMemberEntityLEVEL_FIB.getId(),multiply);
                 DappAccountMoneyChangeEntity dappAccountMoneyChangeEntity = new DappAccountMoneyChangeEntity(
                         dappMemberEntityLEVEL_FIB.getId(), multiply, "盈利分成", 8);
                 dappAccountMoneyChangeDao.insert(dappAccountMoneyChangeEntity);
@@ -895,12 +911,14 @@
                 BigDecimal multiply = BigDecimal.ZERO;
                 if(!DataDictionaryEnum.LEVEL_FIB.getCode().equals(LEVEL_FIB)){
                     multiply = getProfitSharing(DataDictionaryEnum.LEVEL_CIB.getCode()).subtract(getProfitSharing(DataDictionaryEnum.LEVEL_FIB.getCode()));
+                }else if(!DataDictionaryEnum.LEVEL_IB.getCode().equals(LEVEL_IB)){
+                    multiply = getProfitSharing(DataDictionaryEnum.LEVEL_CIB.getCode()).subtract(getProfitSharing(DataDictionaryEnum.LEVEL_IB.getCode()));
                 }else{
                     multiply = getProfitSharing(DataDictionaryEnum.LEVEL_CIB.getCode());
                 }
                 multiply = totalProfit.multiply(multiply);
                 DappMemberEntity dappMemberEntityLEVEL_CIB = dappMemberDao.selectMemberInfoByInviteId(LEVEL_CIB);
-                dappWalletCoinDao.addTotalAndaddAvailableById(dappMemberEntityLEVEL_CIB.getId(),multiply);
+                dappWalletCoinDao.addTotalAndaddAvailableByMemberId(dappMemberEntityLEVEL_CIB.getId(),multiply);
                 DappAccountMoneyChangeEntity dappAccountMoneyChangeEntity = new DappAccountMoneyChangeEntity(
                         dappMemberEntityLEVEL_CIB.getId(), multiply, "盈利分成", 8);
                 dappAccountMoneyChangeDao.insert(dappAccountMoneyChangeEntity);
@@ -911,12 +929,16 @@
                 BigDecimal multiply = BigDecimal.ZERO;
                 if(!DataDictionaryEnum.LEVEL_CIB.getCode().equals(LEVEL_CIB)){
                     multiply = getProfitSharing(DataDictionaryEnum.LEVEL_AIB.getCode()).subtract(getProfitSharing(DataDictionaryEnum.LEVEL_CIB.getCode()));
+                }else if(!DataDictionaryEnum.LEVEL_FIB.getCode().equals(LEVEL_FIB)){
+                    multiply = getProfitSharing(DataDictionaryEnum.LEVEL_AIB.getCode()).subtract(getProfitSharing(DataDictionaryEnum.LEVEL_FIB.getCode()));
+                }else if(!DataDictionaryEnum.LEVEL_IB.getCode().equals(LEVEL_IB)){
+                    multiply = getProfitSharing(DataDictionaryEnum.LEVEL_AIB.getCode()).subtract(getProfitSharing(DataDictionaryEnum.LEVEL_IB.getCode()));
                 }else{
                     multiply = getProfitSharing(DataDictionaryEnum.LEVEL_AIB.getCode());
                 }
                 multiply = totalProfit.multiply(multiply);
                 DappMemberEntity dappMemberEntityLEVEL_AIB = dappMemberDao.selectMemberInfoByInviteId(LEVEL_AIB);
-                dappWalletCoinDao.addTotalAndaddAvailableById(dappMemberEntityLEVEL_AIB.getId(),multiply);
+                dappWalletCoinDao.addTotalAndaddAvailableByMemberId(dappMemberEntityLEVEL_AIB.getId(),multiply);
                 DappAccountMoneyChangeEntity dappAccountMoneyChangeEntity = new DappAccountMoneyChangeEntity(
                         dappMemberEntityLEVEL_AIB.getId(), multiply, "盈利分成", 8);
                 dappAccountMoneyChangeDao.insert(dappAccountMoneyChangeEntity);
@@ -927,12 +949,18 @@
                 BigDecimal multiply = BigDecimal.ZERO;
                 if(!DataDictionaryEnum.LEVEL_AIB.getCode().equals(LEVEL_AIB)){
                     multiply = getProfitSharing(DataDictionaryEnum.LEVEL_GIB.getCode()).subtract(getProfitSharing(DataDictionaryEnum.LEVEL_AIB.getCode()));
+                }else if(!DataDictionaryEnum.LEVEL_CIB.getCode().equals(LEVEL_CIB)){
+                    multiply = getProfitSharing(DataDictionaryEnum.LEVEL_GIB.getCode()).subtract(getProfitSharing(DataDictionaryEnum.LEVEL_CIB.getCode()));
+                }else if(!DataDictionaryEnum.LEVEL_FIB.getCode().equals(LEVEL_FIB)){
+                    multiply = getProfitSharing(DataDictionaryEnum.LEVEL_GIB.getCode()).subtract(getProfitSharing(DataDictionaryEnum.LEVEL_FIB.getCode()));
+                }else if(!DataDictionaryEnum.LEVEL_IB.getCode().equals(LEVEL_IB)){
+                    multiply = getProfitSharing(DataDictionaryEnum.LEVEL_GIB.getCode()).subtract(getProfitSharing(DataDictionaryEnum.LEVEL_IB.getCode()));
                 }else{
                     multiply = getProfitSharing(DataDictionaryEnum.LEVEL_GIB.getCode());
                 }
                 multiply = totalProfit.multiply(multiply);
                 DappMemberEntity dappMemberEntityLEVEL_GIB = dappMemberDao.selectMemberInfoByInviteId(LEVEL_GIB);
-                dappWalletCoinDao.addTotalAndaddAvailableById(dappMemberEntityLEVEL_GIB.getId(),multiply);
+                dappWalletCoinDao.addTotalAndaddAvailableByMemberId(dappMemberEntityLEVEL_GIB.getId(),multiply);
                 DappAccountMoneyChangeEntity dappAccountMoneyChangeEntity = new DappAccountMoneyChangeEntity(
                         dappMemberEntityLEVEL_GIB.getId(), multiply, "盈利分成", 8);
                 dappAccountMoneyChangeDao.insert(dappAccountMoneyChangeEntity);
@@ -943,12 +971,20 @@
                 BigDecimal multiply = BigDecimal.ZERO;
                 if(!DataDictionaryEnum.LEVEL_GIB.getCode().equals(LEVEL_GIB)){
                     multiply = getProfitSharing(DataDictionaryEnum.LEVEL_BP.getCode()).subtract(getProfitSharing(DataDictionaryEnum.LEVEL_GIB.getCode()));
+                }else if(!DataDictionaryEnum.LEVEL_AIB.getCode().equals(LEVEL_AIB)){
+                    multiply = getProfitSharing(DataDictionaryEnum.LEVEL_BP.getCode()).subtract(getProfitSharing(DataDictionaryEnum.LEVEL_AIB.getCode()));
+                }else if(!DataDictionaryEnum.LEVEL_CIB.getCode().equals(LEVEL_CIB)){
+                    multiply = getProfitSharing(DataDictionaryEnum.LEVEL_BP.getCode()).subtract(getProfitSharing(DataDictionaryEnum.LEVEL_CIB.getCode()));
+                }else if(!DataDictionaryEnum.LEVEL_FIB.getCode().equals(LEVEL_FIB)){
+                    multiply = getProfitSharing(DataDictionaryEnum.LEVEL_BP.getCode()).subtract(getProfitSharing(DataDictionaryEnum.LEVEL_FIB.getCode()));
+                }else if(!DataDictionaryEnum.LEVEL_IB.getCode().equals(LEVEL_IB)){
+                    multiply = getProfitSharing(DataDictionaryEnum.LEVEL_BP.getCode()).subtract(getProfitSharing(DataDictionaryEnum.LEVEL_IB.getCode()));
                 }else{
                     multiply = getProfitSharing(DataDictionaryEnum.LEVEL_BP.getCode());
                 }
                 multiply = totalProfit.multiply(multiply);
                 DappMemberEntity dappMemberEntityLEVEL_BP = dappMemberDao.selectMemberInfoByInviteId(LEVEL_BP);
-                dappWalletCoinDao.addTotalAndaddAvailableById(dappMemberEntityLEVEL_BP.getId(),multiply);
+                dappWalletCoinDao.addTotalAndaddAvailableByMemberId(dappMemberEntityLEVEL_BP.getId(),multiply);
                 DappAccountMoneyChangeEntity dappAccountMoneyChangeEntity = new DappAccountMoneyChangeEntity(
                         dappMemberEntityLEVEL_BP.getId(), multiply, "盈利分成", 8);
                 dappAccountMoneyChangeDao.insert(dappAccountMoneyChangeEntity);
@@ -959,12 +995,22 @@
                 BigDecimal multiply = BigDecimal.ZERO;
                 if(!DataDictionaryEnum.LEVEL_BP.getCode().equals(LEVEL_BP)){
                     multiply = getProfitSharing(DataDictionaryEnum.LEVEL_SP.getCode()).subtract(getProfitSharing(DataDictionaryEnum.LEVEL_BP.getCode()));
+                }else if(!DataDictionaryEnum.LEVEL_GIB.getCode().equals(LEVEL_GIB)){
+                    multiply = getProfitSharing(DataDictionaryEnum.LEVEL_SP.getCode()).subtract(getProfitSharing(DataDictionaryEnum.LEVEL_GIB.getCode()));
+                }else if(!DataDictionaryEnum.LEVEL_AIB.getCode().equals(LEVEL_AIB)){
+                    multiply = getProfitSharing(DataDictionaryEnum.LEVEL_SP.getCode()).subtract(getProfitSharing(DataDictionaryEnum.LEVEL_AIB.getCode()));
+                }else if(!DataDictionaryEnum.LEVEL_CIB.getCode().equals(LEVEL_CIB)){
+                    multiply = getProfitSharing(DataDictionaryEnum.LEVEL_SP.getCode()).subtract(getProfitSharing(DataDictionaryEnum.LEVEL_CIB.getCode()));
+                }else if(!DataDictionaryEnum.LEVEL_FIB.getCode().equals(LEVEL_FIB)){
+                    multiply = getProfitSharing(DataDictionaryEnum.LEVEL_SP.getCode()).subtract(getProfitSharing(DataDictionaryEnum.LEVEL_FIB.getCode()));
+                }else if(!DataDictionaryEnum.LEVEL_IB.getCode().equals(LEVEL_IB)){
+                    multiply = getProfitSharing(DataDictionaryEnum.LEVEL_SP.getCode()).subtract(getProfitSharing(DataDictionaryEnum.LEVEL_IB.getCode()));
                 }else{
                     multiply = getProfitSharing(DataDictionaryEnum.LEVEL_SP.getCode());
                 }
                 multiply = totalProfit.multiply(multiply);
                 DappMemberEntity dappMemberEntityLEVEL_SP = dappMemberDao.selectMemberInfoByInviteId(LEVEL_SP);
-                dappWalletCoinDao.addTotalAndaddAvailableById(dappMemberEntityLEVEL_SP.getId(),multiply);
+                dappWalletCoinDao.addTotalAndaddAvailableByMemberId(dappMemberEntityLEVEL_SP.getId(),multiply);
                 DappAccountMoneyChangeEntity dappAccountMoneyChangeEntity = new DappAccountMoneyChangeEntity(
                         dappMemberEntityLEVEL_SP.getId(), multiply, "盈利分成", 8);
                 dappAccountMoneyChangeDao.insert(dappAccountMoneyChangeEntity);
@@ -975,12 +1021,24 @@
                 BigDecimal multiply = BigDecimal.ZERO;
                 if(!DataDictionaryEnum.LEVEL_SP.getCode().equals(LEVEL_SP)){
                     multiply = getProfitSharing(DataDictionaryEnum.LEVEL_GP.getCode()).subtract(getProfitSharing(DataDictionaryEnum.LEVEL_SP.getCode()));
+                }else if(!DataDictionaryEnum.LEVEL_BP.getCode().equals(LEVEL_BP)){
+                    multiply = getProfitSharing(DataDictionaryEnum.LEVEL_GP.getCode()).subtract(getProfitSharing(DataDictionaryEnum.LEVEL_BP.getCode()));
+                }else if(!DataDictionaryEnum.LEVEL_GIB.getCode().equals(LEVEL_GIB)){
+                    multiply = getProfitSharing(DataDictionaryEnum.LEVEL_GP.getCode()).subtract(getProfitSharing(DataDictionaryEnum.LEVEL_GIB.getCode()));
+                }else if(!DataDictionaryEnum.LEVEL_AIB.getCode().equals(LEVEL_AIB)){
+                    multiply = getProfitSharing(DataDictionaryEnum.LEVEL_GP.getCode()).subtract(getProfitSharing(DataDictionaryEnum.LEVEL_AIB.getCode()));
+                }else if(!DataDictionaryEnum.LEVEL_CIB.getCode().equals(LEVEL_CIB)){
+                    multiply = getProfitSharing(DataDictionaryEnum.LEVEL_GP.getCode()).subtract(getProfitSharing(DataDictionaryEnum.LEVEL_CIB.getCode()));
+                }else if(!DataDictionaryEnum.LEVEL_FIB.getCode().equals(LEVEL_FIB)){
+                    multiply = getProfitSharing(DataDictionaryEnum.LEVEL_GP.getCode()).subtract(getProfitSharing(DataDictionaryEnum.LEVEL_FIB.getCode()));
+                }else if(!DataDictionaryEnum.LEVEL_IB.getCode().equals(LEVEL_IB)){
+                    multiply = getProfitSharing(DataDictionaryEnum.LEVEL_GP.getCode()).subtract(getProfitSharing(DataDictionaryEnum.LEVEL_IB.getCode()));
                 }else{
-                    multiply = getProfitSharing(DataDictionaryEnum.LEVEL_SP.getCode());
+                    multiply = getProfitSharing(DataDictionaryEnum.LEVEL_GP.getCode());
                 }
                 multiply = totalProfit.multiply(multiply);
                 DappMemberEntity dappMemberEntityLEVEL_GP = dappMemberDao.selectMemberInfoByInviteId(LEVEL_GP);
-                dappWalletCoinDao.addTotalAndaddAvailableById(dappMemberEntityLEVEL_GP.getId(),multiply);
+                dappWalletCoinDao.addTotalAndaddAvailableByMemberId(dappMemberEntityLEVEL_GP.getId(),multiply);
                 DappAccountMoneyChangeEntity dappAccountMoneyChangeEntity = new DappAccountMoneyChangeEntity(
                         dappMemberEntityLEVEL_GP.getId(), multiply, "盈利分成", 8);
                 dappAccountMoneyChangeDao.insert(dappAccountMoneyChangeEntity);
@@ -996,7 +1054,7 @@
                 BigDecimal multiply = totalProfit.multiply(getRunningCommission(DataDictionaryEnum.LEVEL_AIB.getCode()));
                 DappMemberEntity dappMemberEntityLEVEL_AIB = dappMemberDao.selectMemberInfoByInviteId(LEVEL_AIB);
 
-                dappWalletCoinDao.addTotalAndaddAvailableById(dappMemberEntityLEVEL_AIB.getId(),multiply);
+                dappWalletCoinDao.addTotalAndaddAvailableByMemberId(dappMemberEntityLEVEL_AIB.getId(),multiply);
                 DappAccountMoneyChangeEntity dappAccountMoneyChangeEntity = new DappAccountMoneyChangeEntity(
                         dappMemberEntityLEVEL_AIB.getId(), multiply, "流水佣金", 7);
                 dappAccountMoneyChangeDao.insert(dappAccountMoneyChangeEntity);
@@ -1008,7 +1066,7 @@
                 BigDecimal multiply = totalProfit.multiply(getRunningCommission(DataDictionaryEnum.LEVEL_GIB.getCode()));
                 DappMemberEntity dappMemberEntityLEVEL_GIB = dappMemberDao.selectMemberInfoByInviteId(LEVEL_GIB);
 
-                dappWalletCoinDao.addTotalAndaddAvailableById(dappMemberEntityLEVEL_GIB.getId(),multiply);
+                dappWalletCoinDao.addTotalAndaddAvailableByMemberId(dappMemberEntityLEVEL_GIB.getId(),multiply);
                 DappAccountMoneyChangeEntity dappAccountMoneyChangeEntity = new DappAccountMoneyChangeEntity(
                         dappMemberEntityLEVEL_GIB.getId(), multiply, "流水佣金", 7);
                 dappAccountMoneyChangeDao.insert(dappAccountMoneyChangeEntity);
@@ -1020,7 +1078,7 @@
                 BigDecimal multiply = totalProfit.multiply(getRunningCommission(DataDictionaryEnum.LEVEL_BP.getCode()));
                 DappMemberEntity dappMemberEntityLEVEL_BP = dappMemberDao.selectMemberInfoByInviteId(LEVEL_BP);
 
-                dappWalletCoinDao.addTotalAndaddAvailableById(dappMemberEntityLEVEL_BP.getId(),multiply);
+                dappWalletCoinDao.addTotalAndaddAvailableByMemberId(dappMemberEntityLEVEL_BP.getId(),multiply);
                 DappAccountMoneyChangeEntity dappAccountMoneyChangeEntity = new DappAccountMoneyChangeEntity(
                         dappMemberEntityLEVEL_BP.getId(), multiply, "流水佣金", 7);
                 dappAccountMoneyChangeDao.insert(dappAccountMoneyChangeEntity);
@@ -1032,7 +1090,7 @@
                 BigDecimal multiply = totalProfit.multiply(getRunningCommission(DataDictionaryEnum.LEVEL_SP.getCode()));
                 DappMemberEntity dappMemberEntityLEVEL_SP = dappMemberDao.selectMemberInfoByInviteId(LEVEL_SP);
 
-                dappWalletCoinDao.addTotalAndaddAvailableById(dappMemberEntityLEVEL_SP.getId(),multiply);
+                dappWalletCoinDao.addTotalAndaddAvailableByMemberId(dappMemberEntityLEVEL_SP.getId(),multiply);
                 DappAccountMoneyChangeEntity dappAccountMoneyChangeEntity = new DappAccountMoneyChangeEntity(
                         dappMemberEntityLEVEL_SP.getId(), multiply, "流水佣金", 7);
                 dappAccountMoneyChangeDao.insert(dappAccountMoneyChangeEntity);
@@ -1044,7 +1102,7 @@
                 BigDecimal multiply = totalProfit.multiply(getRunningCommission(DataDictionaryEnum.LEVEL_GP.getCode()));
                 DappMemberEntity dappMemberEntityLEVEL_GP = dappMemberDao.selectMemberInfoByInviteId(LEVEL_GP);
 
-                dappWalletCoinDao.addTotalAndaddAvailableById(dappMemberEntityLEVEL_GP.getId(),multiply);
+                dappWalletCoinDao.addTotalAndaddAvailableByMemberId(dappMemberEntityLEVEL_GP.getId(),multiply);
                 DappAccountMoneyChangeEntity dappAccountMoneyChangeEntity = new DappAccountMoneyChangeEntity(
                         dappMemberEntityLEVEL_GP.getId(), multiply, "流水佣金", 7);
                 dappAccountMoneyChangeDao.insert(dappAccountMoneyChangeEntity);
@@ -1056,11 +1114,35 @@
 
     @Override
     public BigDecimal updatePTFC(Long memberId, BigDecimal totalProfit) {
+        if(BigDecimal.ZERO.compareTo(totalProfit)>=0){
+            return BigDecimal.ZERO;
+        }
         BigDecimal multiply = totalProfit.multiply(new BigDecimal(0.05));
-        DappAccountMoneyChangeEntity dappAccountMoneyChangeEntity = new DappAccountMoneyChangeEntity(
-                memberId, multiply, "系统", 9);
+        DappAccountMoneyChangeEntity dappAccountMoneyChangeEntity = new DappAccountMoneyChangeEntity(65L,
+                multiply.negate(), "系统", 9);
         dappAccountMoneyChangeDao.insert(dappAccountMoneyChangeEntity);
         return multiply;
+    }
+
+    @Override
+    public Integer isGoal(String num) {
+        Set set = new HashSet();
+        num = StrUtil.subSuf(num,1);
+        char[] chars = num.toCharArray();
+        for(char c:chars) {
+            set.add(c);
+        }
+        if(set.size()==num.length()){
+            return 1;
+        }else{
+            return 2;
+        }
+    }
+
+    public static void main(String[] args) {
+
+        String num = StrUtil.subSuf("01234",1);
+        System.out.print(num);
     }
 
     private String isIdentity(List<String> refererIds,String levelCode){
@@ -1071,6 +1153,7 @@
                 String identity = dappMemberEntity.getIdentity();
                 if(levelCode.equals(identity)){
                     flag = str;
+                    return flag;
                 }
             }
         }

--
Gitblit v1.9.1