[feat] 결제시 동일한 카트에 대한 중복 결제 문제

build.gradle

@@ -24,30 +24,34 @@ repositories {
 }
 
 dependencies {
-	implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
 	implementation 'org.springframework.boot:spring-boot-starter-thymeleaf'
 	implementation 'org.springframework.boot:spring-boot-starter-validation'
 	implementation 'org.springframework.boot:spring-boot-starter-web'
-	compileOnly 'org.projectlombok:lombok'
-	developmentOnly 'org.springframework.boot:spring-boot-devtools'
-	runtimeOnly 'com.h2database:h2'
-	runtimeOnly 'com.mysql:mysql-connector-j'
-	annotationProcessor 'org.projectlombok:lombok'
-	testImplementation 'org.springframework.boot:spring-boot-starter-test'
-	testRuntimeOnly 'org.junit.platform:junit-platform-launcher'
-
-    // https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-data-redis
-    implementation 'org.springframework.boot:spring-boot-starter-data-redis:3.3.3'
-    implementation 'org.redisson:redisson-spring-boot-starter:3.35.0'
-
-    // https://mvnrepository.com/artifact/com.github.codemonstur/embedded-redis
-    implementation 'com.github.codemonstur:embedded-redis:1.4.3'
-
+	// jpa
+	implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
 	// QueryDsl
 	implementation 'com.querydsl:querydsl-jpa:5.0.0:jakarta'
 	annotationProcessor "com.querydsl:querydsl-apt:${dependencyManagement.importedProperties['querydsl.version']}:jakarta"
 	annotationProcessor "jakarta.annotation:jakarta.annotation-api"
 	annotationProcessor "jakarta.persistence:jakarta.persistence-api"
+	// redis
+	implementation 'org.springframework.boot:spring-boot-starter-data-redis'
+	// redisson
+	implementation 'org.redisson:redisson-spring-boot-starter:3.35.0'
+	// lombok
+	compileOnly 'org.projectlombok:lombok'
+	annotationProcessor 'org.projectlombok:lombok'
+	// jdbc driver
+	runtimeOnly 'com.h2database:h2'
+	runtimeOnly 'com.mysql:mysql-connector-j'
+	// test
+	testImplementation 'org.springframework.boot:spring-boot-starter-test'
+	testRuntimeOnly 'org.junit.platform:junit-platform-launcher'
+	// embedded redis
+	implementation 'com.github.codemonstur:embedded-redis:1.4.3'
+	// actuator
+	implementation 'org.springframework.boot:spring-boot-starter-actuator'
+	implementation 'io.micrometer:micrometer-registry-prometheus'
 }
 
 tasks.named('test') {
@@ -72,4 +76,4 @@ compileJava.dependsOn clean
 // java source set 에 querydsl QClass 위치 추가
 sourceSets {
 	main.java.srcDirs += "$projectDir/build/generated"
-}
+}

src/main/java/camp/woowak/lab/cart/domain/Cart.java

