Агрегировать данные, сгруппированные по дате, но из разных полей даты - PullRequest
Новая
       11

Агрегировать данные, сгруппированные по дате, но из разных полей даты

1 голос
/ 18 июня 2019

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

Итак, на дату 2018-11 (год-месяц), сколько было регистров, сколько было активаций, сколько клиентов и сколько отмен. Но каждая регистрация / активация / клиент / отмена должны учитываться в том месяце, когда это произошло.

Мои данные хранятся следующим образом: 

{
        "track" : {
                "hasBeenCustomer" : true,
                "hasActivated" : true,
                "hasActivatedAt" : ISODate("2018-08-21T14:32:53.929Z"),
                "hasBeenCustomerAt" : ISODate("2019-02-26T07:21:06Z"),
                "hasRegisteredAt" : ISODate("2018-08-09T10:17:38.329Z"),
                "hasCanceled" : true,
                "hasCanceledAt" : ISODate("2019-04-29T13:56:04Z")
        }
}
{
        "track" : {
                "hasBeenCustomer" : true,
                "hasActivated" : true,
                "hasActivatedAt" : ISODate("2018-08-26T15:04:58.854Z"),
                "hasBeenCustomerAt" : ISODate("2018-11-24T10:37:14Z"),
                "hasRegisteredAt" : ISODate("2018-08-25T11:12:36.309Z"),
                "hasCanceled" : true,
                "hasCanceledAt" : ISODate("2019-05-30T18:11:04Z")
        }
}
{
        "track" : {
                "hasBeenCustomer" : true,
                "hasActivated" : true,
                "hasActivatedAt" : ISODate("2018-09-24T23:21:55.733Z"),
                "hasBeenCustomerAt" : ISODate("2019-03-12T10:26:01Z"),
                "hasRegisteredAt" : ISODate("2018-09-22T17:56:57.256Z"),
                "hasCanceled" : true,
                "hasCanceledAt" : ISODate("2019-04-12T10:22:03Z")
        }
}
{
        "track" : {
                "hasBeenCustomer" : true,
                "hasActivated" : true,
                "hasActivatedAt" : ISODate("2018-10-18T15:08:15.351Z"),
                "hasBeenCustomerAt" : ISODate("2018-12-22T21:37:01Z"),
                "hasRegisteredAt" : ISODate("2018-10-16T03:54:16.056Z"),
                "hasCanceled" : true,
                "hasCanceledAt" : ISODate("2019-01-22T21:39:03Z")
        }
}

Я пробовал это: 

db.user.aggregate(
    [
        { 
            $match: 
                { 
                    projectId : "00001"
                } 
        },
        {
            "$project": {
                "createDate": { 
                    "$dateToString": { 
                        "format": "%Y-%m", 
                        "date": "$track.hasRegisteredAt" 
                    } 
                },
                activationAt: { 
                    "$dateToString": { 
                        "format": "%Y-%m", 
                        "date": "$track.hasActivatedAt" 
                    } 
                },
                customerAt: { 
                    "$dateToString": { 
                        "format": "%Y-%m", 
                        "date": "$track.hasBeenCustomerAt" 
                    } 
                },
                cancelAt: { 
                    "$dateToString": { 
                        "format": "%Y-%m", 
                        "date": "$track.hasCanceledAt" 
                    } 
                },
                activations: { 
          "$sum": { 
              "$cond": [
                  { "$eq": [ "$track.hasActivated", true ] },
                  1,
                  0
              ]
          }
        },              
                customers: { 
          "$sum": { 
              "$cond": [
                  { "$eq": [ "$track.hasBeenCustomer", true ] },
                  1,
                  0
              ]
          }
        },
                cancels: { 
          "$sum": { 
              "$cond": [{ 
                                "$and": [ 
                                    { "$eq": [ "$status", 3 ] },
                                    { "$eq": [ "$track.hasCanceled", true ] }
                                ]},  
                  1,
                  0
              ]
          }
        }
            }
        },      
        {
            $group:
                {
                    _id: "$createDate",
                    users: {$sum: 1},
                    activations: {$sum: "$activations"},
                    activationsM: { 
            "$sum": { 
                "$cond": [
                    { "$eq": [ "$activationAt", "$createDate" ] },
                    1,
                    0
                ]
            }
            },
                    customers: {$sum: "$customers"},
                    customersM: { 
            "$sum": { 
                "$cond": [
                    { "$eq": [ "$customerAt", "$createDate" ] },
                    1,
                    0
                ]
            }
            },
                    cancels: {$sum: "$cancels"},
                    cancelsM: { 
            "$sum": { 
                "$cond": [
                    { "$eq": [ "$cancelAt", "$createDate" ] },
                    1,
                    0
                ]
            }
            },
                }
        },
        {
            $sort: 
                { 
                    _id: 1
                }
        }
    ]
)

