Java Stream使用reduce报错lambda返回类型不匹配问题求解

• 直接原因：flatMap执行完成后，流中元素类型为CategoryWise，但你在reduce操作中传入的二元lambda接收两个CategoryWise参数，返回值却是CategoryWiseEarnings，不符合reduce操作要求的「输入输出类型一致」规则，因此触发类型转换异常。
• 逻辑缺失：原有Stream代码的reduce没有实现同分类下的收益金额累加逻辑，和你可正常运行的for循环功能不符。

List<CategoryWiseEarnings> data = tripEarnings.getOrders()
    .stream()
    // 展开所有CategoryWise元素，对齐原for循环逻辑
    .flatMap(tripsOrders -> tripsOrders.getCategoryRulesEarnedList().stream())
    // 按分类ID分组
    .collect(Collectors.groupingBy(CategoryWise::getCategoryId))
    .values()
    .stream()
    // 每个分类分组聚合为一个CategoryWiseEarnings对象
    .map(categoryWiseList -> {
        CategoryWise firstItem = categoryWiseList.get(0);
        // 初始化当前分类的收益对象
        CategoryWiseEarnings totalEarnings = new CategoryWiseEarnings(
            new CategoryWise(firstItem.getCategoryName(), firstItem.getCategoryId()),
            firstItem.getBonus()
        );
        // 累加同分类下所有收益
        for (int i = 1; i < categoryWiseList.size(); i++) {
            CategoryWise current = categoryWiseList.get(i);
            double sum = Double.parseDouble(totalEarnings.getTotalAmount())
                    + Double.parseDouble(current.getBonus());
            totalEarnings.setTotalAmount(Double.toString(sum));
        }
        return totalEarnings;
    })
    .collect(Collectors.toList());

如果你希望使用纯函数式写法避免内部循环，可以使用带初始值的reduce实现：

List<CategoryWiseEarnings> data = tripEarnings.getOrders()
    .stream()
    .flatMap(tripsOrders -> tripsOrders.getCategoryRulesEarnedList().stream())
    .collect(Collectors.groupingBy(CategoryWise::getCategoryId))
    .values()
    .stream()
    .map(categoryWiseList -> categoryWiseList.stream()
        .reduce(
            // 初始值：当前分类的空收益对象
            new CategoryWiseEarnings(
                new CategoryWise(categoryWiseList.get(0).getCategoryName(), categoryWiseList.get(0).getCategoryId()),
                "0"
            ),
            // 累加单个元素收益
            (earnings, current) -> {
                double sum = Double.parseDouble(earnings.getTotalAmount())
                        + Double.parseDouble(current.getBonus());
                earnings.setTotalAmount(Double.toString(sum));
                return earnings;
            },
            // 并行流场景下的合并逻辑
            (e1, e2) -> {
                double sum = Double.parseDouble(e1.getTotalAmount())
                        + Double.parseDouble(e2.getTotalAmount());
                e1.setTotalAmount(Double.toString(sum));
                return e1;
            }
        )
    )
    .collect(Collectors.toList());

• 直接对分组后的CategoryWise列表做聚合，提前初始化CategoryWiseEarnings对象，从根源上避免类型不匹配问题
• 所有金额累加逻辑完全对齐原for循环实现，保证功能一致性
• 调整了变量命名，避免语义混淆

内容的提问来源于stack exchange，提问作者mansi