[#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,42 @@
+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.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.PutMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+
+@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("/items/new")
+    public ResponseEntity addItem(@CurrentUser AccountDto accountDto, @RequestBody CartItem cartItem) {
+        return ResponseEntity.ok(cartService.addItem(String.valueOf(accountDto.getEmail()), cartItem));
+    }
+
+    @PutMapping("/items")
+    public ResponseEntity removeItem(@CurrentUser AccountDto accountDto, @RequestBody CartItem cartItem) {
+        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/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,77 @@
+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.dao.DataAccessException;
+import org.springframework.data.redis.core.RedisOperations;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.core.SessionCallback;
+import org.springframework.stereotype.Service;
+
+import javax.persistence.EntityNotFoundException;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@Service
+@RequiredArgsConstructor
+public class CartService {
+    private final CartRedisRepository cartRedisRepository;
+    private final RedisTemplate redisTemplate;
+
+    public Cart getCart(String id) {
+        return cartRedisRepository.findById(id).orElseThrow(EntityNotFoundException::new);
+    }
+
+    public Cart addItem(String id, CartItem cartItem) {
+
+        final String key = String.format("cart:%s", id);
+        // "_class", "id" 필드를 제외하고 "cartItemList[n]" 의 필드개수 6개로 나누어주면 상품개수
+        int cartItemSize = (int)((redisTemplate.opsForHash().size(key) - 2) / 6);
+        boolean hasKey = redisTemplate.hasKey(key);
+        final Map<String, Object> map;
+
+        if (hasKey) {
+            map = convertCartItemToMap(cartItemSize,cartItem);
+        } else {
+            map = convertCartItemToMap(0,cartItem);
+        }
+
+        redisTemplate.execute(new SessionCallback() {
+            @Override
+            public Object execute(RedisOperations redisOperations) throws DataAccessException {
+                redisOperations.watch(key);
+                redisOperations.multi();
+                redisOperations.opsForHash().putAll(key,map);
+                return redisOperations.exec();
+            }
+        });
+
+        return getCart(id);
+    }
+
+    private Map<String, Object> convertCartItemToMap(int size, CartItem cartItem) {
+        Map<String, Object> map = new HashMap<>();
+        map.put(String.format("cartItemList.[%d].item.id", size), cartItem.getItem().getId());
+        map.put(String.format("cartItemList.[%d].item.name", size), cartItem.getItem().getName());
+        map.put(String.format("cartItemList.[%d].item.price", size), cartItem.getItem().getPrice());
+        map.put(String.format("cartItemList.[%d].item.stockQuantity", size), cartItem.getItem().getStockQuantity());
+        map.put(String.format("cartItemList.[%d].price", size), cartItem.getPrice());
+        map.put(String.format("cartItemList.[%d].quantity", size), cartItem.getQuantity());
+        return map;
+    }
+
+    public Cart removeItem(String id, CartItem cartItem) {
+        Cart cart = getCart(id);
+        List<CartItem> cartItemList = cart.getCartItemList();
+        cartItemList.remove(cartItem);
+
+        return cartRedisRepository.save(cart);
+    }
+
+    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