20260429chenwu

zhouxin & chenwu 修改
2026-04-29 15:57:22 +00:00
parent d0753fc790
commit 550df7d257
8 changed files with 225 additions and 129 deletions
--- a/ORG/DM_TD_EXT_CHC_ORG.sql
+++ b/ORG/DM_TD_EXT_CHC_ORG.sql
@@ -122,9 +122,7 @@ where t1.yyyymm in(
 --事实表与维度表来自于不同手工表，目前存在一部分audit_cod在事实表有销量，但是在维度表没有这个audit_cod，导致销量缺失。
 --因此需要从事实表补全这部分audit_cod
 with sales as (
-select distinct PACK_COD,AUDIT_COD,DATA_SOURCE from dm.DM_TF_EXT_UNIONALL_SALES
-union
-select distinct PACK_COD,AUDIT_COD,DATA_SOURCE from dm.dm_tf_external_sales_thc
+select distinct PACK_CODE,AUDIT_CODE,DATA_SOURCE from dm.DM_TF_EXT_UNIONALL_SALES
 )
 ,market_pack as (
 select distinct PACK_COD,MARKET,DATA_SOURCE from dm.dm_td_external_market_pack_mapping
@@ -133,10 +131,10 @@ select distinct PACK_COD,MARKET,DATA_SOURCE from dm.dm_td_external_market_pack_m
 select distinct AUDIT_COD,MARKET,DATA_SOURCE from dm.DM_TD_EXT_CHC_ORG
 )
 ,tmp_org as (
-select distinct a.AUDIT_COD,b.MARKET,a.DATA_SOURCE
+select distinct a.AUDIT_CODE,b.MARKET,a.DATA_SOURCE
 from sales a 
-left join market_pack b on a.PACK_COD = b.PACK_COD and a.DATA_SOURCE = b.DATA_SOURCE
-left join org c on a.DATA_SOURCE = c.DATA_SOURCE and a.AUDIT_COD = c.AUDIT_COD and b.MARKET = c.MARKET
+left join market_pack b on a.PACK_CODE = b.PACK_COD and a.DATA_SOURCE = b.DATA_SOURCE
+left join org c on a.DATA_SOURCE = c.DATA_SOURCE and a.AUDIT_CODE = c.AUDIT_COD and b.MARKET = c.MARKET
 where C.AUDIT_COD IS NULL
 )

@@ -178,7 +176,7 @@ select
 'ROC' as rc_name_en,
 'Vacant' as RC_Name,
 null as RegionCenter,
-AUDIT_COD,
+AUDIT_CODE,
 MARKET,
 null as bu_category,
 null as bu_name_en,
--- a/ORG/DM_TD_EXT_CHPA_ORG.sql
+++ b/ORG/DM_TD_EXT_CHPA_ORG.sql
@@ -120,9 +120,7 @@ WHERE
 --事实表与维度表来自于不同手工表，目前存在一部分audit_cod在事实表有销量，但是在维度表没有这个audit_cod，导致销量缺失。
 --因此需要从事实表补全这部分audit_cod
 with sales as (
-select distinct PACK_COD,AUDIT_COD,DATA_SOURCE from dm.DM_TF_EXT_UNIONALL_SALES
-union
-select distinct PACK_COD,AUDIT_COD,DATA_SOURCE from dm.dm_tf_external_sales_thc
+select distinct PACK_CODE,AUDIT_CODE,DATA_SOURCE from dm.DM_TF_EXT_UNIONALL_SALES
 )
 ,market_pack as (
 select distinct PACK_COD,MARKET,DATA_SOURCE from dm.dm_td_external_market_pack_mapping
@@ -131,10 +129,10 @@ select distinct PACK_COD,MARKET,DATA_SOURCE from dm.dm_td_external_market_pack_m
 select distinct AUDIT_COD,MARKET,DATA_SOURCE from dm.DM_TD_EXT_CHPA_ORG
 )
 ,tmp_org as (
-select distinct a.AUDIT_COD,b.MARKET,a.DATA_SOURCE
+select distinct a.AUDIT_CODE,b.MARKET,a.DATA_SOURCE
 from sales a 
-left join market_pack b on a.PACK_COD = b.PACK_COD and a.DATA_SOURCE = b.DATA_SOURCE
-left join org c on a.DATA_SOURCE = c.DATA_SOURCE and a.AUDIT_COD = c.AUDIT_COD and b.MARKET = c.MARKET
+left join market_pack b on a.PACK_CODE = b.PACK_COD and a.DATA_SOURCE = b.DATA_SOURCE
+left join org c on a.DATA_SOURCE = c.DATA_SOURCE and a.AUDIT_CODE = c.AUDIT_COD and b.MARKET = c.MARKET
 where C.AUDIT_COD IS NULL
 )

@@ -176,7 +174,7 @@ select
 'ROC' as rc_name_en,
 'Vacant' as RC_Name,
 null as RegionCenter,
-AUDIT_COD,
+AUDIT_CODE,
 MARKET,
 null as bu_category,
 null as bu_name_en,
--- a/ORG/DM_TD_EXT_COUNTY_ORG.sql
+++ b/ORG/DM_TD_EXT_COUNTY_ORG.sql
@@ -70,7 +70,7 @@ DSM_NAME,
 MR_KCODE,
 MR_NAME
 )
