blame | history | patch | commit | commitdiff | ignore whitespace
xiaoyong931011
2020-09-11 58959179bbcf0383836159e3ac18461725bf223b 
 src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java


@@ -1,6 +1,7 @@


package com.xcong.excoin.modules.member.service.impl;




import cn.hutool.core.collection.CollUtil;


import cn.hutool.core.util.ObjectUtil;


import cn.hutool.core.util.StrUtil;


import com.baomidou.mybatisplus.core.metadata.IPage;


import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;


@@ -649,6 +650,10 @@


      String walletNum = memberMapper.selectBBZCForBasicRealData();


      String walletCoinNum = memberMapper.selectHYZCForBasicRealData();


      String agentNum = memberMapper.selectDLZCForBasicRealData();


      double allCoin = 0 ;


      allCoin = (walletNum == null ? 0 : Double.parseDouble(walletNum))


            +(walletCoinNum == null ? 0 : Double.parseDouble(walletCoinNum))


            +(agentNum == null ? 0 : Double.parseDouble(agentNum));


      


      double platformProfitAndLoss = 0 ;


      platformProfitAndLoss = platformProfitAndLoss + (totalAmountUsdtB == null ? 0 : Double.parseDouble(totalAmountUsdtB));


@@ -673,6 +678,7 @@


         memberDataInfoVo.setWalletNum(walletNum == null ? "0" : walletNum);


         memberDataInfoVo.setWalletCoinNum(walletCoinNum == null ? "0" : walletCoinNum);


         memberDataInfoVo.setAgentNum(agentNum == null ? "0" : agentNum);


         memberDataInfoVo.setAllCoin(allCoin);


      }


      selectMemberListInPage.setTotal(1);


        return selectMemberListInPage;


@@ -902,6 +908,10 @@


      String walletNum = memberMapper.selectBBZCForBasicRealDataAlone();


      String walletCoinNum = memberMapper.selectHYZCForBasicRealDataAlone();


      String agentNum = memberMapper.selectDLZCForBasicRealDataAlone();


      double allCoin = 0 ;


      allCoin = (walletNum == null ? 0 : Double.parseDouble(walletNum))


            +(walletCoinNum == null ? 0 : Double.parseDouble(walletCoinNum))


            +(agentNum == null ? 0 : Double.parseDouble(agentNum));


      


      double platformProfitAndLoss = 0 ;


      platformProfitAndLoss = platformProfitAndLoss + (totalAmountUsdtB == null ? 0 : Double.parseDouble(totalAmountUsdtB));


@@ -926,6 +936,7 @@


         memberDataInfoVo.setWalletNum(walletNum == null ? "0" : walletNum);


         memberDataInfoVo.setWalletCoinNum(walletCoinNum == null ? "0" : walletCoinNum);


         memberDataInfoVo.setAgentNum(agentNum == null ? "0" : agentNum);


         memberDataInfoVo.setAllCoin(allCoin);


      }


      selectMemberListInPage.setTotal(1);


        return selectMemberListInPage;


@@ -965,6 +976,10 @@


      String walletNum = memberMapper.selectBBZCForBasicData();


      String walletCoinNum = memberMapper.selectHYZCForBasicData();


      String agentNum = memberMapper.selectDLZCForBasicData();


      double allCoin = 0 ;


      allCoin = (walletNum == null ? 0 : Double.parseDouble(walletNum))


            +(walletCoinNum == null ? 0 : Double.parseDouble(walletCoinNum))


            +(agentNum == null ? 0 : Double.parseDouble(agentNum));


      


      double platformProfitAndLoss = 0 ;


      platformProfitAndLoss = platformProfitAndLoss + (totalAmountUsdtB == null ? 0 : Double.parseDouble(totalAmountUsdtB));


@@ -989,6 +1004,7 @@


         memberDataInfoVo.setWalletNum(walletNum == null ? "0" : walletNum);


         memberDataInfoVo.setWalletCoinNum(walletCoinNum == null ? "0" : walletCoinNum);


         memberDataInfoVo.setAgentNum(agentNum == null ? "0" : agentNum);


         memberDataInfoVo.setAllCoin(allCoin);


      }


      selectMemberListInPage.setTotal(1);


        return selectMemberListInPage;


@@ -1029,6 +1045,10 @@


      String walletNum = memberMapper.selectBBZCForBasicAllDataAlone();


      String walletCoinNum = memberMapper.selectHYZCForBasicAllDataAlone();


      String agentNum = memberMapper.selectDLZCForBasicAllDataAlone();


      double allCoin = 0 ;


      allCoin = (walletNum == null ? 0 : Double.parseDouble(walletNum))


            +(walletCoinNum == null ? 0 : Double.parseDouble(walletCoinNum))


            +(agentNum == null ? 0 : Double.parseDouble(agentNum));


      


      double platformProfitAndLoss = 0 ;


      platformProfitAndLoss = platformProfitAndLoss + (totalAmountUsdtB == null ? 0 : Double.parseDouble(totalAmountUsdtB));


