From 4a6da027fb4f1376f7aa0b57a6d7f92fdc82f73a Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Fri, 11 Jun 2021 15:49:45 +0800
Subject: [PATCH] modify
---
src/main/java/com/xcong/excoin/quartz/job/CoinTradeInitJob.java | 13 +++++++++++++
1 files changed, 13 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/quartz/job/CoinTradeInitJob.java b/src/main/java/com/xcong/excoin/quartz/job/CoinTradeInitJob.java
index a72ee84..58fd0fa 100644
--- a/src/main/java/com/xcong/excoin/quartz/job/CoinTradeInitJob.java
+++ b/src/main/java/com/xcong/excoin/quartz/job/CoinTradeInitJob.java
@@ -33,6 +33,7 @@
import java.math.BigDecimal;
import java.text.ParseException;
import java.util.ArrayList;
+import java.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -124,6 +125,18 @@
if(o!=null){
Map<String, Candlestick> currentKlineMap = (Map<String, Candlestick> )o;
((DefaultCoinProcessor) processor).setCurrentKlineMap(currentKlineMap);
+ }else{
+ // 当最新K线不存在时 需要初始化
+ // 1min 5min 15min 30min 1hour 4hour 1day 1week
+ String[] rang = {"1min","5min","15min","30min","1hour","4hour","1day","1week"};
+ Map<String, Candlestick> currentKlineMap = new HashMap<>();
+ long currentTimeMillis = System.currentTimeMillis();
+ for (String s : rang) {
+ Candlestick candlestick = new Candlestick();
+ candlestick.setTimestamp(currentTimeMillis);
+ currentKlineMap.put(s,candlestick);
+ }
+ redisUtils.set(key,currentKlineMap);
}
processorFactory.addProcessor(symbol, processor);
--
Gitblit v1.9.1