-SELECT DISTINCT '' REGION_CODE,'' region_name_en,'' rc_code,'' rc_name_en,'' RegionCenter,A.AUDIT_COD,B.MARKET,C.bu_category,C.bu_name_en,C.sub_bu_name,C.sub_bu_code sub_bu_code_auth,concat(c.bu_code,'IQVIA-COUNTY(Quarterly)') bu_code_auth,A.DATA_SOURCE,1 REGION_RATIO,'','',
+SELECT DISTINCT '' REGION_CODE,'' region_name_en,'' rc_code,'' rc_name_en,'' RegionCenter,A.AUDIT_CODE,B.MARKET,C.bu_category,C.bu_name_en,C.sub_bu_name,C.sub_bu_code sub_bu_code_auth,concat(c.bu_code,'IQVIA-COUNTY(Quarterly)') bu_code_auth,A.DATA_SOURCE,1 REGION_RATIO,'','',
 '' as TEAM,
 '' as MR_TRTY_CODE,
 '' as NSD_KCODE,
@@ -83,7 +83,7 @@ SELECT DISTINCT '' REGION_CODE,'' region_name_en,'' rc_code,'' rc_name_en,'' Reg
 '' as MR_KCODE,
 '' as MR_NAME
 FROM DM.DM_TF_EXT_UNIONALL_SALES A 
-INNER JOIN DM.dm_td_external_market_pack_mapping B ON A.PACK_COD = B.PACK_COD
+INNER JOIN DM.dm_td_external_market_pack_mapping B ON A.PACK_CODE = B.PACK_COD
 AND A.DATA_SOURCE = B.DATA_SOURCE
 INNER JOIN 
 (
@@ -104,8 +104,6 @@ WHERE A.DATA_SOURCE = 'IQVIA-COUNTY(Quarterly)'
 --因此需要从事实表补全这部分audit_cod
 with sales as (
 select distinct PACK_COD,AUDIT_COD,DATA_SOURCE from dm.DM_TF_EXT_UNIONALL_SALES
-union
-select distinct PACK_COD,AUDIT_COD,DATA_SOURCE from dm.dm_tf_external_sales_thc
 )
 ,market_pack as (
 select distinct PACK_COD,MARKET,DATA_SOURCE from dm.dm_td_external_market_pack_mapping
@@ -114,10 +112,10 @@ select distinct PACK_COD,MARKET,DATA_SOURCE from dm.dm_td_external_market_pack_m
 select distinct AUDIT_COD,MARKET,DATA_SOURCE from dm.DM_TD_EXT_COUNTY_ORG
 )
 ,tmp_org as (
-select distinct a.AUDIT_COD,b.MARKET,a.DATA_SOURCE
+select distinct a.AUDIT_CODE,b.MARKET,a.DATA_SOURCE
 from sales a 
-left join market_pack b on a.PACK_COD = b.PACK_COD and a.DATA_SOURCE = b.DATA_SOURCE
-left join org c on a.DATA_SOURCE = c.DATA_SOURCE and a.AUDIT_COD = c.AUDIT_COD and b.MARKET = c.MARKET
+left join market_pack b on a.PACK_CODE = b.PACK_COD and a.DATA_SOURCE = b.DATA_SOURCE
+left join org c on a.DATA_SOURCE = c.DATA_SOURCE and a.AUDIT_CODE = c.AUDIT_COD and b.MARKET = c.MARKET
 where C.AUDIT_COD IS NULL
 )

--- a/ORG/DM_TD_EXT_EC_ORG.sql
+++ b/ORG/DM_TD_EXT_EC_ORG.sql
@@ -69,7 +69,7 @@ DSM_NAME,
 MR_KCODE,
 MR_NAME
 )
