From c50561d007e420f7397f73afce8966231973ec54 Mon Sep 17 00:00:00 2001
From: peter <14100000001@qq.com>
Date: Mon, 18 Aug 2025 17:35:30 +0800
Subject: [PATCH] 外汇接口调整
---
trading-order-huobi/src/main/java/com.yami.trading.huobi/data/job/ForexGetDataJob.java | 10 ++++++----
1 files changed, 6 insertions(+), 4 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..2448ace 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,6 +95,8 @@
return;
}
List<Realtime> realtimeList = this.hobiDataService.realtimeXinLang(symbols);
+// List<Realtime> realtimeList1 = this.hobiDataService.realtime24HoruData(symbols,realtimeList);
+// List<Realtime> realtimeList1 = this.hobiDataService.realtimeNewPrice(symbols,realtimeList);
super.handleRealTimeList(realtimeList);
}
--
Gitblit v1.9.3