Skip to content

Commit 07f9c35

Browse files
committed
Refactors onibus data refresh process
Improves the process of refreshing onibus (bus) coordinate data. - Removes the `@Async` annotation from the scheduler, simplifying the thread management. - Updates the timezone for calculating `dataLimite` to "America/Sao_Paulo", ensuring correct time comparisons. - Removes debug logging statements to reduce noise in production.
1 parent b37ce45 commit 07f9c35

File tree

3 files changed

+2
-13
lines changed

3 files changed

+2
-13
lines changed

mvnw

100644100755
File mode changed.

src/main/java/com/dmware/api_onibusbh/scheduler/CoordenadasScheduler.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,6 @@ public CoordenadasScheduler(APIService apiService, OnibusService onibusService)
2323
this.onibusService = onibusService;
2424
}
2525

26-
@Async
2726
@Scheduled(fixedDelay = 20, timeUnit = TimeUnit.SECONDS)
2827
public void fetchCoordenadasOnibus() {
2928
List<CoordenadaDTO> coordenadas = apiService.getOnibusCoordenadaBH();

src/main/java/com/dmware/api_onibusbh/services/OnibusService.java

Lines changed: 2 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,7 @@
1515
import org.springframework.stereotype.Service;
1616

1717
import java.time.LocalDateTime;
18+
import java.time.ZoneId;
1819
import java.util.*;
1920
import java.util.function.BinaryOperator;
2021
import java.util.function.Function;
@@ -110,13 +111,9 @@ public void salvaCoordenadas(List<CoordenadaDTO> todasCoordenadasNovas) {
110111
.values().stream()
111112
.filter(c -> c.getNumeroLinha() != null)
112113
.collect(Collectors.groupingBy(CoordenadaDTO::getNumeroLinha));
113-
114-
// DEBUG: Logar algumas chaves disponíveis no mapa de coordenadas
115-
logger.info("Chaves (NL) disponíveis nas novas coordenadas: {}",
116-
mapaNovasCoordenadasPorLinha.keySet().stream().limit(10).toList());
117114
}
118115

119-
LocalDateTime dataLimite = LocalDateTime.now().minusMinutes(ttlMinutes);
116+
LocalDateTime dataLimite = LocalDateTime.now(ZoneId.of("America/Sao_Paulo")).minusMinutes(ttlMinutes);
120117
List<LinhaEntity> linhasParaSalvar = new ArrayList<>();
121118

122119
for (LinhaEntity linha : linhasExistentes) {
@@ -134,13 +131,6 @@ public void salvaCoordenadas(List<CoordenadaDTO> todasCoordenadasNovas) {
134131

135132
// Merge com as novas coordenadas (se houver para esta linha)
136133
List<CoordenadaDTO> novasDaLinha = mapaNovasCoordenadasPorLinha.get(linha.getNumeroLinha());
137-
138-
// DEBUG: Se achou coordenadas para a linha, avisa
139-
if (novasDaLinha != null && !novasDaLinha.isEmpty()) {
140-
// logger.info("Encontradas {} coordenadas para linha {}", novasDaLinha.size(), linha.getNumeroLinha());
141-
} else if (mapaNovasCoordenadasPorLinha.containsKey(linha.getNumeroLinha())) {
142-
logger.warn("Chave existe mas lista é nula/vazia para linha {}", linha.getNumeroLinha());
143-
}
144134

145135
if (novasDaLinha != null) {
146136
for (CoordenadaDTO nova : novasDaLinha) {

0 commit comments

Comments
 (0)