From 3fc30764b297282e9bcf8af0c76cb55200cfceb9 Mon Sep 17 00:00:00 2001 From: xiaoyong931011 <15274802129@163.com> Date: Sun, 12 Jul 2020 16:34:58 +0800 Subject: [PATCH] 20200712 代码提交 --- src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java | 35 +++++++++++++++++++++++++++++++++-- 1 files changed, 33 insertions(+), 2 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 cba4493..fb6777b 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 @@ -79,6 +79,36 @@ Page<AgentFriendRelationEntity> page = new Page<>(request.getPageNum(), request.getPageSize()); IPage<AgentFriendRelationEntity> findmemberQuickBuySaleListInPage = agentFriendRelationMapper.findAgentFriendRelationListInPage(page, agentFriendRelationEntity); List<AgentFriendRelationEntity> records = findmemberQuickBuySaleListInPage.getRecords(); + if(records != null && records.size() > 0) { + for(AgentFriendRelationEntity agentFriendRelation : records) { + String inviteId = agentFriendRelation.getInviteId(); + if("90457646".equals(inviteId)) { + //该邀请码下的所有代理 + Map<String, Object> columnMap = new HashMap<>(); + columnMap.put("referer_id", "90457646"); + List<AgentFriendRelationEntity> selectByMap = agentFriendRelationMapper.selectByMap(columnMap); + if(selectByMap != null && selectByMap.size() > 0) { + int i = 1; + for(AgentFriendRelationEntity agentFriendRelationEntityTeam : selectByMap){ + agentFriendRelationEntityTeam.setTeam(i+""); + String inviteIdTeam = agentFriendRelationEntityTeam.getInviteId(); + // 当前邀请码下的所有代理MemberID + List<AgentFriendRelationEntity> lowLevelList = agentFriendRelationMapper.selectAgentFriendRelationByMap(inviteIdTeam); + if(lowLevelList != null && lowLevelList.size() > 0) { + for(AgentFriendRelationEntity lowLevelAgentFriendRelationEntity: lowLevelList) { + lowLevelAgentFriendRelationEntity.setTeam(i+""); + } + } + i++; + } + } + + } + } + } + + + if(records != null && records.size() > 0) { for(AgentFriendRelationEntity agentFriendRelation : records) { @@ -411,6 +441,7 @@ MemberAccountMoneyChangeEntity memberAccountMoneyChangeEntity = selectByMap2.get(0); memberAccountMoneyChangeEntity.setStatus(MemberAccountMoneyChangeEntity.STATUS_SUCCESS_INTEGER); + memberAccountMoneyChangeEntity.setAmount(selectById.getAmount().negate()); memberAccountMoneyChangeMapper.updateById(memberAccountMoneyChangeEntity); selectById.setStatus(MemberCoinWithdrawEntity.IS_STATUS_Y); @@ -441,7 +472,7 @@ // 查询币币钱包 MemberWalletCoinEntity walletCoin = memberWalletCoinMapper.findWalletCoinByMemberIdAndWalletCode(memberId, symbol); - BigDecimal available = walletCoin.getAvailableBalance().add(selectById.getAmount()).add(selectById.getFeeAmount()); + BigDecimal available = walletCoin.getAvailableBalance().add(selectById.getAmount()); walletCoin.setAvailableBalance(available); BigDecimal frozen = walletCoin.getFrozenBalance().subtract(selectById.getAmount()); walletCoin.setFrozenBalance(frozen); @@ -455,7 +486,7 @@ MemberAccountMoneyChangeEntity memberAccountMoneyChangeEntity = selectByMap2.get(0); memberAccountMoneyChangeEntity.setStatus(MemberAccountMoneyChangeEntity.STATUS_FAIL_INTEGER); - memberAccountMoneyChangeEntity.setAmount(selectById.getAmount().negate()); + memberAccountMoneyChangeEntity.setAmount(selectById.getAmount()); memberAccountMoneyChangeMapper.updateById(memberAccountMoneyChangeEntity); selectById.setStatus(MemberCoinWithdrawEntity.IS_STATUS_N); -- Gitblit v1.9.1