[#26] 장바구니 도메인 추가

src/main/java/me/jjeda/mall/cart/configs/RedisConfig.java

@@ -0,0 +1,41 @@
+package me.jjeda.mall.cart.configs;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.repository.configuration.EnableRedisRepositories;
+import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
+import org.springframework.data.redis.serializer.StringRedisSerializer;
+
+@Configuration
+@EnableRedisRepositories
+public class RedisConfig {
+    @Value("${spring.redis.host}")
+    private String redisHost;
+
+    @Value("${spring.redis.port}")
+    private int redisPort;
+
+    @Bean
+    public RedisConnectionFactory redisConnectionFactory() {
+        return new LettuceConnectionFactory(redisHost, redisPort);
+    }
+
+    @Bean
+    public RedisTemplate<?, ?> redisTemplate(RedisConnectionFactory redisConnectionFactory, ObjectMapper objectMapper) {
+        GenericJackson2JsonRedisSerializer serializer = new GenericJackson2JsonRedisSerializer(objectMapper);
+        RedisTemplate<byte[], byte[]> redisTemplate = new RedisTemplate<>();
+
+        redisTemplate.setConnectionFactory(redisConnectionFactory);
+        redisTemplate.setKeySerializer(new StringRedisSerializer());
+        redisTemplate.setValueSerializer(serializer);
+        redisTemplate.setHashKeySerializer(new StringRedisSerializer());
+        redisTemplate.setHashValueSerializer(serializer);
+
+        return redisTemplate;
+    }
+}

src/main/java/me/jjeda/mall/cart/controller/CartController.java

@@ -0,0 +1,47 @@
+package me.jjeda.mall.cart.controller;
+
+import lombok.RequiredArgsConstructor;
+import me.jjeda.mall.accounts.dto.AccountDto;
+import me.jjeda.mall.cart.domain.CartItem;
+import me.jjeda.mall.cart.domain.CartModifyType;
+import me.jjeda.mall.cart.service.CartService;
+import me.jjeda.mall.common.CurrentUser;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.DeleteMapping;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.PutMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+
+import java.util.Objects;
+
+@Controller
+@RequiredArgsConstructor
+@RequestMapping("/api/carts")
+public class CartController {
+    private final CartService cartService;
+
+    @GetMapping
+    public ResponseEntity getCart(@CurrentUser AccountDto accountDto) {
+        return ResponseEntity.ok(cartService.getCart(String.valueOf(accountDto.getEmail())));
+    }
+
+    @PutMapping
+    public ResponseEntity modifyCart(@CurrentUser AccountDto accountDto, @RequestBody CartItem cartItem,
+                                  @RequestParam CartModifyType cartModifyType) {
+
+        if(Objects.equals(cartModifyType,CartModifyType.ADD)) {
+            return ResponseEntity.ok(cartService.addItem(String.valueOf(accountDto.getEmail()), cartItem));
+        } else {
+            return ResponseEntity.ok(cartService.removeItem(String.valueOf(accountDto.getEmail()), cartItem));
+        }
+    }
+    @DeleteMapping
+    public ResponseEntity deleteCart(@CurrentUser AccountDto accountDto) {
+        cartService.deleteCart(String.valueOf(accountDto.getId()));
+        return ResponseEntity.ok().build();
+    }
+}

src/main/java/me/jjeda/mall/cart/domain/Cart.java

@@ -0,0 +1,34 @@
+package me.jjeda.mall.cart.domain;
+
+import lombok.AccessLevel;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import org.springframework.data.annotation.Id;
+import org.springframework.data.redis.core.RedisHash;
+
+import java.util.ArrayList;
+import java.util.List;
+
+@Getter
+@Builder
+@RedisHash("cart")
+@NoArgsConstructor(access = AccessLevel.PACKAGE)
+@AllArgsConstructor(access = AccessLevel.PACKAGE)
+public class Cart {
+
+    @Id
+    private String id;
+
+    private List<CartItem> cartItemList;
+
+    private Cart(String id) {
+        this.id = id;
+        this.cartItemList = new ArrayList<>();
+    }
+
+    public static Cart of(String id) {
+        return new Cart(id);
+    }
+}

src/main/java/me/jjeda/mall/cart/domain/CartItem.java

@@ -0,0 +1,18 @@
+package me.jjeda.mall.cart.domain;
+
+import lombok.AccessLevel;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.EqualsAndHashCode;
+import lombok.Getter;
+import me.jjeda.mall.items.domain.Item;
+
+@Getter
+@EqualsAndHashCode
+@Builder
+@AllArgsConstructor(access = AccessLevel.PACKAGE)
+public class CartItem {
+    private Item item;
+    private int price;
+    private int quantity;
+}

src/main/java/me/jjeda/mall/cart/domain/CartModifyType.java

@@ -0,0 +1,5 @@
+package me.jjeda.mall.cart.domain;
+
+public enum CartModifyType {
+    ADD, REMOVE
+}

src/main/java/me/jjeda/mall/cart/repository/CartRedisRepository.java

@@ -0,0 +1,7 @@
+package me.jjeda.mall.cart.repository;
+
+import me.jjeda.mall.cart.domain.Cart;
+import org.springframework.data.repository.CrudRepository;
+
+public interface CartRedisRepository extends CrudRepository<Cart, String> {
+}

src/main/java/me/jjeda/mall/cart/service/CartService.java

@@ -0,0 +1,51 @@
+package me.jjeda.mall.cart.service;
+
+import lombok.RequiredArgsConstructor;
+import me.jjeda.mall.cart.domain.Cart;
+import me.jjeda.mall.cart.domain.CartItem;
+import me.jjeda.mall.cart.repository.CartRedisRepository;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import javax.persistence.EntityNotFoundException;
+import java.util.List;
+
+@Service
+@RequiredArgsConstructor
+public class CartService {
+    private final CartRedisRepository cartRedisRepository;
+
+    @Transactional(readOnly = true)
+    public Cart getCart(String id) {
+        return cartRedisRepository.findById(id).orElseThrow(EntityNotFoundException::new);
+    }
+
+    @Transactional
+    public Cart addItem(String id, CartItem cartItem) {
+        final Cart cart;
+
+        if (!cartRedisRepository.existsById(id)) {
+            cart = Cart.of(id);
+        } else {
+            cart = getCart(id);
+        }
+
+        List<CartItem> cartItemList = cart.getCartItemList();
+        cartItemList.add(cartItem);
+        return cartRedisRepository.save(cart);
+    }
+
+    @Transactional
+    public Cart removeItem(String id, CartItem cartItem) {
+        final Cart cart = getCart(id);
+        List<CartItem> cartItemList = cart.getCartItemList();
+        cartItemList.remove(cartItem);
+
+        return cartRedisRepository.save(cart);
+    }
+
+    @Transactional
+    public void deleteCart(String id) {
+        cartRedisRepository.delete(getCart(id));
+    }
+}

src/main/java/me/jjeda/mall/items/domain/Item.java

@@ -3,6 +3,7 @@
 import lombok.AccessLevel;
 import lombok.AllArgsConstructor;
 import lombok.Builder;
+import lombok.EqualsAndHashCode;
 import lombok.Getter;
 import lombok.NoArgsConstructor;
 import lombok.Setter;
@@ -22,6 +23,7 @@
 @Entity
 @Getter @Setter
 @Builder
+@EqualsAndHashCode
 @NoArgsConstructor(access = AccessLevel.PROTECTED)
 @AllArgsConstructor(access = AccessLevel.PROTECTED)
 public class Item {

src/main/resources/application.properties

@@ -1,2 +1,3 @@
 spring.redis.port=6379
+spring.redis.host=localhost