From 83f9014a75f572154ae7732f0fc78d6467edde93 Mon Sep 17 00:00:00 2001
From: peter <908253177@qq.com>
Date: Tue, 08 Jul 2025 14:56:52 +0800
Subject: [PATCH] 外汇
---
trading-order-huobi/src/main/java/com.yami.trading.huobi/data/job/ForexGetDataJob.java | 11 ++++++-----
1 files changed, 6 insertions(+), 5 deletions(-)
diff --git a/trading-order-huobi/src/main/java/com.yami.trading.huobi/data/job/ForexGetDataJob.java b/trading-order-huobi/src/main/java/com.yami.trading.huobi/data/job/ForexGetDataJob.java
index 5cd57ac..43f73a7 100644
--- a/trading-order-huobi/src/main/java/com.yami.trading.huobi/data/job/ForexGetDataJob.java
+++ b/trading-order-huobi/src/main/java/com.yami.trading.huobi/data/job/ForexGetDataJob.java
@@ -44,9 +44,9 @@
while (true) {
try {
// 老外汇tradeView接口
- String symbols = itemService.findByType(Item.forex)
- .stream().filter(i -> !i.getCategory().equalsIgnoreCase(Item.forex))
- .map(Item::getSymbol).collect(Collectors.joining(","));
+// String symbols = itemService.findByType(Item.forex)
+// .stream().filter(i -> !i.getCategory().equalsIgnoreCase(Item.forex))
+// .map(Item::getSymbol).collect(Collectors.joining(","));
// 新外汇
String xinLangsymbols = itemService.findByType(Item.forex)
@@ -60,7 +60,7 @@
// log.info("开市时间 {}", f.format(UTCDateUtils.getOpenTime()));
Date now = f.parse(f.format(new Date()));
if (MarketOpenChecker.isMarketOpenByItemCloseType(Item.forex)) {
- this.realtimeHandle(symbols);
+// this.realtimeHandle(symbols);
this.realtimeHandleXinLang(xinLangsymbols);
} else {
logger.debug("当前为休市时间，当前UTS标准时间：{}, 开市时间：{}, 休市时间：{}",
@@ -95,7 +95,8 @@
return;
}
List<Realtime> realtimeList = this.hobiDataService.realtimeXinLang(symbols);
- super.handleRealTimeList(realtimeList);
+ List<Realtime> realtimeList1 = this.hobiDataService.realtimeNewPrice(symbols,realtimeList);
+ super.handleRealTimeList(realtimeList1);
}
}
--
Gitblit v1.9.3