@@ -16,6 +16,7 @@
 
 @Getter
 public class Cart {
+	private Long id;
 	private final String customerId;
 	private final List<CartItem> cartItems;
 
@@ -29,12 +30,16 @@ public Cart(String customerId) {
 	}
 
 	/**
-	 * 해당 Domain을 사용하는 같은 패키지내의 클래스, 혹은 자식 클래스는 List를 커스텀할 수 있습니다.
-	 *
 	 * @param customerId 장바구니 소유주의 ID값입니다.
 	 * @param cartItems   장바구니에 사용될 List입니다.
 	 */
-	protected Cart(String customerId, List<CartItem> cartItems) {
+	public Cart(String customerId, List<CartItem> cartItems) {
+		this.customerId = customerId;
+		this.cartItems = cartItems;
+	}
+
+	public Cart(Long id, String customerId, List<CartItem> cartItems) {
+		this.id = id;
 		this.customerId = customerId;
 		this.cartItems = cartItems;
 	}

src/main/java/camp/woowak/lab/cart/domain/vo/CartItem.java

@@ -2,7 +2,11 @@
 
 import java.util.Objects;
 
+import lombok.Getter;
+
+@Getter
 public class CartItem {
+	private Long id;
 	private final Long menuId;
 	private final Long storeId;
 	private final int amount;
@@ -13,20 +17,15 @@ public CartItem(Long menuId, Long storeId, Integer amount) {
 		this.amount = amount;
 	}
 
-	public Long getMenuId() {
-		return menuId;
-	}
-
-	public Long getStoreId() {
-		return storeId;
-	}
-
-	public int getAmount() {
-		return amount;
+	public CartItem(Long id, Long menuId, Long storeId, int amount) {
+		this.id = id;
+		this.menuId = menuId;
+		this.storeId = storeId;
+		this.amount = amount;
 	}
 
 	public CartItem add(Integer increment) {
-		return new CartItem(menuId, storeId, amount + increment);
+		return new CartItem(id, menuId, storeId, amount + increment);
 	}
 
 	@Override

src/main/java/camp/woowak/lab/cart/exception/CartErrorCode.java

@@ -7,7 +7,8 @@
 public enum CartErrorCode implements ErrorCode {
 	MENU_NOT_FOUND(HttpStatus.NOT_FOUND, "ca_1_1", "해당 메뉴가 존재하지 않습니다."),
 	OTHER_STORE_MENU(HttpStatus.BAD_REQUEST, "ca_1_2", "다른 매장의 메뉴는 등록할 수 없습니다."),
-	STORE_NOT_OPEN(HttpStatus.BAD_REQUEST, "ca_1_3", "주문 가능한 시간이 아닙니다.");
+	STORE_NOT_OPEN(HttpStatus.BAD_REQUEST, "ca_1_3", "주문 가능한 시간이 아닙니다."),
+	NOT_FOUND(HttpStatus.BAD_REQUEST, "ca_2_1", "카트에 담긴 상품이 없습니다.");
 
 	private final int status;
 	private final String errorCode;

src/main/java/camp/woowak/lab/cart/exception/NotFoundCartException.java

@@ -0,0 +1,9 @@
+package camp.woowak.lab.cart.exception;
+
+import camp.woowak.lab.common.exception.BadRequestException;
+
+public class NotFoundCartException extends BadRequestException {
+	public NotFoundCartException(String message) {
+		super(CartErrorCode.NOT_FOUND, message);
+	}
+}

src/main/java/camp/woowak/lab/cart/persistence/jpa/entity/CartEntity.java

@@ -0,0 +1,45 @@
+package camp.woowak.lab.cart.persistence.jpa.entity;
+
+import java.util.List;
+import java.util.UUID;
+import java.util.stream.Collectors;
+
+import camp.woowak.lab.cart.domain.Cart;
+import camp.woowak.lab.cart.domain.vo.CartItem;
+import jakarta.persistence.CascadeType;
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import jakarta.persistence.OneToMany;
+import lombok.AccessLevel;
+import lombok.NoArgsConstructor;
+
+@Entity
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+public class CartEntity {
+	@Id
+	@GeneratedValue(strategy = GenerationType.IDENTITY)
+	private Long id;
+	@Column(unique = true, nullable = false)
+	private UUID customerId;
+	@OneToMany(mappedBy = "cart", cascade = CascadeType.ALL, orphanRemoval = true)
+	private List<CartItemEntity> cartItems;
+
+	public Cart toDomain() {
+		List<CartItem> cartItems = this.cartItems.stream().map(CartItemEntity::toDomain).collect(Collectors.toList());
+		return new Cart(id, customerId.toString(), cartItems);
+	}
+
+	public static CartEntity fromDomain(Cart cart) {
+		CartEntity entity = new CartEntity();
+		entity.id = cart.getId();
+		entity.customerId = UUID.fromString(cart.getCustomerId());
+		entity.cartItems = cart.getCartItems()
+			.stream()
+			.map((cartItem) -> CartItemEntity.fromDomain(entity, cartItem))
+			.collect(Collectors.toList());
+		return entity;
+	}
+}

src/main/java/camp/woowak/lab/cart/persistence/jpa/entity/CartItemEntity.java

@@ -0,0 +1,35 @@
+package camp.woowak.lab.cart.persistence.jpa.entity;
+
+import camp.woowak.lab.cart.domain.vo.CartItem;
+import jakarta.persistence.Entity;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import jakarta.persistence.ManyToOne;
+
+@Entity
+public class CartItemEntity {
+	@Id
+	@GeneratedValue(strategy = GenerationType.IDENTITY)
+	private Long id;
+	private Long menuId;
+	private Long storeId;
+	private int amount;
+
+	@ManyToOne
+	private CartEntity cart;
+
+	public CartItem toDomain() {
+		return new CartItem(id, menuId, storeId, amount);
+	}
+
+	public static CartItemEntity fromDomain(CartEntity cartEntity, CartItem cartItem) {
+		CartItemEntity entity = new CartItemEntity();
+		entity.id = cartItem.getId();
+		entity.menuId = cartItem.getMenuId();
+		entity.storeId = cartItem.getStoreId();
+		entity.amount = cartItem.getAmount();
+		entity.cart = cartEntity;
+		return entity;
+	}
+}

src/main/java/camp/woowak/lab/cart/persistence/jpa/repository/CartEntityRepository.java

@@ -0,0 +1,12 @@
+package camp.woowak.lab.cart.persistence.jpa.repository;
+
+import java.util.Optional;
+import java.util.UUID;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+
+import camp.woowak.lab.cart.persistence.jpa.entity.CartEntity;
+
+public interface CartEntityRepository extends JpaRepository<CartEntity, Long> {
+	Optional<CartEntity> findByCustomerId(UUID customerId);
+}

src/main/java/camp/woowak/lab/cart/persistence/jpa/repository/JpaCartRepository.java

@@ -0,0 +1,43 @@
+package camp.woowak.lab.cart.persistence.jpa.repository;
+
+import java.util.Optional;
+import java.util.UUID;
+
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.stereotype.Repository;
+
+import camp.woowak.lab.cart.domain.Cart;
+import camp.woowak.lab.cart.persistence.jpa.entity.CartEntity;
+import camp.woowak.lab.cart.repository.CartRepository;
+
+@Repository
+@ConditionalOnProperty(name="cart.repository", havingValue = "jpa")
+public class JpaCartRepository implements CartRepository {
+	private final CartEntityRepository entityRepository;
+
+	public JpaCartRepository(CartEntityRepository entityRepository) {
+		this.entityRepository = entityRepository;
+	}
+
+	@Override
+	public Optional<Cart> findByCustomerId(String customerId) {
+		Optional<CartEntity> entity = entityRepository.findByCustomerId(UUID.fromString(customerId));
+		if (entity.isEmpty()) {
+			return Optional.empty();
+		}
+		return entity.map(CartEntity::toDomain);
+	}
+
+	@Override
+	public Cart save(Cart cart) {
+		CartEntity entity = CartEntity.fromDomain(cart);
+		CartEntity save = entityRepository.save(entity);
+		return save.toDomain();
+	}
+
+	@Override
+	public void delete(Cart cart) {
+		CartEntity cartEntity = CartEntity.fromDomain(cart);
+		entityRepository.delete(cartEntity);
+	}
+}

src/main/java/camp/woowak/lab/cart/persistence/redis/entity/RedisCartEntity.java

@@ -0,0 +1,44 @@
+package camp.woowak.lab.cart.persistence.redis.entity;
+
+import java.io.Serializable;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.stream.Collectors;
+
+import org.springframework.data.annotation.Id;
+import org.springframework.data.redis.core.RedisHash;
+
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+import camp.woowak.lab.cart.domain.Cart;
+import lombok.Getter;
+
+@RedisHash("cart")
+@Getter
+public class RedisCartEntity implements Serializable {
+	@Id
+	private String customerId;
+
+	private List<RedisCartItemEntity> cartItems;
+
+	@JsonCreator
+	private RedisCartEntity(@JsonProperty("customerId") String customerId,
+							@JsonProperty("cartItems") List<RedisCartItemEntity> cartItems) {
+		this.customerId = customerId;
+		this.cartItems = cartItems == null ? new ArrayList<>() : cartItems;
+	}
+
+	public static RedisCartEntity fromDomain(Cart cart) {
+		List<RedisCartItemEntity> list = cart.getCartItems().stream()
+			.map(RedisCartItemEntity::fromDomain)
+			.collect(Collectors.toList());
+		return new RedisCartEntity(cart.getCustomerId(), list);
+	}
+
+	public Cart toDomain() {
+		return new Cart(customerId, cartItems.stream()
+			.map(RedisCartItemEntity::toDomain)
+			.collect(Collectors.toList()));
+	}
+}

src/main/java/camp/woowak/lab/cart/persistence/redis/entity/RedisCartItemEntity.java

@@ -0,0 +1,33 @@
+package camp.woowak.lab.cart.persistence.redis.entity;
+
+import java.io.Serializable;
+
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+import camp.woowak.lab.cart.domain.vo.CartItem;
+import lombok.Getter;
+
+@Getter
+public class RedisCartItemEntity implements Serializable {
+	private Long menuId;
+	private Long storeId;
+	private int amount;
+
+	@JsonCreator
+	private RedisCartItemEntity(@JsonProperty("menuId") Long menuId,
+								@JsonProperty("storeId") Long storeId,
+								@JsonProperty("amount") int amount) {
+		this.menuId = menuId;
+		this.storeId = storeId;
+		this.amount = amount;
+	}
+
+	protected static RedisCartItemEntity fromDomain(CartItem item) {
+		return new RedisCartItemEntity(item.getMenuId(), item.getStoreId(), item.getAmount());
+	}
+
+	protected CartItem toDomain() {
+		return new CartItem(menuId, storeId, amount);
+	}
+}

src/main/java/camp/woowak/lab/cart/persistence/redis/repository/RedisCartRepository.java

@@ -0,0 +1,29 @@
+package camp.woowak.lab.cart.persistence.redis.repository;
+
+import java.util.Optional;
+
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.data.repository.CrudRepository;
+
+import camp.woowak.lab.cart.domain.Cart;
+import camp.woowak.lab.cart.persistence.redis.entity.RedisCartEntity;
+import camp.woowak.lab.cart.repository.CartRepository;
+
+@ConditionalOnProperty(name = "cart.repository", havingValue = "redis")
+public interface RedisCartRepository extends CrudRepository<RedisCartEntity, String>, CartRepository {
+	@Override
+	default Optional<Cart> findByCustomerId(String customerId) {
+		return findById(customerId).map(RedisCartEntity::toDomain);
+	}
+
+	@Override
+	default Cart save(Cart cart) {
+		RedisCartEntity entity = RedisCartEntity.fromDomain(cart);
+		return save(entity).toDomain();
+	}
+
+	@Override
+	default void delete(Cart cart) {
+		deleteById(cart.getCustomerId());
+	}
+}