Merge pull request #12 from Kimjipang/round06

Round06

Author: Kimjipang

apps/commerce-api/build.gradle.kts

@@ -16,6 +16,13 @@ dependencies {
     annotationProcessor("jakarta.persistence:jakarta.persistence-api")
     annotationProcessor("jakarta.annotation:jakarta.annotation-api")
 
+    // FeignClient
+    implementation("org.springframework.cloud:spring-cloud-starter-openfeign")
+
+    // Resilience4j
+    implementation("io.github.resilience4j:resilience4j-spring-boot3")
+    implementation("org.springframework.boot:spring-boot-starter-aop")
+
     // test-fixtures
     testImplementation(testFixtures(project(":modules:jpa")))
     testImplementation(testFixtures(project(":modules:redis")))

apps/commerce-api/src/main/java/com/loopers/CommerceApiApplication.java

@@ -5,12 +5,14 @@
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.context.properties.ConfigurationPropertiesScan;
 import org.springframework.cache.annotation.EnableCaching;
+import org.springframework.cloud.openfeign.EnableFeignClients;
 
 import java.util.TimeZone;
 
 @ConfigurationPropertiesScan
 @SpringBootApplication
 @EnableCaching
+@EnableFeignClients
 public class CommerceApiApplication {
 
     @PostConstruct

apps/commerce-api/src/main/java/com/loopers/application/payment/PaymentFacade.java

@@ -0,0 +1,31 @@
+package com.loopers.application.payment;
+
+import com.loopers.infrastructure.payment.client.PgClient;
+import com.loopers.interfaces.api.ApiResponse;
+import com.loopers.interfaces.api.payment.PaymentV1Dto;
+import io.github.resilience4j.circuitbreaker.annotation.CircuitBreaker;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+
+@Component
+@RequiredArgsConstructor
+public class PaymentFacade {
+    private final PgClient pgClient;
+
+    @CircuitBreaker(name = "pgCircuit", fallbackMethod = "fallback")
+    public PaymentV1Dto.TransactionResponse requestPayment(String userId, PaymentV1Dto.PaymentRequest request) {
+        ApiResponse<PaymentV1Dto.TransactionResponse> result = pgClient.requestPayment(userId, request);
+
+        PaymentV1Dto.TransactionResponse response = result.data();
+
+        return response;
+    }
+
+    public PaymentV1Dto.TransactionResponse fallback(String userId, PaymentV1Dto.PaymentRequest request, Throwable throwable) {
+        return new PaymentV1Dto.TransactionResponse(
+                null,
+                PaymentV1Dto.TransactionStatusResponse.FAILED,
+                "현재 결제 서비스가 불안정합니다. 잠시 후 다시 시도해주세요."
+        );
+    }
+}

apps/commerce-api/src/main/java/com/loopers/domain/payment/Payment.java

@@ -0,0 +1,25 @@
+package com.loopers.domain.payment;
+
+import com.loopers.domain.BaseEntity;
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.Table;
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Entity
+@Getter
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+@Table(name = "payment")
+public class Payment extends BaseEntity {
+    @Column(name = "ref_order_id", nullable = false)
+    private Long orderId;
+
+    @Column(name = "ref_user_id", nullable = false)
+    private Long userId;
+
+    @Column(name = "transaction_key")
+    private String transactionKey;
+
+}

apps/commerce-api/src/main/java/com/loopers/domain/payment/PaymentTransactionStatus.java

@@ -0,0 +1,7 @@
+package com.loopers.domain.payment;
+
+public enum PaymentTransactionStatus {
+    PENDING,
+    SUCCESS,
+    FAILED,
+}

apps/commerce-api/src/main/java/com/loopers/infrastructure/payment/client/FeignClientTimeoutConfig.java

@@ -0,0 +1,13 @@
+package com.loopers.infrastructure.payment.client;
+
+import feign.Request;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class FeignClientTimeoutConfig {
+    @Bean
+    public Request.Options feignOptions() {
+        return new Request.Options(1000, 3000); // 연결/응답 타임아웃 (ms)
+    }
+}

apps/commerce-api/src/main/java/com/loopers/infrastructure/payment/client/PgClient.java

@@ -0,0 +1,22 @@
+package com.loopers.infrastructure.payment.client;
+
+import com.loopers.interfaces.api.ApiResponse;
+import com.loopers.interfaces.api.payment.PaymentV1Dto;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestHeader;
+
+
+@FeignClient(
+        name = "pgClient",
+        url = "http://localhost:8082",
+        configuration = FeignClientTimeoutConfig.class
+)
+public interface PgClient {
+    @PostMapping("/api/v1/payments")
+    ApiResponse<PaymentV1Dto.TransactionResponse> requestPayment(
+            @RequestHeader("X-USER-ID") String userId,
+            @RequestBody PaymentV1Dto.PaymentRequest request
+    );
+}

apps/commerce-api/src/main/java/com/loopers/interfaces/api/payment/PaymentV1Controller.java

@@ -0,0 +1,29 @@
+package com.loopers.interfaces.api.payment;
+
+import com.loopers.application.payment.PaymentFacade;
+import com.loopers.interfaces.api.ApiResponse;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestHeader;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("/api/v1/payments")
+@RequiredArgsConstructor
+public class PaymentV1Controller implements PaymentV1Spec {
+    private final PaymentFacade paymentFacade;
+
+    @PostMapping
+    @Override
+    public ApiResponse<PaymentV1Dto.TransactionResponse> requestPayment(
+            @RequestHeader("X-USER-ID") String userId,
+            @RequestBody PaymentV1Dto.PaymentRequest request
+    ) {
+        PaymentV1Dto.TransactionResponse response = paymentFacade.requestPayment(userId, request);
+
+        return ApiResponse.success(response);
+    }
+
+}

apps/commerce-api/src/main/java/com/loopers/interfaces/api/payment/PaymentV1Dto.java

@@ -0,0 +1,30 @@
+package com.loopers.interfaces.api.payment;
+
+
+public class PaymentV1Dto {
+    public record TransactionResponse(
+            String transactionKey,
+            TransactionStatusResponse status,
+            String reason
+    ) { }
+
+    public enum TransactionStatusResponse {
+        PENDING,
+        SUCCESS,
+        FAILED,
+    }
+
+    public record PaymentRequest(
+            String orderId,
+            CardTypeDto cardType,
+            String cardNo,
+            Long amount,
+            String callbackUrl
+    ) { }
+
+    public enum CardTypeDto {
+        SAMSUNG,
+        KB,
+        HYUNDAI
+    }
+}

apps/commerce-api/src/main/java/com/loopers/interfaces/api/payment/PaymentV1Spec.java

@@ -0,0 +1,13 @@
+package com.loopers.interfaces.api.payment;
+
+import com.loopers.interfaces.api.ApiResponse;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+
+@Tag(name = "Payment V1 API", description = "Payment V1 API Spec")
+public interface PaymentV1Spec {
+
+    @Operation(summary = "PG사 결제 요청")
+    ApiResponse<PaymentV1Dto.TransactionResponse> requestPayment(String userId, PaymentV1Dto.PaymentRequest request);
+
+}