modify

Helius

2020-09-08 dfff6a8de2ac1337c1bd44e8d2f1fd04ddc5877a

modify

 src/main/java/com/xcong/excoin/quartz/job/NewestPriceUpdateJob.java

@@ -51,12 +51,12 @@
                String price = tradeEvent.getTradeList().get(0).getPrice().toPlainString();
                // TODO 测试环境关闭这个插入redis
                redisUtils.set(CoinTypeConvert.convertToKey(symbol), price);
                // 比较
                websocketPriceService.comparePriceAsc(symbol, price);
                websocketPriceService.comparePriceDesc(symbol, price);
                if ("ETC/USDT".equalsIgnoreCase(symbol)) {
                    websocketPriceService.wholeBomb(symbol, price);
                }
                // 比较
                websocketPriceService.comparePriceAsc(symbol, price);
                websocketPriceService.comparePriceDesc(symbol, price);
                //System.out.println("比较完毕:"+symbol+"-"+price);

            }

 src/main/java/com/xcong/excoin/rabbit/pricequeue/WebsocketPriceService.java

@@ -304,7 +304,7 @@

                    BigDecimal sub = wallet.getTotalBalance().add(totalProfitOrLess);
                    BigDecimal target = wallet.getTotalBalance().multiply(BigDecimal.valueOf(0.01));
                    log.info("sub : {}, target : {}", sub, target);
//                    log.info("sub : {}, target : {}", sub, target);
                    if (sub.compareTo(target) <= 0) {
                        List<OrderModel> list = new ArrayList<>();
                        OrderModel orderModel = new OrderModel(null, 0, price, symbol, memberId);