Anna_Saiapina/five9
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Replace mappings from stg to raw ones

Browse Source
This commit is contained in:
Anna Saiapina 2025-10-02 14:26:19 +00:00 committed by GCP Dataform
parent ee267f4939
commit 7ed6bc8010
11 changed files with 39 additions and 39 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
definitions/staging/stg_AGENT.sqlx
View File

@ -117,8 +117,8 @@ select all_agents_dedup.AGENT_ID,
all_agents_dedup.AGENT_GROUP, all_agents_dedup.AGENT_GROUP,
ag.AGENT_GROUP_ID ag.AGENT_GROUP_ID
from all_agents_dedup from all_agents_dedup
left join ${ref("stg_MAPPING_AGENT_GROUP")} ag left join ${ref("MAPPING_AGENT_GROUP")} ag
on all_agents_dedup.AGENT_GROUP = ag.AGENT_GROUP on all_agents_dedup.AGENT_GROUP = ag.AGENT_GROUP
left join ${ref("stg_MAPPING_LANGUAGES")} ml left join ${ref("MAPPING_LANGUAGES")} ml
on upper(all_agents_dedup.LANGUAGES) = upper(ml.LANGUAGE) on upper(all_agents_dedup.LANGUAGES) = upper(ml.LANGUAGE)
where row_n = 1 where row_n = 1

10
definitions/staging/stg_CAMPAIGN.sqlx
View File

@ -11,12 +11,12 @@ select c.CAMPAIGN,
cgi.CAMPAIGN_GROUP, cgi.CAMPAIGN_GROUP,
cit.CAMPAIGN_TYPE_ID, cit.CAMPAIGN_TYPE_ID,
ct.CAMPAIGN_TYPE ct.CAMPAIGN_TYPE
from ${ref("stg_MAPPING_CAMPAIGN")} c from ${ref("MAPPING_CAMPAIGN")} c
left join ${ref("stg_MAPPING_CAMPAIGN_GROUP")} cg left join ${ref("MAPPING_CAMPAIGN_GROUP")} cg
on c.CAMPAIGN_ID = cg.CAMPAIGN_ID on c.CAMPAIGN_ID = cg.CAMPAIGN_ID
left join ${ref("stg_MAPPING_CAMPAIGN_GROUP_ID")} cgi left join ${ref("MAPPING_CAMPAIGN_GROUP_ID")} cgi
on cg.campaign_group_id = cgi.campaign_group_id on cg.campaign_group_id = cgi.campaign_group_id
left join ${ref("stg_MAPPING_CAMPAIGN_ID_TYPE")} cit left join ${ref("MAPPING_CAMPAIGN_ID_TYPE")} cit
on c.CAMPAIGN_ID = cit.CAMPAIGN_ID on c.CAMPAIGN_ID = cit.CAMPAIGN_ID
left join ${ref("stg_MAPPING_CAMPAIGN_TYPE")} ct left join ${ref("MAPPING_CAMPAIGN_TYPE")} ct
on ct.CAMPAIGN_TYPE_ID = cit.CAMPAIGN_TYPE_ID on ct.CAMPAIGN_TYPE_ID = cit.CAMPAIGN_TYPE_ID

6
definitions/staging/stg_DISPOSITION.sqlx
View File

@ -9,8 +9,8 @@ select d.DISPOSITION,
d.DISPOSITION_ID, d.DISPOSITION_ID,
di.DISPOSITION_GROUP_ID, di.DISPOSITION_GROUP_ID,
dg.DISPOSITION_GROUP dg.DISPOSITION_GROUP
from ${ref("stg_MAPPING_DISPOSITION_ID")} d from ${ref("MAPPING_DISPOSITION_ID")} d
left join ${ref("stg_MAPPING_DISPOSITION_ID_GROUP")} di left join ${ref("MAPPING_DISPOSITION_ID_GROUP")} di
on d.DISPOSITION_ID = di.DISPOSITION_ID on d.DISPOSITION_ID = di.DISPOSITION_ID
left join ${ref("stg_MAPPING_DISPOSITION_GROUP_ID")} dg left join ${ref("MAPPING_DISPOSITION_GROUP_ID")} dg
on di.DISPOSITION_GROUP_ID = dg.DISPOSITION_GROUP_ID on di.DISPOSITION_GROUP_ID = dg.DISPOSITION_GROUP_ID

