feat(broker): KIS 모의주문 연동 1차

build.gradle

@@ -27,11 +27,13 @@ dependencies {
     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.springframework.boot:spring-boot-starter-webflux'
     compileOnly 'org.projectlombok:lombok'
     developmentOnly 'org.springframework.boot:spring-boot-devtools'
     annotationProcessor 'org.projectlombok:lombok'
     testImplementation 'org.springframework.boot:spring-boot-starter-test'
     testRuntimeOnly 'org.junit.platform:junit-platform-launcher'
+    runtimeOnly 'com.h2database:h2'
 }
 
 tasks.named('test') {

src/main/java/trademill/apiserver/TrademillApiApplication.java

@@ -2,7 +2,11 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import trademill.apiserver.config.KisProperties;
 
+
+@EnableConfigurationProperties(KisProperties.class)
 @SpringBootApplication
 public class TrademillApiApplication {
 

src/main/java/trademill/apiserver/broker/BrokerGateway.java

@@ -0,0 +1,12 @@
+package trademill.apiserver.broker;
+
+import java.math.BigDecimal;
+
+
+// BrokerGateway : '증권사와 어떻게 대화할지' 계약서(포트) 역할
+public interface BrokerGateway {
+    String placeMarketBuy(String symbol, BigDecimal quantity);
+    String placeMarketSell(String symbol, BigDecimal quantity);
+    String placeLimitBuy(String symbol, BigDecimal quantity, BigDecimal price);
+    String placeLimitSell(String symbol, BigDecimal quantity, BigDecimal price);
+}

src/main/java/trademill/apiserver/broker/FakeBrokerGateway.java

@@ -0,0 +1,20 @@
+package trademill.apiserver.broker;
+
+import org.springframework.context.annotation.Profile;
+import org.springframework.stereotype.Component;
+
+import java.math.BigDecimal;
+import java.util.UUID;
+
+@Profile({"local","default"})
+@Component
+
+// FakeBrokerGateway : 실제 증권사 호출 대신 로컬 개발/테스트용으로 응답을 꾸며주는 구현체(어댑터)
+public class FakeBrokerGateway implements BrokerGateway {
+    private String id(){ return "SIM-" + UUID.randomUUID(); }
+
+    public String placeMarketBuy(String s, BigDecimal q){ return id(); }
+    public String placeMarketSell(String s, BigDecimal q){ return id(); }
+    public String placeLimitBuy(String s, BigDecimal q, BigDecimal p){ return id(); }
+    public String placeLimitSell(String s, BigDecimal q, BigDecimal p){ return id(); }
+}

src/main/java/trademill/apiserver/broker/kis/KisBrokerGateway.java

@@ -0,0 +1,136 @@
+package trademill.apiserver.broker.kis;
+
+import lombok.RequiredArgsConstructor;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.context.annotation.Profile;
+import org.springframework.http.MediaType;
+import org.springframework.stereotype.Component;
+import org.springframework.web.reactive.function.client.WebClient;
+import trademill.apiserver.broker.BrokerGateway;
+import trademill.apiserver.config.KisProperties;
+import trademill.apiserver.order.OrderSide;
+import trademill.apiserver.broker.kis.dto.KisResponse;
+import trademill.apiserver.broker.kis.dto.OrderCashOutput;
+
+import java.math.BigDecimal;
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+@Component
+@Profile("kis")
+@RequiredArgsConstructor
+public class KisBrokerGateway implements BrokerGateway {
+
+    private static final Logger log = LoggerFactory.getLogger(KisBrokerGateway.class);
+
+    private final WebClient kisWebClient;
+    private final KisTokenService tokenService;
+    private final KisProperties props;
+
+    @Override
+    public String placeMarketBuy(String symbol, BigDecimal quantity) {
+        return place(OrderSide.BUY, "MARKET", symbol, quantity, null);
+    }
+
+    @Override
+    public String placeLimitBuy(String symbol, BigDecimal quantity, BigDecimal price) {
+        return place(OrderSide.BUY, "LIMIT", symbol, quantity, price);
+    }
+
+    @Override
+    public String placeMarketSell(String symbol, BigDecimal quantity) {
+        return place(OrderSide.SELL, "MARKET", symbol, quantity, null);
+    }
+
+    @Override
+    public String placeLimitSell(String symbol, BigDecimal quantity, BigDecimal price) {
+        return place(OrderSide.SELL, "LIMIT", symbol, quantity, price);
+    }
+
+    private String place(OrderSide side, String orderType, String symbol, BigDecimal qty, BigDecimal price) {
+        log.info("[KIS:{} {}] symbol={}, qty={}, price={}", side, orderType, symbol, qty, price);
+
+        // 0) 토큰
+        String token = tokenService.getAccessToken();
+
+        // 1) KIS 주문 바디 구성
+        //    ORD_DVSN: 00=지정가, 01=시장가
+        final String ordDvsn = "LIMIT".equals(orderType) ? "00" : "01";
+        final String ordUnpr = "MARKET".equals(orderType) ? "0" : price.toPlainString();
+
+        Map<String, Object> body = new LinkedHashMap<>();
+        body.put("CANO", props.getCano());               // 계좌번호(앞 8자리)
+        body.put("ACNT_PRDT_CD", props.getAcntPrdtCd()); // 상품코드(보통 01)
+        body.put("PDNO", symbol);                        // 종목코드
+        body.put("ORD_DVSN", ordDvsn);
+        body.put("ORD_QTY", qty.toPlainString());
+        body.put("ORD_UNPR", ordUnpr);
+
+        // 2) 해시키 요청
+        String hashKey = requestHashKey(token, body);
+
+        // 3) 주문 요청
+        String trId = mapTrId(side, props.isVirtual()); // KIS는 현금주문 TR이 매수/매도로 구분됨
+        KisResponse<OrderCashOutput> resp = kisWebClient.post()
+                .uri("/uapi/domestic-stock/v1/trading/order-cash")
+                .contentType(MediaType.APPLICATION_JSON)
+                .headers(h -> {
+                    h.add("authorization", "Bearer " + token);
+                    h.add("appkey", props.getAppKey());
+                    h.add("appsecret", props.getAppSecret());
+                    h.add("tr_id", trId);
+                    h.add("custtype", "P"); // 개인
+                    h.add("hashkey", hashKey);
+                })
+                .bodyValue(body)
+                .retrieve()
+                .bodyToMono(ParameterizedTypes.orderCashResponse())
+                .block();
+
+        if (resp == null) throw new IllegalStateException("KIS response is null");
+        if (!"0".equals(resp.getRt_cd())) {
+            throw new IllegalStateException("KIS error: " + resp.getMsg_cd() + " - " + resp.getMsg1());
+        }
+
+        String ordNo = resp.getOutput() != null ? resp.getOutput().getORD_NO() : null;
+        log.info("[KIS] rt_cd=0, ORD_NO={}", ordNo);
+        return ordNo != null ? ordNo : "KIS-NO-ORDER-NO";
+    }
+
+    private String requestHashKey(String token, Map<String, Object> body) {
+        Map<String, Object> resp = kisWebClient.post()
+                .uri("/uapi/hashkey")
+                .contentType(MediaType.APPLICATION_JSON)
+                .headers(h -> {
+                    h.add("authorization", "Bearer " + token);
+                    h.add("appkey", props.getAppKey());
+                    h.add("appsecret", props.getAppSecret());
+                })
+                .bodyValue(body)
+                .retrieve()
+                .bodyToMono(Map.class)
+                .block();
+
+        Object hk = resp != null ? resp.get("HASH") : null;
+        if (hk == null) throw new IllegalStateException("Failed to get hashkey from KIS");
+        return hk.toString();
+    }
+
+    /** KIS 현금주문 TR 매핑 (모의/실전, 매수/매도) */
+    private String mapTrId(OrderSide side, boolean virtual) {
+        boolean buy = side == OrderSide.BUY;
+        if (virtual) {
+            return buy ? "VTTC0802U" : "VTTC0801U"; // 모의: 매수/매도
+        } else {
+            return buy ? "TTTC0802U" : "TTTC0801U"; // 실전: 매수/매도
+        }
+    }
+
+    /** WebClient 제네릭 응답 타입 헬퍼 */
+    static class ParameterizedTypes {
+        static org.springframework.core.ParameterizedTypeReference<KisResponse<OrderCashOutput>> orderCashResponse() {
+            return new org.springframework.core.ParameterizedTypeReference<>() {};
+        }
+    }
+}

src/main/java/trademill/apiserver/broker/kis/KisTokenService.java

@@ -0,0 +1,50 @@
+package trademill.apiserver.broker.kis;
+
+import lombok.RequiredArgsConstructor;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.context.annotation.Profile;
+import org.springframework.http.MediaType;
+import org.springframework.stereotype.Service;
+import org.springframework.web.reactive.function.client.WebClient;
+import trademill.apiserver.config.KisProperties;
+
+import java.time.Instant;
+import java.util.Map;
+
+@Service
+@Profile("kis")
+@RequiredArgsConstructor
+public class KisTokenService {
+    private static final Logger log = LoggerFactory.getLogger(KisTokenService.class);
+
+    private final WebClient kisWebClient;
+    private final KisProperties props;
+
+    private volatile String cachedToken;
+    private volatile Instant expiresAt = Instant.EPOCH;
+
+    public String getAccessToken() {
+        if (cachedToken != null && Instant.now().isBefore(expiresAt.minusSeconds(30))) {
+            return cachedToken;
+        }
+        Map<String, Object> resp = kisWebClient.post()
+                .uri("/oauth2/tokenP")
+                .contentType(MediaType.APPLICATION_JSON)
+                .bodyValue(Map.of(
+                        "grant_type", "client_credentials",
+                        "appkey", props.getAppKey(),
+                        "appsecret", props.getAppSecret()
+                ))
+                .retrieve()
+                .bodyToMono(Map.class)
+                .block();
+
+        String token = (String) resp.get("access_token");
+        Number exp = (Number) resp.getOrDefault("expires_in", 0);
+        this.cachedToken = token;
+        this.expiresAt = Instant.now().plusSeconds(exp.longValue());
+        log.info("[KIS] access_token issued, expires_in={}s", exp);
+        return token;
+    }
+}

src/main/java/trademill/apiserver/broker/kis/dto/KisResponse.java

@@ -0,0 +1,11 @@
+package trademill.apiserver.broker.kis.dto;
+
+import lombok.Data;
+
+@Data
+public class KisResponse<T> {
+    private String rt_cd;   // "0" 성공, "1" 실패
+    private String msg_cd;
+    private String msg1;
+    private T output;
+}

src/main/java/trademill/apiserver/broker/kis/dto/OrderCashOutput.java

@@ -0,0 +1,9 @@
+package trademill.apiserver.broker.kis.dto;
+
+import lombok.Data;
+
+@Data
+public class OrderCashOutput {
+    // KIS 주문응답의 주문번호 필드 (문서 기준)
+    private String ORD_NO;
+}

src/main/java/trademill/apiserver/config/KisConfig.java

@@ -0,0 +1,27 @@
+package trademill.apiserver.config;
+
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Profile;
+import org.springframework.http.MediaType;
+import org.springframework.web.reactive.function.client.ExchangeStrategies;
+import org.springframework.web.reactive.function.client.WebClient;
+
+@Configuration
+@EnableConfigurationProperties(KisProperties.class)
+@Profile("kis")
+public class KisConfig {
+
+    @Bean
+    public WebClient kisWebClient(KisProperties props) {
+        return WebClient.builder()
+                .baseUrl(props.getBaseUrl())
+                .defaultHeader("Content-Type", MediaType.APPLICATION_JSON_VALUE + "; charset=UTF-8")
+                .defaultHeader("Accept", MediaType.APPLICATION_JSON_VALUE)
+                .exchangeStrategies(ExchangeStrategies.builder()
+                        .codecs(c -> c.defaultCodecs().maxInMemorySize(4 * 1024 * 1024))
+                        .build())
+                .build();
+    }
+}

src/main/java/trademill/apiserver/config/KisProperties.java

@@ -0,0 +1,31 @@
+package trademill.apiserver.config;
+
+import lombok.Getter;
+import lombok.Setter;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+
+@Getter @Setter
+@ConfigurationProperties(prefix = "kis")
+public class KisProperties {
+    private String baseUrl;
+    private String appKey;
+    private String appSecret;
+    private String accountNo; // 예: 50151652-01
+
+    public String getCano() {
+        if (accountNo == null) return null;
+        int idx = accountNo.indexOf('-');
+        return idx > 0 ? accountNo.substring(0, idx) : accountNo;
+    }
+
+    public String getAcntPrdtCd() {
+        if (accountNo == null) return null;
+        int idx = accountNo.indexOf('-');
+        return idx > 0 ? accountNo.substring(idx + 1) : "01";
+    }
+
+    public boolean isVirtual() {
+        // 모의투자 여부 (base-url 에 vts 포함 시 true)
+        return baseUrl != null && baseUrl.contains("openapivts");
+    }
+}

src/main/java/trademill/apiserver/demo/domain/Demo.java

@@ -18,7 +18,7 @@ public class Demo {
 	@GeneratedValue(strategy = GenerationType.IDENTITY)
 	private Long id;
 
-	@Column(nullable = false)
+    @Column(name = "val")
 	private String value;
 
 }

src/main/java/trademill/apiserver/order/Order.java

@@ -0,0 +1,42 @@
+package trademill.apiserver.order;
+
+import jakarta.persistence.*;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+
+import java.math.BigDecimal;
+import java.time.OffsetDateTime;
+
+@Entity
+@Table(name = "orders")
+@Getter @Setter @NoArgsConstructor
+public class Order {
+
+    @Id @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    private Long userId;
+    private String symbol;
+
+    @Enumerated(EnumType.STRING) private OrderSide side;
+    @Enumerated(EnumType.STRING) private OrderType orderType;
+
+    private BigDecimal quantity;
+    private BigDecimal price; // MARKET이면 null 가능
+
+    @Enumerated(EnumType.STRING) private OrderStatus status;
+    private String brokerOrderId;
+
+    private OffsetDateTime createdAt;
+    private OffsetDateTime updatedAt;
+
+    @PrePersist
+    void onCreate() {
+        createdAt = OffsetDateTime.now();
+        updatedAt = createdAt;
+        if (status == null) status = OrderStatus.PENDING;
+    }
+    @PreUpdate
+    void onUpdate() { updatedAt = OffsetDateTime.now(); }
+}