From d9e5afcd0b04e52fe9a9e16f727685171a00842d Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Mon, 03 Aug 2020 10:45:14 +0800
Subject: [PATCH] modify

---
 src/main/java/com/xcong/excoin/modules/documentary/service/impl/DocumentaryServiceImpl.java |   66 +++++++++++++++++++++++++++------
 1 files changed, 54 insertions(+), 12 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 e583568..8fdc2c2 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
@@ -10,6 +10,7 @@
 import javax.annotation.Resource;
 import javax.validation.Valid;
 
+import org.apache.http.impl.NoConnectionReuseStrategy;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -51,6 +52,7 @@
 import com.xcong.excoin.modules.documentary.vo.MemberIsTradeVo;
 import com.xcong.excoin.modules.documentary.vo.MyFollowOrderVo;
 import com.xcong.excoin.modules.documentary.vo.MyFollowTraderInfoVo;
+import com.xcong.excoin.modules.documentary.vo.TraderStatusVo;
 import com.xcong.excoin.modules.member.dao.MemberDao;
 import com.xcong.excoin.modules.member.dao.MemberLevelRateDao;
 import com.xcong.excoin.modules.member.dao.MemberWalletContractDao;
@@ -254,6 +256,14 @@
         	if(CollUtil.isNotEmpty(records)) {
         		for(ContractOrderEntity contractOrderEntity : records) {
         			MyFollowOrderVo myFollowOrderVo = new MyFollowOrderVo();
+        			//获取交易员信息
+					Long orderId = contractOrderEntity.getId();
+					FollowFollowerOrderRelationEntity FollowFollowerOrderRelation = followFollowerOrderRelationDao.selectHistoryOneByorderId(orderId);
+					Long tradeId = FollowFollowerOrderRelation.getTradeId();
+					FollowTraderInfoEntity followTraderInfoEntity = followTraderInfoDao.selectById(tradeId);
+					String nickname = followTraderInfoEntity.getNickname();
+					myFollowOrderVo.setNickname(nickname);
+        			
         			String symbol = contractOrderEntity.getSymbol();
         			myFollowOrderVo.setSymbol(symbol);
         			int orderType = contractOrderEntity.getOrderType();
@@ -301,7 +311,7 @@
 					MyFollowOrderVo myFollowOrderVo = new MyFollowOrderVo();
 					//获取交易员信息
 					Long orderId = contractHoldOrderEntity.getId();
-					FollowFollowerOrderRelationEntity FollowFollowerOrderRelation = followFollowerOrderRelationDao.selectOneByorderIdandMemberId(orderId,memberId);
+					FollowFollowerOrderRelationEntity FollowFollowerOrderRelation = followFollowerOrderRelationDao.selectNowOneByorderId(orderId);
 					Long tradeId = FollowFollowerOrderRelation.getTradeId();
 					FollowTraderInfoEntity followTraderInfoEntity = followTraderInfoDao.selectById(tradeId);
 					String nickname = followTraderInfoEntity.getNickname();
@@ -365,9 +375,7 @@
 	public Result getMyFollowTraderInfo(@Valid MyFollowTraderInfoDto myFollowTraderInfoDto) {
 		//获取用户ID
         Long memberId = LoginUserUtils.getAppLoginUser().getId();
-        
-        Page<MyFollowTraderInfoVo> result = new Page<>();
-        List<MyFollowTraderInfoVo> myFollowOrderVos = result.getRecords();
+        List<MyFollowTraderInfoVo> myFollowOrderVos = new ArrayList<>();
         
         Page<FollowFollowerProfitEntity> page = new Page<>(myFollowTraderInfoDto.getPageNum(), myFollowTraderInfoDto.getPageSize());
 		IPage<FollowFollowerProfitEntity> followFollowerProfitEntitys = followFollowerProfitDao.selectFollowFollowerProfitEntitys(page, memberId);
@@ -389,7 +397,7 @@
 	        	myFollowOrderVos.add(myFollowTraderInfoVo);
 	        }
 		}
-		return Result.ok(result);
+		return Result.ok(myFollowOrderVos);
 	}
 
 	@Override
@@ -462,14 +470,15 @@
 	}
 
 	@Override
