Можете да обобщите като:
$match
документите за конкретната дата.- Конструирайте
$group
и$project
обекти преди заявка. $group
до$hour
, натрупва всички документи на час на минута в масив. Съхранявайте минутата някъде в документа.$project
променлива документира като$setUnion
от всички документи на час.$unwind
документите.$sort
поorders
$limit
първите10
документи, което изискваме.
Код:
var inputDate = new ISODate("2015-01-09T13:00:00Z");
var group = {};
var set = [];
for(var i=0;i<=60;i++){
group[i] = {$push:{"doc":"$vals."+i,
"hour":"$_id.hour",
"min":{$literal:i}}};
set.push("$"+i);
}
group["_id"] = {$hour:"$hour"};
var project = {"docs":{$setUnion:set}}
db.t.aggregate([
{$match:{"hour":{$lte:inputDate,$gte:inputDate}}},
{$group:group},
{$project:project},
{$unwind:"$docs"},
{$sort:{"docs.doc.orders":-1}},
{$limit:2},
{$project:{"_id":0,
"hour":"$_id",
"doc":"$docs.doc",
"min":"$docs.min"}}
])