[AFP-53] 🚧 Fix status update issues to update all other fields of order [@svalencia]

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

@@ -52,14 +52,12 @@ public class Receiver {
         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);
             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);
         }
@@ -67,16 +65,23 @@ public class Receiver {
 
 
 
-
     private boolean checkExistingOrder(String orderId) {
-        Flux<Order> orders = orderService.getAllOrders();
-        List<Order> orderList = orders.collectList().block();
-        Order res = orderList.stream()
-                .filter(order -> orderId.equals(order.getId()))
-                .findAny()
-                .orElse(null);
-
-        if (res == null) {
+//        Flux<Order> orders = orderService.getAllOrders();
+//        List<Order> orderList = orders.collectList().block();
+//        Order res = orderList.stream()
+//                .filter(order -> orderId.equals(order.getId()))
+//                .findAny()
+//                .orElse(null);
+
+//        if (res == null) {
+//            log.error("Order {} not found", orderId);
+//            return false;
+//        }
+
+
+        Mono<Order> order = orderRepository.findById(orderId);
+
+        if (order == null) {
             log.error("Order {} not found", orderId);
             return false;
         }

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

@@ -53,6 +53,7 @@ public class OrderService {
                     existingOrder.setOrderTrackingCode(newOrder.getOrderTrackingCode());
                     existingOrder.setOrderItems(newOrder.getOrderItems());
                     existingOrder.setOrderStatus(newOrder.getOrderStatus());
+                    existingOrder.setOrderItems(newOrder.getOrderItems());
                     return orderRepository.save(existingOrder);
                 });
     }