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-21 19:47:34 +08:00
parent 7be8beb73b
commit e3529b3531
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -33,7 +33,7 @@ or (p1.district ='' and p2.district like '%(客户未提供具体区域%')
drop table if exists newsletter_contact_t1; drop table if exists newsletter_contact_t1;
create temporary table newsletter_contact_t1 create temporary table newsletter_contact_t1
as as
select distinct on (contact_id) cci.contact_id,contact,full_name,mobile,email,wechat,company,'' job_title,p2.active_time from p30_common.cust_contact_info cci select distinct on (contact_id) cci.contact_id,contact,full_name,mobile,email,wechat,company,'' job_title,p2.active_time,'market_summary' source_system from p30_common.cust_contact_info cci
left join p30_common.v_cust_active_all p2 left join p30_common.v_cust_active_all p2
on cci.contact_id =p2.contact_id on cci.contact_id =p2.contact_id
where company in (select distinct company_name from newsletter_t1); where company in (select distinct company_name from newsletter_t1);
@ -42,7 +42,7 @@ drop table if exists newsletter_funnel_one_t1;
create temporary table newsletter_funnel_one_t1 create temporary table newsletter_funnel_one_t1
as as
select p1.record_id ,p1.apply_date ,contact_name ,contact_phone ,check_date::date ,'Partner' source_channel,case when region_name in ('华南','华东') then 'SE' when region_name in ('华北') then 'NW' else region_name end region_name select p1.record_id ,p1.apply_date ,contact_name ,contact_phone ,check_date::date ,'Partner' source_channel,case when region_name in ('华南','华东') then 'SE' when region_name in ('华北') then 'NW' else region_name end region_name
,customer_name ,p1.product_name ,p1.product_type ,p1.progress ,rp_total_price*p2.target_currency_value /p2.currency_value as total_amt from p20_pdm.t01_partner_report p1 ,customer_name ,p1.product_name ,p1.product_type ,p1.progress ,rp_total_price*p2.target_currency_value /p2.currency_value as total_amt,'market_summary' source_system from p20_pdm.t01_partner_report p1
left join p31_dim.d_currency p2 left join p31_dim.d_currency p2
on p2.currency_cd ='CNY' on p2.currency_cd ='CNY'
and p2.target_currency_cd ='USD' and p2.target_currency_cd ='USD'
@ -52,7 +52,7 @@ where check_status_str ='已通过' and customer_name in (select distinct compan
drop table if exists newsletter_funnel_crm_t1; drop table if exists newsletter_funnel_crm_t1;
create temporary table newsletter_funnel_crm_t1 create temporary table newsletter_funnel_crm_t1
as as
select distinct on (p1.tek_opportunity_id) p1.tek_opportunity_id ,p1.create_time ::date create_date,p5.last_name||p5.first_name contact_name,p5.mobile_phone contact_phone,p1.as_of_date::date,'CRM' source_channel,case when upper(p1.area_id) like '%SOUTH%' then 'SE' when upper(p1.area_id) like '%NORTH%' then 'NW' else p1.area_id end area_id,coalesce(p2.name,p1.parent_account_name) account_name,p1.product_name ,split_part(product_class, ':', 1) product_type,p1.state,p1.total_amount/p4.currency_value*p4.target_currency_value total_amount select distinct on (p1.tek_opportunity_id) p1.tek_opportunity_id ,p1.create_time ::date create_date,p5.last_name||p5.first_name contact_name,p5.mobile_phone contact_phone,p1.as_of_date::date,'CRM' source_channel,case when upper(p1.area_id) like '%SOUTH%' then 'SE' when upper(p1.area_id) like '%NORTH%' then 'NW' else p1.area_id end area_id,coalesce(p2.name,p1.parent_account_name) account_name,p1.product_name ,split_part(product_class, ':', 1) product_type,p1.state,p1.total_amount/p4.currency_value*p4.target_currency_value total_amount,'market_summary' source_system
from p30_common.crm_opportunity_weekly p1 from p30_common.crm_opportunity_weekly p1
left join p20_pdm.t01_crm_account p2 left join p20_pdm.t01_crm_account p2
on p1.account_number =p2.accountnumber on p1.account_number =p2.accountnumber
@ -85,7 +85,7 @@ drop table if exists newsletter_funnel_one_t2;
create temporary table newsletter_funnel_one_t2 create temporary table newsletter_funnel_one_t2
as as
select p1.record_id ,p1.dealer_name ,p1.apply_admin_name ,p1.apply_date ,contact_name ,contact_phone ,check_date::date ,'Partner' source_channel,case when region_name in ('华南','华东') then 'SE' when region_name in ('华北') then 'NW' else region_name end region_name select p1.record_id ,p1.dealer_name ,p1.apply_admin_name ,p1.apply_date ,contact_name ,contact_phone ,check_date::date ,'Partner' source_channel,case when region_name in ('华南','华东') then 'SE' when region_name in ('华北') then 'NW' else region_name end region_name
,customer_name ,p1.product_name ,p1.product_type ,p1.progress ,rp_total_price*p2.target_currency_value /p2.currency_value as total_amt from p20_pdm.t01_partner_report p1 ,customer_name ,p1.product_name ,p1.product_type ,p1.progress ,rp_total_price*p2.target_currency_value /p2.currency_value as total_amt,'market_summary' source_system from p20_pdm.t01_partner_report p1
left join p31_dim.d_currency p2 left join p31_dim.d_currency p2
on p2.currency_cd ='CNY' on p2.currency_cd ='CNY'
and p2.target_currency_cd ='USD' and p2.target_currency_cd ='USD'