55测试环境

KKSU

2024-04-17 d23645e976981bc9b670eea1d469fe8a36be309c

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

@@ -2,10 +2,20 @@


import java.math.BigDecimal;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import javax.annotation.Resource;

import java.util.Map;



import javax.annotation.Resource;

import javax.validation.Valid;



import com.xcong.excoin.modules.contract.dao.ContractHoldOrderDao;

import com.xcong.excoin.modules.contract.entity.ContractEntrustOrderEntity;

import com.xcong.excoin.modules.contract.entity.ContractHoldOrderEntity;

import com.xcong.excoin.modules.contract.entity.ContractOrderEntity;

import com.xcong.excoin.modules.platform.entity.PlatformCnyUsdtExchangeEntity;

import com.xcong.excoin.modules.platform.entity.PlatformTradeSettingEntity;

import com.xcong.excoin.utils.*;

import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;



@@ -20,8 +30,10 @@
import com.xcong.excoin.modules.coin.entity.MemberAccountMoneyChange;

import com.xcong.excoin.modules.coin.entity.OrderCoinsDealEntity;

import com.xcong.excoin.modules.coin.mapper.MemberAccountMoneyChangeMapper;

import com.xcong.excoin.modules.coin.parameter.dto.CoinInListDto;

import com.xcong.excoin.modules.coin.parameter.dto.RecordsPageDto;

import com.xcong.excoin.modules.coin.parameter.vo.AllWalletCoinVo;

import com.xcong.excoin.modules.coin.parameter.vo.CoinInListVo;

import com.xcong.excoin.modules.coin.parameter.vo.ContractSymbolListVo;

import com.xcong.excoin.modules.coin.parameter.vo.MemberAccountMoneyChangeInfoVo;

import com.xcong.excoin.modules.coin.parameter.vo.MemberWalletAgentInfoVo;

@@ -29,23 +41,24 @@
import com.xcong.excoin.modules.coin.parameter.vo.MemberWalletCoinVo;

import com.xcong.excoin.modules.coin.parameter.vo.MemberWalletContractInfoVo;

import com.xcong.excoin.modules.coin.service.CoinService;

import com.xcong.excoin.modules.member.dao.MemberCoinChargeDao;

import com.xcong.excoin.modules.member.dao.MemberCoinWithdrawDao;

import com.xcong.excoin.modules.member.dao.MemberDao;

import com.xcong.excoin.modules.member.dao.MemberWalletAgentDao;

import com.xcong.excoin.modules.member.dao.MemberWalletCoinDao;

import com.xcong.excoin.modules.member.dao.MemberWalletContractDao;

import com.xcong.excoin.modules.member.entity.MemberCoinChargeEntity;

import com.xcong.excoin.modules.member.entity.MemberCoinWithdrawEntity;

import com.xcong.excoin.modules.member.entity.MemberEntity;

import com.xcong.excoin.modules.member.entity.MemberWalletAgentEntity;

import com.xcong.excoin.modules.member.entity.MemberWalletCoinEntity;

import com.xcong.excoin.modules.member.entity.MemberWalletContractEntity;

import com.xcong.excoin.modules.platform.dao.PlatformCnyUsdtExchangeDao;

import com.xcong.excoin.utils.CoinTypeConvert;

import com.xcong.excoin.utils.MessageSourceUtils;

import com.xcong.excoin.utils.RedisUtils;

import com.xcong.excoin.utils.ThreadPoolUtils;



import cn.hutool.core.collection.CollUtil;

import cn.hutool.core.util.ObjectUtil;

import cn.hutool.core.util.StrUtil;

import jnr.ffi.Struct.int16_t;



@Service

public class CoinServiceImpl extends ServiceImpl<MemberWalletCoinDao, MemberWalletCoinEntity> implements CoinService {

@@ -65,7 +78,15 @@
    @Resource

    MemberDao memberDao;

    @Resource

    MemberCoinChargeDao memberCoinChargeDao;

    @Resource

    MemberCoinWithdrawDao memberCoinWithdrawDao;

    @Resource

    RedisUtils redisUtils;

    @Resource

    CacheSettingUtils cacheSettingUtils;

    @Resource

    ContractHoldOrderDao contractHoldOrderDao;





    @Override

@@ -181,22 +202,24 @@


        //获取用户ID

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



