From fa290cbb49fc30778af140f133ec9f590573e3fb Mon Sep 17 00:00:00 2001 From: zainali5120 <512061637@qq.com> Date: Sun, 01 Nov 2020 20:46:37 +0800 Subject: [PATCH] 添加相关功能 --- src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java | 154 +++++++++++++++++++++++++++----------------------- 1 files changed, 83 insertions(+), 71 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 634d34e..e5bda2a 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 @@ -447,6 +447,10 @@ BigDecimal feeAmount = memberCoinWithdrawVo.getFeeAmount(); BigDecimal subtract = amount.subtract(feeAmount); memberCoinWithdrawVo.setRealAmount(subtract); + if("Y".equals(memberCoinWithdrawVo.getIsInside())){ + // 是内部转账 查询对应的地址 + + } } } return findmemberQuickBuySaleListInPage; @@ -465,7 +469,16 @@ if(status != 1) { return new FebsResponse().fail().message("只有等待审核的状态才能确认!"); } - + // 转币 需要扣除手续费 + amount = amount.subtract(selectById.getFeeAmount()); + if("ROC".equals(symbol) && !"Y".equals(selectById.getIsInside())){ + // 如果是ROC 则自动转 + String transfer = RocService.transfer(amount, address, "ROC"); + if(!"success".equals(transfer)){ + FebsResponse febsResponse = new FebsResponse(); + return febsResponse.fail().message(transfer); + } + } // 查询币币钱包 MemberWalletCoinEntity walletCoin = memberWalletCoinMapper.findWalletCoinByMemberIdAndWalletCode(memberId, symbol); @@ -488,8 +501,8 @@ Long aimMemberId = selectByMap.get(0).getMemberId(); MemberWalletCoinEntity aimWalletCoin = memberWalletCoinMapper.findWalletCoinByMemberIdAndWalletCode(aimMemberId, symbol); - BigDecimal addTotal = aimWalletCoin.getTotalBalance().add(selectById.getAmount()); - BigDecimal addAvailable = aimWalletCoin.getAvailableBalance().add(selectById.getAmount()); + BigDecimal addTotal = aimWalletCoin.getTotalBalance().add(amount); + BigDecimal addAvailable = aimWalletCoin.getAvailableBalance().add(amount); aimWalletCoin.setTotalBalance(addTotal); aimWalletCoin.setAvailableBalance(addAvailable); @@ -498,7 +511,7 @@ MemberAccountMoneyChangeEntity memberAccountMoneyChangeEntity = new MemberAccountMoneyChangeEntity(); memberAccountMoneyChangeEntity.setContent("收款"); memberAccountMoneyChangeEntity.setMemberId(aimMemberId); - memberAccountMoneyChangeEntity.setAmount(selectById.getAmount()); + memberAccountMoneyChangeEntity.setAmount(amount); memberAccountMoneyChangeEntity.setStatus(MemberAccountMoneyChangeEntity.STATUS_SUCCESS_INTEGER); memberAccountMoneyChangeEntity.setSymbol(selectById.getSymbol()); memberAccountMoneyChangeEntity.setType(MemberAccountMoneyChangeEntity.TYPE_WALLET_COIN); @@ -530,12 +543,7 @@ if(StrUtil.isNotBlank(phone)) { Sms106Send.sendWithdrawalCoinMsg(phone, time); } - // 转币 需要扣除手续费 - amount = amount.subtract(selectById.getFeeAmount()); - if("ROC".equals(symbol)){ - // 如果是ROC 则自动转 - String transfer = RocService.transfer(amount, address, "ROC"); - }else if("USDT".equals(symbol) && !"Y".equals(selectById.getIsInside())){ + if("USDT".equals(symbol) && !"Y".equals(selectById.getIsInside())){ // EthService ethService = new EthService(); // // 查询余额是否足够 // BigDecimal bigDecimal = ethService.tokenGetBalance(EthService.TOTAL_ADDRESS); @@ -729,38 +737,38 @@ @Override public FebsResponse addCoinConfirm(@Valid MemberEntity memberEntity) { - Long memberId = memberEntity.getId(); - String walletCode = "USDT"; - BigDecimal amountUsdt = memberEntity.getCoinNumber(); - - MemberEntity selectById = this.baseMapper.selectById(memberId); - if(ObjectUtils.isEmpty(selectById)) { - return new FebsResponse().message("用户已不存在"); - } - //获取币币钱包 - MemberWalletCoinEntity memberWalletCoinEntity = memberWalletCoinMapper.findWalletCoinByMemberIdAndWalletCode(memberId,walletCode); - BigDecimal availableBalance = memberWalletCoinEntity.getAvailableBalance(); - BigDecimal totalBalance = memberWalletCoinEntity.getTotalBalance(); - - memberWalletCoinEntity.setAvailableBalance(availableBalance.add(amountUsdt)); - memberWalletCoinEntity.setTotalBalance(totalBalance.add(amountUsdt)); - // 更新 - memberWalletCoinMapper.updateById(memberWalletCoinEntity); - - //添加币币资金划转历史记录 - MemberAccountMoneyChangeEntity memberAccountMoneyChangeEntity = new MemberAccountMoneyChangeEntity(); - memberAccountMoneyChangeEntity.setContent("充值"); - memberAccountMoneyChangeEntity.setMemberId(memberId); - memberAccountMoneyChangeEntity.setAmount(amountUsdt); - memberAccountMoneyChangeEntity.setStatus(MemberAccountMoneyChangeEntity.STATUS_SUCCESS_INTEGER); - memberAccountMoneyChangeEntity.setSymbol("USDT"); - memberAccountMoneyChangeEntity.setType(MemberAccountMoneyChangeEntity.TYPE_WALLET_COIN); - memberAccountMoneyChangeEntity.setCreateBy(selectById.getCreateBy()); - memberAccountMoneyChangeEntity.setCreateTime(new Date()); - memberAccountMoneyChangeEntity.setUpdateBy(selectById.getCreateBy()); - memberAccountMoneyChangeEntity.setUpdateTime(new Date()); - - memberAccountMoneyChangeMapper.insert(memberAccountMoneyChangeEntity); +// Long memberId = memberEntity.getId(); +// String walletCode = "USDT"; +// BigDecimal amountUsdt = memberEntity.getCoinNumber(); +// +// MemberEntity selectById = this.baseMapper.selectById(memberId); +// if(ObjectUtils.isEmpty(selectById)) { +// return new FebsResponse().message("用户已不存在"); +// } +// //获取币币钱包 +// MemberWalletCoinEntity memberWalletCoinEntity = memberWalletCoinMapper.findWalletCoinByMemberIdAndWalletCode(memberId,walletCode); +// BigDecimal availableBalance = memberWalletCoinEntity.getAvailableBalance(); +// BigDecimal totalBalance = memberWalletCoinEntity.getTotalBalance(); +// +// memberWalletCoinEntity.setAvailableBalance(availableBalance.add(amountUsdt)); +// memberWalletCoinEntity.setTotalBalance(totalBalance.add(amountUsdt)); +// // 更新 +// memberWalletCoinMapper.updateById(memberWalletCoinEntity); +// +// //添加币币资金划转历史记录 +// MemberAccountMoneyChangeEntity memberAccountMoneyChangeEntity = new MemberAccountMoneyChangeEntity(); +// memberAccountMoneyChangeEntity.setContent("充值"); +// memberAccountMoneyChangeEntity.setMemberId(memberId); +// memberAccountMoneyChangeEntity.setAmount(amountUsdt); +// memberAccountMoneyChangeEntity.setStatus(MemberAccountMoneyChangeEntity.STATUS_SUCCESS_INTEGER); +// memberAccountMoneyChangeEntity.setSymbol("USDT"); +// memberAccountMoneyChangeEntity.setType(MemberAccountMoneyChangeEntity.TYPE_WALLET_COIN); +// memberAccountMoneyChangeEntity.setCreateBy(selectById.getCreateBy()); +// memberAccountMoneyChangeEntity.setCreateTime(new Date()); +// memberAccountMoneyChangeEntity.setUpdateBy(selectById.getCreateBy()); +// memberAccountMoneyChangeEntity.setUpdateTime(new Date()); +// +// memberAccountMoneyChangeMapper.insert(memberAccountMoneyChangeEntity); /** * todo SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm"); @@ -782,47 +790,51 @@ MemberInfoDetailVo memberInfoDetailVo = new MemberInfoDetailVo(); //USDT充币总额+USDT提币总额 - String totalAmountUsdtB = memberMapper.selectTotalAmountUsdtBForBasicRealDataBymemberId(memberId); + 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)); +// 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); +// 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 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 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); + 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; } @@ -1343,7 +1355,7 @@ MemberInfoDetailVo memberInfoDetailVo = new MemberInfoDetailVo(); //USDT充币总额+USDT提币总额 - String totalAmountUsdtB = memberMapper.selectTotalAmountUsdtBForBasicRealDataBymemberId(memberId); + 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)); @@ -1378,7 +1390,7 @@ memberInfoDetailVo.setDoingPrice(doingPrice == null ? 0 : Double.parseDouble(doingPrice)); //账户金额 - String walletNum = memberMapper.selectBBZCForBasicRealDataBymemberId(memberId); + String walletNum = memberMapper.selectBBZCForBasicRealDataBymemberId(memberId,"USDT"); memberInfoDetailVo.setWalletCoinNum(walletNum == null ? 0 : Double.parseDouble(walletNum)); String walletCoinNum = memberMapper.selectHYZCForBasicRealDataBymemberId(memberId); memberInfoDetailVo.setTotalContract(walletCoinNum == null ? 0 : Double.parseDouble(walletCoinNum)); -- Gitblit v1.9.1