Merge pull request #175 from jeonga1022/feat/volume-7

 [volume-7] Decoupling with Event

Author: jeonga1022

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

@@ -5,8 +5,10 @@
 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 java.util.TimeZone;
 
+@EnableAsync
 @EnableFeignClients
 @ConfigurationPropertiesScan
 @SpringBootApplication

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

@@ -0,0 +1,33 @@
+package com.loopers.application.coupon.event;
+
+import com.loopers.domain.coupon.CouponDomainService;
+import com.loopers.domain.coupon.event.CouponUsedEvent;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.transaction.event.TransactionPhase;
+import org.springframework.transaction.event.TransactionalEventListener;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class CouponEventHandler {
+
+    private final CouponDomainService couponDomainService;
+
+    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
+    @Transactional(propagation = Propagation.REQUIRES_NEW)
+    public void handleCouponUsed(CouponUsedEvent event) {
+        log.info("쿠폰 사용 이벤트 수신 (AFTER_COMMIT): couponId={}, orderId={}",
+                event.getCouponId(), event.getOrderId());
+        try {
+            couponDomainService.useCoupon(event.getCouponId());
+            log.info("쿠폰 사용 처리 완료: couponId={}", event.getCouponId());
+        } catch (Exception e) {
+            log.error("쿠폰 사용 처리 실패: couponId={}, error={}",
+                    event.getCouponId(), e.getMessage(), e);
+        }
+    }
+}

apps/commerce-api/src/main/java/com/loopers/application/like/event/ProductLikeEventHandler.java

@@ -0,0 +1,36 @@
+package com.loopers.application.like.event;
+
+import com.loopers.domain.like.event.ProductLikedEvent;
+import com.loopers.domain.product.ProductRepository;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.transaction.event.TransactionPhase;
+import org.springframework.transaction.event.TransactionalEventListener;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class ProductLikeEventHandler {
+
+    private final ProductRepository productRepository;
+
+    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
+    @Transactional(propagation = Propagation.REQUIRES_NEW)
+    public void handleProductLiked(ProductLikedEvent event) {
+        try {
+            if (event.isLiked()) {
+                productRepository.incrementLikeCount(event.getProductId());
+            } else {
+                productRepository.decrementLikeCount(event.getProductId());
+            }
+            log.info("좋아요 집계 완료: productId={}, liked={}", event.getProductId(), event.isLiked());
+        } catch (Exception e) {
+            // 집계 실패해도 좋아요 기록은 이미 저장됨
+            // 배치에서 일관성 보정 예정
+            log.warn("좋아요 집계 실패: productId={}, liked={}", event.getProductId(), event.isLiked(), e);
+        }
+    }
+}

apps/commerce-api/src/main/java/com/loopers/application/order/CardInfo.java

@@ -0,0 +1,16 @@
+package com.loopers.application.order;
+
+import com.loopers.support.error.CoreException;
+import com.loopers.support.error.ErrorType;
+
+public record CardInfo(String cardType, String cardNo) {
+
+    public CardInfo {
+        if (cardType == null || cardType.isBlank()) {
+            throw new CoreException(ErrorType.BAD_REQUEST, "카드 타입은 필수입니다.");
+        }
+        if (cardNo == null || cardNo.isBlank()) {
+            throw new CoreException(ErrorType.BAD_REQUEST, "카드 번호는 필수입니다.");
+        }
+    }
+}

apps/commerce-api/src/main/java/com/loopers/application/order/OrderCreateCommand.java

@@ -0,0 +1,36 @@
+package com.loopers.application.order;
+
+import com.loopers.interfaces.api.order.OrderDto;
+
+import java.util.List;
+
+public record OrderCreateCommand(
+    String userId,
+    List<OrderDto.OrderItemRequest> items,
+    CardInfo cardInfo,
+    Long couponId
+) {
+    public static OrderCreateCommand forPointPayment(String userId, List<OrderDto.OrderItemRequest> items) {
+        return new OrderCreateCommand(userId, items, null, null);
+    }
+
+    public static OrderCreateCommand forPointPaymentWithCoupon(String userId, List<OrderDto.OrderItemRequest> items, Long couponId) {
+        return new OrderCreateCommand(userId, items, null, couponId);
+    }
+
+    public static OrderCreateCommand forCardPayment(String userId, List<OrderDto.OrderItemRequest> items, CardInfo cardInfo) {
+        return new OrderCreateCommand(userId, items, cardInfo, null);
+    }
+
+    public static OrderCreateCommand forCardPaymentWithCoupon(String userId, List<OrderDto.OrderItemRequest> items, CardInfo cardInfo, Long couponId) {
+        return new OrderCreateCommand(userId, items, cardInfo, couponId);
+    }
+
+    public boolean isCardPayment() {
+        return cardInfo != null;
+    }
+
+    public boolean hasCoupon() {
+        return couponId != null;
+    }
+}