From 3e19825c156bd9fe95eaaee16aad6701196045e7 Mon Sep 17 00:00:00 2001 From: root Date: Mon, 9 Feb 2026 10:46:39 +0800 Subject: [PATCH] =?UTF-8?q?add=20workflow=20=E5=B8=82=E5=9C=BA=E6=98=93API?= =?UTF-8?q?=E8=81=94=E7=B3=BB=E4=BA=BA,dev?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../SCRM线索/t01_scrm_leads_agi.sql | 24 +++++++++---------- 1 file changed, 12 insertions(+), 12 deletions(-) diff --git a/dev/workflow/TK_Cust/yi_api_contact/SCRM线索/t01_scrm_leads_agi.sql b/dev/workflow/TK_Cust/yi_api_contact/SCRM线索/t01_scrm_leads_agi.sql index 7937aae..1efd903 100644 --- a/dev/workflow/TK_Cust/yi_api_contact/SCRM线索/t01_scrm_leads_agi.sql +++ b/dev/workflow/TK_Cust/yi_api_contact/SCRM线索/t01_scrm_leads_agi.sql @@ -4,11 +4,11 @@ /*Brilliance stems from wisdoms. */ /*************Head Section**************************************************************************/ /*Script Use: Periodically load data to :t01_scrm_leads(SCRM线索) */ -/*Create Date:2025-10-30 11:07:00 */ +/*Create Date:2026-02-09 10:46:12 */ /*SDM Developed By: dev */ /*SDM Developed Date: 2024-01-12 */ /*SDM Checked By: dev */ -/*SDM Checked Date: 2025-10-30 */ +/*SDM Checked Date: 2026-02-09 */ /*Script Developed By: dev */ /*Script Checked By: dev */ /*Source table 1: :PDMDB.(SELECT @@ -84,7 +84,7 @@ SELECT ,COALESCE(TRIM(CAST(p0.source AS varchar(50))),'') /*source*/ ,COALESCE(TRIM(CAST(p0.tag AS varchar(30))),'') /*tag*/ ,COALESCE(TRIM(CAST(p0.c_keyword AS varchar(30))),'') /*c_keyword*/ - ,COALESCE(TRIM(CAST(p0.attr2 AS varchar(30))),'') /*attr2*/ + ,COALESCE(TRIM(p0.attr2),'') /*attr2*/ ,COALESCE(TRIM(CAST(p0.label AS varchar(30))),'') /*label*/ ,COALESCE(TRIM(CAST(p0.group_label AS varchar(30))),'') /*group_label*/ ,0 /*Etl_Batch_No*/ @@ -151,7 +151,7 @@ SELECT ,p0.channel_name /*source*/ ,'' /*tag*/ ,'' /*c_keyword*/ - ,COALESCE(TRIM(p0.properties),'') /*attr2*/ + ,COALESCE(TRIM(p0.properties),'') /*attr2*/ ,COALESCE(TRIM(CAST(p0.meta_remark AS varchar(30))),'') /*label*/ ,COALESCE(TRIM(CAST(p0.meta_remark AS varchar(30))),'') /*group_label*/ ,0 /*Etl_Batch_No*/ @@ -189,10 +189,10 @@ group by p0 .contact_id ,p0 .properties ,p0.at,p0 .connect_name,p0 .meta_remark ,source /*source*/ ,tag /*tag*/ ,c_keyword /*c_keyword*/ - ,attr2 /*attr2*/ ,group_label /*groupLabel*/ ,customer_id /*customerId*/ ,date /*date*/ + ,attr2 /*attr2*/ ,label /*label*/ ,Etl_Batch_No /*作业批次号*/ ,Etl_First_Dt /*最初入库时间*/ @@ -211,10 +211,10 @@ group by p0 .contact_id ,p0 .properties ,p0.at,p0 .connect_name,p0 .meta_remark ,P1.source /*source*/ ,P1.tag /*tag*/ ,P1.c_keyword /*c_keyword*/ - ,P1.attr2 /*attr2*/ ,P1.group_label /*groupLabel*/ ,P1.customer_id /*customerId*/ ,P1.date /*date*/ + ,P1.attr2 /*attr2*/ ,P1.label /*label*/ ,P1.Etl_Batch_No /*作业批次号*/ ,P1.Etl_First_Dt /*最初入库时间*/ @@ -233,10 +233,10 @@ ON P1.target_name = P2.target_name AND P1.source = P2.source AND P1.tag = P2.tag AND P1.c_keyword = P2.c_keyword - AND P1.attr2 = P2.attr2 AND P1.group_label = P2.group_label AND P1.customer_id = P2.customer_id AND P1.date = P2.date + AND P1.attr2 = P2.attr2 AND P1.label = P2.label WHERE P2.target_name IS NULL @@ -246,10 +246,10 @@ WHERE P2.target_name IS NULL OR P2.source IS NULL OR P2.tag IS NULL OR P2.c_keyword IS NULL - OR P2.attr2 IS NULL OR P2.group_label IS NULL OR P2.customer_id IS NULL OR P2.date IS NULL + OR P2.attr2 IS NULL OR P2.label IS NULL ; @@ -262,10 +262,10 @@ WHERE P2.target_name IS NULL ,source /*source*/ ,tag /*tag*/ ,c_keyword /*c_keyword*/ - ,attr2 /*attr2*/ ,group_label /*groupLabel*/ ,customer_id /*customerId*/ ,date /*date*/ + ,attr2 /*attr2*/ ,label /*label*/ ,Etl_Batch_No /*作业批次号*/ ,Etl_First_Dt /*最初入库时间*/ @@ -284,10 +284,10 @@ SELECT ,P1.source /*source*/ ,P1.tag /*tag*/ ,P1.c_keyword /*c_keyword*/ - ,P1.attr2 /*attr2*/ ,P1.group_label /*groupLabel*/ ,P1.customer_id /*customerId*/ ,P1.date /*date*/ + ,P1.attr2 /*attr2*/ ,P1.label /*label*/ ,P1.Etl_Batch_No /*作业批次号*/ ,P1.Etl_First_Dt /*最初入库时间*/ @@ -298,10 +298,11 @@ SELECT ,P1.Src_Table /*来源表*/ FROM t01_scrm_leads_agi_INS P1 -ON CONFLICT ( customer_id,date,label) +ON CONFLICT ( customer_id,date,attr2,label) DO UPDATE SET customer_id=excluded.customer_id ,date=excluded.date + ,attr2=excluded.attr2 ,label=excluded.label ,target_name=excluded.target_name ,c_name=excluded.c_name @@ -310,7 +311,6 @@ DO UPDATE SET ,source=excluded.source ,tag=excluded.tag ,c_keyword=excluded.c_keyword - ,attr2=excluded.attr2 ,group_label=excluded.group_label ,Etl_Batch_No=excluded.Etl_Batch_No ,Etl_First_Dt=excluded.Etl_First_Dt