feat: 폴백 시 아웃박스 패턴 적용

Author: rnqhstmd

apps/commerce-api/src/main/java/com/loopers/infrastructure/kafka/producer/PaymentEventProducer.java

@@ -1,19 +1,23 @@
 package com.loopers.infrastructure.kafka.producer;
 
+import com.loopers.domain.outbox.OutboxService;
 import com.loopers.infrastructure.kafka.dto.PaymentEventDto;
 import io.github.resilience4j.retry.annotation.Retry;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.kafka.core.KafkaTemplate;
 import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.transaction.annotation.Transactional;
 
 @Slf4j
 @Component
 @RequiredArgsConstructor
 public class PaymentEventProducer {
 
     private final KafkaTemplate<Object, Object> kafkaTemplate;
+    private final OutboxService outboxService;
 
     @Value("${kafka.topic.payment-events-name}")
     private String paymentEventsTopic;
@@ -39,15 +43,64 @@ public void sendPaymentPendingEvent(Long orderId, Long userId, String transactio
         log.info("결제 대기 이벤트 발행: orderId={}, transactionId={}", orderId, transactionId);
     }
 
+    @Transactional(propagation = Propagation.REQUIRES_NEW)
     public void paymentSuccessFallback(Long orderId, Long userId, String transactionId, Long amount, Throwable ex) {
-        log.error("결제 성공 이벤트 발행 실패: orderId={}", orderId, ex);
+        log.error("결제 성공 이벤트 발행 실패, Outbox에 저장: orderId={}", orderId, ex);
+
+        try {
+            PaymentEventDto event = PaymentEventDto.success(orderId, userId, transactionId, amount);
+
+            outboxService.saveEvent(
+                    "PAYMENT",
+                    orderId.toString(),
+                    "PAYMENT_SUCCESS",
+                    paymentEventsTopic,
+                    orderId.toString(),
+                    event
+            );
+        } catch (Exception e) {
+            log.error("Fallback Outbox 저장 실패: orderId={}", orderId, e);
+            // 최후의 수단: 별도 실패 테이블에 저장하거나 알림 발송
+        }
     }
 
+    @Transactional(propagation = Propagation.REQUIRES_NEW)
     public void paymentFailedFallback(Long orderId, Long userId, String failureReason, Throwable ex) {
-        log.error("결제 실패 이벤트 발행 실패: orderId={}", orderId, ex);
+        log.error("결제 실패 이벤트 발행 실패, Outbox에 저장: orderId={}", orderId, ex);
+
+        try {
+            PaymentEventDto event = PaymentEventDto.failed(orderId, userId, failureReason);
+
+            outboxService.saveEvent(
+                    "PAYMENT",
+                    orderId.toString(),
+                    "PAYMENT_FAILED",
+                    paymentEventsTopic,
+                    orderId.toString(),
+                    event
+            );
+        } catch (Exception e) {
+            log.error("Fallback Outbox 저장 실패: orderId={}", orderId, e);
+        }
     }
 
+    @Transactional(propagation = Propagation.REQUIRES_NEW)
     public void paymentPendingFallback(Long orderId, Long userId, String transactionId, Throwable ex) {
-        log.error("결제 대기 이벤트 발행 실패: orderId={}", orderId, ex);
+        log.error("결제 대기 이벤트 발행 실패, Outbox에 저장: orderId={}", orderId, ex);
+
+        try {
+            PaymentEventDto event = PaymentEventDto.pending(orderId, userId, transactionId);
+
+            outboxService.saveEvent(
+                    "PAYMENT",
+                    orderId.toString(),
+                    "PAYMENT_PENDING",
+                    paymentEventsTopic,
+                    orderId.toString(),
+                    event
+            );
+        } catch (Exception e) {
+            log.error("Fallback Outbox 저장 실패: orderId={}", orderId, e);
+        }
     }
 }