feat: 조회 비관적 락 메서드 추가

Author: rnqhstmd

apps/commerce-api/src/main/java/com/loopers/domain/payment/PaymentRepository.java

@@ -8,6 +8,7 @@ public interface PaymentRepository {
     Optional<Payment> findById(Long id);
     Optional<Payment> findByOrderId(Long orderId);
     Optional<Payment> findByTransactionId(String transactionId);
+    Optional<Payment> findByTransactionIdWithLock(String transactionId);
     Optional<Payment> findByIdempotencyKey(String idempotencyKey);
     List<Payment> findByStatus(PaymentStatus status);
 }

apps/commerce-api/src/main/java/com/loopers/infrastructure/payment/PaymentJpaRepository.java

@@ -2,7 +2,9 @@
 
 import com.loopers.domain.payment.Payment;
 import com.loopers.domain.payment.PaymentStatus;
+import jakarta.persistence.LockModeType;
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Lock;
 import org.springframework.data.jpa.repository.Query;
 import org.springframework.data.repository.query.Param;
 
@@ -19,4 +21,8 @@ public interface PaymentJpaRepository extends JpaRepository<Payment, Long> {
 
     @Query("SELECT p FROM Payment p WHERE p.status = :status ORDER BY p.createdAt ASC")
     List<Payment> findByStatus(@Param("status") PaymentStatus status);
+
+    @Lock(LockModeType.PESSIMISTIC_WRITE)
+    @Query("SELECT p FROM Payment p WHERE p.transactionId = :transactionId")
+    Optional<Payment> findByTransactionIdWithLock(@Param("transactionId") String transactionId);
 }

apps/commerce-api/src/main/java/com/loopers/infrastructure/payment/PaymentRepositoryImpl.java

@@ -35,6 +35,11 @@ public Optional<Payment> findByTransactionId(String transactionId) {
         return jpaRepository.findByTransactionId(transactionId);
     }
 
+    @Override
+    public Optional<Payment> findByTransactionIdWithLock(String transactionId) {
+        return jpaRepository.findByTransactionIdWithLock(transactionId);
+    }
+
     @Override
     public Optional<Payment> findByIdempotencyKey(String idempotencyKey) {
         return jpaRepository.findByIdempotencyKey(idempotencyKey);