在分页查询中，一般是需要返回符合条件的文档总数的，下面的代码是先获取文档总数count，然后获取0-20条数据。这两部分的代码高度重复，如果查询条件复杂的话，更是十分冗长。

  // 文档总数量count读取
    let queryCount = db.collection('cats-order').aggregate()
  .match(orderMatch)
  .project({
    shopId: true,
    customerId: true,
    status: true,
    services: true,
    createTime: true,
  })
  .lookup({
    from: 'cats-shop',
    let : {
      shopId: '$shopId'
    },
    pipeline: $.pipeline()
    .match(_.expr($.and([
      $.eq(['$_id', '$$shopId'])
    ])))
    .project({
      _id: false,
      shopTitle: '$title'
    })
    .done(),
    as: 'shops'
  })
  .replaceRoot({
    newRoot: $.mergeObjects([$.arrayElemAt(['$shops', 0]), '$$ROOT'])
  })
  .project({
    shops: false
  })
  .lookup({
    from: 'cats-customer',
    let: {
      customerId: '$customerId'
    },
    pipeline: $.pipeline()
    .match(_.expr($.and([
      $.eq(['$_id', '$$customerId'])
    ]))).project({
      _id: false,
      customerTitle: '$title',
      customerPhone: '$phone',
      customerLevel: '$level'
    }).done(),
    as: 'customers'
  })
  .replaceRoot({
    newRoot: $.mergeObjects([$.arrayElemAt(['$customers', 0]), '$$ROOT'])
  })
  .project({
    customers: false
  })
  if (searchWord) {
    queryCount = queryCount.match(_.or([{
      customerTitle: new RegExp(searchWord, 'i')
    }, {
      customerPhone: new RegExp(searchWord, 'i')
    }]))
  }
  let countRes = await queryCount.count('total').end()
  pager.Total = countRes.list[0].total

    // 分页数据读取
  let queryList = db.collection('cats-order').aggregate()
  .match(orderMatch)
  .project({
    shopId: true,
    customerId: true,
    status: true,
    services: true,
    createTime: true,
  })
  .lookup({
    from: 'cats-department',
    let : {
      shopId: '$shopId'
    },
    pipeline: $.pipeline()
    .match(_.expr($.and([
      $.eq(['$_id', '$$shopId'])
    ])))
    .project({
      _id: false,
      shopTitle: '$title'
    })
    .done(),
    as: 'shops'
  })
  .replaceRoot({
    newRoot: $.mergeObjects([$.arrayElemAt(['$shops', 0]), '$$ROOT'])
  })
  .project({
    shops: false
  })
  .lookup({
    from: 'cats-customer',
    let: {
      customerId: '$customerId'
    },
    pipeline: $.pipeline()
    .match(_.expr($.and([
      $.eq(['$_id', '$$customerId'])
    ]))).project({
      _id: false,
      customerTitle: '$title',
      customerPhone: '$phone',
      customerLevel: '$level'
    }).done(),
    as: 'customers'
  })
  .replaceRoot({
    newRoot: $.mergeObjects([$.arrayElemAt(['$customers', 0]), '$$ROOT'])
  })
  .project({
    customers: false
  })
  if (searchWord) {
    queryList = queryList.match(_.or([{
      customerTitle: new RegExp(searchWord, 'i')
    }, {
      customerPhone: new RegExp(searchWord, 'i')
    }]))
  }
  let listRes = await queryList.sort({createTime: -1}).skip(pager.Offset).limit(pager.Limit).end()


  return {
    data: listRes.list,
    pager, // 返回{ data, pager: {Offset, Limit, Total }}这样的数据结构，是为了和云数据库的http读取方式统一
    errMsg: 'collection.aggregate:ok'
  }