如何使用组弹簧数据的MongoDB，并得到每个月的最新值基于一个月的日期？

Question

下面是我的JSON结构的一部分：

   {
       "dateOfCalculation" : ISODate("2018-08-13T06:02:48.587Z"),
       "value" : 6.0
   },
   {
       "dateOfCalculation" : ISODate("2018-08-13T06:04:38.294Z"),
       "value" : 8.0
   },
   {
       "dateOfCalculation" : ISODate("2018-08-30T07:21:08.444Z"),
       "value" : 5.0
   },    
   {
       "dateOfCalculation" : ISODate("2018-10-01T10:04:33.564Z"),
       "value" : 5.58333349227905
   },
   {
       "dateOfCalculation" : ISODate("2018-10-24T11:41:24.188Z"),
       "value" : 5.16666650772095
   },
   {
       "dateOfCalculation" : ISODate("2018-10-26T14:03:54.672Z"),
       "value" : 5.58333349227905
   },    
   {
       "dateOfCalculation" : ISODate("2019-01-10T15:05:44.842Z"),
       "value" : 3.5
   },
   {
       "dateOfCalculation" : ISODate("2019-01-21T10:08:52.429Z"),
       "value" : 6.0
   },
   {
       "dateOfCalculation" : ISODate("2019-01-21T10:38:57.468Z"),
       "value" : 5.16666650772095
   },
   {
       "dateOfCalculation" : ISODate("2019-01-25T14:01:56.779Z"),
       "value" : 6.0
   }

使用Spring-数据MongoDB的，我想这组每月的基础上，并获取记录在最新的日期值。类似下面：对于第8个月 -

    {
        "dateOfCalculation" : ISODate("2018-08-30T07:21:08.444Z"),
        "value" : 5.0
    },

对于第一个月 -

   {
       "dateOfCalculation" : ISODate("2019-01-25T14:01:56.779Z"),
       "value" : 6.0
   }

我应该在Spring的数据MongoDB中使用什么样的聚合操作的，这样我可以将它们基于组的一个月，然后再获取最新当月的？

Answer 1

MongoDB的查询是这样的：

db.yourCollection.aggregate([
    {$addFields: {month: {$month :"$dateOfCalculation"}}},
    {$group:{_id: {month:"$month"},documents:{$push:"$$ROOT"}}},
    {$project:{lastestDate: {$arrayElemAt:["$documents", {$indexOfArray:["$documents",{$max:"$documents.dateOfCalculation"}]}]}}}
])

这种聚合将返回文档与下面的模式：

{
    "_id" : {
        "month" : 1
    },
    "lastestDate" : {
        "_id" : ObjectId("5c59c05fb6f5b50bd40235a1"),
        "dateOfCalculation" : ISODate("2019-01-25T15:01:56.779+01:00"),
        "value" : 6,
        "month" : 1
    }
}

并请在下面的例子中使用Spring数据MongoDB的做出来。

ProjectionOperation projectionOperation1 = project("dateOfCalculation","value").andExpression("month(dateOfCalculation)").as("month");
GroupOperation groupOperation = group("month").push("$$ROOT").as("documents");
ProjectionOperation projectionOperation2 = project().and(ArrayOperators.ArrayElemAt.arrayOf("documents")
        .elementAt(ArrayOperators.IndexOfArray.arrayOf("documents")
                .indexOf(AccumulatorOperators.Max.maxOf("documents.dateOfAccumulation")))).as("latestDate");
 List<yourEntityObject> result = mongoTemplate.aggregate(Aggregation.newAggregation(projectionOperation1,groupOperation,projectionOperation2)
        , "yourCollection", yourEntityObject.class).getMappedResults();

MongoDB的qazxsw POI运营商没有在春季MongoDB中实现，所以你必须使用$addFileds做同样的。关于向ProjectionOperation运营商可以使用eithor或$month SpEL andExpression()。