Merge branch 'main' of https://github.com/TeamMemeSphere/Backend-MemeSphere into develop

Author: nimuy99

src/main/java/com/memesphere/MemesphereApplication.java

@@ -3,9 +3,11 @@
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.data.jpa.repository.config.EnableJpaAuditing;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 @SpringBootApplication
 @EnableJpaAuditing
+@EnableScheduling
 public class MemesphereApplication {
 
 	public static void main(String[] args) {

src/main/java/com/memesphere/binance/dto/response/BinanceTickerResponse.java

@@ -0,0 +1,15 @@
+package com.memesphere.binance.dto.response;
+
+import lombok.Data;
+
+@Data
+public class BinanceTickerResponse {
+    private String symbol;
+    private String priceChange;
+    private String priceChangePercent;
+    private String weightedAvgPrice;
+    private String lastPrice;
+    private String highPrice;
+    private String lowPrice;
+    private String volume;
+}

src/main/java/com/memesphere/binance/service/BinanceQueryService.java

@@ -0,0 +1,7 @@
+package com.memesphere.binance.service;
+
+import com.memesphere.binance.dto.response.BinanceTickerResponse;
+
+public interface BinanceQueryService {
+    BinanceTickerResponse getTickerData(String symbol);
+}

src/main/java/com/memesphere/binance/service/BinanceQueryServiceImpl.java

@@ -0,0 +1,22 @@
+package com.memesphere.binance.service;
+
+import com.memesphere.binance.dto.response.BinanceTickerResponse;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.web.client.RestTemplate;
+
+@Service
+@RequiredArgsConstructor
+public class BinanceQueryServiceImpl implements BinanceQueryService {
+    private final RestTemplate restTemplate;
+
+    private static final String BINANCE_API_URL = "https://api.binance.com/api/v3/ticker/24hr?symbol=";
+
+    @Override
+    @Transactional
+    public BinanceTickerResponse getTickerData(String symbol) {
+        String url = BINANCE_API_URL + symbol;
+        return restTemplate.getForObject(url, BinanceTickerResponse.class);
+    }
+}

src/main/java/com/memesphere/dashboard/service/DashboardQueryService.java

@@ -0,0 +1,25 @@
+package com.memesphere.domain.chartdata.converter;
+
+import com.memesphere.binance.dto.response.BinanceTickerResponse;
+import com.memesphere.domain.chartdata.entity.ChartData;
+import com.memesphere.domain.memecoin.entity.MemeCoin;
+
+import java.math.BigDecimal;
+import java.time.LocalDateTime;
+
+public class ChartDataConverter {
+
+    public static ChartData toChartData(MemeCoin memeCoin, BinanceTickerResponse response) {
+        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()))
+                .volume(new BigDecimal(response.getVolume()))
+                .low_price(new BigDecimal(response.getLowPrice()))
+                .high_price(new BigDecimal(response.getHighPrice()))
+                .build();
+    }
+}

src/main/java/com/memesphere/dashboard/service/DashboardQueryServiceImpl.java

@@ -1,7 +1,7 @@
-package com.memesphere.chartdata.domain;
+package com.memesphere.domain.chartdata.entity;
 
-import com.memesphere.global.domain.BaseEntity;
-import com.memesphere.memecoin.domain.MemeCoin;
+import com.memesphere.global.common.BaseEntity;
+import com.memesphere.domain.memecoin.entity.MemeCoin;
 import jakarta.persistence.*;
 import lombok.*;
 import org.hibernate.annotations.DynamicInsert;
@@ -24,7 +24,7 @@ public class ChartData extends BaseEntity {
     private Long id;
 
     @Column
-    private LocalDateTime recorded_time;
+    private LocalDateTime recordedTime;
 
     @Column
     private BigDecimal price;
@@ -35,22 +35,26 @@ public class ChartData extends BaseEntity {
     @Column
     private BigDecimal priceChangeRate;
 
-//    @Column
-//    private BigDecimal marketCap;
-
     @Column
     private BigDecimal weighted_average_price;
 
     @Column
-    private Integer volume;
+    private BigDecimal volume;
 
     @Column
     private BigDecimal low_price;
 
     @Column
     private BigDecimal high_price;
 
-    @OneToOne(fetch = FetchType.LAZY)
+    @ManyToOne(fetch = FetchType.LAZY)
     @JoinColumn(name = "coin_id", nullable = false) // 외래 키
     private MemeCoin memeCoin;
+
+    public void setMemeCoin(MemeCoin memeCoin) {
+        this.memeCoin = memeCoin;
+        if (!memeCoin.getChartDataList().contains(this)) {
+            memeCoin.getChartDataList().add(this);
+        }
+    }
 }

src/main/java/com/memesphere/domain/chartdata/converter/ChartDataConverter.java

@@ -1,6 +1,7 @@
-package com.memesphere.chartdata.repository;
+package com.memesphere.domain.chartdata.repository;
 
-import com.memesphere.chartdata.domain.ChartData;
+import com.memesphere.domain.chartdata.entity.ChartData;
+import com.memesphere.domain.memecoin.entity.MemeCoin;
 import org.springframework.data.jpa.repository.EntityGraph;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.data.jpa.repository.Query;
@@ -13,4 +14,6 @@ public interface ChartDataRepository extends JpaRepository<ChartData, Long> {
 
     @EntityGraph(attributePaths = {"memeCoin"})
     List<ChartData> findTop5ByOrderByVolumeDesc();
+
+    List<ChartData> findByMemeCoinOrderByRecordedTimeDesc(MemeCoin memeCoin);
 }

…mesphere/chartdata/domain/ChartData.java …e/domain/chartdata/entity/ChartData.javasrc/main/java/com/memesphere/chartdata/domain/ChartData.java renamed to src/main/java/com/memesphere/domain/chartdata/entity/ChartData.java src/main/java/com/memesphere/chartdata/domain/ChartData.java renamed to src/main/java/com/memesphere/domain/chartdata/entity/ChartData.java

@@ -0,0 +1,48 @@
+package com.memesphere.domain.chartdata.scheduler;
+
+import com.memesphere.binance.dto.response.BinanceTickerResponse;
+import com.memesphere.binance.service.BinanceQueryService;
+import com.memesphere.domain.chartdata.entity.ChartData;
+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.memecoin.repository.MemeCoinRepository;
+import com.memesphere.domain.memecoin.service.MemeCoinQueryService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+
+import static com.memesphere.domain.chartdata.converter.ChartDataConverter.toChartData;
+
+@Component
+@RequiredArgsConstructor
+public class ChartDataScheduler {
+    private final MemeCoinRepository memeCoinRepository;
+    private final BinanceQueryService binanceQueryService;
+    private final MemeCoinQueryService memeCoinQueryService;
+
+    @Scheduled(fixedRate = 600000) // 10분 간격 실행
+    @Transactional
+    public void updateChartData() {
+        List<MemeCoin> memeCoins = memeCoinRepository.findAll();
+
+        for (MemeCoin memeCoin : memeCoins) {
+            try {
+                String symbol = memeCoin.getSymbol() + "USDT";
+                BinanceTickerResponse response = binanceQueryService.getTickerData(symbol);
+
+                ChartData chartData = toChartData(memeCoin,response);
+
+                memeCoinQueryService.updateChartData(memeCoin.getId(), chartData);
+
+            } catch (Exception e) {
+                throw new GeneralException(ErrorStatus.CANNOT_LOAD_CHARTDATA);
+            }
+        }
+    }
+}
+
+