counterweight/data-dwh-dbt-project
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Commit wip

Browse source
This commit is contained in:
Joaquin 2025-04-28 09:20:59 +02:00
parent b230bf8f47
commit afb9e7ae01
1 changed files with 11 additions and 17 deletions
Download patch file Download diff file Expand all files Collapse all files

28
models/intermediate/kpis/int_kpis__metric_daily_host_resolutions.sql
View file

@ -4,8 +4,8 @@
{{ config(materialized="table", unique_key=["date", "id_deal", "business_scope"]) }} {{ config(materialized="table", unique_key=["date", "id_deal", "business_scope"]) }}
select select
-- Unique Key -- -- Unique Key --
ixbt.transaction_date_utc as date, hrp.transaction_date_utc as date,
coalesce(ixc.id_deal, 'UNSET') as id_deal, coalesce(hrp.id_deal, 'UNSET') as id_deal,
case case
when ikdd.client_type = 'API' when ikdd.client_type = 'API'
then 'API' then 'API'
@ -17,11 +17,11 @@ select
case case
when when
icnddsd.id_deal is not null icnddsd.id_deal is not null
and date_trunc('month', ixbt.transaction_date_utc)::date and date_trunc('month', hrp.transaction_date_utc)::date
>= date_trunc( >= date_trunc(
'month', icnddsd.min_user_in_new_dash_since_date_utc 'month', icnddsd.min_user_in_new_dash_since_date_utc
)::date )::date
and ixbt.transaction_date_utc and hrp.transaction_date_utc
>= date({{ var("new_dash_first_invoicing_date") }}) >= date({{ var("new_dash_first_invoicing_date") }})
then 'New Dash' then 'New Dash'
else 'Old Dash' else 'Old Dash'
@ -36,21 +36,15 @@ select
icmas.active_accommodations_per_deal_segmentation, 'UNSET' icmas.active_accommodations_per_deal_segmentation, 'UNSET'
) as active_accommodations_per_deal_segmentation, ) as active_accommodations_per_deal_segmentation,
-- Metrics -- -- Metrics --
sum(ixbtli.line_amount_wo_taxes_in_gbp) as xero_host_resolution_amount_paid_in_gbp, sum(hrp.line_amount_wo_taxes_in_gbp) as xero_host_resolution_amount_paid_in_gbp,
count(distinct ixbt.id_bank_transaction) as xero_host_resolution_payment_count count(distinct hrp.id_line_item) as xero_host_resolution_payment_count
from {{ ref("int_xero__bank_transactions") }} as ixbt from {{ ref("int_xero__host_resolutions_payments") }} as hrp
inner join left join {{ ref("int_kpis__dimension_deals") }} as ikdd on hrp.id_deal = ikdd.id_deal
{{ ref("int_xero__bank_transaction_line_items") }} as ixbtli
on ixbt.id_bank_transaction = ixbtli.id_bank_transaction
and upper(ixbtli.account_name) in {{ resolutions_host_payment_account_name }}
and upper(ixbt.transaction_status) in {{ relevant_transaction_status }}
left join {{ ref("int_xero__contacts") }} as ixc on ixc.id_contact = ixbt.id_contact
left join {{ ref("int_kpis__dimension_deals") }} as ikdd on ixc.id_deal = ikdd.id_deal
left join left join
{{ ref("int_kpis__dimension_daily_accommodation") }} as icmas {{ ref("int_kpis__dimension_daily_accommodation") }} as icmas
on ixc.id_deal = icmas.id_deal on hrp.id_deal = icmas.id_deal
and ixbt.transaction_date_utc = icmas.date and hrp.transaction_date_utc = icmas.date
left join left join
{{ ref("int_core__new_dash_deal_since_date") }} as icnddsd {{ ref("int_core__new_dash_deal_since_date") }} as icnddsd
on ixc.id_deal = icnddsd.id_deal on hrp.id_deal = icnddsd.id_deal
group by 1, 2, 3, 4, 5 group by 1, 2, 3, 4, 5