From 0469ade9be848d97eefb92f3e584441d89e6b69d Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Thu, 20 May 2021 19:32:05 +0800 Subject: [PATCH] modify --- src/main/java/com/xcong/excoin/modules/yunding/service/Impl/YunDingServiceImpl.java | 58 +++++++++++++++++++++++++++++++++++++++++++++++++++------- 1 files changed, 51 insertions(+), 7 deletions(-) diff --git a/src/main/java/com/xcong/excoin/modules/yunding/service/Impl/YunDingServiceImpl.java b/src/main/java/com/xcong/excoin/modules/yunding/service/Impl/YunDingServiceImpl.java index 5fbb658..820863f 100644 --- a/src/main/java/com/xcong/excoin/modules/yunding/service/Impl/YunDingServiceImpl.java +++ b/src/main/java/com/xcong/excoin/modules/yunding/service/Impl/YunDingServiceImpl.java @@ -1,7 +1,6 @@ package com.xcong.excoin.modules.yunding.service.Impl; import cn.hutool.core.collection.CollUtil; -import cn.hutool.core.date.DateTime; import cn.hutool.core.date.DateUtil; import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; @@ -42,7 +41,6 @@ import java.math.BigDecimal; import java.text.DecimalFormat; import java.util.Date; -import java.util.HashMap; import java.util.List; @Slf4j @@ -148,10 +146,8 @@ Date endTime = DateUtil.offsetDay(workTime, proCycle); ydProductVo.setEndTime(endTime); - if (ydProductVo.getTotalT().compareTo(BigDecimal.ZERO) < 1) { + if (ydProductVo.getSurplusT().compareTo(BigDecimal.ZERO) < 1) { ydProductVo.setStatus(2); - } else { - ydProductVo.setStatus(1); } return Result.ok(ydProductVo); } @@ -282,7 +278,6 @@ "USDT", 1, 3, ydOrderEntity.getId()); yunDingProducter.sendYunDingUsdtProfit(ydOrderEntity.getId()); - yunDingProducter.sendYunDingAutoAgent(ydOrderEntity.getMemberId()); return Result.ok("支付成功"); } @@ -587,7 +582,6 @@ memberEntity.setAgentLevel(id.intValue()); LoginUserUtils.resetAppLoginUser(memberEntity); - yunDingProducter.sendYunDingAutoAgent(memberId); yunDingProducter.sendYunDingUsdtProfit(orderEntity.getId()); return Result.ok("购买成功"); } @@ -603,6 +597,56 @@ return Result.ok(xchNewPrices); } + @Override + public Result getTeamList(TeamInfoDto teamInfoDto) { + log.info("获取团队信息"); + MemberEntity memberEntity = LoginUserUtils.getAppLoginUser(); + Long memberId = memberEntity.getId(); +// Long memberId = 444L; +// MemberEntity memberEntity = memberDao.selectById(memberId); + /** + * 获取团队总人数,总购买数 + * 详细列表 + * + */ + TeamVo teamVo = new TeamVo(); + //团队总人数 + int memberNum = 0; + String inviteId = memberEntity.getInviteId(); + List<MemberEntity> memberEntityList = ydOrderDao.selectMemberByInviteId(inviteId); + if(CollUtil.isNotEmpty(memberEntityList)){ + memberNum = memberEntityList.size(); + } + teamVo.setMemberNum(memberNum); + //购买总算力 + int allPower = ydOrderDao.selectAllPowerByMemberIdAndElse(inviteId); + teamVo.setAllPower(allPower); + //详细列表 + Page<TeamInfoVo> page = new Page<>(teamInfoDto.getPageNum(), teamInfoDto.getPageSize()); + IPage<TeamInfoVo> teamInfoVos = ydOrderDao.getTeamInfoList(page, memberEntity); + List<TeamInfoVo> records = teamInfoVos.getRecords(); + if(CollUtil.isNotEmpty(records)){ + for(TeamInfoVo teamInfoVo : records){ + String phone = teamInfoVo.getInvitephone(); + if(StrUtil.isNotEmpty(phone)){ + teamInfoVo.setInvitephone(StrUtil.subSufByLength(phone,4)); + } + //下属团队人数 + int memberNumInvite = 0; + List<MemberEntity> memberEntityInviteList = ydOrderDao.selectMemberByInviteId(phone); + if(CollUtil.isNotEmpty(memberEntityInviteList)){ + memberNumInvite = memberEntityInviteList.size(); + } + teamInfoVo.setMemberNum(memberNumInvite); + //下属团队总算力 + int powerNum = ydOrderDao.selectAllPowerByMemberIdAndElse(phone); + teamInfoVo.setPowerNum(powerNum); + } + } + teamVo.setTeamInfoVos(records); + return Result.ok(teamVo); + } + /** * 去加减币币账户余额,减少产品的剩余数目 -- Gitblit v1.9.1