Преобразовать расширенный для каждого l oop в потоки java 8 - PullRequest
Новая
       50

Преобразовать расширенный для каждого l oop в потоки java 8

0 голосов
/ 03 августа 2020

Я пытаюсь преобразовать код, написанный в расширенном формате для каждого l oop, в потоки в java. Вот мой традиционный код 

    List<OrderDetail> orderDetails = new ArrayList<>();
    if (arInvoiceOrderResponseBody != null) {
        if (arInvoiceOrderResponseBody.getOrders() != null && 
         arInvoiceOrderResponseBody.getOrders().size() > 0) {
         for (OrderDetail orderDetail : arInvoiceOrderResponseBody.getOrders()) {
                if (orderDetail != null) {
                    if (orderDetail.getStatusHistory() != null && 
                        orderDetail.getStatusHistory().size() > 0) {
                        for (StatusHistory statusHistory : orderDetail.getStatusHistory()) {
                            if (statusHistory != null) {
                                if (statusHistory.getStatusCode() != null) {
                                    if (statusHistory.getStatusCode().equals("POD")) {
                                        orderDetail.setStatusDateTime(statusHistory.getStatus_date_time());
                                    }
                                }

                            }
                        }
                    }
                }
                orderDetails.add(orderDetail);
            }
            arInvoiceOrderResponseBody.setOrders(orderDetails);
        }

Может ли кто-нибудь помочь мне воспроизвести ту же функциональность через потоки. Любая помощь была бы очень полезна

Это то, что я пытаюсь 

    arInvoiceOrderResponseBody.getOrders().stream() .flatMap(order ->
    order.getStatusHistory().stream()) 
    .filter(statusHistory ->statusHistory.getStatusCode().equals("POD"))
    //Here if condition is true then i need to do this.I need to set one
    //of the property of main order object to one of the property of status 
    //history object 
    //order.setStatusDateTime(statusHistory.getStatus_date_time());

Ответы [ 2 ]

1 голос
/ 03 августа 2020

Разделение его на несколько методов и разбиение на два потока может работать. Что-то вроде: 

  public static ResponseBody processResponseBody(ResponseBody responseBody)
  {
    if(validate(responseBody))
    {
      List<OrderDetail> orderDetails = responseBody.getOrders().stream()
          .filter(od -> validate(od))
          .map(od -> processOrderDetail(od))
          .collect(Collectors.toList());
      responseBody.setOrders(orderDetails);
    }
    
    return responseBody;
  }
  
  private static OrderDetail processOrderDetail(OrderDetail orderDetail)
  {
    StatusHistory statusHistory = orderDetail.getStatusHistory().stream()
          .filter(sh -> validate(sh))
          .findFirst()
          .orElseThrow(() -> new IllegalArgumentException("No Status History Found"));
    orderDetail.setStatusDateTime(statusHistory.getStatus_date_time());

    return orderDetail;
  }
  
  private static boolean validate(ResponseBody responseBody)
  {
    return responseBody != null && responseBody.getOrders() != null && responseBody.getOrders().size() > 0;
  }
  
  private static boolean validate(OrderDetail orderDetail)
  {
    return orderDetail != null && orderDetail.getStatusHistory() != null && orderDetail.getStatusHistory().size() > 0;
  }
  
  private static boolean validate(StatusHistory statusHistory)
  {
    return statusHistory != null && statusHistory.getStatusCode() != null && statusHistory.getStatusCode().equals("POD");
  }

Я разбил его на поток, чтобы обработать объект OrderDetail, и поток, чтобы уменьшить StatusHistory до одного объекта. Я также разбил валидацию на их собственные методы для краткости и организованности.

1 голос
/ 03 августа 2020

Ниже примерно как Java -8, поскольку это будет, по моему мнению. 

arInvoiceOrderResponseBody.getOrders().forEach(
      orderDetail -> orderDetail.getStatusHistory().stream()
        .filter(statusHistory -> "POD".equals(statusHistory.getStatusCode()))
        .findFirst()
        .ifPresent(statusHistory -> orderDetail.setStatusDateTime(statusHistory.getStatus_date_time()))
    );

Я заметил, что исходный код изменяет существующие экземпляры OrderDetail, но затем помещает их (все) в новую коллекцию и заменяет исходную коллекцию. На первый взгляд это кажется бессмысленным!

...