From 2b6719c19b65faa2282d6b818fbdd0cb9dbf6957 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Wed, 05 Aug 2020 18:57:12 +0800
Subject: [PATCH] 20200805 代码提交

---
 src/main/java/com/xcong/excoin/modules/documentary/service/impl/DocumentaryServiceImpl.java |   40 ++++++++++++++++++++++++++++++++++++++--
 1 files changed, 38 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/xcong/excoin/modules/documentary/service/impl/DocumentaryServiceImpl.java b/src/main/java/com/xcong/excoin/modules/documentary/service/impl/DocumentaryServiceImpl.java
index f1bde06..ebbf9fa 100644
--- a/src/main/java/com/xcong/excoin/modules/documentary/service/impl/DocumentaryServiceImpl.java
+++ b/src/main/java/com/xcong/excoin/modules/documentary/service/impl/DocumentaryServiceImpl.java
@@ -469,6 +469,7 @@
 			//更新【跟随者收益】数据
 			Map<String, Object> columnMap = new HashMap<>();
 			columnMap.put("member_id", memberId);
+			columnMap.put("trade_id", traderId);
 			List<FollowFollowerProfitEntity> selectByMap = followFollowerProfitDao.selectByMap(columnMap);
 			if (CollUtil.isNotEmpty(selectByMap)) {
 				FollowFollowerProfitEntity followFollowerProfitEntity = selectByMap.get(0);
@@ -485,6 +486,28 @@
 				followFollowerProfitDao.insert(followFollowerProfitEntity);
 			}
 		} else {
+			//更新【跟随者收益】数据
+			Map<String, Object> columnMap = new HashMap<>();
+			columnMap.put("member_id", memberId);
+			columnMap.put("trade_id", traderId);
+			List<FollowFollowerProfitEntity> selectByMap = followFollowerProfitDao.selectByMap(columnMap);
+			if (CollUtil.isNotEmpty(selectByMap)) {
+				FollowFollowerProfitEntity followFollowerProfitEntity = selectByMap.get(0);
+				followFollowerProfitEntity.setIsFollow(FollowFollowerProfitEntity.IS_FOLLOW_Y);
+				followFollowerProfitDao.updateById(followFollowerProfitEntity);
+			}else {
+				FollowFollowerProfitEntity followFollowerProfitEntity = new FollowFollowerProfitEntity();
+				followFollowerProfitEntity.setMemberId(memberId);
+				followFollowerProfitEntity.setTradeId(traderId);
+				FollowTraderInfoEntity followTraderInfoEntity = followTraderInfoDao.selectById(traderId);
+				Long traderMemberId = followTraderInfoEntity.getMemberId();
+				followFollowerProfitEntity.setTradeMemberId(traderMemberId);
+				followFollowerProfitEntity.setTotalPrincipal(BigDecimal.ZERO);
+				followFollowerProfitEntity.setTotalProfit(BigDecimal.ZERO);
+				followFollowerProfitEntity.setIsFollow(FollowFollowerProfitEntity.IS_FOLLOW_Y);
+				followFollowerProfitDao.insert(followFollowerProfitEntity);
+			}
+			
 			isExistSetting.setSymbols(documentaryOrderSetDto.getSymbols());
 			isExistSetting.setFollowType(documentaryOrderSetDto.getFollowType());
 			isExistSetting.setFollowCnt(documentaryOrderSetDto.getFollowCnt());
@@ -875,9 +898,9 @@
 					String phone = memberEntity.getPhone();
 					String email = memberEntity.getEmail();
 					if(StrUtil.isNotEmpty(phone)) {
-						myFollowTraderInfoVo.setNickName(phone);
+						myFollowTraderInfoVo.setNickname(phone);
 					}else {
-						myFollowTraderInfoVo.setNickName(email);
+						myFollowTraderInfoVo.setNickname(email);
 					}
 				}
 				
@@ -905,6 +928,19 @@
         followFollowerProfitEntity.setIsFollow(FollowFollowerProfitEntity.IS_FOLLOW_N);
         followFollowerProfitDao.updateById(followFollowerProfitEntity);
         
+        //删除【跟随者设置】
+        Map<String, Object> columnMap = new HashMap<>();
+        Long followMemberId = followFollowerProfitEntity.getMemberId();
+        Long tradeId = followFollowerProfitEntity.getTradeId();
+        columnMap.put("member_id", followMemberId);
+        columnMap.put("trade_id", tradeId);
+        List<FollowFollowerSettingEntity> selectByMap = followFollowerSettingDao.selectByMap(columnMap);
+        if(CollUtil.isNotEmpty(selectByMap)) {
+        	for(FollowFollowerSettingEntity followFollowerSettingEntity : selectByMap) {
+        		followFollowerSettingDao.deleteById(followFollowerSettingEntity.getId());
+        	}
+        }
+        
 		return Result.ok(MessageSourceUtils.getString("member_service_0026"));
 	}
 	

--
Gitblit v1.9.1