| | |
|---|
| | | @PostConstruct |
|---|
| | | public void initCoinTrade() { |
|---|
| | | log.info("#=======撮合交易器开启=======#"); |
|---|
| | | String symbol = SymbolsConstats.ROC; |
|---|
| | | String symbol = SymbolsConstats.CPV; |
|---|
| | | CoinTrader newTrader = new CoinTrader(symbol); |
|---|
| | | newTrader.setExchangeProducer(exchangeProducer); |
|---|
| | | //newTrader.setKafkaTemplate(kafkaTemplate); |
|---|
| | |
|---|
| | | processor.initializeThumb(); |
|---|
| | | //processor.initializeUsdRate(); |
|---|
| | | processor.setIsHalt(false); |
|---|
| | | List<ExchangeTrade> nekk = orderCoinDealDao.selectOrderCoinDealByTime(SymbolsConstats.ROC, null, null); |
|---|
| | | List<ExchangeTrade> nekk = orderCoinDealDao.selectOrderCoinDealByTime(SymbolsConstats.CPV, null, null); |
|---|
| | | processor.process(nekk); |
|---|
| | | String symbolUsdt = symbol; |
|---|
| | | if(!symbol.contains("USDT")){ |
|---|
