[volume-7] Decoupling with Event

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 {
 

apps/commerce-api/src/main/java/com/loopers/application/catalog/CatalogBrandFacade.java → 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);
     }
 

apps/commerce-api/src/main/java/com/loopers/application/catalog/CatalogProductFacade.java → 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/CouponEventHandler.java

@@ -0,0 +1,73 @@
+package com.loopers.application.coupon;
+
+import com.loopers.domain.coupon.CouponEvent;
+import com.loopers.domain.coupon.CouponEventPublisher;
+import com.loopers.domain.order.OrderEvent;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+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;
+        }
+
+        // 쿠폰 사용 처리 (쿠폰 사용 마킹 및 할인 금액 계산)
+        Integer discountAmount = couponService.applyCoupon(
+                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);
+    }
+}
+

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

@@ -0,0 +1,91 @@
+package com.loopers.application.coupon;
+
+import com.loopers.domain.coupon.Coupon;
+import com.loopers.domain.coupon.CouponRepository;
+import com.loopers.domain.coupon.UserCoupon;
+import com.loopers.domain.coupon.UserCouponRepository;
+import com.loopers.domain.coupon.discount.CouponDiscountStrategyFactory;
+import com.loopers.support.error.CoreException;
+import com.loopers.support.error.ErrorType;
+import lombok.RequiredArgsConstructor;
+import org.springframework.orm.ObjectOptimisticLockingFailureException;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+/**
+ * 쿠폰 애플리케이션 서비스.
+ * <p>
+ * 쿠폰 조회, 사용 등의 애플리케이션 로직을 처리합니다.
+ * Repository에 의존하며 트랜잭션 관리 및 동시성 제어를 담당합니다.
+ * </p>
+ *
+ * @author Loopers
+ * @version 1.0
+ */
+@RequiredArgsConstructor
+@Component
+public class CouponService {
+    private final CouponRepository couponRepository;
+    private final UserCouponRepository userCouponRepository;
+    private final CouponDiscountStrategyFactory couponDiscountStrategyFactory;
+
+    /**
+     * 쿠폰을 적용하여 할인 금액을 계산하고 쿠폰을 사용 처리합니다.
+     * <p>
+     * <b>동시성 제어 전략:</b>
+     * <ul>
+     *   <li><b>OPTIMISTIC_LOCK 사용 근거:</b> 쿠폰 중복 사용 방지, Hot Spot 대응</li>
+     *   <li><b>@Version 필드:</b> UserCoupon 엔티티의 version 필드를 통해 자동으로 낙관적 락 적용</li>
+     *   <li><b>동시 사용 시:</b> 한 명만 성공하고 나머지는 OptimisticLockException 발생</li>
+     *   <li><b>사용 목적:</b> 동일 쿠폰으로 여러 기기에서 동시 주문해도 한 번만 사용되도록 보장</li>
+     * </ul>
+     * </p>
+     *
+     * @param userId 사용자 ID
+     * @param couponCode 쿠폰 코드
+     * @param subtotal 주문 소계 금액
+     * @return 할인 금액
+     * @throws CoreException 쿠폰을 찾을 수 없거나 사용 불가능한 경우, 동시 사용으로 인한 충돌 시
+     */
+    @Transactional
+    public Integer applyCoupon(Long userId, String couponCode, Integer subtotal) {
+        // 쿠폰 존재 여부 확인
+        Coupon coupon = couponRepository.findByCode(couponCode)
+            .orElseThrow(() -> new CoreException(ErrorType.NOT_FOUND,
+                String.format("쿠폰을 찾을 수 없습니다. (쿠폰 코드: %s)", couponCode)));
+
+        // 낙관적 락을 사용하여 사용자 쿠폰 조회 (동시성 제어)
+        // @Version 필드가 있어 자동으로 낙관적 락이 적용됨
+        UserCoupon userCoupon = userCouponRepository.findByUserIdAndCouponCodeForUpdate(userId, couponCode)
+            .orElseThrow(() -> new CoreException(ErrorType.NOT_FOUND,
+                String.format("사용자가 소유한 쿠폰을 찾을 수 없습니다. (쿠폰 코드: %s)", couponCode)));
+
+        // 쿠폰 사용 가능 여부 확인
+        if (!userCoupon.isAvailable()) {
+            throw new CoreException(ErrorType.BAD_REQUEST,
+                String.format("이미 사용된 쿠폰입니다. (쿠폰 코드: %s)", couponCode));
+        }
+
+        // 쿠폰 사용 처리
+        userCoupon.use();
+
+        // 할인 금액 계산 (전략 패턴 사용)
+        Integer discountAmount = coupon.calculateDiscountAmount(subtotal, couponDiscountStrategyFactory);
+
+        try {
+            // 사용자 쿠폰 저장 (version 체크 자동 수행)
+            // 다른 트랜잭션이 먼저 수정했다면 OptimisticLockException 발생
+            userCouponRepository.save(userCoupon);
+            // ✅ flush()를 명시적으로 호출하여 Optimistic Lock 체크를 즉시 수행
+            // flush() 없이는 트랜잭션 커밋 시점에 체크되므로, 여러 트랜잭션이 동시에 성공할 수 있음
+            userCouponRepository.flush();
+        } catch (ObjectOptimisticLockingFailureException e) {
+            // 낙관적 락 충돌: 다른 트랜잭션이 먼저 쿠폰을 사용함
+            throw new CoreException(ErrorType.CONFLICT,
+                String.format("쿠폰이 이미 사용되었습니다. (쿠폰 코드: %s)", couponCode));
+        }
+
+        return discountAmount;
+    }
+}
+