Java利用Stream流实现部门数据结算

需求：某个公司的开发部门，分为开发一部和二部，现在需要进行年中数据结算。

分析:
     1.员工信息至少包含了(名称、性别、工资、奖金、处罚记录)
     2.开发一部有4个员工、开发二部有5名员工
     3.分别筛选出2个部门的最高工资的员工信息，封装成优秀员工对象Topperformer
     4.分别统计出2个部门的平均月收入，要求去掉最高和最低工资。
     5.统计2个开发部门整体的平均工资，去掉最低和最高工资的平均值。

实现代码

StreamTest2类（实现类）

package stream.exception.log.d2_stream;

import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.ArrayList;
import java.util.Comparator;
import java.util.List;
import java.util.stream.Stream;

/**
    需求：某个公司的开发部门，分为开发一部和二部，现在需要进行年中数据结算。

    分析:
         1.员工信息至少包含了(名称、性别、工资、奖金、处罚记录)
         2.开发一部有4个员工、开发二部有5名员工
         3.分别筛选出2个部门的最高工资的员工信息，封装成优秀员工对象Topperformer
         4.分别统计出2个部门的平均月收入，要求去掉最高和最低工资。
         5.统计2个开发部门整体的平均工资，去掉最低和最高工资的平均值。

 */
public class StreamTest2 {
    //定义一个静态变量来计算工资
    public static double allMoney;
    //定义一个静态变量来计算两个部门的总工资
    public static double allMoney2;

    public static void main(String[] args) {


        List one=new ArrayList<>();

        one.add(new Employee("猪八戒",'男',30000,25000,null));
        one.add(new Employee("孙悟空",'男',25000,1000,"顶撞上司"));
        one.add(new Employee("沙僧",'男',20000,20000,null));
        one.add(new Employee("小白龙",'男',20000,25000,null));

        List tow=new ArrayList<>();

        tow.add(new Employee("武松",'男',15000,9000,null));
        tow.add(new Employee("李逵",'男',20000,10000,null));
        tow.add(new Employee("西门庆",'男',50000,100000,"被打"));
        tow.add(new Employee("潘金莲",'女',3500,1000,"被打"));
        tow.add(new Employee("武大郎",'男',20000,9000,"被下毒"));


        //1.开发一部的最高工资的员工
        //新建比较器，制定比较规则
//        Employee e=one.stream().max((e1,e2) ->Double.compare(e1.getSalary()+e1.getBonus(),e2.getSalary()+e2.getBonus())).get();
//        System.out.println(e);

        //将员工加入Topperformer类中封装
        Topperformer t=one.stream().max((e1,e2) ->Double.compare(e1.getSalary()+e1.getBonus(),e2.getSalary()+e2.getBonus()))
                .map(e ->new Topperformer(e.getName(),e.getSalary()+e.getBonus())).get();
        System.out.println(t);


        //2.统计平均工资，去掉最低与最高工资的平均值
            //开发一部
        //先排序
        one.stream().sorted((e1,e2) ->Double.compare(e1.getSalary()+e1.getBonus(),e2.getSalary()+e2.getBonus()))
                .skip(1).limit(one.size()-2).forEach(e -> {
                        allMoney+=(e.getSalary()+e.getBonus());
                });

        System.out.println("开发一部的平均工资为："+allMoney/(one.size()-2));

            //开发二部
        //先排序
        tow.stream().sorted((e1,e2) ->Double.compare(e1.getSalary()+e1.getBonus(),e2.getSalary()+e2.getBonus()))
                .skip(1).limit(tow.size()-2).forEach(e -> {
                    //求出总和
                    allMoney+=(e.getSalary()+e.getBonus());
                });

        System.out.println("开发二部的平均工资为："+allMoney/(tow.size()-2));


        //3.统计两个开发部门的平均月收入，去掉最低与最高工资的平均值
            //合并流
        Stream s1=one.stream();
        Stream s2=tow.stream();
        Stream s3=Stream.concat(s1, s2);

        s3.sorted((o1,o2)->Double.compare(o1.getSalary()+ o1.getBonus(), o2.getSalary()+ o2.getBonus()))
                .skip(1).limit(one.size()+ tow.size()-2).forEach(e->{
                    //求出总和
                    allMoney2+=(e.getBonus()+e.getSalary());
                });

        //为了使结果更为精准，引入BigDecimal
        BigDecimal a=BigDecimal.valueOf(allMoney2);
        BigDecimal b=BigDecimal.valueOf(one.size()+ tow.size()-2);
        System.out.println("开发部的总开发工资："+a.divide(b,2, RoundingMode.HALF_UP));//结果不精准,将数据保留2位小数，并四舍五入。
    }
}

Employee类（员工类 ）

package stream.exception.log.d2_stream;

/**
    员工类
 */
public class Employee {
    private String name;
    private char sex;
    private double salary;
    private double bonus;
    private String punish;

    public Employee() {
    }

    public Employee(String name, char sex, double salary, double bonus, String punish) {
        this.name = name;
        this.sex = sex;
        this.salary = salary;//工资
        this.bonus = bonus;//奖金
        this.punish = punish;//处罚信息
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public char getSex() {
        return sex;
    }

    public void setSex(char sex) {
        this.sex = sex;
    }

    public double getSalary() {
        return salary;
    }

    public void setSalary(double salary) {
        this.salary = salary;
    }

    public double getBonus() {
        return bonus;
    }

    public void setBonus(double bonus) {
        this.bonus = bonus;
    }

    public String getPunish() {
        return punish;
    }

    public void setPunish(String punish) {
        this.punish = punish;
    }

    @Override
    public String toString() {
        return "Employee{" +
                "name='" + name + '\'' +
                ", sex=" + sex +
                ", salary=" + salary +
                ", bonus=" + bonus +
                ", punish='" + punish + '\'' +
                '}';
    }
}

Topperformer类（优秀员工类）

package stream.exception.log.d2_stream;

/**
    优秀员工类
 */
public class Topperformer {
    private String name;
    private double money;//月薪

    public Topperformer() {
    }

    public Topperformer(String name, double money) {
        this.name = name;
        this.money = money;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public double getMoney() {
        return money;
    }

    public void setMoney(double money) {
        this.money = money;
    }

    @Override
    public String toString() {
        return "Topperformer{" +
                "name='" + name + '\'' +
                ", money=" + money +
                '}';
    }
}

运行截图