Skip to content

Commit

Permalink
release/0315-04 (#177)
Browse files Browse the repository at this point in the history
release/0315-04 (#177)
  • Loading branch information
Bisi3asi authored Mar 15, 2024
1 parent e6d6937 commit bd33b9f
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -256,14 +256,17 @@ public void updateChargerState3() {
List<ChargerStateUpdateForm> updatedChargerList =
chargerStateRedisService.updateExistingChargersToRedis(apiChargerList);

// DB 업데이트 로직 1. 단건 업데이트
// DB 업데이트 로직 단건 업데이트
AtomicInteger successCnt = new AtomicInteger();
LocalDateTime dbStartTime = LocalDateTime.now();
updatedChargerList.forEach(charger -> {
int isUpdated = chargerRepository.updateChargerState(charger);
if (isUpdated == 1)
successCnt.getAndIncrement();
});
LocalDateTime dbEndTime = LocalDateTime.now();
log.info("[DB] : 충전기 상태 {}건 중 {}건 업데이트 완료", apiChargerList.size(), successCnt);
log.info("[DB] 충전기 상태 갱신 시간 : {}", Ut.calcDuration(dbStartTime, dbEndTime));

LocalDateTime endTime = LocalDateTime.now();
log.info("[Scheduler3] : 충전기 상태 업데이트 종료 : 메소드 실행시간 {}", Ut.calcDuration(startTime, endTime));
Expand Down Expand Up @@ -334,10 +337,10 @@ public void updateChargerState4() {
List<ChargerStateUpdateForm> filteredChargerList =
chargerStateRedisService.filterExistingChargersFromRedis(apiChargerList);

// DB 업데이트 로직 1. 단건 업데이트
AtomicInteger successCnt = new AtomicInteger();
Set<String> nonExistingChargerKeySet = new HashSet<>();

LocalDateTime dbStartTime = LocalDateTime.now();
filteredChargerList.forEach(charger -> {
int isUpdated = chargerRepository.updateChargerState(charger);

Expand All @@ -348,7 +351,9 @@ public void updateChargerState4() {
nonExistingChargerKeySet.add(String.format("%s_%s", charger.getStatId(), charger.getChgerId()));
}
});
LocalDateTime dbEndTime = LocalDateTime.now();
log.info("[DB] : 충전기 상태 {}건 중 {}건 업데이트 완료", apiChargerList.size(), successCnt);
log.info("[DB] 충전기 상태 갱신 시간 : {}", Ut.calcDuration(dbStartTime, dbEndTime));

// DB 비교 후 없는 충전기 정보를 Redis에 저장
chargerStateRedisService.updateNonExistingChargersToRedis(nonExistingChargerKeySet);
Expand Down
2 changes: 1 addition & 1 deletion src/main/resources/application.yml
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ spring:
fail-on-empty-beans: false
threads:
virtual:
enabled: true
enabled: false
sql:
init:
mode: always
Expand Down

0 comments on commit bd33b9f

Please sign in to comment.