[3주차] Cart App #1

build.gradle.kts

@@ -19,6 +19,9 @@ dependencies {
     implementation("org.springframework.boot:spring-boot-starter-web")
     implementation("org.springframework.boot:spring-boot-starter-validation")
 
+    implementation("org.mongodb:mongodb-driver-core:5.3.1")
+    implementation("org.mongodb:mongodb-driver-sync:5.3.1")
+
     developmentOnly("org.springframework.boot:spring-boot-devtools")
 
     testImplementation("org.springframework.boot:spring-boot-starter-test")

src/main/java/com/example/demo/Application.java

@@ -1,11 +1,25 @@
 package com.example.demo;
 
+import com.mongodb.client.MongoClient;
+import com.mongodb.client.MongoClients;
+import com.mongodb.client.MongoDatabase;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.annotation.Bean;
 
 @SpringBootApplication
 public class Application {
     public static void main(String[] args) {
         SpringApplication.run(Application.class, args);
     }
+
+    @Bean
+    public MongoClient mongoClient() {
+        return MongoClients.create("mongodb://localhost:27017");
+    }
+
+    @Bean
+    public MongoDatabase mongoDatabase(MongoClient mongoClient) {
+        return mongoClient.getDatabase("demo");
+    }
 }

src/main/java/com/example/demo/application/CartService.java

@@ -0,0 +1,61 @@
+package com.example.demo.application;
+
+import com.example.demo.infrastructure.LineItemDAO;
+import com.example.demo.infrastructure.ProductDAO;
+import com.example.demo.model.Cart;
+import com.example.demo.model.LineItem;
+import com.example.demo.model.Product;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+public class CartService {
+    private final LineItemDAO lineItemDAO;
+    private final ProductDAO productDAO;
+
+    public CartService(LineItemDAO lineItemDAO, ProductDAO productDAO) {
+        this.lineItemDAO = lineItemDAO;
+        this.productDAO = productDAO;
+    }
+
+    public Cart getCart() {
+        List<LineItem> lineItems = lineItemDAO.findAll();
+
+        lineItems.forEach(lineItem -> {
+            String productId = lineItem.getProductId();
+            Product product = productDAO.find(productId);
+
+            int unitPrice = product.getPrice();
+            int quantity = lineItem.getQuantity();
+
+            lineItem.setProductName(product.getName());
+            lineItem.setUnitPrice(product.getPrice());
+            lineItem.setTotalPrice(unitPrice * quantity);
+        });
+
+        int totalPrice = lineItems.stream()
+                .mapToInt(LineItem::getTotalPrice)
+                .sum();
+
+        return new Cart(lineItems, totalPrice);
+    }
+
+    public void addProduct(String productId, int quantity) {
+
+        List<LineItem> lineItems = lineItemDAO.findAll();
+
+        LineItem lineItem = lineItems.stream()
+                .filter(i -> i.getProductId().equals(productId))
+                .findFirst()
+                .orElse(null);
+
+        if (lineItem == null) {
+            lineItem = new LineItem(productId, quantity);
+            lineItemDAO.add(lineItem);
+            return;
+        }
+        lineItem.setQuantity(lineItem.getQuantity() + quantity);
+        lineItemDAO.update(lineItem);
+    }
+}

src/main/java/com/example/demo/controllers/CartController.java

@@ -1,14 +1,42 @@
 package com.example.demo.controllers;
 
+import com.example.demo.application.CartService;
+import com.example.demo.controllers.dtos.CartDto;
+import com.example.demo.model.Cart;
+import com.example.demo.model.LineItem;
+import org.springframework.web.bind.annotation.DeleteMapping;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
 @RestController
 @RequestMapping("/cart")
 public class CartController {
+
+    private final CartService cartService;
+
+    public CartController(CartService cartService) {
+        this.cartService = cartService;
+    }
+
     @GetMapping
-    String detail() {
-        return "";
+    CartDto detail() {
+
+        Cart cart = cartService.getCart();
+        return new CartDto(
+                cart.getLineItems().stream()
+                        .map(this::mapToDto)
+                        .toList(),
+                cart.getTotalPrice());
+    }
+
+    private CartDto.LineItemDto mapToDto(LineItem lineItem) {
+        return new CartDto.LineItemDto(
+                lineItem.getId(),
+                lineItem.getProductId(),
+                lineItem.getProductName(),
+                lineItem.getUnitPrice(),
+                lineItem.getQuantity(),
+                lineItem.getTotalPrice());
     }
 }

src/main/java/com/example/demo/controllers/LineItemController.java

@@ -1,17 +1,33 @@
 package com.example.demo.controllers;
 
+import com.example.demo.application.CartService;
+import com.example.demo.controllers.dtos.AddProductToCartDto;
+import jakarta.validation.Valid;
 import org.springframework.http.HttpStatus;
 import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.ResponseStatus;
 import org.springframework.web.bind.annotation.RestController;
 
 @RestController
 @RequestMapping("/cart/line-items")
 public class LineItemController {
+
+    private final CartService cartService;
+
+    public LineItemController(CartService cartService) {
+        this.cartService = cartService;
+    }
+
     @PostMapping
     @ResponseStatus(HttpStatus.CREATED)
-    void create() {
-        //
+    void create(
+           @Valid @RequestBody AddProductToCartDto addProductToCartDto
+    ) {
+        cartService.addProduct(
+                addProductToCartDto.productId(),
+                addProductToCartDto.quantity()
+        );
     }
 }

src/main/java/com/example/demo/controllers/dtos/AddProductToCartDto.java

@@ -0,0 +1,12 @@
+package com.example.demo.controllers.dtos;
+
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.Positive;
+
+public record AddProductToCartDto(
+        @NotBlank
+        String productId,
+        @Positive
+        int quantity
+) {
+}

src/main/java/com/example/demo/controllers/dtos/CartDto.java

@@ -0,0 +1,18 @@
+package com.example.demo.controllers.dtos;
+
+import java.util.List;
+
+public record CartDto(
+        List<LineItemDto> lineItems,
+        int totalPrice
+) {
+    public record LineItemDto(
+            String id,
+            String productId,
+            String productName,
+            int unitPrice,
+            int quantity,
+            int totalPrice
+    ) {
+    }
+}

src/main/java/com/example/demo/infrastructure/LineItemDAO.java

@@ -0,0 +1,56 @@
+package com.example.demo.infrastructure;
+
+import com.example.demo.model.LineItem;
+import com.mongodb.client.MongoCollection;
+import com.mongodb.client.MongoDatabase;
+import com.mongodb.client.model.Filters;
+import com.mongodb.client.model.Updates;
+import org.bson.Document;
+import org.bson.types.ObjectId;
+import org.springframework.stereotype.Component;
+
+import java.util.ArrayList;
+import java.util.List;
+
+@Component
+public class LineItemDAO {
+
+    private final MongoCollection<Document> collection;
+
+    public LineItemDAO(MongoDatabase mongoDatabase) {
+        this.collection = mongoDatabase.getCollection("line_items");
+    }
+
+    public List<LineItem> findAll() {
+        List<Document> documents = new ArrayList<>();
+        collection.find().into(documents);
+
+        return documents.stream().map(this::mapToModel).toList();
+    }
+
+    public void add(LineItem lineItem) {
+        Document document = new Document()
+                .append("product_id", lineItem.getProductId())
+                .append("quantity", lineItem.getQuantity());
+
+        collection.insertOne(document);
+    }
+
+    public void update(LineItem lineItem) {
+        collection.updateOne(
+                Filters.eq("_id", new ObjectId(lineItem.getId())),
+                Updates.combine(
+                        Updates.set("product_id", lineItem.getProductId()),
+                        Updates.set("quantity", lineItem.getQuantity())
+                )
+        );
+    }
+
+    private LineItem mapToModel(Document document) {
+        return new LineItem(
+                document.getObjectId("_id").toString(),
+                document.getString("product_id"),
+                document.getInteger("quantity")
+        );
+    }
+}

src/main/java/com/example/demo/infrastructure/ProductDAO.java

@@ -0,0 +1,37 @@
+package com.example.demo.infrastructure;
+
+import com.example.demo.model.LineItem;
+import com.example.demo.model.Product;
+import com.mongodb.client.MongoCollection;
+import com.mongodb.client.MongoDatabase;
+import com.mongodb.client.model.Filters;
+import org.bson.Document;
+import org.bson.types.ObjectId;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+@Component
+public class ProductDAO {
+
+    private final MongoDatabase mongoDatabase;
+
+    public ProductDAO(MongoDatabase mongoDatabase) {
+        this.mongoDatabase = mongoDatabase;
+    }
+
+    public Product find(String productId) {
+
+        MongoCollection<Document> collection = mongoDatabase.getCollection("products");
+
+        Document document = collection.find(
+                Filters.eq("_id", new ObjectId(productId))
+        ).first();
+
+        return new Product(
+                document.getObjectId("_id").toString(),
+                document.getString("name"),
+                document.getInteger("price")
+        );
+    }
+}

src/main/java/com/example/demo/model/Cart.java

@@ -0,0 +1,23 @@
+package com.example.demo.model;
+
+import java.util.Collections;
+import java.util.List;
+
+public class Cart {
+    private List<LineItem> lineItems;
+    private int totalPrice;
+
+    public Cart(List<LineItem> lineItems, int totalPrice) {
+        this.lineItems = lineItems;
+        this.totalPrice = totalPrice;
+    }
+
+    public List<LineItem> getLineItems() {
+        return Collections.unmodifiableList(lineItems);
+    }
+
+    public int getTotalPrice() {
+        return totalPrice;
+    }
+
+}

src/main/java/com/example/demo/model/LineItem.java

@@ -0,0 +1,63 @@
+package com.example.demo.model;
+
+public class LineItem {
+
+    private String id;
+    private String productId;
+    private int quantity;
+
+    private String productName;
+    private int unitPrice;
+    private int totalPrice;
+
+    public LineItem(String id, String productId, int quantity) {
+        this.id = id;
+        this.productId = productId;
+        this.quantity = quantity;
+    }
+
+    public LineItem(String productId, int quantity) {
+        this.productId = productId;
+        this.quantity = quantity;
+    }
+
+    public String getId() {
+        return id;
+    }
+
+    public String getProductId() {
+        return productId;
+    }
+
+    public int getQuantity() {
+        return quantity;
+    }
+
+    public String getProductName() {
+        return productName;
+    }
+
+    public void setProductName(String productName) {
+        this.productName = productName;
+    }
+
+    public int getUnitPrice() {
+        return unitPrice;
+    }
+
+    public void setUnitPrice(int unitPrice) {
+        this.unitPrice = unitPrice;
+    }
+
+    public int getTotalPrice() {
+        return totalPrice;
+    }
+
+    public void setTotalPrice(int totalPrice) {
+        this.totalPrice = totalPrice;
+    }
+
+    public void setQuantity(int quantity) {
+        this.quantity = quantity;
+    }
+}