优化usdt同步

zainali5120

2020-10-08 c24fc100ef9966495dc706e110fc37f13e003448

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

@@ -4,10 +4,14 @@
import java.util.ArrayList;

import java.util.List;

import javax.annotation.Resource;

import javax.validation.Valid;



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

import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;



import com.baomidou.mybatisplus.core.metadata.IPage;

import com.baomidou.mybatisplus.extension.plugins.pagination.Page;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;

import com.xcong.excoin.common.LoginUserUtils;

import com.xcong.excoin.common.enumerates.CoinTypeEnum;

@@ -15,7 +19,12 @@
import com.xcong.excoin.common.response.Result;

import com.xcong.excoin.modules.coin.dao.MemberAccountMoneyChangeDao;

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.RecordsPageDto;

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

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

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

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

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

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

@@ -132,7 +141,6 @@
            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);

        }

    }

@@ -178,26 +186,12 @@
        if (ObjectUtil.isEmpty(walletContract)) {

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

        }

        /**

         * todo

         */

        //获取当前的合约持仓

        //获取实时盈亏

        BigDecimal profitAndLoss = new BigDecimal("50.000");

        //获取总付款

        BigDecimal totalPayment = new BigDecimal("50.000");

        BigDecimal lastTotalBalance = new BigDecimal("0");

        BigDecimal totalBalance = walletContract.getTotalBalance();

        lastTotalBalance = totalBalance.add(profitAndLoss);

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

            lastTotalBalance = new BigDecimal("0");

        }



        MemberWalletContractInfoVo memberWalletContractInfoVo = new MemberWalletContractInfoVo();

        memberWalletContractInfoVo.setFrozenBalance(totalPayment.setScale(4, BigDecimal.ROUND_DOWN));

        memberWalletContractInfoVo.setAvailableBalance(walletContract.getAvailableBalance());

        memberWalletContractInfoVo.setTotalBalance(lastTotalBalance.setScale(4, BigDecimal.ROUND_DOWN));

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

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



        return Result.ok(memberWalletContractInfoVo);

    }

