diff --git a/definitions/staging/stg_calls_report.sqlx b/definitions/staging/stg_calls_report.sqlx new file mode 100644 index 0000000..f36adca --- /dev/null +++ b/definitions/staging/stg_calls_report.sqlx @@ -0,0 +1,62 @@ +config { + type: "table", + uniqueKey: ["SESSION_ID", "TIMESTAMP", "DNIS"], + schema: "pphe_five9_stg", + assertions: { + uniqueKey: ["SESSION_ID", "TIMESTAMP", "DNIS"], + nonNull: ["SESSION_ID", "TIMESTAMP", "DNIS", "AGENT_GROUP_ID", "DISPOSITION_ID", "DISPOSITION_GROUP_ID", + "DISPOSITION_GROUP", "CAMPAIGN_ID", "CAMPAIGN_GROUP_ID", + "CAMPAIGN_GROUP", "SKILL_ID"] + }, + tags: ["calls_report"], + description: "Main calls data for report" +} + +select sc.SESSION_ID, + sc.DNIS, + sc.TIMESTAMP, + date(sc.TIMESTAMP) DATE, + EXTRACT(HOUR FROM sc.TIMESTAMP) HOUR, + EXTRACT(MONTH FROM sc.TIMESTAMP) MONTH, + EXTRACT(YEAR FROM sc.TIMESTAMP) YEAR, + sc.DAY_OF_WEEK, + sc.CALL_ID, + sc.HOTEL_NAME, + sc.AGENT_ID, + sc.AGENT_NAME, + a.LANGUAGES, + a.CODE LANGUAUGE_ID, + a.AGENT_GROUP_ID, + sc.AGENT_GROUP, + d.DISPOSITION_ID, + sc.DISPOSITION, + d.DISPOSITION_GROUP_ID, + d.DISPOSITION_GROUP, + c.CAMPAIGN_ID, + sc.CAMPAIGN, + c.CAMPAIGN_GROUP_ID, + c.CAMPAIGN_GROUP, + sc.SKILL, + s.SKILL_ID, + sc.CALL_TIME, + sc.RING_TIME, + sc.TALK_TIME, + sc.SPEED_OF_ANSWER, + sc.AFTER_CALL_WORK_TIME, + sc.CALLS, + sc.ANI, + c.CAMPAIGN_TYPE_ID, + sc.CAMPAIGN_TYPE +from ${ref("stg_CALL_SOURCE")} cl +from ${ref("stg_calls")} sc +left join ${ref("stg_AGENT")} a +on sc.AGENT_ID = a.AGENT_ID +left join ${ref("stg_DISPOSITION")} dis +on sc.DISPOSITION = dis.DISPOSITION +left join ${ref("stg_CAMPAIGN")} c +on sc.CAMPAIGN = c.CAMPAIGN +left join ${ref("stg_MAPPING_SKILL")} s +on sc.SKILL = s.SKILL +left join ${ref("stg_MAPPING_MEDIA_TYPE")} m +on sc.MEDIA_TYPE = m.MEDIA_TYPE +where date(sc.TIMESTAMP) >= DATE_SUB(CURRENT_DATE(), INTERVAL 5 DAY) \ No newline at end of file diff --git a/definitions/staging/stg_digital_report.sqlx b/definitions/staging/stg_digital_report.sqlx index 37a9649..d2e377b 100644 --- a/definitions/staging/stg_digital_report.sqlx +++ b/definitions/staging/stg_digital_report.sqlx @@ -46,4 +46,4 @@ left join ${ref("stg_MAPPING_SKILL")} s on d.SKILL = s.SKILL left join ${ref("stg_MAPPING_MEDIA_TYPE")} m on d.MEDIA_TYPE = m.MEDIA_TYPE -where date(d.TIMESTAMP) >= DATE_SUB(CURRENT_DATE(), INTERVAL 10 DAY) \ No newline at end of file +where date(d.TIMESTAMP) >= DATE_SUB(CURRENT_DATE(), INTERVAL 5 DAY) \ No newline at end of file