@@ -1053,6 +1073,7 @@


         memberDataInfoVo.setWalletNum(walletNum == null ? "0" : walletNum);


         memberDataInfoVo.setWalletCoinNum(walletCoinNum == null ? "0" : walletCoinNum);


         memberDataInfoVo.setAgentNum(agentNum == null ? "0" : agentNum);


         memberDataInfoVo.setAllCoin(allCoin);


      }


      selectMemberListInPage.setTotal(1);


        return selectMemberListInPage;


@@ -1155,6 +1176,7 @@


      //USDT充币总额+USDT提币总额


       String totalAmountUsdtB = memberMapper.selectTotalAmountUsdtBForBasicRealTestDataAlone();


       String totalAmountUsdtS = memberMapper.selectTotalAmountUsdtSForBasicRealTestDataAlone();


    	


       //USDT充值总额+USDT提现总额


       String totalAmountUsdtCZ = memberMapper.selectTotalAmountUsdtCZForBasicRealTestDataAlone();


       String totalAmountUsdtTX = memberMapper.selectTotalAmountUsdtTXForBasicRealTestDataAlone();


@@ -1181,18 +1203,25 @@


      String walletNum = memberMapper.selectBBZCForBasicRealTestDataAlone();


      String walletCoinNum = memberMapper.selectHYZCForBasicRealTestDataAlone();


      String agentNum = memberMapper.selectDLZCForBasicRealTestDataAlone();


      double allCoin = 0 ;


      allCoin = (walletNum == null ? 0 : Double.parseDouble(walletNum))


            +(walletCoinNum == null ? 0 : Double.parseDouble(walletCoinNum))


            +(agentNum == null ? 0 : Double.parseDouble(agentNum));


      


      double platformProfitAndLoss = 0 ;


		


		


		


      platformProfitAndLoss = platformProfitAndLoss + (totalAmountUsdtB == null ? 0 : Double.parseDouble(totalAmountUsdtB));


      platformProfitAndLoss = platformProfitAndLoss + (totalAmountUsdtCZ == null ? 0 : Double.parseDouble(totalAmountUsdtCZ));


      platformProfitAndLoss = platformProfitAndLoss - (totalAmountUsdtS == null ? 0 : Double.parseDouble(totalAmountUsdtS));


      platformProfitAndLoss = platformProfitAndLoss - (totalAmountUsdtS == null ? 0 : (Double.parseDouble(totalAmountUsdtS)-6780));


      platformProfitAndLoss = platformProfitAndLoss - (totalAmountUsdtTX == null ? 0 : Double.parseDouble(totalAmountUsdtTX));


      List<MemberDataInfoVo> records = selectMemberListInPage.getRecords();


      for(MemberDataInfoVo memberDataInfoVo : records) {


         memberDataInfoVo.setChargeUsdt(totalAmountUsdtCZ == null ? 0 : Double.parseDouble(totalAmountUsdtCZ));


         memberDataInfoVo.setAppealUsdt(totalAmountUsdtTX == null ? 0 : Double.parseDouble(totalAmountUsdtTX));


         memberDataInfoVo.setChargeCoin(totalAmountUsdtB == null ? 0 : Double.parseDouble(totalAmountUsdtB));


         memberDataInfoVo.setAppealCoin(totalAmountUsdtS == null ? 0 : Double.parseDouble(totalAmountUsdtS));


         memberDataInfoVo.setAppealCoin(totalAmountUsdtS == null ? 0 : (Double.parseDouble(totalAmountUsdtS)-6780));


         memberDataInfoVo.setClosingPrice(closingpriceByMid == null ? "0" : closingpriceByMid);


         memberDataInfoVo.setSellClosingPrice(sellClosingpriceByMid == null ? "0" : sellClosingpriceByMid);


         memberDataInfoVo.setFee(returnMoneyByMid == null ? "0" : returnMoneyByMid);


@@ -1205,6 +1234,7 @@


         memberDataInfoVo.setWalletNum(walletNum == null ? "0" : walletNum);


         memberDataInfoVo.setWalletCoinNum(walletCoinNum == null ? "0" : walletCoinNum);


         memberDataInfoVo.setAgentNum(agentNum == null ? "0" : agentNum);


         memberDataInfoVo.setAllCoin(allCoin);


      }


      selectMemberListInPage.setTotal(1);


        return selectMemberListInPage;