        PlatformCnyUsdtExchangeEntity cnyUsdtExchange = cnyUsdtExchangeDao.getCNYAndUSDTOne();

        BigDecimal cnyUsdt = cnyUsdtExchange.getValue();



        String walletCode = MemberWalletCoinEnum.WALLETCOINCODE.getValue();

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

        if (ObjectUtil.isEmpty(walletContract)) {

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

        }



        MemberWalletContractInfoVo memberWalletContractInfoVo = new MemberWalletContractInfoVo();

        memberWalletContractInfoVo.setFrozenBalance(walletContract.getFrozenBalance().setScale(4, BigDecimal.ROUND_DOWN));

        memberWalletContractInfoVo.setAvailableBalance(walletContract.getAvailableBalance().setScale(4, BigDecimal.ROUND_DOWN));

        memberWalletContractInfoVo.setTotalBalance(walletContract.getTotalBalance().setScale(4, BigDecimal.ROUND_DOWN));

        memberWalletContractInfoVo.setTotalRMBBalance(walletContract.getTotalBalance().multiply(cnyUsdt).setScale(4, BigDecimal.ROUND_DOWN));



        
        Map<String, Object> columnMap = new HashMap<String, Object>();

        columnMap.put("member_id", memberId);

        columnMap.put("wallet_code", "USDT");

      List<MemberWalletContractEntity> selectByMap = memberWalletContractDao.selectByMap(columnMap);

      MemberWalletContractInfoVo memberWalletContractInfoVo = new MemberWalletContractInfoVo();

      if(CollUtil.isNotEmpty(selectByMap)) {

         for(MemberWalletContractEntity memberWalletContractEntity : selectByMap) {

            memberWalletContractInfoVo.setFrozenBalance(memberWalletContractEntity.getFrozenBalance().setScale(4, BigDecimal.ROUND_DOWN));

            memberWalletContractInfoVo.setAvailableBalance(memberWalletContractEntity.getAvailableBalance().setScale(4, BigDecimal.ROUND_DOWN));

            memberWalletContractInfoVo.setTotalCoin(memberWalletContractEntity.getTotalBalance().setScale(4, BigDecimal.ROUND_DOWN));

            memberWalletContractInfoVo.setAvailableCoin(memberWalletContractEntity.getTotalBalance().multiply(cnyUsdt).setScale(4, BigDecimal.ROUND_DOWN));

            memberWalletContractInfoVo.setWalletCode(memberWalletContractEntity.getWalletCode()+"/USDT");

         }

      }

		
        return Result.ok(memberWalletContractInfoVo);

    }



@@ -301,7 +324,9 @@
            //更新合约全仓模式下的订单权益

            MemberEntity memberEntity = memberDao.selectById(memberId);

            String symbols = symbol+"/USDT";

            ThreadPoolUtils.sendWholeForceClosingPrice(symbols, memberEntity);

            //ThreadPoolUtils.sendWholeForceClosingPrice(symbols, memberEntity);

            // 全仓爆仓

            ThreadPoolUtils.sendWholePrice(memberEntity.getId());

            

            //添加币币资金划转历史记录

            MemberAccountMoneyChange memberAccountRecord = new MemberAccountMoneyChange();

@@ -385,24 +410,64 @@
    @Override

    @Transactional(rollbackFor = Exception.class)

    public Result contractTransferToWalletCoins(BigDecimal balance, String symbol) {

       if (balance.compareTo(BigDecimal.ZERO) <= 0) {

        //获取用户ID

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

        MemberEntity memberEntity = memberDao.selectById(memberId);

        if (balance.compareTo(BigDecimal.ZERO) <= 0) {

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

       }

       //获取用户ID

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

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

        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);

                }

            }

        }



       String walletCode = MemberWalletCoinEnum.WALLETCOINCODE.getValue();

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

       BigDecimal availableBalance = walletContract.getAvailableBalance();



       BigDecimal canReduce = availableBalance;

       //可用减去盈亏

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

            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) {

@@ -421,11 +486,9 @@
       if (updateById < 1) {

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

       }

    	
       //更新合约全仓模式下的订单权益

        MemberEntity memberEntity = memberDao.selectById(memberId);

        String symbols = symbol+"/USDT";

        ThreadPoolUtils.sendWholeForceClosingPrice(symbols, memberEntity);



        // 全仓爆仓

        ThreadPoolUtils.sendWholePrice(memberEntity.getId());

       

       //添加资金划转历史记录

       MemberAccountMoneyChange memberAccountRecord = new MemberAccountMoneyChange();

@@ -447,12 +510,55 @@
    }



    @Override

    public Result findWalletContractBySymbol() {

    public Result findWalletContractBySymbol(String symbol) {

        //获取用户ID

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

        String walletCode = MemberWalletCoinEnum.WALLETCOINCODE.getValue();

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

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

        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();

        //可用减去盈亏

        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);

    }



