1

zyy3

2025-11-05 0426160a1f283c1f810e3059f6037676da8cb110

 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);
    }