From 7d9bf660d08d1b39af670e54dedf784e32080dc2 Mon Sep 17 00:00:00 2001
From: zyy <zyy@email.com>
Date: Fri, 09 Jan 2026 17:54:01 +0800
Subject: [PATCH] ipo
---
trading-order-huobi/src/main/java/com/yami/trading/huobi/data/job/StockGetDataJob.java | 17 ++++++++---------
1 files changed, 8 insertions(+), 9 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 db51644..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,14 +116,14 @@
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)){
//美股
- this.realtimeHandleTradingViewUsStock();
+ //this.realtimeHandleTradingViewUsStock();
//this.realtimeHandleXueQiu(usStockRemarks);
//美股ETF
@@ -133,7 +133,7 @@
this.realtimeHandleTradingViewUsEtf();
//美股
- this.realtimeHandleTradingViewUsStock();
+ //this.realtimeHandleTradingViewUsStock();
//if(MarketOpenChecker.isMarketOpen(Item.TW_STOCKS, 30)){
// this.realtimeHandleTW(twStockRemarks);
@@ -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