From 8d3774e6d2440690348dc7fb6fcb6c1a53236255 Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Mon, 07 Sep 2020 17:43:06 +0800 Subject: [PATCH] modify --- src/test/java/com/xcong/excoin/WholeTest.java | 28 ++++++++++++++++++++-------- 1 files changed, 20 insertions(+), 8 deletions(-) diff --git a/src/test/java/com/xcong/excoin/WholeTest.java b/src/test/java/com/xcong/excoin/WholeTest.java index 8c1ab3a..39041ca 100644 --- a/src/test/java/com/xcong/excoin/WholeTest.java +++ b/src/test/java/com/xcong/excoin/WholeTest.java @@ -13,8 +13,10 @@ 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; import com.xcong.excoin.utils.ThreadPoolUtils; import org.junit.jupiter.api.Test; import org.springframework.beans.factory.annotation.Autowired; @@ -95,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手续费)*面值*(开多张数+开空张数) @@ -138,4 +132,22 @@ } } + @Resource + private RedisUtils redisUtils; + + @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