dtgitea
/
dataops
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add workflow 泰克客户,dev

This commit is contained in:
root 2024-09-10 13:29:28 +08:00
parent 9460d14456
commit 84ada5fe80
1 changed files with 17 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
dev/workflow/TK_Cust/tk_cust/客户线索明细/cust_leads_detail_agi.sql
View File

@ -4,11 +4,11 @@
/*Brilliance stems from wisdoms. */ /*Brilliance stems from wisdoms. */
/*************Head Section**************************************************************************/ /*************Head Section**************************************************************************/
/*Script Use: Periodically load data to :cust_leads_detail(客户线索明细) */ /*Script Use: Periodically load data to :cust_leads_detail(客户线索明细) */
/*Create Date:2024-06-04 11:19:40 */ /*Create Date:2024-09-10 13:28:54 */
/*SDM Developed By: dev */ /*SDM Developed By: dev */
/*SDM Developed Date: 2024-05-31 */ /*SDM Developed Date: 2024-05-31 */
/*SDM Checked By: dev */ /*SDM Checked By: dev */
/*SDM Checked Date: 2024-06-04 */ /*SDM Checked Date: 2024-09-10 */
/*Script Developed By: dev */ /*Script Developed By: dev */
/*Script Checked By: dev */ /*Script Checked By: dev */
/*Source table 1: :PDMDB.t01_scrm_leads_his */ /*Source table 1: :PDMDB.t01_scrm_leads_his */
@ -47,7 +47,7 @@ ON COMMIT PRESERVE ROWS;
/*****************************************************************************************************/ /*****************************************************************************************************/
INSERT INTO cust_leads_detail_agi_CUR_I ( INSERT INTO cust_leads_detail_agi_CUR_I (
contact_channel /*线索渠道*/ contact_channel /*线索渠道*/
,contact_account /*线索编号*/ ,contact_account /*联系编号*/
,label /*标签*/ ,label /*标签*/
,event /*事件*/ ,event /*事件*/
,active_time /*活跃时间*/ ,active_time /*活跃时间*/
@ -83,7 +83,7 @@ FROM :PDMDB.t01_crm_raw_leads p0
/*****************************************************************************************************/ /*****************************************************************************************************/
INSERT INTO cust_leads_detail_agi_CUR_I ( INSERT INTO cust_leads_detail_agi_CUR_I (
contact_channel /*线索渠道*/ contact_channel /*线索渠道*/
,contact_account /*线索编号*/ ,contact_account /*联系编号*/
,label /*标签*/ ,label /*标签*/
,event /*事件*/ ,event /*事件*/
,active_time /*活跃时间*/ ,active_time /*活跃时间*/
@ -119,7 +119,7 @@ FROM :PDMDB.t01_scrm_leads_his p0
/*****************************************************************************************************/ /*****************************************************************************************************/
INSERT INTO cust_leads_detail_agi_CUR_I ( INSERT INTO cust_leads_detail_agi_CUR_I (
contact_channel /*线索渠道*/ contact_channel /*线索渠道*/
,contact_account /*线索编号*/ ,contact_account /*联系编号*/
,label /*标签*/ ,label /*标签*/
,event /*事件*/ ,event /*事件*/
,active_time /*活跃时间*/ ,active_time /*活跃时间*/
@ -153,9 +153,10 @@ FROM :PDMDB.t01_scrm_leads p0
/*****************************************************************************************************/ /*****************************************************************************************************/
/* GROUP 4:Source Table:t01_udesk_record**************************************************************/ /* GROUP 4:Source Table:t01_udesk_record**************************************************************/
/*****************************************************************************************************/ /*****************************************************************************************************/
INSERT INTO cust_leads_detail_agi_CUR_I ( INSERT INTO cust_leads_detail_agi_CUR_I (
contact_channel /*线索渠道*/ contact_channel /*线索渠道*/
,contact_account /*线索编号*/ ,contact_account /*联系编号*/
,label /*标签*/ ,label /*标签*/
,event /*事件*/ ,event /*事件*/
,active_time /*活跃时间*/ ,active_time /*活跃时间*/
@ -186,7 +187,11 @@ else '其他' end /*event*/
,current_timestamp(0) /*Etl_Proc_Dt*/ ,current_timestamp(0) /*Etl_Proc_Dt*/
,0 /*Etl_Batch_No*/ ,0 /*Etl_Batch_No*/
FROM :PDMDB.t01_udesk_record p0 FROM (select distinct on (call_id)
* from p20_pdm.t01_udesk_record tur
order by call_id,"type") p0
; ;
@ -196,7 +201,7 @@ FROM :PDMDB.t01_udesk_record p0
/*****************************************************************************************************/ /*****************************************************************************************************/
INSERT INTO cust_leads_detail_agi_CUR_I ( INSERT INTO cust_leads_detail_agi_CUR_I (
contact_channel /*线索渠道*/ contact_channel /*线索渠道*/
,contact_account /*线索编号*/ ,contact_account /*联系编号*/
,label /*标签*/ ,label /*标签*/
,event /*事件*/ ,event /*事件*/
,active_time /*活跃时间*/ ,active_time /*活跃时间*/
@ -235,7 +240,7 @@ FROM :PDMDB.t01_livechat_record p0
;INSERT INTO cust_leads_detail_agi_INS ( ;INSERT INTO cust_leads_detail_agi_INS (
event /*事件*/ event /*事件*/
,contact_channel /*线索渠道*/ ,contact_channel /*线索渠道*/
,contact_account /*线索编号*/ ,contact_account /*联系编号*/
,label /*标签*/ ,label /*标签*/
,active_time /*活跃时间*/ ,active_time /*活跃时间*/
,Src_Sysname /*来源系统*/ ,Src_Sysname /*来源系统*/
@ -250,7 +255,7 @@ FROM :PDMDB.t01_livechat_record p0
SELECT SELECT
P1.event /*事件*/ P1.event /*事件*/
,P1.contact_channel /*线索渠道*/ ,P1.contact_channel /*线索渠道*/
,P1.contact_account /*线索编号*/ ,P1.contact_account /*联系编号*/
,P1.label /*标签*/ ,P1.label /*标签*/
,P1.active_time /*活跃时间*/ ,P1.active_time /*活跃时间*/
,P1.Src_Sysname /*来源系统*/ ,P1.Src_Sysname /*来源系统*/
@ -280,7 +285,7 @@ WHERE P2.event IS NULL
;INSERT INTO :COMMDB.cust_leads_detail ( ;INSERT INTO :COMMDB.cust_leads_detail (
event /*事件*/ event /*事件*/
,contact_channel /*线索渠道*/ ,contact_channel /*线索渠道*/
,contact_account /*线索编号*/ ,contact_account /*联系编号*/
,label /*标签*/ ,label /*标签*/
,active_time /*活跃时间*/ ,active_time /*活跃时间*/
,Src_Sysname /*来源系统*/ ,Src_Sysname /*来源系统*/
@ -295,7 +300,7 @@ WHERE P2.event IS NULL
SELECT SELECT
P1.event /*事件*/ P1.event /*事件*/
,P1.contact_channel /*线索渠道*/ ,P1.contact_channel /*线索渠道*/
,P1.contact_account /*线索编号*/ ,P1.contact_account /*联系编号*/
,P1.label /*标签*/ ,P1.label /*标签*/
,P1.active_time /*活跃时间*/ ,P1.active_time /*活跃时间*/
,P1.Src_Sysname /*来源系统*/ ,P1.Src_Sysname /*来源系统*/