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/StockGetDataJob.java | 13 ++++++-------
1 files changed, 6 insertions(+), 7 deletions(-)
diff --git a/trading-order-huobi/src/main/java/com/yami/trading/huobi/data/job/StockGetDataJob.java b/trading-order-huobi/src/main/java/com/yami/trading/huobi/data/job/StockGetDataJob.java
index 0e9bc54..ee56a25 100644
--- a/trading-order-huobi/src/main/java/com/yami/trading/huobi/data/job/StockGetDataJob.java
+++ b/trading-order-huobi/src/main/java/com/yami/trading/huobi/data/job/StockGetDataJob.java
@@ -94,9 +94,9 @@
if(stockFirstFetch){
- this.realtimeHandleXueQiu(aStockRemarks);
- this.realtimeHandleXueQiu(hkStockRemarks);
- this.realtimeHandleXueQiu(usStockRemarks);
+ //this.realtimeHandleXueQiu(aStockRemarks);
+ //this.realtimeHandleXueQiu(hkStockRemarks);
+ //this.realtimeHandleXueQiu(usStockRemarks);
//this.realtimeHandleTW(twStockRemarks);
//this.realtimeHandleCommon(jpStockRemarks);
//this.realtimeHandleCommon(indiaStockRemarks);
@@ -116,10 +116,10 @@
if(MarketOpenChecker.isMarketOpen(Item.A_STOCKS, 30)){
- this.realtimeHandleXueQiu(aStockRemarks);
+ //this.realtimeHandleXueQiu(aStockRemarks);
}
if(MarketOpenChecker.isMarketOpen(Item.HK_STOCKS, 30)){
- this.realtimeHandleXueQiu(hkStockRemarks);
+ //this.realtimeHandleXueQiu(hkStockRemarks);
}
if(MarketOpenChecker.isMarketOpen(Item.US_STOCKS, 30)){
//美股
@@ -224,11 +224,10 @@
*/
public void realtimeHandleTradingViewUsEtf() {
List<Realtime> realtimeList = this.tradingViewDataService.realtimeUsEtfSingle();
- List<Item> list = itemService.lambdaQuery().eq(Item::getMarket, Item.US_ETF).list();
+ List<Item> list = itemService.lambdaQuery().eq(Item::getType, Item.indices).list();
//去除未存在的symbol
List<String> collect = list.stream().map(Item::getSymbol).collect(Collectors.toList());
realtimeList.removeIf(realtime -> !collect.contains(realtime.getSymbol()));
-
super.handleRealTimeList(realtimeList);
}
--
Gitblit v1.9.3