通过将两个集合与spring数据mongodb数据中的条件合并来获取计数

Question

我有两个名为广告和包含的集合。 对于该广告，我需要在当前月份中包含的包含状态为“ACTIVE”和 lastModifiedDate 的计数。

我还有一个关于 adState 是“ACTIVE”的广告条件。

advertisement document
{

    "_id" : ObjectId("1231321321321"),
    "adNumber":1
    "adState" : "ACTIVE"
    "company" : "companyABC",
    "address" : "123 new road",
    "agentName": "Agent_2"
    "lastpublish" : ISODate("2018-01-18T20:20:02.262Z"),
    "createdDate" : ISODate("2018-01-10T16:03:06.694Z"),
    "lastModifiedDate" : ISODate("2018-01-18T20:20:02.262Z"),
    "createdBy" : "yasa",
    "lastModifiedBy" : "System",   
}

    contains documents

{   

    "_id" : ObjectId("465465456456"),
    "adNumber":1
    "containId": 10
    "containState" : "ACTIVE",
    "title" : "Increase sales by 10%",
    "detials" : "buy this solution to incresce ur sale by 10%",
    "agentName": "Agent_2"
    "createdDate" : ISODate("2018-01-11T15:03:06.694Z"),
    "lastModifiedDate" : ISODate("2018-01-11T15:03:06.694Z"),
    "createdBy" : "yasa",
    "lastModifiedBy" : "System",   
}

{    

    "_id" : ObjectId("56565656555"),
    "adNumber":1
    "containId": 11
    "containState" : "IN-ACTIVE",
    "title" : "Land for sale",
    "detials" : "Land near water park for sale",
    "agentName": "Agent_2"
    "createdDate" : ISODate("2018-01-11T15:30:01.694Z"),
    "lastModifiedDate" : ISODate("2018-01-12T15:03:06.694Z"),
    "createdBy" : "yasa",
    "lastModifiedBy" : "System",   
}

{


    "_id" : ObjectId("56887423587"),
    "adNumber":1
    "containId": 12
    "containState" : "ACTIVE",
    "title" : "car for sale",
    "detials" : "BMW for sale",
    "agentName": "Agent_2"
    "createdDate" : ISODate("2018-01-11T15:45:01.690Z"),
    "lastModifiedDate" : ISODate("2018-01-11T15:45:01.690Z"),
    "createdBy" : "yasa",
    "lastModifiedBy" : "System",   
}

给出代码示例以在 java 中将其合并到 spring-data、mongodb 上。

还建议获得结果聚合或映射减少的最佳方法

聚合查询

db.advertisement.aggregate([
  {$match:{"adState": "ACTIVE", "agentName": "Agent_2"}},
  {$lookup:
   {
     from: "contains",
     localField: "adNumber",
     foreignField: "adNumber",
     as: "result_ad"
   }},
{$project:{result_ad:1}},
{$match:{"result_ad": {'$ne': []}}},  
{$unwind:"$result_ad"},
{$match:{"result_ad.containState" : "ACTIVE"}},
{$group: { _id: null, count: { $sum: 1 } }}])

Answer 1

您可以在 spring mongo 2.x 和 Mongo 3.4 版本中尝试下面的 spring 聚合查询。

Instant startofMonth = LocalDate.now()
                .with( TemporalAdjusters.firstDayOfMonth() ).atStartOfDay().toInstant(ZoneOffset.UTC);
Instant endofMonth = LocalDate.now()
                .with( TemporalAdjusters.lastDayOfMonth() ).atTime(LocalTime.MAX).toInstant(ZoneOffset.UTC);

MatchOperation matchOperation = Aggregation.match(Criteria.where("adState").is("ACTIVE").and("agentName").is("Agent_2"));
LookupOperation lookupOperation = LookupOperation.newLookup().
                from("contains").
                localField("adNumber").
                foreignField("adNumber").
                as("result_ad");
UnwindOperation unwindOperation = Aggregation.unwind("result_ad");
MatchOperation matchOperation2 = Aggregation.match(Criteria.where("result_ad.containState").is("ACTIVE").and("result_ad.lastModifiedDate").gte(startofMonth).lte(endofMonth));
CountOperation countOperation = Aggregation.count().as("count");

Aggregation aggregation = Aggregation.newAggregation(matchOperation, lookupOperation, unwindOperation, matchOperation2, countOperation);
Integer results = mongoOperations.aggregate(aggregation, colname, Document.class).getUniqueMappedResult().getInteger("count");

Answer 2

以下是 mongo 聚合管道，您需要获取计数

步骤

1. $match - 匹配广告 ID
2. $lookup - 加入包含
3. $unwind - 将数组拆分为单个文档
4. $addFields - 检查当前月份的字段
5. $match - 过滤不匹配的文档
6. $group - 计算匹配项

你可以把它翻译成Java、Spring和MongoRepositories

管道

db.advertisement.aggregate(
    [
        { $match : { "adNumber" : 1 } },
        { $lookup : {
                from : "contains",
                localField : "adNumber",
                foreignField : "adNumber",
                as : "cons"
            }
        },
        { $unwind : "$cons" },
        { $addFields : {
                monthMatch : { $eq : [ { $month : new Date() }, { $month : "$cons.lastModifiedDate" }  ] }
            }
        },
        { $match : { "cons.containState" : "ACTIVE", monthMatch : true} },
        { $group : { _id : null, count : { $sum : 1 } } }
    ]
)