Anyado un caso especial para facturar un número 900 de esencial pool a l numero generlal e ellos

app/manager_cdr_fijos_fibra.py

@@ -252,7 +252,8 @@ def cdr_insert_update_cdr_fijos(path_filenames: list, cursor_wifi):
             cursor_wifi (Cursor): Cursor DB_wifi
     """
     try:
-        #print(f'Ficheros a procesar: {path_filenames}')
+        print(f'Ficheros a procesar: {path_filenames}')
+        logging.info('Inicializa proceso de insertar o actualizar registros en [TB_Cdr_Fibra]')
         for path_file in path_filenames:
            
             if os.path.exists(path_file):
@@ -283,8 +284,13 @@ def cdr_insert_update_cdr_fijos(path_filenames: list, cursor_wifi):
                         
                         if line_parse is not None:
                             try:
-                                #TODO Si existe lo actualiza si no lo inserta
+                                # Si existe lo actualiza si no lo inserta
                                    # Definir los campos clave para identificar si el registro ya existe
+                                
+                                # Normalizar num_origen ESTO ES UNA EXCEPCION PAR UN DESVIO DE ESENCIL POOL
+                                if line_parse["num_origen"] == '900920902':
+                                    line_parse["num_origen"] = '856032903'
+
                                 campos_clave = (
                                     line_parse["num_origen"], 
                                     line_parse["num_destino"], 
@@ -328,8 +334,8 @@ def cdr_insert_update_cdr_fijos(path_filenames: list, cursor_wifi):
                                         line_parse["campo13"], line_parse["campo14"], line_parse["fecha_inicio"], line_parse["fecha_fin"],
                                         line_parse["otra_fecha"], line_parse["campo18"]))
                                     
-                                    # Confirmar los cambios en la base de datos
-                                    cursor_wifi.commit()
+                                # Confirmar los cambios en la base de datos
+                                cursor_wifi.commit()
                                 lineas_save += 1  
                                        
                             except Exception as e:
@@ -340,6 +346,7 @@ def cdr_insert_update_cdr_fijos(path_filenames: list, cursor_wifi):
                     time_procesado =  time_final - time_init 
                     time_procesado_fin = str(time_procesado)  
                     message = f'Total registros procesados con costes: {lineas_save}.'
+                    logging.info(f'Total registros procesados con costes: {lineas_save}.')
                     
                     cursor_wifi.execute(
                     "UPDATE TB_CDR_Ficheros SET processed_at=?, Num_Reg_Pro=?, Time_Procesado=?,Observaciones=? WHERE filename=?",
@@ -358,6 +365,7 @@ def cdr_insert_update_cdr_fijos(path_filenames: list, cursor_wifi):
                             os.remove(path_file)
             else:
                 print(f'⚠️ El fichero no existe: {path_file}')
+                logging.warning(f'⚠️ El fichero no existe: {path_file}')
                 
     except Exception as e:
         message = f'Total registros procesados con costes: {lineas_save}.'

main.py

@@ -16,6 +16,7 @@ if __name__ == '__main__':
     # PROCESA ficheros de fijos y los inserta o actualiza en tb_CDR_fijos
     x.save_cdr_fijos_into_database() """
     
+    # Se ejecuta con un crontab
     ### -- Accede al SFTP de fibra y descarga el fichero que le toca y crea registro en tb_cdr_ficheros -- ### 
     manager = ManagerCdrFijosFibra()
     manager.get_cdr_filename_download_fijos_fibra()