new physical db

.gitignore

@@ -4,4 +4,4 @@
 __pycache__
 /data2
 /physical_db/physical_database.csv
-/physical_db
+# /physical_db

queries/process_trx.py

@@ -56,6 +56,13 @@ TRX_BTS_COLUMNS = [
     "trxFrequencyType",
     "trxRfPower",
     "tsc",
+    "TCHs",
+    "SDs",
+    "BCCHs",
+    "CCCHs",
+    "CBCs",
+    "TotalChannels",
+    "Signal",
 ]
 
 
@@ -123,6 +130,52 @@ def process_trx_with_bts_name(file_path: str):
     df_bts = process_small_bts_data(file_path=file_path)
 
     df_trx_bts_name = pd.merge(df_gsm_trx, df_bts, on="ID_BTS", how="left")
+
+    # Filter columns strictly by names like "channelXType"
+    channel_columns = [
+        col
+        for col in df_trx_bts_name.columns
+        if col.startswith("channel") and col.endswith("Type")
+    ]
+
+    # TCHs	SDs	BCCH	CCCH	CBC	Total	Signal
+
+    # Calculate "count of channels per TRX" for each row
+    df_trx_bts_name["TCHs"] = df_trx_bts_name[channel_columns].apply(
+        lambda row: (row == 2).sum(), axis=1
+    )
+    df_trx_bts_name["SDs"] = df_trx_bts_name[channel_columns].apply(
+        lambda row: (row == 3).sum(), axis=1
+    )
+
+    df_trx_bts_name["BCCHs"] = df_trx_bts_name[channel_columns].apply(
+        lambda row: (row == 4).sum(), axis=1
+    )
+
+    df_trx_bts_name["CCCHs"] = df_trx_bts_name[channel_columns].apply(
+        lambda row: (row == 6).sum(), axis=1
+    )
+
+    df_trx_bts_name["CBCs"] = df_trx_bts_name[channel_columns].apply(
+        lambda row: (row == 8).sum(), axis=1
+    )
+
+    # Total Channels =  TCHs + SDs + BCCHs + CCCHs + CBCs
+
+    df_trx_bts_name["TotalChannels"] = (
+        df_trx_bts_name["TCHs"]
+        + df_trx_bts_name["SDs"]
+        + df_trx_bts_name["BCCHs"]
+        + df_trx_bts_name["CCCHs"]
+        + df_trx_bts_name["CBCs"]
+    )
+
+    # Signal =  BCCHs + CCCHs + CBCs
+
+    df_trx_bts_name["Signal"] = (
+        df_trx_bts_name["BCCHs"] + df_trx_bts_name["CCCHs"] + df_trx_bts_name["CBCs"]
+    )
+
     df_trx_bts_name = df_trx_bts_name[TRX_BTS_COLUMNS]
 
     # UtilsVars.all_db_dfs.append(df_trx_bts_name)