From 028f851deb0fe2a2242292a0751c00cc767c46ee Mon Sep 17 00:00:00 2001
From: Yam ZhengLim <data@cief-malaysia.com>
Date: Wed, 2 Aug 2023 04:17:57 +0000
Subject: [PATCH] Base model

---
 .../base/base_exchange__seasonal_segments.sql | 55 +++++++++++++++++++
 1 file changed, 55 insertions(+)
 create mode 100644 models/staging/exchange/base/base_exchange__seasonal_segments.sql

diff --git a/models/staging/exchange/base/base_exchange__seasonal_segments.sql b/models/staging/exchange/base/base_exchange__seasonal_segments.sql
new file mode 100644
index 0000000..918906c
--- /dev/null
+++ b/models/staging/exchange/base/base_exchange__seasonal_segments.sql
@@ -0,0 +1,55 @@
+-- IMPORTS
+WITH source as (
+    SELECT * FROM {{ source('src_exchange_mysql', 'seasonal_segment') }}
+
+),
+
+-- LOGIC
+seasonal_segment_rename AS (
+
+    SELECT
+        id                  AS seasonal_segment_id,
+        company_id,
+        status,
+        segment_id,
+        starting_on         AS seasonal_segment_started_datetime,
+        ending_on           AS seasonal_segment_ended_datetime,
+        deleted_at          AS seasonal_segment_deleted_datetime,
+        created_at          AS seasonal_segment_created_datetime,
+        updated_at          AS seasonal_segment_updated_datetime,
+        '{{ modules.datetime.datetime.now(modules.pytz.timezone("Asia/Kuala_Lumpur")) }}' AS _dbt_ran_datetime
+
+    FROM source
+
+    -- id 1 is wrong setup, it should not occur
+    WHERE id != 1
+),
+
+-- FINAL
+final__base_exchange__seasonal_segments AS (
+    
+    SELECT
+        -- ids
+        seasonal_segment_id,
+        company_id,
+        segment_id,
+
+        -- dimensions
+        status,
+
+        -- measures
+
+        -- date/times
+        seasonal_segment_started_datetime,
+        seasonal_segment_ended_datetime,
+        seasonal_segment_deleted_datetime,
+        seasonal_segment_created_datetime,
+        seasonal_segment_updated_datetime,
+
+        -- metadata
+        _dbt_ran_datetime
+
+    FROM seasonal_segment_rename
+)
+
+SELECT * from final__base_exchange__seasonal_segments