@@ -1245,18 +1275,22 @@


      String walletNum = memberMapper.selectBBZCForBasicRealTestAllDataAlone();


      String walletCoinNum = memberMapper.selectHYZCForBasicRealTestAllDataAlone();


      String agentNum = memberMapper.selectDLZCForBasicRealTestAllDataAlone();


      double allCoin = 0 ;


      allCoin = (walletNum == null ? 0 : Double.parseDouble(walletNum))


            +(walletCoinNum == null ? 0 : Double.parseDouble(walletCoinNum))


            +(agentNum == null ? 0 : Double.parseDouble(agentNum));


      


      double platformProfitAndLoss = 0 ;


      platformProfitAndLoss = platformProfitAndLoss + (totalAmountUsdtB == null ? 0 : Double.parseDouble(totalAmountUsdtB));


      platformProfitAndLoss = platformProfitAndLoss + (totalAmountUsdtCZ == null ? 0 : Double.parseDouble(totalAmountUsdtCZ));


      platformProfitAndLoss = platformProfitAndLoss - (totalAmountUsdtS == null ? 0 : Double.parseDouble(totalAmountUsdtS));


      platformProfitAndLoss = platformProfitAndLoss - (totalAmountUsdtS == null ? 0 : (Double.parseDouble(totalAmountUsdtS)-6780));


      platformProfitAndLoss = platformProfitAndLoss - (totalAmountUsdtTX == null ? 0 : Double.parseDouble(totalAmountUsdtTX));


      List<MemberDataInfoVo> records = selectMemberListInPage.getRecords();


      for(MemberDataInfoVo memberDataInfoVo : records) {


         memberDataInfoVo.setChargeUsdt(totalAmountUsdtCZ == null ? 0 : Double.parseDouble(totalAmountUsdtCZ));


         memberDataInfoVo.setAppealUsdt(totalAmountUsdtTX == null ? 0 : Double.parseDouble(totalAmountUsdtTX));


         memberDataInfoVo.setChargeCoin(totalAmountUsdtB == null ? 0 : Double.parseDouble(totalAmountUsdtB));


         memberDataInfoVo.setAppealCoin(totalAmountUsdtS == null ? 0 : Double.parseDouble(totalAmountUsdtS));


         memberDataInfoVo.setAppealCoin(totalAmountUsdtS == null ? 0 : (Double.parseDouble(totalAmountUsdtS)-6780));


         memberDataInfoVo.setClosingPrice(closingpriceByMid == null ? "0" : closingpriceByMid);


         memberDataInfoVo.setSellClosingPrice(sellClosingpriceByMid == null ? "0" : sellClosingpriceByMid);


         memberDataInfoVo.setFee(returnMoneyByMid == null ? "0" : returnMoneyByMid);


@@ -1269,6 +1303,7 @@


         memberDataInfoVo.setWalletNum(walletNum == null ? "0" : walletNum);


         memberDataInfoVo.setWalletCoinNum(walletCoinNum == null ? "0" : walletCoinNum);


         memberDataInfoVo.setAgentNum(agentNum == null ? "0" : agentNum);


         memberDataInfoVo.setAllCoin(allCoin);


      }


      selectMemberListInPage.setTotal(1);


        return selectMemberListInPage;


@@ -1327,4 +1362,43 @@


      return memberInfoDetailVo;


   }






   @Override


   public IPage<MemberEntity> memberDataInfoListSearchs(MemberEntity member, QueryRequest request) {




        Page<MemberEntity> page = new Page<>(request.getPageNum(), request.getPageSize());


        IPage<MemberEntity> selectMemberListInPage = this.baseMapper.selectDataInfoListSearchs(page, member);


        List<MemberEntity> records = selectMemberListInPage.getRecords();


        Set<MemberEntity> set = new HashSet<>();


        if(CollUtil.isNotEmpty(records)) {


           if(StrUtil.isNotBlank(member.getAccount())) {


              MemberEntity memberEntity = records.get(0);


              //当前查询下级关系


              String inviteId = memberEntity.getInviteId();


              List<MemberEntity> members = memberMapper.selectMemberDataInfoListSearchs(inviteId);


              if(CollUtil.isNotEmpty(members)) {


                 for(MemberEntity semberEntity : members) {


                    set.add(semberEntity);


                 }


              }


              //当前查询上级关系


              String refererIds = memberEntity.getRefererIds();


              String[] strs = refererIds.split(",");


              if(ObjectUtil.isNotEmpty(strs)) {


                 for(int i=0,len=strs.length;i<len;i++){


                    String string = strs[i].toString();


                    if(StrUtil.isNotEmpty(string)) {


                       MemberEntity mem = memberMapper.selectMemberByInviteId(string);


                       set.add(mem);


                    }


                 }


              }


           }


           if(set.size() > 0) {


              records.addAll(set);


           }


        }


        return selectMemberListInPage;


   }




}