updating logic 2

src/main/java/com/example/kafka/service/OrderServiceImpl.java

@@ -45,26 +45,31 @@ public class OrderServiceImpl implements OrderService {
     }
 
     @Override
-    public void validateOrder(String orderJson) {
-        try {
-            ObjectMapper mapper = new ObjectMapper();
-            Order order = mapper.readValue(orderJson,Order.class);
-            double amount = order.getAmount();
-            double balance = userService.findById(order.getId()).block().getBalance();
-            OrderStatus orderStatus;
-            if(amount>balance) {
-                orderStatus=OrderStatus.REJECTED;
-            } else {
-                orderStatus=OrderStatus.ACCEPTED;
-            }
-            Order dbOrder = orderRepository.findById(order.getId()).block();
-            if(dbOrder!=null)
-            {
-                dbOrder.setOrderStatus(orderStatus);
-            }
-            orderRepository.save(dbOrder);
-        } catch(JsonProcessingException e) {
-            log.error("Caught Exception {}:: ",e);
-        }
+    public Mono<Order> validateOrder(String orderJson) {
+//        try {
+            return orderRepository.findById("1")
+                    .flatMap(dbOrder -> {
+                        dbOrder.setOrderStatus(OrderStatus.REJECTED);
+                        return orderRepository.save(dbOrder);
+                    });
+            //            ObjectMapper mapper = new ObjectMapper();
+//            Order order = mapper.readValue(orderJson,Order.class);
+//            double amount = order.getAmount();
+//            double balance = userService.findById(order.getId()).block().getBalance();
+//            OrderStatus orderStatus;
+//            if(amount>balance) {
+//                orderStatus=OrderStatus.REJECTED;
+//            } else {
+//                orderStatus=OrderStatus.ACCEPTED;
+//            }
+//            Order dbOrder = orderRepository.findById(order.getId()).block();
+//            if(dbOrder!=null)
+//            {
+//                dbOrder.setOrderStatus(orderStatus);
+//            }
+//            orderRepository.save(dbOrder);
+//        } catch(JsonProcessingException e) {
+//            log.error("Caught Exception {}:: ",e);
+//        }
     }
 }