From e74838c27c1779c1fd056e40b1e9dad5ff1537d4 Mon Sep 17 00:00:00 2001 From: xiaoyong931011 <15274802129@163.com> Date: Thu, 20 Aug 2020 11:39:46 +0800 Subject: [PATCH] 20200820 --- src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java | 45 +++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 45 insertions(+), 0 deletions(-) diff --git a/src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java b/src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java index 6e8d090..09742ca 100644 --- a/src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java +++ b/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; @@ -1245,6 +1246,10 @@ 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)); @@ -1269,6 +1274,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 +1333,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; + } + } -- Gitblit v1.9.1