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