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 d5e7183..4589c5c 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 @@ -66,11 +66,11 @@ order by p1.tek_opportunity_id,status_last_update desc,p1.as_of_date asc; delete from 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) +(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) 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 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' 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