Commit 429c81d5 authored by Shanelle Valencia's avatar Shanelle Valencia

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

parent 2e140675
......@@ -58,6 +58,7 @@ public class Receiver {
Mono<Order> updated = orderService.updateOrderByOrderId(orderId, order);
updated.block();
} catch (Exception e) {
log.error("Caught error", e);
}
......@@ -65,30 +66,5 @@ 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) {
// 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;
}
log.info("Order exists on the database");
return true;
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment