From 3b51e28456fc8c3ca03a27df70645b82c1a1530b Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Tue, 08 Sep 2020 18:00:30 +0800 Subject: [PATCH] modify --- src/test/java/com/xcong/excoin/WholeTest.java | 22 +++++++++++++--------- 1 files changed, 13 insertions(+), 9 deletions(-) diff --git a/src/test/java/com/xcong/excoin/WholeTest.java b/src/test/java/com/xcong/excoin/WholeTest.java index e8eb9e4..8245296 100644 --- a/src/test/java/com/xcong/excoin/WholeTest.java +++ b/src/test/java/com/xcong/excoin/WholeTest.java @@ -13,6 +13,7 @@ import com.xcong.excoin.modules.member.entity.MemberEntity; import com.xcong.excoin.modules.member.entity.MemberWalletContractEntity; import com.xcong.excoin.rabbit.pricequeue.OrderModel; +import com.xcong.excoin.rabbit.pricequeue.WebsocketPriceService; import com.xcong.excoin.rabbit.producer.OrderProducer; import com.xcong.excoin.utils.CalculateUtil; import com.xcong.excoin.utils.RedisUtils; @@ -96,14 +97,6 @@ @Autowired private OrderProducer orderProducer; - @Test - public void sendMsg() { - List<OrderModel> list = new ArrayList<>(); - OrderModel orderModel = new OrderModel(1L, RabbitPriceTypeEnum.ENTRUST_OPEN_MORE.getValue(), "111", "BTC"); - list.add(orderModel); - orderProducer.sendLimitClose(JSONObject.toJSONString(list)); - } - // 面值*(多单张数*多单开仓价-空单张数*空单开仓价)-余额-已实现盈亏 / 面值*(多单张数-空单张数)-(维持保证金率+TAKER手续费)*面值*(开多张数+开空张数) @@ -119,7 +112,7 @@ */ @Test public void forceSetPriceTest() { - MemberEntity memberEntity = memberDao.selectById(5L); + MemberEntity memberEntity = memberDao.selectById(21L); CalculateUtil.getForceSetPriceForWhole("BTC/USDT", memberEntity); } @@ -144,6 +137,17 @@ @Test public void redisTest() { + for (int i = 827; i < 999; i++) { + redisUtils.del(AppContants.CLOSING_ORDER_PREFIX + i); + } + } + + @Resource + private WebsocketPriceService websocketPriceService; + + @Test + public void wholeBombTest() { + websocketPriceService.wholeBomb("BTC/USDT", "9000"); } } -- Gitblit v1.9.1