From 32aaab10b1d9caaf0fb36e889c3f0940d5975bab Mon Sep 17 00:00:00 2001 From: root Date: Fri, 26 Dec 2025 10:58:10 +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 --- .../news_letter/dysql_news_letter_info.sql | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/dev/workflow/TK_Cust/agents_market_newsletter/news_letter/dysql_news_letter_info.sql b/dev/workflow/TK_Cust/agents_market_newsletter/news_letter/dysql_news_letter_info.sql index 5fa1c49..665c13b 100644 --- a/dev/workflow/TK_Cust/agents_market_newsletter/news_letter/dysql_news_letter_info.sql +++ b/dev/workflow/TK_Cust/agents_market_newsletter/news_letter/dysql_news_letter_info.sql @@ -4,14 +4,15 @@ \set AUTOCOMMIT on \timing on + drop table if exists newsletter_t1; create temporary table newsletter_t1 as select distinct on (p1.company_name,p1.newsletter_title) p1.company_name,p2.saler_name,p1.whitelist_flag,p1.newsletter_title -,p1.summary ,p1.tek_products ,p1.tk_relevance,p1.industry ,p1.prov_name ,p1.city_name ,p1.district,p1.source_url,p1.business_type,p1.create_tm +,p1.summary ,p1.tek_products ,p1.tk_relevance,p1.industry ,p1.prov_name ,p1.city_name ,p1.district,p1.source_url,p1.business_type,p1.create_tm,p1.data_source from (select case when p1.company_name_ai<>'' then p1.company_name_ai else p1.company_name end company_name ,case when p3.account_name is not null then '1' else '0' end whitelist_flag,p1.newsletter_title -,p1.summary ,p1.tek_products ,p1.tk_relevance,p2.industry ,p2.prov_name ,p2.city_name ,coalesce(p3.district,p1.district )district ,p1.source_url,p1.business_type,p1.create_tm +,p1.summary ,p1.tek_products ,p1.tk_relevance,p2.industry ,p2.prov_name ,p2.city_name ,coalesce(p3.district,p1.district )district ,p1.source_url,p1.business_type,p1.create_tm,p1.data_source from p30_common.a_market_intelligence_newsletter p1 left join p30_common.d_account_info p2 on p1.company_name =p2."name" @@ -19,7 +20,7 @@ or p1.company_name_ai =p2."name" left join p30_common.white_list p3 on (p1.company_name =p3.account_name or p1.company_name_ai =p3.account_name) -and p3.as_of_date='2025-11-14' +and p3.as_of_date='2025-12-19' where p2."name" is not null)p1 left join p20_pdm.t00_china_city_pnum p2 on p2.prov_name =p1.prov_name @@ -67,11 +68,11 @@ order by p1.tek_opportunity_id,status_last_update desc,p1.as_of_date asc; delete from p60_mart.news_letter_info where source_system='market_summary'; INSERT INTO p60_mart.news_letter_info -(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) +(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,data_source) select distinct on (p1.company_name,p1.source_url) p1.company_name account_name, coalesce(saler_name,''), whitelist_flag, newsletter_title, summary , case when p5.data_json::text like '{%' then replace(replace(replace(p5.data_json->>'主营产品'::text,'"',''),'[',''),']','') when p5.data_json::text like '[%' then replace(replace(replace(p5.data_json::text,'"',''),'[',''),']','') else '' end -,coalesce(p5.recomend_product_series::text,'') tek_relevance, industry, coalesce(prov_name,''), coalesce(city_name), district,coalesce(p2.contact_qty,0) contact_qty, coalesce(total_amt,0)+coalesce(total_amount,0) total_funnel,coalesce(total_amt,0) report_amt,p1.source_url,p1.business_type,p1.create_tm,'market_summary' from newsletter_t1 p1 +,coalesce(p5.recomend_product_series::text,'') tek_relevance, industry, coalesce(prov_name,''), coalesce(city_name), district,coalesce(p2.contact_qty,0) contact_qty, coalesce(total_amt,0)+coalesce(total_amount,0) total_funnel,coalesce(total_amt,0) report_amt,p1.source_url,p1.business_type,p1.create_tm,'market_summary',p1.data_source from newsletter_t1 p1 left join (select company,count(*) contact_qty from newsletter_contact_t1 group by 1 ) p2 on p1.company_name=p2.company left join (select customer_name,sum(total_amt) total_amt from newsletter_funnel_one_t1 group by 1) p3 @@ -115,4 +116,5 @@ select * from newsletter_funnel_one_t2 + \q \ No newline at end of file