Merge pull request #133 from nimuy99/fix/#131-binance-api-response

nimuyman · web-flow · commit 99d2cf52d1d1 · 2025-02-19T20:30:35.000+09:00
#131 Fix: 바이낸스 api 응답 자료형 변경
diff --git a/src/main/java/com/memesphere/domain/chartdata/converter/ChartDataConverter.java b/src/main/java/com/memesphere/domain/chartdata/converter/ChartDataConverter.java
@@ -13,13 +13,13 @@ public static ChartData toChartData(MemeCoin memeCoin, BinanceTickerResponse res
         return ChartData.builder()
                 .memeCoin(memeCoin)
                 .recordedTime(LocalDateTime.now())
-                .price(new BigDecimal(response.getLastPrice()))
-                .priceChange(new BigDecimal(response.getPriceChange()))
-                .priceChangeRate(new BigDecimal(response.getPriceChangePercent()))
-                .weighted_average_price(new BigDecimal(response.getWeightedAvgPrice()))
+                .price(Double.parseDouble(response.getLastPrice()))
+                .priceChange(Double.parseDouble(response.getPriceChange()))
+                .priceChangeRate(Double.parseDouble(response.getPriceChangePercent()))
+                .weighted_average_price(Double.parseDouble(response.getWeightedAvgPrice()))
                 .volume(new BigDecimal(response.getVolume()))
-                .low_price(new BigDecimal(response.getLowPrice()))
-                .high_price(new BigDecimal(response.getHighPrice()))
+                .low_price(Double.parseDouble(response.getLowPrice()))
+                .high_price(Double.parseDouble(response.getHighPrice()))
                 .build();
     }
 }
