外汇接口调整

peter

2025-08-18 c50561d007e420f7397f73afce8966231973ec54

 trading-order-huobi/src/main/java/com.yami.trading.huobi/data/job/ForexGetDataJob.java

@@ -44,9 +44,9 @@
        while (true) {
            try {
                // 老外汇tradeView接口
                String symbols = itemService.findByType(Item.forex)
                        .stream().filter(i -> !i.getCategory().equalsIgnoreCase(Item.forex))
                        .map(Item::getSymbol).collect(Collectors.joining(","));
//                String symbols = itemService.findByType(Item.forex)
//                        .stream().filter(i -> !i.getCategory().equalsIgnoreCase(Item.forex))
//                        .map(Item::getSymbol).collect(Collectors.joining(","));

                // 新外汇
                String xinLangsymbols = itemService.findByType(Item.forex)
@@ -60,7 +60,7 @@
//            log.info("开市时间 {}", f.format(UTCDateUtils.getOpenTime()));
                Date now = f.parse(f.format(new Date()));
                if (MarketOpenChecker.isMarketOpenByItemCloseType(Item.forex)) {
                    this.realtimeHandle(symbols);
//                    this.realtimeHandle(symbols);
                    this.realtimeHandleXinLang(xinLangsymbols);
                } else {
                    logger.debug("当前为休市时间，当前UTS标准时间：{}, 开市时间：{}, 休市时间：{}",
@@ -95,6 +95,8 @@
            return;
        }
        List<Realtime> realtimeList = this.hobiDataService.realtimeXinLang(symbols);
//        List<Realtime> realtimeList1 = this.hobiDataService.realtime24HoruData(symbols,realtimeList);
//        List<Realtime> realtimeList1 = this.hobiDataService.realtimeNewPrice(symbols,realtimeList);
        super.handleRealTimeList(realtimeList);
    }