From bd446b3f1fd19928abd491394881193a719bda44 Mon Sep 17 00:00:00 2001 From: CIEF ACC1 Date: Mon, 1 Apr 2024 09:48:53 +0000 Subject: [PATCH] Build voucher users --- ... => stg_exchange__voucher_redemptions.sql} | 8 +++++--- ...ouchers.sql => stg_exchange__vouchers.sql} | 19 +++++++++++++------ 2 files changed, 18 insertions(+), 9 deletions(-) rename models/staging/exchange/{base/base_exchange__voucher_redemptions.sql => stg_exchange__voucher_redemptions.sql} (85%) rename models/staging/exchange/{base/base_exchange__vouchers.sql => stg_exchange__vouchers.sql} (67%) diff --git a/models/staging/exchange/base/base_exchange__voucher_redemptions.sql b/models/staging/exchange/stg_exchange__voucher_redemptions.sql similarity index 85% rename from models/staging/exchange/base/base_exchange__voucher_redemptions.sql rename to models/staging/exchange/stg_exchange__voucher_redemptions.sql index 3f62da6..85dbcc9 100644 --- a/models/staging/exchange/base/base_exchange__voucher_redemptions.sql +++ b/models/staging/exchange/stg_exchange__voucher_redemptions.sql @@ -1,9 +1,9 @@ -- IMPORTS WITH source AS ( SELECT * FROM {{ source('src_exchange_mysql', 'voucher_redemptions') }} - ), + -- LOGIC voucher_redemptions_rename AS ( @@ -15,14 +15,16 @@ voucher_redemptions_rename AS ( value AS voucher_credit, created_at AS created_datetime, updated_at AS updated_datetime, + '{{ modules.datetime.datetime.now(modules.pytz.timezone("Asia/Kuala_Lumpur")) }}' AS _dbt_ran_datetime FROM source ), + -- FINAL -final__base_exchange__voucher_redemptions AS ( +final__stg_exchange__voucher_redemptions AS ( SELECT -- ids @@ -47,4 +49,4 @@ final__base_exchange__voucher_redemptions AS ( ) -SELECT * FROM final__base_exchange__voucher_redemptions +SELECT * FROM final__stg_exchange__voucher_redemptions \ No newline at end of file diff --git a/models/staging/exchange/base/base_exchange__vouchers.sql b/models/staging/exchange/stg_exchange__vouchers.sql similarity index 67% rename from models/staging/exchange/base/base_exchange__vouchers.sql rename to models/staging/exchange/stg_exchange__vouchers.sql index ab6229a..6b7ca99 100644 --- a/models/staging/exchange/base/base_exchange__vouchers.sql +++ b/models/staging/exchange/stg_exchange__vouchers.sql @@ -1,9 +1,9 @@ --- IMPORTS +-- IMPORT WITH source AS ( SELECT * FROM {{ source('src_exchange_mysql', 'vouchers') }} - ), + -- LOGIC vouchers_rename AS ( @@ -11,18 +11,22 @@ vouchers_rename AS ( id AS voucher_id, name, code, - type, + type AS credit_type, value AS voucher_credit, + start_date AS voucher_start_datetime, + end_date AS voucher_end_datetime created_at AS created_datetime, updated_at AS updated_datetime, + '{{ modules.datetime.datetime.now(modules.pytz.timezone("Asia/Kuala_Lumpur")) }}' AS _dbt_ran_datetime FROM source ), + -- FINAL -final__base_exchange__vouchers AS ( +final__stg_exchange__vouchers AS ( SELECT -- ids @@ -32,11 +36,14 @@ final__base_exchange__vouchers AS ( name, code, type, - voucher_credit, + credit_type, -- measures + voucher_credit, -- date/times + voucher_start_datetime, + voucher_end_datetime created_datetime, updated_datetime, @@ -47,4 +54,4 @@ final__base_exchange__vouchers AS ( ) -SELECT * FROM final__base_exchange__vouchers +SELECT * FROM final__stg_exchange__vouchers