Create calls report

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)

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)
+where date(d.TIMESTAMP) >= DATE_SUB(CURRENT_DATE(), INTERVAL 5 DAY)