From ce8c9cfa094fda54d88e61be626a6a12cf2728d8 Mon Sep 17 00:00:00 2001 From: "zhuchenwu@chenwuzhu.cn" Date: Thu, 28 May 2026 06:47:38 +0000 Subject: [PATCH] =?UTF-8?q?20260528=E5=8F=91=E7=89=88=E6=9C=80=E7=BB=88?= =?UTF-8?q?=E7=89=88=E6=9C=AC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- 09 dm_td_external_geo_type.sql | 2 +- ORG/DM_TD_EXT_COUNTY_ORG.sql | 37 ++++++++++++++++++++++++++-------- XIEHE/03 dm_ext_xiehe_geo.sql | 2 +- 3 files changed, 31 insertions(+), 10 deletions(-) diff --git a/09 dm_td_external_geo_type.sql b/09 dm_td_external_geo_type.sql index d2bb4f2..ec900c1 100644 --- a/09 dm_td_external_geo_type.sql +++ b/09 dm_td_external_geo_type.sql @@ -876,7 +876,7 @@ with original_table( A.AUDIT_COD, CASE WHEN A.PROVINCE_C IN ( - 'BBU_OtherProv', 'OBU_OtherProv', 'Others', + 'Others', 'ROC', 'Other Low Tiers', 'OTHER LOW TIERS' ) OR A.PROVINCE_C IS NULL diff --git a/ORG/DM_TD_EXT_COUNTY_ORG.sql b/ORG/DM_TD_EXT_COUNTY_ORG.sql index 1da6693..98772a3 100644 --- a/ORG/DM_TD_EXT_COUNTY_ORG.sql +++ b/ORG/DM_TD_EXT_COUNTY_ORG.sql @@ -64,7 +64,7 @@ FROM DM.dm_td_org P2 -- COMMAND ---------- -- -insert into DM.DM_TD_EXT_RETAIL_ORG +insert overwrite DM.DM_TD_EXT_COUNTY_ORG (REGION_CODE,region_name_en,rc_code,rc_name_en,RegionCenter,AUDIT_COD,MARKET,bu_category,bu_name_en,sub_bu_name,sub_bu_code_auth,bu_code_auth,DATA_SOURCE,REGION_RATIO,RSM_Name,RC_Name, TEAM, MR_TRTY_CODE, @@ -171,7 +171,7 @@ province_market AS ( LEFT JOIN dwd.dwd_td_institution t2 ON t1.inst_code = t2.inst_code INNER JOIN family_2_markt t3 ON t1.family_code = t3.prd_family_cd ) - +,part1( -- ════════════════════════════════════════════ -- 主查询 Part 1：正常地理覆盖行 -- ════════════════════════════════════════════ @@ -208,6 +208,24 @@ INNER JOIN province_market t2 ON t1.mr_trty_code = t2.trty_code INNER JOIN external_geo t3 ON t2.province_name = t3.province_c WHERE t2.market IS NOT NULL AND t3.audit_cod IS NOT NULL +) + +,all_combinations AS ( + SELECT + /*+ BROADCAST(geo) */ + p.market, + P.subbu, + geo.audit_cod + FROM (SELECT DISTINCT market,subbu FROM pack_2_market) p + CROSS JOIN external_geo geo + GROUP BY + p.market, + P.subbu, + geo.audit_cod +) + + +SELECT * FROM part1 UNION ALL @@ -220,12 +238,12 @@ SELECT DISTINCT 'ROC' AS rc_code, 'ROC' AS rc_name_en, 'Other Low Tiers' AS RegionCenter, - 'ROC' AS AUDIT_COD, - t2.MARKET, + ac.audit_cod AS AUDIT_COD, + ac.market, 'All Channel' AS bu_category, - nvl(subbu,'BBU_County') AS bu_name_en, - nvl(subbu,'BBU_County') AS sub_bu_name, - nvl(subbu,'BBU_County') AS sub_bu_code_auth, + NVL(subbu,'ROC') AS bu_name_en, + NVL(subbu,'ROC') AS sub_bu_name, + NVL(subbu,'ROC') AS sub_bu_code_auth, 'IQVIA-COUNTY(Quarterly)' AS bu_code_auth, 'IQVIA-COUNTY(Quarterly)' AS DATA_SOURCE, 1 AS REGION_RATIO, @@ -242,4 +260,7 @@ SELECT DISTINCT '' AS DSM_NAME, '' AS MR_KCODE, '' AS MR_NAME -FROM pack_2_market t2 +FROM all_combinations ac +LEFT ANTI JOIN part1 p + ON ac.market = p.market + AND ac.audit_cod = p.audit_cod diff --git a/XIEHE/03 dm_ext_xiehe_geo.sql b/XIEHE/03 dm_ext_xiehe_geo.sql index cc127d9..fae265e 100644 --- a/XIEHE/03 dm_ext_xiehe_geo.sql +++ b/XIEHE/03 dm_ext_xiehe_geo.sql @@ -12,7 +12,7 @@ with geo_xiehe as (-- dwd层表 group by fact_province,fact_city,geo_city,nvl(geo_province,'') ) --- 特殊区域：'黑吉辽','云贵川青','湖北','甘肃','其他地区' +-- 特殊区域：'黑吉辽','云贵川','湖北','其他地区' select -- a.*, concat('xiehe_',nvl(b.AUDIT_COD,concat(a.geo_province,a.fact_province,a.fact_city))) as AUDIT_COD