[AFP-53] ✨ Persist order info from warehouse to db [@svalencia]

src/main/java/com/afp/ordermanagement/controller/OrderController.java

@@ -67,4 +67,5 @@ public class OrderController {
     }
 
 
+
 }

src/main/java/com/afp/ordermanagement/model/OrderStatus.java

@@ -3,5 +3,5 @@ package com.afp.ordermanagement.model;
 public enum OrderStatus {
     RECEIVED,
     FULFILLED,
-    CANCELLED
+    CANCELLED,
 }

src/main/java/com/afp/ordermanagement/reactivekafkaservice/Receiver.java

@@ -31,10 +31,6 @@ public class Receiver {
     @Autowired
     private OrderService orderService;
 
-    @Autowired
-    private OrderRepository orderRepository;
-
-
 
     @EventListener(ApplicationStartedEvent.class)
     public void consumeOrderStatus() {
@@ -48,18 +44,20 @@ public class Receiver {
 
 
 
-    private void updateOrderStatus(String orderStatusStr) {
+    private void updateOrderStatus(String orderObj) {
         try {
             //deserialize kafka message into java object using ObjectMapper
             ObjectMapper objectMapper = new ObjectMapper();
             //Map<String, String> orderStatus = objectMapper.readValue(orderStatusStr, Map.class);
-            Order order = objectMapper.readValue(orderStatusStr, Order.class);
+            Order order = objectMapper.readValue(orderObj, Order.class);
             log.info("ORDER objectMapper {}", order);
+
             String orderId = order.getId();
 
             Mono<Order> updated = orderService.updateOrderByOrderId(orderId, order);
             updated.block();
 
+
         } catch (Exception e) {
             log.error("Caught error", e);
         }
@@ -76,13 +74,16 @@ public class Receiver {
                 .findAny()
                 .orElse(null);
 
+
         if (res == null) {
             log.error("Order {} not found", orderId);
             return false;
         }
 
+
         log.info("Order exists on the database");
         return true;
+
     }
 
 

src/main/java/com/afp/ordermanagement/service/OrderService.java

@@ -58,5 +58,9 @@ public class OrderService {
     }
 
 
+    public Mono<Void> deleteOrderById(String orderId) {
+        return orderRepository.deleteById(orderId);
+    }
+
 
 }