Merge pull request #36 from NashTech-Labs/feature/added_cart_products…

…_visibility

added cart product visibility

cart-service/pom.xml

@@ -43,7 +43,6 @@
 		<java.version>19</java.version>
 		<maven.compiler.source>19</maven.compiler.source>
 		<mysql-connector.version>8.0.33</mysql-connector.version>
-		<common.version>1.0</common.version>
 		<dotenv.version>4.0.0</dotenv.version>
 	</properties>
 

cart-service/src/main/java/com/nashtech/car/cart/config/Configurations.java

@@ -0,0 +1,14 @@
+package com.nashtech.car.cart.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.web.client.RestTemplate;
+
+@Configuration
+public class Configurations {
+
+    @Bean
+    public RestTemplate restTemplate() {
+        return new RestTemplate();
+    }
+}

cart-service/src/main/java/com/nashtech/car/cart/config/ProductConfigs.java

@@ -0,0 +1,15 @@
+package com.nashtech.car.cart.config;
+
+import lombok.Getter;
+import lombok.Setter;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.stereotype.Component;
+
+@ConfigurationProperties(prefix ="inventory-service")
+@Component
+@Getter
+@Setter
+public class ProductConfigs {
+    private String host;
+    private String productUri;
+}

cart-service/src/main/java/com/nashtech/car/cart/controller/CartController.java

@@ -1,12 +1,16 @@
 package com.nashtech.car.cart.controller;
 
 import com.nashtech.car.cart.model.CartItem;
-import com.nashtech.car.cart.services.CartService;
+import com.nashtech.car.cart.service.CartService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.ResponseEntity;
-import org.springframework.web.bind.annotation.*;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
 
 @RestController
 @RequestMapping("/cart")

cart-service/src/main/java/com/nashtech/car/cart/data/ProductsSummary.java

@@ -0,0 +1,17 @@
+package com.nashtech.car.cart.data;
+
+import lombok.Data;
+
+@Data
+public class ProductsSummary {
+    private String productId;
+    private String brand;
+    private String model;
+    private Integer year;
+    private String color;
+    private Double mileage = 0.0d;
+    private Double basePrice = 0.0d;
+    private Integer quantity =0;
+    private Float tax = 0.0f;
+
+}

cart-service/src/main/java/com/nashtech/car/cart/model/CartItem.java

@@ -1,7 +1,11 @@
 package com.nashtech.car.cart.model;
 
 import com.nashtech.car.cart.audit.Auditable;
-import jakarta.persistence.*;
+import jakarta.persistence.Entity;
+import jakarta.persistence.EntityListeners;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
 import lombok.Getter;
 import lombok.Setter;
 import org.springframework.data.jpa.domain.support.AuditingEntityListener;
@@ -17,7 +21,14 @@ public class CartItem extends Auditable<String> implements Serializable {
     @GeneratedValue(strategy = GenerationType.IDENTITY)
     private Long id;
     private String productId;
-    private int quantity;
+    private String brand;
+    private String model;
+    private Integer year;
+    private String color;
+    private Double mileage;
+    private Double basePrice;
+    private Integer quantity;
+    private Float tax;
     private String userId;
 
 }

cart-service/src/main/java/com/nashtech/car/cart/service/CartService.java

@@ -0,0 +1,87 @@
+package com.nashtech.car.cart.service;
+
+import com.nashtech.car.cart.config.ProductConfigs;
+import com.nashtech.car.cart.data.ProductsSummary;
+import com.nashtech.car.cart.model.CartItem;
+import com.nashtech.car.cart.repository.CartItemRepository;
+import jakarta.transaction.Transactional;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.RestTemplate;
+
+import java.util.Objects;
+
+@Service
+@Slf4j
+public class CartService {
+
+    private final CartItemRepository cartItemRepository;
+
+    private final RestTemplate apiCall;
+
+    private final ProductConfigs productConfigs;
+
+    public CartService(CartItemRepository cartItemRepository, RestTemplate apiCall, ProductConfigs productConfigs) {
+        this.cartItemRepository = cartItemRepository;
+        this.apiCall = apiCall;
+        this.productConfigs = productConfigs;
+    }
+
+    // @Transactional
+    public CartItem addToCart(String productId, int quantity, String userId) {
+
+        CartItem cartItem = cartItemRepository.findByProductIdAndUserId(productId, userId);
+
+        if (Objects.isNull(cartItem)) {
+            ProductsSummary productsSummary;
+            try {
+                productsSummary = apiCall.getForEntity(productConfigs.getHost() + productConfigs.getProductUri(),
+                        ProductsSummary.class, productId).getBody();
+            } catch (Exception ex) {
+                log.error("Unable to process add to cart due to {} ", ex.getMessage());
+                throw ex;
+            }
+            cartItem = new CartItem();
+            cartItem.setProductId(productId);
+            cartItem.setQuantity(quantity);
+            cartItem.setUserId(userId);
+            cartItem.setBasePrice(productsSummary.getBasePrice());
+            cartItem.setMileage(productsSummary.getMileage());
+            cartItem.setModel(productsSummary.getModel());
+            cartItem.setColor(productsSummary.getColor());
+            cartItem.setBrand(productsSummary.getBrand());
+            cartItem.setTax(productsSummary.getTax());
+            cartItem.setYear(productsSummary.getYear());
+        } else {
+            cartItem.setQuantity(cartItem.getQuantity() + quantity);
+        }
+
+        return cartItemRepository.save(cartItem);
+    }
+
+    public CartItem removeFromCart(String productId, int quantity, String userId) {
+        CartItem cartItem = cartItemRepository.findByProductIdAndUserId(productId, userId);
+
+        if (cartItem != null) {
+            int updatedQuantity = cartItem.getQuantity() - quantity;
+            if (updatedQuantity <= 0) {
+                cartItemRepository.delete(cartItem);
+                throw new IllegalStateException("Product removed from cart");
+            } else {
+                cartItem.setQuantity(updatedQuantity);
+                cartItem = cartItemRepository.save(cartItem);
+            }
+        }
+        return cartItem;
+    }
+
+    @Transactional
+    public CartItem getFromCart(String productId, String userId) {
+        CartItem cartItem = cartItemRepository.findByProductIdAndUserId(productId, userId);
+        if (cartItem == null) {
+            throw new IllegalStateException("Product not found from the cart");
+        }
+        return cartItem;
+    }
+
+}

cart-service/src/main/resources/.env

@@ -2,3 +2,4 @@ MYSQL_HOST=localhost
 MYSQL_DB_USERNAME=root
 MYSQL_DB_PASSWORD=password
 SERVICE_NAME=CartService
+INVENTORY_HOST=http://localhost:9091

cart-service/src/main/resources/application.yml

@@ -11,4 +11,8 @@ spring:
   jpa:
     database-platform: org.hibernate.dialect.MySQL8Dialect
     hibernate:
-      ddl-auto: update
+      ddl-auto: update
+
+inventory-service:
+  host: ${INVENTORY_HOST}
+  product-uri: /products/product/{productId}