-SELECT DISTINCT '' REGION_CODE,'' region_name_en,'' rc_code,'' rc_name_en,'' RegionCenter,A.AUDIT_COD,B.MARKET,C.bu_category,C.bu_name_en,C.sub_bu_name,C.sub_bu_code sub_bu_code_auth,concat(c.bu_code,'EC(Monthly)') bu_code_auth,A.DATA_SOURCE,1 REGION_RATIO,'','',
+SELECT DISTINCT '' REGION_CODE,'' region_name_en,'' rc_code,'' rc_name_en,'' RegionCenter,A.AUDIT_CODE,B.MARKET,C.bu_category,C.bu_name_en,C.sub_bu_name,C.sub_bu_code sub_bu_code_auth,concat(c.bu_code,'EC(Monthly)') bu_code_auth,A.DATA_SOURCE,1 REGION_RATIO,'','',
 '' as TEAM,
 '' as MR_TRTY_CODE,
 '' as NSD_KCODE,
@@ -82,7 +82,7 @@ SELECT DISTINCT '' REGION_CODE,'' region_name_en,'' rc_code,'' rc_name_en,'' Reg
 '' as MR_KCODE,
 '' as MR_NAME
 FROM DM.DM_TF_EXT_UNIONALL_SALES A 
-INNER JOIN DM.dm_td_external_market_pack_mapping B ON A.PACK_COD = B.PACK_COD
+INNER JOIN DM.dm_td_external_market_pack_mapping B ON A.PACK_CODE = B.PACK_COD
 AND A.DATA_SOURCE = B.DATA_SOURCE
 INNER JOIN 
 (
@@ -102,9 +102,7 @@ WHERE A.DATA_SOURCE = 'EC(Monthly)'
 --事实表与维度表来自于不同手工表，目前存在一部分audit_cod在事实表有销量，但是在维度表没有这个audit_cod，导致销量缺失。
 --因此需要从事实表补全这部分audit_cod
 with sales as (
-select distinct PACK_COD,AUDIT_COD,DATA_SOURCE from dm.DM_TF_EXT_UNIONALL_SALES
-union
-select distinct PACK_COD,AUDIT_COD,DATA_SOURCE from dm.dm_tf_external_sales_thc
+select distinct PACK_CODE,AUDIT_CODE,DATA_SOURCE from dm.DM_TF_EXT_UNIONALL_SALES
 )
 ,market_pack as (
 select distinct PACK_COD,MARKET,DATA_SOURCE from dm.dm_td_external_market_pack_mapping
@@ -113,10 +111,10 @@ select distinct PACK_COD,MARKET,DATA_SOURCE from dm.dm_td_external_market_pack_m
 select distinct AUDIT_COD,MARKET,DATA_SOURCE from dm.DM_TD_EXT_EC_ORG
 )
 ,tmp_org as (
-select distinct a.AUDIT_COD,b.MARKET,a.DATA_SOURCE
+select distinct a.AUDIT_CODE,b.MARKET,a.DATA_SOURCE
 from sales a 
-left join market_pack b on a.PACK_COD = b.PACK_COD and a.DATA_SOURCE = b.DATA_SOURCE
-left join org c on a.DATA_SOURCE = c.DATA_SOURCE and a.AUDIT_COD = c.AUDIT_COD and b.MARKET = c.MARKET
+left join market_pack b on a.PACK_CODE = b.PACK_COD and a.DATA_SOURCE = b.DATA_SOURCE
+left join org c on a.DATA_SOURCE = c.DATA_SOURCE and a.AUDIT_CODE = c.AUDIT_COD and b.MARKET = c.MARKET
 where C.AUDIT_COD IS NULL
 )

@@ -158,7 +156,7 @@ select
 'ROC' as rc_name_en,
 'Vacant' as RC_Name,
 null as RegionCenter,
-AUDIT_COD,
+AUDIT_CODE,
 MARKET,
 null as bu_category,
 null as bu_name_en,
--- a/ORG/DM_TD_EXT_THC_ORG.sql
+++ b/ORG/DM_TD_EXT_THC_ORG.sql
@@ -227,9 +227,7 @@ ON t1.PACK_COD = t2.PACK_COD
 --事实表与维度表来自于不同手工表，目前存在一部分audit_cod在事实表有销量，但是在维度表没有这个audit_cod，导致销量缺失。
 --因此需要从事实表补全这部分audit_cod
 with sales as (
-select distinct PACK_COD,AUDIT_COD,DATA_SOURCE from dm.DM_TF_EXT_UNIONALL_SALES
-union
-select distinct PACK_COD,AUDIT_COD,DATA_SOURCE from dm.dm_tf_external_sales_thc
+select distinct PACK_CODE,AUDIT_CODE,DATA_SOURCE from dm.DM_TF_EXT_UNIONALL_SALES
 )
 ,market_pack as (
 select distinct PACK_COD,MARKET,DATA_SOURCE from dm.dm_td_external_market_pack_mapping
@@ -238,10 +236,10 @@ select distinct PACK_COD,MARKET,DATA_SOURCE from dm.dm_td_external_market_pack_m
 select distinct AUDIT_COD,MARKET,DATA_SOURCE from dm.DM_TD_EXT_THC_ORG
 )
 ,tmp_org as (
-select distinct a.AUDIT_COD,b.MARKET,a.DATA_SOURCE
+select distinct a.AUDIT_CODE,b.MARKET,a.DATA_SOURCE
 from sales a 
-left join market_pack b on a.PACK_COD = b.PACK_COD and a.DATA_SOURCE = b.DATA_SOURCE
-left join org c on a.DATA_SOURCE = c.DATA_SOURCE and a.AUDIT_COD = c.AUDIT_COD and b.MARKET = c.MARKET
+left join market_pack b on a.PACK_CODE = b.PACK_COD and a.DATA_SOURCE = b.DATA_SOURCE
+left join org c on a.DATA_SOURCE = c.DATA_SOURCE and a.AUDIT_CODE = c.AUDIT_COD and b.MARKET = c.MARKET
 where C.AUDIT_COD IS NULL
 )

@@ -283,7 +281,7 @@ select
 'ROC' as rc_name_en,
 'Vacant' as RC_Name,
 null as RegionCenter,
-AUDIT_COD,
+AUDIT_CODE,
 MARKET,
 null as bu_category,
 null as bu_name_en,
--- a/ORG/DM_TD_EXT_XIEHE_ORG.sql
+++ b/ORG/DM_TD_EXT_XIEHE_ORG.sql
@@ -166,9 +166,7 @@ where
 --事实表与维度表来自于不同手工表，目前存在一部分audit_cod在事实表有销量，但是在维度表没有这个audit_cod，导致销量缺失。
 --因此需要从事实表补全这部分audit_cod
 with sales as (
-select distinct PACK_COD,AUDIT_COD,DATA_SOURCE from dm.DM_TF_EXT_UNIONALL_SALES
-union
-select distinct PACK_COD,AUDIT_COD,DATA_SOURCE from dm.dm_tf_external_sales_thc
+select distinct PACK_CODE,AUDIT_CODE,DATA_SOURCE from dm.DM_TF_EXT_UNIONALL_SALES
 )
 ,market_pack as (
 select distinct PACK_COD,MARKET,DATA_SOURCE from dm.dm_td_external_market_pack_mapping
@@ -177,10 +175,10 @@ select distinct PACK_COD,MARKET,DATA_SOURCE from dm.dm_td_external_market_pack_m
 select distinct AUDIT_COD,MARKET,DATA_SOURCE from dm.DM_TD_EXT_XIEHE_ORG
 )
 ,tmp_org as (
-select distinct a.AUDIT_COD,b.MARKET,a.DATA_SOURCE
+select distinct a.AUDIT_CODE,b.MARKET,a.DATA_SOURCE
 from sales a 
-left join market_pack b on a.PACK_COD = b.PACK_COD and a.DATA_SOURCE = b.DATA_SOURCE
-left join org c on a.DATA_SOURCE = c.DATA_SOURCE and a.AUDIT_COD = c.AUDIT_COD and b.MARKET = c.MARKET
+left join market_pack b on a.PACK_CODE = b.PACK_COD and a.DATA_SOURCE = b.DATA_SOURCE
+left join org c on a.DATA_SOURCE = c.DATA_SOURCE and a.AUDIT_CODE = c.AUDIT_COD and b.MARKET = c.MARKET
 where C.AUDIT_COD IS NULL
 )

@@ -222,7 +220,7 @@ select
 'ROC' as rc_name_en,
 'Vacant' as RC_Name,
 null as RegionCenter,
-AUDIT_COD,
+AUDIT_CODE,
 MARKET,
 null as bu_category,
 null as bu_name_en,
--- a/DM_TF_EXT_RETAIL_SALES.sql
+++ b/DM_TF_EXT_RETAIL_SALES.sql
@@ -59,13 +59,7 @@ SELECT
  A.PACK_FLAG,
  A.brand_flag PROD_FLAG,
  0 DTP_FLAG,
-  case
-    when
-      max(lower(C.CMPS_DES)) in ('atorvastatin', 'rosuvastatin', 'esomeprazole', 'omeprazole')
-    then
-      1
-    else 0
-  end as cmps_flag,
+  null as cmps_flag,
  -------------------------------------
  --EC数据标签--------------------------
  '' PLATFORM_TYPE,
@@ -91,14 +85,6 @@ SELECT
 -------------------------------------
 FROM
  dm.dm_zk_retail_sales A
-    LEFT JOIN (
-      select DISTINCT
-        iqvia_pack_code,
-        CMPS_DES
-      from
-        dm.dm_zk_retail_pack_property
-    ) C
-      ON A.iqvia_pack_code = C.iqvia_pack_code
 where
  A.YYYYMM >= '202001' 
 GROUP BY
--- a/UNIONALL/DM_TF_EXT_UNIONALL_SALES_MAPPING.sql
+++ b/UNIONALL/DM_TF_EXT_UNIONALL_SALES_MAPPING.sql
@@ -57,6 +57,138 @@

 -- COMMAND ----------

+--Retail
+CREATE OR REPLACE TEMPORARY VIEW RETAIL_EXTERNAL_SALES AS
+SELECT
+  T0.MARKET,
+  T0.KEY_COMPETITOR,
+  T0.CLASS,
+    CONCAT(
+        SUBSTR(T0.YYYYMM, 1, 4),
+        CASE 
+            WHEN SUBSTR(T0.YYYYMM, 5, 2) IN ('01','02','03') THEN '03'
+            WHEN SUBSTR(T0.YYYYMM, 5, 2) IN ('04','05','06') THEN '06'
+            WHEN SUBSTR(T0.YYYYMM, 5, 2) IN ('07','08','09') THEN '09'
+            ELSE '12'
+        END
+    ) AS YYYYMM,
+  T0.PACK_COD,
+  T0.CORP_COD,
+  T0.AUDIT_COD,
+  T0.PLATFORM_TYPE,
+  T0.STORE_NAME,
+  T0.STORE_TYPE,
+  T0.REGION_TYPE,
+  T0.DATA_SOURCE,
+  CASE WHEN P.MARKET IS NOT NULL THEN 1 
+  WHEN T0.PACK_FLAG  = 0 THEN 0 ELSE 2 END PACK_FLAG,
+  CASE WHEN P.MARKET IS NOT NULL THEN 1
+  WHEN T0.MARKET = 'Metoprolol Succinate Market' AND PACK.PROD_DES = 'BETALOC ZOK' THEN 1
+  WHEN T0.MARKET = 'Atorvastatin Market' AND PACK.PROD_DES = 'LIPITOR' THEN 1
+  WHEN T0.MARKET = 'AZITHROMYCIN Market' AND PACK.PROD_DES = 'ZITHROMAX' THEN 1
+  WHEN T0.PROD_FLAG = 0 THEN 0 ELSE 2 END PROD_FLAG,
+  T0.DTP_FLAG,
+  CASE WHEN P.MARKET IS NOT NULL THEN 1 
+  WHEN T0.MARKET = 'Metoprolol Succinate Market' AND PACK.PROD_DES = 'BETALOC ZOK' THEN 1
+  WHEN T0.MARKET = 'Atorvastatin Market' AND PACK.PROD_DES = 'LIPITOR' THEN 1
+  WHEN T0.MARKET = 'AZITHROMYCIN Market' AND PACK.PROD_DES = 'ZITHROMAX' THEN 1
+  WHEN PACK.CMPS_DES in ('AZITHROMYCIN', 'METOPROLOL', 'ATORVASTATIN') THEN 1 
+  ELSE 0 END CMPS_FLAG,
+  T0.NEW_CODE,
+  PACK.PROD_COD,
+  PACK.CMPS_COD,
+  T0.INST_CODE,
+  T0.AIA_HP_FLAG,
+  T0.DEPT_NAME,
+  T0.H_LEVEL,
+  T0.REIMBURSE,
+  T0.REIMBURSE_TYPE,
+  T0.PRESCRIPTION_TYPE,
+  T0.VA,
+  T0.UT,
+  T0.CU,
+  T0.PT,
+  T0.SALES_UNIT_CAL,
+  T0.SALES_UNIT_CAL_LY,
+  T0.SALES_VALUE_CAL,
+  T0.SALES_VALUE_CAL_LY,
+  T0.CONUTING_UNIT,
+  T0.CONUTING_UNIT_LY,
+  T0.PDOT,
+  T0.PDOT_LY,
+  T0.PRESCRIPTION,
+  T0.PRESCRIPTION_LY,
+  1 MERGED_DATA_DTP_OTHERS
+FROM
+  DM.DM_TF_EXT_UNIONALL_MARKET_SALES AS T0
+    LEFT JOIN (
+      SELECT
+        OTHERS_MONTH
+      FROM
+        tmp.tmp_dm_td_ext_retail_niad_month
+    ) T1 --Retail取非niad先来数据部分
+    LEFT JOIN tmp.tmp_td_ext_market_hide_flag P 
+      ON T0.DATA_SOURCE = P.data_source AND T0.MARKET = P.market
+    LEFT JOIN dm.dm_td_external_packinfo PACK 
+      ON T0.PACK_COD = PACK.PACK_COD AND T0.DATA_SOURCE = PACK.DATA_SOURCE
+WHERE
+  T0.DATA_SOURCE = 'Retail(Quarterly)'
+  AND T0.YYYYMM<=T1.others_month
+
+-- COMMAND ----------
+
+CREATE OR REPLACE TEMPORARY VIEW RETAIL_EXTERNAL_SALES_ALL AS
+SELECT
+  T0.MARKET,
+  T0.KEY_COMPETITOR,
+  T0.CLASS,
+  T0.YYYYMM,
+  T0.PACK_COD,
+  T0.CORP_COD,
+  T0.AUDIT_COD,
+  T0.PLATFORM_TYPE,
+  T0.STORE_NAME,
+  T0.STORE_TYPE,
+  T0.REGION_TYPE,
+  T0.DATA_SOURCE,
+  CASE WHEN T1.PACK_COD IS NOT NULL THEN 1 ELSE T0.PACK_FLAG END PACK_FLAG,
+  CASE WHEN T2.PROD_COD IS NOT NULL THEN 1 ELSE T0.PROD_FLAG END PROD_FLAG,
+  T0.DTP_FLAG,
+  CASE WHEN T3.CMPS_COD IS NOT NULL THEN 1 ELSE T0.CMPS_FLAG END CMPS_FLAG,
+  T0.NEW_CODE,
+  T0.INST_CODE,
+  T0.AIA_HP_FLAG,
+  T0.DEPT_NAME,
+  T0.H_LEVEL,
+  T0.REIMBURSE,
+  T0.REIMBURSE_TYPE,
+  T0.PRESCRIPTION_TYPE,
+  T0.VA,
+  T0.UT,
+  T0.CU,
+  T0.PT,
+  T0.SALES_UNIT_CAL,
+  T0.SALES_UNIT_CAL_LY,
+  T0.SALES_VALUE_CAL,
+  T0.SALES_VALUE_CAL_LY,
+  T0.CONUTING_UNIT,
+  T0.CONUTING_UNIT_LY,
+  T0.PDOT,
+  T0.PDOT_LY,
+  T0.PRESCRIPTION,
+  T0.PRESCRIPTION_LY,
+  T0.MERGED_DATA_DTP_OTHERS
+FROM
+  RETAIL_EXTERNAL_SALES AS T0
+LEFT JOIN (SELECT DISTINCT PACK_COD FROM RETAIL_EXTERNAL_SALES WHERE PACK_FLAG = 1) T1
+  ON T0.PACK_COD = T1.PACK_COD
+LEFT JOIN (SELECT DISTINCT PROD_COD FROM RETAIL_EXTERNAL_SALES WHERE PROD_FLAG = 1) T2
+  ON T0.PROD_COD = T2.PROD_COD
+LEFT JOIN (SELECT DISTINCT CMPS_COD FROM RETAIL_EXTERNAL_SALES WHERE CMPS_FLAG = 1) T3
+  ON T0.CMPS_COD = T3.CMPS_COD
+
+-- COMMAND ----------
+
 CREATE OR REPLACE TEMPORARY VIEW ALL_EXTERNAL_SALES AS
 --DTP
 SELECT
@@ -103,68 +235,6 @@ FROM
  DM.DM_TF_EXT_UNIONALL_MARKET_SALES AS T0
 WHERE
  T0.DATA_SOURCE = 'DTP(Quarterly)'
-
--Retail
-UNION ALL
-SELECT
-  T0.MARKET,
-  T0.KEY_COMPETITOR,
-  T0.CLASS,
-    CONCAT(
-        SUBSTR(T0.YYYYMM, 1, 4),
-        CASE 
-            WHEN SUBSTR(T0.YYYYMM, 5, 2) IN ('01','02','03') THEN '03'
-            WHEN SUBSTR(T0.YYYYMM, 5, 2) IN ('04','05','06') THEN '06'
-            WHEN SUBSTR(T0.YYYYMM, 5, 2) IN ('07','08','09') THEN '09'
-            ELSE '12'
-        END
-    ) AS YYYYMM,
-  T0.PACK_COD,
-  T0.CORP_COD,
-  T0.AUDIT_COD,
-  T0.PLATFORM_TYPE,
-  T0.STORE_NAME,
-  T0.STORE_TYPE,
-  T0.REGION_TYPE,
-  T0.DATA_SOURCE,
-  T0.PACK_FLAG,
-  T0.PROD_FLAG,
-  T0.DTP_FLAG,
-  T0.CMPS_FLAG,
-  T0.NEW_CODE,
-  T0.INST_CODE,
-  T0.AIA_HP_FLAG,
-  T0.DEPT_NAME,
-  T0.H_LEVEL,
-  T0.REIMBURSE,
-  T0.REIMBURSE_TYPE,
-  T0.PRESCRIPTION_TYPE,
-  T0.VA,
-  T0.UT,
-  T0.CU,
-  T0.PT,
-  T0.SALES_UNIT_CAL,
-  T0.SALES_UNIT_CAL_LY,
-  T0.SALES_VALUE_CAL,
-  T0.SALES_VALUE_CAL_LY,
-  T0.CONUTING_UNIT,
-  T0.CONUTING_UNIT_LY,
-  T0.PDOT,
-  T0.PDOT_LY,
-  T0.PRESCRIPTION,
-  T0.PRESCRIPTION_LY,
-  1 MERGED_DATA_DTP_OTHERS
-FROM
-  DM.DM_TF_EXT_UNIONALL_MARKET_SALES AS T0
-    LEFT JOIN (
-      SELECT
-        OTHERS_MONTH
-      FROM
-        tmp.tmp_dm_td_ext_retail_niad_month
-    ) T1 --Retail取非niad先来数据部分
-WHERE
-  T0.DATA_SOURCE = 'Retail(Quarterly)'
-  AND T0.YYYYMM<=T1.others_month
 --EC
 UNION ALL
 SELECT
@@ -226,6 +296,50 @@ FROM
 WHERE
  T0.DATA_SOURCE = 'EC(Monthly)'
  AND SUBSTR(T0.YYYYMM, 5, 2) IN ('03', '06', '09', '12')
+UNION ALL 
+--RETAIL
+SELECT
+  T0.MARKET,
+  T0.KEY_COMPETITOR,
+  T0.CLASS,
+  T0.YYYYMM,
+  T0.PACK_COD,
+  T0.CORP_COD,
+  T0.AUDIT_COD,
+  T0.PLATFORM_TYPE,
+  T0.STORE_NAME,
+  T0.STORE_TYPE,
+  T0.REGION_TYPE,
+  T0.DATA_SOURCE,
+  T0.PACK_FLAG,
+  T0.PROD_FLAG,
+  T0.DTP_FLAG,
+  T0.CMPS_FLAG,
+  T0.NEW_CODE,
+  T0.INST_CODE,
+  T0.AIA_HP_FLAG,
+  T0.DEPT_NAME,
+  T0.H_LEVEL,
+  T0.REIMBURSE,
+  T0.REIMBURSE_TYPE,
+  T0.PRESCRIPTION_TYPE,
+  T0.VA,
+  T0.UT,
+  T0.CU,
+  T0.PT,
+  T0.SALES_UNIT_CAL,
+  T0.SALES_UNIT_CAL_LY,
+  T0.SALES_VALUE_CAL,
+  T0.SALES_VALUE_CAL_LY,
+  T0.CONUTING_UNIT,
+  T0.CONUTING_UNIT_LY,
+  T0.PDOT,
+  T0.PDOT_LY,
+  T0.PRESCRIPTION,
+  T0.PRESCRIPTION_LY,
+  T0.MERGED_DATA_DTP_OTHERS
+FROM
+  RETAIL_EXTERNAL_SALES_ALL AS T0
 --OTHERS DATA SOURCE
 UNION ALL
 SELECT
@@ -275,6 +389,14 @@ WHERE

 -- COMMAND ----------

+
+
+-- COMMAND ----------
+
+select distinct PACK_FLAG,PROD_FLAG from DM.DM_TF_EXT_UNIONALL_MARKET_SALES where DATA_SOURCE = 'Retail(Quarterly)'
+
+-- COMMAND ----------
+
 create or replace table tmp.tmp_tf_ext_aia_target_inst 
 -- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/TMP/tmp_tf_ext_aia_target_inst';
 -- 上面是生产环境location，下面是测试环境location
@@ -351,7 +473,7 @@ SELECT
  END AS CONUTING_UNIT,
  CASE
    WHEN A.CONUTING_UNIT_LY = 0 THEN NULL
-    ELSE CAST(A.CONUTING_UNIT_LY AS DECIMAL(35, 10))
+    https://adb-1064580724995799.3.databricks.azure.cn/editor/notebooks/3456519074298505?o=1064580724995799$0ELSE CAST(A.CONUTING_UNIT_LY AS DECIMAL(35, 10))
  END AS CONUTING_UNIT_LY,
  CASE
    WHEN A.PDOT = 0 THEN NULL