activationsM, CustomersM, cancellsM, должны быть подсчетом в месяц независимо от поля _id, но я понял, что этот запрос освобождает результаты, соответствующие _id, и, как только он совпадает с ним, он проверяет условие , Мне нужно, чтобы сумма была суммой, даже если _id не соответствует полям hasActivationAt, hasBeenCustomerAt, hasCanceledAt. * ​​1011 *

Надеюсь, я все правильно объяснил.

Желаемый результат будет: 

{ "_id" : "2018-06", "users" : 18, "activations" : 5, "activationsM" : 2, "customers" : 4, "customersM" : 0, "cancels" : 1, "cancelsM" : 0 }
{ "_id" : "2018-07", "users" : 78, "activations" : 39, "activationsM" : 31, "customers" : 11, "customersM" : 0, "cancels" : 7, "cancelsM" : 0 }
{ "_id" : "2018-08", "users" : 115, "activations" : 49, "activationsM" : 38, "customers" : 18, "customersM" : 0, "cancels" : 8, "cancelsM" : 0 }

Быть fiedlM общее количество для соответствующей даты поля и поля даты _id.

Спасибо.

1 Ответ

1 голос
/ 18 июня 2019

Попробуйте, как показано ниже: 

db.collection.aggregate([
    {
        $facet: {
            "TOTAL_ACTIVATION": [
                {
                    $group: { 
                        _id: "$track.hasActivated",
                        total: { "$sum": 1 }, 
                        "totalActiveCustomer": {
                            "$sum": { "$cond": [
                                { "$eq": [ "$track.hasActivated", true ] },
                                1,
                                0
                            ]}
                        },
                        "totalNonActiveCustomer": {
                            "$sum": { "$cond": [
                                { "$eq": [ "$track.hasActivated", false ] },
                                1,
                                0
                            ]}
                        },

                    }
                }
            ],
            "TOTAL_CUSTOMERS": [
                {
                    $group: { 
                        _id: "$track.hasBeenCustomer",
                        total: { "$sum": 1 },
                        "totalCustomer": {
                            "$sum": { "$cond": [
                                { "$eq": [ "$track.hasBeenCustomer", true ] },
                                1,
                                0
                            ]}
                        },
                        "totalNonCustomer": {
                            "$sum": { "$cond": [
                                { "$eq": [ "$track.hasBeenCustomer", false ] },
                                1,
                                0
                            ]}
                        },
                    }
                }
            ],
            "TOTAL_CANCELLED": [
                {
                    $group: { 
                        _id: "$track.hasCanceled",
                        total: { "$sum": 1 },
                        "totalCancelledCustomer": {
                            "$sum": { "$cond": [
                                { "$eq": [ "$track.hasCanceled", true ] },
                                1,
                                0
                            ]}
                        },
                        "totalNonCancelledCustomer": {
                            "$sum": { "$cond": [
                                { "$eq": [ "$track.hasCanceled", false ] },
                                1,
                                0
                            ]}
                        },
                    }
                }
            ],
            "MONTHLY_ACTIVATION" : [
                {
                    $group: { 
                        _id: {
                            year: { $year: "$track.hasActivatedAt" },
                            month: { $month: "$track.hasActivatedAt" }
                        },
                        totalThisMonth: { $sum : 1},
                        "totalActiveCustomer": {
                            "$sum": { "$cond": [
                                { "$eq": [ "$track.hasActivated", true ] },
                                1,
                                0
                            ]}
                        },
                        "totalNonActiveCustomer": {
                            "$sum": { "$cond": [
                                { "$eq": [ "$track.hasActivated", false ] },
                                1,
                                0
                            ]}
                        },
                    }   
                }

            ],
            "MONTHLY_CUSTOMER" : [
                {
                    $group: { 
                        _id: {
                            year: { $year: "$track.hasBeenCustomerAt" },
                            month: { $month: "$track.hasBeenCustomerAt" }
                        },
                        totalThisMonth: { $sum : 1},
                        "totalCustomer": {
                            "$sum": { "$cond": [
                                { "$eq": [ "$track.hasBeenCustomer", true ] },
                                1,
                                0
                            ]}
                        },
                        "totalNonCustomer": {
                            "$sum": { "$cond": [
                                { "$eq": [ "$track.hasBeenCustomer", false ] },
                                1,
                                0
                            ]}
                        },
                    }   
                }

            ],
            "MONTHLY_CANCELLED" : [
                {
                    $group: { 
                        _id: {
                            year: { $year: "$track.hasCanceledAt" },
                            month: { $month: "$track.hasCanceledAt" }
                        },
                        totalThisMonth: { $sum : 1},
                        "totalCancelledCustomer": {
                            "$sum": { "$cond": [
                                { "$eq": [ "$track.hasCanceled", true ] },
                                1,
                                0
                            ]}
                        },
                        "totalNonCancelledCustomer": {
                            "$sum": { "$cond": [
                                { "$eq": [ "$track.hasCanceled", false ] },
                                1,
                                0
                            ]}
                        },
                    }   
                }

            ]

        }
    }
])

