20200525

xiaoyong931011

2020-05-25 365d8acae71b0f7c8df0d045156dce90f69ec32c

20200525

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

@@ -52,22 +52,20 @@
    

    @Override

    public Result getWalletCoin() {

        try {

            BigDecimal totalUsdt = BigDecimal.ZERO;

            //获取用户ID

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

			
            CnyUsdtExchange cnyUsdtExchange =cnyUsdtExchangeDao.getCNYAndUSDTOne();

            BigDecimal cnyUsdt = cnyUsdtExchange.getValue();

            

            BigDecimal totalUsdts = BigDecimal.ZERO;

            if(!StrUtil.isEmpty(memberId.toString())) {

                

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

				
                List<MemberWalletCoinInfoVo> memberWalletCoinInfoVolist = new ArrayList<MemberWalletCoinInfoVo>();

                MemberWalletCoinInfoVo memberWalletCoinInfoVo = new MemberWalletCoinInfoVo();

				
                if(CollUtil.isNotEmpty(memberWalletCoinlist)) {

                    for(MemberWalletCoinEntity memberWalletCoinEntity : memberWalletCoinlist) {

                        MemberWalletCoinInfoVo memberWalletCoinInfoVo = new MemberWalletCoinInfoVo();

                        memberWalletCoinInfoVo.setAvailableBalance(memberWalletCoinEntity.getAvailableBalance());

                        memberWalletCoinInfoVo.setFrozenBalance(memberWalletCoinEntity.getFrozenBalance());

                        memberWalletCoinInfoVo.setMemberId(memberWalletCoinEntity.getMemberId());

@@ -77,25 +75,28 @@
                    }

                }

                

				
                if(CollUtil.isNotEmpty(memberWalletCoinlist)) {

                    for(MemberWalletCoinEntity walletCoin : memberWalletCoinlist) {

                if(CollUtil.isNotEmpty(memberWalletCoinInfoVolist)) {

                    for(MemberWalletCoinInfoVo walletCoin : memberWalletCoinInfoVolist) {

                        if(MemberWalletCoinEnum.WALLETCOINCODE.getValue().equals(walletCoin.getWalletCode())) {    

                            BigDecimal totalUsdt = BigDecimal.ZERO;

                            totalUsdt = walletCoin.getAvailableBalance().add(walletCoin.getFrozenBalance());

                            totalUsdts = totalUsdts.add(totalUsdt);

                            BigDecimal totalCny = totalUsdt.multiply(cnyUsdt);

                            walletCoin.setTotalBalance(totalCny.setScale(4, BigDecimal.ROUND_DOWN));

                        }else {

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

                            BigDecimal closePrice = new BigDecimal("10.0000");

                            BigDecimal totalUsdt = BigDecimal.ZERO;

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

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

                            walletCoin.setTotalBalance(totalUsdt.multiply(closePrice).multiply(cnyUsdt).setScale(4, BigDecimal.ROUND_DOWN));

                            totalUsdts = totalUsdts.add(totalUsdt);

                            walletCoin.setTotalBalance(totalUsdt.multiply(cnyUsdt).setScale(4, BigDecimal.ROUND_DOWN));

                        }

                    }

                }

                MemberWalletCoinVo memberWalletCoinVo = new MemberWalletCoinVo();

                memberWalletCoinVo.setTotalUsdt(totalUsdt.setScale(4, BigDecimal.ROUND_DOWN));

                memberWalletCoinVo.setTotalCny(totalUsdt.multiply(cnyUsdt).setScale(4, BigDecimal.ROUND_DOWN));

                memberWalletCoinVo.setTotalUsdt(totalUsdts.setScale(4, BigDecimal.ROUND_DOWN));

                memberWalletCoinVo.setTotalCny(totalUsdts.multiply(cnyUsdt).setScale(4, BigDecimal.ROUND_DOWN));

                memberWalletCoinVo.setMemberWalletCoinInfoVo(memberWalletCoinInfoVolist);

                return Result.ok(memberWalletCoinVo);

            }else {

@@ -122,20 +123,15 @@
                memberWalletCoinlist.add(coin);

                

                MemberWalletCoinVo memberWalletCoinVo = new MemberWalletCoinVo();

                memberWalletCoinVo.setTotalUsdt(totalUsdt.setScale(4, BigDecimal.ROUND_DOWN));

                memberWalletCoinVo.setTotalCny(totalUsdt.multiply(cnyUsdt).setScale(4, BigDecimal.ROUND_DOWN));

                memberWalletCoinVo.setTotalUsdt(totalUsdts.setScale(4, BigDecimal.ROUND_DOWN));

                memberWalletCoinVo.setTotalCny(totalUsdts.multiply(cnyUsdt).setScale(4, BigDecimal.ROUND_DOWN));

                memberWalletCoinVo.setMemberWalletCoinInfoVo(memberWalletCoinlist);;

                return Result.ok(memberWalletCoinVo);

            }

        } catch (Exception e) {

            e.printStackTrace();

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

        }

    }



    @Override

    public Result getWalletCoinBySymbol(String symbol) {

        try {

            //获取用户ID

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

            MemberWalletCoinEntity walletCoin = memberWalletCoinDao.selectWalletCoinBymIdAndCode(memberId,symbol);

@@ -159,10 +155,6 @@
                }

            }

            return Result.ok(memberWalletCoinInfoVo);

        } catch (Exception e) {

            e.printStackTrace();

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

        }

    }



    @Override

