From eb9d939661413fc70975b0a75b44126c257bdc49 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Wed, 14 Apr 2021 18:27:43 +0800
Subject: [PATCH] 20210414 测试账号的跟随者不返利给交易员
---
src/main/java/com/xcong/excoin/modules/documentary/service/impl/DocumentaryServiceImpl.java | 145 +++++++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 141 insertions(+), 4 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 6db2a42..4df5e40 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
@@ -2,6 +2,7 @@
import java.math.BigDecimal;
import java.util.ArrayList;
+import java.util.Calendar;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
@@ -65,6 +66,7 @@
import com.xcong.excoin.modules.documentary.vo.BeTraderConditionVo;
import com.xcong.excoin.modules.documentary.vo.DocumentaryOrderInfoVo;
import com.xcong.excoin.modules.documentary.vo.DocumentaryOrderSetInfoVo;
+import com.xcong.excoin.modules.documentary.vo.DocumentaryOrderSetStateVo;
import com.xcong.excoin.modules.documentary.vo.FollowFollowerNoticeVo;
import com.xcong.excoin.modules.documentary.vo.FollowInfoVo;
import com.xcong.excoin.modules.documentary.vo.FollowRecordsVo;
@@ -159,7 +161,17 @@
FollowTraderProfitInfoEntity followTraderProfitInfoEntity = new FollowTraderProfitInfoEntity();
if(FollowTraderInfoEntity.IS_SETFRIST_Y.equals(type)) {
followTraderProfitInfoEntity.setType(type);
+ }else {
+ String nicknameDto = recordsPageDto.getNickname();
+ followTraderProfitInfoEntity.setNickname(nicknameDto);
+ int totalProfitRatioSc = recordsPageDto.getTotalProfitRatioSc();
+ followTraderProfitInfoEntity.setTotalProfitRatioSc(totalProfitRatioSc);
+ int totalFollowerCntSc = recordsPageDto.getTotalFollowerCntSc();
+ followTraderProfitInfoEntity.setTotalFollowerCntSc(totalFollowerCntSc);
+ int winRateSc = recordsPageDto.getWinRateSc();
+ followTraderProfitInfoEntity.setWinRateSc(winRateSc);
}
+
IPage<FollowTraderProfitInfoVo> followTraderProfitInfoList = followTraderProfitInfoDao.selectFollowTraderProfitInfoEntity(page, followTraderProfitInfoEntity);
List<FollowTraderProfitInfoVo> followTraderProfitInfoVoList = followTraderProfitInfoList.getRecords();
@@ -175,9 +187,27 @@
}else {
FollowTraderProfitInfoVo.setDocumentaryType(2);
}
+
}
Long traderId = FollowTraderProfitInfoVo.getTraderId();
FollowTraderInfoEntity followTraderInfoEntity = followTraderInfoDao.selectFollowTraderInfoEntityBytreaderId(traderId);
+
+ //获取当前跟单人数
+ Map<String, Object> columnMap = new HashMap<>();
+ columnMap.put("trader_id", traderId);
+ List<FollowFollowerSettingEntity> selectByMap = followFollowerSettingDao.selectByMap(columnMap);
+ if(CollUtil.isNotEmpty(selectByMap)) {
+ Integer followNum = followTraderInfoEntity.getFollowNum();
+ int size = selectByMap.size();
+ if(followNum > size) {
+ FollowTraderProfitInfoVo.setIsActualAll(2);
+ }else {
+ FollowTraderProfitInfoVo.setIsActualAll(1);
+ }
+ }else {
+ FollowTraderProfitInfoVo.setIsActualAll(2);
+ }
+
String avatar = followTraderInfoEntity.getAvatar();
FollowTraderProfitInfoVo.setAvatar(avatar);
String nickname = followTraderInfoEntity.getNickname();
@@ -186,6 +216,10 @@
FollowTraderProfitInfoVo.setDeclaration(declaration);
Integer isAll = followTraderInfoEntity.getIsAll();
FollowTraderProfitInfoVo.setIsAll(isAll);
+
+ Date entryTime = followTraderInfoEntity.getEntryTime();
+ int datePoor = getDatePoor(entryTime, new Date());
+ FollowTraderProfitInfoVo.setEntryDays(datePoor);
String labels = followTraderInfoEntity.getLabels();
if(StrUtil.isNotEmpty(labels)) {
@@ -375,7 +409,7 @@
myFollowOrderVo.setLeverRatio(leverRatio);
BigDecimal rewardAmount = contractOrderEntity.getRewardAmount().setScale(2, BigDecimal.ROUND_DOWN);
myFollowOrderVo.setRewardAmount(rewardAmount);
- BigDecimal rewardRatio = contractOrderEntity.getRewardRatio().setScale(4, BigDecimal.ROUND_DOWN);
+ BigDecimal rewardRatio = contractOrderEntity.getRewardRatio() == null ? BigDecimal.ZERO : contractOrderEntity.getRewardRatio().setScale(4, BigDecimal.ROUND_DOWN);
myFollowOrderVo.setRewardRatio(rewardRatio);
int symbolCnt = contractOrderEntity.getSymbolCnt();
myFollowOrderVo.setSymbolCnt(symbolCnt);
@@ -496,7 +530,7 @@
String nickname = followTraderInfoEntity.getNickname();
myFollowTraderInfoVo.setNickname(nickname);
BigDecimal totalPrincipal = FollowFollowerProfitEntity.getTotalPrincipal();
- myFollowTraderInfoVo.setTotalPrincipal(totalPrincipal);
+ myFollowTraderInfoVo.setTotalPrincipal(totalPrincipal.setScale(2, BigDecimal.ROUND_DOWN));
BigDecimal totalProfit = FollowFollowerProfitEntity.getTotalProfit();
myFollowTraderInfoVo.setTotalProfit(totalProfit.setScale(2, BigDecimal.ROUND_DOWN));
@@ -749,6 +783,9 @@
String declaration = followTraderInfoEntity.getDeclaration();
Integer isAll = followTraderInfoEntity.getIsAll();
Integer followNum = followTraderInfoEntity.getFollowNum();
+ Date entryTime = followTraderInfoEntity.getEntryTime();
+ int datePoor = getDatePoor(entryTime, new Date());
+ followTraderProfitInfoVo.setEntryDays(datePoor);
//获取当前跟单人数
Map<String, Object> columnMap = new HashMap<>();
columnMap.put("trade_id", traderId);
@@ -759,12 +796,34 @@
}else {
followTraderProfitInfoVo.setFollowNumNow(0);
}
+ if(CollUtil.isNotEmpty(selectByMap)) {
+ if(followNum > selectByMap.size()){
+ followTraderProfitInfoVo.setIsActualAll(2);
+ }else{
+ followTraderProfitInfoVo.setIsActualAll(1);
+ }
+ }else {
+ followTraderProfitInfoVo.setIsActualAll(2);
+ }
followTraderProfitInfoVo.setFollowNum(followNum);
followTraderProfitInfoVo.setAvatar(avatar);
followTraderProfitInfoVo.setNickname(nickname);
followTraderProfitInfoVo.setDeclaration(declaration);
followTraderProfitInfoVo.setIsAll(isAll);
return Result.ok(followTraderProfitInfoVo);
+ }
+
+ //获取两个时间之间的日期
+ private int getDatePoor(Date endDate, Date nowDate) {
+ Calendar cal = Calendar.getInstance();
+ cal.setTime(endDate);
+ long time1 = cal.getTimeInMillis();
+ cal.setTime(nowDate);
+ long time2 = cal.getTimeInMillis();
+ long between_days=(time2-time1)/(1000*3600*24);
+ int parseInt = Integer.parseInt(String.valueOf(between_days));
+ parseInt = parseInt + 1;
+ return parseInt ;
}
@Override
@@ -939,7 +998,22 @@
TradeProfitInfoVo tradeProfitInfoVo = new TradeProfitInfoVo();
//获取【交易员信息表】数据
FollowTraderInfoEntity followTraderInfoEntity = followTraderInfoDao.selectTraderInfoByMemberId(memberId);
+ Date entryTime = followTraderInfoEntity.getEntryTime();
+ int datePoor = getDatePoor(entryTime, new Date());
+ tradeProfitInfoVo.setEntryDays(datePoor);
if(ObjectUtil.isNotEmpty(followTraderInfoEntity)) {
+ Integer followNum = followTraderInfoEntity.getFollowNum();
+ //获取当前跟单人数
+ Map<String, Object> columnMap = new HashMap<>();
+ columnMap.put("trade_id", followTraderInfoEntity.getId());
+ columnMap.put("is_follow", FollowFollowerProfitEntity.IS_FOLLOW_Y);
+ List<FollowFollowerProfitEntity> selectByMap = followFollowerProfitDao.selectByMap(columnMap);
+ if(CollUtil.isNotEmpty(selectByMap)) {
+ tradeProfitInfoVo.setFollowNumNow(selectByMap.size());
+ }else {
+ tradeProfitInfoVo.setFollowNumNow(0);
+ }
+ tradeProfitInfoVo.setFollowNum(followNum);
String avatar = followTraderInfoEntity.getAvatar();
tradeProfitInfoVo.setAvatar(avatar);
String nickname = followTraderInfoEntity.getNickname();
@@ -962,7 +1036,11 @@
tradeProfitInfoVo.setTotalFollowerCnt(totalFollowerCnt);
BigDecimal totalOrderCnt = followTraderProfitInfoVo.getTotalOrderCnt();
tradeProfitInfoVo.setTotalOrderCnt(totalOrderCnt);
- }
+ BigDecimal thirtyProfitRatio = followTraderProfitInfoVo.getThirtyProfitRatio();
+ tradeProfitInfoVo.setThirtyProfitRatio(thirtyProfitRatio);
+ BigDecimal thirtyRatio = followTraderProfitInfoVo.getThirtyRatio();
+ tradeProfitInfoVo.setThirtyRatio(thirtyRatio);
+ }
return Result.ok(tradeProfitInfoVo);
}
@@ -1078,6 +1156,7 @@
BigDecimal rewardAmount = orderEntity.getRewardAmount();
allRewardAmount = allRewardAmount.add(rewardAmount);
BigDecimal rewardRatio = orderEntity.getRewardRatio();
+ rewardRatio = rewardRatio == null ? BigDecimal.ZERO : rewardRatio;
allRewardRatio = allRewardRatio.add(rewardRatio);
}
}
@@ -1100,7 +1179,7 @@
myFollowOrderVo.setLeverRatio(leverRatio);
BigDecimal rewardAmount = contractOrderEntity.getRewardAmount().setScale(2, BigDecimal.ROUND_DOWN);
myFollowOrderVo.setRewardAmount(rewardAmount);
- BigDecimal rewardRatio = contractOrderEntity.getRewardRatio().setScale(4, BigDecimal.ROUND_DOWN);
+ BigDecimal rewardRatio = contractOrderEntity.getRewardRatio() == null ? BigDecimal.ZERO : contractOrderEntity.getRewardRatio().setScale(4, BigDecimal.ROUND_DOWN);
myFollowOrderVo.setRewardRatio(rewardRatio);
int symbolCnt = contractOrderEntity.getSymbolCnt();
myFollowOrderVo.setSymbolCnt(symbolCnt);
@@ -1265,6 +1344,64 @@
List<BeTraderConditionVo> beTraderConditionVos = followTraderInfoDao.selectBeTraderCondition(type);
return Result.ok(beTraderConditionVos);
}
+
+ @Override
+ public Result getDocumentaryOrderSetState(String tradeId) {
+ //获取用户ID
+ Long memberId = LoginUserUtils.getAppLoginUser().getId();
+ long parseLong = Long.parseLong(tradeId);
+ //交易员判断
+ Map<String, Object> columnMapTrader = new HashMap<>();
+ columnMapTrader.put("member_id", memberId);
+ List<FollowTraderInfoEntity> followTraderInfoEntitys = followTraderInfoDao.selectByMap(columnMapTrader);
+
+ //只能跟随一个人
+ Map<String, Object> columnMaps = new HashMap<>();
+ columnMaps.put("member_id", memberId);
+ List<FollowFollowerSettingEntity> followFollowerSettingEntityAllows = followFollowerSettingDao.selectByMap(columnMaps);
+
+ //没有交易员审核记录
+ if(CollUtil.isEmpty(followTraderInfoEntitys)) {
+ //没有跟随记录
+ if(CollUtil.isEmpty(followFollowerSettingEntityAllows)) {
+ return Result.ok("获取成功");
+ }else {
+ //有跟随记录
+ if(followFollowerSettingEntityAllows.size() == 1) {
+ Long tradeIdAllow = followFollowerSettingEntityAllows.get(0).getTraderId();
+ if(parseLong == tradeIdAllow) {
+ return Result.ok("获取成功");
+ }else{
+ return Result.fail("最多跟单一人");
+ }
+ }else{
+ return Result.fail("已经跟随多人，请修改");
+ }
+ }
+ }else{
+ Integer verifyStatus = followTraderInfoEntitys.get(0).getVerifyStatus();
+ if(FollowTraderInfoEntity.VERIFYSTATUS_N == verifyStatus) {
+ if(CollUtil.isEmpty(followFollowerSettingEntityAllows)) {
+ return Result.ok("获取成功");
+ }else {
+ if(followFollowerSettingEntityAllows.size() == 1) {
+ Long tradeIdAllow = followFollowerSettingEntityAllows.get(0).getTraderId();
+ if(parseLong == tradeIdAllow) {
+ return Result.ok("获取成功");
+ }else{
+ return Result.fail("最多跟单一人");
+ }
+ }else{
+ return Result.fail("已经跟随多人，请修改");
+ }
+ }
+ }else if(FollowTraderInfoEntity.VERIFYSTATUS_Y == verifyStatus){
+ return Result.fail("交易员不允许跟单");
+ }else {
+ return Result.fail("交易员审核中不允许跟单");
+ }
+ }
+ }
--
Gitblit v1.9.1