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

add workflow 天润dynamic邮件同步,dev

This commit is contained in:
root 2024-09-13 13:29:57 +08:00
parent b997c4c2a8
commit e417de4c73
2 changed files with 32 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
dev/workflow/TK_Cust/smart_ccc_dynamic_email/smartccc工单信息集成/f_ccc_work_ticket_integ.sql
View File

@ -51,7 +51,9 @@ CREATE TABLE IF NOT EXISTS p30_common.f_ccc_work_ticket_integ (
, Etl_Tx_Dt timestamp(0) , Etl_Tx_Dt timestamp(0)
, Etl_First_Dt timestamp(0) , Etl_First_Dt timestamp(0)
, Etl_Proc_Dt timestamp(0) , Etl_Proc_Dt timestamp(0)
, Etl_Batch_No varchar(50) , Etl_Batch_No varchar(50)
, second_mobile_number varchar(20)
, company_phone_number varchar(20)
,primary key( SUFFIX ) ,primary key( SUFFIX )
); );
@ -106,5 +108,7 @@ CREATE TABLE IF NOT EXISTS p30_common.f_ccc_work_ticket_integ (
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.Etl_First_Dt IS '最初入库时间'; COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.Etl_First_Dt IS '最初入库时间';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.Etl_Proc_Dt IS '本次入库时间'; COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.Etl_Proc_Dt IS '本次入库时间';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.Etl_Batch_No IS '作业批次号'; COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.Etl_Batch_No IS '作业批次号';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.second_mobile_number IS '第二手机号';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.company_phone_number IS '固话号';
COMMENT ON TABLE p30_common.f_ccc_work_ticket_integ IS 'smartccc工单信息集成'; COMMENT ON TABLE p30_common.f_ccc_work_ticket_integ IS 'smartccc工单信息集成';

30
dev/workflow/TK_Cust/smart_ccc_dynamic_email/smartccc工单信息集成/f_ccc_work_ticket_integ_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 :f_ccc_work_ticket_integ(smartccc工单信息集成) */ /*Script Use: Periodically load data to :f_ccc_work_ticket_integ(smartccc工单信息集成) */
/*Create Date:2024-09-10 18:23:10 */ /*Create Date:2024-09-13 13:29:12 */
/*SDM Developed By: dev */ /*SDM Developed By: dev */
/*SDM Developed Date: 2024-07-09 */ /*SDM Developed Date: 2024-07-09 */
/*SDM Checked By: dev */ /*SDM Checked By: dev */
/*SDM Checked Date: 2024-09-10 */ /*SDM Checked Date: 2024-09-13 */
/*Script Developed By: dev */ /*Script Developed By: dev */
/*Script Checked By: dev */ /*Script Checked By: dev */
/*Source table 1: :PDMDB.t01_ccc_cust_info */ /*Source table 1: :PDMDB.t01_ccc_cust_info */
@ -96,6 +96,8 @@ INSERT INTO f_ccc_work_ticket_integ_agi_CUR_I (
,Etl_First_Dt /*最初入库时间*/ ,Etl_First_Dt /*最初入库时间*/
,Etl_Proc_Dt /*本次入库时间*/ ,Etl_Proc_Dt /*本次入库时间*/
,Etl_Batch_No /*作业批次号*/ ,Etl_Batch_No /*作业批次号*/
,second_mobile_number /*第二手机号*/
,company_phone_number /*固话号*/
) )
SELECT SELECT
case when coalesce(p0.start_form::json->>'formName','') ='选型报价_Outbound' then '449662X449662' case when coalesce(p0.start_form::json->>'formName','') ='选型报价_Outbound' then '449662X449662'
@ -121,7 +123,7 @@ SELECT
,coalesce(p2.prov_name,'') /*STATE_COUNTY_LOCATION*/ ,coalesce(p2.prov_name,'') /*STATE_COUNTY_LOCATION*/
,'CN' /*COUNTRY_CODE*/ ,'CN' /*COUNTRY_CODE*/
,coalesce(p2.postalcode,'') /*POSTAL_CODE*/ ,coalesce(p2.postalcode,'') /*POSTAL_CODE*/
,coalesce(replace(replace(replace(split_part(p1.tel,',',1),'"',''),'[',''),']',''),'') /*CONTACT_MOBILE_NUMBER*/ ,coalesce(find_first_phone_number(replace(replace(replace(p1.tel,'"',''),'[','{'),']','}')::text[]),find_first_not_phone_number(replace(replace(replace(p1.tel,'"',''),'[','{'),']','}')::text[]),'null') /*CONTACT_MOBILE_NUMBER*/
,coalesce(p1.email,'') /*EMAIL_ADDRESS*/ ,coalesce(p1.email,'') /*EMAIL_ADDRESS*/
,'YES' /*REQUEST_A_DEMO*/ ,'YES' /*REQUEST_A_DEMO*/
,'YES' /*REQUEST_A_QUOTE*/ ,'YES' /*REQUEST_A_QUOTE*/
@ -198,6 +200,10 @@ WHERE jsonb_extract_path_text(field, 'id')::int = 299137),'') /*LEAD_PROD
,TO_DATE(:TXDATE,'YYYYMMDD') /*Etl_First_Dt*/ ,TO_DATE(:TXDATE,'YYYYMMDD') /*Etl_First_Dt*/
,current_timestamp(0) /*Etl_Proc_Dt*/ ,current_timestamp(0) /*Etl_Proc_Dt*/
,0 /*Etl_Batch_No*/ ,0 /*Etl_Batch_No*/
,case when cardinality(array_remove(replace(replace(replace(p1.tel,'"',''),'[','{'),']','}')::text[],find_first_phone_number(replace(replace(replace(p1.tel,'"',''),'[','{'),']','}')::text[])))=0 then ''
else find_first_phone_number(array_remove(replace(replace(replace(p1.tel,'"',''),'[','{'),']','}')::text[],find_first_phone_number(replace(replace(replace(p1.tel,'"',''),'[','{'),']','}')::text[])))
end /*second_mobile_number*/
,coalesce(find_first_not_phone_number(replace(replace(replace(p1.tel,'"',''),'[','{'),']','}')::text[]),'') /*company_phone_number*/
FROM :PDMDB.t01_ccc_work_ticket_info p0 FROM :PDMDB.t01_ccc_work_ticket_info p0
LEFT JOIN :PDMDB.t01_ccc_cust_info p1 LEFT JOIN :PDMDB.t01_ccc_cust_info p1
@ -274,6 +280,8 @@ INSERT INTO f_ccc_work_ticket_integ_agi_CUR_I (
,Etl_First_Dt /*最初入库时间*/ ,Etl_First_Dt /*最初入库时间*/
,Etl_Proc_Dt /*本次入库时间*/ ,Etl_Proc_Dt /*本次入库时间*/
,Etl_Batch_No /*作业批次号*/ ,Etl_Batch_No /*作业批次号*/
,second_mobile_number /*第二手机号*/
,company_phone_number /*固话号*/
) )
SELECT SELECT
'401890X401890' /*PEXTENSION_CODE*/ '401890X401890' /*PEXTENSION_CODE*/
@ -367,6 +375,8 @@ WHERE jsonb_extract_path_text(field, 'id')::int = 299137),'') /*LEAD_PROD
,TO_DATE(:TXDATE,'YYYYMMDD') /*Etl_First_Dt*/ ,TO_DATE(:TXDATE,'YYYYMMDD') /*Etl_First_Dt*/
,current_timestamp(0) /*Etl_Proc_Dt*/ ,current_timestamp(0) /*Etl_Proc_Dt*/
,0 /*Etl_Batch_No*/ ,0 /*Etl_Batch_No*/
,'' /*second_mobile_number*/
,'' /*company_phone_number*/
FROM :PDMDB.t01_ccc_work_ticket_info p0 FROM :PDMDB.t01_ccc_work_ticket_info p0
LEFT JOIN :PDMDB.t00_china_city_info p2 LEFT JOIN :PDMDB.t00_china_city_info p2
@ -424,6 +434,8 @@ where p0 .state_selected ='TW_leads'
,BRAND_SSO /*BRAND_SSO*/ ,BRAND_SSO /*BRAND_SSO*/
,BRAND_KEITHLEY /*BRAND_KEITHLEY*/ ,BRAND_KEITHLEY /*BRAND_KEITHLEY*/
,EMAIL_PREFERENCE /*EMAIL_PREFERENCE*/ ,EMAIL_PREFERENCE /*EMAIL_PREFERENCE*/
,second_mobile_number /*第二手机号*/
,company_phone_number /*固话号*/
,SUFFIX /*工单ID*/ ,SUFFIX /*工单ID*/
,Src_Sysname /*来源系统*/ ,Src_Sysname /*来源系统*/
,Etl_Job /*作业名称*/ ,Etl_Job /*作业名称*/
@ -478,6 +490,8 @@ where p0 .state_selected ='TW_leads'
,P1.BRAND_SSO /*BRAND_SSO*/ ,P1.BRAND_SSO /*BRAND_SSO*/
,P1.BRAND_KEITHLEY /*BRAND_KEITHLEY*/ ,P1.BRAND_KEITHLEY /*BRAND_KEITHLEY*/
,P1.EMAIL_PREFERENCE /*EMAIL_PREFERENCE*/ ,P1.EMAIL_PREFERENCE /*EMAIL_PREFERENCE*/
,P1.second_mobile_number /*第二手机号*/
,P1.company_phone_number /*固话号*/
,P1.SUFFIX /*工单ID*/ ,P1.SUFFIX /*工单ID*/
,P1.Src_Sysname /*来源系统*/ ,P1.Src_Sysname /*来源系统*/
,P1.Etl_Job /*作业名称*/ ,P1.Etl_Job /*作业名称*/
@ -532,6 +546,8 @@ ON P1.PEXTENSION_CODE = P2.PEXTENSION_CODE
AND P1.BRAND_SSO = P2.BRAND_SSO AND P1.BRAND_SSO = P2.BRAND_SSO
AND P1.BRAND_KEITHLEY = P2.BRAND_KEITHLEY AND P1.BRAND_KEITHLEY = P2.BRAND_KEITHLEY
AND P1.EMAIL_PREFERENCE = P2.EMAIL_PREFERENCE AND P1.EMAIL_PREFERENCE = P2.EMAIL_PREFERENCE
AND P1.second_mobile_number = P2.second_mobile_number
AND P1.company_phone_number = P2.company_phone_number
AND P1.SUFFIX = P2.SUFFIX AND P1.SUFFIX = P2.SUFFIX
WHERE P2.PEXTENSION_CODE IS NULL WHERE P2.PEXTENSION_CODE IS NULL
@ -577,6 +593,8 @@ WHERE P2.PEXTENSION_CODE IS NULL
OR P2.BRAND_SSO IS NULL OR P2.BRAND_SSO IS NULL
OR P2.BRAND_KEITHLEY IS NULL OR P2.BRAND_KEITHLEY IS NULL
OR P2.EMAIL_PREFERENCE IS NULL OR P2.EMAIL_PREFERENCE IS NULL
OR P2.second_mobile_number IS NULL
OR P2.company_phone_number IS NULL
OR P2.SUFFIX IS NULL OR P2.SUFFIX IS NULL
; ;
@ -625,6 +643,8 @@ WHERE P2.PEXTENSION_CODE IS NULL
,BRAND_SSO /*BRAND_SSO*/ ,BRAND_SSO /*BRAND_SSO*/
,BRAND_KEITHLEY /*BRAND_KEITHLEY*/ ,BRAND_KEITHLEY /*BRAND_KEITHLEY*/
,EMAIL_PREFERENCE /*EMAIL_PREFERENCE*/ ,EMAIL_PREFERENCE /*EMAIL_PREFERENCE*/
,second_mobile_number /*第二手机号*/
,company_phone_number /*固话号*/
,SUFFIX /*工单ID*/ ,SUFFIX /*工单ID*/
,Src_Sysname /*来源系统*/ ,Src_Sysname /*来源系统*/
,Etl_Job /*作业名称*/ ,Etl_Job /*作业名称*/
@ -679,6 +699,8 @@ SELECT
,P1.BRAND_SSO /*BRAND_SSO*/ ,P1.BRAND_SSO /*BRAND_SSO*/
,P1.BRAND_KEITHLEY /*BRAND_KEITHLEY*/ ,P1.BRAND_KEITHLEY /*BRAND_KEITHLEY*/
,P1.EMAIL_PREFERENCE /*EMAIL_PREFERENCE*/ ,P1.EMAIL_PREFERENCE /*EMAIL_PREFERENCE*/
,P1.second_mobile_number /*第二手机号*/
,P1.company_phone_number /*固话号*/
,P1.SUFFIX /*工单ID*/ ,P1.SUFFIX /*工单ID*/
,P1.Src_Sysname /*来源系统*/ ,P1.Src_Sysname /*来源系统*/
,P1.Etl_Job /*作业名称*/ ,P1.Etl_Job /*作业名称*/
@ -735,6 +757,8 @@ DO UPDATE SET
,BRAND_SSO=excluded.BRAND_SSO ,BRAND_SSO=excluded.BRAND_SSO
,BRAND_KEITHLEY=excluded.BRAND_KEITHLEY ,BRAND_KEITHLEY=excluded.BRAND_KEITHLEY
,EMAIL_PREFERENCE=excluded.EMAIL_PREFERENCE ,EMAIL_PREFERENCE=excluded.EMAIL_PREFERENCE
,second_mobile_number=excluded.second_mobile_number
,company_phone_number=excluded.company_phone_number
,Src_Sysname=excluded.Src_Sysname ,Src_Sysname=excluded.Src_Sysname
,Etl_Job=excluded.Etl_Job ,Etl_Job=excluded.Etl_Job
,Src_Table=excluded.Src_Table ,Src_Table=excluded.Src_Table