@@ -666,7 +772,9 @@
          //更新合约全仓模式下的订单权益

            MemberEntity memberEntity = memberDao.selectById(memberId);

            String symbols = symbol+"/USDT";

            ThreadPoolUtils.sendWholeForceClosingPrice(symbols, memberEntity);

            //ThreadPoolUtils.sendWholeForceClosingPrice(symbols, memberEntity);

            // 全仓爆仓

            ThreadPoolUtils.sendWholePrice(memberEntity.getId());

          

          //添加资金划转历史记录

          memberAccountRecord.setMemberId(memberId);

@@ -846,7 +954,9 @@
       //更新合约全仓模式下的订单权益

        MemberEntity memberEntity = memberDao.selectById(memberId);

        String symbols = symbolOut+"/USDT";

        ThreadPoolUtils.sendWholeForceClosingPrice(symbols, memberEntity);

        //ThreadPoolUtils.sendWholeForceClosingPrice(symbols, memberEntity);

        // 全仓爆仓

        ThreadPoolUtils.sendWholePrice(memberEntity.getId());

        

        // 加币

        // 查询合约账户

@@ -864,7 +974,9 @@
        

        //更新合约全仓模式下的订单权益

        String symbolIns = symbolIn+"/USDT";

        ThreadPoolUtils.sendWholeForceClosingPrice(symbolIns, memberEntity);

        //ThreadPoolUtils.sendWholeForceClosingPrice(symbolIns, memberEntity);

        // 全仓爆仓

        ThreadPoolUtils.sendWholePrice(memberEntity.getId());

        

        //添加币币资金划转历史记录

        MemberAccountMoneyChange memberAccountRecord = new MemberAccountMoneyChange();