-	public Result getDocumentaryOrderSetInfo() {
+	public Result getDocumentaryOrderSetInfo(String tradeId) {
 		//获取用户ID
         Long memberId = LoginUserUtils.getAppLoginUser().getId();
         DocumentaryOrderSetInfoVo documentaryOrderSetInfoVo = new DocumentaryOrderSetInfoVo();
+        long parseLong = Long.parseLong(tradeId);
         //获取【跟随者设置】数据
-        FollowFollowerSettingEntity followFollowerSettingEntity = followFollowerSettingDao.selectDocumentaryOrderSetInfoBymemberId(memberId);
-        Long tradeId = followFollowerSettingEntity.getTradeId();
-        documentaryOrderSetInfoVo.setTraderId(tradeId);
+        FollowFollowerSettingEntity followFollowerSettingEntity = followFollowerSettingDao.selectOneBymemberIdAndTradeId(memberId,parseLong);
+
+        documentaryOrderSetInfoVo.setTraderId(parseLong);
         
         FollowTraderInfoEntity followTraderInfoEntity = followTraderInfoDao.selectById(tradeId);
         String avatar = followTraderInfoEntity.getAvatar();
@@ -477,7 +486,11 @@
         
         String nickname = followTraderInfoEntity.getNickname();
         documentaryOrderSetInfoVo.setNickname(nickname);
-        
+
+		documentaryOrderSetInfoVo.setProfit(followTraderInfoEntity.getProfitRatio());
+        if (followFollowerSettingEntity == null) {
+        	return Result.ok(documentaryOrderSetInfoVo);
+		}
         String symbols = followFollowerSettingEntity.getSymbols();
         documentaryOrderSetInfoVo.setSymbols(symbols);
         
@@ -489,7 +502,6 @@
         
         Integer maxFollowCnt = followFollowerSettingEntity.getMaxFollowCnt();
         documentaryOrderSetInfoVo.setMaxFollowCnt(maxFollowCnt);
-        
         
 		return Result.ok(documentaryOrderSetInfoVo);
 	}
@@ -551,8 +563,14 @@
         MemberEntity memberEntity = memberDao.selectById(memberId);
         Integer certifyStatus = memberEntity.getCertifyStatus();
         if(MemberEntity.CERTIFY_STATUS_Y != certifyStatus) {
-        	return Result.ok(MessageSourceUtils.getString("member_controller_0009"));
+        	return Result.fail(MessageSourceUtils.getString("member_controller_0009"));
         }
+        Map<String, Object> columnMap = new HashMap<>();
+        columnMap.put("member_id", memberId);
+		List<FollowTraderInfoEntity> selectByMap = followTraderInfoDao.selectByMap(columnMap);
+		if(CollUtil.isNotEmpty(selectByMap)) {
+			return Result.fail("submit_repeat");
+		}
         //新增【交易员信息表】数据
         FollowTraderInfoEntity followTraderInfoEntity = new FollowTraderInfoEntity();
         followTraderInfoEntity.setMemberId(memberId);
@@ -572,6 +590,30 @@
         followTraderInfoDao.insert(followTraderInfoEntity);
 		return Result.ok(MessageSourceUtils.getString("member_service_0024"));
 	}
+
+	@Override
+	public Result beTraderStatus() {
+		//获取用户ID
+        Long memberId = LoginUserUtils.getAppLoginUser().getId();
+        MemberEntity memberEntity = memberDao.selectById(memberId);
+        
+        TraderStatusVo traderStatusVo = new TraderStatusVo();
+        Integer isTraer = memberEntity.getIsTrader();
+        traderStatusVo.setIsTrader(isTraer);
+        
+        Map<String, Object> columnMap = new HashMap<>();
+        columnMap.put("member_id", memberId);
+		List<FollowTraderInfoEntity> selectByMap = followTraderInfoDao.selectByMap(columnMap);
+		if(CollUtil.isNotEmpty(selectByMap)) {
+			for(FollowTraderInfoEntity followTraderInfoEntity : selectByMap) {
+				Integer verifyStatus = followTraderInfoEntity.getVerifyStatus();
+				traderStatusVo.setVerifyStatus(verifyStatus);
+			}
+		}else{
+			traderStatusVo.setVerifyStatus(4);
+		}
+		return Result.ok(traderStatusVo);
+	}
 	
 	
 	

--
Gitblit v1.9.1