Added GET end point to fetch all records,delete end point, update endpoint and...

Added GET end point to fetch all records,delete end point, update endpoint and update by id, added validation

src/main/java/com/nisum/example/controller/ProductController.java

@@ -8,12 +8,17 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.MediaType;
+import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
+import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 
+import javax.validation.Valid;
+
 @RestController
 @RequestMapping(value = ProductConstants.PRODUCT_SERVICE_ROOT,produces = MediaType.APPLICATION_JSON_VALUE)
 @Slf4j
+@Validated
 public class ProductController {
 
     @Autowired
@@ -24,20 +29,56 @@ public class ProductController {
 
     @PostMapping(value = "/product-create",consumes = MediaType.APPLICATION_JSON_VALUE)
     @ResponseStatus(HttpStatus.CREATED)
-    public Mono<Product> createProduct(@RequestBody Product product){
+    public Mono<Product> createProduct(@Valid @RequestBody Product product){
         log.info("Calling service saveProduct() ...");
        return productService.saveProduct(productMapper.toDto(product))
                .map(productMapper::toModel)
                .log();
     }
 
-    @GetMapping(value = "/product-get/{id}")
+    @GetMapping(value = "/product-get/{id}",produces = MediaType.APPLICATION_JSON_VALUE)
     @ResponseStatus(HttpStatus.OK)
     public Mono<Product> fetchProduct(@PathVariable  String id){
         log.info("Calling service getProduct()...");
         return productService.getProduct(id)
                 .map(productMapper::toModel)
                 .log();
+    }
+
+    @GetMapping(value = "/product-all",produces = MediaType.APPLICATION_JSON_VALUE)
+    @ResponseStatus(HttpStatus.FOUND)
+    public Flux<Product> fetchProducts(){
+        log.info("Calling service getProducts()...");
+        return productService.getProducts()
+                .map(productMapper::toModel)
+                .log();
+    }
+
+    @PutMapping(value = "/product-update",consumes = MediaType.APPLICATION_JSON_VALUE)
+    @ResponseStatus(HttpStatus.OK)
+    public Mono<Product> modifyProduct(@Valid @RequestBody Product product){
+        log.info("Calling service updateProduct()...");
+        return productService.updateProduct(productMapper.toDto(product))
+                .map(productMapper::toModel)
+                .log();
+    }
+
+    @DeleteMapping(value = "/product-delete/{id}",produces = MediaType.APPLICATION_JSON_VALUE)
+    @ResponseStatus(HttpStatus.OK)
+    public Mono<Boolean> deleteById(@PathVariable String id){
+        log.info("Calling service removeById()...");
+        return productService.removeById(id)
+                .log();
+    }
+
+    @PutMapping("/product-update-price/{id}")
+    @ResponseStatus(HttpStatus.OK)
+    public Mono<Product> modifyProductPrice(@PathVariable String id,
+                                            @Valid @RequestBody Product product){
+        log.info("Calling service updateProductPrice()...");
+        return productService.updateProductPrice(id,productMapper.toDto(product))
+                .map(productMapper::toModel)
+                .log();
 
     }
 }

src/main/java/com/nisum/example/model/Product.java

@@ -3,6 +3,8 @@ package com.nisum.example.model;
 import lombok.*;
 import lombok.experimental.FieldDefaults;
 
+import javax.validation.constraints.NotEmpty;
+import javax.validation.constraints.NotNull;
 import java.util.List;
 
 @Data
@@ -12,8 +14,15 @@ import java.util.List;
 @FieldDefaults(level = AccessLevel.PRIVATE)
 public class Product {
     String prodId;
+
+    @NotNull(message = "name should not be null")
+    @NotEmpty(message = "name cannot be empty")
     String prodName;
+    @NotNull(message = "description should not be null")
+    @NotEmpty(message = "description cannot be empty")
     String prodDescription;
+    @NotNull(message = "price should not be null")
     Double prodPrice;
+    @NotNull(message = "Locations can not be null")
     List<Location> prodLocationList;
 }

src/main/java/com/nisum/example/service/IProductService.java

 package com.nisum.example.service;
 
 import com.nisum.example.dto.ProductDTO;
+import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 
 public interface IProductService {
 
     Mono<ProductDTO> saveProduct(ProductDTO productDTO);
     Mono<ProductDTO> getProduct(String id);
+    Flux<ProductDTO> getProducts();
+    Mono<ProductDTO> updateProduct(ProductDTO productDTO);
+    Mono<Boolean> removeById(String id);
+    Mono<ProductDTO> updateProductPrice(String id,ProductDTO productDTO);
 }

src/main/java/com/nisum/example/service/ProductServiceImpl.java

@@ -4,7 +4,11 @@ import com.nisum.example.dto.ProductDTO;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.mongodb.core.ReactiveMongoTemplate;
+import org.springframework.data.mongodb.core.query.Criteria;
+import org.springframework.data.mongodb.core.query.Query;
+import org.springframework.data.mongodb.core.query.Update;
 import org.springframework.stereotype.Service;
+import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 
 /**
@@ -35,7 +39,42 @@ public class ProductServiceImpl implements IProductService {
      */
     @Override
     public Mono<ProductDTO> getProduct(String id) {
-        log.info("Calling service findById()...");
+        log.info("Calling template findById()...");
         return reactiveMongoTemplate.findById(id,ProductDTO.class);
     }
+
+    @Override
+    public Flux<ProductDTO> getProducts() {
+        log.info("Calling template findAll()...");
+        return reactiveMongoTemplate.findAll(ProductDTO.class);
+    }
+
+    @Override
+    public Mono<ProductDTO> updateProduct(ProductDTO productDTO) {
+        log.info("Calling template save()...");
+        return reactiveMongoTemplate.save(productDTO);
+    }
+
+    @Override
+    public Mono<Boolean> removeById(String id) {
+        log.info("Calling template remove()...");
+        return reactiveMongoTemplate.remove(Query.query(Criteria.where("id").is(id)),
+                ProductDTO.class)
+                .flatMap(deleteResult -> Mono.just(deleteResult.wasAcknowledged()));
+    }
+
+    @Override
+    public Mono<ProductDTO> updateProductPrice(String id,ProductDTO productDTO) {
+        log.info("Calling template findAndModify()...");
+        return reactiveMongoTemplate.findById(id,ProductDTO.class)
+                .flatMap(productDto->
+                        reactiveMongoTemplate.findAndModify(Query
+                                .query(Criteria.where("id").is(id)),
+                                Update.update("prodPrice",productDTO.getProdPrice()),
+                                ProductDTO.class)
+                .flatMap(result -> {
+                    result.setProdPrice(productDto.getProdPrice());
+                    return Mono.just(result);
+                }));
+    }
 }