refactor(symbols): 优化K线历史数据加载逻辑

Administrator

1 days ago c4d7235172c0d4c451b3bd71d5520e15bf8fde66

 src/main/java/com/xcong/excoin/rabbit/producer/OrderProducer.java

@@ -107,7 +107,7 @@
     */
    public void sendPriceOperate(String content) {
        CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());
        System.out.println("发送价格操作：" + content + "==pid:" + correlationData.getId());
        log.info("发送价格操作 : {}==pid : {}", content, correlationData.getId());
        rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_A, RabbitMqConfig.ROUTINGKEY_PRICEOPERATE, content, correlationData);
    }

@@ -137,5 +137,28 @@
        }
    }

    /**
     * 发送委托平仓
     *
     * @param content
     */
    public void sendLimitClose(String content) {
        CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());
        log.info("发送委托平仓消息：{} == pid:{}", content, correlationData.getId());

        rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_A, RabbitMqConfig.ROUTINGKEY_LIMIT_CLOSE, content, correlationData);
    }

    /**
     * 发送全仓爆仓
     *
     * @param content
     */
    public void sendWholeBomb(String content) {
        CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());
        log.info("发送全仓爆仓消息：{} == pid:{}", content, correlationData.getId());

        rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_A, RabbitMqConfig.ROUTINGKEY_WHOLE_BOMB, content, correlationData);
    }

}