🐛 [Bug] 최대 주문 정보 조회 API 버그 수정 - side 파라미터 추가 및 시장가(매도/매수) 수량 계산 오류 해결

rlawngjs0313 · web-flow · commit 430b46bd313c · 2026-02-09T23:23:47.000+08:00
diff --git a/src/main/java/com/example/scoi/domain/invest/client/ExchangeApiClient.java b/src/main/java/com/example/scoi/domain/invest/client/ExchangeApiClient.java
@@ -6,7 +6,7 @@
 
 //여러 거래소 어댑터들을 한 타입으로 묶기 위한 인터페이스
 public interface ExchangeApiClient {
-    MaxOrderInfoDTO getMaxOrderInfo(String phoneNumber, ExchangeType exchangeType, String coinType, String unitPrice);
+    MaxOrderInfoDTO getMaxOrderInfo(String phoneNumber, ExchangeType exchangeType, String coinType, String unitPrice, String orderType, String side);
     
     // 주문 가능 여부 확인 (주문 가능하면 정상 반환, 불가능하면 예외)
     void checkOrderAvailability(
diff --git a/src/main/java/com/example/scoi/domain/invest/client/adapter/BithumbApiClient.java b/src/main/java/com/example/scoi/domain/invest/client/adapter/BithumbApiClient.java
diff --git a/src/main/java/com/example/scoi/domain/invest/client/adapter/UpbitApiClient.java b/src/main/java/com/example/scoi/domain/invest/client/adapter/UpbitApiClient.java
@@ -35,14 +35,14 @@ public class UpbitApiClient implements ExchangeApiClient {
     private final JwtApiUtil jwtApiUtil; 
     
     @Override
-    public MaxOrderInfoDTO getMaxOrderInfo(String phoneNumber, ExchangeType exchangeType, String coinType, String unitPrice) {
+    public MaxOrderInfoDTO getMaxOrderInfo(String phoneNumber, ExchangeType exchangeType, String coinType, String unitPrice, String orderType, String side) {
         try {
             // coinType을 업비트 형식으로 정규화 (KRW-BTC 형식으로 통일)
             String normalizedCoinType = normalizeCoinType(coinType);
             
             String authorization = jwtApiUtil.createUpBitJwt(phoneNumber, null, null);
-            log.info("업비트 최대 주문 정보 조회 API 호출 시작 - phoneNumber: {}, coinType: {} (정규화: {}), unitPrice: {}",
-                    phoneNumber, coinType, normalizedCoinType, unitPrice);
+            log.info("업비트 최대 주문 정보 조회 API 호출 시작 - phoneNumber: {}, coinType: {} (정규화: {}), unitPrice: {}, orderType: {}, side: {}",
+                    phoneNumber, coinType, normalizedCoinType, unitPrice, orderType, side);
             
             // Feign Client가 자동으로 List<Account>로 변환해줌 (ObjectMapper 불필요!)
             List<UpbitResDTO.Account> accounts = upbitFeignClient.getAccounts(authorization);
@@ -54,7 +54,7 @@ public MaxOrderInfoDTO getMaxOrderInfo(String phoneNumber, ExchangeType exchange
                         account.currency(), account.balance(), account.locked(), account.available());
             }
             
-            return parseMaxOrderInfoResponse(accounts, normalizedCoinType, unitPrice);
+            return parseMaxOrderInfoResponse(accounts, normalizedCoinType, unitPrice, orderType, side);
             
         } catch (MemberException e) {
             log.error("업비트 API 키를 찾을 수 없습니다 - phoneNumber: {}", phoneNumber, e);
@@ -148,21 +148,53 @@ public MaxOrderInfoDTO getMaxOrderInfo(String phoneNumber, ExchangeType exchange
         }
     }
     
-    private MaxOrderInfoDTO parseMaxOrderInfoResponse(List<UpbitResDTO.Account> accounts, String coinType, String unitPrice) {
+    private MaxOrderInfoDTO parseMaxOrderInfoResponse(List<UpbitResDTO.Account> accounts, String coinType, String unitPrice, String orderType, String side) {
         try {
-            // coinType이 KRW-BTC 형식이면, 매수 시 KRW 잔액을 조회해야 함
             String currency;
-            if (coinType.contains("-")) {
-                String[] parts = coinType.split("-");
-                // KRW-BTC 형식이면 KRW 잔액 조회 (매수 가능 금액)
-                currency = parts[0]; // KRW
+            String targetCurrency; // 조회할 화폐 (KRW 또는 코인)
+            
+            // 시장가 주문인 경우
+            boolean isMarketOrder = "price".equals(orderType) || "market".equals(orderType);
+            
+            if (isMarketOrder) {
+                // side 파라미터를 기준으로 매수/매도 판단
+                if ("bid".equals(side)) {
+                    // 매수: KRW 잔액 조회
+                    targetCurrency = "KRW";
+                    currency = "KRW";
+                    log.info("업비트 시장가 매수 - {}를 매수하기 위해 KRW 잔액 조회", coinType);
+                } else if ("ask".equals(side)) {
+                    // 매도: 코인 잔액 조회
+                    if (coinType.contains("-")) {
+                        String[] parts = coinType.split("-");
+                        targetCurrency = parts[1]; // KRW-BTC -> BTC
+                        currency = parts[1];
+                    } else {
+                        targetCurrency = coinType;
+                        currency = coinType;
+                    }
+                    log.info("업비트 시장가 매도 - {} 잔액 조회", targetCurrency);
+                } else {
+                    // side가 없거나 잘못된 경우 기본값 (매수)
+                    targetCurrency = "KRW";
+                    currency = "KRW";
+                    log.warn("업비트 시장가 주문 - side 파라미터가 없거나 잘못됨 ({}), 기본값으로 매수 처리", side);
+                }
             } else {
-                currency = coinType; // BTC 등 단일 코인
+                // 지정가 주문
+                if (coinType.contains("-")) {
+                    String[] parts = coinType.split("-");
+                    currency = parts[0]; // KRW
+                    targetCurrency = parts[0];
+                } else {
+                    currency = coinType;
+                    targetCurrency = coinType;
+                }
             }
             
             String balance = "0";
             
-            // 먼저 해당 currency로 계좌 찾기
+            // 해당 currency로 계좌 찾기
             for (UpbitResDTO.Account account : accounts) {
                 if (currency.equals(account.currency())) {
                     // available이 있으면 available 사용 (매수 가능 금액)
@@ -189,28 +221,76 @@ private MaxOrderInfoDTO parseMaxOrderInfoResponse(List<UpbitResDTO.Account> acco
                 }
             }
             
-            // unitPrice가 있으면 최대 주문 수량 계산 (balance / unitPrice)
-            // 소수점 절사하여 정수로 반환 (0.8개 → 0개, 1.2개 → 1개)
             String maxQuantity = null;
-            if (unitPrice != null && !unitPrice.isEmpty()) {
-                try {
-                    BigDecimal balanceDecimal = new BigDecimal(balance);
-                    BigDecimal unitPriceDecimal = new BigDecimal(unitPrice);
-                    
-                    if (unitPriceDecimal.compareTo(BigDecimal.ZERO) > 0) {
-                        BigDecimal quantity = balanceDecimal.divide(unitPriceDecimal, 8, RoundingMode.DOWN);
-                        // 소수점 절사하여 정수로 변환
-                        maxQuantity = quantity.setScale(0, RoundingMode.DOWN).toPlainString();
-                        log.info("업비트 최대 주문 수량 계산 - balance: {}, unitPrice: {}, maxQuantity: {} (정수)", balance, unitPrice, maxQuantity);
-                    } else {
-                        log.warn("단위 가격이 0 이하입니다. 최대 주문 수량을 계산할 수 없습니다.");
+            
+            // 시장가 주문 처리
+            if (isMarketOrder) {
+                if ("bid".equals(side)) {
+                    // 시장가 매수: 현재가 조회하여 대략적인 수량 계산
+                    try {
+                        List<UpbitResDTO.Ticker> tickers = upbitFeignClient.getTicker(coinType);
+                        
+                        if (tickers != null && !tickers.isEmpty()) {
+                            UpbitResDTO.Ticker ticker = tickers.get(0);
+                            if (ticker.trade_price() != null && ticker.trade_price() > 0) {
+                                BigDecimal balanceDecimal = new BigDecimal(balance);
+                                BigDecimal currentPrice = BigDecimal.valueOf(ticker.trade_price());
+                                BigDecimal quantity = balanceDecimal.divide(currentPrice, 8, RoundingMode.DOWN);
+                                // 소수점 절사하여 정수로 변환
+                                maxQuantity = quantity.setScale(0, RoundingMode.DOWN).toPlainString();
+                                log.info("업비트 시장가 매수 - KRW 잔액: {}, 현재가: {}, 최대 매수 가능 수량: {} (정수)", 
+                                        balance, currentPrice, maxQuantity);
+                            } else {
+                                log.warn("업비트 현재가 조회 실패 또는 가격이 0 이하 - market: {}", coinType);
+                                maxQuantity = null;
+                            }
+                        } else {
+                            log.warn("업비트 현재가 조회 실패 - 응답이 비어있음: {}", coinType);
+                            maxQuantity = null;
+                        }
+                    } catch (Exception e) {
+                        log.warn("업비트 현재가 조회 실패 - 시장가 매수 수량 계산 불가: {}", e.getMessage());
+                        maxQuantity = null;
+                    }
+                } else if ("ask".equals(side)) {
+                    // 시장가 매도: 코인 잔액을 maxQuantity로 반환 (최대 매도 가능 수량)
+                    // 소수점 절사하여 정수로 변환
+                    try {
+                        BigDecimal balanceDecimal = new BigDecimal(balance);
+                        maxQuantity = balanceDecimal.setScale(0, RoundingMode.DOWN).toPlainString();
+                        log.info("업비트 시장가 매도 - 코인 잔액: {}, 최대 매도 가능 수량: {} (정수)", balance, maxQuantity);
+                    } catch (NumberFormatException e) {
+                        log.warn("업비트 시장가 매도 - 잔액 파싱 실패, 원본 값 사용: {}", balance);
+                        maxQuantity = balance;
+                    }
+                } else {
+                    log.warn("업비트 시장가 주문 - side 파라미터가 없거나 잘못됨 ({}), maxQuantity: null", side);
+                    maxQuantity = null;
+                }
+            } else {
+                // 지정가 주문
+                if (unitPrice != null && !unitPrice.isEmpty()) {
+                    try {
+                        BigDecimal balanceDecimal = new BigDecimal(balance);
+                        BigDecimal unitPriceDecimal = new BigDecimal(unitPrice);
+                        
+                        if (unitPriceDecimal.compareTo(BigDecimal.ZERO) > 0) {
+                            BigDecimal quantity = balanceDecimal.divide(unitPriceDecimal, 8, RoundingMode.DOWN);
+                            // 소수점 절사하여 정수로 변환
+                            maxQuantity = quantity.setScale(0, RoundingMode.DOWN).toPlainString();
+                            log.info("업비트 최대 주문 수량 계산 - balance: {}, unitPrice: {}, maxQuantity: {} (정수)", 
+                                    balance, unitPrice, maxQuantity);
+                        } else {
+                            log.warn("단위 가격이 0 이하입니다. 최대 주문 수량을 계산할 수 없습니다.");
+                        }
+                    } catch (NumberFormatException e) {
+                        log.warn("단위 가격 형식이 올바르지 않습니다. 최대 주문 수량을 계산할 수 없습니다. unitPrice: {}", unitPrice);
                     }
-                } catch (NumberFormatException e) {
-                    log.warn("단위 가격 형식이 올바르지 않습니다. 최대 주문 수량을 계산할 수 없습니다. unitPrice: {}", unitPrice);
                 }
             }
             
-            log.info("업비트 최대 주문 정보 조회 완료 - coinType: {}, balance: {}, maxQuantity: {}", coinType, balance, maxQuantity);
+            log.info("업비트 최대 주문 정보 조회 완료 - coinType: {}, balance: {}, maxQuantity: {}, orderType: {}", 
+                    coinType, balance, maxQuantity, orderType);
             
             return new MaxOrderInfoDTO(balance, maxQuantity);
                     
diff --git a/src/main/java/com/example/scoi/domain/invest/client/feign/BithumbFeignClient.java b/src/main/java/com/example/scoi/domain/invest/client/feign/BithumbFeignClient.java
@@ -46,4 +46,9 @@ BithumbResDTO.CancelOrder cancelOrder(
     //마켓 코드 조회 (PUBLIC API - 인증 불필요)
     @GetMapping("/v1/market/all")
     String getMarketAll(@RequestParam(value = "isDetails", required = false) Boolean isDetails);
+
+    //현재가 조회 (PUBLIC API - 인증 불필요)
+    // 빗썸 API는 배열을 반환하거나 다른 형식을 사용할 수 있으므로 String으로 받아서 파싱
+    @GetMapping("/v1/ticker")
+    String getTicker(@RequestParam("markets") String markets);
 }
diff --git a/src/main/java/com/example/scoi/domain/invest/client/feign/UpbitFeignClient.java b/src/main/java/com/example/scoi/domain/invest/client/feign/UpbitFeignClient.java
@@ -50,4 +50,8 @@ UpbitResDTO.CancelOrder cancelOrder(
             @RequestHeader("Authorization") String authorization,
             @RequestParam("uuid") String uuid
     );
+
+    //현재가 조회 (PUBLIC API - 인증 불필요)
+    @GetMapping("/v1/ticker")
+    List<UpbitResDTO.Ticker> getTicker(@RequestParam("markets") String markets);
 }
diff --git a/src/main/java/com/example/scoi/domain/invest/controller/InvestController.java b/src/main/java/com/example/scoi/domain/invest/controller/InvestController.java
@@ -34,10 +34,12 @@ public ApiResponse<MaxOrderInfoDTO> getMaxOrderInfo(
             @RequestParam ExchangeType exchangeType,
             @RequestParam String coinType,
             @RequestParam(required = false) String unitPrice,  // 단위 가격 (선택적)
+            @RequestParam(required = false) String orderType,    // 주문 타입 (limit, price, market)
+            @RequestParam(required = false) String side,        // 주문 방향 (bid, ask)
             @AuthenticationPrincipal CustomUserDetails user
     ) {
         // JWT에서 추출한 phoneNumber로 조회
-        MaxOrderInfoDTO result = investService.getMaxOrderInfo(user.getUsername(), exchangeType, coinType, unitPrice);
+        MaxOrderInfoDTO result = investService.getMaxOrderInfo(user.getUsername(), exchangeType, coinType, unitPrice, orderType, side);
         
         return ApiResponse.onSuccess(InvestSuccessCode.MAX_ORDER_INFO_SUCCESS, result);
     }
diff --git a/src/main/java/com/example/scoi/domain/invest/controller/InvestControllerDocs.java b/src/main/java/com/example/scoi/domain/invest/controller/InvestControllerDocs.java
@@ -23,6 +23,8 @@ ApiResponse<MaxOrderInfoDTO> getMaxOrderInfo(
             @RequestParam ExchangeType exchangeType,
             @RequestParam String coinType,
             @RequestParam(required = false) String unitPrice,
+            @RequestParam(required = false) String orderType,
+            @RequestParam(required = false) String side,
             @AuthenticationPrincipal CustomUserDetails user
     );
 
diff --git a/src/main/java/com/example/scoi/domain/invest/service/InvestService.java b/src/main/java/com/example/scoi/domain/invest/service/InvestService.java
@@ -26,7 +26,7 @@ public class InvestService {
     private final BithumbApiClient bithumbApiClient;
     private final UpbitApiClient upbitApiClient;
     
-    public MaxOrderInfoDTO getMaxOrderInfo(String phoneNumber, ExchangeType exchangeType, String coinType, String unitPrice) {
+    public MaxOrderInfoDTO getMaxOrderInfo(String phoneNumber, ExchangeType exchangeType, String coinType, String unitPrice, String orderType, String side) {
         // 사용자 존재 여부 확인
         Member member = memberRepository.findByPhoneNumber(phoneNumber)
                 .orElseThrow(() -> new InvestException(InvestErrorCode.API_KEY_NOT_FOUND));
@@ -37,7 +37,7 @@ public MaxOrderInfoDTO getMaxOrderInfo(String phoneNumber, ExchangeType exchange
 
         try {
             // 거래소 서버 응답 정제해 보내기
-            return apiClient.getMaxOrderInfo(phoneNumber, exchangeType, coinType, unitPrice);
+            return apiClient.getMaxOrderInfo(phoneNumber, exchangeType, coinType, unitPrice, orderType, side);
         } catch (InvestException e) {
             throw e;
         } catch (FeignException e) {
diff --git a/src/main/java/com/example/scoi/global/client/dto/BithumbResDTO.java b/src/main/java/com/example/scoi/global/client/dto/BithumbResDTO.java
@@ -313,4 +313,35 @@ public record WithdrawalAddressResponse(
             String owner_corp_ko_name,
             String owner_corp_en_name
     ) {}
+
+    // 현재가 조회 (Ticker)
+    @JsonIgnoreProperties(ignoreUnknown = true)
+    public record Ticker(
+            String market,
+            String trade_date,
+            String trade_time,
+            String trade_date_kst,
+            String trade_time_kst,
+            Long trade_timestamp,
+            Double opening_price,
+            Double high_price,
+            Double low_price,
+            Double trade_price,  // 현재가
+            Double prev_closing_price,
+            String change,
+            Double change_price,
+            Double change_rate,
+            Double signed_change_price,
+            Double signed_change_rate,
+            Double trade_volume,
+            Double acc_trade_volume,
+            Double acc_trade_volume_24h,
+            Double acc_trade_price,
+            Double acc_trade_price_24h,
+            Long highest_52_week_price,
+            String highest_52_week_date,
+            Long lowest_52_week_price,
+            String lowest_52_week_date,
+            Long timestamp
+    ) {}
 }
diff --git a/src/main/java/com/example/scoi/global/client/dto/UpbitResDTO.java b/src/main/java/com/example/scoi/global/client/dto/UpbitResDTO.java
@@ -335,4 +335,35 @@ public record WithdrawalAddressResponse(
             String exchange_name,
             String wallet_type
     ) {}
+
+    // 현재가 조회 (Ticker)
+    @JsonIgnoreProperties(ignoreUnknown = true)
+    public record Ticker(
+            String market,
+            String trade_date,
+            String trade_time,
+            String trade_date_kst,
+            String trade_time_kst,
+            Long trade_timestamp,
+            Double opening_price,
+            Double high_price,
+            Double low_price,
+            Double trade_price,  // 현재가
+            Double prev_closing_price,
+            String change,
+            Double change_price,
+            Double change_rate,
+            Double signed_change_price,
+            Double signed_change_rate,
+            Double trade_volume,
+            Double acc_trade_volume,
+            Double acc_trade_volume_24h,
+            Double acc_trade_price,
+            Double acc_trade_price_24h,
+            Long highest_52_week_price,
+            String highest_52_week_date,
+            Long lowest_52_week_price,
+            String lowest_52_week_date,
+            Long timestamp
+    ) {}
 }

Original file line number	Diff line number	Diff line change
`@@ -50,4 +50,8 @@ UpbitResDTO.CancelOrder cancelOrder(`
`50`	`50`	`@RequestHeader("Authorization") String authorization,`
`51`	`51`	`@RequestParam("uuid") String uuid`
`52`	`52`	`);`
	`53`	`+`
	`54`	`+ //현재가 조회 (PUBLIC API - 인증 불필요)`
	`55`	`+ @GetMapping("/v1/ticker")`
	`56`	`+ List<UpbitResDTO.Ticker> getTicker(@RequestParam("markets") String markets);`
`53`	`57`	`}`