modify

Helius

2021-05-13 f8c1d9838e3c337d0dc9f406fb1b2b54e2be06b5

 src/main/java/com/xcong/excoin/modules/coin/service/impl/CoinServiceImpl.java

@@ -104,13 +104,15 @@


            if (CollUtil.isNotEmpty(memberWalletCoinlist)) {

                for (MemberWalletCoinEntity memberWalletCoinEntity : memberWalletCoinlist) {

                    MemberWalletCoinInfoVo memberWalletCoinInfoVo = new MemberWalletCoinInfoVo();

                    memberWalletCoinInfoVo.setAvailableBalance(memberWalletCoinEntity.getAvailableBalance().setScale(4, BigDecimal.ROUND_DOWN));

                    memberWalletCoinInfoVo.setFrozenBalance(memberWalletCoinEntity.getFrozenBalance().setScale(4, BigDecimal.ROUND_DOWN));

                    memberWalletCoinInfoVo.setMemberId(memberWalletCoinEntity.getMemberId());

                    memberWalletCoinInfoVo.setTotalBalance(memberWalletCoinEntity.getTotalBalance().setScale(4, BigDecimal.ROUND_DOWN));

                    memberWalletCoinInfoVo.setWalletCode(memberWalletCoinEntity.getWalletCode());

                    memberWalletCoinInfoVolist.add(memberWalletCoinInfoVo);

                    if ("USDT".equals(memberWalletCoinEntity.getWalletCode()) || "XCH".equals(memberWalletCoinEntity.getWalletCode())) {

                        MemberWalletCoinInfoVo memberWalletCoinInfoVo = new MemberWalletCoinInfoVo();

                        memberWalletCoinInfoVo.setAvailableBalance(memberWalletCoinEntity.getAvailableBalance().setScale(4, BigDecimal.ROUND_DOWN));

                        memberWalletCoinInfoVo.setFrozenBalance(memberWalletCoinEntity.getFrozenBalance().setScale(4, BigDecimal.ROUND_DOWN));

                        memberWalletCoinInfoVo.setMemberId(memberWalletCoinEntity.getMemberId());

                        memberWalletCoinInfoVo.setTotalBalance(memberWalletCoinEntity.getTotalBalance().setScale(4, BigDecimal.ROUND_DOWN));

                        memberWalletCoinInfoVo.setWalletCode(memberWalletCoinEntity.getWalletCode());

                        memberWalletCoinInfoVolist.add(memberWalletCoinInfoVo);

                    }

                }

            }



@@ -122,16 +124,25 @@
                        totalUsdts = totalUsdts.add(totalUsdt);

                        BigDecimal totalCny = totalUsdt.multiply(cnyUsdt);

                        walletCoin.setTotalBalance(totalCny);

                    } else {

                        BigDecimal amount = walletCoin.getAvailableBalance().add(walletCoin.getFrozenBalance());

                        // 获取最新价

                        BigDecimal closePrice = new BigDecimal(redisUtils.getString(CoinTypeConvert.convertToKey(walletCoin.getWalletCode()+"/USDT")));

                        BigDecimal totalUsdt = BigDecimal.ZERO;

                        //Double closePrice = symbolsService.getCloseSymbolsBySymbolsName(walletCoin.getWalletCode()+"/USDT");

                        totalUsdt = totalUsdt.add(amount.multiply(closePrice));

                        totalUsdts = totalUsdts.add(totalUsdt);

                        walletCoin.setTotalBalance(totalUsdt.multiply(cnyUsdt));

                    }



                    if ("XCH".equals(walletCoin.getWalletCode())) {

                        BigDecimal xch = walletCoin.getAvailableBalance().add(walletCoin.getFrozenBalance());

                        String xchNewPrice = redisUtils.getString("XCH_NEW_PRICE");

                        BigDecimal totalUsdt = xch.add(new BigDecimal(xchNewPrice));

                        BigDecimal totalCny = totalUsdt.multiply(cnyUsdt);

                        walletCoin.setTotalBalance(totalCny);

                    }

