feat: 충전기 상태 및 혼잡도를 저장하는 기능을 구현한다 #113

kiarakim · 2023-07-18T08:20:38Z

📄 Summary

충전기 상태 및 혼잡도를 저장하는 기능을 구현합니다.

핵심 과정

혼잡도 저장은 2가지 스텝으로 구분되어있습니다.

API 에서 10분간 변경된 충전기의 정보를 받아와 충전기의 상태를 갱신해주는 과정(7분마다)
DB 에서 모든 충전기의 상태를 바탕으로 혼잡도를 업데이트 하는 과정(1시간마다)

1번의 과정에서 ChargerStateUpdateService 의 update 메서드가 schedule 에 등록되어 7분마다 실행됩니다.

없는 충전기가 등록이 된다면, 새롭게 추가되고, 이미 있는 충전기가 등록이 된다면 업데이트 되는 과정을
ON DUPLICATE KEY UPDATE 를 사용해서 구현했습니다.

2번의 과정에서 ChargerStationService 의 calculateCongestion 메서드가 schedule 에 등록되어 1시간마다 실행됩니다.
이 과정에서 현재 충전기가 사용되고 있다면 총 카운트 +1, 사용 카운트 + 1 이 진행됩니다.
충전기가 사용되지 않는다면 총 카운트 +1 만 진행됩니다.

이때 추후 조회 성능을 개선하기 위해서 congestion 도 미리 double 형태로 저장해두도록 만들었습니다.

🙋🏻 More

close #21

