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

Fixed mapping

Browse source
This commit is contained in:
Joaquin Ossa 2024-09-09 18:32:25 +02:00
parent 7ea70d3f4c
commit a54bc78c53
2 changed files with 16 additions and 16 deletions
Download patch file Download diff file Expand all files Collapse all files

17
models/intermediate/edeposit/int_edeposit__verification_fees.sql
View file

@ -3,6 +3,21 @@
{% set rejected_fee = 0.25 %}
{% set cancellation_fee = 0.25 %}
{% set cancellation_threshold = 0.05 %}
-- mapping of users that have a different id in Cosmos DB so we can join them
{% set mapped_users = {
"6580e7a6da7d1d09344c847d": "011339af-1206-4b4b-bd58-db2588381673",
"3f6e171e-b6a3-4e5d-b178-309cd91fa704": "e2a34440-c382-4352-bb57-60e898752826",
"hello-manhattanbnb-com": "b1e28c21-ddc2-4c2b-9207-62e248ff83aa",
"9471281a-6404-4614-8cf3-66b1c24e6f24": "e2fa2f20-4fcf-4736-b5e5-f8b118ca98fe",
} %}
{% set user_mapping_case %}
case
{% for old_user, new_user in mapped_users.items() %}
when v.id_user_partner = '{{ old_user }}' then '{{ new_user }}'
{% endfor %}
else v.id_user_partner
end
{% endset %}
with
int_edeposit__verifications as (
select * from {{ ref("int_edeposit__verifications") }}
@ -14,7 +29,7 @@ with
edeposit_records as (
select
v.id_verification,
v.id_user_partner,
{{ user_mapping_case }} as id_user_partner,
v.id_booking,
eu.currency,
cer.rate,

15
models/staging/core/stg_core__edeposit_user.sql
View file

@ -14,21 +14,6 @@
"d327a19d-6111-4364-b27c-02253d093045",
"61029f39-fb8a-4160-9353-d5d441147a42",
) %}
-- mapping of users that have a different id in Cosmos DB so we keep those
{% set mapped_users = {
"6580e7a6da7d1d09344c847d": "011339af-1206-4b4b-bd58-db2588381673",
"3f6e171e-b6a3-4e5d-b178-309cd91fa704": "e2a34440-c382-4352-bb57-60e898752826",
"hello-manhattanbnb-com": "b1e28c21-ddc2-4c2b-9207-62e248ff83aa",
"9471281a-6404-4614-8cf3-66b1c24e6f24": "e2fa2f20-4fcf-4736-b5e5-f8b118ca98fe",
} %}
{% set user_mapping_case %}
case
{% for old_user, new_user in mapped_users.items() %}
when lower({{ adapter.quote("UserId") }}) = '{{ old_user }}' then '{{ new_user }}'
{% endfor %}
else lower({{ adapter.quote("UserId") }})
end
{% endset %}
with
raw_electronic_deposit_user as (
select * from {{ source("core", "ElectronicDepositUser") }}