//                    else {

//                        BigDecimal amount = walletCoin.getAvailableBalance().add(walletCoin.getFrozenBalance());

//                        // 获取最新价

//                        BigDecimal closePrice = new BigDecimal(redisUtils.getString(CoinTypeConvert.convertToKey(walletCoin.getWalletCode()+"/USDT")));

//                        BigDecimal totalUsdt = BigDecimal.ZERO;

//                        //Double closePrice = symbolsService.getCloseSymbolsBySymbolsName(walletCoin.getWalletCode()+"/USDT");

//                        totalUsdt = totalUsdt.add(amount.multiply(closePrice));

//                        totalUsdts = totalUsdts.add(totalUsdt);

//                        walletCoin.setTotalBalance(totalUsdt.multiply(cnyUsdt));

//                    }

                }

            }

            MemberWalletCoinVo memberWalletCoinVo = new MemberWalletCoinVo();

@@ -416,57 +427,58 @@
        if (balance.compareTo(BigDecimal.ZERO) <= 0) {

          return Result.fail(MessageSourceUtils.getString("member_service_0004"));

       }



        //获取全仓模式下的所有持仓信息

        PlatformTradeSettingEntity tradeSetting = cacheSettingUtils.getTradeSetting();

        BigDecimal newPriceSymbol = new BigDecimal(redisUtils.getString(CoinTypeConvert.convertToKey(symbol)));

        List<ContractHoldOrderEntity> holdOrderEntities = contractHoldOrderDao.selectHoldOrderListForWholeByMemberIdAndSymbol(memberEntity.getId(),"");



        //获取合约当前持仓类型

        Integer contractPositionType = memberEntity.getContractPositionType();

        // 总盈利

        BigDecimal totalProfitOrLess = BigDecimal.ZERO;

        if (CollUtil.isNotEmpty(holdOrderEntities)) {

            for (ContractHoldOrderEntity holdOrderEntity : holdOrderEntities) {

                // 获取最新价

                BigDecimal newPrice = new BigDecimal(redisUtils.getString(CoinTypeConvert.convertToKey(holdOrderEntity.getSymbol())));

                BigDecimal lotNumber = cacheSettingUtils.getSymbolSku(holdOrderEntity.getSymbol());



                // 单个订单盈利

                BigDecimal profitOrLess = BigDecimal.ZERO;

                // 开多

                if (ContractHoldOrderEntity.OPENING_TYPE_MORE == holdOrderEntity.getOpeningType()) {

                    profitOrLess = newPrice.subtract(holdOrderEntity.getOpeningPrice()).multiply(new BigDecimal(holdOrderEntity.getSymbolCntSale())).multiply(lotNumber);

                    // 开空

                } else {

                    profitOrLess = holdOrderEntity.getOpeningPrice().subtract(newPrice).multiply(new BigDecimal(holdOrderEntity.getSymbolCntSale())).multiply(lotNumber);

                }



                if (MemberEntity.IS_PROFIT_Y == memberEntity.getIsProfit()) {

                    if (profitOrLess.compareTo(BigDecimal.ZERO) > 0) {

                        profitOrLess = profitOrLess.multiply(BigDecimal.ONE.subtract(tradeSetting.getForceParam()));

        if(contractPositionType == 2){

            //获取全仓模式下的所有持仓信息

            PlatformTradeSettingEntity tradeSetting = cacheSettingUtils.getTradeSetting();

            List<ContractHoldOrderEntity> holdOrderEntities = contractHoldOrderDao.selectHoldOrderListForWholeByMemberIdAndSymbol(memberEntity.getId(),"");

            if (CollUtil.isNotEmpty(holdOrderEntities)) {

                for (ContractHoldOrderEntity holdOrderEntity : holdOrderEntities) {

                    // 获取最新价

                    BigDecimal newPrice = new BigDecimal(redisUtils.getString(CoinTypeConvert.convertToKey(holdOrderEntity.getSymbol())));

                    BigDecimal lotNumber = cacheSettingUtils.getSymbolSku(holdOrderEntity.getSymbol());

                    // 单个订单盈利

                    BigDecimal profitOrLess = BigDecimal.ZERO;

                    // 开多

                    if (ContractHoldOrderEntity.OPENING_TYPE_MORE == holdOrderEntity.getOpeningType()) {

                        profitOrLess = newPrice.subtract(holdOrderEntity.getOpeningPrice()).multiply(new BigDecimal(holdOrderEntity.getSymbolCntSale())).multiply(lotNumber);

                        // 开空

                    } else {

                        profitOrLess = profitOrLess.multiply(BigDecimal.ONE.add(tradeSetting.getForceParam()));

                        profitOrLess = holdOrderEntity.getOpeningPrice().subtract(newPrice).multiply(new BigDecimal(holdOrderEntity.getSymbolCntSale())).multiply(lotNumber);

                    }

                    if (MemberEntity.IS_PROFIT_Y == memberEntity.getIsProfit()) {

                        if (profitOrLess.compareTo(BigDecimal.ZERO) > 0) {

                            profitOrLess = profitOrLess.multiply(BigDecimal.ONE.subtract(tradeSetting.getForceParam()));

                        } else {

                            profitOrLess = profitOrLess.multiply(BigDecimal.ONE.add(tradeSetting.getForceParam()));

                        }

                    }

                    totalProfitOrLess = totalProfitOrLess.add(profitOrLess);

                }

                totalProfitOrLess = totalProfitOrLess.add(profitOrLess);

            }

        }

    	


       String walletCode = MemberWalletCoinEnum.WALLETCOINCODE.getValue();

       MemberWalletContractEntity walletContract = memberWalletContractDao.findWalletContractByMemberIdAndSymbol(memberId, symbol);

       BigDecimal availableBalance = walletContract.getAvailableBalance();



       BigDecimal canReduce = availableBalance;

       //可用减去盈亏

       if(totalProfitOrLess.compareTo(BigDecimal.ZERO) < 0){

            availableBalance = availableBalance.add(totalProfitOrLess);

            canReduce = availableBalance.add(totalProfitOrLess);

        }

       // 扣币

       BigDecimal availableSubtract = availableBalance.subtract(balance);

       BigDecimal availableSubtract = canReduce.subtract(balance);

       if (availableSubtract.compareTo(BigDecimal.ZERO) < 0) {

          return Result.fail(MessageSourceUtils.getString("member_service_0007"));

       }

       BigDecimal totalBalance = walletContract.getTotalBalance();

       BigDecimal totalSubtract = totalBalance.subtract(balance);

       

       walletContract.setAvailableBalance(availableSubtract);

       walletContract.setAvailableBalance(availableBalance.subtract(balance));

       walletContract.setTotalBalance(totalSubtract);

       int updateWalletCoinById = memberWalletContractDao.updateById(walletContract);

       if (updateWalletCoinById < 1) {

@@ -512,8 +524,52 @@
    public Result findWalletContractBySymbol(String symbol) {

        //获取用户ID

        Long memberId = LoginUserUtils.getAppLoginUser().getId();

        MemberEntity memberEntity = memberDao.selectById(memberId);

        //获取合约当前持仓类型

        Integer contractPositionType = memberEntity.getContractPositionType();

        // 总盈利

        BigDecimal totalProfitOrLess = BigDecimal.ZERO;

        if(contractPositionType == 2){

            //获取全仓模式下的所有持仓信息

            PlatformTradeSettingEntity tradeSetting = cacheSettingUtils.getTradeSetting();

            List<ContractHoldOrderEntity> holdOrderEntities = contractHoldOrderDao.selectHoldOrderListForWholeByMemberIdAndSymbol(memberEntity.getId(),"");

            if (CollUtil.isNotEmpty(holdOrderEntities)) {

                for (ContractHoldOrderEntity holdOrderEntity : holdOrderEntities) {

                    // 获取最新价

                    BigDecimal newPrice = new BigDecimal(redisUtils.getString(CoinTypeConvert.convertToKey(holdOrderEntity.getSymbol())));

                    BigDecimal lotNumber = cacheSettingUtils.getSymbolSku(holdOrderEntity.getSymbol());

                    // 单个订单盈利

                    BigDecimal profitOrLess = BigDecimal.ZERO;

                    // 开多

                    if (ContractHoldOrderEntity.OPENING_TYPE_MORE == holdOrderEntity.getOpeningType()) {

                        profitOrLess = newPrice.subtract(holdOrderEntity.getOpeningPrice()).multiply(new BigDecimal(holdOrderEntity.getSymbolCntSale())).multiply(lotNumber);

                        // 开空

                    } else {

                        profitOrLess = holdOrderEntity.getOpeningPrice().subtract(newPrice).multiply(new BigDecimal(holdOrderEntity.getSymbolCntSale())).multiply(lotNumber);

                    }

                    if (MemberEntity.IS_PROFIT_Y == memberEntity.getIsProfit()) {

                        if (profitOrLess.compareTo(BigDecimal.ZERO) > 0) {

                            profitOrLess = profitOrLess.multiply(BigDecimal.ONE.subtract(tradeSetting.getForceParam()));

                        } else {

                            profitOrLess = profitOrLess.multiply(BigDecimal.ONE.add(tradeSetting.getForceParam()));

                        }

                    }

                    totalProfitOrLess = totalProfitOrLess.add(profitOrLess);

                }

            }

        }



        MemberWalletContractEntity walletContract = memberWalletContractDao.findWalletContractByMemberIdAndSymbol(memberId, symbol);

        BigDecimal availableBalance = walletContract.getAvailableBalance().setScale(4, BigDecimal.ROUND_DOWN);

        BigDecimal availableBalance = walletContract.getAvailableBalance();

        //可用减去盈亏

        if(totalProfitOrLess.compareTo(BigDecimal.ZERO) < 0){

            availableBalance = availableBalance.add(totalProfitOrLess);

        }

        if(availableBalance.compareTo(BigDecimal.ZERO) > 0){

            availableBalance = availableBalance.setScale(4, BigDecimal.ROUND_DOWN);

        }else{

            availableBalance = BigDecimal.ZERO;

        }

        return Result.ok(availableBalance);

    }



@@ -1067,33 +1123,30 @@
        return Result.fail(MessageSourceUtils.getString("member_controller_0005"));

        

    }

	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	




    @Override

    public BigDecimal getAllWalletAmount(Long memberId) {

        List<MemberWalletCoinEntity> memberWalletCoinList = memberWalletCoinDao.selectMemberWalletCoinsByMemberId(memberId);

        BigDecimal total = BigDecimal.ZERO;

        if (CollUtil.isNotEmpty(memberWalletCoinList)) {

            for (MemberWalletCoinEntity memberWalletCoinEntity : memberWalletCoinList) {

                if (memberWalletCoinEntity.getWalletCode().equals(CoinTypeEnum.USDT.name())) {

                    total = total.add(memberWalletCoinEntity.getTotalBalance());

                } else {

                    BigDecimal newPrice = new BigDecimal(redisUtils.getString(CoinTypeConvert.convertToKey(memberWalletCoinEntity.getWalletCode() + "/USDT")));

                    total = total.add(memberWalletCoinEntity.getTotalBalance().multiply(newPrice));

                }

            }

        }



        MemberWalletContractEntity contractWallet = memberWalletContractDao.findWalletContractByMemberIdAndSymbol(memberId, CoinTypeEnum.USDT.name());

        total = total.add(contractWallet.getTotalBalance());



        MemberWalletAgentEntity walletAgent = memberWalletAgentDao.selectWalletAgentBymIdAndCode(memberId, CoinTypeEnum.USDT.name());

        if (walletAgent != null) {

            total = total.add(walletAgent.getTotalBalance());

        }

        return total;

    }

}