Merge pull request #166 from Kimjipang/main

[volume-6] 외부 시스템 장애 및 지연 대응

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/coupon/CouponFacade.java

@@ -0,0 +1,55 @@
+package com.loopers.application.coupon;
+
+import com.loopers.domain.coupon.Coupon;
+import com.loopers.domain.coupon.CouponRepository;
+import com.loopers.domain.user.UserRepository;
+import com.loopers.interfaces.api.coupon.CouponV1Dto;
+import com.loopers.support.error.CoreException;
+import com.loopers.support.error.ErrorType;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+@Component
+@RequiredArgsConstructor
+public class CouponFacade {
+    private final CouponRepository couponRepository;
+    private final UserRepository userRepository;
+
+    public CouponInfo issueCoupon(CouponV1Dto.CouponRequest request) {
+        /*
+        👨‍💻 쿠폰 발급 로직
+        - [ ] 사용자 검증
+        - [ ] 쿠폰 발급
+         */
+        Long userId = request.userId();
+        userRepository.findById(userId).orElseThrow(
+                () -> new CoreException(ErrorType.NOT_FOUND, "존재하지 않는 회원입니다.")
+        );
+
+        Coupon coupon = Coupon.create(request);
+        Coupon saved = couponRepository.save(coupon);
+
+        return CouponInfo.from(saved);
+    }
+
+    public List<CouponInfo> findCoupons(Long userId) {
+        /*
+        👨‍💻 사용 가능한 쿠폰 조회 로직
+        - [ ] 사용자 검증
+        - [ ] 쿠폰 조회
+         */
+        userRepository.findById(userId).orElseThrow(
+                () -> new CoreException(ErrorType.NOT_FOUND, "존재하지 않는 회원입니다.")
+        );
+
+        List<Coupon> coupons = couponRepository.findAllByUserId(userId).orElseThrow(
+                () -> new CoreException(ErrorType.BAD_REQUEST, "사용 가능한 쿠폰이 존재하지 않습니다.")
+        );
+
+        return coupons.stream()
+                .map(CouponInfo::from)
+                .toList();
+    }
+}

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

@@ -0,0 +1,15 @@
+package com.loopers.application.coupon;
+
+import com.loopers.domain.coupon.Coupon;
+import com.loopers.domain.coupon.CouponType;
+
+public record CouponInfo(Long id, Long userId, CouponType couponType, int quantity) {
+    public static CouponInfo from(Coupon coupon) {
+        return new CouponInfo(
+                coupon.getId(),
+                coupon.getUserId(),
+                coupon.getCouponType(),
+                coupon.getQuantity()
+        );
+    }
+}

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

@@ -0,0 +1,30 @@
+package com.loopers.application.event.coupon;
+
+import com.loopers.application.order.OrderCreatedEvent;
+import com.loopers.domain.coupon.Coupon;
+import com.loopers.domain.coupon.CouponRepository;
+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.Propagation;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.transaction.event.TransactionPhase;
+import org.springframework.transaction.event.TransactionalEventListener;
+
+@Component
+@RequiredArgsConstructor
+public class CouponEventHandler {
+    private final CouponRepository couponRepository;
+
+    @Transactional(propagation = Propagation.REQUIRES_NEW)
+    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
+    public void onOrderCreated(OrderCreatedEvent event) {
+        Long couponId = event.couponId();
+        Coupon coupon = couponRepository.findById(couponId).orElseThrow(
+                () -> new CoreException(ErrorType.NOT_FOUND, "존재하지 않는 쿠폰입니다.")
+        );
+
+        coupon.useCoupon();
+    }
+}

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

@@ -0,0 +1,29 @@
+package com.loopers.application.event.like;
+
+import com.loopers.application.like.LikeCreateEvent;
+import com.loopers.domain.product.Product;
+import com.loopers.domain.product.ProductRepository;
+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.Propagation;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.transaction.event.TransactionPhase;
+import org.springframework.transaction.event.TransactionalEventListener;
+
+@Component
+@RequiredArgsConstructor
+public class LikeEventHandler {
+    private final ProductRepository productRepository;
+
+    @Transactional(propagation = Propagation.REQUIRES_NEW)
+    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
+    public void onLikeCreated(LikeCreateEvent event) {
+        Product product = productRepository.findById(event.productId()).orElseThrow(
+                () -> new CoreException(ErrorType.NOT_FOUND, "존재하지 않는 상품입니다.")
+        );
+
+        product.addLikeCount();
+    }
+}

apps/commerce-api/src/main/java/com/loopers/application/event/useraction/UserActionLogEventHandler.java

@@ -0,0 +1,24 @@
+package com.loopers.application.event.useraction;
+
+import com.loopers.application.product.UserActionEvent;
+import com.loopers.domain.actionlog.UserActionLog;
+import com.loopers.infrastructure.actionlog.UserActionLogJpaRepository;
+import lombok.RequiredArgsConstructor;
+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;
+
+@Component
+@RequiredArgsConstructor
+public class UserActionLogEventHandler {
+    private final UserActionLogJpaRepository userActionLogJpaRepository;
+
+    @Transactional(propagation = Propagation.REQUIRES_NEW)
+    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
+    public void onUserAction(UserActionEvent event) {
+        UserActionLog userActionLog = UserActionLog.create(event);
+        userActionLogJpaRepository.save(userActionLog);
+    }
+}

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

@@ -0,0 +1,4 @@
+package com.loopers.application.like;
+
+public record LikeCreateEvent(Long userId, Long productId) {
+}

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

@@ -1,14 +1,16 @@
 package com.loopers.application.like;
 
+import com.loopers.application.product.UserActionEvent;
+import com.loopers.domain.actionlog.ActionType;
 import com.loopers.domain.like.Like;
 import com.loopers.domain.like.LikeRepository;
-import com.loopers.domain.product.Product;
 import com.loopers.domain.product.ProductRepository;
 import com.loopers.domain.user.UserRepository;
 import com.loopers.interfaces.api.like.LikeV1Dto;
 import com.loopers.support.error.CoreException;
 import com.loopers.support.error.ErrorType;
 import lombok.RequiredArgsConstructor;
+import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -18,6 +20,7 @@ public class LikeFacade {
     private final LikeRepository likeRepository;
     private final UserRepository userRepository;
     private final ProductRepository productRepository;
+    private final ApplicationEventPublisher publisher;
 
     @Transactional
     public LikeInfo doLike(LikeV1Dto.LikeRequest request) {
@@ -33,7 +36,7 @@ public LikeInfo doLike(LikeV1Dto.LikeRequest request) {
                 () -> new CoreException(ErrorType.NOT_FOUND, "존재하지 않는 유저입니다.")
         );
 
-        Product product = productRepository.findById(productId).orElseThrow(
+        productRepository.findById(productId).orElseThrow(
                 () -> new CoreException(ErrorType.NOT_FOUND, "존재하지 않는 상품입니다.")
         );
 
@@ -43,7 +46,8 @@ public LikeInfo doLike(LikeV1Dto.LikeRequest request) {
                     Like newLike = request.toEntity();
                     likeRepository.save(newLike);
 
-                    product.addLikeCount();
+                    publisher.publishEvent(new LikeCreateEvent(userId, productId));
+                    publisher.publishEvent(new UserActionEvent(userId, productId, ActionType.DO_LIKE));
 
                     return LikeInfo.from(newLike);
                 });

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

@@ -0,0 +1,4 @@
+package com.loopers.application.order;
+
+public record OrderCreatedEvent(Long couponId) {
+}