Merge pull request #63 from Capstone-QuarterBack/feature

Main Merge

Author: taewon0

build.gradle

@@ -56,6 +56,9 @@ dependencies {
 	//validation
 	implementation 'org.springframework.boot:spring-boot-starter-validation'
 
+	//mongoDB
+	implementation 'org.springframework.boot:spring-boot-starter-data-mongodb'
+
 }
 
 tasks.named('test') {

src/main/java/com/example/quaterback/api/domain/charger/constant/ChargerStatus.java

@@ -3,5 +3,6 @@
 public enum ChargerStatus {
     OCCUPIED,
     AVAILABLE,
-    UNAVAILABLE
+    UNAVAILABLE,
+    FAULT
 }

src/main/java/com/example/quaterback/api/domain/charger/entity/ChargerEntity.java

@@ -3,13 +3,10 @@
 import com.example.quaterback.api.domain.charger.constant.ChargerStatus;
 import com.example.quaterback.api.domain.charger.domain.ChargerDomain;
 import com.example.quaterback.api.domain.station.entity.ChargingStationEntity;
-import com.example.quaterback.api.domain.txinfo.entity.TransactionInfoEntity;
 import jakarta.persistence.*;
 import lombok.*;
 
 import java.time.LocalDateTime;
-import java.util.ArrayList;
-import java.util.List;
 
 @Entity
 @Table(name = "charger_info")
@@ -59,8 +56,8 @@ public void updateChargerStatus(ChargerStatus status) {
 
     public void assignStation(ChargingStationEntity stationEntity) {
         station = stationEntity;
-        if (!stationEntity.getChargerList().contains(this)) {
-            stationEntity.getChargerList().add(this);
+        if (!stationEntity.getChargerEntityList().contains(this)) {
+            stationEntity.getChargerEntityList().add(this);
         }
     }
 

src/main/java/com/example/quaterback/api/domain/charger/repository/ChargerRepository.java

@@ -1,7 +1,10 @@
 package com.example.quaterback.api.domain.charger.repository;
 
+import com.example.quaterback.api.domain.charger.constant.ChargerStatus;
 import com.example.quaterback.api.domain.charger.domain.ChargerDomain;
 import com.example.quaterback.api.domain.charger.entity.ChargerEntity;
+import com.example.quaterback.api.domain.station.constant.StationStatus;
+import com.example.quaterback.api.feature.statistics.dto.response.StatisticsData;
 
 import java.util.List;
 
@@ -13,4 +16,7 @@ public interface ChargerRepository {
     List<ChargerDomain> findAllByStationId(String stationId);
     List<ChargerDomain> findByStationID(String stationId);
     void save(ChargerDomain chargerDomain);
+    List<StatisticsData.ChartData> countFaultAndNormalChargers();
+
+    ChargerDomain updateChargerStatus(String stationId, Integer evseId, ChargerStatus status);
 }

src/main/java/com/example/quaterback/api/domain/charger/repository/JpaChargerRepository.java

@@ -1,11 +1,16 @@
 package com.example.quaterback.api.domain.charger.repository;
 
+import com.example.quaterback.api.domain.charger.constant.ChargerStatus;
 import com.example.quaterback.api.domain.charger.entity.ChargerEntity;
 import com.example.quaterback.api.domain.charger.domain.ChargerDomain;
+import com.example.quaterback.api.domain.station.constant.StationStatus;
 import com.example.quaterback.api.domain.station.entity.ChargingStationEntity;
 import com.example.quaterback.api.domain.station.repository.ChargingStationRepository;
 import com.example.quaterback.api.domain.station.repository.SpringDataJpaChargingStationRepository;
+import com.example.quaterback.api.feature.statistics.dto.response.StatisticsData;
 import jakarta.persistence.EntityNotFoundException;
+import jakarta.persistence.Transient;
+import jakarta.transaction.Transactional;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Repository;
 
@@ -19,6 +24,8 @@
 public class JpaChargerRepository implements ChargerRepository {
     private final SpringDataJpaChargingStationRepository springDataJpaChargingStationRepository;
     private final SpringDataJpaChargerRepository chargerRepository;
+    private final SpringDataJpaChargerRepository springDataJpaChargerRepository;
+
     @Override
     public ChargerDomain findByStationIdAndEvseId(String stationId, Integer evseId) {
         ChargerEntity entity = chargerRepository.findByStation_StationIdAndEvseId(stationId, evseId)
@@ -63,4 +70,33 @@ public List<ChargerDomain> findAllByStationId(String stationId) {
                 .map(ChargerEntity::toDomain)
                 .toList();
     }
+
+    @Override
+    public List<StatisticsData.ChartData> countFaultAndNormalChargers() {
+        List<Object[]> resultList = chargerRepository.countFaultAndNormalChargers();
+        Object[] results = resultList.get(0);
+        double normalChargers = ((Number) results[0]).doubleValue();
+        double faultChargers = ((Number) results[1]).doubleValue();
+        return List.of(
+                StatisticsData.ChartData.builder()
+                        .label("정상")
+                        .value(normalChargers)
+                        .build(),
+                StatisticsData.ChartData.builder()
+                        .label("고장")
+                        .value(faultChargers)
+                        .build()
+        );
+    }
+
+    @Override
+    @Transactional
+    public ChargerDomain updateChargerStatus(String stationId, Integer evseId, ChargerStatus status) {
+        ChargerEntity entity = springDataJpaChargerRepository.findOneCharger(stationId, evseId)
+                .orElseThrow(() -> new EntityNotFoundException("entity not found"));
+
+        entity.updateChargerStatus(status);
+        ChargerEntity updatedEntity = springDataJpaChargerRepository.save(entity);
+        return updatedEntity.toDomain();
+    }
 }

src/main/java/com/example/quaterback/api/domain/charger/repository/SpringDataJpaChargerRepository.java

@@ -14,4 +14,15 @@ public interface SpringDataJpaChargerRepository extends JpaRepository<ChargerEnt
 
     @Query("select c from ChargerEntity c where c.station.stationId =:stationId")
     List<ChargerEntity> findAllByStationId(@Param("stationId")String stationId);
+
+    @Query(value = """
+    SELECT
+        SUM(CASE WHEN c.charger_status != 'FAULT' THEN 1 ELSE 0 END) AS faultCount,
+        SUM(CASE WHEN c.charger_status = 'FAULT' THEN 1 ELSE 0 END) AS normalCount
+    FROM charger_info c
+    """, nativeQuery = true)
+    List<Object[]> countFaultAndNormalChargers();
+
+    @Query("select c from ChargerEntity c where c.station.stationId = :stationId and c.evseId = :evseId")
+    Optional<ChargerEntity> findOneCharger(String stationId, Integer evseId);
 }

src/main/java/com/example/quaterback/api/domain/price/constant/Season.java

@@ -0,0 +1,5 @@
+package com.example.quaterback.api.domain.price.constant;
+
+public enum Season {
+    SUMMER, SPRING_FALL, WINTER
+}

src/main/java/com/example/quaterback/api/domain/price/constant/TimeSlot.java

@@ -0,0 +1,5 @@
+package com.example.quaterback.api.domain.price.constant;
+
+public enum TimeSlot {
+    OFF_PEAK, MID_PEAK, ON_PEAK
+}

src/main/java/com/example/quaterback/api/domain/price/entity/KepcoPrice.java

@@ -0,0 +1,28 @@
+package com.example.quaterback.api.domain.price.entity;
+
+import com.example.quaterback.api.domain.price.constant.Season;
+import com.example.quaterback.api.domain.price.constant.TimeSlot;
+import jakarta.persistence.*;
+import lombok.*;
+
+@Entity
+@Table(name = "kepco_price")
+@Getter
+@Setter
+@NoArgsConstructor
+@AllArgsConstructor
+@Builder
+public class KepcoPrice {
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private long id;
+
+    @Enumerated(EnumType.STRING)
+    private Season season;
+
+    @Enumerated(EnumType.STRING)
+    private TimeSlot timeSlot;
+
+    private double pricePerKwh;
+}
+

src/main/java/com/example/quaterback/api/domain/price/entity/PricePerMwh.java

@@ -0,0 +1,29 @@
+package com.example.quaterback.api.domain.price.entity;
+
+import jakarta.persistence.*;
+import lombok.*;
+
+import java.time.LocalDateTime;
+
+@Entity
+@Table(name = "cs_price")
+@Getter
+@Setter
+@NoArgsConstructor
+@AllArgsConstructor
+@Builder
+public class PricePerMwh {
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private long id;
+
+    private double pricePerMwh;
+    private LocalDateTime updatedDateTime;
+
+    public static PricePerMwh from(double pricePerMwh) {
+        return PricePerMwh.builder()
+                .pricePerMwh(pricePerMwh)
+                .updatedDateTime(LocalDateTime.now())
+                .build();
+    }
+}