java - 如何在流中结合统计数据和映射器？

Question

public static PriceRangeData getCanonicalPriceRange(final ProductData productDataParent) {
    if (MapUtils.isNotEmpty(productDataParent.getAggregates())
            && null != productDataParent.getAggregates().get(DtCoreConstants.RANGED_DATA)) {
        final PriceRangeData data = new PriceRangeData();
        final Map<String, Double> mapPrices = productDataParent.getRangeMapPrices();
        final List<ProductData> ranges = (List<ProductData>) productDataParent.getAggregates()
                .get(DtCoreConstants.RANGED_DATA);
        if(MapUtils.isNotEmpty(mapPrices)) {
            ranges.stream()
            .map(productData -> getMapUpdatedData(mapPrices, productData));
        }
        final DoubleSummaryStatistics stats = ranges.stream()
                .collect(Collectors.summarizingDouble(ProductData::getRawPrice));
        if (null != stats) {
            PriceData minPrice = new PriceData();
            minPrice.setValue(new BigDecimal(stats.getMin()));
            data.setMinPrice(minPrice);
            PriceData maxPrice = new PriceData();
            maxPrice.setValue(new BigDecimal(stats.getMax()));
            data.setMaxPrice(maxPrice);
        }
        return data;
    }
    return null;
}

private static ProductData getMapUpdatedData(final Map<String, Double> mapPrices, final ProductData productData) {
    if (mapPrices.containsKey(productData.getCode())) {
        productData.setRawPrice(mapPrices.get(productData.getCode()));
    }
    return productData;
}

有没有办法结合起来

if(MapUtils.isNotEmpty(mapPrices)) {
            ranges.stream()
            .map(productData -> getMapUpdatedData(mapPrices, productData));
        }

和

final DoubleSummaryStatistics stats = ranges.stream()
                .collect(Collectors.summarizingDouble(ProductData::getRawPrice));

通过引用 getRawPrice 的本地方法而不是 ProductData.getRawPrice。目前，我们正在将 rawPrice 更新为 mapPrice 中的价格(如果存在)，然后重做统计数据流。有没有一种方法可以做到这一点而不必先更新，而只需使用本地方法输入值来计算 summarizingDouble 中的统计信息

就像在 Collectors.summarizingDouble 方法中使用下面的方法

private Double getRawPrice(final Map<String, Double> mapPrices, final ProductData productData) {
        if (mapPrices.containsKey(productData.getCode())) {
            return mapPrices.get(productData.getCode());
        }
        return productData.getRawPrice();
    }

Answer 1

据我了解您需要

 ranges.stream()
        .map(productData -> mapPrices.getOrDefault(productData.getCode(), productData.getRawPrice())) 
        .collect(Collectors.summarizingDouble(x->x));