From 829d77f7145514d67d957ad54dbef854440f77d3 Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Fri, 31 Jul 2020 17:05:08 +0800
Subject: [PATCH] fix conflect

---
 src/main/java/com/xcong/excoin/modules/documentary/service/impl/DocumentaryServiceImpl.java |   65 ++++++++++++++++++++++++++++----
 1 files changed, 57 insertions(+), 8 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 5f59d22..44a35ad 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;
 
@@ -23,6 +24,7 @@
 import com.xcong.excoin.modules.contract.dao.ContractHoldOrderDao;
 import com.xcong.excoin.modules.contract.entity.ContractHoldOrderEntity;
 import com.xcong.excoin.modules.contract.entity.ContractOrderEntity;
+import com.xcong.excoin.modules.documentary.dao.FollowFollowerOrderRelationDao;
 import com.xcong.excoin.modules.documentary.dao.FollowFollowerProfitDao;
 import com.xcong.excoin.modules.documentary.dao.FollowFollowerSettingDao;
 import com.xcong.excoin.modules.documentary.dao.FollowTraderInfoDao;
@@ -35,6 +37,7 @@
 import com.xcong.excoin.modules.documentary.dto.MyFollowOrderDto;
 import com.xcong.excoin.modules.documentary.dto.MyFollowTraderInfoDto;
 import com.xcong.excoin.modules.documentary.dto.UpdateDocumentaryOrderSetDto;
+import com.xcong.excoin.modules.documentary.entity.FollowFollowerOrderRelationEntity;
 import com.xcong.excoin.modules.documentary.entity.FollowFollowerProfitEntity;
 import com.xcong.excoin.modules.documentary.entity.FollowFollowerSettingEntity;
 import com.xcong.excoin.modules.documentary.entity.FollowTraderInfoEntity;
@@ -94,6 +97,8 @@
     private MemberWalletContractDao memberWalletContractDao;
     @Resource
     private FollowFollowerSettingDao followFollowerSettingDao;
+    @Resource
+    private FollowFollowerOrderRelationDao followFollowerOrderRelationDao;
     
 	
 	@Override
@@ -241,8 +246,7 @@
 	public Result getHistoryMyFollowOrderRecords(@Valid MyFollowOrderDto myFollowOrderDto) {
 		//获取用户ID
         Long memberId = LoginUserUtils.getAppLoginUser().getId();
-        Page<MyFollowOrderVo> result = new Page<>();
-        List<MyFollowOrderVo> myFollowOrderVos = result.getRecords();
+        List<MyFollowOrderVo> myFollowOrderVos = new ArrayList<>();
         //历史跟单
         	Page<ContractOrderEntity> page = new Page<>(myFollowOrderDto.getPageNum(), myFollowOrderDto.getPageSize());
         	IPage<ContractOrderEntity> contractOrderEntitys = followFollowerProfitDao.getMyFollowOrderHistoryRecords(page, memberId);
@@ -251,6 +255,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();
@@ -287,8 +299,7 @@
 		Long memberId = LoginUserUtils.getAppLoginUser().getId();
 		MemberEntity member = memberDao.selectById(memberId);
 		
-		Page<MyFollowOrderVo> result = new Page<>();
-		List<MyFollowOrderVo> myFollowOrderVos = result.getRecords();
+		List<MyFollowOrderVo> myFollowOrderVos = new ArrayList<>();
 			//当前跟单	
 			Page<ContractHoldOrderEntity> page = new Page<>(myFollowOrderDto.getPageNum(), myFollowOrderDto.getPageSize());
 			IPage<ContractHoldOrderEntity> contractHoldOrderEntitys = followFollowerProfitDao.getMyFollowOrderNowRecords(page, memberId);
@@ -297,6 +308,14 @@
 			if(CollUtil.isNotEmpty(records)) {
 				for(ContractHoldOrderEntity contractHoldOrderEntity : records) {
 					MyFollowOrderVo myFollowOrderVo = new MyFollowOrderVo();
+					//获取交易员信息
+					Long orderId = contractHoldOrderEntity.getId();
+					FollowFollowerOrderRelationEntity FollowFollowerOrderRelation = followFollowerOrderRelationDao.selectNowOneByorderId(orderId);
+					Long tradeId = FollowFollowerOrderRelation.getTradeId();
+					FollowTraderInfoEntity followTraderInfoEntity = followTraderInfoDao.selectById(tradeId);
+					String nickname = followTraderInfoEntity.getNickname();
+					myFollowOrderVo.setNickname(nickname);
+					
 					String symbol = contractHoldOrderEntity.getSymbol();
 					myFollowOrderVo.setSymbol(symbol);
 					int orderType = contractHoldOrderEntity.getOpeningType();
@@ -316,6 +335,8 @@
 					
 					// 获取最新价
 					BigDecimal newPrice = new BigDecimal(redisUtils.getString(CoinTypeConvert.convertToKey(contractHoldOrderEntity.getSymbol())));
+					myFollowOrderVo.setNewPrice(newPrice);
+					
 					BigDecimal lotNumber = cacheSettingUtils.getSymbolSku(contractHoldOrderEntity.getSymbol());
 					// 盈亏
 					BigDecimal rewardRatio = BigDecimal.ZERO;
@@ -353,9 +374,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);
@@ -377,7 +396,7 @@
 	        	myFollowOrderVos.add(myFollowTraderInfoVo);
 	        }
 		}
-		return Result.ok(result);
+		return Result.ok(myFollowOrderVos);
 	}
 
 	@Override
@@ -530,6 +549,36 @@
 		followTraderProfitInfoVo.setIsAll(isAll);
 		return Result.ok(followTraderProfitInfoVo);
 	}
+
+	@Override
+	@Transactional
+	public Result beTrader() {
+		//获取用户ID
+        Long memberId = LoginUserUtils.getAppLoginUser().getId();
+        MemberEntity memberEntity = memberDao.selectById(memberId);
+        Integer certifyStatus = memberEntity.getCertifyStatus();
+        if(MemberEntity.CERTIFY_STATUS_Y != certifyStatus) {
+        	return Result.ok(MessageSourceUtils.getString("member_controller_0009"));
+        }
+        //新增【交易员信息表】数据
+        FollowTraderInfoEntity followTraderInfoEntity = new FollowTraderInfoEntity();
+        followTraderInfoEntity.setMemberId(memberId);
+        followTraderInfoEntity.setAvatar(FollowTraderInfoEntity.AVATAR_DEFAULT);
+        String phone = memberEntity.getPhone();
+        String email = memberEntity.getEmail();
+        if(StrUtil.isNotEmpty(phone)) {
+        	followTraderInfoEntity.setNickname(phone);
+        }else {
+        	followTraderInfoEntity.setNickname(email);
+        }
+        followTraderInfoEntity.setDeclaration(FollowTraderInfoEntity.DECLARATION_DEFAULT);
+        followTraderInfoEntity.setIsAll(FollowTraderInfoEntity.IS_ALL_N);
+        followTraderInfoEntity.setProfitRatio(BigDecimal.ZERO);
+        followTraderInfoEntity.setVerifyStatus(FollowTraderInfoEntity.VERIFYSTATUS_ING);
+        followTraderInfoEntity.setIsOpen(FollowTraderInfoEntity.ISOPEN_Y);
+        followTraderInfoDao.insert(followTraderInfoEntity);
+		return Result.ok(MessageSourceUtils.getString("member_service_0024"));
+	}
 	
 	
 	

--
Gitblit v1.9.1