Commit b84c07d1 authored by Shaphen Pangburn's avatar Shaphen Pangburn

Merge branch 'master' of https://gitlab.mynisum.com/ascend/ecommerce-maven...

Merge branch 'master' of https://gitlab.mynisum.com/ascend/ecommerce-maven into product-page-users-can-add-one-or-more-item-to-cart-with-a-button
parents 7ad8ab7d 659a0802
package com.nisum.ecomservice.controller;
import com.nisum.ecomservice.dto.CartDTO;
import com.nisum.ecomservice.dto.Order;
import com.nisum.ecomservice.dto.OrderRequest;
import com.nisum.ecomservice.service.OrderService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
@RestController
......@@ -18,6 +21,9 @@ public class OrdersController {
private Mono<Order> postOrder(@RequestBody OrderRequest orderRequest){
return orderService.postOrder(orderRequest);
}
@GetMapping("/byUser/{userId}")
private ResponseEntity<Flux<Order>> getUserOrderHistory(@PathVariable String userId){
return ResponseEntity.ok(orderService.getOrderFromOmsAPI(userId));
}
}
......@@ -81,6 +81,13 @@ public class OrderService {
.retrieve()
.bodyToMono(Order.class);
}
public Flux<Order> getOrderFromOmsAPI(String userId){
return WebClient.create(String.format("%s/orders/byCustomer/%s", AppConfig.getOrderManagementAPI(),userId))
.get()
.retrieve()
.bodyToFlux(Order.class);
}
}
/*
.map(productMono -> {
......
......@@ -11,7 +11,7 @@ import reactor.core.publisher.Flux;
@Service
public class ProductService {
public Mono<Product> getProductBySku(String sku){
return WebClient.create(String.format("http://localhost:8082/api/products/%s",sku))
return WebClient.create(String.format("http://localhost:8083/api/products/%s",sku))
.get()
.retrieve()
.bodyToMono(Product.class);
......
class Config {
static baseApiUrl = "http://localhost:8080/api"; //env file
static orderHistoryApiUrlMethod = (userId) => `${this.baseApiUrl}/users/${userId}/orders`;
static orderHistoryApiUrlMethod = (userId) => `${this.baseApiUrl}/orders/byUser/${userId}`;
}
......
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