From ddb80e71d0cd0b60fd9805fe38a55245d325baa7 Mon Sep 17 00:00:00 2001 From: zainali5120 <512061637@qq.com> Date: Wed, 11 Nov 2020 16:40:19 +0800 Subject: [PATCH] 添加相关功能 --- src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java | 136 +++++++++++++++++++++++--------------------- 1 files changed, 71 insertions(+), 65 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 e5bda2a..0322221 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 @@ -9,8 +9,10 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.xcong.excoin.common.entity.FebsResponse; import com.xcong.excoin.common.entity.QueryRequest; +import com.xcong.excoin.common.utils.RedisUtils; import com.xcong.excoin.modules.Sms106Send; import com.xcong.excoin.modules.member.dto.MemberDetailConfirmDto; +import com.xcong.excoin.modules.member.dto.MemberLimitDto; import com.xcong.excoin.modules.member.entity.AgentFriendRelationEntity; import com.xcong.excoin.modules.member.entity.MemberAccountMoneyChangeEntity; import com.xcong.excoin.modules.member.entity.MemberAuthenticationEntity; @@ -85,6 +87,8 @@ private final MemberAuthenticationMapper memberAuthenticationMapper; private final AgentFriendRelationMapper agentFriendRelationMapper; + + private final RedisUtils redisUtils; @Override public IPage<AgentFriendRelationEntity> findAgentInfoListInPage(AgentFriendRelationEntity agentFriendRelationEntity, @@ -401,23 +405,6 @@ QueryRequest request) { Page<MemberCoinChargeEntity> page = new Page<>(request.getPageNum(), request.getPageSize()); IPage<MemberCoinChargeVo> findmemberQuickBuySaleListInPage = memberCoinChargeMapper.findMemberApplyCoinListInPage(page, memberCoinChargeEntity); - List<MemberCoinChargeVo> records = findmemberQuickBuySaleListInPage.getRecords(); - if(CollUtil.isNotEmpty(records)) { - for(MemberCoinChargeVo memberCoinChargeVo : records) { - Long memberId = memberCoinChargeVo.getMemberId(); - Map<String, Object> columnMap = new HashMap<>(); - columnMap.put("member_id", memberId); - List<MemberAuthenticationEntity> selectByMap = memberAuthenticationMapper.selectByMap(columnMap ); - if(selectByMap != null && selectByMap.size() > 0) { - MemberAuthenticationEntity memberAuthenticationEntity = selectByMap.get(0); - String firstName = memberAuthenticationEntity.getFirstName(); - String secondName = memberAuthenticationEntity.getSecondName(); - String realName = firstName + secondName; - memberCoinChargeVo.setRealName(realName); - } - } - } - return findmemberQuickBuySaleListInPage; } @@ -432,17 +419,6 @@ for(MemberCoinWithdrawVo memberCoinWithdrawVo : records) { Long memberId = memberCoinWithdrawVo.getMemberId(); - Map<String, Object> columnMap = new HashMap<>(); - columnMap.put("member_id", memberId); - List<MemberAuthenticationEntity> selectByMap = memberAuthenticationMapper.selectByMap(columnMap ); - if(selectByMap != null && selectByMap.size() > 0) { - MemberAuthenticationEntity memberAuthenticationEntity = selectByMap.get(0); - String firstName = memberAuthenticationEntity.getFirstName(); - String secondName = memberAuthenticationEntity.getSecondName(); - String realName = firstName + secondName; - memberCoinWithdrawVo.setRealName(realName); - } - BigDecimal amount = memberCoinWithdrawVo.getAmount(); BigDecimal feeAmount = memberCoinWithdrawVo.getFeeAmount(); BigDecimal subtract = amount.subtract(feeAmount); @@ -1349,54 +1325,58 @@ @Override - public MemberInfoDetailVo selectMemberInfoDetailByInviteId(String inviteId) { + public MemberInfoDetailVo selectMemberInfoDetailByInviteId(String inviteId) { String id = memberMapper.selectMemberInfoDetailByInviteId(inviteId); Long memberId = Long.parseLong(id); MemberInfoDetailVo memberInfoDetailVo = new MemberInfoDetailVo(); - + //USDT充币总额+USDT提币总额 - String totalAmountUsdtB = memberMapper.selectTotalAmountUsdtBForBasicRealDataBymemberId(memberId,"USDT"); - memberInfoDetailVo.setChargeCoin(totalAmountUsdtB == null ? 0 : Double.parseDouble(totalAmountUsdtB)); - String totalAmountUsdtS = memberMapper.selectTotalAmountUsdtSForBasicRealDataBymemberId(memberId); - memberInfoDetailVo.setAppealCoin(totalAmountUsdtS == null ? 0 : Double.parseDouble(totalAmountUsdtS)); - //USDT充值总额+USDT提现总额 - String totalAmountUsdtCZ = memberMapper.selectTotalAmountUsdtCZForBasicRealDataBymemberId(memberId); - memberInfoDetailVo.setChargeUsdt(totalAmountUsdtCZ == null ? 0 : Double.parseDouble(totalAmountUsdtCZ)); - String totalAmountUsdtTX = memberMapper.selectTotalAmountUsdtTXForBasicRealDataBymemberId(memberId); - memberInfoDetailVo.setAppealUsdt(totalAmountUsdtTX == null ? 0 : Double.parseDouble(totalAmountUsdtTX)); - //总剩余 - double platformProfitAndLoss = 0 ; - 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)); - memberInfoDetailVo.setTotalCoin(platformProfitAndLoss); + String totalAmountUsdtB = memberMapper.selectTotalAmountUsdtBForBasicRealDataBymemberId(memberId,"USDT"); + String totalAmountUsdtBRoc = memberMapper.selectTotalAmountUsdtBForBasicRealDataBymemberId(memberId,"ROC"); + memberInfoDetailVo.setChargeCoin(totalAmountUsdtB == null ? 0 : Double.parseDouble(totalAmountUsdtB)); + memberInfoDetailVo.setChargeCoinRoc(totalAmountUsdtBRoc == null ? 0 : Double.parseDouble(totalAmountUsdtBRoc)); + String totalAmountUsdtS = memberMapper.selectTotalAmountUsdtSForBasicRealDataBymemberId(memberId); + memberInfoDetailVo.setAppealCoin(totalAmountUsdtS == null ? 0 : Double.parseDouble(totalAmountUsdtS)); + //USDT充值总额+USDT提现总额 +// String totalAmountUsdtCZ = memberMapper.selectTotalAmountUsdtCZForBasicRealDataBymemberId(memberId); +// memberInfoDetailVo.setChargeUsdt(totalAmountUsdtCZ == null ? 0 : Double.parseDouble(totalAmountUsdtCZ)); +// String totalAmountUsdtTX = memberMapper.selectTotalAmountUsdtTXForBasicRealDataBymemberId(memberId); +// memberInfoDetailVo.setAppealUsdt(totalAmountUsdtTX == null ? 0 : Double.parseDouble(totalAmountUsdtTX)); + //总剩余 +// double platformProfitAndLoss = 0 ; +// 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)); +// memberInfoDetailVo.setTotalCoin(platformProfitAndLoss); //佣金 - String returnMoneyByMid = memberMapper.selectReturnMoneyForBasicRealDataBymemberId(memberId); - memberInfoDetailVo.setFee(returnMoneyByMid == null ? 0 : Double.parseDouble(returnMoneyByMid)); +// String returnMoneyByMid = memberMapper.selectReturnMoneyForBasicRealDataBymemberId(memberId); +// memberInfoDetailVo.setFee(returnMoneyByMid == null ? 0 : Double.parseDouble(returnMoneyByMid)); //开仓手续费总额 - String closingpriceByMid = memberMapper.selectClosingpriceForBasicRealDataBymemberId(memberId); - memberInfoDetailVo.setClosingPrice(closingpriceByMid == null ? 0 : Double.parseDouble(closingpriceByMid)); +// String closingpriceByMid = memberMapper.selectClosingpriceForBasicRealDataBymemberId(memberId); +// memberInfoDetailVo.setClosingPrice(closingpriceByMid == null ? 0 : Double.parseDouble(closingpriceByMid)); //平仓总手续费 - String sellClosingpriceByMid = memberMapper.selectSellClosingpriceForBasicRealDataBymemberId(memberId); - memberInfoDetailVo.setSellClosingPrice(sellClosingpriceByMid == null ? 0 : Double.parseDouble(sellClosingpriceByMid)); - - //总盈亏 - String rewardratioByMid = memberMapper.selectRewardratioForBasicRealDataBymemberId(memberId); - memberInfoDetailVo.setPlatformProfitAndLoss(rewardratioByMid == null ? 0 : Double.parseDouble(rewardratioByMid)); - +// String sellClosingpriceByMid = memberMapper.selectSellClosingpriceForBasicRealDataBymemberId(memberId); +// memberInfoDetailVo.setSellClosingPrice(sellClosingpriceByMid == null ? 0 : Double.parseDouble(sellClosingpriceByMid)); + +// //总盈亏 +// String rewardratioByMid = memberMapper.selectRewardratioForBasicRealDataBymemberId(memberId); +// memberInfoDetailVo.setPlatformProfitAndLoss(rewardratioByMid == null ? 0 : Double.parseDouble(rewardratioByMid)); + //持仓手续费 - String doingPrice = memberMapper.selectprepriceForBasicRealDataBymemberId(memberId); - memberInfoDetailVo.setDoingPrice(doingPrice == null ? 0 : Double.parseDouble(doingPrice)); - +// String doingPrice = memberMapper.selectprepriceForBasicRealDataBymemberId(memberId); +// memberInfoDetailVo.setDoingPrice(doingPrice == null ? 0 : Double.parseDouble(doingPrice)); + //账户金额 String walletNum = memberMapper.selectBBZCForBasicRealDataBymemberId(memberId,"USDT"); + String walletNumRoc = memberMapper.selectBBZCForBasicRealDataBymemberId(memberId,"ROC"); memberInfoDetailVo.setWalletCoinNum(walletNum == null ? 0 : Double.parseDouble(walletNum)); - String walletCoinNum = memberMapper.selectHYZCForBasicRealDataBymemberId(memberId); - memberInfoDetailVo.setTotalContract(walletCoinNum == null ? 0 : Double.parseDouble(walletCoinNum)); - String agentNum = memberMapper.selectDLZCForBasicRealDataBymemberId(memberId); - memberInfoDetailVo.setAgentNum(agentNum == null ? 0 : Double.parseDouble(agentNum)); - + memberInfoDetailVo.setWalletCoinNumRoc(walletNumRoc == null ? 0 : Double.parseDouble(walletNumRoc)); + //String walletCoinNum = memberMapper.selectHYZCForBasicRealDataBymemberId(memberId); + //memberInfoDetailVo.setTotalContract(walletCoinNum == null ? 0 : Double.parseDouble(walletCoinNum)); + //String agentNum = memberMapper.selectDLZCForBasicRealDataBymemberId(memberId); + //memberInfoDetailVo.setAgentNum(agentNum == null ? 0 : Double.parseDouble(agentNum)); + return memberInfoDetailVo; } @@ -1439,4 +1419,30 @@ return selectMemberListInPage; } + @Override + public MemberLimitDto memberLimit() { + Map<String,String> map = new HashMap<>(); + // 算力系统提币限制 + String roc_limit_transfer = redisUtils.getString("ROC_LIMIT_TRANSFER"); + // 交易所交易限制 + String sell_limit_key_phone = redisUtils.getString("SELL_LIMIT_KEY_PHONE"); + String golden_limit_transfer = redisUtils.getString("GOLDEN_LIMIT_TRANSFER"); + String buy_limit_key_phone = redisUtils.getString("BUY_LIMIT_KEY_PHONE"); + MemberLimitDto limitDto = new MemberLimitDto(); + limitDto.setJysmcxz(sell_limit_key_phone); + limitDto.setJystbxz(golden_limit_transfer); + limitDto.setSlxttbxz(roc_limit_transfer); + limitDto.setJysmrxz(buy_limit_key_phone); + return limitDto; + } + + @Override + public void setLimit(MemberLimitDto memberLimitDto) { + redisUtils.set("ROC_LIMIT_TRANSFER",memberLimitDto.getSlxttbxz()); + // 交易所交易限制 + redisUtils.set("SELL_LIMIT_KEY_PHONE",memberLimitDto.getJysmcxz()); + redisUtils.set("GOLDEN_LIMIT_TRANSFER",memberLimitDto.getJystbxz()); + redisUtils.set("BUY_LIMIT_KEY_PHONE",memberLimitDto.getJysmrxz()); + } + } -- Gitblit v1.9.1