From e7721972cf2ae6daf4f705c50074de5b68d17a17 Mon Sep 17 00:00:00 2001
From: root <root@64792e78fd4d>
Date: Thu, 2 Apr 2026 13:47:39 +0800
Subject: [PATCH] =?UTF-8?q?add=20workflow=20=E5=B8=82=E5=9C=BANews-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

---
 .../wf_dag_agents_market_newsletter.py          | 17 ++++++++++++++++-
 .../dysql_news_letter_result.sql                | 12 ++++++++++++
 2 files changed, 28 insertions(+), 1 deletion(-)
 create mode 100644 dev/workflow/TK_Cust/agents_market_newsletter/新闻发送结果汇总/dysql_news_letter_result.sql

diff --git a/dev/workflow/TK_Cust/agents_market_newsletter/市场News-Agents调度/wf_dag_agents_market_newsletter.py b/dev/workflow/TK_Cust/agents_market_newsletter/市场News-Agents调度/wf_dag_agents_market_newsletter.py
index b104931..fcce6b7 100644
--- a/dev/workflow/TK_Cust/agents_market_newsletter/市场News-Agents调度/wf_dag_agents_market_newsletter.py
+++ b/dev/workflow/TK_Cust/agents_market_newsletter/市场News-Agents调度/wf_dag_agents_market_newsletter.py
@@ -104,6 +104,18 @@ dag=dag)
 
 
 
+
+dysql_news_letter_result = SSHOperator(
+ssh_hook=sshHook,
+task_id='dysql_news_letter_result',
+command='/data/airflow/etl/MART/run_psql.sh {{ ds_nodash }} {{params.my_param}}  ',
+params={'my_param':"dysql_news_letter_result"},
+depends_on_past=False, 
+retries=3, 
+dag=dag)
+
+
+
 agents_market_summar >> tk_product_prefer
 a_market_Intelligence_newsletter >> tk_product_prefer
 tk_product_prefer >> dysql_news_letter_info
@@ -111,4 +123,7 @@ agents_market_summar >> a_market_Intelligence_newsletter
 tk_product_prefer >> dysql_recruitment_news_letter
 dysql_enterprise_card_newsletter >> dysql_recruitment_news_letter
 tk_product_prefer >> dysql_enterprise_card_newsletter
-dysql_enterprise_card_newsletter >> task_failed 
+dysql_news_letter_info >> dysql_news_letter_result
+dysql_enterprise_card_newsletter >> dysql_news_letter_result
+dysql_recruitment_news_letter >> dysql_news_letter_result
+dysql_news_letter_result >> task_failed 
diff --git a/dev/workflow/TK_Cust/agents_market_newsletter/新闻发送结果汇总/dysql_news_letter_result.sql b/dev/workflow/TK_Cust/agents_market_newsletter/新闻发送结果汇总/dysql_news_letter_result.sql
new file mode 100644
index 0000000..01abf82
--- /dev/null
+++ b/dev/workflow/TK_Cust/agents_market_newsletter/新闻发送结果汇总/dysql_news_letter_result.sql
@@ -0,0 +1,12 @@
+/********************************************************************************************/
+/*******Main Section**************************************************************************/
+\set ON_ERROR_STOP on
+\set AUTOCOMMIT on
+\timing on
+
+delete from p60_mart.news_letter_info_result where create_tm>= current_date;
+insert into p60_mart.news_letter_info_result
+SELECT account_name, saler_name, whitelist_flag, newsletter_title, summary, key_products, tek_relevance, industry, prov_name, city_name, district, contact_qty, total_funnel, report_amt, source_url, business_type, create_tm,  source_system,channel_type, portal_url, zip_url
+FROM p60_mart.v_news_letter_info_weekly
+
+\q
\ No newline at end of file