chenwu/MarketAnalysis-Rebuild
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

添加分区

Browse Source
This commit is contained in:
chenwu
2026-04-17 13:08:46 +08:00
parent 6ab0cd209e
commit a9e216295e
76 changed files with 1669 additions and 711 deletions
Download Patch File Download Diff File Expand all files Collapse all files

289
External All Channel.SemanticModel/definition/tables/Fact_Sales.tmdl
View File

@@ -598,86 +598,215 @@ table Fact_Sales
){
[Name = CatalogName, Kind = "Database"]
}[Data],
"
select
DATA_SOURCE,
MARKET,
KEY_COMPETITOR,
CLASS,
YYYYMM,
PACK_COD,
AUDIT_COD,
VA,
UT,
CU,
PT,
SALES_UNIT_CAL,
SALES_UNIT_CAL_LY,
SALES_VALUE_CAL,
SALES_VALUE_CAL_LY,
CONUTING_UNIT,
CONUTING_UNIT_LY,
PDOT,
PDOT_LY,
PRESCRIPTION,
PRESCRIPTION_LY,
---关联主键-----------------------------
TO_DATE(CONCAT(YYYYMM, '01'), 'yyyyMMdd') AS DATE_KEY,
COALESCE(MARKET, '') || DATA_SOURCE AS MARKET_KEY,
COALESCE(PACK_COD, '') || DATA_SOURCE AS PACK_SOURCE,
COALESCE(AUDIT_COD, '') || DATA_SOURCE AS AUDIT_SOURCE,
COALESCE(AUDIT_COD, '') || DATA_SOURCE AS AUDIT_KEY,
COALESCE(MARKET, '') || COALESCE(CLASS, '') || DATA_SOURCE AS CLASS_KEY,
COALESCE(STORE_TYPE, '') || DATA_SOURCE AS STORE_TYPE_SOURCE,
COALESCE(STORE_TYPE, '') || '-' || COALESCE(PLATFORM_TYPE, '') AS STORE_PLATFORM,
COALESCE(REIMBURSE_TYPE, '') || DATA_SOURCE AS REIMBURSETYPE_SOURCE,
COALESCE(REIMBURSE, '') || DATA_SOURCE AS REIMBURSE_SOURCE,
COALESCE(PRESCRIPTION_TYPE, '') || DATA_SOURCE AS PRESCRIPTION_SOURCE,
COALESCE(PLATFORM_TYPE, '') || DATA_SOURCE AS PLATFORM_TYPE_SOURCE,
COALESCE(dept_name, '') || DATA_SOURCE AS DEPT_SOURCE,
COALESCE(AUDIT_COD, '') || DATA_SOURCE AS INST_SOURCE,
COALESCE(AIA_HP_FLAG, '') || DATA_SOURCE AS HP_SOURCE,
-------------------------------------
--Retail藏数逻辑标签------------------
PACK_FLAG,
PROD_FLAG,
DTP_FLAG,
CMPS_FLAG,
-------------------------------------
--EC数据标签--------------------------
PLATFORM_TYPE,
STORE_NAME,
STORE_TYPE,
-------------------------------------
--COUNTY数据标签----------------------
REGION_TYPE,
--AIA数据标签-------------------------
INST_CODE,
AIA_HP_FLAG,
AIA_REMOVE,
-------------------------------------
--XIE HE 数据标签---------------------
NEW_CODE,
DEPT_NAME,
H_LEVEL,
REIMBURSE,
REIMBURSE_TYPE,
PRESCRIPTION_TYPE,
-------------------------------------
--Merged Data部分--------------------
MERGEDATA_FLAG,
MERGEDATA_FLAG_MKT,
MERGEDATA_FLAG_CHPA_DTP,
MERGEDATA_FLAG_DTP_NOROC,
MERGED_DATA_DTP_OTHERS,
EGFR_FLAG,
-------------------------------------
NULL AS CORP_COD
from
DM.DM_TF_EXT_UNIONALL_SALES_MAPPING
"& Fact_Sales_SQL_limit
& UsingLimit,
Fact_Sales_SQL &"WHERE DATA_SOURCE = 'IQVIA-CHPA(Monthly)'"& Fact_Sales_SQL_limit& UsingLimit,
null,
[
EnableFolding = true
]
)
in
Source
```
partition Fact_Sales_AIA = m
mode: import
queryGroup: Fact_Sales
source = ```
let
Source =
Value.NativeQuery(
Databricks.Catalogs(
ServerAddress, HttpPath, [
Catalog = CatalogName,
Database = null,
EnableAutomaticProxyDiscovery = null,EnableQueryResultDownload="0"
]
){
[Name = CatalogName, Kind = "Database"]
}[Data],
Fact_Sales_SQL &"WHERE DATA_SOURCE = 'AIA(Monthly)'"& Fact_Sales_SQL_limit& UsingLimit,
null,
[
EnableFolding = true
]
)
in
Source
```
partition Fact_Sales_CHC = m
mode: import
queryGroup: Fact_Sales
source = ```
let
Source =
Value.NativeQuery(
Databricks.Catalogs(
ServerAddress, HttpPath, [
Catalog = CatalogName,
Database = null,
EnableAutomaticProxyDiscovery = null,EnableQueryResultDownload="0"
]
){
[Name = CatalogName, Kind = "Database"]
}[Data],
Fact_Sales_SQL &"WHERE DATA_SOURCE = 'CHC(Quarterly)'"& Fact_Sales_SQL_limit& UsingLimit,
null,
[
EnableFolding = true
]
)
in
Source
```
partition Fact_Sales_COUNTY = m
mode: import
queryGroup: Fact_Sales
source = ```
let
Source =
Value.NativeQuery(
Databricks.Catalogs(
ServerAddress, HttpPath, [
Catalog = CatalogName,
Database = null,
EnableAutomaticProxyDiscovery = null,EnableQueryResultDownload="0"
]
){
[Name = CatalogName, Kind = "Database"]
}[Data],
Fact_Sales_SQL &"WHERE DATA_SOURCE = 'IQVIA-COUNTY(Quarterly)'"& Fact_Sales_SQL_limit& UsingLimit,
null,
[
EnableFolding = true
]
)
in
Source
```
partition Fact_Sales_THC = m
mode: import
queryGroup: Fact_Sales
source = ```
let
Source =
Value.NativeQuery(
Databricks.Catalogs(
ServerAddress, HttpPath, [
Catalog = CatalogName,
Database = null,
EnableAutomaticProxyDiscovery = null,EnableQueryResultDownload="0"
]
){
[Name = CatalogName, Kind = "Database"]
}[Data],
Fact_Sales_SQL &"WHERE DATA_SOURCE = 'THC(Quarterly)'"& Fact_Sales_SQL_limit& UsingLimit,
null,
[
EnableFolding = true
]
)
in
Source
```
partition Fact_Sales_EC = m
mode: import
queryGroup: Fact_Sales
source = ```
let
Source =
Value.NativeQuery(
Databricks.Catalogs(
ServerAddress, HttpPath, [
Catalog = CatalogName,
Database = null,
EnableAutomaticProxyDiscovery = null,EnableQueryResultDownload="0"
]
){
[Name = CatalogName, Kind = "Database"]
}[Data],
Fact_Sales_SQL &"WHERE DATA_SOURCE = 'EC(Monthly)'"& Fact_Sales_SQL_limit& UsingLimit,
null,
[
EnableFolding = true
]
)
in
Source
```
partition Fact_Sales_DTP = m
mode: import
queryGroup: Fact_Sales
source = ```
let
Source =
Value.NativeQuery(
Databricks.Catalogs(
ServerAddress, HttpPath, [
Catalog = CatalogName,
Database = null,
EnableAutomaticProxyDiscovery = null,EnableQueryResultDownload="0"
]
){
[Name = CatalogName, Kind = "Database"]
}[Data],
Fact_Sales_SQL &"WHERE DATA_SOURCE = 'DTP(Quarterly)'"& Fact_Sales_SQL_limit& UsingLimit,
null,
[
EnableFolding = true
]
)
in
Source
```
partition Fact_Sales_Retail = m
mode: import
queryGroup: Fact_Sales
source = ```
let
Source =
Value.NativeQuery(
Databricks.Catalogs(
ServerAddress, HttpPath, [
Catalog = CatalogName,
Database = null,
EnableAutomaticProxyDiscovery = null,EnableQueryResultDownload="0"
]
){
[Name = CatalogName, Kind = "Database"]
}[Data],
Fact_Sales_SQL &"WHERE DATA_SOURCE = 'Retail(Quarterly)'"& Fact_Sales_SQL_limit& UsingLimit,
null,
[
EnableFolding = true
]
)
in
Source
```
partition Fact_Sales_XIEHE = m
mode: import
queryGroup: Fact_Sales
source = ```
let
Source =
Value.NativeQuery(
Databricks.Catalogs(
ServerAddress, HttpPath, [
Catalog = CatalogName,
Database = null,
EnableAutomaticProxyDiscovery = null,EnableQueryResultDownload="0"
]
){
[Name = CatalogName, Kind = "Database"]
}[Data],
Fact_Sales_SQL &"WHERE DATA_SOURCE = 'XH Data(Quarterly)'"& Fact_Sales_SQL_limit& UsingLimit,
null,
[
EnableFolding = true