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 Ossa 2025-02-10 17:47:40 +01:00
parent 0a0ef84c4c
commit f846656989
2 changed files with 133 additions and 121 deletions
Download patch file Download diff file Expand all files Collapse all files

130
models/intermediate/core/int_core__verification_payments_v2.sql
View file

@ -21,10 +21,7 @@ with
int_core__payaway_per_month_user as (
select * from {{ ref("int_core__payaway_per_month_user") }}
),
int_core__payaway as (select * from {{ ref("int_core__payaway") }}),
int_daily_currency_exchange_rates as (
select * from {{ ref("int_daily_currency_exchange_rates") }}
),
int_core__waiver_fees as (select * from {{ ref("int_core__waiver_fees") }}),
not_taxed_vat_details as (
-- This CTE contains the logic that applies to payments that are not
-- subject to VAT.
@ -179,115 +176,6 @@ with
where
vpt.verification_payment_type = 'Waiver'
and pamu.id_payaway_plan is not null
),
-- CTE to obtain amount due to host and superhog fee.
-- This depends on their payaway plan at the moment of the payment.
-- If they don't have a payaway plan, then superhog is taking the risk.
-- For more details on the calculation, please refer to the documentation.
-- https://www.notion.so/truvi/Guest-Services-Taxes-How-to-calculate-a5ab4c049d61427fafab669dbbffb3a2?pvs=4
payaways as (
select
vtp.id_payment,
pa.payaway_percentage,
pa.payaway_minimum_commission_local_curr
* cer.rate as payaway_minimum_commission_local_curr,
case
when pa.id_payaway_plan is not null then true else false
end as is_host_taking_waiver_risk,
case
when pa.id_payaway_plan is not null
then
p.amount - greatest(
p.amount * pa.payaway_percentage,
pa.payaway_minimum_commission_local_curr * cer.rate
)
else 0
end as amount_due_to_host_in_txn_currency,
case
when pa.id_payaway_plan is not null
then
(
p.amount - greatest(
p.amount * pa.payaway_percentage,
pa.payaway_minimum_commission_local_curr * cer.rate
)
)
* der.rate
else 0
end as amount_due_to_host_in_gbp,
case
when pa.id_payaway_plan is not null and uu.billing_country_iso_3 = 'GBR'
then
(
greatest(
p.amount * pa.payaway_percentage,
pa.payaway_minimum_commission_local_curr * cer.rate
)
)
/ (vat.vat_rate + 1)
when
pa.id_payaway_plan is not null and uu.billing_country_iso_3 <> 'GBR'
then
greatest(
p.amount * pa.payaway_percentage,
pa.payaway_minimum_commission_local_curr * cer.rate
)
else p.amount
end as superhog_fee_in_txn_currency,
case
when pa.id_payaway_plan is not null and uu.billing_country_iso_3 = 'GBR'
then
(
greatest(
p.amount * pa.payaway_percentage,
pa.payaway_minimum_commission_local_curr * cer.rate
)
)
/ (vat.vat_rate + 1)
* der.rate
when
pa.id_payaway_plan is not null and uu.billing_country_iso_3 <> 'GBR'
then
(
greatest(
p.amount * pa.payaway_percentage,
pa.payaway_minimum_commission_local_curr * cer.rate
)
)
* der.rate
else p.amount
end as superhog_fee_in_gbp
from stg_core__verification_to_payment vtp
left join stg_core__payment p on vtp.id_payment = p.id_payment
left join stg_core__verification v on vtp.id_verification = v.id_verification
left join
stg_core__verification_payment_type vpt
on vtp.id_verification_payment_type = vpt.id_verification_payment_type
left join
stg_core__verification_request vr
on v.id_verification_request = vr.id_verification_request
left join
int_core__payaway pa
on vr.id_user_host = pa.id_user_host
and p.paid_at_utc
between pa.start_at_utc and coalesce(pa.end_at_utc, '2050-12-31')
left join
int_daily_currency_exchange_rates der
on p.paid_date_utc = der.rate_date_utc
and der.from_currency = p.currency
and der.to_currency = 'GBP'
left join int_core__unified_user uu on vr.id_user_host = uu.id_user
-- We need to exchange the minimum payaway commissions from host currency
-- to currency used by guest in the payment.
left join
int_daily_currency_exchange_rates cer
on p.paid_date_utc = cer.rate_date_utc
and cer.from_currency = uu.account_currency_iso4217
and cer.to_currency = p.currency
left join
stg_seed__guest_services_vat_rates_by_country vat
on uu.billing_country_iso_3 = vat.alpha_3
where upper(vpt.verification_payment_type) = 'WAIVER'
)
select
vtp.id_verification_to_payment,
@ -316,9 +204,9 @@ select
vtp.id_verification,
v.id_verification_request,
vpt.verification_payment_type,
pa.is_host_taking_waiver_risk,
pa.payaway_percentage,
pa.payaway_minimum_commission_local_curr,
wf.is_host_taking_waiver_risk,
wf.payaway_percentage,
wf.payaway_minimum_commission_local_curr,
p.currency,
p.amount as total_amount_in_txn_currency,
(p.amount * r.rate)::decimal(19, 4) as total_amount_in_gbp,
@ -354,10 +242,10 @@ select
vat.vat_rate,
vat.is_service_subject_to_vat,
vat.is_vat_taxed,
pa.amount_due_to_host_in_txn_currency,
pa.amount_due_to_host_in_gbp,
pa.superhog_fee_in_txn_currency,
pa.superhog_fee_in_gbp,
wf.amount_due_to_host_in_txn_currency,
wf.amount_due_to_host_in_gbp,
wf.superhog_fee_in_txn_currency,
wf.superhog_fee_in_gbp,
vat.is_missing_user_country,
vat.are_user_details_deleted,
vat.is_missing_vat_rate_for_country,
@ -391,4 +279,4 @@ left join
from not_taxed_vat_details
) as vat
on vat.id_verification_to_payment = vtp.id_verification_to_payment
left join payaways pa on vtp.id_payment = pa.id_payment
left join int_core__waiver_fees wf on vtp.id_payment = wf.id_payment

