From c959a292d61fd2dea37bd3d1e7f4fc52d3c5cf12 Mon Sep 17 00:00:00 2001
From: CIEF ACC1 <cief.acc1@gmail.com>
Date: Fri, 12 Jan 2024 01:25:21 +0000
Subject: [PATCH] build

---
 ...fct_exchange__frozen_account_incidents.sql | 92 +++++++++++++++++++
 1 file changed, 92 insertions(+)
 create mode 100644 models/marts/warehouse/fct_exchange__frozen_account_incidents.sql

diff --git a/models/marts/warehouse/fct_exchange__frozen_account_incidents.sql b/models/marts/warehouse/fct_exchange__frozen_account_incidents.sql
new file mode 100644
index 0000000..10e7b5d
--- /dev/null
+++ b/models/marts/warehouse/fct_exchange__frozen_account_incidents.sql
@@ -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
\ No newline at end of file