如下样例代码：在集合内取总收入，然后下一级取A部门的总收入，输出，可实际上这样的代码是报错的无法生效，请教一下大佬该如何实现呢？

db.collection('demo').aggregate()

      .match({

        stage: "已确认",

        Process: _.in(["第一阶段", "第二阶段", "第三阶段"])

      })

      .group({

        _id: 0,

        TotalEarning: $.sum('$Earning')

      })

      .match({

        Department:"A部门"

      })

      .group({

        _id: 1,

        TotalEarning: $.sum('$Earning')

      })

      .end()