124
models/intermediate/core/int_core__waiver_fees.sql Normal file
View file

@ -0,0 +1,124 @@
-- {{ config(materialized="table") }}
with
stg_core__verification_to_payment as (
select * from {{ ref("stg_core__verification_to_payment") }}
),
stg_core__verification_payment_type as (
select * from {{ ref("stg_core__verification_payment_type") }}
),
stg_core__verification as (select * from {{ ref("stg_core__verification") }}),
stg_core__verification_request as (
select * from {{ ref("stg_core__verification_request") }}
),
stg_core__payment as (select * from {{ ref("stg_core__payment") }}),
int_simple_exchange_rates as (select * from {{ ref("int_simple_exchange_rates") }}),
int_core__unified_user as (select * from {{ ref("int_core__unified_user") }}),
stg_seed__guest_services_vat_rates_by_country as (
select * from {{ ref("stg_seed__guest_services_vat_rates_by_country") }}
),
int_core__payaway as (select * from {{ ref("int_core__payaway") }})
-- CTE to obtain amount due to host and superhog fee.
-- This depends on their payaway plan at the moment of the payment.
-- If they don't have a payaway plan, then superhog is taking the risk.
-- For more details on the calculation, please refer to the documentation.
-- https://www.notion.so/truvi/Guest-Services-Taxes-How-to-calculate-a5ab4c049d61427fafab669dbbffb3a2?pvs=4
select
vtp.id_payment,
pa.payaway_percentage,
pa.payaway_minimum_commission_local_curr
* cer.rate as payaway_minimum_commission_local_curr,
case
when pa.id_payaway_plan is not null then true else false
end as is_host_taking_waiver_risk,
case
when pa.id_payaway_plan is not null
then
p.amount - greatest(
p.amount * pa.payaway_percentage,
pa.payaway_minimum_commission_local_curr * cer.rate
)
else 0
end as amount_due_to_host_in_txn_currency,
case
when pa.id_payaway_plan is not null
then
(
p.amount - greatest(
p.amount * pa.payaway_percentage,
pa.payaway_minimum_commission_local_curr * cer.rate
)
)
* ser.rate
else 0
end as amount_due_to_host_in_gbp,
case
when pa.id_payaway_plan is not null and uu.billing_country_iso_3 = 'GBR'
then
(
greatest(
p.amount * pa.payaway_percentage,
pa.payaway_minimum_commission_local_curr * cer.rate
)
)
/ (vat.vat_rate + 1)
when pa.id_payaway_plan is not null and uu.billing_country_iso_3 <> 'GBR'
then
greatest(
p.amount * pa.payaway_percentage,
pa.payaway_minimum_commission_local_curr * cer.rate
)
else p.amount
end as superhog_fee_in_txn_currency,
case
when pa.id_payaway_plan is not null and uu.billing_country_iso_3 = 'GBR'
then
(
greatest(
p.amount * pa.payaway_percentage,
pa.payaway_minimum_commission_local_curr * cer.rate
)
)
/ (vat.vat_rate + 1)
* ser.rate
when pa.id_payaway_plan is not null and uu.billing_country_iso_3 <> 'GBR'
then
(
greatest(
p.amount * pa.payaway_percentage,
pa.payaway_minimum_commission_local_curr * cer.rate
)
)
* ser.rate
else p.amount
end as superhog_fee_in_gbp
from stg_core__verification_to_payment vtp
left join stg_core__payment p on vtp.id_payment = p.id_payment
left join stg_core__verification v on vtp.id_verification = v.id_verification
left join
stg_core__verification_payment_type vpt
on vtp.id_verification_payment_type = vpt.id_verification_payment_type
left join
stg_core__verification_request vr
on v.id_verification_request = vr.id_verification_request
left join
int_core__payaway pa
on vr.id_user_host = pa.id_user_host
and p.paid_at_utc
between pa.start_at_utc and coalesce(pa.end_at_utc, {{ var("end_of_time") }})
left join
int_simple_exchange_rates ser
on p.paid_date_utc = ser.rate_date_utc
and ser.from_currency = p.currency
and ser.to_currency = 'GBP'
left join int_core__unified_user uu on vr.id_user_host = uu.id_user
-- We need to exchange the minimum payaway commissions from host currency
-- to currency used by guest in the payment.
left join
int_simple_exchange_rates cer
on p.paid_date_utc = cer.rate_date_utc
and cer.from_currency = uu.account_currency_iso4217
and cer.to_currency = p.currency
left join
stg_seed__guest_services_vat_rates_by_country vat
on uu.billing_country_iso_3 = vat.alpha_3
where upper(vpt.verification_payment_type) = 'WAIVER'