From 0426160a1f283c1f810e3059f6037676da8cb110 Mon Sep 17 00:00:00 2001
From: zyy3 <zyy3@zy.com>
Date: Wed, 05 Nov 2025 16:37:01 +0800
Subject: [PATCH] 1
---
trading-order-huobi/src/main/java/com/yami/trading/huobi/data/job/TradingViewJob.java | 11 ++++++-----
1 files changed, 6 insertions(+), 5 deletions(-)
diff --git a/trading-order-huobi/src/main/java/com/yami/trading/huobi/data/job/TradingViewJob.java b/trading-order-huobi/src/main/java/com/yami/trading/huobi/data/job/TradingViewJob.java
index 415e34c..8a83331 100644
--- a/trading-order-huobi/src/main/java/com/yami/trading/huobi/data/job/TradingViewJob.java
+++ b/trading-order-huobi/src/main/java/com/yami/trading/huobi/data/job/TradingViewJob.java
@@ -52,8 +52,9 @@
//etf 跟 美股的行情
String etfUsStockSymbols = list.stream()
- .filter(item -> item.getOpenCloseType() != null &&item.getOpenCloseType()
- .equalsIgnoreCase(Item.US_STOCKS)).map(Item::getSymbolData)
+ .filter(item -> item.getOpenCloseType() != null &&item.getOpenCloseType().equalsIgnoreCase(Item.US_STOCKS)
+ && item.getType().equalsIgnoreCase(Item.indices)
+ ).map(Item::getSymbolData)
.collect(Collectors.joining(","));
//外汇
String forexSymbols = list.stream()
@@ -62,13 +63,13 @@
.collect(Collectors.joining(","));
//港股
- String hkSymbols = list.stream()
+ /*String hkSymbols = list.stream()
.filter(item -> item.getOpenCloseType() != null && item.getOpenCloseType().equalsIgnoreCase(Item.HK_STOCKS))
.map(item -> "HKEX:" + Integer.valueOf(item.getSymbolData()))
- .collect(Collectors.joining(","));
+ .collect(Collectors.joining(","));*/
// 开始订阅币种
- tradingViewService.subscribeSymbol(hkSymbols + "," + forexSymbols + "," + etfUsStockSymbols, data -> {
+ tradingViewService.subscribeSymbol(/*hkSymbols + "," +*/ forexSymbols + "," + etfUsStockSymbols, data -> {
// 使用共享线程池，延迟30分钟执行推送
Realtime realtime = new Realtime();
realtime.setSymbol(data.getShortName());
--
Gitblit v1.9.3