| | |
| | | **/ |
| | | @Slf4j |
| | | @Component |
| | | @ConditionalOnProperty(prefix = "app", name = "trade", havingValue = "true") |
| | | @ConditionalOnProperty(prefix = "app", name = "exchange-trade", havingValue = "true") |
| | | public class CoinTradeInitJob { |
| | | |
| | | @Resource |
| | |
| | | List<OrderCoinsEntity> tradingOrders = new ArrayList<>(); |
| | | List<OrderCoinsEntity> completedOrders = new ArrayList<>(); |
| | | orders.forEach(order -> { |
| | | if(order.getDealCnt()==null){ |
| | | order.setDealCnt(BigDecimal.ZERO); |
| | | } |
| | | if(order.getDealAmount()==null){ |
| | | order.setDealAmount(BigDecimal.ZERO); |
| | | } |
| | | tradingOrders.add(order); |
| | | }); |
| | | try { |
| | |
| | | // 创建K线生成器 |
| | | CoinProcessor processor = new DefaultCoinProcessor(symbol, "USDT"); |
| | | processor.setMarketService(marketService); |
| | | processor.setRedisUtils(redisUtils); |
| | | //processor.setExchangeRate(exchangeRate); |
| | | processor.initializeThumb(); |
| | | //processor.initializeUsdRate(); |