cief/dbt_cloud
1
0
Fork 0
mirror of https://gitlab.com/cief-data/dbt_cloud.git synced 2026-08-19 04:14:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

Added logic to identify migrated_companies

Browse Source
This commit is contained in:
CIEF ACC1
2023-12-29 10:32:28 +00:00
parent 20db620d27
commit 021cd467dc
1 changed files with 34 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files
models/staging/shipping/stg_shipping__parent_and_sub_companies.sql
+34 -16
View File
@@ -26,23 +26,27 @@ status AS (
WHERE category = 'DEFAULT' WHERE category = 'DEFAULT'
), ),
migrated_sub_company_marking_id AS (
SELECT * FROM {{ ref('seed_shipping__migrated_company_marking_id') }}
),
-- LOGIC -- LOGIC
parent_companies_join_sub_companies AS ( parent_companies_join_sub_companies AS (
SELECT SELECT
parent_companies.parent_company_id AS parent_company_id, parent_companies.parent_company_id AS parent_company_id,
parent_companies.autocount_id, parent_companies.autocount_id,
parent_companies.name AS parent_company_name, parent_companies.name AS parent_company_name,
parent_companies.parent_company_type AS company_type, parent_companies.parent_company_type AS company_type,
parent_companies.status, parent_companies.status,
parent_companies.created_datetime AS parent_company_created_datetime, parent_companies.created_datetime AS parent_company_created_datetime,
parent_companies.updated_datetime AS parent_company_updated_datetime, parent_companies.updated_datetime AS parent_company_updated_datetime,
sub_companies.sub_company_id AS sub_company_id, sub_companies.sub_company_id AS sub_company_id,
sub_companies.name AS sub_company_name, sub_companies.name AS sub_company_name,
sub_companies.sub_company_type AS business_type, sub_companies.sub_company_type AS business_type,
sub_companies.created_datetime AS sub_company_created_datetime, sub_companies.created_datetime AS sub_company_created_datetime,
sub_companies.updated_datetime AS sub_company_updated_datetime sub_companies.updated_datetime AS sub_company_updated_datetime
FROM parent_companies FROM parent_companies
@@ -56,39 +60,50 @@ parent_companies_and_sub_companies_map_constants AS (
parent_companies_join_sub_companies.autocount_id, parent_companies_join_sub_companies.autocount_id,
parent_companies_join_sub_companies.parent_company_name, parent_companies_join_sub_companies.parent_company_name,
COALESCE(company_types.name, parent_companies_join_sub_companies.company_type::string) AS company_type, COALESCE(company_types.name, parent_companies_join_sub_companies.company_type::string) AS company_type,
COALESCE(status.name, parent_companies_join_sub_companies.status::string) AS status, COALESCE(status.name, parent_companies_join_sub_companies.status::string) AS status,
parent_companies_join_sub_companies.parent_company_created_datetime, parent_companies_join_sub_companies.parent_company_created_datetime,
parent_companies_join_sub_companies.parent_company_updated_datetime, parent_companies_join_sub_companies.parent_company_updated_datetime,
parent_companies_join_sub_companies.sub_company_id, parent_companies_join_sub_companies.sub_company_id,
parent_companies_join_sub_companies.sub_company_name, parent_companies_join_sub_companies.sub_company_name,
COALESCE(business_type.name, parent_companies_join_sub_companies.business_type::string) AS business_type, COALESCE(business_type.name, parent_companies_join_sub_companies.business_type::string) AS business_type,
parent_companies_join_sub_companies.sub_company_created_datetime, parent_companies_join_sub_companies.sub_company_created_datetime,
parent_companies_join_sub_companies.sub_company_updated_datetime, parent_companies_join_sub_companies.sub_company_updated_datetime,
sub_company_marking_connections.sub_company_marking_id, sub_company_marking_connections.sub_company_marking_id,
sub_company_marking_connections.is_credit_term_company,
'{{ modules.datetime.datetime.now(modules.pytz.timezone("Asia/Kuala_Lumpur")) }}' AS _dbt_ran_datetime CASE
WHEN sub_company_marking_id IN (SELECT * FROM migrated_sub_company_marking_id)
OR
DATE(sub_company_marking_connections.created_datetime) = '2021-08-18'
THEN 1
ELSE 0
END AS is_migrated_company,
'{{ modules.datetime.datetime.now(modules.pytz.timezone("Asia/Kuala_Lumpur")) }}' AS _dbt_ran_datetime
FROM parent_companies_join_sub_companies FROM parent_companies_join_sub_companies
LEFT JOIN sub_company_marking_connections LEFT JOIN sub_company_marking_connections
ON (parent_companies_join_sub_companies.sub_company_id = sub_company_marking_connections.sub_company_id) ON (parent_companies_join_sub_companies.sub_company_id = sub_company_marking_connections.sub_company_id)
LEFT JOIN parent_company_types AS company_types LEFT JOIN parent_company_types AS company_types
ON (parent_companies_join_sub_companies.company_type = company_types.id) ON (parent_companies_join_sub_companies.company_type = company_types.id)
LEFT JOIN sub_company_types AS business_type LEFT JOIN sub_company_types AS business_type
ON (parent_companies_join_sub_companies.business_type = business_type.id) ON (parent_companies_join_sub_companies.business_type = business_type.id)
LEFT JOIN status LEFT JOIN status
ON (parent_companies_join_sub_companies.status = status.id) ON (parent_companies_join_sub_companies.status = status.id)
), ),
-- FINAL -- FINAL
final__stg_shipping__parent_and_sub_companies AS ( final__stg_shipping__parent_and_sub_companies AS (
@@ -101,6 +116,8 @@ final__stg_shipping__parent_and_sub_companies AS (
-- dimensions -- dimensions
status, status,
is_credit_term_company,
is_migrated_company,
parent_company_name, parent_company_name,
sub_company_name, sub_company_name,
company_type, company_type,
@@ -118,6 +135,7 @@ final__stg_shipping__parent_and_sub_companies AS (
_dbt_ran_datetime _dbt_ran_datetime
FROM parent_companies_and_sub_companies_map_constants FROM parent_companies_and_sub_companies_map_constants
) )
SELECT * FROM final__stg_shipping__parent_and_sub_companies SELECT * FROM final__stg_shipping__parent_and_sub_companies