按客戶ID標記客戶ID的唯一記錄，並跟蹤客戶ID的總記錄

Question

我試圖按月份和年份獲取一組mongo文檔。目前的查詢我的作品：

var query = Order.aggregate(
     { 
      $project: 
      { 
       cust_ID : '$request.headers.custID', 
       cost : '$request.body.expectedPrice', 
       year : 
       { 
        $year: '$date' 
       }, 
       month: 
       { 
        $month: '$date' 
       } 
      } 
     }, 
     { 
      $match: 
      { 
       year : year, 
       month: month 
      } 
     } 
    ); 

但我也需要聚合/按客戶ID推總訂單，所以我說這查詢的中期階段$project和$match之間。該查詢回來空，甚至以爲我知道有結果：

 { 
      $group: 
      { 
       "_id": "$request.headers.custID", 
       "custID" : { 
        "$first" : "$request.headers.custID" 
       }, 
       "orders": 
       { 
        "$push": 
        { 
         "order": "$request.body" 
        } 
       } 
      } 
     }, 

我想補充一點聚合push至$項目，但項目$不支持。我該如何編寫這個查詢？

Answer 1

既然你已經通過$project管道新的領域，你應該通過他們到一個流水線一步，因爲它們的定義：

var pipeline = [ 
    { 
     "$project": { 
      cust_ID: '$request.headers.custID', 
      "cost": '$request.body.expectedPrice', 
      "year": { "$year": '$date' }, 
      "month": { "$month": '$date' }, 
      "order": "request.body" 
     } 
    }, 
    { 
     "$match": { 
      "year": year, 
      "month": month 
     } 
    }, 
    { 
     "$group": { 
      "_id": "$cust_ID", 
      "custID": { "$first" : "$cust_ID" }, 
      "cost": { "$first" : "$cost" }, 
      "orders": { "$push": "$order" }     
     } 
    }, 
] 

var query = Order.aggregate(pipeline)