Merge pull request #36 from CleanEngine/dev

Dev

Author: bongj9

.gitignore

@@ -35,3 +35,6 @@ out/
 
 ### VS Code ###
 .vscode/
+
+### 로컬 환경변수 ###
+local.properties

build.gradle

@@ -24,14 +24,37 @@ repositories {
 }
 
 dependencies {
+
+  implementation 'org.springframework.boot:spring-boot-starter-websocket' // WS + STOMP
+
 	implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
+	implementation 'org.springframework.boot:spring-boot-starter-validation'
 	implementation 'org.springframework.boot:spring-boot-starter-web'
+
+	implementation 'org.springdoc:springdoc-openapi-starter-webmvc-ui:2.8.8'
+	implementation 'org.springframework.boot:spring-boot-starter-actuator'
+
+
+	implementation 'com.squareup.okhttp3:okhttp:4.12.0'
+	implementation 'com.google.code.gson:gson:2.13.1'
 	compileOnly 'org.projectlombok:lombok'
+	annotationProcessor 'org.projectlombok:lombok'
+
 	runtimeOnly 'com.h2database:h2'
+	implementation("org.mariadb.jdbc:mariadb-java-client:3.3.3")  // ← 드라이버
 	runtimeOnly 'org.mariadb.jdbc:mariadb-java-client'
-	annotationProcessor 'org.projectlombok:lombok'
+
 	testImplementation 'org.springframework.boot:spring-boot-starter-test'
 	testRuntimeOnly 'org.junit.platform:junit-platform-launcher'
+
+	// Spring Security + OAuth2
+	implementation 'org.springframework.boot:spring-boot-starter-security'
+	implementation 'org.springframework.boot:spring-boot-starter-oauth2-client'
+
+	// jwt
+	implementation 'io.jsonwebtoken:jjwt-api:0.12.3'
+	runtimeOnly 'io.jsonwebtoken:jjwt-impl:0.12.3'
+	runtimeOnly 'io.jsonwebtoken:jjwt-jackson:0.12.3'
 }
 
 tasks.named('test') {

src/main/java/com/cleanengine/coin/CoinApplication.java

@@ -2,7 +2,10 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
+
+@EnableScheduling
 @SpringBootApplication
 public class CoinApplication {
 

src/main/java/com/cleanengine/coin/chart/config/WebSocketConfig.java

@@ -0,0 +1,37 @@
+package com.cleanengine.coin.chart.config;
+
+
+import org.springframework.context.annotation.Configuration;
+import org.springframework.messaging.simp.config.MessageBrokerRegistry;
+import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
+import org.springframework.web.socket.config.annotation.StompEndpointRegistry;
+import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer;
+
+@Configuration
+@EnableWebSocketMessageBroker
+public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
+
+    @Override
+    public void configureMessageBroker(MessageBrokerRegistry config) {
+        config.enableSimpleBroker("/topic"); //메세지 브로커로 라우팅 되어야한다
+        config.setApplicationDestinationPrefixes("/app"); //app으로 시작되는 메세지가 message-handling 라우팅 되어야한다
+    }
+
+    @Override
+    public void registerStompEndpoints(StompEndpointRegistry registry) {
+        registry
+                .addEndpoint("/coin/min") //endPoint 지정
+                //추후 cors url추가
+    .setAllowedOrigins("http://localhost:63342", "http://localhost:8080", "http://localhost:5500", "http://localhost:5173");
+        registry
+                .addEndpoint("/coin/realtime")
+                .setAllowedOrigins("http://localhost:63342", "http://localhost:8080", "http://localhost:5500", "http://localhost:5173");
+        registry
+                .addEndpoint("/coin/orderbook")
+                .setAllowedOrigins("http://localhost:63342", "http://localhost:8080", "http://localhost:5500", "http://localhost:5173");
+    }
+
+
+}
+
+

src/main/java/com/cleanengine/coin/chart/controller/ChartDataController.java

@@ -0,0 +1,74 @@
+package com.cleanengine.coin.chart.controller;
+
+
+import com.cleanengine.coin.chart.dto.RealTimeOhlcDto;
+//import com.cleanengine.coin.chart.Dto.RealTimeTradeDto;
+import com.cleanengine.coin.chart.service.*;
+import com.cleanengine.coin.chart.service.ChartSubscriptionService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.messaging.simp.SimpMessagingTemplate;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import java.time.LocalDateTime;
+
+@Component
+@RequiredArgsConstructor
+@Slf4j
+public class ChartDataController {
+
+    private final ChartSubscriptionService subscriptionService;
+    private final SimpMessagingTemplate messagingTemplate;
+    private final RealTimeOhlcService realTimeOhlcService;
+
+    /**
+     * 1초마다 실행 - 실시간 OHLC 데이터 전송
+     */
+    @Scheduled(fixedRate = 1000)
+    public void publishRealTimeOhlc() {
+        try {
+            log.info("△ 실시간 OHLC 데이터 스케줄러 실행");
+
+            // 구독된 티커가 없으면 조기 종료
+            if (subscriptionService.getAllRealTimeOhlcSubscribedTickers().isEmpty()) {
+                log.info("실시간 OHLC 구독된 티커 없음, 전송 생략");
+                return;
+            }
+
+            // 모든 구독된 티커에 대해 데이터 전송
+            for (String ticker : subscriptionService.getAllRealTimeOhlcSubscribedTickers()) {
+                try {
+                    log.info("티커 {} 실시간 OHLC 데이터 전송 중...", ticker);
+
+                    // 티커별 최신 OHLC 데이터 조회 및 전송
+                    RealTimeOhlcDto ohlcData = realTimeOhlcService.getRealTimeOhlc(ticker);
+
+                    if (ohlcData == null) {
+                        log.warn("티커 {}의 실시간 OHLC 데이터가 없습니다. 빈 데이터 전송", ticker);
+                        RealTimeOhlcDto emptyData = new RealTimeOhlcDto();
+                        emptyData.setTicker(ticker);
+                        emptyData.setTimestamp(LocalDateTime.now());
+                        emptyData.setOpen(0.0);
+                        emptyData.setHigh(0.0);
+                        emptyData.setLow(0.0);
+                        emptyData.setClose(0.0);
+                        emptyData.setVolume(0.0);
+
+                        messagingTemplate.convertAndSend("/topic/realTimeOhlc/" + ticker, emptyData);
+                    } else {
+                        // 조회된 실시간 OHLC 데이터 전송
+                        messagingTemplate.convertAndSend("/topic/realTimeOhlc/" + ticker, ohlcData);
+                        log.info("실시간 OHLC 데이터 전송: {}", ohlcData);
+                    }
+                } catch (Exception e) {
+                    log.error("티커 {} 실시간 OHLC 데이터 처리 중 오류: {}", ticker, e.getMessage(), e);
+                }
+            }
+        } catch (Exception e) {
+            log.error("△ 실시간 OHLC 데이터 발행 중 오류: {}", e.getMessage(), e);
+        }
+    }
+
+
+}

src/main/java/com/cleanengine/coin/chart/controller/MinuteOhlcDataController.java

@@ -0,0 +1,29 @@
+package com.cleanengine.coin.chart.controller;
+
+import com.cleanengine.coin.chart.dto.RealTimeOhlcDto;
+import com.cleanengine.coin.chart.service.minute.MinuteOhlcDataService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+@RestController
+@RequestMapping("/api/minute-ohlc")
+@RequiredArgsConstructor
+public class MinuteOhlcDataController {
+
+    private final MinuteOhlcDataService service;
+
+    /**
+     * GET /api/minute-ohlc?ticker=BTC
+     * DB에 있는 과거 거래를 1분 단위로 묶어 OHLC+volume을 계산한 리스트 반환
+     */
+    @GetMapping
+    public ResponseEntity<List<RealTimeOhlcDto>> getMinuteOhlc(
+            @RequestParam("ticker") String ticker
+    ) {
+        List<RealTimeOhlcDto> data = service.getMinuteOhlcData(ticker);
+        return ResponseEntity.ok(data);
+    }
+}

src/main/java/com/cleanengine/coin/chart/controller/PrevRateController.java

@@ -0,0 +1,34 @@
+package com.cleanengine.coin.chart.controller;
+
+import com.cleanengine.coin.chart.dto.PrevRateDto;
+import com.cleanengine.coin.chart.service.RealTimeDataPrevRateService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.messaging.handler.annotation.DestinationVariable;
+import org.springframework.messaging.handler.annotation.MessageMapping;
+import org.springframework.messaging.simp.SimpMessagingTemplate;
+import org.springframework.stereotype.Controller;
+
+@Controller
+@RequiredArgsConstructor
+@Slf4j
+public class PrevRateController {
+
+    private final RealTimeDataPrevRateService prevRateService;
+    private final SimpMessagingTemplate messagingTemplate;
+
+    @MessageMapping("/subscribe/prevRate/{ticker}")
+    public void subscribePrevRate(@DestinationVariable String ticker) {
+        log.info("티커 {} 전일 대비 변동률 구독 요청", ticker);
+
+        // 서비스를 통해 전일 대비 변동률 데이터 얻기
+        PrevRateDto data = prevRateService.generatePrevRateData(ticker);
+
+        // 티커별 토픽으로 전송
+        messagingTemplate.convertAndSend(
+                "/topic/prevRate/" + ticker,
+                data
+        );
+        log.debug("전송 완료: /topic/prevRate/{} -> {}", ticker, data);
+    }
+}

src/main/java/com/cleanengine/coin/chart/controller/PrevRateScheduler.java

@@ -0,0 +1,16 @@
+package com.cleanengine.coin.chart.controller;
+
+import lombok.RequiredArgsConstructor;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+@Component
+@RequiredArgsConstructor
+public class PrevRateScheduler {
+    private final PrevRateController prevRateController;
+
+    @Scheduled(fixedDelay = 1000)
+    public void sendPrevRate(){
+        prevRateController.subscribePrevRate("TRUMP");
+    }
+}

src/main/java/com/cleanengine/coin/chart/controller/RealTimeRateScheduler.java

@@ -0,0 +1,16 @@
+package com.cleanengine.coin.chart.controller;
+
+import lombok.RequiredArgsConstructor;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+@Component
+@RequiredArgsConstructor
+public class RealTimeRateScheduler {
+    private final RealTimeTradeController realTimeTradeController;
+
+    @Scheduled(fixedDelay = 5000)
+    public void sendPrevRate(){
+        realTimeTradeController.realTimeTradeRate("TRUMP");
+    }
+}

src/main/java/com/cleanengine/coin/chart/controller/RealTimeTradeController.java

@@ -0,0 +1,38 @@
+package com.cleanengine.coin.chart.controller;
+
+import com.cleanengine.coin.chart.dto.RealTimeDataDto;
+import com.cleanengine.coin.chart.service.RealTimeTradeService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.messaging.handler.annotation.DestinationVariable;
+import org.springframework.messaging.handler.annotation.MessageMapping;
+import org.springframework.messaging.simp.SimpMessagingTemplate;
+import org.springframework.stereotype.Controller;
+
+@Controller
+@RequiredArgsConstructor
+@Slf4j
+public class RealTimeTradeController {
+
+    private final SimpMessagingTemplate messagingTemplate;
+    private final RealTimeTradeService realTimeTradeService;
+
+    /**
+     * 클라이언트가 /app/subscribe/realTimeTradeRate/{ticker} 로 send() 하면
+     * {ticker} 값을 받습니다.
+     */
+    @MessageMapping("/subscribe/realTimeTradeRate/{ticker}")
+    public void realTimeTradeRate(@DestinationVariable String ticker) {
+        log.info("티커 {} 실시간 구독 요청", ticker);
+
+        // 서비스로부터 DTO 생성
+        RealTimeDataDto data = realTimeTradeService.generateRealTimeData(ticker);
+
+        // 티커별 토픽으로 전송
+        messagingTemplate.convertAndSend(
+                "/topic/realTimeTradeRate/" + ticker,
+                data
+        );
+        log.debug("전송 완료: /topic/realTimeTradeRate/{} -> {}", ticker, data);
+    }
+}