10
definitions/staging/stg_agent_status_history_report.sqlx
View File

@ -68,15 +68,15 @@ select ags.AGENT_ID,
from ${ref("stg_agent_status")} ags from ${ref("stg_agent_status")} ags
left join ${ref("stg_AGENT")} a left join ${ref("stg_AGENT")} a
on ags.AGENT_ID = a.AGENT_ID on ags.AGENT_ID = a.AGENT_ID
left join ${ref("stg_MAPPING_AGENT_STATE_ID")} mas left join ${ref("MAPPING_AGENT_STATE_ID")} mas
on ags.STATE = mas.STATE on ags.STATE = mas.STATE
left join ${ref("stg_MAPPING_AGENT_STATE_GROUP")} masgi left join ${ref("MAPPING_AGENT_STATE_GROUP")} masgi
on mas.STATE_ID = masgi.STATE_ID on mas.STATE_ID = masgi.STATE_ID
left join ${ref("stg_MAPPING_AGENT_STATE_GROUP_ID")} masg left join ${ref("MAPPING_AGENT_STATE_GROUP_ID")} masg
on masgi.STATE_GROUP_ID = masg.STATE_GROUP_ID on masgi.STATE_GROUP_ID = masg.STATE_GROUP_ID
left join ${ref("stg_MAPPING_AGENT_REASON_CODE_ID")} mrc left join ${ref("MAPPING_AGENT_REASON_CODE_ID")} mrc
on ags.REASON_CODE = mrc.REASON_CODE on ags.REASON_CODE = mrc.REASON_CODE
left join ${ref("stg_MAPPING_PRODUCTIVE_REVENUE")} mpr left join ${ref("MAPPING_PRODUCTIVE_REVENUE")} mpr
on COALESCE(mas.STATE_ID, 0) = COALESCE(mpr.STATE_ID, 0) on COALESCE(mas.STATE_ID, 0) = COALESCE(mpr.STATE_ID, 0)
and COALESCE(mrc.REASON_CODE_ID, 0) = COALESCE(mpr.REASON_CODE_ID, 0) and COALESCE(mrc.REASON_CODE_ID, 0) = COALESCE(mpr.REASON_CODE_ID, 0)
where ags.STATE not in ('Login', 'Logout', 'On Park', 'On Preview', 'On Video', 'On Voicemail') where ags.STATE not in ('Login', 'Logout', 'On Park', 'On Preview', 'On Video', 'On Voicemail')

10
definitions/staging/stg_agent_status_report.sqlx
View File

