refactor: payment 장애대응로직 보강

* refactor: payment 서킷브레이커 구현

* feat: 결제 서킷브레이커 yml설정 추가

* refactor: order 엔티티 레벨 상태전이 가드, order 서비스 레벨 중복 방어 로직 추가

* refactor: timelimiter, retry제거, client timeout으로 장애 대응

* refactor: client호출 트랜잭션에서 분리, DB점유시간/실패 시 트랜잭션 롤백 문제 방지

* refactor: 멱등성 보장 검증로직 추가, 테스트 코드 추가

Author: gksdud1109

backend/src/main/java/com/back/api/payment/order/service/OrderService.java

@@ -31,6 +31,7 @@ public class OrderService {
 	private final OrderRepository orderRepository;
 	private final TicketService ticketService;
 	private final V2_OrderRepository v2_orderRepository;
+
 	/**
 	 * 주문 생성
 	 * draft 티켓 확인 -> 주문 생성 -> 티켓 상태 PAID로 변경
@@ -129,6 +130,19 @@ public V2_OrderResponseDto v2_createOrder(OrderRequestDto orderRequestDto, Long
 		// 티켓이 DRAFT 상태인지 확인
 		Ticket draft = ticketService.getDraftTicket(orderRequestDto.eventId(), orderRequestDto.seatId(), userId);
 
+		// 이미 PENDING 상태의 Order가 있는지 확인
+		// 다중 요청 방어 로직
+		Optional<V2_Order> existingOrder = v2_orderRepository.findByTicket_IdAndStatus(
+			draft.getId(),
+			OrderStatus.PENDING
+		);
+
+		if (existingOrder.isPresent()) {
+			// 기존 Order 재사용 (새로 만들지 않음)
+			log.info("Duplicate order request, reusing existing orderId={}", existingOrder.get().getOrderId());
+			return V2_OrderResponseDto.from(existingOrder.get());
+		}
+
 		// 금액 일치 여부 확인
 		Integer actualAmount = draft.getSeat().getPrice();
 		if (!orderRequestDto.amount().equals(actualAmount.longValue())) {
@@ -169,4 +183,24 @@ public V2_Order v2_getOrderForPayment(String orderId, Long userId, Long clientAm
 
 		return order;
 	}
+
+	/**
+	 * Order 검증 후 ticketId만 반환 (PG 호출 전 검증용)
+	 */
+	@Transactional(readOnly = true)
+	public Long v2_validateAndGetTicketId(String orderId, Long userId, Long clientAmount) {
+		V2_Order order = v2_getOrderForPayment(orderId, userId, clientAmount);
+		return order.getTicket().getId();
+	}
+
+	/**
+	 * 이미 결제 완료된 Order 조회 (멱등성 보장용)
+	 * - PAID 상태 + 소유자 확인
+	 */
+	@Transactional(readOnly = true)
+	public Optional<V2_Order> v2_findPaidOrder(String orderId, Long userId) {
+		return v2_orderRepository.findById(orderId)
+			.filter(order -> order.getStatus() == OrderStatus.PAID)
+			.filter(order -> order.getTicket().getOwner().getId().equals(userId));
+	}
 }

backend/src/main/java/com/back/api/payment/payment/config/TossPaymentConfig.java

@@ -1,15 +1,28 @@
 package com.back.api.payment.payment.config;
 
+import java.net.http.HttpClient;
+import java.time.Duration;
 import java.util.Base64;
 
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.http.client.JdkClientHttpRequestFactory;
 import org.springframework.web.client.RestClient;
 
+/**
+ * Toss Payments API RestClient 설정
+ * 타임아웃 설정:
+ * - 연결 타임아웃: 3초 - 서버 연결까지 대기 시간
+ * - 읽기 타임아웃: 5초 - 응답 대기 시간 (Toss 권장 최대 30초이나 UX 고려)
+ * 타임아웃 초과 시 ResourceAccessException 발생 → 서킷브레이커에서 처리
+ */
 @Configuration
 public class TossPaymentConfig {
 
+	private static final Duration CONNECT_TIMEOUT = Duration.ofSeconds(3);
+	private static final Duration READ_TIMEOUT = Duration.ofSeconds(5);
+
 	@Value("${toss.payments.secret}")
 	private String secretKey;
 
@@ -18,11 +31,19 @@ public RestClient tossRestClient() {
 		String encodedKey = Base64.getEncoder()
 			.encodeToString((secretKey + ":").getBytes());
 
+		// JDK HttpClient 기반 타임아웃 설정
+		HttpClient httpClient = HttpClient.newBuilder()
+			.connectTimeout(CONNECT_TIMEOUT)
+			.build();
+
+		JdkClientHttpRequestFactory requestFactory = new JdkClientHttpRequestFactory(httpClient);
+		requestFactory.setReadTimeout(READ_TIMEOUT);
+
 		return RestClient.builder()
 			.baseUrl("https://api.tosspayments.com")
 			.defaultHeader("Authorization", "Basic " + encodedKey)
 			.defaultHeader("Content-Type", "application/json")
+			.requestFactory(requestFactory)
 			.build();
 	}
-
 }

