时间戳

首页 > 解决方案 > Java Mongo模板中同一查询中的Mongo DB日期差异和查询条件

java - Java Mongo模板中同一查询中的Mongo DB日期差异和查询条件

问题描述

大家好，我试图进行如下查询

更新日期超过 2 小时，则 status=inprogress 获取所有任务。查询样本日期是

{
    "_id" : "ATK-l64KC3vm",
    "nodeid" : "NOD-AJaodNfH",
    "accountid" : "d983356b-7fde-4683-9ba5-e6b6f5a0680d",
    "applicationid" : "59a57cb7-7d67-4d55-bd6c-ff537bcf05d6",
    "avmdepid" : "DEP-1aa81899",
    "instanceId" : "INS-YNXr1ldB",
    "cloudinstanceid" : "",
    "inputxml" : "",
    "status" : "No value present",
    "callbackUrl" : "",
    "callbackMethod" : "PUT",
    "callbackInput" : "<input></input>",
    "priority" : "false",
    "type" : "datapush",
    "createdDt" : ISODate("2020-05-20T05:56:55.467Z"),
    "updatedDt" : ISODate("2020-05-20T05:56:55.478Z"),
    "agentid" : "IAG-R2koJqnk"
}

请帮助在 java Mongo 模板聚合过滤器中进行此查询

标签： javamongodbspring-dataaggregation-framework

解决方案

首先，我们可以使用$addFields或$set向文档中添加新字段（临时）来保存时差。（以毫秒为单位）

db.collectionName.aggregate([
  {"$addFields": {"timeDiff": { $subtract: [new Date(), "$updatedDt"]}}}
]);

现在，我们将使用这些字段来过滤记录$match

db.collectionName.aggregate([
 {"$addFields": {"timeDiff": { $subtract: [new Date(), "$updatedDt"]}}},
 {$match: {"timeDiff":{ $gte: 2* 60* 60* 1000},"status":"in-progress"}}
]);

现在，我们可以使用删除额外添加的字段$project

db.collectionName.aggregate([
 {"$addFields": {"timeDiff": { $subtract: [new Date(), "$updatedDt"]}}}, 
 {$match:{"timeDiff":{$gte: 2* 60* 60* 1000},"status":"in-progress"}},
 {$project: {"timeDiff":0}}
]);

推荐阅读