@@ -882,33 +994,148 @@
        

        return Result.ok(MessageSourceUtils.getString("member_service_0006"));

   }

	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	


   @Override

   public Result coinInList(@Valid CoinInListDto coinInListDto) {

      //获取用户ID

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

        int type = coinInListDto.getType();

        //充币记录

        if(type == 1) {

           Page<MemberCoinChargeEntity> page = new Page<>(coinInListDto.getPageNum(), coinInListDto.getPageSize());

           MemberCoinChargeEntity memberCoinChargeEntity = new MemberCoinChargeEntity();

           memberCoinChargeEntity.setMemberId(memberId);

          IPage<MemberCoinChargeEntity> memberCoinCharge = memberCoinChargeDao.findMemberCoinChargeInPage(page, memberCoinChargeEntity);

          List<MemberCoinChargeEntity> records = memberCoinCharge.getRecords();



          Page<CoinInListVo> responsePage = new Page<>(coinInListDto.getPageNum(), coinInListDto.getPageSize());

          if(CollUtil.isNotEmpty(records)) {

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

             for(MemberCoinChargeEntity memberCoinChargeEntitys : records) {

                CoinInListVo coinInListVo = new CoinInListVo();

                coinInListVo.setSymbol(memberCoinChargeEntitys.getSymbol());

                coinInListVo.setAmount(memberCoinChargeEntitys.getAmount());

                coinInListVo.setContent("充币");

                coinInListVo.setStatus(memberCoinChargeEntitys.getStatus());

                coinInListVo.setUpdateTime(memberCoinChargeEntitys.getUpdateTime());

                arrayList.add(coinInListVo);

             }

             responsePage.setRecords(arrayList);

          }

          return Result.ok(responsePage);

        }

        //提币记录

        if(type == 2) {

           Page<MemberCoinWithdrawEntity> page = new Page<>(coinInListDto.getPageNum(), coinInListDto.getPageSize());

           MemberCoinWithdrawEntity memberCoinWithdrawEntity = new MemberCoinWithdrawEntity();

           memberCoinWithdrawEntity.setMemberId(memberId);

          IPage<MemberCoinWithdrawEntity> memberCoinWithdraw = memberCoinWithdrawDao.findMemberCoinWithdrawInPage(page, memberCoinWithdrawEntity);

          List<MemberCoinWithdrawEntity> records = memberCoinWithdraw.getRecords();

    		
          Page<CoinInListVo> responsePage = new Page<>(coinInListDto.getPageNum(), coinInListDto.getPageSize());

          if(CollUtil.isNotEmpty(records)) {

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

             for(MemberCoinWithdrawEntity memberCoinWithdrawEntitys : records) {

                CoinInListVo coinInListVo = new CoinInListVo();

                coinInListVo.setSymbol(memberCoinWithdrawEntitys.getSymbol());

                coinInListVo.setAmount(memberCoinWithdrawEntitys.getAmount());

                coinInListVo.setContent("提币");

                int status = memberCoinWithdrawEntitys.getStatus();

                int statusOut = 0;

                if(status == 1) {

                   statusOut = 0;

                }

                if(status == 2) {

                   statusOut = 1;

                }

                if(status == 3) {

                   statusOut = 2;

                }

                coinInListVo.setStatus(statusOut);

                coinInListVo.setUpdateTime(memberCoinWithdrawEntitys.getUpdateTime());

                coinInListVo.setIsInside(memberCoinWithdrawEntitys.getIsInside());

                arrayList.add(coinInListVo);

             }

             responsePage.setRecords(arrayList);

          }

          return Result.ok(responsePage);

        }

        //划转记录

        if(type == 3) {

           Page<MemberAccountMoneyChange> page = new Page<>(coinInListDto.getPageNum(), coinInListDto.getPageSize());

           MemberAccountMoneyChange memberAccountMoneyChange = new MemberAccountMoneyChange();

           memberAccountMoneyChange.setMemberId(memberId);

           IPage<MemberAccountMoneyChange> list = memberAccountMoneyChangeDao.coinInList(page, memberAccountMoneyChange);

           List<MemberAccountMoneyChange> records = list.getRecords();

        	
           Page<CoinInListVo> responsePage = new Page<>(coinInListDto.getPageNum(), coinInListDto.getPageSize());

          if(CollUtil.isNotEmpty(records)) {

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

             for(MemberAccountMoneyChange memberAccountMoneyChanges : records) {

                CoinInListVo coinInListVo = new CoinInListVo();

                coinInListVo.setSymbol(memberAccountMoneyChanges.getSymbol());

                coinInListVo.setAmount(memberAccountMoneyChanges.getAmount());

                coinInListVo.setContent(memberAccountMoneyChanges.getContent());

                coinInListVo.setStatus(memberAccountMoneyChanges.getStatus());

                coinInListVo.setUpdateTime(memberAccountMoneyChanges.getUpdateTime());

                arrayList.add(coinInListVo);

             }

             responsePage.setRecords(arrayList);

          }

          return Result.ok(responsePage);

        }

        //其他记录

        if(type == 4) {

           Page<OrderCoinsDealEntity> page = new Page<>(coinInListDto.getPageNum(), coinInListDto.getPageSize());

           MemberAccountMoneyChange memberAccountMoneyChange = new MemberAccountMoneyChange();

           memberAccountMoneyChange.setMemberId(memberId);

           IPage<MemberAccountMoneyChange> list = memberAccountMoneyChangeDao.selectWalletAgentIntoRecordsByMemIdTypeSymbol(page, memberAccountMoneyChange);

           List<MemberAccountMoneyChange> records = list.getRecords();

        	
           Page<CoinInListVo> responsePage = new Page<>(coinInListDto.getPageNum(), coinInListDto.getPageSize());

          if(CollUtil.isNotEmpty(records)) {

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

             for(MemberAccountMoneyChange memberAccountMoneyChanges : records) {

                CoinInListVo coinInListVo = new CoinInListVo();

                coinInListVo.setSymbol(memberAccountMoneyChanges.getSymbol());

                coinInListVo.setAmount(memberAccountMoneyChanges.getAmount());

                coinInListVo.setContent(memberAccountMoneyChanges.getContent());

                coinInListVo.setStatus(memberAccountMoneyChanges.getStatus());

                coinInListVo.setUpdateTime(memberAccountMoneyChanges.getUpdateTime());

                arrayList.add(coinInListVo);

             }

             responsePage.setRecords(arrayList);

          }

          return Result.ok(responsePage);

        }

        
        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;

    }

}