Merge pull request #109 from nimuy99/feat/105-detail-price-info

#105 Feat: 코인 디테일 가격 정보 조회 기능 구현

Author: nimuyman

src/main/java/com/memesphere/domain/chartdata/repository/ChartDataRepository.java

@@ -11,6 +11,7 @@
 import java.math.BigDecimal;
 import java.time.LocalDateTime;
 import java.util.List;
+import java.util.Optional;
 
 public interface ChartDataRepository extends JpaRepository<ChartData, Long> {
     @Query("SELECT SUM(c.volume) FROM ChartData c " +
@@ -32,4 +33,9 @@ public interface ChartDataRepository extends JpaRepository<ChartData, Long> {
     //TODO: 위아래 코드 합치는 방법 찾기
     List<ChartData> findByMemeCoinOrderByRecordedTimeDesc(MemeCoin memeCoin, Pageable pageable);
 
+    @Query("SELECT c FROM ChartData c " +
+            "WHERE c.memeCoin.id = :coinId " +
+            "AND c.recordedTime = " +
+            "(SELECT MAX(c2.recordedTime) FROM ChartData c2 WHERE c2.memeCoin = c.memeCoin)")
+    Optional<ChartData> findLatestByCoinId(Long coinId);
 }

src/main/java/com/memesphere/domain/detail/controller/DetailController.java

@@ -1,8 +1,10 @@
 package com.memesphere.domain.detail.controller;
 
+import com.memesphere.domain.detail.dto.response.PriceInfoResponse;
+import com.memesphere.domain.detail.service.DetailQueryServiceImpl;
 import com.memesphere.global.apipayload.ApiResponse;
 import com.memesphere.domain.detail.dto.response.DetailGetResponse;
-import com.memesphere.domain.detail.service.DetailService;
+import com.memesphere.domain.detail.service.DetailQueryService;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import lombok.RequiredArgsConstructor;
@@ -17,7 +19,7 @@
 @RequestMapping("/detail")
 public class DetailController {
 
-    private final DetailService detailService;
+    private final DetailQueryService detailQueryService;
 
     @GetMapping("/{memeId}")
     @Operation(summary = "밈코인 세부 정보 조회 API",
@@ -35,10 +37,38 @@ public class DetailController {
                     - "image": 밈코인 이미지
                     - "keywords": 밈코인 키워드 (리스트 형식)
                     - "collectionActive": 컬렉션 유무 (저장 유무)
+                    - "rank": 밈코인 순위(1 ~ 5위까지, 나머지 순위는 null)
                     ```""")
     public ApiResponse<DetailGetResponse> getDetail(@PathVariable("memeId") Long memeId) {
 
-        DetailGetResponse detailGetResponse = detailService.getDetail(memeId);
+        DetailGetResponse detailGetResponse = detailQueryService.getDetail(memeId);
         return ApiResponse.onSuccess(detailGetResponse);
     }
+
+    @GetMapping("/{memeId}/price-info")
+    @Operation(summary = "밈코인 가격 정보 조회 API",
+            description = """
+                    해당 밈코인의 24시간 기준 가격 정보를 보여줍니다. \n
+                    
+                    **요청 형식**:
+                    ```
+                    "memeId": 코인 아이디
+                    ```
+                    \n
+                    **응답 형식**:
+                    ```
+                    - "coinId": 코인 아이디
+                    - "price": 현재가
+                    - "priceChange": 가격 변화량
+                    - "priceChangeAbsolute": 가격 변화량(절대값)
+                    - "priceChangeDirection": 밈코인 상승(up, 0 이상)/하락(down)
+                    - "priceChangeRate": 가격 변화율
+                    - "weightedAveragePrice": 거래량 가중 평균 가격
+                    - "highPrice": 24h 최고가
+                    - "lowPrice": 24h 최저가
+                    ```""")
+    public ApiResponse<PriceInfoResponse> getPriceInfo(@PathVariable("memeId") Long coinId) {
+
+        return ApiResponse.onSuccess(detailQueryService.findPriceInfo(coinId));
+    }
 }

src/main/java/com/memesphere/domain/detail/converter/DetailConverter.java

@@ -1,8 +1,12 @@
 package com.memesphere.domain.detail.converter;
 
+import com.memesphere.domain.chartdata.entity.ChartData;
+import com.memesphere.domain.detail.dto.response.PriceInfoResponse;
 import com.memesphere.domain.memecoin.entity.MemeCoin;
 import com.memesphere.domain.detail.dto.response.DetailGetResponse;
 
+import java.math.BigDecimal;
+
 public class DetailConverter {
 
     public static DetailGetResponse toDetailGetResponse(MemeCoin memeCoin) {
@@ -15,6 +19,21 @@ public static DetailGetResponse toDetailGetResponse(MemeCoin memeCoin) {
                 .image(memeCoin.getImage())
                 .keywords(memeCoin.getKeywords())
                 .collectionActive(memeCoin.getCollectionList().isEmpty())
+                .rank(memeCoin.getTrendRank())
+                .build();
+    }
+
+    public static PriceInfoResponse toPriceInfoResponse(MemeCoin memeCoin, ChartData data) {
+        return PriceInfoResponse.builder()
+                .coinId(memeCoin.getId())
+                .price(data.getPrice())
+                .priceChange(data.getPriceChange())
+                .priceChangeAbsolute(data.getPriceChange().abs())
+                .priceChangeDirection(data.getPriceChangeRate().compareTo(BigDecimal.ZERO) < 0 ? "down" : "up")
+                .priceChangeRate(data.getPriceChangeRate())
+                .weightedAveragePrice(data.getWeighted_average_price())
+                .highPrice(data.getHigh_price())
+                .lowPrice(data.getLow_price())
                 .build();
     }
 }

src/main/java/com/memesphere/domain/detail/dto/response/DetailGetResponse.java

@@ -30,4 +30,7 @@ public class DetailGetResponse {
 
     @Schema(description = "컬렉션 유무", example = "True")
     private boolean collectionActive;
+
+    @Schema(description = "밈코인 순위", example = "1")
+    private Integer rank;
 }

src/main/java/com/memesphere/domain/detail/dto/response/PriceInfoResponse.java

@@ -0,0 +1,38 @@
+package com.memesphere.domain.detail.dto.response;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Builder;
+import lombok.Getter;
+
+import java.math.BigDecimal;
+
+@Getter
+@Builder
+public class PriceInfoResponse {
+    @Schema(description = "밈코인 아이디", example = "1")
+    private Long coinId;
+
+    @Schema(description = "현재가", example = "0.20")
+    private BigDecimal price;
+
+    @Schema(description = "가격 변화량", example = "-0.03")
+    private BigDecimal priceChange;
+
+    @Schema(description = "가격 변화량 절대값", example = "0.03")
+    private BigDecimal priceChangeAbsolute;
+
+    @Schema(description = "가격 변화 방향", example = "down")
+    private String priceChangeDirection;
+
+    @Schema(description = "가격 변화율", example = "-6.35")
+    private BigDecimal priceChangeRate;
+
+    @Schema(description = "거래량 가중 평균 가격", example = "-942.38")
+    private BigDecimal weightedAveragePrice;
+
+    @Schema(description = "24h 최고가", example = "2500")
+    private BigDecimal highPrice;
+
+    @Schema(description = "24h 최저가", example = "1500")
+    private BigDecimal lowPrice;
+}

src/main/java/com/memesphere/domain/detail/service/DetailQueryService.java

@@ -0,0 +1,10 @@
+package com.memesphere.domain.detail.service;
+
+
+import com.memesphere.domain.detail.dto.response.DetailGetResponse;
+import com.memesphere.domain.detail.dto.response.PriceInfoResponse;
+
+public interface DetailQueryService {
+    DetailGetResponse getDetail(Long meme_id);
+    PriceInfoResponse findPriceInfo(Long coinId);
+}

…domain/detail/service/DetailService.java …tail/service/DetailQueryServiceImpl.javasrc/main/java/com/memesphere/domain/detail/service/DetailService.java renamed to src/main/java/com/memesphere/domain/detail/service/DetailQueryServiceImpl.java src/main/java/com/memesphere/domain/detail/service/DetailService.java renamed to src/main/java/com/memesphere/domain/detail/service/DetailQueryServiceImpl.java

@@ -1,20 +1,23 @@
 package com.memesphere.domain.detail.service;
 
+import com.memesphere.domain.chartdata.entity.ChartData;
+import com.memesphere.domain.chartdata.repository.ChartDataRepository;
 import com.memesphere.domain.detail.converter.DetailConverter;
-import com.memesphere.global.apipayload.code.status.ErrorStatus;
-import com.memesphere.global.apipayload.exception.GeneralException;
-import com.memesphere.domain.memecoin.entity.MemeCoin;
 import com.memesphere.domain.detail.dto.response.DetailGetResponse;
+import com.memesphere.domain.detail.dto.response.PriceInfoResponse;
+import com.memesphere.domain.memecoin.entity.MemeCoin;
 import com.memesphere.domain.memecoin.repository.MemeCoinRepository;
+import com.memesphere.global.apipayload.code.status.ErrorStatus;
+import com.memesphere.global.apipayload.exception.GeneralException;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 @Service
 @RequiredArgsConstructor
-public class DetailService {
-
+public class DetailQueryServiceImpl implements DetailQueryService {
     private final MemeCoinRepository memeCoinRepository;
+    private final ChartDataRepository chartDataRepository;
 
     @Transactional
     public DetailGetResponse getDetail(Long meme_id) {
@@ -26,4 +29,14 @@ public DetailGetResponse getDetail(Long meme_id) {
 
         return detailGetResponse;
     }
+
+    public PriceInfoResponse findPriceInfo(Long coinId) {
+        MemeCoin memeCoin = memeCoinRepository.findById(coinId)
+                .orElseThrow(() -> new GeneralException(ErrorStatus.MEMECOIN_NOT_FOUND));
+
+        ChartData data = chartDataRepository.findLatestByCoinId(coinId)
+                .orElseThrow(() -> new GeneralException(ErrorStatus.CHARTDATA_NOT_FOUND));
+
+        return DetailConverter.toPriceInfoResponse(memeCoin, data);
+    }
 }

src/main/java/com/memesphere/global/apipayload/code/status/ErrorStatus.java

@@ -31,6 +31,7 @@ public enum ErrorStatus implements BaseCode {
 
     // ChartData load 에러
     CANNOT_LOAD_CHARTDATA(HttpStatus.BAD_REQUEST, "CANNOT LOAD CHARTDATA", "ChartData를 Binance에서 로드할 수 없습니다."),
+    CHARTDATA_NOT_FOUND(HttpStatus.NOT_FOUND, "CHARTDATA NOT FOUND", "차트 데이터를 찾을 수 없습니다."),
 
     // notification 에러
     CANNOT_CHECK_VOLATILITY(HttpStatus.NOT_FOUND, "CANNOT CHECK VOLATILITY", "변동성을 확인할 수 없습니다."),