$ match значение локального поля (вложенное поле) не пустая строка в $ lookup pipe - PullRequest
Новая
       20

$ match значение локального поля (вложенное поле) не пустая строка в $ lookup pipe

1 голос
/ 02 апреля 2019

Я не могу использовать вложенное поле в выражении конвейерного поиска, чтобы получить только непустые строковые значения.

Я делаю агрегированный запрос с двумя этапами поиска, где второй запрос поиска зависит от вложенногополе результата первого поиска.Я не могу понять, в чем проблема с моим кодом. 

invoice_lines_collection.aggregate([
        {'$match':{'customer':'rtv'}, 
        {'$lookup':{
            'from':'products',
            'localField':'ArticleNumber',
            'foreignField':'number',
            'as':'article_details'
            }
        },
        {$unwind:{
            'path':'$article_details',
            'preserveNullAndEmptyArrays': true
            }
        },
        {'$lookup':{
            'from':'cutomers',
            'let':{'group_id':'$article_details.group._id',
                   'customer':'$customer'},
            'pipeline':{
                {'$unwind':'$productgroups'},
                {'$match':
                      {'$expr':
                            {$and:
                                  ['$ne':['$$group_id','2'],
                                   '$eq': 
                                    ['$productgroups.id','$$group_id'],
                                    '$eq':['$name','$$customer']
                                  ],
                            }
                        }
                 }
             },
             'as':'customer_data'
         }
      }

])

invoice_lines=[
    {
       "_id" : ObjectId("5c885d21a202fc001103saf7"),
       "ShipmentNumber" : "70727320006714asda4",
       "Price" : 179.57,
        "customer" : "test"
    }
]

products = [
             {
               "_id" : ObjectId("2cv21eba4bd009f00161153b7"),
               "number": "1234",
               "group":{
                          "_id" :'',
                          "name" : '',
                  }
             },
             {
                 "_id" : ObjectId("5ca1eba4bd009f00161153b7"),
                 "number" : "2456",
                 "group" : {
                            "_id" : ObjectId("5ca29852bd009f00185553e3"),
                             "name" : "Test group",
                  }
             }
    ]
customers = [
                {
"_id" : ObjectId("5c6fd17a72ef146fcc29c6a1"),
"name" : "test",
"displayName" : "Test",
"productgroups" : [ 
    {
        "name" : "Test group",
        "id" : ObjectId("5ca29852bd009f00185553e3"),
        "markup" : 0.5
    },
     {
        "name" : "Test group 2",
        "id" : ObjectId("5ca29852bd009f0888554443"),
        "markup" : 3.0
    }
    ]
  }
]

Я хочу иметь только одну группу продуктов и брать только строки счета-фактуры, где статья принадлежит группе, и получать сведения о группе.

Когда я запускаю приведенный выше код (преобразованный в язык PHP), я получаю

Объект, представляющий выражение, должен иметь ровно одно поле: {$ ne: ["", "$$ group_id "] ...

1 Ответ

0 голосов
/ 02 апреля 2019

Я понял, что это была некоторая синтаксическая ошибка, и в конце мне пришлось выполнить этап $ match, чтобы получить только результаты, в которых в строке счета-фактуры есть продукт, который связан с группой продуктов, и мой код теперь выглядит как это: 

db.getCollection('invoice_lines').aggregate([
    {$match:{'customer':'rtv'}}, 
    {$lookup:{
        'from':'products',
        'localField':'ArticleNumber',
        'foreignField':'number',
        'as':'article_details'
        }
    },
    {$unwind:{
        'path':'$article_details',
        'preserveNullAndEmptyArrays': true
        }
    },
    {$lookup:{
        'from':'customers',
        'let':{'group_id':'$article_details.group._id',
               'customer':'$customer'},
        'pipeline':[
            {$unwind:'$productgroups'},
            {'$match':
                  {'$expr':
                        {$and:
                              [
                                {$ne:['$$group_id','']},
                                {$eq:['$productgroups.id','$$group_id']},
                                {$eq:['$name','$$customer']}
                              ],
                        }
                    }
             }
         ],
         'as':'customer_data'
     }
},
 {$match:{'customer_data':{$exists: true, $not: {$size: 0}}}}
...