@@ -221,11 +215,8 @@
                return Result.fail(MessageSourceUtils.getString("member_service_0005"));

            }

            BigDecimal subtract = walletCoin.getTotalBalance().subtract(balance);

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

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

            }

            walletCoin.setAvailableBalance(total.setScale(4, BigDecimal.ROUND_DOWN));

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

            walletCoin.setAvailableBalance(total);

            walletCoin.setTotalBalance(subtract);

            int updateWalletCoinById = memberWalletCoinDao.updateById(walletCoin);

            if (updateWalletCoinById < 1) {

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

@@ -343,72 +334,44 @@
    }



    @Override

    public Result getWalletCoinRecords() {

    public Result getWalletCoinRecords(RecordsPageDto recordsPageDto) {

        //获取用户ID

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

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

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

        if (CollUtil.isNotEmpty(coinRecordList)) {

            for (MemberAccountMoneyChange memberAccountMoneyChange : coinRecordList) {

                MemberAccountMoneyChangeInfoVo memberAccountMoneyChangeInfoVo = new MemberAccountMoneyChangeInfoVo();

                memberAccountMoneyChangeInfoVo.setAmount(memberAccountMoneyChange.getAmount());

                memberAccountMoneyChangeInfoVo.setContent(memberAccountMoneyChange.getContent());

                memberAccountMoneyChangeInfoVo.setStatus(memberAccountMoneyChange.getStatus());

                memberAccountMoneyChangeInfoVo.setSymbol(memberAccountMoneyChange.getSymbol());

                memberAccountMoneyChangeInfoVo.setType(memberAccountMoneyChange.getType());

                memberAccountMoneyChangeInfoVo.setUpdateTime(memberAccountMoneyChange.getUpdateTime());

                arrayList.add(memberAccountMoneyChangeInfoVo);

            }

        }

        return Result.ok(arrayList);

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

        MemberAccountMoneyChange memberAccountMoneyChange = new MemberAccountMoneyChange();

        memberAccountMoneyChange.setMemberId(memberId);

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

        Page<MemberAccountMoneyChangeInfoVo> pageEntityToPageVo = MemberAccountMoneyChangeMapper.INSTANCE.pageEntityToPageVo(list);

        
        return Result.ok(pageEntityToPageVo);

    }



    @Override

    public Result getWalletContractRecords() {

    public Result getWalletContractRecords(RecordsPageDto recordsPageDto) {

        //获取用户ID

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

        String symbol = MemberWalletCoinEnum.WALLETCOINCODE.getValue();

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



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

        if (ObjectUtil.isNotNull(contractRecordList)) {

            for (MemberAccountMoneyChange memberAccountMoneyChange : contractRecordList) {

                MemberAccountMoneyChangeInfoVo memberAccountMoneyChangeInfoVo = new MemberAccountMoneyChangeInfoVo();

                memberAccountMoneyChangeInfoVo.setAmount(memberAccountMoneyChange.getAmount());

                memberAccountMoneyChangeInfoVo.setContent(memberAccountMoneyChange.getContent());

                memberAccountMoneyChangeInfoVo.setStatus(memberAccountMoneyChange.getStatus());

                memberAccountMoneyChangeInfoVo.setSymbol(memberAccountMoneyChange.getSymbol());

                memberAccountMoneyChangeInfoVo.setType(memberAccountMoneyChange.getType());

                memberAccountMoneyChangeInfoVo.setUpdateTime(memberAccountMoneyChange.getUpdateTime());

                arrayList.add(memberAccountMoneyChangeInfoVo);

            }

        }



        return Result.ok(arrayList);

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

        MemberAccountMoneyChange memberAccountMoneyChange = new MemberAccountMoneyChange();

        memberAccountMoneyChange.setMemberId(memberId);

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

        Page<MemberAccountMoneyChangeInfoVo> pageEntityToPageVo = MemberAccountMoneyChangeMapper.INSTANCE.pageEntityToPageVo(list);

        return Result.ok(pageEntityToPageVo);

    }



    @Override

    public Result getWalletAgentRecords() {

    public Result getWalletAgentRecords(RecordsPageDto recordsPageDto) {

        //获取用户ID

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



        List<MemberAccountMoneyChange> contractRecordList =

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



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

        if (ObjectUtil.isNotNull(contractRecordList)) {

            for (MemberAccountMoneyChange memberAccountMoneyChange : contractRecordList) {

                MemberAccountMoneyChangeInfoVo memberAccountMoneyChangeInfoVo = new MemberAccountMoneyChangeInfoVo();

                memberAccountMoneyChangeInfoVo.setAmount(memberAccountMoneyChange.getAmount());

                memberAccountMoneyChangeInfoVo.setContent(memberAccountMoneyChange.getContent());

                memberAccountMoneyChangeInfoVo.setStatus(memberAccountMoneyChange.getStatus());

                memberAccountMoneyChangeInfoVo.setSymbol(memberAccountMoneyChange.getSymbol());

                memberAccountMoneyChangeInfoVo.setType(memberAccountMoneyChange.getType());

                memberAccountMoneyChangeInfoVo.setUpdateTime(memberAccountMoneyChange.getUpdateTime());

                arrayList.add(memberAccountMoneyChangeInfoVo);

            }

        }

        return Result.ok(arrayList);

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

        MemberAccountMoneyChange memberAccountMoneyChange = new MemberAccountMoneyChange();

        memberAccountMoneyChange.setMemberId(memberId);

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

        Page<MemberAccountMoneyChangeInfoVo> pageEntityToPageVo = MemberAccountMoneyChangeMapper.INSTANCE.pageEntityToPageVo(list);

        
        return Result.ok(pageEntityToPageVo);

    }



    @Override

@@ -517,4 +480,98 @@
        return Result.ok(memberWalletAgentInfoVo);

    }



   @Override

   public Result getWalletAgentIntoRecords(RecordsPageDto recordsPageDto) {

           //获取用户ID

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

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

           MemberAccountMoneyChange memberAccountMoneyChange = new MemberAccountMoneyChange();

           memberAccountMoneyChange.setMemberId(memberId);

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

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

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

           if(CollUtil.isNotEmpty(contractRecordList)) {

              if (ObjectUtil.isNotNull(contractRecordList)) {

                 for (MemberAccountMoneyChange memberAccountMoneyChanges : contractRecordList) {

                    MemberAccountMoneyChangeInfoVo memberAccountMoneyChangeInfoVo = new MemberAccountMoneyChangeInfoVo();

                    memberAccountMoneyChangeInfoVo.setAmount(memberAccountMoneyChanges.getAmount());

                    memberAccountMoneyChangeInfoVo.setContent(memberAccountMoneyChanges.getContent());

                    memberAccountMoneyChangeInfoVo.setStatus(memberAccountMoneyChanges.getStatus());

                    memberAccountMoneyChangeInfoVo.setSymbol(memberAccountMoneyChanges.getSymbol());

                    memberAccountMoneyChangeInfoVo.setType(memberAccountMoneyChanges.getType());

                    memberAccountMoneyChangeInfoVo.setUpdateTime(memberAccountMoneyChanges.getUpdateTime());

                    arrayList.add(memberAccountMoneyChangeInfoVo);

                 }

              }

           }

           Page<MemberAccountMoneyChangeInfoVo> pageEntityToPageVo = new Page<>();

           pageEntityToPageVo.setRecords(arrayList);

	        
           return Result.ok(pageEntityToPageVo);

   }



   @Override

   public Result getAllWalletCoin() {

      //获取【币币】

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

        PlatformCnyUsdtExchangeEntity cnyUsdtExchange = cnyUsdtExchangeDao.getCNYAndUSDTOne();

        BigDecimal cnyUsdt = cnyUsdtExchange.getValue();

        AllWalletCoinVo allWalletCoinVo = new AllWalletCoinVo();



        BigDecimal totalUsdts = BigDecimal.ZERO;

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



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

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



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

                    } else {

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

                        // 获取最新价

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

                        BigDecimal totalUsdt = BigDecimal.ZERO;

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

                        totalUsdts = totalUsdts.add(totalUsdt);

                    }

                }

            }

        } 
        allWalletCoinVo.setWalletUsdt(totalUsdts.setScale(4, BigDecimal.ROUND_DOWN));

      //获取【合约】

        String walletCode = MemberWalletCoinEnum.WALLETCOINCODE.getValue();

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

        if (ObjectUtil.isEmpty(walletContract)) {

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

        }

        allWalletCoinVo.setContractUsdt(walletContract.getTotalBalance().setScale(4, BigDecimal.ROUND_DOWN));

        totalUsdts = totalUsdts.add(walletContract.getTotalBalance());

      //获取【代理】

        MemberWalletAgentEntity walletAgent = memberWalletAgentDao.selectWalletAgentBymIdAndCode(memberId, walletCode);

        BigDecimal availableBalance = walletAgent.getAvailableBalance();

        allWalletCoinVo.setAgentUsdt(availableBalance.setScale(4, BigDecimal.ROUND_DOWN));

        totalUsdts = totalUsdts.add(availableBalance);

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

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

        return Result.ok(allWalletCoinVo);

   }



}