build

2026-08-19 04:14:00 +00:00 · 2024-01-12 01:25:21 +00:00
parent 5297dd0756
commit c959a292d6
1 changed files with 92 additions and 0 deletions
@@ -0,0 +1,92 @@
+-- IMPORT
+WITH frozen_account_incidents AS (
+    SELECT * FROM {{ ref('stg_googlesheet__account_frozen_cases') }}
+),
+
+bookings AS (
+    SELECT * FROM {{ ref('int_exchange__bookings_get_estimate_booking_values') }}
+),
+
+banks AS (
+    SELECT * FROM {{ ref('stg_exchange__banks') }}
+),
+
+
+-- LOGIC
+data_enrich AS (
+    
+    SELECT
+        frozen_account_incidents.frozen_account_case_id,
+        frozen_account_incidents.booking_marking_id,
+        frozen_account_incidents.crm_ticket_id,
+        frozen_account_incidents.account_freeze_reason,
+        frozen_account_incidents.ticket_status          AS incident_ticket_status,
+        frozen_account_incidents.agent_reply_status,
+        frozen_account_incidents.affected_order_amount,
+        frozen_account_incidents.affected_order_currency,
+        frozen_account_incidents.ticket_created_datetime,
+        frozen_account_incidents.ticket_updated_datetime,
+        frozen_account_incidents.ticket_closed_datetime,
+
+        bookings.booking_id,
+        bookings.company_id,
+        bookings.bank_id                                AS recipient_bank_id,
+        bookings.service_type,              
+
+        banks.country_id                                AS recipient_bank_country_id,
+        banks.bank_type                                 AS recipient_bank_type,
+        banks.bank_name                                 AS recipient_bank_name,
+        banks.bank_branch                               AS recipient_bank_branch,
+
+        '{{ modules.datetime.datetime.now(modules.pytz.timezone("Asia/Kuala_Lumpur")) }}' AS _dbt_ran_datetime
+
+    FROM frozen_account_incidents
+
+    LEFT JOIN bookings ON
+        ( frozen_account_incidents.booking_marking_id = bookings.booking_marking_id )
+
+    LEFT JOIN banks ON 
+        ( bookings.bank_id = banks.bank_id )
+
+),
+
+
+-- FINAL
+final__fct_exchange__frozen_account_incidents AS (
+
+    SELECT
+        -- ids
+        frozen_account_case_id,
+        crm_ticket_id,
+        booking_id,
+        booking_marking_id,
+        company_id,
+        recipient_bank_id,
+        recipient_bank_country_id,
+
+        -- dimensions
+        account_freeze_reason,
+        incident_ticket_status,
+        agent_reply_status,
+        service_type,
+        recipient_bank_type,
+        recipient_bank_name,
+        recipient_bank_branch,
+
+        -- measures
+        affected_order_amount,
+        affected_order_currency,
+
+        -- date/times
+        ticket_created_datetime,
+        ticket_updated_datetime,
+        ticket_closed_datetime,
+
+        -- metadata
+        _dbt_ran_datetime
+
+    FROM data_enrich
+
+)
+
+SELECT * FROM final__fct_exchange__frozen_account_incidents