diff --git a/src/main/java/com/memesphere/domain/chartdata/entity/ChartData.java b/src/main/java/com/memesphere/domain/chartdata/entity/ChartData.java
@@ -27,25 +27,25 @@ public class ChartData extends BaseEntity {
     private LocalDateTime recordedTime;
 
     @Column
-    private BigDecimal price;
+    private Double price;
 
     @Column
-    private BigDecimal priceChange;
+    private Double priceChange;
 
     @Column
-    private BigDecimal priceChangeRate;
+    private Double priceChangeRate;
 
     @Column
-    private BigDecimal weighted_average_price;
+    private Double weighted_average_price;
 
     @Column
     private BigDecimal volume;
 
     @Column
-    private BigDecimal low_price;
+    private Double low_price;
 
     @Column
-    private BigDecimal high_price;
+    private Double high_price;
 
     @ManyToOne(fetch = FetchType.LAZY)
     @JoinColumn(name = "coin_id", nullable = false) // 외래 키
diff --git a/src/main/java/com/memesphere/domain/collection/converter/CollectionConverter.java b/src/main/java/com/memesphere/domain/collection/converter/CollectionConverter.java
@@ -12,6 +12,7 @@
 import org.springframework.data.domain.Page;
 
 import java.math.BigDecimal;
+import java.math.RoundingMode;
 import java.util.List;
 import java.util.stream.Collectors;
 
@@ -56,11 +57,21 @@ private static CollectionGridPreviewResponse toCollectionGridPreviewDTO(Collecti
                 .name(memeCoin.getName())
                 .symbol(memeCoin.getSymbol())
                 .image(memeCoin.getImage())
-                .currentPrice(chartData.getPrice())
-                .highPrice(chartData.getHigh_price())
-                .lowPrice(chartData.getLow_price())
-                .priceChange(chartData.getPriceChange())
-                .priceChangeRate(chartData.getPriceChangeRate())
+                .currentPrice(BigDecimal.valueOf(chartData.getPrice())
+                        .setScale(8, RoundingMode.HALF_UP)
+                        .toPlainString())
+                .highPrice(BigDecimal.valueOf(chartData.getHigh_price())
+                        .setScale(8, RoundingMode.HALF_UP)
+                        .toPlainString())
+                .lowPrice(BigDecimal.valueOf(chartData.getLow_price())
+                        .setScale(8, RoundingMode.HALF_UP)
+                        .toPlainString())
+                .priceChange(BigDecimal.valueOf(chartData.getPriceChange())
+                        .setScale(8, RoundingMode.HALF_UP)
+                        .toPlainString())
+                .priceChangeRate(BigDecimal.valueOf(chartData.getPriceChangeRate())
+                        .setScale(8, RoundingMode.HALF_UP)
+                        .toPlainString())
                 .build();
     }
 
@@ -72,9 +83,15 @@ public static CollectionListPreviewResponse toCollectionListPreviewDTO(Collectio
                 .coinId(memeCoin.getId())
                 .name(memeCoin.getName())
                 .symbol(memeCoin.getSymbol())
-                .currentPrice(chartData.getPrice())
-                .priceChangeRate(chartData.getPriceChangeRate())
-                .weightedAveragePrice(chartData.getWeighted_average_price())
+                .currentPrice(BigDecimal.valueOf(chartData.getPrice())
+                        .setScale(8, RoundingMode.HALF_UP)
+                        .toPlainString())
+                .priceChangeRate(BigDecimal.valueOf(chartData.getPriceChangeRate())
+                        .setScale(8, RoundingMode.HALF_UP)
+                        .toPlainString())
+                .weightedAveragePrice(BigDecimal.valueOf(chartData.getWeighted_average_price())
+                        .setScale(8, RoundingMode.HALF_UP)
+                        .toPlainString())
                 .volume(chartData.getVolume())
                 .build();
     }
diff --git a/src/main/java/com/memesphere/domain/collection/dto/response/CollectionGridPreviewResponse.java b/src/main/java/com/memesphere/domain/collection/dto/response/CollectionGridPreviewResponse.java
@@ -1,5 +1,6 @@
 package com.memesphere.domain.collection.dto.response;
 
+import com.fasterxml.jackson.annotation.JsonFormat;
 import io.swagger.v3.oas.annotations.media.Schema;
 import lombok.AllArgsConstructor;
 import lombok.Builder;
@@ -15,20 +16,28 @@
 public class CollectionGridPreviewResponse {
     @Schema(description = "밈코인 id", example = "1")
     Long coinId;
+
     @Schema(description = "밈코인 name", example = "도지코인")
     String name;
+
     @Schema(description = "밈코인 symbol", example = "DOGE")
     String symbol;
+
     @Schema(description = "밈코인 image", example = "https://bucketname.s3.region.amazonaws.com/image1.jpg")
     String image;
+
     @Schema(description = "차트 데이터의 price", example = "2000")
-    BigDecimal currentPrice;
+    String currentPrice;
+
     @Schema(description = "차트 데이터의 high_price", example = "2500")
-    BigDecimal highPrice;
+    String highPrice;
+
     @Schema(description = "차트 데이터의 low_price", example = "1500")
-    BigDecimal lowPrice;
+    String lowPrice;
+
     @Schema(description = "차트 데이터의 price_change", example = "500")
-    BigDecimal priceChange;
+    String priceChange;
+
     @Schema(description = "차트 데이터의 price_change_rate", example = "2.4")
-    BigDecimal priceChangeRate;
+    String priceChangeRate;
 }
diff --git a/src/main/java/com/memesphere/domain/collection/dto/response/CollectionListPreviewResponse.java b/src/main/java/com/memesphere/domain/collection/dto/response/CollectionListPreviewResponse.java
@@ -1,5 +1,6 @@
 package com.memesphere.domain.collection.dto.response;
 
+import com.fasterxml.jackson.annotation.JsonFormat;
 import io.swagger.v3.oas.annotations.media.Schema;
 import lombok.AllArgsConstructor;
 import lombok.Builder;
@@ -15,16 +16,22 @@
 public class CollectionListPreviewResponse {
     @Schema(description = "밈코인 id", example = "1")
     Long coinId;
+
     @Schema(description = "밈코인 name", example = "도지코인")
     String name;
+
     @Schema(description = "밈코인 symbol", example = "DOGE")
     String symbol;
+
     @Schema(description = "차트 데이터의 price", example = "2000")
-    BigDecimal currentPrice;
+    String currentPrice;
+
     @Schema(description = "차트 데이터의 price_change_rate", example = "+2.4%")
-    BigDecimal priceChangeRate;
+    String priceChangeRate;
+
     @Schema(description = "차트 데이터의 weighted average price", example = "10000")
-    BigDecimal weightedAveragePrice; // market cap 대신 사용
+    String weightedAveragePrice; // market cap 대신 사용
+
     @Schema(description = "차트 데이터의 volume", example = "5")
     BigDecimal volume;
 }
diff --git a/src/main/java/com/memesphere/domain/dashboard/converter/DashboardConverter.java b/src/main/java/com/memesphere/domain/dashboard/converter/DashboardConverter.java
@@ -8,6 +8,7 @@
 
 
 import java.math.BigDecimal;
+import java.math.RoundingMode;
 import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.List;
@@ -68,11 +69,19 @@ public static DashboardTrendResponse toTrend(ChartData data,
                 .name(memeCoin.getName())
                 .symbol(memeCoin.getSymbol())
                 .volume(data.getVolume())
-                .price(data.getPrice())
-                .priceChange(data.getPriceChange())
-                .priceChangeAbsolute(data.getPriceChange().abs())
-                .priceChangeDirection(data.getPriceChangeRate().compareTo(BigDecimal.ZERO) < 0 ? "down" : "up")
-                .priceChangeRate(data.getPriceChangeRate())
+                .price(BigDecimal.valueOf(data.getPrice())
+                        .setScale(8, RoundingMode.HALF_UP)
+                        .toPlainString())
+                .priceChange(BigDecimal.valueOf(data.getPriceChange())
+                        .setScale(8, RoundingMode.HALF_UP)
+                        .toPlainString())
+                .priceChangeAbsolute(BigDecimal.valueOf(Math.abs(data.getPriceChange()))
+                        .setScale(8, RoundingMode.HALF_UP)
+                        .toPlainString())
+                .priceChangeDirection(data.getPriceChangeRate() < 0 ? "down" : "up")
+                .priceChangeRate(BigDecimal.valueOf(data.getPriceChangeRate())
+                        .setScale(8, RoundingMode.HALF_UP)
+                        .toPlainString())
                 .rankChangeDirection(rankDirection)
                 .build();
     }
diff --git a/src/main/java/com/memesphere/domain/dashboard/dto/response/DashboardTrendResponse.java b/src/main/java/com/memesphere/domain/dashboard/dto/response/DashboardTrendResponse.java
@@ -1,5 +1,6 @@
 package com.memesphere.domain.dashboard.dto.response;
 
+import com.fasterxml.jackson.annotation.JsonFormat;
 import io.swagger.v3.oas.annotations.media.Schema;
 import lombok.Builder;
 import lombok.Getter;
@@ -25,19 +26,19 @@ public class DashboardTrendResponse {
     private BigDecimal volume;
 
     @Schema(description = "현재가", example = "0.20")
-    private BigDecimal price;
+    private String price;
 
     @Schema(description = "가격 변화량", example = "-0.03")
-    private BigDecimal priceChange;
+    private String priceChange;
 
     @Schema(description = "가격 변화량 절대값", example = "0.03")
-    private BigDecimal priceChangeAbsolute;
+    private String priceChangeAbsolute;
 
     @Schema(description = "가격 변화 방향", example = "down")
     private String priceChangeDirection;
 
     @Schema(description = "가격 변화율", example = "-6.35")
-    private BigDecimal priceChangeRate;
+    private String priceChangeRate;
 
     @Schema(description = "순위 변화 방향", example = "down")
     private String rankChangeDirection;
diff --git a/src/main/java/com/memesphere/domain/detail/converter/DetailConverter.java b/src/main/java/com/memesphere/domain/detail/converter/DetailConverter.java
@@ -6,6 +6,7 @@
 import com.memesphere.domain.detail.dto.response.DetailGetResponse;
 
 import java.math.BigDecimal;
+import java.math.RoundingMode;
 
 public class DetailConverter {
 
@@ -26,14 +27,28 @@ public static DetailGetResponse toDetailGetResponse(MemeCoin memeCoin) {
     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())
+                .price(BigDecimal.valueOf(data.getPrice())
+                        .setScale(8, RoundingMode.HALF_UP)
+                        .toPlainString())
+                .priceChange(BigDecimal.valueOf(data.getPriceChange())
+                        .setScale(8, RoundingMode.HALF_UP)
+                        .toPlainString())
+                .priceChangeAbsolute(BigDecimal.valueOf(Math.abs(data.getPriceChange()))
+                        .setScale(8, RoundingMode.HALF_UP)
+                        .toPlainString())
+                .priceChangeDirection(data.getPriceChangeRate() < 0 ? "down" : "up")
+                .priceChangeRate(BigDecimal.valueOf(data.getPriceChangeRate())
+                        .setScale(8, RoundingMode.HALF_UP)
+                        .toPlainString())
+                .weightedAveragePrice(BigDecimal.valueOf(data.getWeighted_average_price())
+                        .setScale(8, RoundingMode.HALF_UP)
+                        .toPlainString())
+                .highPrice(BigDecimal.valueOf(data.getHigh_price())
+                        .setScale(8, RoundingMode.HALF_UP)
+                        .toPlainString())
+                .lowPrice(BigDecimal.valueOf(data.getLow_price())
+                        .setScale(8, RoundingMode.HALF_UP)
+                        .toPlainString())
                 .build();
     }
 }
diff --git a/src/main/java/com/memesphere/domain/detail/dto/response/PriceInfoResponse.java b/src/main/java/com/memesphere/domain/detail/dto/response/PriceInfoResponse.java
@@ -1,5 +1,6 @@
 package com.memesphere.domain.detail.dto.response;
 
+import com.fasterxml.jackson.annotation.JsonFormat;
 import io.swagger.v3.oas.annotations.media.Schema;
 import lombok.Builder;
 import lombok.Getter;
@@ -13,26 +14,26 @@ public class PriceInfoResponse {
     private Long coinId;
 
     @Schema(description = "현재가", example = "0.20")
-    private BigDecimal price;
+    private String price;
 
     @Schema(description = "가격 변화량", example = "-0.03")
-    private BigDecimal priceChange;
+    private String priceChange;
 
     @Schema(description = "가격 변화량 절대값", example = "0.03")
-    private BigDecimal priceChangeAbsolute;
+    private String priceChangeAbsolute;
 
     @Schema(description = "가격 변화 방향", example = "down")
     private String priceChangeDirection;
 
     @Schema(description = "가격 변화율", example = "-6.35")
-    private BigDecimal priceChangeRate;
+    private String priceChangeRate;
 
     @Schema(description = "거래량 가중 평균 가격", example = "-942.38")
-    private BigDecimal weightedAveragePrice;
+    private String weightedAveragePrice;
 
     @Schema(description = "24h 최고가", example = "2500")
-    private BigDecimal highPrice;
+    private String highPrice;
 
     @Schema(description = "24h 최저가", example = "1500")
-    private BigDecimal lowPrice;
+    private String lowPrice;
 }
diff --git a/src/main/java/com/memesphere/domain/notification/service/PushNotificationServiceImpl.java b/src/main/java/com/memesphere/domain/notification/service/PushNotificationServiceImpl.java
@@ -144,11 +144,16 @@ private boolean isVolatilityExceeded(Notification notification) {
             return false; // 비교할 데이터가 부족하면 알림을 보내지 않음
         }
 
-        BigDecimal sum = lastNData.stream()
-                .map(ChartData::getPriceChangeRate)
-                .reduce(BigDecimal.ZERO, BigDecimal::add);
-        BigDecimal average = sum.divide(BigDecimal.valueOf(count), 4, RoundingMode.HALF_UP);
-        BigDecimal definedVolatility = new BigDecimal(notification.getVolatility());
+//        BigDecimal sum = lastNData.stream()
+//                .map(ChartData::getPriceChangeRate)
+//                .reduce(BigDecimal.ZERO, BigDecimal::add);
+//        BigDecimal average = sum.divide(BigDecimal.valueOf(count), 4, RoundingMode.HALF_UP);
+//        BigDecimal definedVolatility = new BigDecimal(notification.getVolatility());
+        Double sum = lastNData.stream()
+                .mapToDouble(ChartData::getPriceChangeRate)
+                .sum();
+        Double average = sum / count;
+        Double definedVolatility = notification.getVolatility().doubleValue();
 
         if (notification.getIsRising()) { // 상승인 경우
             return average.compareTo(definedVolatility) > 0;
diff --git a/src/main/java/com/memesphere/domain/search/converter/SearchConverter.java b/src/main/java/com/memesphere/domain/search/converter/SearchConverter.java
diff --git a/src/main/java/com/memesphere/domain/search/dto/response/SearchGridPreviewResponse.java b/src/main/java/com/memesphere/domain/search/dto/response/SearchGridPreviewResponse.java
diff --git a/src/main/java/com/memesphere/domain/search/dto/response/SearchListPreviewResponse.java b/src/main/java/com/memesphere/domain/search/dto/response/SearchListPreviewResponse.java
