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