adding some columns to gsm and wcdma
Browse files- queries/process_gsm.py +15 -2
- queries/process_wcdma.py +4 -0
- utils/check_sheet_exist.py +5 -5
- utils/utils_vars.py +10 -0
queries/process_gsm.py
CHANGED
|
@@ -31,8 +31,6 @@ BTS_COLUMNS = [
|
|
| 31 |
"fddRscpMin",
|
| 32 |
"gprsEnabled",
|
| 33 |
"locationAreaIdLAC",
|
| 34 |
-
"locationAreaIdMCC",
|
| 35 |
-
"locationAreaIdMNC",
|
| 36 |
"rac",
|
| 37 |
"rachDropRxLevelThreshold",
|
| 38 |
"sectorId",
|
|
@@ -42,6 +40,9 @@ BTS_COLUMNS = [
|
|
| 42 |
"gsmPriority",
|
| 43 |
"segmentName",
|
| 44 |
"Code_Sector",
|
|
|
|
|
|
|
|
|
|
| 45 |
]
|
| 46 |
|
| 47 |
BCF_COLUMNS = [
|
|
@@ -78,6 +79,18 @@ def process_gsm_data(file_path: str):
|
|
| 78 |
df_bts["SectorId2"] = (
|
| 79 |
df_bts["sectorId"].map(UtilsVars.sector_mapping).fillna(df_bts["sectorId"])
|
| 80 |
)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 81 |
df_bts["ID_BCF"] = df_bts[["BSC", "BCF"]].astype(str).apply("_".join, axis=1)
|
| 82 |
df_bts["Code_Sector"] = (
|
| 83 |
df_bts[["code", "SectorId2"]].astype(str).apply("_".join, axis=1)
|
|
|
|
| 31 |
"fddRscpMin",
|
| 32 |
"gprsEnabled",
|
| 33 |
"locationAreaIdLAC",
|
|
|
|
|
|
|
| 34 |
"rac",
|
| 35 |
"rachDropRxLevelThreshold",
|
| 36 |
"sectorId",
|
|
|
|
| 40 |
"gsmPriority",
|
| 41 |
"segmentName",
|
| 42 |
"Code_Sector",
|
| 43 |
+
"band_frequence",
|
| 44 |
+
"type_cellule",
|
| 45 |
+
"configuration_schema",
|
| 46 |
]
|
| 47 |
|
| 48 |
BCF_COLUMNS = [
|
|
|
|
| 79 |
df_bts["SectorId2"] = (
|
| 80 |
df_bts["sectorId"].map(UtilsVars.sector_mapping).fillna(df_bts["sectorId"])
|
| 81 |
)
|
| 82 |
+
df_bts["band_frequence"] = (
|
| 83 |
+
df_bts["frequencyBandInUse"].map(UtilsVars.band_frequence).fillna("not found")
|
| 84 |
+
)
|
| 85 |
+
df_bts["type_cellule"] = (
|
| 86 |
+
df_bts["frequencyBandInUse"].map(UtilsVars.type_cellule).fillna("not found")
|
| 87 |
+
)
|
| 88 |
+
df_bts["configuration_schema"] = (
|
| 89 |
+
df_bts["frequencyBandInUse"]
|
| 90 |
+
.map(UtilsVars.configuration_schema)
|
| 91 |
+
.fillna("not found")
|
| 92 |
+
)
|
| 93 |
+
|
| 94 |
df_bts["ID_BCF"] = df_bts[["BSC", "BCF"]].astype(str).apply("_".join, axis=1)
|
| 95 |
df_bts["Code_Sector"] = (
|
| 96 |
df_bts[["code", "SectorId2"]].astype(str).apply("_".join, axis=1)
|
queries/process_wcdma.py
CHANGED
|
@@ -38,6 +38,7 @@ WCEL_COLUMNS = [
|
|
| 38 |
"SectorID",
|
| 39 |
"Code_Sector",
|
| 40 |
"code_wcel",
|
|
|
|
| 41 |
]
|
| 42 |
|
| 43 |
WBTS_COLUMNS = [
|
|
@@ -92,6 +93,9 @@ def process_wcdma_data(file_path: str):
|
|
| 92 |
|
| 93 |
df_wcel["Code_Sector"] = df_wcel["Code_Sector"].str.replace(".0", "")
|
| 94 |
|
|
|
|
|
|
|
|
|
|
| 95 |
# Process WBTS data
|
| 96 |
df_wbts = dfs["WBTS"]
|
| 97 |
df_wbts.columns = df_wbts.columns.str.replace(r"[ ]", "", regex=True)
|
|
|
|
| 38 |
"SectorID",
|
| 39 |
"Code_Sector",
|
| 40 |
"code_wcel",
|
| 41 |
+
"porteuse",
|
| 42 |
]
|
| 43 |
|
| 44 |
WBTS_COLUMNS = [
|
|
|
|
| 93 |
|
| 94 |
df_wcel["Code_Sector"] = df_wcel["Code_Sector"].str.replace(".0", "")
|
| 95 |
|
| 96 |
+
df_wcel["porteuse"] = (
|
| 97 |
+
df_wcel["UARFCN"].map(UtilsVars.porteuse_mapping).fillna("not found")
|
| 98 |
+
)
|
| 99 |
# Process WBTS data
|
| 100 |
df_wbts = dfs["WBTS"]
|
| 101 |
df_wbts.columns = df_wbts.columns.str.replace(r"[ ]", "", regex=True)
|
utils/check_sheet_exist.py
CHANGED
|
@@ -43,11 +43,11 @@ def check_sheets(technology_attr, sheet_list, file_path):
|
|
| 43 |
missing_sheets = [sheet for sheet in sheet_list if sheet not in available_sheets]
|
| 44 |
if not missing_sheets:
|
| 45 |
setattr(Technology, technology_attr, True)
|
| 46 |
-
|
| 47 |
-
|
| 48 |
-
else:
|
| 49 |
-
|
| 50 |
-
|
| 51 |
|
| 52 |
|
| 53 |
# Check each technology's sheets
|
|
|
|
| 43 |
missing_sheets = [sheet for sheet in sheet_list if sheet not in available_sheets]
|
| 44 |
if not missing_sheets:
|
| 45 |
setattr(Technology, technology_attr, True)
|
| 46 |
+
# print(getattr(Technology, technology_attr))
|
| 47 |
+
# print("All sheets exist")
|
| 48 |
+
# else:
|
| 49 |
+
# print(f"Missing sheets: {missing_sheets}")
|
| 50 |
+
# print(getattr(Technology, technology_attr))
|
| 51 |
|
| 52 |
|
| 53 |
# Check each technology's sheets
|
utils/utils_vars.py
CHANGED
|
@@ -18,7 +18,17 @@ def get_physical_db():
|
|
| 18 |
|
| 19 |
class UtilsVars:
|
| 20 |
sector_mapping = {4: 1, 5: 2, 6: 3, 11: 1, 12: 2, 13: 3}
|
|
|
|
|
|
|
|
|
|
| 21 |
channeltype_mapping = {4: "BCCH", 3: "TCH"}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 22 |
final_lte_database = ""
|
| 23 |
final_gsm_database = ""
|
| 24 |
final_wcdma_database = ""
|
|
|
|
| 18 |
|
| 19 |
class UtilsVars:
|
| 20 |
sector_mapping = {4: 1, 5: 2, 6: 3, 11: 1, 12: 2, 13: 3}
|
| 21 |
+
type_cellule = {1: "Macro Cell 1800", 0: "Macro Cell 900"}
|
| 22 |
+
band_frequence = {1: "OML BAND GSM 1800", 0: "OML BAND GSM 900"}
|
| 23 |
+
configuration_schema = {1: "EGPRS 1800", 0: "EGPRS 900"}
|
| 24 |
channeltype_mapping = {4: "BCCH", 3: "TCH"}
|
| 25 |
+
porteuse_mapping = {
|
| 26 |
+
3004: "OML UTRA Band VIII",
|
| 27 |
+
3006: "OML UTRA Band VIII",
|
| 28 |
+
10812: "OML UTRA Band I",
|
| 29 |
+
10787: "OML UTRA Band I",
|
| 30 |
+
10837: "OML UTRA Band I",
|
| 31 |
+
}
|
| 32 |
final_lte_database = ""
|
| 33 |
final_gsm_database = ""
|
| 34 |
final_wcdma_database = ""
|