lambda表达式中的返回类型错误：

Question

List<CategoryWiseEarnings> data = tripEarnings.getOrders()
    .stream()
    .flatMap(getCategoryRulesEarnedList -> getCategoryRulesEarnedList.getCategoryRulesEarnedList().stream())
    .collect(Collectors.groupingBy(foo -> foo.getCategoryId()))
    .entrySet()
    .stream()
    .map(e -> e.getValue()
               .stream()
               .reduce((c,c2) -> new CategoryWiseEarnings(
                   new CategoryWise(
                       c.getCategoryName(), 
                       c.getCategoryId()
                   ), 
                   c.getBonus()
               ))
    )
    .map(f -> f.get())
    .collect(Collectors.toList());

将异常获取为

：lambda表达式中的返回类型错误：categorywiseernings不能转换为CategoryWise

public class CategoryWiseEarnings {

    @JsonProperty("category")
    private CategoryWise earnings;

    @JsonProperty("total_amount")
    private String totalAmount;

}

public class CategoryWise {

    @JsonProperty("category_id")
    Long categoryId;

    @JsonProperty("category_name")
    String categoryName;

    public CategoryWise(String categoryName, Long categoryId) {
        this.categoryName = categoryName;
        this.categoryId = categoryId;
    }
}

这是我想使用流和lambda函数编写的代码，如果我这样写，它可以正常工作：

for (Trips tripsOrders : tripEarnings.getOrders()) {

    if (!tripsOrders.getCategoryRulesEarnedList().isEmpty()) {

        for (CategoryWise c : tripsOrders.getCategoryRulesEarnedList()) {

            if (hashMapCategory.containsKey(c.getCategoryId())) {

                // hashmapk.put(c.getCategoryId(),new CategoryWiseEarnings(new CategoryWise(c.getCategoryName(),c.getCategoryId()),c.getBonus()+hashmapk.get(c.getCategoryId()).getTotalAmount()));
                CategoryWiseEarnings categoryObject = hashMapCategory.get(c.getCategoryId());
            
                categoryObject.setTotalAmount(Double.toString(
                    Double.parseDouble(c.getBonus())
                  + Double.parseDouble(categoryObject.getTotalAmount())
                ));

                hashMapCategory.put(c.getCategoryId(), categoryObject);

            } else {
                hashMapCategory.put(c.getCategoryId(), new CategoryWiseEarnings(new CategoryWise(c.getCategoryName(), c.getCategoryId()), c.getBonus()));
            }
        }
    }
}

List<CategoryWiseEarnings> list = new ArrayList<CategoryWiseEarnings>(hashMapCategory.values());




Answer 1

匿名用户

流：：reduce（二进制操作符）需要一个双函数

此外，数据模型似乎是不恰当的：在类别智慧收益字段总应该是双以避免冗余转换，类类别智慧缺少奖金字段。

因此，解决方案可能是使用收集器。按收集器分组。将double求和以计算映射中的总值，然后将映射条目重新映射到类别收入：

List<CategoryWiseEarnings> result = tripEarnings.getOrders()
    .stream() // Stream<Trips>
    .flatMap(trips -> trips.getCategoryRulesEarnedList().stream()) // Stream<CategoryWise>
    .collect(Collectors.groupingBy(
        cw -> Arrays.asList(cw.getCategoryId(), cw.getCategoryName()) // key -> List<Object>
        LinkedHashMap::new, // keep insertion order
        Collectors.summingDouble(cw -> Double.parseDouble(cw.getBonus()))
    )) // Map<List<Id, Name>, Double>
    .entrySet()
    .stream()
    .map(e -> new CategoryWiseEarnings(
        new CategoryWise(e.getKey().get(0), e.getKey().get(1)), 
        String.valueOf(e.getValue()) // assuming the total is String
    ))
    .collect(Collectors.toList());