@ -68,15 +68,15 @@ select ags.AGENT_ID,
from ${ref("stg_agent_status")} ags from ${ref("stg_agent_status")} ags
left join ${ref("stg_AGENT")} a left join ${ref("stg_AGENT")} a
on ags.AGENT_ID = a.AGENT_ID on ags.AGENT_ID = a.AGENT_ID
left join ${ref("stg_MAPPING_AGENT_STATE_ID")} mas left join ${ref("MAPPING_AGENT_STATE_ID")} mas
on ags.STATE = mas.STATE on ags.STATE = mas.STATE
left join ${ref("stg_MAPPING_AGENT_STATE_GROUP")} masgi left join ${ref("MAPPING_AGENT_STATE_GROUP")} masgi
on mas.STATE_ID = masgi.STATE_ID on mas.STATE_ID = masgi.STATE_ID
left join ${ref("stg_MAPPING_AGENT_STATE_GROUP_ID")} masg left join ${ref("MAPPING_AGENT_STATE_GROUP_ID")} masg
on masgi.STATE_GROUP_ID = masg.STATE_GROUP_ID on masgi.STATE_GROUP_ID = masg.STATE_GROUP_ID
left join ${ref("stg_MAPPING_AGENT_REASON_CODE_ID")} mrc left join ${ref("MAPPING_AGENT_REASON_CODE_ID")} mrc
on ags.REASON_CODE = mrc.REASON_CODE on ags.REASON_CODE = mrc.REASON_CODE
left join ${ref("stg_MAPPING_PRODUCTIVE_REVENUE")} mpr left join ${ref("MAPPING_PRODUCTIVE_REVENUE")} mpr
on COALESCE(mas.STATE_ID, 0) = COALESCE(mpr.STATE_ID, 0) on COALESCE(mas.STATE_ID, 0) = COALESCE(mpr.STATE_ID, 0)
and COALESCE(mrc.REASON_CODE_ID, 0) = COALESCE(mpr.REASON_CODE_ID, 0) and COALESCE(mrc.REASON_CODE_ID, 0) = COALESCE(mpr.REASON_CODE_ID, 0)
where date(ags.TIMESTAMP) >= DATE_SUB(CURRENT_DATE(), INTERVAL 7 DAY) where date(ags.TIMESTAMP) >= DATE_SUB(CURRENT_DATE(), INTERVAL 7 DAY)

4
definitions/staging/stg_calls_history_report.sqlx
View File

@ -84,9 +84,9 @@ left join ${ref("stg_DISPOSITION")} d
on sc.DISPOSITION = d.DISPOSITION on sc.DISPOSITION = d.DISPOSITION
left join ${ref("stg_CAMPAIGN")} c left join ${ref("stg_CAMPAIGN")} c
on sc.CAMPAIGN = c.CAMPAIGN on sc.CAMPAIGN = c.CAMPAIGN
left join ${ref("stg_MAPPING_PROPERTY_CALLS")} p left join ${ref("MAPPING_PROPERTY_CALLS")} p
on sc.Routing_Hotel_Name = p.ROUTING_HOTEL_NAME on sc.Routing_Hotel_Name = p.ROUTING_HOTEL_NAME
left join ${ref("stg_MAPPING_SKILL")} s left join ${ref("MAPPING_SKILL")} s
on sc.SKILL = s.SKILL on sc.SKILL = s.SKILL
${ when(incremental(), `where date(sc.TIMESTAMP) >= DATE_SUB(CURRENT_DATE(), INTERVAL 7 DAY) ${ when(incremental(), `where date(sc.TIMESTAMP) >= DATE_SUB(CURRENT_DATE(), INTERVAL 7 DAY)
and date(sc.TIMESTAMP) < CURRENT_DATE()`) } and date(sc.TIMESTAMP) < CURRENT_DATE()`) }

4
definitions/staging/stg_calls_report.sqlx
View File

@ -83,9 +83,9 @@ left join ${ref("stg_DISPOSITION")} d
on sc.DISPOSITION = d.DISPOSITION on sc.DISPOSITION = d.DISPOSITION
left join ${ref("stg_CAMPAIGN")} c left join ${ref("stg_CAMPAIGN")} c
on sc.CAMPAIGN = c.CAMPAIGN on sc.CAMPAIGN = c.CAMPAIGN
left join ${ref("stg_MAPPING_PROPERTY_CALLS")} p left join ${ref("MAPPING_PROPERTY_CALLS")} p
on sc.Routing_Hotel_Name = p.ROUTING_HOTEL_NAME on sc.Routing_Hotel_Name = p.ROUTING_HOTEL_NAME
left join ${ref("stg_MAPPING_SKILL")} s left join ${ref("MAPPING_SKILL")} s
on sc.SKILL = s.SKILL on sc.SKILL = s.SKILL
where date(sc.TIMESTAMP) >= DATE_SUB(CURRENT_DATE(), INTERVAL 7 DAY) where date(sc.TIMESTAMP) >= DATE_SUB(CURRENT_DATE(), INTERVAL 7 DAY)
and date(sc.TIMESTAMP) < CURRENT_DATE() and date(sc.TIMESTAMP) < CURRENT_DATE()

