Rev 764 | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed
| Rev 764 | Rev 783 | ||
|---|---|---|---|
| Line 70... | Line 70... | ||
| 70 | public void iniciarColetor1Minuto() { |
70 | public void iniciarColetor1Minuto() { |
| 71 | RoboDTO roboDTO = new RoboDTO(); |
71 | RoboDTO roboDTO = new RoboDTO(); |
| 72 | roboDTO.setRodando(true); |
72 | roboDTO.setRodando(true); |
| 73 | setRoboDTO(roboDTO); |
73 | setRoboDTO(roboDTO); |
| 74 | 74 | ||
| - | 75 | /*
|
|
| 75 | this.profitDataProvider = new ExcelProfitTempoRealPorSegundoProvider(Paths.get(EXCEL_PATH), EXCEL_SHEET); |
76 | this.profitDataProvider = new ExcelProfitTempoRealPorSegundoProvider(Paths.get(EXCEL_PATH), EXCEL_SHEET);
|
| 76 | if (!rodando.compareAndSet(false, true)) { |
77 | if (!rodando.compareAndSet(false, true)) {
|
| 77 | // já está rodando
|
78 | // já está rodando
|
| 78 | return; |
79 | return;
|
| 79 | }
|
80 | }
|
| - | 81 | */
|
|
| 80 | 82 | ||
| 81 | Thread t = new Thread(this::loopColetor, "CandleCollector-1M"); |
83 | Thread t = new Thread(this::loopColetor, "CandleCollector-1M"); |
| 82 | t.setDaemon(true); |
84 | t.setDaemon(true); |
| 83 | t.start(); |
85 | t.start(); |
| 84 | }
|
86 | }
|
| Line 112... | Line 114... | ||
| 112 | System.out.println("INICIANDO CAPTURA!"); |
114 | System.out.println("INICIANDO CAPTURA!"); |
| 113 | getRoboDTO().setObservacaoRobo("INICIANDO CAPTURA!"); |
115 | getRoboDTO().setObservacaoRobo("INICIANDO CAPTURA!"); |
| 114 | 116 | ||
| 115 | while (rodando.get()) { |
117 | while (rodando.get()) { |
| 116 | try { |
118 | try { |
| - | 119 | /*
|
|
| 117 | // Lê ticks atuais de TODOS os ativos (snapshot)
|
120 | // Lê ticks atuais de TODOS os ativos (snapshot)
|
| 118 | Map<String, ProfitTick> ticks = profitDataProvider.readCurrentTicks(); |
121 | Map<String, ProfitTick> ticks = profitDataProvider.readCurrentTicks();
|
| 119 | 122 | ||
| 120 | // Atualiza estado de cada ativo
|
123 | // Atualiza estado de cada ativo
|
| 121 | for (Map.Entry<String, ProfitTick> entry : ticks.entrySet()) { |
124 | for (Map.Entry<String, ProfitTick> entry : ticks.entrySet()) {
|
| 122 | String symbol = entry.getKey(); |
125 | String symbol = entry.getKey();
|
| 123 | ProfitTick tick = entry.getValue(); |
126 | ProfitTick tick = entry.getValue();
|
| 124 | processarTick(symbol, tick); |
127 | processarTick(symbol, tick);
|
| 125 | }
|
128 | }
|
| 126 | - | ||
| - | 129 | */
|
|
| 127 | // Espera 1 segundo antes da próxima leitura
|
130 | // Espera 1 segundo antes da próxima leitura
|
| 128 | TimeUnit.SECONDS.sleep(1); |
131 | TimeUnit.SECONDS.sleep(1); |
| 129 | } catch (Exception e) { |
132 | } catch (Exception e) { |
| 130 | e.printStackTrace(); |
133 | e.printStackTrace(); |
| 131 | try { |
134 | try { |