Результат будет следующим: 

{
    "TOTAL_ACTIVATION" : [
        {
            "_id" : true,
            "total" : 4,
            "totalActiveCustomer" : 4,
            "totalNonActiveCustomer" : 0
        }
    ],
    "TOTAL_CUSTOMERS" : [
        {
            "_id" : true,
            "total" : 4,
            "totalCustomer" : 4,
            "totalNonCustomer" : 0
        }
    ],
    "TOTAL_CANCELLED" : [
        {
            "_id" : true,
            "total" : 4,
            "totalCancelledCustomer" : 4,
            "totalNonCancelledCustomer" : 0
        }
    ],
    "MONTHLY_ACTIVATION" : [
        {
            "_id" : {
                "year" : NumberInt(2018),
                "month" : NumberInt(10)
            },
            "totalThisMonth" : 1,
            "totalActiveCustomer" : 1,
            "totalNonActiveCustomer" : 0
        },
        {
            "_id" : {
                "year" : NumberInt(2018),
                "month" : NumberInt(9)
            },
            "totalThisMonth" : 1,
            "totalActiveCustomer" : 1,
            "totalNonActiveCustomer" : 0
        },
        {
            "_id" : {
                "year" : NumberInt(2018),
                "month" : NumberInt(8)
            },
            "totalThisMonth" : 2,
            "totalActiveCustomer" : 2,
            "totalNonActiveCustomer" : 0
        }
    ],
    "MONTHLY_CUSTOMER" : [
        {
            "_id" : {
                "year" : NumberInt(2018),
                "month" : NumberInt(12)
            },
            "totalThisMonth" : 1,
            "totalCustomer" : 1,
            "totalNonCustomer" : 0
        },
        {
            "_id" : {
                "year" : NumberInt(2019),
                "month" : NumberInt(3)
            },
            "totalThisMonth" : 1,
            "totalCustomer" : 1,
            "totalNonCustomer" : 0
        },
        {
            "_id" : {
                "year" : NumberInt(2018),
                "month" : NumberInt(11)
            },
            "totalThisMonth" : 1,
            "totalCustomer" : 1,
            "totalNonCustomer" : 0
        },
        {
            "_id" : {
                "year" : NumberInt(2019),
                "month" : NumberInt(2)
            },
            "totalThisMonth" : 1,
            "totalCustomer" : 1,
            "totalNonCustomer" : 0
        }
    ],
    "MONTHLY_CANCELLED" : [
        {
            "_id" : {
                "year" : NumberInt(2019),
                "month" : NumberInt(1)
            },
            "totalThisMonth" : 1,
            "totalCancelledCustomer" : 1,
            "totalNonCancelledCustomer" : 0
        },
        {
            "_id" : {
                "year" : NumberInt(2019),
                "month" : NumberInt(5)
            },
            "totalThisMonth" : 1,
            "totalCancelledCustomer" : 1,
            "totalNonCancelledCustomer" : 0
        },
        {
            "_id" : {
                "year" : NumberInt(2019),
                "month" : NumberInt(4)
            },
            "totalThisMonth" : 2,
            "totalCancelledCustomer" : 2,
            "totalNonCancelledCustomer" : 0
        }
    ]
}
...