[volume-7] Decoupling with Event (#171)

* Feature/refactor purchasing (#30)

* feat: PG 모듈 추가 (#24)

* Feature/pg client (#27)

* test: PG 호출 테스트 코드 추가

* feat: PG 호출 로직 구현

* test: PG CircuitBreaker 테스트 코드 추가

* feat: CircuitBreaker 로직 구현

* test: payment 도메인 단위 테스트 추가

* feat: payment 도메인 구현

* test: PaymentService 도메인 서비스 테스트 코드 추가

* feat: PaymentService 도메인 서비스 구현

* refactor: payment 도메인의 책임이지만 order 도메인에 있던 로직들 이동

* test: Order 도메인 서비스 로직 테스트 코드 작성

* refactor: Order 도메인의 도메인 서비스 로직 재구성

* refactor: purchasing facade에서 처리하고 있던 내용 중 도메인 레이어로 위임할 수 있는 내용들 재배치

* refactor: DIP 원칙에 맞춰 PG 로직에서 infra 레이어가 domain 레이어를 의존하도록 재구성

* refactor: payment 관련 스케줄링 로직들은 infra 레이어로 이동

* refactor: PurchasingFacade가 repository를 직접 사용하지 않도록 도메인 서비스 로직 재구성

* refactor: PuhrchasingFacade가 도메인 서비스를 조합해서 사용하는 역할만 담당하도록 재구성

* refactor: 재구성한 도메인 서비스 로직에 맞춰 테스트 코드 재구성

* refactor: 주문 결제시 포인트 또는 카드만을 사용하여 결제 할 수 있도록 수정

* refactor: 포인트 또는 카드를 사용하여 결제할 수 있도록 테스트 코드 재구성

* refactor: 다른 application레이어와 동일하게 command의 위치를 domain에서 application으로 이동

* refactor: Order도메인 서비스에 대한 테스트 코드 중 application 레이어에 더 적합한 부분 분리

* refactor: Order 도메인 서비스에 있던 내용 중 어플리케이션 서비스에 해당하는 부분들은 application 레이어로 이동시킴

* refactor: infrastructure 레이어에 domain레이어와 달리 payment와 paymentgateway가 구분되어있어 통일함

* chore: 중복되는 로그 정리, 불필요하게 높은 level인 로그는 debug 로그로 전환

* Feature/refactor application (#31)

* refactor: application 레이어를 도메인별 어플리케이션 서비스와 어플리케이션의 조합인 facade로 분리하여 구성

* refactor: application가 도메인별 어플리케이션 서비스와 파사드로 구분된 것에 맞춰 테스트 코드 수정

* refactor: scheduler를 infrastructure 레이어로 이동

* refactor: 도메인의 캡슐화가 부족한 부분 개선

* refactor: 캐시 사용할 때 dip 적용하여 application레이어가 infrastructure 레이어를 참조하지 않도록 수정 (#32)

* Feature/event (#34)

* feat: 도메인별 event 추가

* feat: DIP 적용하여 event publisher 구현

* refactor: 좋아요 수 집계를 스케줄 기반 처리하는 것에서 이벤트 기반 처리하는 것으로 변경

* feat: 쿠폰 이벤트 처리하는 로직 추가

* feat: order 도메인의 이벤트 처리 로직 추가

* feat: payment 도메인의 이벤트 처리 로직 추가

* feat: point 도메인의 이벤트 처리 로직 추가

* feat: product 도메인의 이벤트 처리 로직 추가

* 도메인이벤트

* refactor: HeartFacade에서 좋아요 처리시 Product 어플리케이션 서비스를 직접호출하지 않고 이벤트 사용하는 방식으로 재구성

* refactor: PurchasingFacade에서 주문 처리시 어플리케이션 서비스를 직접호출하지 않고 이벤트 사용하는 방식으로 재구성

* test: eventhandler에 대한 테스트 추가

* refactor: event handler 테스트에 맞춰 코드 수정

* feat: 데이터 플랫폼으로 주문 데이터 전송하는 로직 추가

* feat: event 및 command 재구성 (#35)

* feat: event 및 command 재구성 (#35)

event

* code rabbit

Author: minor7295

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.cloud.openfeign.EnableFeignClients;
+import org.springframework.scheduling.annotation.EnableAsync;
 import org.springframework.scheduling.annotation.EnableScheduling;
 import java.util.TimeZone;
 
 @ConfigurationPropertiesScan
 @SpringBootApplication
 @EnableScheduling
+@EnableAsync
 @EnableFeignClients
 public class CommerceApiApplication {
 

…lication/catalog/CatalogBrandFacade.java …pers/application/brand/BrandService.javaapps/commerce-api/src/main/java/com/loopers/application/catalog/CatalogBrandFacade.java renamed to apps/commerce-api/src/main/java/com/loopers/application/brand/BrandService.java apps/commerce-api/src/main/java/com/loopers/application/catalog/CatalogBrandFacade.java renamed to apps/commerce-api/src/main/java/com/loopers/application/brand/BrandService.java

@@ -1,11 +1,14 @@
-package com.loopers.application.catalog;
+package com.loopers.application.brand;
 
 import com.loopers.domain.brand.Brand;
 import com.loopers.domain.brand.BrandRepository;
 import com.loopers.support.error.CoreException;
 import com.loopers.support.error.ErrorType;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
 
 /**
  * 브랜드 조회 파사드.
@@ -18,19 +21,45 @@
  */
 @RequiredArgsConstructor
 @Component
-public class CatalogBrandFacade {
+public class BrandService {
     private final BrandRepository brandRepository;
 
+    /**
+     * 브랜드 ID로 브랜드를 조회합니다.
+     *
+     * @param brandId 브랜드 ID
+     * @return 조회된 브랜드
+     * @throws CoreException 브랜드를 찾을 수 없는 경우
+     */
+    @Transactional(readOnly = true)
+    public Brand getBrand(Long brandId) {
+        return brandRepository.findById(brandId)
+            .orElseThrow(() -> new CoreException(ErrorType.NOT_FOUND, "브랜드를 찾을 수 없습니다."));
+    }
+
+    /**
+     * 브랜드 ID 목록으로 브랜드 목록을 조회합니다.
+     * <p>
+     * 배치 조회를 통해 N+1 쿼리 문제를 해결합니다.
+     * </p>
+     *
+     * @param brandIds 조회할 브랜드 ID 목록
+     * @return 조회된 브랜드 목록
+     */
+    @Transactional(readOnly = true)
+    public List<Brand> getBrands(List<Long> brandIds) {
+        return brandRepository.findAllById(brandIds);
+    }
+
     /**
      * 브랜드 정보를 조회합니다.
      *
      * @param brandId 브랜드 ID
      * @return 브랜드 정보
      * @throws CoreException 브랜드를 찾을 수 없는 경우
      */
-    public BrandInfo getBrand(Long brandId) {
-        Brand brand = brandRepository.findById(brandId)
-            .orElseThrow(() -> new CoreException(ErrorType.NOT_FOUND, "브랜드를 찾을 수 없습니다."));
+    public BrandInfo getBrandInfo(Long brandId) {
+        Brand brand = getBrand(brandId);
         return BrandInfo.from(brand);
     }
 

…cation/catalog/CatalogProductFacade.java …s/application/catalog/CatalogFacade.javaapps/commerce-api/src/main/java/com/loopers/application/catalog/CatalogProductFacade.java renamed to apps/commerce-api/src/main/java/com/loopers/application/catalog/CatalogFacade.java apps/commerce-api/src/main/java/com/loopers/application/catalog/CatalogProductFacade.java renamed to apps/commerce-api/src/main/java/com/loopers/application/catalog/CatalogFacade.java

@@ -1,10 +1,11 @@
 package com.loopers.application.catalog;
 
+import com.loopers.application.brand.BrandService;
+import com.loopers.application.product.ProductCacheService;
+import com.loopers.application.product.ProductService;
 import com.loopers.domain.brand.Brand;
-import com.loopers.domain.brand.BrandRepository;
 import com.loopers.domain.product.Product;
 import com.loopers.domain.product.ProductDetail;
-import com.loopers.domain.product.ProductRepository;
 import com.loopers.support.error.CoreException;
 import com.loopers.support.error.ErrorType;
 import lombok.RequiredArgsConstructor;
@@ -25,9 +26,9 @@
  */
 @RequiredArgsConstructor
 @Component
-public class CatalogProductFacade {
-    private final ProductRepository productRepository;
-    private final BrandRepository brandRepository;
+public class CatalogFacade {
+    private final BrandService brandService;
+    private final ProductService productService;
     private final ProductCacheService productCacheService;
 
     /**
@@ -54,8 +55,8 @@ public ProductInfoList getProducts(Long brandId, String sort, int page, int size
         }
 
         // 캐시에 없으면 DB에서 조회
-        long totalCount = productRepository.countAll(brandId);
-        List<Product> products = productRepository.findAll(brandId, normalizedSort, page, size);
+        long totalCount = productService.countAll(brandId);
+        List<Product> products = productService.findAll(brandId, normalizedSort, page, size);
 
         if (products.isEmpty()) {
             ProductInfoList emptyResult = new ProductInfoList(List.of(), totalCount, page, size);
@@ -72,7 +73,7 @@ public ProductInfoList getProducts(Long brandId, String sort, int page, int size
             .toList();
 
         // 브랜드 배치 조회 및 Map으로 변환 (O(1) 조회를 위해)
-        Map<Long, Brand> brandMap = brandRepository.findAllById(brandIds).stream()
+        Map<Long, Brand> brandMap = brandService.getBrands(brandIds).stream()
             .collect(Collectors.toMap(Brand::getId, brand -> brand));
 
         // 상품 정보 변환 (이미 조회한 Product 재사용)
@@ -116,12 +117,10 @@ public ProductInfo getProduct(Long productId) {
         }
 
         // 캐시에 없으면 DB에서 조회
-        Product product = productRepository.findById(productId)
-            .orElseThrow(() -> new CoreException(ErrorType.NOT_FOUND, "상품을 찾을 수 없습니다."));
+        Product product = productService.getProduct(productId);
 
         // 브랜드 조회
-        Brand brand = brandRepository.findById(product.getBrandId())
-            .orElseThrow(() -> new CoreException(ErrorType.NOT_FOUND, "브랜드를 찾을 수 없습니다."));
+        Brand brand = brandService.getBrand(product.getBrandId());
 
         // ✅ Product.likeCount 필드 사용 (비동기 집계된 값)
         Long likesCount = product.getLikeCount();

apps/commerce-api/src/main/java/com/loopers/application/coupon/ApplyCouponCommand.java

@@ -0,0 +1,30 @@
+package com.loopers.application.coupon;
+
+/**
+ * 쿠폰 적용 명령.
+ * <p>
+ * 쿠폰 적용을 위한 명령 객체입니다.
+ * </p>
+ *
+ * @param userId 사용자 ID
+ * @param couponCode 쿠폰 코드
+ * @param subtotal 주문 소계 금액
+ */
+public record ApplyCouponCommand(
+    Long userId,
+    String couponCode,
+    Integer subtotal
+) {
+    public ApplyCouponCommand {
+        if (userId == null) {
+            throw new IllegalArgumentException("userId는 필수입니다.");
+        }
+        if (couponCode == null || couponCode.isBlank()) {
+            throw new IllegalArgumentException("couponCode는 필수입니다.");
+        }
+        if (subtotal == null || subtotal < 0) {
+            throw new IllegalArgumentException("subtotal은 0 이상이어야 합니다.");
+        }
+    }
+}
+

apps/commerce-api/src/main/java/com/loopers/application/coupon/CouponEventHandler.java

@@ -0,0 +1,116 @@
+package com.loopers.application.coupon;
+
+import com.loopers.domain.coupon.CouponEvent;
+import com.loopers.domain.coupon.CouponEventPublisher;
+import com.loopers.domain.order.OrderEvent;
+import com.loopers.support.error.CoreException;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.orm.ObjectOptimisticLockingFailureException;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+/**
+ * 쿠폰 이벤트 핸들러.
+ * <p>
+ * 주문 생성 이벤트를 받아 쿠폰 사용 처리를 수행하는 애플리케이션 로직을 처리합니다.
+ * </p>
+ * <p>
+ * <b>DDD/EDA 관점:</b>
+ * <ul>
+ *   <li><b>책임 분리:</b> CouponService는 쿠폰 도메인 비즈니스 로직, CouponEventHandler는 이벤트 처리 로직</li>
+ *   <li><b>이벤트 핸들러:</b> 이벤트를 받아서 처리하는 역할을 명확히 나타냄</li>
+ *   <li><b>도메인 경계 준수:</b> 쿠폰 도메인은 쿠폰 적용 이벤트만 발행하고, 주문 도메인은 자신의 상태를 관리</li>
+ * </ul>
+ * </p>
+ *
+ * @author Loopers
+ * @version 1.0
+ */
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class CouponEventHandler {
+
+    private final CouponService couponService;
+    private final CouponEventPublisher couponEventPublisher;
+
+    /**
+     * 주문 생성 이벤트를 처리하여 쿠폰을 사용하고 쿠폰 적용 이벤트를 발행합니다.
+     * <p>
+     * 쿠폰 코드가 있는 경우에만 쿠폰 사용 처리를 수행합니다.
+     * 쿠폰 적용 후 CouponApplied 이벤트를 발행하여 주문 도메인이 자신의 상태를 업데이트하도록 합니다.
+     * </p>
+     *
+     * @param event 주문 생성 이벤트
+     */
+    @Transactional
+    public void handleOrderCreated(OrderEvent.OrderCreated event) {
+        // 쿠폰 코드가 없는 경우 처리하지 않음
+        if (event.couponCode() == null || event.couponCode().isBlank()) {
+            log.debug("쿠폰 코드가 없어 쿠폰 사용 처리를 건너뜁니다. (orderId: {})", event.orderId());
+            return;
+        }
+
+        try {
+            // ✅ OrderEvent.OrderCreated를 구독하여 쿠폰 적용 Command 실행
+            // 쿠폰 사용 처리 (쿠폰 사용 마킹 및 할인 금액 계산)
+            Integer discountAmount = couponService.applyCoupon(
+                    new ApplyCouponCommand(
+                            event.userId(),
+                            event.couponCode(),
+                            event.subtotal()
+                    )
+            );
+
+            // ✅ 도메인 이벤트 발행: 쿠폰이 적용되었음 (과거 사실)
+            // 주문 도메인이 이 이벤트를 구독하여 자신의 상태를 업데이트함
+            couponEventPublisher.publish(CouponEvent.CouponApplied.of(
+                    event.orderId(),
+                    event.userId(),
+                    event.couponCode(),
+                    discountAmount
+            ));
+
+            log.info("쿠폰 사용 처리 완료. (orderId: {}, couponCode: {}, discountAmount: {})",
+                    event.orderId(), event.couponCode(), discountAmount);
+        } catch (CoreException e) {
+            // 비즈니스 예외 발생 시 실패 이벤트 발행
+            String failureReason = e.getMessage() != null ? e.getMessage() : "쿠폰 적용 실패";
+            log.error("쿠폰 적용 실패. (orderId: {}, couponCode: {})",
+                    event.orderId(), event.couponCode(), e);
+            couponEventPublisher.publish(CouponEvent.CouponApplicationFailed.of(
+                    event.orderId(),
+                    event.userId(),
+                    event.couponCode(),
+                    failureReason
+            ));
+            throw e;
+        } catch (ObjectOptimisticLockingFailureException e) {
+            // 낙관적 락 충돌: 다른 트랜잭션이 먼저 쿠폰을 사용함
+            String failureReason = "쿠폰이 이미 사용되었습니다. (동시성 충돌)";
+            log.warn("쿠폰 사용 중 낙관적 락 충돌 발생. (orderId: {}, couponCode: {})",
+                    event.orderId(), event.couponCode());
+            couponEventPublisher.publish(CouponEvent.CouponApplicationFailed.of(
+                    event.orderId(),
+                    event.userId(),
+                    event.couponCode(),
+                    failureReason
+            ));
+            throw e;
+        } catch (Exception e) {
+            // 예상치 못한 오류 발생 시 실패 이벤트 발행
+            String failureReason = e.getMessage() != null ? e.getMessage() : "쿠폰 적용 처리 중 오류 발생";
+            log.error("쿠폰 적용 처리 중 오류 발생. (orderId: {}, couponCode: {})",
+                    event.orderId(), event.couponCode(), e);
+            couponEventPublisher.publish(CouponEvent.CouponApplicationFailed.of(
+                    event.orderId(),
+                    event.userId(),
+                    event.couponCode(),
+                    failureReason
+            ));
+            throw e;
+        }
+    }
+}
+