From e3529b35317055c7e34e914e9ee3080570e3ba88 Mon Sep 17 00:00:00 2001 From: root Date: Sun, 21 Dec 2025 19:47:34 +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 | 8 ++++---- 1 file changed, 4 insertions(+), 4 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 4589c5c..d96389c 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 @@ -33,7 +33,7 @@ or (p1.district ='' and p2.district like '%(客户未提供具体区域%') drop table if exists newsletter_contact_t1; create temporary table newsletter_contact_t1 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 on cci.contact_id =p2.contact_id 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 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 - ,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 on p2.currency_cd ='CNY' 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; create temporary table newsletter_funnel_crm_t1 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 left join p20_pdm.t01_crm_account p2 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 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 - ,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 on p2.currency_cd ='CNY' and p2.target_currency_cd ='USD'