From d174d6963d62b3bd176f9e7ba3cf0d7f75a91b69 Mon Sep 17 00:00:00 2001 From: zainali5120 <512061637@qq.com> Date: Wed, 16 Sep 2020 16:03:22 +0800 Subject: [PATCH] 撮合交易代码提交 --- src/main/java/com/xcong/excoin/processor/MarketService.java | 6 +++--- 1 files changed, 3 insertions(+), 3 deletions(-) diff --git a/src/main/java/com/xcong/excoin/processor/MarketService.java b/src/main/java/com/xcong/excoin/processor/MarketService.java index 11c6c56..d47b2c9 100644 --- a/src/main/java/com/xcong/excoin/processor/MarketService.java +++ b/src/main/java/com/xcong/excoin/processor/MarketService.java @@ -75,20 +75,20 @@ // Query query = new Query(criteria).with(sort); // // return mongoTemplate.find(query,ExchangeTrade.class,"exchange_trade_"+symbol); - return orderCoinDealDao.selectOrderCoinDealByTime(symbol, new Date(timeStart), new Date(timeStart)); + return orderCoinDealDao.selectOrderCoinDealByTime(symbol, new Date(timeStart), new Date(timeEnd)); // return null; } public void saveKLine(String symbol, String period, Candlestick kLine) { // 先获取 - String key = "KINE_" + symbol + "_" + period; + String key = "KINE_" + symbol + "/USDT_" + period; Object data = redisUtils.get(key); List list = new ArrayList(); if (data != null) { list = (List) data; } list.add(kLine); - redisUtils.set("KINE_" + symbol + "_" + period, list); + redisUtils.set(key, list); // mongoTemplate.insert(kLine,"exchange_kline_"+symbol+"_"+kLine.getPeriod()); } -- Gitblit v1.9.1