撮合交易代码提交

zainali5120

2020-09-14 74ca5bc0f40e3b91464c8972392271d24dd5f066

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

@@ -744,7 +744,9 @@
    @Override

    @Transactional(rollbackFor = Exception.class)

    public void dealEntrustCoinOrder() {

        List<OrderCoinsEntity> list = orderCoinsDao.selectAllEntrustingCoinOrderList();

        List<String> ignoreTypes = new ArrayList<>();

        ignoreTypes.add("NEKK");

        List<OrderCoinsEntity> list = orderCoinsDao.selectAllEntrustingCoinOrderList(ignoreTypes);

        if (CollUtil.isNotEmpty(list)) {

            for (OrderCoinsEntity orderCoinsEntity : list) {

                BigDecimal nowPrice = new BigDecimal(redisUtils.getString(CoinTypeConvert.convertToKey(orderCoinsEntity.getSymbol() + "/USDT")));

@@ -813,7 +815,9 @@
    public void handleOrder(List<ExchangeTrade> trades){

        // 处理撮合交易的订单

        for(ExchangeTrade exchangeTrade : trades){



            if(exchangeTrade==null){

                continue;

            }

            BigDecimal amount = exchangeTrade.getAmount();

            Long buyOrderId = exchangeTrade.getBuyOrderId();

            BigDecimal buyTurnover = exchangeTrade.getBuyTurnover();