6
definitions/staging/stg_closed_digital_report.sqlx
View File

@ -54,11 +54,11 @@ left join ${ref("stg_DISPOSITION")} dis
on d.DISPOSITION = dis.DISPOSITION on d.DISPOSITION = dis.DISPOSITION
left join ${ref("stg_CAMPAIGN")} c left join ${ref("stg_CAMPAIGN")} c
on d.CAMPAIGN = c.CAMPAIGN on d.CAMPAIGN = c.CAMPAIGN
left join ${ref("stg_MAPPING_PROPERTY_DIGITAL")} p left join ${ref("MAPPING_PROPERTY_DIGITAL")} p
on c.CAMPAIGN_ID = p.CAMPAIGN_ID on c.CAMPAIGN_ID = p.CAMPAIGN_ID
left join ${ref("stg_MAPPING_SKILL")} s left join ${ref("MAPPING_SKILL")} s
on d.SKILL = s.SKILL on d.SKILL = s.SKILL
left join ${ref("stg_MAPPING_MEDIA_TYPE")} m left join ${ref("MAPPING_MEDIA_TYPE")} m
on d.MEDIA_TYPE = m.MEDIA_TYPE on d.MEDIA_TYPE = m.MEDIA_TYPE
where date(d.END_TIME) >= DATE_SUB(CURRENT_DATE(), INTERVAL 7 DAY) where date(d.END_TIME) >= DATE_SUB(CURRENT_DATE(), INTERVAL 7 DAY)
and date(d.END_TIME) < CURRENT_DATE() and date(d.END_TIME) < CURRENT_DATE()

12
definitions/staging/stg_csc_agent.sqlx
View File

