서비스 계층에 데이터소스 라우팅 어노테이션 추가 (#113)

f-lab-edu · Nov 6, 2023 · 7387fde · 7387fde
1 parent 5e3639c
commit 7387fde
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 0 deletions.
diff --git a/src/main/java/com/ayucoupon/coupon/service/ShowCouponsService.java b/src/main/java/com/ayucoupon/coupon/service/ShowCouponsService.java
@@ -1,5 +1,6 @@
 package com.ayucoupon.coupon.service;
 
+import com.ayucoupon.common.aop.multidatasource.DataSource;
 import com.ayucoupon.coupon.domain.CouponRepository;
 import lombok.RequiredArgsConstructor;
 import org.springframework.data.domain.PageRequest;
@@ -19,6 +20,7 @@ public class ShowCouponsService {
 
     private static final String COUPON_ID = "couponId";
 
+    @DataSource("secondary")
     public List<CouponDto> getCouponsInProgress(LocalDateTime currentTime, Pageable pageable) {
         Pageable pageRequest = PageRequest.of(
                 pageable.getPageNumber(),

diff --git a/src/main/java/com/ayucoupon/usercoupon/service/ShowUserCouponService.java b/src/main/java/com/ayucoupon/usercoupon/service/ShowUserCouponService.java
@@ -1,5 +1,6 @@
 package com.ayucoupon.usercoupon.service;
 
+import com.ayucoupon.common.aop.multidatasource.DataSource;
 import com.ayucoupon.coupon.domain.CouponRepository;
 import com.ayucoupon.coupon.domain.entity.Coupon;
 import com.ayucoupon.usercoupon.domain.UserCouponRepository;
@@ -26,6 +27,7 @@ public class ShowUserCouponService {
 
     private static final String USER_COUPON_ID = "userCouponId";
 
+    @DataSource("primary")
     public List<UserCouponDto> getUnexpiredUserCoupons(Long userId, LocalDateTime currentTime, Pageable pageable) {
         Pageable pageRequest = PageRequest.of(
                 pageable.getPageNumber(),

diff --git a/src/main/java/com/ayucoupon/usercoupon/service/UseUserCouponService.java b/src/main/java/com/ayucoupon/usercoupon/service/UseUserCouponService.java
@@ -1,6 +1,7 @@
 package com.ayucoupon.usercoupon.service;
 
 import com.ayucoupon.common.Money;
+import com.ayucoupon.common.aop.multidatasource.DataSource;
 import com.ayucoupon.common.exception.NotFoundUserCouponException;
 import com.ayucoupon.coupon.domain.CouponRepository;
 import com.ayucoupon.coupon.domain.entity.Coupon;
@@ -21,6 +22,7 @@ public class UseUserCouponService {
     private final CouponRepository couponRepository;
 
     @Transactional
+    @DataSource("primary")
     public Money use(UseUserCouponCommand command) {
         return applyUserCoupon(command);
     }

diff --git a/src/main/java/com/ayucoupon/usercoupon/service/issue/IssueUserCouponService.java b/src/main/java/com/ayucoupon/usercoupon/service/issue/IssueUserCouponService.java
@@ -1,5 +1,6 @@
 package com.ayucoupon.usercoupon.service.issue;
 
+import com.ayucoupon.common.aop.multidatasource.DataSource;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -12,6 +13,7 @@ public class IssueUserCouponService {
     private final IssueUserCouponModule issueUserCouponModule;
     private final IssueValidator issueValidator;
 
+    @DataSource("primary")
     public Long issue(IssueUserCouponCommand command) {
         issueValidator.validate(command);
         return issueUserCouponModule.issue(command);