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 | 70 +++++++++++++++++++++++------------ 1 files changed, 46 insertions(+), 24 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 3b89c26..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) { @@ -405,18 +435,14 @@ memberAccountMoneyChangeMapper.insert(memberAccountMoneyChangeEntity); } - MemberAccountMoneyChangeEntity memberAccountMoneyChangeEntity = new MemberAccountMoneyChangeEntity(); - memberAccountMoneyChangeEntity.setContent("提币"); - memberAccountMoneyChangeEntity.setMemberId(memberId); - memberAccountMoneyChangeEntity.setAmount(selectById.getAmount()); + Map<String, Object> columnMaps = new HashMap<>(); + columnMaps.put("withdraw_id", selectById.getId()); + List<MemberAccountMoneyChangeEntity> selectByMap2 = memberAccountMoneyChangeMapper.selectByMap(columnMaps); + + MemberAccountMoneyChangeEntity memberAccountMoneyChangeEntity = selectByMap2.get(0); memberAccountMoneyChangeEntity.setStatus(MemberAccountMoneyChangeEntity.STATUS_SUCCESS_INTEGER); - memberAccountMoneyChangeEntity.setSymbol(selectById.getSymbol()); - memberAccountMoneyChangeEntity.setType(MemberAccountMoneyChangeEntity.TYPE_WALLET_COIN); - memberAccountMoneyChangeEntity.setCreateBy(selectById.getCreateBy()); - memberAccountMoneyChangeEntity.setCreateTime(new Date()); - memberAccountMoneyChangeEntity.setUpdateBy(selectById.getCreateBy()); - memberAccountMoneyChangeEntity.setUpdateTime(new Date()); - memberAccountMoneyChangeMapper.insert(memberAccountMoneyChangeEntity); + memberAccountMoneyChangeEntity.setAmount(selectById.getAmount().negate()); + memberAccountMoneyChangeMapper.updateById(memberAccountMoneyChangeEntity); selectById.setStatus(MemberCoinWithdrawEntity.IS_STATUS_Y); memberCoinWithdrawMapper.updateById(selectById); @@ -446,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); @@ -454,18 +480,14 @@ memberWalletCoinMapper.updateById(walletCoin); // 提币退款记录 - MemberAccountMoneyChangeEntity memberAccountMoneyChangeEntity = new MemberAccountMoneyChangeEntity(); - memberAccountMoneyChangeEntity.setContent("提币"); - memberAccountMoneyChangeEntity.setMemberId(memberId); - memberAccountMoneyChangeEntity.setAmount(selectById.getAmount()); + Map<String, Object> columnMaps = new HashMap<>(); + columnMaps.put("withdraw_id", selectById.getId()); + List<MemberAccountMoneyChangeEntity> selectByMap2 = memberAccountMoneyChangeMapper.selectByMap(columnMaps); + + MemberAccountMoneyChangeEntity memberAccountMoneyChangeEntity = selectByMap2.get(0); memberAccountMoneyChangeEntity.setStatus(MemberAccountMoneyChangeEntity.STATUS_FAIL_INTEGER); - memberAccountMoneyChangeEntity.setSymbol(selectById.getSymbol()); - memberAccountMoneyChangeEntity.setType(MemberAccountMoneyChangeEntity.TYPE_WALLET_COIN); - memberAccountMoneyChangeEntity.setCreateBy(selectById.getCreateBy()); - memberAccountMoneyChangeEntity.setCreateTime(new Date()); - memberAccountMoneyChangeEntity.setUpdateBy(selectById.getCreateBy()); - memberAccountMoneyChangeEntity.setUpdateTime(new Date()); - memberAccountMoneyChangeMapper.insert(memberAccountMoneyChangeEntity); + memberAccountMoneyChangeEntity.setAmount(selectById.getAmount()); + memberAccountMoneyChangeMapper.updateById(memberAccountMoneyChangeEntity); selectById.setStatus(MemberCoinWithdrawEntity.IS_STATUS_N); memberCoinWithdrawMapper.updateById(selectById); @@ -610,7 +632,7 @@ //添加币币资金划转历史记录 MemberAccountMoneyChangeEntity memberAccountMoneyChangeEntity = new MemberAccountMoneyChangeEntity(); - memberAccountMoneyChangeEntity.setContent("转入币币账户"); + memberAccountMoneyChangeEntity.setContent("充值"); memberAccountMoneyChangeEntity.setMemberId(memberId); memberAccountMoneyChangeEntity.setAmount(amountUsdt); memberAccountMoneyChangeEntity.setStatus(MemberAccountMoneyChangeEntity.STATUS_SUCCESS_INTEGER); -- Gitblit v1.9.1