From 325508eb8d311e07c68cb6c352ffe519459f9edd Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Tue, 23 Mar 2021 17:22:37 +0800
Subject: [PATCH] 20210323 后台保留两位小数，（平台数据除外）
---
src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java | 120 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 117 insertions(+), 3 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java b/src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java
index 670653d..70d8431 100644
--- a/src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java
+++ b/src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java
@@ -3,10 +3,14 @@
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
+
+import com.baomidou.mybatisplus.core.conditions.Wrapper;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.xcong.excoin.common.configure.FebsConfigure;
import com.xcong.excoin.common.entity.FebsResponse;
import com.xcong.excoin.common.entity.QueryRequest;
import com.xcong.excoin.modules.Sms106Send;
@@ -40,6 +44,7 @@
import lombok.RequiredArgsConstructor;
import java.math.BigDecimal;
+import java.text.DecimalFormat;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
@@ -93,10 +98,10 @@
if(records != null && records.size() > 0) {
for(AgentFriendRelationEntity agentFriendRelation : records) {
String inviteId = agentFriendRelation.getInviteId();
- if("90457646".equals(inviteId)) {
+ if("rxadr3".equals(inviteId)) {
//该邀请码下的所有代理
Map<String, Object> columnMap = new HashMap<>();
- columnMap.put("referer_id", "90457646");
+ columnMap.put("referer_id", "rxadr3");
List<AgentFriendRelationEntity> selectByMap = agentFriendRelationMapper.selectByMap(columnMap);
if(selectByMap != null && selectByMap.size() > 0) {
@@ -396,6 +401,23 @@
@Override
public IPage<MemberCoinChargeVo> findMemberApplyCoinListInPage(MemberCoinChargeEntity memberCoinChargeEntity,
QueryRequest request) {
+ //查询条件 查询某条线下的所有数据
+ String account = memberCoinChargeEntity.getAccount();
+ //如果account为空，查询全部，account不为空查询对应的memberEntity
+ if(StrUtil.isNotEmpty(account)) {
+ MemberEntity selectMemberByAccount = memberMapper.selectMemberByAccount(account);
+ String inviteId = selectMemberByAccount.getInviteId();
+ Long id = selectMemberByAccount.getId();
+ memberCoinChargeEntity.setMemberId(id);
+ memberCoinChargeEntity.setInviteId(inviteId);
+ }else {
+ MemberEntity memberEntity = memberMapper.selectMemberByAccount(MemberEntity.SYSTEM_REFERER);
+ String inviteId = memberEntity.getInviteId();
+ Long id = memberEntity.getId();
+ memberCoinChargeEntity.setMemberId(id);
+ memberCoinChargeEntity.setInviteId(inviteId);
+ }
+
Page<MemberCoinChargeEntity> page = new Page<>(request.getPageNum(), request.getPageSize());
IPage<MemberCoinChargeVo> findmemberQuickBuySaleListInPage = memberCoinChargeMapper.findMemberApplyCoinListInPage(page, memberCoinChargeEntity);
List<MemberCoinChargeVo> records = findmemberQuickBuySaleListInPage.getRecords();
@@ -421,8 +443,24 @@
@Override
public IPage<MemberCoinWithdrawVo> findmemberWithdrawCoinListInPage(
MemberCoinWithdrawEntity memberCoinWithdrawEntity, QueryRequest request) {
- Page<MemberCoinWithdrawEntity> page = new Page<>(request.getPageNum(), request.getPageSize());
+ //查询条件 查询某条线下的所有数据
+ String account = memberCoinWithdrawEntity.getAccount();
+ //如果account为空，查询全部，account不为空查询对应的memberEntity
+ if(StrUtil.isNotEmpty(account)) {
+ MemberEntity selectMemberByAccount = memberMapper.selectMemberByAccount(account);
+ String inviteId = selectMemberByAccount.getInviteId();
+ Long id = selectMemberByAccount.getId();
+ memberCoinWithdrawEntity.setMemberId(id);
+ memberCoinWithdrawEntity.setInviteId(inviteId);
+ }else {
+ MemberEntity memberEntity = memberMapper.selectMemberByAccount(MemberEntity.SYSTEM_REFERER);
+ String inviteId = memberEntity.getInviteId();
+ Long id = memberEntity.getId();
+ memberCoinWithdrawEntity.setMemberId(id);
+ memberCoinWithdrawEntity.setInviteId(inviteId);
+ }
+ Page<MemberCoinWithdrawEntity> page = new Page<>(request.getPageNum(), request.getPageSize());
IPage<MemberCoinWithdrawVo> findmemberQuickBuySaleListInPage = memberCoinWithdrawMapper.findmemberWithdrawCoinListInPage(page, memberCoinWithdrawEntity);
List<MemberCoinWithdrawVo> records = findmemberQuickBuySaleListInPage.getRecords();
if(records != null && records.size() > 0) {
@@ -2182,4 +2220,80 @@
return findmemberQuickBuySaleListInPage;
}
+ @Override
+ public IPage<MemberDataInfoVo> findAllDataInfoListInPage(MemberEntity memberEntity, QueryRequest request) {
+ String account = memberEntity.getAccount();
+ String isTest = memberEntity.getIsTest();
+ //如果account为空，查询全部，account不为空查询对应的memberEntity
+ if(StrUtil.isNotEmpty(account)) {
+ memberEntity = memberMapper.selectMemberByAccount(account);
+ }else {
+ memberEntity = memberMapper.selectMemberByAccount(MemberEntity.SYSTEM_REFERER);
+ }
+ memberEntity.setIsTest(isTest);
+ Page<MemberEntity> page = new Page<>(request.getPageNum(), request.getPageSize());
+ IPage<MemberDataInfoVo> selectMemberListInPage = memberMapper.findMemberDataInfoOneAllRealInPage(page, memberEntity);
+ //USDT充币总额+USDT提币总额
+ String totalAmountUsdtB = memberMapper.selectTotalAmountUsdtBForAllDataInfo(memberEntity);
+ String totalAmountUsdtS = memberMapper.selectTotalAmountUsdtSForAllDataInfo(memberEntity);
+ String totalAmountUsdtCZ = memberMapper.selectTotalAmountUsdtCZForAllDataInfo(memberEntity);
+ String totalAmountUsdtTX = memberMapper.selectTotalAmountUsdtTXForAllDataInfo(memberEntity);
+ //佣金
+ String returnMoneyByMid = memberMapper.selectReturnMoneyForAllDataInfo(memberEntity);
+ //开仓手续费
+ String closingpriceByMid = memberMapper.selectClosingpriceForAllDataInfo(memberEntity);
+ //平仓总手续费
+ String sellClosingpriceByMid = memberMapper.selectSellClosingpriceForForAllDataInfo(memberEntity);
+ //总盈亏
+ String rewardratioByMid = memberMapper.selectRewardratioForAllDataInfo(memberEntity);
+
+ //持仓人数
+ String notNullNumber = memberMapper.selectSFCCForAllDataInfo(memberEntity);
+ //币币账户不为空的人数
+ String walletNumber = memberMapper.selectBBZHForAllDataInfo(memberEntity);
+ //合约账户不为空的人数
+ String walletCoinNumber = memberMapper.selectHYZHForAllDataInfo(memberEntity);
+ //持仓手续费
+ String doingPrice = memberMapper.selectprepriceForAllDataInfo(memberEntity);
+
+ //账户金额
+ String walletNum = memberMapper.selectBBZCForAllDataInfo(memberEntity);
+ String walletCoinNum = memberMapper.selectHYZCForAllDataInfo(memberEntity);
+ String agentNum = memberMapper.selectDLZCForAllDataInfo(memberEntity);
+ double allCoin = 0 ;
+ allCoin = (walletNum == null ? 0 : Double.parseDouble(walletNum))
+ +(walletCoinNum == null ? 0 : Double.parseDouble(walletCoinNum))
+ +(agentNum == null ? 0 : Double.parseDouble(agentNum));
+
+ double platformProfitAndLoss = 0.00 ;
+ platformProfitAndLoss = platformProfitAndLoss + (totalAmountUsdtB == null ? 0 : Double.parseDouble(totalAmountUsdtB));
+ platformProfitAndLoss = platformProfitAndLoss + (totalAmountUsdtCZ == null ? 0 : Double.parseDouble(totalAmountUsdtCZ));
+ platformProfitAndLoss = platformProfitAndLoss - (totalAmountUsdtS == null ? 0 : Double.parseDouble(totalAmountUsdtS));
+ platformProfitAndLoss = platformProfitAndLoss - (totalAmountUsdtTX == null ? 0 : Double.parseDouble(totalAmountUsdtTX));
+
+ List<MemberDataInfoVo> records = selectMemberListInPage.getRecords();
+ for(MemberDataInfoVo memberDataInfoVo : records) {
+ DecimalFormat df = new DecimalFormat("0.00");
+ memberDataInfoVo.setChargeUsdt(totalAmountUsdtCZ == null ? 0 : Double.parseDouble(totalAmountUsdtCZ));
+ memberDataInfoVo.setAppealUsdt(totalAmountUsdtTX == null ? 0 : Double.parseDouble(totalAmountUsdtTX));
+ memberDataInfoVo.setChargeCoin(totalAmountUsdtB == null ? 0 : Double.parseDouble(totalAmountUsdtB));
+ memberDataInfoVo.setAppealCoin(totalAmountUsdtS == null ? 0 : Double.parseDouble(totalAmountUsdtS));
+ memberDataInfoVo.setClosingPrice(closingpriceByMid == "0" ? "0" : df.format(Double.parseDouble(closingpriceByMid)));
+ memberDataInfoVo.setSellClosingPrice(sellClosingpriceByMid == "0" ? "0" : df.format(Double.parseDouble(sellClosingpriceByMid)));
+ memberDataInfoVo.setFee(returnMoneyByMid == "0" ? "0" : df.format(Double.parseDouble(returnMoneyByMid)));
+ memberDataInfoVo.setYingkui(rewardratioByMid == null ? "0" : df.format(Double.parseDouble(rewardratioByMid)));
+ memberDataInfoVo.setNotNullNumber(notNullNumber == null ? "0" : notNullNumber);
+ memberDataInfoVo.setWalletNumber(walletNumber == null ? "0" : walletNumber);
+ memberDataInfoVo.setWalletCoinNumber(walletCoinNumber == null ? "0" : walletCoinNumber);
+ memberDataInfoVo.setPlatformProfitAndLoss(platformProfitAndLoss == 0.00 ? "0" : df.format(platformProfitAndLoss));
+ memberDataInfoVo.setDoingPrice(doingPrice == "0" ? "0" : df.format(Double.parseDouble(doingPrice)));
+ memberDataInfoVo.setWalletNum(walletNum == null ? "0" : df.format(Double.parseDouble(walletNum)));
+ memberDataInfoVo.setWalletCoinNum(walletCoinNum == null ? "0" : df.format(Double.parseDouble(walletCoinNum)));
+ memberDataInfoVo.setAgentNum(agentNum == null ? "0" : df.format(Double.parseDouble(agentNum)));
+ memberDataInfoVo.setAllCoin(allCoin);
+ }
+ selectMemberListInPage.setTotal(1);
+ return selectMemberListInPage;
+ }
+
}
--
Gitblit v1.9.1