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

add workflow 市场News-Agents调度,dev

This commit is contained in:
root 2025-12-26 10:58:10 +08:00
parent 7e4569c148
commit 32aaab10b1
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
dev/workflow/TK_Cust/agents_market_newsletter/news_letter/dysql_news_letter_info.sql
View File

@ -4,14 +4,15 @@
\set AUTOCOMMIT on \set AUTOCOMMIT on
\timing on \timing on
drop table if exists newsletter_t1; drop table if exists newsletter_t1;
create temporary table newsletter_t1 create temporary table newsletter_t1
as as
select distinct on (p1.company_name,p1.newsletter_title) p1.company_name,p2.saler_name,p1.whitelist_flag,p1.newsletter_title 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 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 ,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 from p30_common.a_market_intelligence_newsletter p1
left join p30_common.d_account_info p2 left join p30_common.d_account_info p2
on p1.company_name =p2."name" on p1.company_name =p2."name"
@ -19,7 +20,7 @@ or p1.company_name_ai =p2."name"
left join p30_common.white_list p3 left join p30_common.white_list p3
on (p1.company_name =p3.account_name on (p1.company_name =p3.account_name
or p1.company_name_ai =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 where p2."name" is not null)p1
left join p20_pdm.t00_china_city_pnum p2 left join p20_pdm.t00_china_city_pnum p2
on p2.prov_name =p1.prov_name 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 delete from p60_mart.news_letter_info
where source_system='market_summary'; where source_system='market_summary';
INSERT INTO p60_mart.news_letter_info 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 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,'"',''),'[',''),']','') , 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 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 left join (select company,count(*) contact_qty from newsletter_contact_t1 group by 1 ) p2
on p1.company_name=p2.company 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 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 \q