[4주차] 쿠폰 신규 도메인 개발, 동시성 제어 및트랜잭션 관리 - 안성훈

apps/commerce-api/src/main/java/com/loopers/application/brand/BrandAdminFacade.java

@@ -6,6 +6,7 @@
 import org.springframework.stereotype.Component;
 
 import java.util.List;
+import java.util.UUID;
 
 @Component
 @RequiredArgsConstructor
@@ -15,8 +16,8 @@ public class BrandAdminFacade {
     private final ProductApplicationService productApplicationService;
     private final LikeApplicationService likeApplicationService;
 
-    public void delete(Long brandId) {
-        List<Long> productIds = productApplicationService.findActiveProductIdsByBrandId(brandId);
+    public void delete(UUID brandId) {
+        List<UUID> productIds = productApplicationService.findActiveProductIdsByBrandId(brandId);
         likeApplicationService.deleteByProductIds(productIds);
         productApplicationService.deleteSoftByBrandId(brandId);
         brandApplicationService.delete(brandId);

apps/commerce-api/src/main/java/com/loopers/application/brand/BrandApplicationService.java

@@ -17,6 +17,7 @@
 import java.util.Collection;
 import java.util.Map;
 import java.util.stream.Collectors;
+import java.util.UUID;
 
 @Service
 @RequiredArgsConstructor
@@ -42,7 +43,7 @@ public Brand create(CreateBrandCommand command) {
     }
 
     @Transactional(readOnly = true)
-    public Brand findById(Long id) {
+    public Brand findById(UUID id) {
         return brandRepository.findById(id)
                 .orElseThrow(() -> new CoreException(ErrorType.NOT_FOUND, "브랜드를 찾을 수 없습니다."));
     }
@@ -53,7 +54,7 @@ public Page<Brand> list(Pageable pageable) {
     }
 
     @Transactional(readOnly = true)
-    public Map<Long, String> findNamesByIds(Collection<Long> brandIds) {
+    public Map<UUID, String> findNamesByIds(Collection<UUID> brandIds) {
         return brandIds.stream()
                 .distinct()
                 .collect(Collectors.toMap(
@@ -65,7 +66,7 @@ public Map<Long, String> findNamesByIds(Collection<Long> brandIds) {
     }
 
     @Transactional
-    public Brand update(Long id, UpdateBrandCommand command) {
+    public Brand update(UUID id, UpdateBrandCommand command) {
         Brand brand = brandRepository.findById(id)
                 .orElseThrow(() -> new CoreException(ErrorType.NOT_FOUND, "브랜드를 찾을 수 없습니다."));
 
@@ -74,7 +75,7 @@ public Brand update(Long id, UpdateBrandCommand command) {
     }
 
     @Transactional
-    public void delete(Long id) {
+    public void delete(UUID id) {
         Brand brand = brandRepository.findById(id)
                 .orElseThrow(() -> new CoreException(ErrorType.NOT_FOUND, "브랜드를 찾을 수 없습니다."));
         brandRepository.delete(brand);

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

@@ -0,0 +1,76 @@
+package com.loopers.application.coupon;
+
+import com.loopers.application.coupon.command.CreateCouponCommand;
+import com.loopers.application.coupon.command.UpdateCouponCommand;
+import com.loopers.application.coupon.view.CouponIssueView;
+import com.loopers.domain.coupon.Coupon;
+import com.loopers.domain.coupon.CouponRepository;
+import com.loopers.domain.coupon.IssuedCouponRepository;
+import com.loopers.support.error.CoreException;
+import com.loopers.support.error.ErrorType;
+import lombok.RequiredArgsConstructor;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.UUID;
+
+@Service
+@RequiredArgsConstructor
+public class CouponAdminApplicationService {
+
+    private final CouponRepository couponRepository;
+    private final IssuedCouponRepository issuedCouponRepository;
+
+    @Transactional(readOnly = true)
+    public Page<Coupon> list(Pageable pageable) {
+        return couponRepository.findAll(pageable);
+    }
+
+    @Transactional(readOnly = true)
+    public Coupon findById(UUID couponId) {
+        return couponRepository.findById(couponId)
+                .orElseThrow(() -> new CoreException(ErrorType.BAD_REQUEST, "쿠폰을 찾을 수 없습니다."));
+    }
+
+    @Transactional
+    public Coupon create(CreateCouponCommand command) {
+        Coupon coupon = new Coupon(
+                command.name(),
+                command.type(),
+                command.value(),
+                command.minOrderAmount(),
+                command.expiredAt()
+        );
+        return couponRepository.save(coupon);
+    }
+
+    @Transactional
+    public Coupon update(UUID couponId, UpdateCouponCommand command) {
+        Coupon coupon = couponRepository.findById(couponId)
+                .orElseThrow(() -> new CoreException(ErrorType.BAD_REQUEST, "쿠폰을 찾을 수 없습니다."));
+        Coupon updated = coupon.update(
+                command.name(),
+                command.type(),
+                command.value(),
+                command.minOrderAmount(),
+                command.expiredAt()
+        );
+        return couponRepository.save(updated);
+    }
+
+    @Transactional
+    public void delete(UUID couponId) {
+        Coupon coupon = couponRepository.findById(couponId)
+                .orElseThrow(() -> new CoreException(ErrorType.BAD_REQUEST, "쿠폰을 찾을 수 없습니다."));
+        couponRepository.delete(coupon);
+    }
+
+    @Transactional(readOnly = true)
+    public Page<CouponIssueView> listIssues(UUID couponId, Pageable pageable) {
+        couponRepository.findById(couponId)
+                .orElseThrow(() -> new CoreException(ErrorType.BAD_REQUEST, "쿠폰을 찾을 수 없습니다."));
+        return issuedCouponRepository.findByCouponId(couponId, pageable).map(CouponIssueView::from);
+    }
+}

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

@@ -0,0 +1,114 @@
+package com.loopers.application.coupon;
+
+import com.loopers.application.coupon.command.UseCouponCommand;
+import com.loopers.application.coupon.view.MyCouponView;
+import com.loopers.domain.coupon.Coupon;
+import com.loopers.domain.coupon.CouponRepository;
+import com.loopers.domain.coupon.CouponStatus;
+import com.loopers.domain.coupon.IssuedCoupon;
+import com.loopers.domain.coupon.IssuedCouponRepository;
+import com.loopers.support.error.CoreException;
+import com.loopers.support.error.ErrorType;
+import lombok.RequiredArgsConstructor;
+import org.springframework.dao.DataIntegrityViolationException;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.time.LocalDateTime;
+import java.util.List;
+import java.util.Map;
+import java.util.UUID;
+
+@Service
+@RequiredArgsConstructor
+public class CouponApplicationService {
+
+    private final CouponRepository couponRepository;
+    private final IssuedCouponRepository issuedCouponRepository;
+
+    @Transactional
+    public void issue(UUID couponId, String memberId) {
+        Coupon coupon = couponRepository.findById(couponId)
+                .orElseThrow(() -> new CoreException(ErrorType.NOT_FOUND, "쿠폰을 찾을 수 없습니다."));
+
+        if (!coupon.isUsableAt(LocalDateTime.now())) {
+            throw new CoreException(ErrorType.BAD_REQUEST, "만료된 쿠폰은 발급할 수 없습니다.");
+        }
+
+        IssuedCoupon issuedCoupon = new IssuedCoupon(
+                memberId,
+                couponId,
+                CouponStatus.AVAILABLE,
+                LocalDateTime.now(),
+                coupon.expiredAt(),
+                null
+        );
+
+        try {
+            issuedCouponRepository.save(issuedCoupon);
+        } catch (DataIntegrityViolationException e) {
+            throw new CoreException(ErrorType.CONFLICT, "이미 발급된 쿠폰입니다.");
+        }
+    }
+
+    @Transactional(readOnly = true)
+    public List<MyCouponView> listMyCoupons(String memberId) {
+        List<IssuedCoupon> issuedCoupons = issuedCouponRepository.findByMemberId(memberId);
+        if (issuedCoupons.isEmpty()) {
+            return List.of();
+        }
+
+        List<UUID> couponIds = issuedCoupons.stream().map(IssuedCoupon::couponId).distinct().toList();
+        Map<UUID, Coupon> couponsById = couponRepository.findAllMapByIdIn(couponIds);
+        LocalDateTime now = LocalDateTime.now();
+
+        return issuedCoupons.stream()
+                .map(issued -> {
+                    Coupon coupon = couponsById.get(issued.couponId());
+                    if (coupon == null) {
+                        throw new CoreException(ErrorType.NOT_FOUND, "쿠폰을 찾을 수 없습니다.");
+                    }
+                    return new MyCouponView(
+                            issued.couponId(),
+                            coupon.name(),
+                            coupon.type(),
+                            coupon.value(),
+                            coupon.minOrderAmount(),
+                            issued.expiredAt(),
+                            issued.resolveStatusAt(now)
+                    );
+                })
+                .toList();
+    }
+
+    @Transactional
+    public void use(UseCouponCommand command) {
+        IssuedCoupon issuedCoupon = issuedCouponRepository.findByMemberIdAndCouponId(command.memberId(), command.couponId())
+                .orElseThrow(() -> new CoreException(ErrorType.NOT_FOUND, "발급된 쿠폰을 찾을 수 없습니다."));
+
+        Coupon coupon = couponRepository.findById(command.couponId())
+                .orElseThrow(() -> new CoreException(ErrorType.NOT_FOUND, "쿠폰을 찾을 수 없습니다."));
+
+        issuedCoupon.validateOwner(command.memberId());
+        if (command.orderAmount() < coupon.minOrderAmount()) {
+            throw new CoreException(ErrorType.BAD_REQUEST, "최소 주문 금액 미달로 쿠폰을 사용할 수 없습니다.");
+        }
+
+        int updatedCount = issuedCouponRepository.markUsedAtomically(command.memberId(), command.couponId(), LocalDateTime.now());
+        if (updatedCount == 0) {
+            throw new CoreException(ErrorType.CONFLICT, "이미 사용되었거나 만료된 쿠폰입니다.");
+        }
+    }
+
+    @Transactional
+    public void cancelUse(UUID couponId, String memberId) {
+        IssuedCoupon issuedCoupon = issuedCouponRepository.findByMemberIdAndCouponId(memberId, couponId)
+                .orElseThrow(() -> new CoreException(ErrorType.NOT_FOUND, "발급된 쿠폰을 찾을 수 없습니다."));
+
+        issuedCoupon.validateOwner(memberId);
+        int updatedCount = issuedCouponRepository.markAvailableAtomically(memberId, couponId, LocalDateTime.now());
+        if (updatedCount == 0) {
+            throw new CoreException(ErrorType.CONFLICT, "사용 취소할 수 없는 쿠폰입니다.");
+        }
+    }
+}

apps/commerce-api/src/main/java/com/loopers/application/category/CategoryApplicationService.java → apps/commerce-api/src/main/java/com/loopers/application/coupon/category/CategoryApplicationService.java

@@ -1,4 +1,4 @@
-package com.loopers.application.category;
+package com.loopers.application.coupon.category;
 
 import com.loopers.domain.category.Category;
 import com.loopers.domain.category.CategoryRepository;
@@ -8,13 +8,14 @@
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.Pageable;
 import org.springframework.stereotype.Service;
+import java.util.UUID;
 
 @Service
 @RequiredArgsConstructor
 public class CategoryApplicationService {
     private final CategoryRepository categoryRepository;
 
-    public Category findById(Long categoryId) {
+    public Category findById(UUID categoryId) {
         return categoryRepository.findById(categoryId)
                 .orElseThrow(() -> new CoreException(ErrorType.BAD_REQUEST, "카테고리를 찾을 수 없습니다."));
     }

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

@@ -0,0 +1,14 @@
+package com.loopers.application.coupon.command;
+
+import com.loopers.domain.coupon.CouponType;
+
+import java.time.LocalDateTime;
+
+public record CreateCouponCommand(
+        String name,
+        CouponType type,
+        int value,
+        int minOrderAmount,
+        LocalDateTime expiredAt
+) {
+}

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

@@ -0,0 +1,14 @@
+package com.loopers.application.coupon.command;
+
+import com.loopers.domain.coupon.CouponType;
+
+import java.time.LocalDateTime;
+
+public record UpdateCouponCommand(
+        String name,
+        CouponType type,
+        int value,
+        int minOrderAmount,
+        LocalDateTime expiredAt
+) {
+}

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

@@ -0,0 +1,24 @@
+package com.loopers.application.coupon.command;
+
+import com.loopers.support.error.CoreException;
+import com.loopers.support.error.ErrorType;
+
+import java.util.UUID;
+
+public record UseCouponCommand(
+        UUID couponId,
+        String memberId,
+        int orderAmount
+) {
+    public UseCouponCommand {
+        if (couponId == null) {
+            throw new CoreException(ErrorType.BAD_REQUEST, "쿠폰 ID는 필수입니다.");
+        }
+        if (memberId == null || memberId.isBlank()) {
+            throw new CoreException(ErrorType.BAD_REQUEST, "회원 식별자는 필수입니다.");
+        }
+        if (orderAmount < 0) {
+            throw new CoreException(ErrorType.BAD_REQUEST, "주문 금액은 0 이상이어야 합니다.");
+        }
+    }
+}

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

@@ -0,0 +1,27 @@
+package com.loopers.application.coupon.view;
+
+import com.loopers.domain.coupon.CouponStatus;
+import com.loopers.domain.coupon.IssuedCoupon;
+
+import java.time.LocalDateTime;
+import java.util.UUID;
+
+public record CouponIssueView(
+        UUID couponId,
+        String memberId,
+        CouponStatus status,
+        LocalDateTime issuedAt,
+        LocalDateTime expiredAt,
+        LocalDateTime usedAt
+) {
+    public static CouponIssueView from(IssuedCoupon issuedCoupon) {
+        return new CouponIssueView(
+                issuedCoupon.couponId(),
+                issuedCoupon.memberId(),
+                issuedCoupon.status(),
+                issuedCoupon.issuedAt(),
+                issuedCoupon.expiredAt(),
+                issuedCoupon.usedAt()
+        );
+    }
+}

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

@@ -0,0 +1,18 @@
+package com.loopers.application.coupon.view;
+
+import com.loopers.domain.coupon.CouponStatus;
+import com.loopers.domain.coupon.CouponType;
+
+import java.time.LocalDateTime;
+import java.util.UUID;
+
+public record MyCouponView(
+        UUID couponId,
+        String name,
+        CouponType type,
+        int value,
+        int minOrderAmount,
+        LocalDateTime expiredAt,
+        CouponStatus status
+) {
+}