| | |
| | | private static final String FUTURES_PING = "futures.ping"; |
| | | private static final String FUTURES_PONG = "futures.pong"; |
| | | private static final String GATE_INTERVAL = "1m"; |
| | | private static final String GATE_CONTRACT = "XAU_USDT"; |
| | | private static final String GATE_CONTRACT = "XAUT_USDT"; |
| | | |
| | | private GateGridTradeService gridTradeService; |
| | | |
| | |
| | | |
| | | public GateKlineWebSocketClient(CaoZuoService caoZuoService, |
| | | GateWebSocketClientManager clientManager, |
| | | WangGeListService wangGeListService |
| | | WangGeListService wangGeListService, |
| | | GateGridTradeService gridTradeService |
| | | ) { |
| | | this.caoZuoService = caoZuoService; |
| | | this.clientManager = clientManager; |
| | | this.wangGeListService = wangGeListService; |
| | | } |
| | | |
| | | public void setGridTradeService(GateGridTradeService gridTradeService) { |
| | | this.gridTradeService = gridTradeService; |
| | | } |
| | | |
| | |
| | | log.info("=================================="); |
| | | |
| | | if (gridTradeService != null) { |
| | | gridTradeService.onKline(closePx, windowClosed); |
| | | gridTradeService.onKline(closePx); |
| | | } |
| | | } catch (Exception e) { |
| | | log.error("处理 K线频道推送数据失败", e); |