backend/src/main/java/com/back/api/payment/payment/dto/response/V2_PaymentConfirmResponse.java

@@ -25,6 +25,7 @@ public record V2_PaymentConfirmResponse(
 	 * V2_Order로부터 응답 객체 생성
 	 * - 변수 추출로 중복 접근 방지 (getTicket() 1번만 호출)
 	 * - N+1 쿼리 방지를 위해 order는 fetch join 필수
+	 * - 멱등성 응답에서 Payment가 null일 수 있음 (이미 결제된 주문 조회 시)
 	 */
 	public static V2_PaymentConfirmResponse from(V2_Order order, boolean success) {
 		var ticket = order.getTicket();
@@ -37,7 +38,7 @@ public static V2_PaymentConfirmResponse from(V2_Order order, boolean success) {
 			success,
 			order.getAmount(),
 			ticket.getCreateAt(),
-			payment.getMethod(),
+			payment != null ? payment.getMethod() : null,
 			ticket.getId(),
 			event.getTitle(),
 			event.getPlace(),

backend/src/main/java/com/back/api/payment/payment/service/PaymentService.java

@@ -1,11 +1,14 @@
 package com.back.api.payment.payment.service;
 
+import java.util.Optional;
+
 import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 import com.back.api.payment.order.service.OrderService;
 import com.back.api.payment.payment.client.PaymentClient;
+import com.back.domain.payment.order.entity.V2_Order;
 import com.back.api.payment.payment.dto.request.PaymentConfirmCommand;
 import com.back.api.payment.payment.dto.request.V2_PaymentConfirmRequest;
 import com.back.api.payment.payment.dto.response.PaymentConfirmResult;
@@ -15,12 +18,8 @@
 import com.back.api.queue.service.QueueEntryProcessService;
 import com.back.api.ticket.service.TicketService;
 import com.back.domain.notification.systemMessage.OrderSuccessMessage;
-import com.back.domain.notification.systemMessage.OrderSuccessV2Message;
 import com.back.domain.payment.order.entity.Order;
-import com.back.domain.payment.order.entity.V2_Order;
 import com.back.domain.payment.payment.entity.ApproveStatus;
-import com.back.domain.payment.payment.entity.Payment;
-import com.back.domain.payment.payment.repository.PaymentRepository;
 import com.back.domain.ticket.entity.Ticket;
 import com.back.global.error.code.PaymentErrorCode;
 import com.back.global.error.exception.ErrorException;
@@ -29,18 +28,6 @@
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 
-/**
- * Payment 관련 비즈니스 로직 처리
- * TODO: PG 연동 시 트랜잭션 경계 재설정 필요
- *
- * [설계 방향]
- * 1. PG API 호출: 트랜잭션 밖으로 이동
- * 2. 핵심 DB 변경만 @Transactional
- * 3. Queue/Notification: @TransactionalEventListener(AFTER_COMMIT)
- *
- * [리팩토링 시점]
- * - 실제 PG 연동 구현 시 (TossPaymentClient 등)
- */
 @Service
 @Slf4j
 @RequiredArgsConstructor
@@ -51,8 +38,8 @@ public class PaymentService {
 	private final TicketService ticketService;
 	private final QueueEntryProcessService queueEntryProcessService;
 	private final ApplicationEventPublisher eventPublisher;
-	private final PaymentRepository paymentRepository;
 	private final TossPaymentService tossPaymentService;
+	private final PaymentTransactionService paymentTransactionService;
 	private final BusinessMetrics businessMetrics;
 
 	@Transactional
@@ -138,82 +125,47 @@ public PaymentReceiptResponse getPaymentReceipt(Long orderId, Long userId) {
 		return PaymentReceiptResponse.from(order, ticket);
 	}
 
-	@Transactional
+	/**
+	 * V2 결제 승인 - PG 호출은 트랜잭션 밖에서 처리
+	 *
+	 * 트랜잭션 분리 이유:
+	 * - PG API 호출 중 DB 커넥션 점유 방지
+	 * - 외부 API 타임아웃 시 트랜잭션 롤백 문제 방지
+	 *
+	 * 처리 흐름:
+	 * 0. 멱등성 확인 (이미 결제 완료된 주문이면 기존 결과 반환)
+	 * 1. Order 검증 (읽기 트랜잭션)
+	 * 2. PG API 호출 (트랜잭션 밖)
+	 * 3. 성공/실패 DB 처리 (각각 단일 쓰기 트랜잭션 - PaymentTransactionService)
+	 */
 	public V2_PaymentConfirmResponse v2_confirmPayment(
 		String orderId,
 		String paymentKey,
 		Long clientAmount,
 		Long userId
 	) {
+		// 0. 멱등성 확인: 이미 결제 완료된 주문이면 기존 결과 반환
+		Optional<V2_Order> paidOrder = orderService.v2_findPaidOrder(orderId, userId);
+		if (paidOrder.isPresent()) {
+			log.info("[Payment] 이미 결제 완료된 주문 - orderId: {}", orderId);
+			// 간단한 응답 반환 (전체 데이터 조회 불필요)
+			return new V2_PaymentConfirmResponse(orderId, true);
+		}
 
-		// OrderService가 order의 정합성(주문자/주문상태/amount) 보장
-		V2_Order order = orderService.v2_getOrderForPayment(orderId, userId, clientAmount);
-
-		// log.info("[v2 결제 디버깅] - 결제 승인 메서드: 결제 서비스 로그");
-		// log.info("[v2 결제 디버깅] - orderId : {}", orderId);
-		// log.info("[v2 결제 디버깅] - paymentKey : {}", paymentKey);
-		// log.info("[v2 결제 디버깅] - userId : {}", userId);
-
-		V2_PaymentConfirmRequest request = new V2_PaymentConfirmRequest(orderId, paymentKey, order.getAmount());
+		// 1. Order 검증 (읽기 트랜잭션)
+		Long ticketId = orderService.v2_validateAndGetTicketId(orderId, userId, clientAmount);
 
+		// 2. PG 호출 (트랜잭션 밖)
+		V2_PaymentConfirmRequest request = new V2_PaymentConfirmRequest(orderId, paymentKey, clientAmount);
 		TossPaymentResponse result = tossPaymentService.confirmPayment(request);
 
-		log.info("[v2 결제 디버깅] - 결제 승인 결과 {}", result.status());
-
-		if (result.status() != ApproveStatus.DONE) { // 결제 승인 완료시 토스 API 응답 : Status = "DONE"
-			order.markFailed();
-			ticketService.failPayment(order.getTicket().getId()); // Ticket FAILED + Seat 해제
+		// 3. 결과에 따라 분기 - PaymentTransactionService에서 단일 트랜잭션으로 처리
+		if (result.status() != ApproveStatus.DONE) {
+			paymentTransactionService.handleFailure(orderId, ticketId);
 			businessMetrics.paymentConfirmFailure("TOSS_PAYMENT_NOT_DONE");
-			//TODO 결제 실패 로직 추가
 			throw new ErrorException(PaymentErrorCode.PAYMENT_FAILED);
 		}
 
-		//결제 엔티티 생성 및 DB 저장 (결제 정보 저장)
-		Payment savedPayment = paymentRepository.save(
-			new Payment(
-				paymentKey,
-				orderId,
-				order.getAmount(),
-				result.method(),
-				result.status()
-			)
-		);
-
-		order.setPayment(savedPayment);
-
-		// Order status PENDING -> PAID, paymentKey DB 저장 (주문 상태 업테이트)
-		order.markPaid(result.paymentKey());
-
-		// 테스트용 : DataInit으로 만든 테스트 데이터 사용한 결제 테스트에서 사용
-		//order.getTicket().getSeat().markAsReserved();
-
-		// Ticket 발급
-		Ticket ticket = ticketService.confirmPayment(
-			order.getTicket().getId(),
-			userId
-		);
-
-		// 결제 성공 메트릭
-		businessMetrics.paymentConfirmSuccess(ticket.getEvent().getId());
-
-		// Queue 완료 // 테스트 데이터로 진행 시 : 큐 대기열이 없으므로 이부분도 주석처리
-		queueEntryProcessService.completePayment(
-			ticket.getEvent().getId(),
-			userId
-		);
-
-		String eventTitle = ticket.getEvent().getTitle();
-
-		// 알림 메시지 발행
-		eventPublisher.publishEvent(
-			new OrderSuccessV2Message(
-				userId,
-				orderId,
-				order.getAmount(),
-				eventTitle
-			)
-		);
-
-		return V2_PaymentConfirmResponse.from(order, true);
+		return paymentTransactionService.handleSuccess(orderId, result, userId);
 	}
 }