@ -52,17 +52,17 @@ csc_agent as (
1 as COUNTER, 1 as COUNTER,
cr.UPDATE_DESCRIPTION cr.UPDATE_DESCRIPTION
from csc_rev_deduplicated cr from csc_rev_deduplicated cr
left join ${ref("pphe_five9_stg","stg_MAPPING_CSC_AGENT")} ca left join ${ref("MAPPING_CSC_AGENT")} ca
on cr.UPDATE_USER=ca.OPERA_UPDATE_USER on cr.UPDATE_USER=ca.OPERA_UPDATE_USER
left join ${ref("pphe_five9_stg","stg_MAPPING_RESV_STATUS")} ms left join ${ref("MAPPING_RESV_STATUS")} ms
on cr.RESV_STATUS=ms.RESV_STATUS on cr.RESV_STATUS=ms.RESV_STATUS
left join ${ref("pphe_five9_stg","stg_MAPPING_UPDATE_TYPE")} mu left join ${ref("MAPPING_UPDATE_TYPE")} mu
on cr.UPDATE_TYPE=mu.UPDATE_TYPE on cr.UPDATE_TYPE=mu.UPDATE_TYPE
left join ${ref("pphe_five9_stg","stg_MAPPING_UPDATE_TYPE_GROUP")} mug left join ${ref("MAPPING_UPDATE_TYPE_GROUP")} mug
on mu.UPDATE_TYPE_ID=mug.UPDATE_TYPE_ID on mu.UPDATE_TYPE_ID=mug.UPDATE_TYPE_ID
left join ${ref("pphe_five9_stg","stg_MAPPING_UPDATE_TYPE_GROUP_ID")} mugi left join ${ref("MAPPING_UPDATE_TYPE_GROUP_ID")} mugi
on mug.UPDATE_TYPE_GROUP_ID=mugi.UPDATE_TYPE_GROUP_ID on mug.UPDATE_TYPE_GROUP_ID=mugi.UPDATE_TYPE_GROUP_ID
left join ${ref("pphe_five9_stg","stg_MAPPING_UPDATE_TYPE_REVENUE")} mur left join ${ref("MAPPING_UPDATE_TYPE_REVENUE")} mur
on mu.UPDATE_TYPE_ID=mur.UPDATE_TYPE_ID on mu.UPDATE_TYPE_ID=mur.UPDATE_TYPE_ID
where row_number = 1 where row_number = 1
and cr.UPDATE_USER is not null and cr.UPDATE_USER is not null

6
definitions/staging/stg_digital_history_report.sqlx
View File

@ -67,11 +67,11 @@ left join ${ref("stg_DISPOSITION")} dis
on d.DISPOSITION = dis.DISPOSITION on d.DISPOSITION = dis.DISPOSITION
left join ${ref("stg_CAMPAIGN")} c left join ${ref("stg_CAMPAIGN")} c
on d.CAMPAIGN = c.CAMPAIGN on d.CAMPAIGN = c.CAMPAIGN
left join ${ref("stg_MAPPING_PROPERTY_DIGITAL")} p left join ${ref("MAPPING_PROPERTY_DIGITAL")} p
on c.CAMPAIGN_ID = p.CAMPAIGN_ID on c.CAMPAIGN_ID = p.CAMPAIGN_ID
left join ${ref("stg_MAPPING_SKILL")} s left join ${ref("MAPPING_SKILL")} s
on d.SKILL = s.SKILL on d.SKILL = s.SKILL
left join ${ref("stg_MAPPING_MEDIA_TYPE")} m left join ${ref("MAPPING_MEDIA_TYPE")} m
on d.MEDIA_TYPE = m.MEDIA_TYPE on d.MEDIA_TYPE = m.MEDIA_TYPE
${ when(incremental(), `where date(d.TIMESTAMP) >= DATE_SUB(CURRENT_DATE(), INTERVAL 7 DAY) ${ when(incremental(), `where date(d.TIMESTAMP) >= DATE_SUB(CURRENT_DATE(), INTERVAL 7 DAY)
and date(d.TIMESTAMP) < CURRENT_DATE()`) } and date(d.TIMESTAMP) < CURRENT_DATE()`) }

6
definitions/staging/stg_digital_report.sqlx
View File

@ -66,11 +66,11 @@ left join ${ref("stg_DISPOSITION")} dis
on d.DISPOSITION = dis.DISPOSITION on d.DISPOSITION = dis.DISPOSITION
left join ${ref("stg_CAMPAIGN")} c left join ${ref("stg_CAMPAIGN")} c
on d.CAMPAIGN = c.CAMPAIGN on d.CAMPAIGN = c.CAMPAIGN
left join ${ref("stg_MAPPING_PROPERTY_DIGITAL")} p left join ${ref("MAPPING_PROPERTY_DIGITAL")} p
on c.CAMPAIGN_ID = p.CAMPAIGN_ID on c.CAMPAIGN_ID = p.CAMPAIGN_ID
left join ${ref("stg_MAPPING_SKILL")} s left join ${ref("MAPPING_SKILL")} s
on d.SKILL = s.SKILL on d.SKILL = s.SKILL
left join ${ref("stg_MAPPING_MEDIA_TYPE")} m left join ${ref("MAPPING_MEDIA_TYPE")} m
on d.MEDIA_TYPE = m.MEDIA_TYPE on d.MEDIA_TYPE = m.MEDIA_TYPE
where date(d.TIMESTAMP) >= DATE_SUB(CURRENT_DATE(), INTERVAL 7 DAY) where date(d.TIMESTAMP) >= DATE_SUB(CURRENT_DATE(), INTERVAL 7 DAY)
and date(d.TIMESTAMP) < CURRENT_DATE() and date(d.TIMESTAMP) < CURRENT_DATE()