Merge remote-tracking branch 'origin/master'

zyy

2025-11-11 df42e224ff59c45d88ad15913d27d2b66a33e6c4

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