首页 > 解决方案 > java8一次性减少多项操作(求和和平均)

问题描述

我有一个项目“Fatturato”的列表,我已经计算了一个字段的总和和另一个字段的平均值。我想知道我是否可以使用“reduce”方法使用独特的代码行来完成它,目前我已经用多行完成了。我想在reduce中使用divide方法,但我不知道如何定义(仅在最后一次迭代中使用,当总和结束时)

import java.math.BigDecimal;
import java.math.MathContext;
import java.math.RoundingMode;
import java.util.ArrayList;
import java.util.List;
import java.util.Optional;

public class Main {

    public static void main (String args[]) {

        List<Fatturato> listFatturato = new ArrayList<Fatturato>();
        Fatturato ftt1 = new Fatturato(new BigDecimal(5000), new BigDecimal(20));
        Fatturato ftt2 = new Fatturato(new BigDecimal(1000), new BigDecimal(34));
        Fatturato ftt3 = new Fatturato(new BigDecimal(4000), new BigDecimal(67));
        listFatturato.add(ftt1);
        listFatturato.add(ftt2);
        listFatturato.add(ftt3);

        Optional<Fatturato> total = listFatturato.stream().reduce((f1, f2) -> new Fatturato()
                    .impFatturato(f1.getImpFatturato().add(f2.getImpFatturato()))
                    .percNostroPortafoglio(f1.getPercNostroPortafoglio().add(f2.getPercNostroPortafoglio()))

        );
        if (total.isPresent()) {
            MathContext m = new MathContext(3, RoundingMode.HALF_UP);
            Fatturato finalFatturato = total.get().percNostroPortafoglio(total.get().getPercNostroPortafoglio().divide(new BigDecimal(3), m));
            System.out.println(finalFatturato);
        }
    }
}

import java.math.BigDecimal;

public class Fatturato {

    private BigDecimal impFatturato;
    private BigDecimal percNostroPortafoglio;

    public Fatturato() {
        super();
    }

    public Fatturato(BigDecimal impFatturato, BigDecimal percNostroPortafoglio) {
        super();
        this.impFatturato = impFatturato;
        this.percNostroPortafoglio = percNostroPortafoglio;
    }

    public Fatturato impFatturato(BigDecimal impFatturato) {
        this.impFatturato = impFatturato;
        return this;
    }

    public Fatturato percNostroPortafoglio(BigDecimal percNostroPortafoglio) {
        this.percNostroPortafoglio = percNostroPortafoglio;
        return this;
    }

    public BigDecimal getImpFatturato() {
        return impFatturato;
    }


    public BigDecimal getPercNostroPortafoglio() {
        return percNostroPortafoglio;
    }

    @Override
    public String toString() {
        return "Fatturato [impFatturato=" + impFatturato + ", percNostroPortafoglio=" + percNostroPortafoglio + "]";
    }
}

谢谢

标签: javajava-streamreducedivide

解决方案


你在考虑这个问题。在将它们添加到新对象时,您不能简单地使用一条神奇的线来求和和平均这些值。您的方法reduce是正确的,但它要求使用方法的Optional<Fatturato>返回类型的优势进行轻微改进reduce。另外不要忘记您正在处理冗长的类Big*,因此只要 Java 不支持运算符重载,整个代码就会变得臃肿,我会发现这对这个用例很有用。

MathContext m = new MathContext(3, RoundingMode.HALF_UP);

listFatturato.stream()
    // reducing >>>  Fatturato(sum, sum)
    .reduce((f1, f2) -> new Fatturato()
        .impFatturato(f1.getImpFatturato().add(f2.getImpFatturato()))
        .percNostroPortafoglio(f1.getPercNostroPortafoglio().add(f2.getPercNostroPortafoglio())))
    // calculating average using listFatturato.size() >>> Fatturato(sum, avg)
    .map(f -> new Fatturato(f.getImpFatturato(), f.getPercNostroPortafoglio()
          .divide(new BigDecimal(listFatturato.size()), m)))
    // printing out
    .ifPresent(System.out::println);

推荐阅读