Feature/refactor application

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/domain/coupon/CouponService.java → apps/commerce-api/src/main/java/com/loopers/application/coupon/CouponService.java

@@ -1,5 +1,9 @@
-package com.loopers.domain.coupon;
+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;
@@ -9,10 +13,10 @@
 import org.springframework.transaction.annotation.Transactional;
 
 /**
- * 쿠폰 도메인 서비스.
+ * 쿠폰 애플리케이션 서비스.
  * <p>
- * 쿠폰 조회, 사용 등의 도메인 로직을 처리합니다.
- * Repository에 의존하며 비즈니스 규칙을 캡슐화합니다.
+ * 쿠폰 조회, 사용 등의 애플리케이션 로직을 처리합니다.
+ * Repository에 의존하며 트랜잭션 관리 및 동시성 제어를 담당합니다.
  * </p>
  *
  * @author Loopers

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

@@ -1,12 +1,12 @@
-package com.loopers.application.like;
+package com.loopers.application.heart;
 
-import com.loopers.application.catalog.ProductCacheService;
+import com.loopers.application.like.LikeService;
+import com.loopers.application.product.ProductCacheService;
+import com.loopers.application.product.ProductService;
+import com.loopers.application.user.UserService;
 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.User;
-import com.loopers.domain.user.UserRepository;
 import com.loopers.support.error.CoreException;
 import com.loopers.support.error.ErrorType;
 import org.springframework.transaction.annotation.Transactional;
@@ -29,10 +29,10 @@
  */
 @RequiredArgsConstructor
 @Component
