Поиск местоположения с помощью $ near и $ geometry в поле $ lookup result

Question

Сценарий: Employee, и они работают в нескольких Store местах и ​​объединяют обе коллекции, что отлично работает,

Проблема в: Поиск в определенном месте ( input lat, long), и этот запрос выдаст конкретного сотрудника, работающего в определенном магазине, и это поле местоположения находится в коллекции поиска.

Сотрудник

{
  "_id": ObjectId("5f03064b3460ef1f10ec2f25"),
  "employeeName": "Anonymous",
  "stores": [
    {
      "storeId": ObjectId("5f03030a3460ef1f10ec2f23"),
      "workTime": "09:30 to 12:30"
    },
    {
      "storeId": ObjectId("5f03064b3460ef1f10ec2f26"),
      "workTime": "01:30 to 02:30"
    }
  ]
}

Магазин

{
  "_id": ObjectId("5f03030a3460ef1f10ec2f23"),
  "storeName": "A",
  "location": {
    "coordinates": ["longitude", "latitude"]
  }
}
{
  "_id": ObjectId("5f03064b3460ef1f10ec2f26"),
  "storeName": "B",
  "location": {
    "coordinates": ["longitude", "latitude"]
  }
}

Ниже приведен окончательный результат, который я получаю успешно:

{
  "_id": ObjectId("5f03064b3460ef1f10ec2f25"),
  "employeeName": "Anonymous",
  "stores": [
    {
      "storeId": ObjectId("5f03030a3460ef1f10ec2f23"),
      "workTime": "09:30 to 12:30",
      "storeLocation": {
        "storeName": "A",
        "location": {
          "coordinates": ["longitude", "latitude"]
        }
      }
    },
    {
      "storeId": ObjectId("5f03064b3460ef1f10ec2f26"),
      "workTime": "01:30 to 02:30",
      "storeLocation": {
        "storeName": "B",
        "location": {
          "coordinates": ["longitude", "latitude"]
        }
      }
    }
  ]
}

Агрегация

db.Enmployee.aggregate([
    { "$unwind": "$stores" },
    {
      "$lookup": {
        "from": "Store",
        "localField": "stores.storeId",
        "foreignField": "_id",
        "as": "stores.storeLocation"
      }
    },
    { "$unwind": "$stores.storeLocation" },
    {
        "$group": {
            "_id": "$_id",
            "root": { "$mergeObjects": "$$ROOT" },
            "stores": { "$push": "$stores" }
        }
    },
    {
        "$replaceRoot": {
            "newRoot": {
                "$mergeObjects": ["$root", "$$ROOT"]
            }
        }
    },
    // <== below $match query will come here
    {
      "$project": {
        "_id": 1,
        "employeeName": 1,
        "stores.workTime": 1,
        "stores.storeLocation.storeName": 1,
        "stores.storeLocation.location": 1
      }
    }
  ]
)

Моя цель - найти сотрудников, они работают с определенным местоположением магазинов, используя его широту и долготу, я пробовал запрос ниже в приведенном выше агрегировании.

{
  "$match": {
    "stores.storeLocation.location": {
      "$near": {
        "$maxDistance": 1000,
        "$geometry": {
          "type": "Point",
          "coordinates": ["Input Longitude", "Input Latitude"]
        }
      }
    }
  }
}

Это дает ошибка:

Failed to execute script.

Error: command failed: {
    "ok" : 0,
    "errmsg" : "$geoNear, $near, and $nearSphere are not allowed in this context",
    "code" : 2,
    "codeName" : "BadValue"
} : aggregate failed 
Details:
_getErrorWithCode@src/mongo/shell/utils.js:25:13
doassert@src/mongo/shell/assert.js:18:14
_assertCommandWorked@src/mongo/shell/assert.js:534:17
assert.commandWorked@src/mongo/shell/assert.js:618:16
DB.prototype._runAggregate@src/mongo/shell/db.js:260:9
DBCollection.prototype.aggregate@src/mongo/shell/collection.js:1062:12
DBCollection.prototype.aggregate@:1:355
@(shell):1:1

Answer 1

$geoNear сам является этапом конвейера, и вы не можете использовать его внутри $match. Кроме того, это должен быть первый этап конвейера, поэтому вам необходимо объявить его в конвейере $lookup. Обратите внимание, что для этого вам также потребуется географический индекс:

db.getCollection('Store').createIndex( { "location.coordinates" : "2dsphere" } )

После внесенных выше изменений запрос будет выглядеть следующим образом:

db.Employee.aggregate([
  { "$unwind": "$stores" },
  {
    "$lookup": {
        from: "Store",
        let: {
          storeId: "$stores.storeId"
        },
        pipeline: [
          { $geoNear: {
                includeLocs: "location",
                distanceField: "distance",
                near: {type: 'Point', coordinates: [57, 35]},
                maxDistance: 1000,
                spherical: true}},
          {
            $match: {
              $expr: { $eq: ["$$storeId", "$_id"] }
            }
          }
    ],
    as: "stores.storeLocation"
  }
},
  { "$unwind": "$stores.storeLocation" },
 
  {
      "$group": {
          "_id": "$_id",
          "root": { "$mergeObjects": "$$ROOT" },
          "stores": { "$push": "$stores" }
      }
  },
  {
      "$replaceRoot": {
          "newRoot": {
              "$mergeObjects": ["$root", "$$ROOT"]
          }
      }
  },
  // <== below $match query will come here
  {
    "$project": {
      "_id": 1,
      "employeeName": 1,
      "stores.workTime": 1,
      "stores.storeLocation.storeName": 1,
      "stores.storeLocation.location": 1
    }
  }
]
)

Вы можете узнать больше примерно $geoNear варианты здесь .