1

zj

5 days ago 6e09aa2c20ff596c2dfae165d94a9af8ce281030

 trading-order-huobi/src/main/java/com.yami.trading.huobi/data/internal/KlineInitServiceImpl.java

@@ -35,32 +35,27 @@
    public void klineInit(String symbols) {
        logger.info("当前开始初始化币对k线图: {}", symbols);
        if (!symbols.contains(",")) {
            Item bySymbol = itemService.findBySymbol(symbols);
            if (Item.cryptos.equalsIgnoreCase(bySymbol.getType())) {
                cryptosKlineService.init(symbols);
            } else if ("1".equalsIgnoreCase(bySymbol.getFake())) {
                fakeKlineInitService.saveInit(symbols);
            } else {
                saveInit(symbols);
            }
            initOne(symbols);
        } else {
            String[] symbolsArrays = symbols.split(",");
            for (String symbol : symbolsArrays) {
                threadPoolComponent.getExecutor().submit(() -> {
                    logger.info("当前开始初始化币对单个k线图: {}", symbol);
                    Item bySymbol = itemService.findBySymbol(symbol);
                    if (Item.cryptos.equalsIgnoreCase(bySymbol.getType())) {
                        cryptosKlineService.init(symbol);
                    } else if ("1".equalsIgnoreCase(bySymbol.getFake())) {
                        fakeKlineInitService.saveInit(symbols);
                    } else {
                        saveInit(symbol);
                    }
                    initOne(symbol);
                    logger.info("当前开始初始化完成币对k线图: {}", symbol);
                });

            }
        }
    }

    private void initOne(String symbol) {
        Item bySymbol = itemService.findBySymbol(symbol);
        if (bySymbol.isFake()) {
            fakeKlineInitService.saveInit(symbol);
        } else if (Item.cryptos.equalsIgnoreCase(bySymbol.getType())) {
            cryptosKlineService.init(symbol);
        } else {
            saveInit(symbol);
        }
    }

@@ -68,7 +63,7 @@
    private final void saveInit(String symbol) {
        Item bySymbol = itemService.findBySymbol(symbol);
        // 机器人的价格，无需初始化
        if ("1".equalsIgnoreCase(bySymbol.getFake())) {
        if (bySymbol.isFake()) {
            return;
        }
        Map<String, List<Kline>> dailyWeekMonthHistoryMap = hobiDataService.getDailyWeekMonthHistory(symbol);