-public class LikeFacade {
-    private final LikeRepository likeRepository;
-    private final UserRepository userRepository;
-    private final ProductRepository productRepository;
+public class HeartFacade {
+    private final LikeService likeService;
+    private final UserService userService;
+    private final ProductService productService;
     private final ProductCacheService productCacheService;
 
     /**
@@ -69,7 +69,7 @@ public void addLike(String userId, Long productId) {
         // 먼저 일반 조회로 중복 체크 (대부분의 경우 빠르게 처리)
         // ⚠️ 주의: 애플리케이션 레벨 체크만으로는 race condition을 완전히 방지할 수 없음
         // 동시에 두 요청이 들어오면 둘 다 "없음"으로 판단 → 둘 다 저장 시도 가능
-        Optional<Like> existingLike = likeRepository.findByUserIdAndProductId(user.getId(), productId);
+        Optional<Like> existingLike = likeService.getLike(user.getId(), productId);
         if (existingLike.isPresent()) {
             return;
         }
@@ -79,7 +79,7 @@ public void addLike(String userId, Long productId) {
         // @Transactional이 없어도 save() 호출 시 자동 트랜잭션으로 예외를 catch할 수 있음
         Like like = Like.of(user.getId(), productId);
         try {
-            likeRepository.save(like);
+            likeService.save(like);
             // 좋아요 추가 성공 시 로컬 캐시의 델타 증가
             productCacheService.incrementLikeCountDelta(productId);
         } catch (org.springframework.dao.DataIntegrityViolationException e) {
@@ -105,13 +105,13 @@ public void removeLike(String userId, Long productId) {
         User user = loadUser(userId);
         loadProduct(productId);
 
-        Optional<Like> like = likeRepository.findByUserIdAndProductId(user.getId(), productId);
+        Optional<Like> like = likeService.getLike(user.getId(), productId);
         if (like.isEmpty()) {
             return;
         }
 
         try {
-            likeRepository.delete(like.get());
+            likeService.delete(like.get());
             // 좋아요 취소 성공 시 로컬 캐시의 델타 감소
             productCacheService.decrementLikeCountDelta(productId);
         } catch (Exception e) {
@@ -144,7 +144,7 @@ public List<LikedProduct> getLikedProducts(String userId) {
         User user = loadUser(userId);
 
         // 사용자의 좋아요 목록 조회
-        List<Like> likes = likeRepository.findAllByUserId(user.getId());
+        List<Like> likes = likeService.getLikesByUserId(user.getId());
 
         if (likes.isEmpty()) {
             return List.of();
@@ -156,7 +156,7 @@ public List<LikedProduct> getLikedProducts(String userId) {
             .toList();
 
         // ✅ 배치 조회로 N+1 쿼리 문제 해결
-        Map<Long, Product> productMap = productRepository.findAllById(productIds).stream()
+        Map<Long, Product> productMap = productService.getProducts(productIds).stream()
             .collect(Collectors.toMap(Product::getId, product -> product));
 
         // 요청한 상품 ID와 조회된 상품 수가 일치하는지 확인
@@ -180,17 +180,11 @@ public List<LikedProduct> getLikedProducts(String userId) {
     }
 
     private User loadUser(String userId) {
-        User user = userRepository.findByUserId(userId);
-        if (user == null) {
-            throw new CoreException(ErrorType.NOT_FOUND, "사용자를 찾을 수 없습니다.");
-        }
-        return user;
+        return userService.getUser(userId);
     }
 
     private Product loadProduct(Long productId) {
-        return productRepository.findById(productId)
-            .orElseThrow(() -> new CoreException(ErrorType.NOT_FOUND,
-                String.format("상품을 찾을 수 없습니다. (상품 ID: %d)", productId)));
+        return productService.getProduct(productId);
     }
 
     /**

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

@@ -0,0 +1,70 @@
+package com.loopers.application.like;
+
+import com.loopers.domain.like.Like;
+import com.loopers.domain.like.LikeRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+import java.util.Optional;
+
+/**
+ * 좋아요 애플리케이션 서비스.
+ * <p>
+ * 좋아요 조회, 저장, 삭제 등의 애플리케이션 로직을 처리합니다.
+ * Repository에 의존하며 트랜잭션 관리를 담당합니다.
+ * </p>
+ *
+ * @author Loopers
+ * @version 1.0
+ */
+@RequiredArgsConstructor
+@Component
+public class LikeService {
+    private final LikeRepository likeRepository;
+
+    /**
+     * 사용자 ID와 상품 ID로 좋아요를 조회합니다.
+     *
+     * @param userId 사용자 ID
+     * @param productId 상품 ID
+     * @return 조회된 좋아요를 담은 Optional
+     */
+    @Transactional(readOnly = true)
+    public Optional<Like> getLike(Long userId, Long productId) {
+        return likeRepository.findByUserIdAndProductId(userId, productId);
+    }
+
+    /**
+     * 좋아요를 저장합니다.
+     *
+     * @param like 저장할 좋아요
+     * @return 저장된 좋아요
+     */
+    @Transactional
+    public Like save(Like like) {
+        return likeRepository.save(like);
+    }
+
+    /**
+     * 좋아요를 삭제합니다.
+     *
+     * @param like 삭제할 좋아요
+     */
+    @Transactional
+    public void delete(Like like) {
+        likeRepository.delete(like);
+    }
+
+    /**
+     * 사용자 ID로 좋아요한 상품 목록을 조회합니다.
+     *
+     * @param userId 사용자 ID
+     * @return 좋아요 목록
+     */
+    @Transactional(readOnly = true)
+    public List<Like> getLikesByUserId(Long userId) {
+        return likeRepository.findAllByUserId(userId);
+    }
+}

apps/commerce-api/src/main/java/com/loopers/domain/order/OrderService.java → apps/commerce-api/src/main/java/com/loopers/application/order/OrderService.java

@@ -1,5 +1,9 @@
-package com.loopers.domain.order;
+package com.loopers.application.order;
 
+import com.loopers.domain.order.Order;
+import com.loopers.domain.order.OrderItem;
+import com.loopers.domain.order.OrderRepository;
+import com.loopers.domain.order.OrderStatus;
 import com.loopers.domain.payment.PaymentStatus;
 import com.loopers.domain.product.Product;
 import com.loopers.domain.user.Point;
@@ -15,9 +19,10 @@
 import java.util.Optional;
 
 /**
- * 주문 도메인 서비스.
+ * 주문 애플리케이션 서비스.
  * <p>
- * 주문의 기본 CRUD 및 상태 변경을 담당합니다.
+ * 주문의 기본 CRUD 및 상태 변경을 담당하는 애플리케이션 서비스입니다.
+ * Repository에 의존하며 트랜잭션 관리를 담당합니다.
  * </p>
  *
  * @author Loopers
@@ -60,7 +65,7 @@ public Order getById(Long orderId) {
      * @return 조회된 주문 (없으면 Optional.empty())
      */
     @Transactional(readOnly = true)
-    public Optional<Order> findById(Long orderId) {
+    public Optional<Order> getOrder(Long orderId) {
         return orderRepository.findById(orderId);
     }
 
@@ -71,7 +76,7 @@ public Optional<Order> findById(Long orderId) {
      * @return 해당 사용자의 주문 목록
      */
     @Transactional(readOnly = true)
-    public List<Order> findAllByUserId(Long userId) {
+    public List<Order> getOrdersByUserId(Long userId) {
         return orderRepository.findAllByUserId(userId);
     }
 
@@ -82,7 +87,7 @@ public List<Order> findAllByUserId(Long userId) {
      * @return 해당 상태의 주문 목록
      */
     @Transactional(readOnly = true)
-    public List<Order> findAllByStatus(OrderStatus status) {
+    public List<Order> getOrdersByStatus(OrderStatus status) {
         return orderRepository.findAllByStatus(status);
     }
 

apps/commerce-api/src/main/java/com/loopers/application/purchasing/PaymentRequestCommand.java → apps/commerce-api/src/main/java/com/loopers/application/payment/PaymentRequestCommand.java

@@ -1,4 +1,4 @@
-package com.loopers.application.purchasing;
+package com.loopers.application.payment;
 
 import com.loopers.support.error.CoreException;
 import com.loopers.support.error.ErrorType;