data-dwh-dbt-project/models/intermediate/cross/int_mtd_deal_metrics.sql

/*
This model provides Month-To-Date (MTD) based on Deal metrics.

*/
{% set dimensions = get_kpi_dimensions() %}

{{ config(materialized="table", unique_key=["date", "dimension", "dimension_value"]) }}

with
    int_mtd_deal_lifecycle as (select * from {{ ref("int_mtd_deal_lifecycle") }}),
    int_dates_mtd_by_dimension as (
        select * from {{ ref("int_dates_mtd_by_dimension") }}
    ),
    int_core__mtd_accommodation_segmentation as (
        select * from {{ ref("int_core__mtd_accommodation_segmentation") }}
    ),
    int_core__deal as (select * from {{ ref("int_core__deal") }}),
    deals_metric_aggregation_per_date as (
        {% for dimension in dimensions %}
            select
                al.date,
                {{ dimension.dimension }} as dimension,
                {{ dimension.dimension_value }} as dimension_value,
                count(
                    distinct case
                        when al.deal_lifecycle_state = '01-New'
                        then al.id_deal
                        else null
                    end
                ) as new_deals,
                count(
                    distinct case
                        when al.deal_lifecycle_state = '02-Never Booked'
                        then al.id_deal
                        else null
                    end
                ) as never_booked_deals,
                count(
                    distinct case
                        when al.deal_lifecycle_state = '03-First Time Booked'
                        then al.id_deal
                        else null
                    end
                ) as first_time_booked_deals,
                count(
                    distinct case
                        when al.deal_lifecycle_state = '04-Active'
                        then al.id_deal
                        else null
                    end
                ) as active_deals,
                count(
                    distinct case
                        when al.deal_lifecycle_state = '05-Churning'
                        then al.id_deal
                        else null
                    end
                ) as churning_deals,
                count(
                    distinct case
                        when al.deal_lifecycle_state = '06-Inactive'
                        then al.id_deal
                        else null
                    end
                ) as inactive_deals,
                count(
                    distinct case
                        when al.deal_lifecycle_state = '07-Reactivated'
                        then al.id_deal
                        else null
                    end
                ) as reactivated_deals,
                sum(
                    case when has_been_booked_within_current_month then 1 else 0 end
                ) as deals_booked_in_month,
                sum(
                    case when has_been_booked_within_last_6_months then 1 else 0 end
                ) as deals_booked_in_6_months,
                sum(
                    case when has_been_booked_within_last_12_months then 1 else 0 end
                ) as deals_booked_in_12_months
            from int_mtd_deal_lifecycle al
            {% if dimension.dimension == "'by_number_of_listings'" %}
                inner join
                    int_core__mtd_accommodation_segmentation mas
                    on al.id_deal = mas.id_deal
                    and al.date = mas.date
            {% elif dimension.dimension == "'by_billing_country'" %}
                inner join
                    int_core__deal ud
                    on al.id_deal = ud.id_deal
                    and ud.main_billing_country_iso_3_per_deal is not null
            {% endif %}
            group by 1, 2, 3
            {% if not loop.last %}
                union all
            {% endif %}
        {% endfor %}
    )
-- Final aggregation of subqueries --
select
    d.year,
    d.month,
    d.day,
    d.date,
    d.dimension,
    d.dimension_value,
    d.is_end_of_month,
    d.is_current_month,
    nullif(l.new_deals, 0) as new_deals,
    nullif(l.never_booked_deals, 0) as never_booked_deals,
    nullif(l.first_time_booked_deals, 0) as first_time_booked_deals,
    nullif(l.active_deals, 0) as active_deals,
    nullif(l.churning_deals, 0) as churning_deals,
    nullif(l.inactive_deals, 0) as inactive_deals,
    nullif(l.reactivated_deals, 0) as reactivated_deals,
    nullif(l.deals_booked_in_month, 0) as deals_booked_in_month,
    nullif(l.deals_booked_in_6_months, 0) as deals_booked_in_6_months,
    nullif(l.deals_booked_in_12_months, 0) as deals_booked_in_12_months
from int_dates_mtd_by_dimension d
left join
    deals_metric_aggregation_per_date l
    on l.date = d.date
    and l.dimension = d.dimension
    and l.dimension_value = d.dimension_value