總計和查找到另一個集合

Question

我有兩個模式，一個是User另一個是Pet。 Pet架構在User.aggregate管道中有我想要$sum的信息。

Mongo版本是3.4.1。

用戶模式：

pets: [{type: Schema.Types.ObjectId, ref: 'Pets'}] 

寵物模式：

 owner: {type: Schema.Types.ObjectId, ref: 'User'}, 
     petLost: { 
     lost   : {type: Boolean, default: false}, 
     lostDate  : {type: String}, 
     selectedComRange: {type: Number, default: 5}, 
     circumstances : {type: String}, 
     extraInfoLost : {type: String}, 
     rewardCheck  : {type: Boolean, default: false}, 
     reward   : {type: String}, 
     addressLost  : {type: String}, 
     } 

這是查找：

{'$unwind': '$pets'}, 
    { 
     '$lookup': { 
     'from'  : 'pets', 
     'localField' : '_id', 
     'foreignField': '_id', 
     'as'   : 'lostPets' 
     } 
    }, 
{'$unwind': {path: '$lostPets', preserveNullAndEmptyArrays:true}} 

這裏就是我想要達到的條件：

'lostPet_count': { 
      '$sum': { 
      '$cond': [{'$eq': ['$lostPets.lost', true]}, 1, 0] 
      } 
     } 

總管道：

User.aggregate([ 
     { 
      $group: { 
      _id    : null, 
      'users_count' : { 
       '$sum': { 
       '$cond': [{'$eq': ['$role', 'user']}, 1, 0] 
       } 
      }, 
      'volunteer_count': { 
       '$sum': { 
       '$cond': [{'$eq': ['$isVolunteer', true]}, 1, 0] 
       } 
      }, 
      'pet_count'  : { 
       '$sum': { 
       $size: '$pets' 
       } 
      }, 
      'lost_pet'  : { 
       '$sum': { 
       **// how can i call another collection and $sum some data?** 
       } 
      } 
      } 
     }, 
     { 
      '$project': { 
      '_id'  : 0, 'role': '$_id', 
      'statistics': { 
       'users'  : '$users_count', 
       'volunteers': '$volunteer_count', 
       'pets'  : '$pet_count' 
      } 
      } 
     } 
     ]).exec((err, result) => { 
     if (err) { 
      console.log(err); 
     } 
     res.status(200).json(result); 
     }); 

我如何注入到信息財產'lost_pet'從寵物模式？

Answer 1

下面的管道應返回所需的結果：

Pets.aggregate([ 
    { 
     '$lookup': { 
      'from': 'users', 
      'localField': 'owner', 
      'foreignField': '_id', 
      'as': 'users' 
     } 
    }, 
    { '$unwind': { 'path': '$users', 'preserveNullAndEmptyArrays': true } }, 
    { 
     '$group': { 
      '_id': '$users._id', 
      'users_count': { 
       '$sum': { 
        '$cond': [{'$eq': ['$users.role', 'user']}, 1, 0] 
       } 
      }, 
      'volunteer_count' : { 
       '$sum': { 
        '$cond': ['$users.isVolunteer', 1, 0] 
       } 
      }, 
      'pet_count': { '$sum': 1 }, 
      'lost_pets': { 
       '$sum': { 
        '$cond': ['$petLost.lost', 1, 0] 
       } 
      }  
     } 
    }, 
    { 
     '$project': { 
      '_id': 0, 'role': '$_id', 
      'statistics': { 
       'users': '$users_count', 
       'volunteers': '$volunteer_count', 
       'pets': '$pet_count', 
       'lostpets': '$lost_pets' 
      } 
     } 
    } 
]).exec((err, result) => { 
    if (err) { 
     console.log(err); 
    } 
    res.status(200).json(result); 
}); 

---

還是從User模型作爲聚合

User.aggregate([ 
    { '$unwind': '$pets' }, 
    { 
     '$lookup': { 
      'from': 'pets', 
      'localField': 'pets', 
      'foreignField': '_id', 
      'as': 'pets' 
     } 
    }, 
    { '$unwind': { 'path': '$pets', 'preserveNullAndEmptyArrays': true } } 
    { 
     '$group': { 
      '_id': '$_id', 
      'role': { '$first': '$role' }, 
      'isVolunteer': { '$first': '$isVolunteer' }, 
      'pet_count': { '$sum': 1 }, 
      'lost_pets': { 
       '$sum': { 
        '$cond': ['$pets.petLost.lost', 1, 0] 
       } 
      } 
     } 
    }, 
    { 
     '$group': { 
      '_id': null, 
      'users_count': { 
       '$sum': { 
        '$cond': [{'$eq': ['$role', 'user']}, 1, 0] 
       } 
      }, 
      'volunteer_count' : { 
       '$sum': { 
        '$cond': ['$isVolunteer', 1, 0] 
       } 
      }, 
      'pet_count': { '$sum': '$pet_count' }, 
      'lost_pets': { '$sum': '$lost_pets' } 
     } 
    }, 
    { 
     '$project': { 
     '_id': 0, 'role': '$_id', 
     'statistics': { 
      'users': '$users_count', 
      'volunteers': '$volunteer_count', 
      'pets': '$pet_count', 
      'lostpets': '$lost_pets' 
     } 
     } 
    } 
]).exec((err, result) => { 
    if (err) { 
     console.log(err); 
    } 
    res.status(200).json(result); 
});