@@ -348,8 +340,8 @@
        //获取用户ID

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

        List<MemberAccountMoneyChange> coinRecordList = memberAccountMoneyChangeDao.selectWalletCoinRecordsByMemIdTypeSymbol(memberId);

        ArrayList<MemberAccountMoneyChangeInfoVo> arrayList = new ArrayList<>();

        if(ObjectUtil.isNotNull(coinRecordList)) {

        List<MemberAccountMoneyChangeInfoVo> arrayList = new ArrayList<>();

        if(CollUtil.isNotEmpty(coinRecordList)) {

            for(MemberAccountMoneyChange memberAccountMoneyChange : coinRecordList) {

                MemberAccountMoneyChangeInfoVo memberAccountMoneyChangeInfoVo = new MemberAccountMoneyChangeInfoVo();

                memberAccountMoneyChangeInfoVo.setAmount(memberAccountMoneyChange.getAmount());

@@ -370,7 +362,7 @@
        String symbol = MemberWalletCoinEnum.WALLETCOINCODE.getValue();

        List<MemberAccountMoneyChange> contractRecordList = memberAccountMoneyChangeDao.selectWalletContractRecordsByMemIdTypeSymbol(symbol,memberId);

        

        ArrayList<MemberAccountMoneyChangeInfoVo> arrayList = new ArrayList<>();

        List<MemberAccountMoneyChangeInfoVo> arrayList = new ArrayList<>();

        if(ObjectUtil.isNotNull(contractRecordList)) {

            for(MemberAccountMoneyChange memberAccountMoneyChange : contractRecordList) {

                MemberAccountMoneyChangeInfoVo memberAccountMoneyChangeInfoVo = new MemberAccountMoneyChangeInfoVo();

@@ -394,7 +386,7 @@
        List<MemberAccountMoneyChange> contractRecordList = 

                memberAccountMoneyChangeDao.selectWalletAgentRecordByMemIdTypeSymbol(MemberWalletCoinEnum.WALLETCOINCODE.getValue(),memberId);

        

        ArrayList<MemberAccountMoneyChangeInfoVo> arrayList = new ArrayList<>();

        List<MemberAccountMoneyChangeInfoVo> arrayList = new ArrayList<>();

        if(ObjectUtil.isNotNull(contractRecordList)) {

            for(MemberAccountMoneyChange memberAccountMoneyChange : contractRecordList) {

                MemberAccountMoneyChangeInfoVo memberAccountMoneyChangeInfoVo = new MemberAccountMoneyChangeInfoVo();