[#21]

drunkenhw · 2023-07-19T02:45:46Z

#69
여기도 같이 리뷰해야합니다~

drunkenhw

수고하셨습니다

drunkenhw · 2023-07-19T04:32:57Z

backend/src/main/java/com/carffeine/carffeine/domain/chargestation/charger/ChargerState.java

+    public static ChargerState from(String input) {
+        return Arrays.stream(ChargerState.values())
+                .filter(it -> it.valueString.equals(input))
+                .findAny()
+                .orElse(STATUS_UNKNOWN);
+    }
+


Suggested change

public static ChargerState from(String input) {

return Arrays.stream(ChargerState.values())

.filter(it -> it.valueString.equals(input))

.findAny()

.orElse(STATUS_UNKNOWN);

}

public static ChargerState from(String input) {

int num = Integer.parseInt(intput);

return Arrays.stream(ChargerState.values())

.filter(it -> it.value == num)

.findAny()

.orElse(STATUS_UNKNOWN);

}

이런 방법은 어떤가요 그럼 관리할 필드가 하나 줄어서 나을 것 같아요

drunkenhw · 2023-07-19T04:35:04Z

...rc/main/java/com/carffeine/carffeine/domain/chargestation/congestion/PeriodicCongestion.java

+            @JoinColumn(name = "station_id", referencedColumnName = "station_id", insertable = false, updatable = false, foreignKey = @ForeignKey(value = ConstraintMode.NO_CONSTRAINT)),
+            @JoinColumn(name = "charger_id", referencedColumnName = "charger_id", insertable = false, updatable = false, foreignKey = @ForeignKey(value = ConstraintMode.NO_CONSTRAINT))


Suggested change

@JoinColumn(name = "station_id", referencedColumnName = "station_id", insertable = false, updatable = false, foreignKey = @ForeignKey(value = ConstraintMode.NO_CONSTRAINT)),

@JoinColumn(name = "charger_id", referencedColumnName = "charger_id", insertable = false, updatable = false, foreignKey = @ForeignKey(value = ConstraintMode.NO_CONSTRAINT))

@JoinColumns(value = {

@JoinColumn(name = "fk_station_id"),

@JoinColumn(name = "fk_charger_id")

}, foreignKey = @ForeignKey(ConstraintMode.NO_CONSTRAINT))

이렇게 하면 한번에 ForeignKey 를 해제할 수 있어요

drunkenhw · 2023-07-19T04:36:16Z

...end/src/main/java/com/carffeine/carffeine/domain/chargestation/congestion/RequestPeriod.java

    ZERO(0),
    TWELVE(1200);

    private static final List<RequestPeriod> periods = Arrays.stream(values())
            .sorted(Comparator.comparingInt(RequestPeriod::getSection))
            .toList();
+    private static final int UNIT = 100;


해당 클래스 필드,메서드, 상수들의 선언위치가 이상해요 수정부탁드립니다ㅓ

drunkenhw · 2023-07-19T04:37:07Z

backend/src/main/java/com/carffeine/carffeine/infra/api/RestTemplateChargeStationRequester.java

@@ -17,26 +19,45 @@
 @RequiredArgsConstructor
 @Slf4j
 @Component
-public class RestTemplateChargeStationRequester implements ChargeStationRequester {
+public class RestTemplateChargeStationRequester implements ChargeStationRequester, ChargerStateRequester {


클래스 멋지네요 굿 👍

drunkenhw · 2023-07-19T04:38:27Z

...rc/main/java/com/carffeine/carffeine/infra/repository/ChargerStatusCustomRepositoryImpl.java

+    private LocalDateTime parseDateTimeFromString(String input) {
+        if (input == null || input.length() != 14) {
+            return null;
+        }
+
+        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyyMMddHHmmss");
+        return LocalDateTime.parse(input, formatter);
+    }
+}


date time이 이상하게 들어오는 경우가 있었나요?
그렇다면 그 부분들도 parsing 할 수 있도록 만들어야겠네요

drunkenhw · 2023-07-19T04:39:40Z

.../main/java/com/carffeine/carffeine/service/chargerstation/ChargerStatusCustomRepository.java

+
+public interface ChargerStatusCustomRepository {
+
+    void saveAll(List<ChargerStateRequest> item);


파라미터명이 모호하네요 ㅎ

drunkenhw · 2023-07-19T04:41:32Z

backend/src/main/java/com/carffeine/carffeine/service/chargerstation/CongestionService.java

@@ -41,7 +46,7 @@ public StatisticsResponse calculateCongestion(StatisticsRequest statisticsReques

    private Map<String, List<CongestionInfoResponse>> calculateQuick(List<PeriodicCongestion> congestions, List<Charger> chargers) {
        List<String> quickChargerIds = chargers.stream()
-                .filter(it -> it.getCapacity().intValue() >= 50)
+                .filter(it -> it.getCapacity().intValue() >= OUTPUT_THRESHOLD)


이 부분에 capacity가 null 일 경우도 있는데, 그 부분에 대해 처리도 해줘야할 것 같아요. 공공 API에서 옵셔널로 제공되더라고요. 그래서 Charger 클래스 내에 예를 들어 isQuick()이라는 메서드를 추가하는 것은 어떤가요?

drunkenhw · 2023-07-19T04:41:40Z

backend/src/main/java/com/carffeine/carffeine/service/chargerstation/CongestionService.java

@@ -50,7 +55,7 @@ private Map<String, List<CongestionInfoResponse>> calculateQuick(List<PeriodicCo

    private Map<String, List<CongestionInfoResponse>> calculateStandard(List<PeriodicCongestion> congestions, List<Charger> chargers) {
        List<String> standardChargerIds = chargers.stream()
-                .filter(it -> it.getCapacity().intValue() < 50)
+                .filter(it -> it.getCapacity().intValue() < OUTPUT_THRESHOLD)


drunkenhw · 2023-07-19T04:43:01Z

.../src/test/java/com/carffeine/carffeine/infra/repository/ChargerStatusRepositoryImplTest.java

+    }
+
+    @Test
+    void 저장() {


테스트 메서드 이름을 좀 더 길게 적어주세요 ㅜ 무엇을 저장할까요.. ㅜ

drunkenhw · 2023-07-19T04:45:02Z

backend/src/main/java/com/carffeine/carffeine/service/chargerstation/dto/RandomKeySelector.java

    @Value("${api.service_key}")
    private List<String> serviceKeys;

    public String generateRandomKey() {
-        int randomNumber = threadLocalRandom.nextInt(START_INDEX, SERVICE_KEY_SIZE);
+        int randomNumber = threadLocalRandom.nextInt(START_INDEX, serviceKeys.size());


근데 이 부분은 yml에 넣어놓은 key가 7개면 0~7 까지의 숫자가 랜덤으로 나오는 것 아닌가요?
그렇게 된다면 7이라는 숫자가 나올 때 out of bound 가 발생할 것 같은데요.
제가 잘못 이해했을 수도 있습니다.

sosow0212

작업하시느라 수고 많으셨습니다~
코멘트 몇 가지만 확인해주세요

sosow0212 · 2023-07-19T04:49:51Z

...rc/main/java/com/carffeine/carffeine/infra/repository/ChargerStatusCustomRepositoryImpl.java

+    }
+
+    private LocalDateTime parseDateTimeFromString(String input) {
+        if (input == null || input.length() != 14) {


매직넘버 상수처리 해주세요~

sosow0212 · 2023-07-19T04:52:39Z

backend/src/main/java/com/carffeine/carffeine/service/chargerstation/ChargerStateRequester.java

+
+public interface ChargerStateRequester {
+
+    ChargerStateUpdateRequest requestChargerStatusUpdateRequest(int pageNo);


메서드 명을 requestChargerStatusUpdate로 바꾸는 건 어떨까요?

sosow0212 · 2023-07-19T04:55:58Z

backend/src/main/java/com/carffeine/carffeine/domain/chargestation/congestion/IdGenerator.java

-    public static String generateIdWithCharger(DayOfWeek dayOfWeek, RequestPeriod startTime, Charger charger) {
-        return generateId(dayOfWeek, startTime, charger.getStationId(), charger.getChargerId());
-    }
-
    public static String generateId(DayOfWeek dayOfWeek, RequestPeriod startTime, String stationId, String chargerId) {
        return dayOfWeek.getValue() * 10000L + startTime.getSection() + stationId + chargerId;


id값이 유니크한 값을 가지면서 데이터처럼 사용되네요👍 이 방법은 추후에 문제점은 없을까요?

sosow0212 · 2023-07-19T05:13:12Z

backend/src/main/java/com/carffeine/carffeine/domain/chargestation/charger/ChargerState.java

-    OPERATION_SUSPENDED(4),
-    UNDER_INSPECTION(5),
-    STATUS_UNKNOWN(9);
+    COMMUNICATION_ERROR(1, "1"),


뒤에 valueString필드를 선언한 이유가 있나요?
메서드에서 Integer.parseInt("...");로 변경한 후에 비교해도 될 것 같아요~

만약 공공 API에서 null 값 혹은 빈 값이 오는 경우가 있어서 의도 했다면 무시하셔도 됩니다!

sosow0212 · 2023-07-19T05:14:58Z

.../src/main/java/com/carffeine/carffeine/service/chargerstation/ChargerStateUpdateService.java

+    private final ChargerStateRequester chargerStateRequester;
+    private final ChargerStatusCustomRepository chargerStatusCustomRepository;
+
+    @Scheduled(cron = "0 0/7 * * * *")


주기적으로 업데이트가 되겠네요 👍

[#21]

[#21] [#21)]

[#21]

sosow0212

작업하시느라 고생하셨습니다 👍

drunkenhw

수고하셨습니다

be-student added 3 commits July 18, 2023 14:54

feat: 충전기 상태 업데이트 기능

f01d7c9

[#21]

feat: 주기적으로 충전기 정보 업데이트 기능 구현

2916a3c

[#21]

feat: 혼잡도 정보 업데이트 기능 구현

619e61c

[#21]

kiarakim requested review from be-student, drunkenhw and sosow0212 as code owners July 18, 2023 08:20

kiarakim temporarily deployed to test July 18, 2023 08:20 — with GitHub Actions Inactive

refactor: 사용하지 않는 메서드 제거 및 매직넘버 처리

002690b

kiarakim temporarily deployed to test July 19, 2023 04:15 — with GitHub Actions Inactive

be-student assigned be-student and kiarakim Jul 19, 2023

drunkenhw requested changes Jul 19, 2023

View reviewed changes

sosow0212 requested changes Jul 19, 2023

View reviewed changes

refactor: 코드리뷰를 반영한다

7fd0167

[#21]

be-student temporarily deployed to test July 19, 2023 09:07 — with GitHub Actions Inactive

drunkenhw mentioned this pull request Jul 19, 2023

충전소를 처음 저장할 때 충전소 상태도 저장하도록 변경한다 #140

Closed

1 task

be-student added 2 commits July 20, 2023 10:05

feat: 혼잡도를 조회하는 컨트롤러 작성

5d4c841

[#21] [#21)]

feat: adoc 작성

a44f9e0

[#21]

be-student force-pushed the feat/21 branch from b97c01a to a44f9e0 Compare July 20, 2023 01:05

be-student temporarily deployed to test July 20, 2023 01:05 — with GitHub Actions Inactive

be-student added 2 commits July 20, 2023 11:48

feat: 처음 저장시 status 도 함께 저장하도록 변경

16354c5

[#21]

fix: charger 조회시, status null 인 경우 false를 반환하도록 한다

d2e381e

[#21]

be-student temporarily deployed to test July 20, 2023 03:16 — with GitHub Actions Inactive

sosow0212 approved these changes Jul 20, 2023

View reviewed changes

drunkenhw approved these changes Jul 20, 2023

View reviewed changes

be-student merged commit 62c3185 into develop Jul 20, 2023
1 check passed

be-student deleted the feat/21 branch July 20, 2023 03:21

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

feat: 충전기 상태 및 혼잡도를 저장하는 기능을 구현한다 #113

feat: 충전기 상태 및 혼잡도를 저장하는 기능을 구현한다 #113

kiarakim commented Jul 18, 2023 •

edited by be-student

Loading

drunkenhw commented Jul 19, 2023

drunkenhw left a comment

drunkenhw Jul 19, 2023

drunkenhw Jul 19, 2023

drunkenhw Jul 19, 2023

drunkenhw Jul 19, 2023

drunkenhw Jul 19, 2023

drunkenhw Jul 19, 2023

drunkenhw Jul 19, 2023

drunkenhw Jul 19, 2023

drunkenhw Jul 19, 2023

drunkenhw Jul 19, 2023

sosow0212 left a comment

sosow0212 Jul 19, 2023

sosow0212 Jul 19, 2023

sosow0212 Jul 19, 2023

sosow0212 Jul 19, 2023

sosow0212 Jul 19, 2023

sosow0212 left a comment

drunkenhw left a comment

		@JoinColumn(name = "station_id", referencedColumnName = "station_id", insertable = false, updatable = false, foreignKey = @ForeignKey(value = ConstraintMode.NO_CONSTRAINT)),
		@JoinColumn(name = "charger_id", referencedColumnName = "charger_id", insertable = false, updatable = false, foreignKey = @ForeignKey(value = ConstraintMode.NO_CONSTRAINT))

-            @JoinColumn(name = "station_id", referencedColumnName = "station_id", insertable = false, updatable = false, foreignKey = @ForeignKey(value = ConstraintMode.NO_CONSTRAINT)),
-            @JoinColumn(name = "charger_id", referencedColumnName = "charger_id", insertable = false, updatable = false, foreignKey = @ForeignKey(value = ConstraintMode.NO_CONSTRAINT))
+  @JoinColumns(value = {
+            @JoinColumn(name = "fk_station_id"),
+            @JoinColumn(name = "fk_charger_id")
+    }, foreignKey = @ForeignKey(ConstraintMode.NO_CONSTRAINT))


		public interface ChargerStatusCustomRepository {

		void saveAll(List<ChargerStateRequest> item);


		public interface ChargerStateRequester {

		ChargerStateUpdateRequest requestChargerStatusUpdateRequest(int pageNo);

feat: 충전기 상태 및 혼잡도를 저장하는 기능을 구현한다 #113

feat: 충전기 상태 및 혼잡도를 저장하는 기능을 구현한다 #113

Conversation

kiarakim commented Jul 18, 2023 • edited by be-student Loading

📄 Summary

핵심 과정

🙋🏻 More

drunkenhw commented Jul 19, 2023

drunkenhw left a comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

sosow0212 left a comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

sosow0212 left a comment

Choose a reason for hiding this comment

drunkenhw left a comment

Choose a reason for hiding this comment

kiarakim commented Jul 18, 2023 •

edited by be-student

Loading