From 44d7096b85dbd2ccb26d5809ec73bc776b44ebdc Mon Sep 17 00:00:00 2001 From: root Date: Tue, 9 Dec 2025 18:42:53 +0800 Subject: [PATCH] =?UTF-8?q?add=20workflow=20=E5=B8=82=E5=9C=BA-Agents?= =?UTF-8?q?=E8=B0=83=E5=BA=A6,dev?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../a_market_Intelligence_newsletter_agi.sql | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) diff --git a/dev/workflow/TK_Cust/agents_market_newsletter/市场信息简报/a_market_Intelligence_newsletter_agi.sql b/dev/workflow/TK_Cust/agents_market_newsletter/市场信息简报/a_market_Intelligence_newsletter_agi.sql index 23fa823..d57d67c 100644 --- a/dev/workflow/TK_Cust/agents_market_newsletter/市场信息简报/a_market_Intelligence_newsletter_agi.sql +++ b/dev/workflow/TK_Cust/agents_market_newsletter/市场信息简报/a_market_Intelligence_newsletter_agi.sql @@ -4,7 +4,7 @@ /*Brilliance stems from wisdoms. */ /*************Head Section**************************************************************************/ /*Script Use: Periodically load data to :a_market_Intelligence_newsletter(市场信息简报) */ -/*Create Date:2025-12-09 18:20:25 */ +/*Create Date:2025-12-09 18:42:38 */ /*SDM Developed By: dev */ /*SDM Developed Date: 2025-11-12 */ /*SDM Checked By: dev */ @@ -66,6 +66,7 @@ INSERT INTO a_market_Intelligence_newsletter_agi_CUR_I ( ,Etl_Tx_Dt /*作业运行时间*/ ,Src_Sysname /*来源系统*/ ,Src_Table /*来源表*/ + ,business_type /*商业活动类型（1-新项目，2-扩产，3-招聘，4-融资）*/ ) SELECT COALESCE(p0.id,0) /*id*/ @@ -92,6 +93,7 @@ SELECT ,TO_DATE(:TXDATE,'YYYYMMDD') /*Etl_Tx_Dt*/ ,Substr('agent_market_summary',1,3) /*Src_Sysname*/ ,'agent_market_summary' /*Src_Table*/ + ,COALESCE(TRIM(p0.business_type),'') /*business_type*/ FROM p70_ai_intelligence.agent_market_summary p0 where create_tm >=current_date - interval '7' day @@ -117,6 +119,7 @@ where create_tm >=current_date - interval '7' day ,source_url /*来源链接（URL）*/ ,news_date /*新闻日期*/ ,create_tm /*采集入库时间*/ + ,business_type /*商业活动类型（1-新项目，2-扩产，3-招聘，4-融资）*/ ,id /*主键*/ ,Etl_Batch_No /*作业批次号*/ ,Etl_First_Dt /*最初入库时间*/ @@ -143,6 +146,7 @@ where create_tm >=current_date - interval '7' day ,P1.source_url /*来源链接（URL）*/ ,P1.news_date /*新闻日期*/ ,P1.create_tm /*采集入库时间*/ + ,P1.business_type /*商业活动类型（1-新项目，2-扩产，3-招聘，4-融资）*/ ,P1.id /*主键*/ ,P1.Etl_Batch_No /*作业批次号*/ ,P1.Etl_First_Dt /*最初入库时间*/ @@ -169,6 +173,7 @@ ON P1.newsletter_title = P2.newsletter_title AND P1.source_url = P2.source_url AND P1.news_date = P2.news_date AND P1.create_tm = P2.create_tm + AND P1.business_type = P2.business_type AND P1.id = P2.id WHERE P2.newsletter_title IS NULL @@ -186,6 +191,7 @@ WHERE P2.newsletter_title IS NULL OR P2.source_url IS NULL OR P2.news_date IS NULL OR P2.create_tm IS NULL + OR P2.business_type IS NULL OR P2.id IS NULL ; @@ -206,6 +212,7 @@ WHERE P2.newsletter_title IS NULL ,source_url /*来源链接（URL）*/ ,news_date /*新闻日期*/ ,create_tm /*采集入库时间*/ + ,business_type /*商业活动类型（1-新项目，2-扩产，3-招聘，4-融资）*/ ,id /*主键*/ ,Etl_Batch_No /*作业批次号*/ ,Etl_First_Dt /*最初入库时间*/ @@ -232,6 +239,7 @@ SELECT ,P1.source_url /*来源链接（URL）*/ ,P1.news_date /*新闻日期*/ ,P1.create_tm /*采集入库时间*/ + ,P1.business_type /*商业活动类型（1-新项目，2-扩产，3-招聘，4-融资）*/ ,P1.id /*主键*/ ,P1.Etl_Batch_No /*作业批次号*/ ,P1.Etl_First_Dt /*最初入库时间*/ @@ -260,6 +268,7 @@ DO UPDATE SET ,source_url=excluded.source_url ,news_date=excluded.news_date ,create_tm=excluded.create_tm + ,business_type=excluded.business_type ,Etl_Batch_No=excluded.Etl_Batch_No ,Etl_First_Dt=excluded.Etl_First_Dt ,Etl_Job=excluded.Etl_Job