U j3@sddlmZddZd ddZddZd d Zd d Zeed ddZedddZ ddZ ddZ ddZ ddZ ddZddZdS)!ensure_analytic_collectioncCs t|dS)N)print)textrW/var/www/itgmanager/itgmanager/Analytic/scapp_database/utils/analytic_database_utils.pydata_analytic_loggersr data_analyticcCs t||S)z{ Args: - database: Instancia de la bd de MongoDB. - database_name: Nombre de la coleccion objetivo r)database database_namerrrensure_data_analytic_collectionsr c Csz,||d|d}ddi}t|||}WnBtk rn}z$td|jjd|iWYSd}~XYnXi}|D]<} | dd } || i| d } | d i|| | <qx|S) uu Obtiene los documentos de analítica almacenados en la base de datos para un rango de días y los ordena por día y por jaula, devolviendo un diccionario con el formato: { 'dd/mm/YYYY': { : { ...data... }, : { ...data... }, ... }, ... } @params: - collection: Colección de MongoDB donde se almacenan los datos. - center_id (str): ID de centro, en formato string, correspondiente al identificador único de cada centro. - start_day (datetime): Fecha de inicio (incluida). - end_day (datetime): Fecha final (exclusiva). @returns: - grouped_data (dict): Datos agrupados por día y por jaula. { 'dd/mm/YYYY': { : { ...data... }, ... }, ... } z$gtez$lt) timestamp centro_id_idr'Error leyendo documentos de analítica  : Nr%d/%m/%Y camera_iddata) listfind Exceptionr __traceback__ tb_linenostrftime setdefaultget) collection center_id start_dayend_dayquery projectiondocse grouped_datadocdayjaula_idrrrfetch_analytic_datas   r*cCsr||t|dkr$t|dn t|d}t|dkrLt|dn t|d}td|d|dS) u ### ? Almacena los datos de analítica en la coleccion correspondiente @params - docs_array [docs] : Array de documentos a añadir en la colección, { timestamp, camera_id, data } - data: one_day_data (dict): Diccionario de los datos del día: { jaula: { sfr_value, delivered_food, tasa_units, tasa_values, tasa_data, fasts_count, feeding_time_range, alarms_data, alarms_count } } u díasu díaz jaulas.z jaula.z"Almacenado correctamente datos de z, con un total de N) insert_manylenr)r docs_array saved_daysinfoZ info_jaularrrsave_analytics_datas ((r1c Cszt||||}WnBtk rT}z$td|jjd|iWYSd}~XYnXi}|D]j}|dd}||kri||<|d} |d} | d| } |d i} | d| i| ||| <q^|S) u Obtiene los documentos de analítica almacenados en la base de datos para un rango de días y los ordena por día y por jaula, devolviendo un diccionario con el formato: { 'dd/mm/YYYY': { : { ...data... }, : { ...data... }, ... }, ... } @params: - collection: Colección de MongoDB donde se almacenan los datos. - center_id (str): ID de centro, en formato string, correspondiente al identificador único de cada centro. - start_day (datetime): Fecha de inicio (incluida). - end_day (datetime): Fecha final (exclusiva). @returns: - grouped_data (dict): Datos agrupados por día y por jaula. rrNrrrr-r)get_docs_by_date_and_arearrrrrrupdate) rarear r!r$r%r&r'r(r)r object_id data_to_packrrrfetch_analytic_area_datas"   r8)rprefijo_objetivoc Csf|}|}dd||diiddddddd d gid gid ddd d gid gigi|giiig}t||S) z Conecta a MongoDB y devuelve los docs cuyo campo 'timestamp' caiga dentro del rango de fechas indicado y cuyo 'centro_id' coincida en los dos primeros segmentos con prefijo_objetivo. $matchrr z$exprz$eqz$concatz $arrayElemAtz$splitz $centro_idr2rr+r aggregate)rr9 start_dateend_date fecha_inicial fecha_finalpipelinerrrr3s8   r3)region_prefijocCs<dd||diidddd|diiig}t||}|S)u Devuelve documentos cuyo campo 'centro_id' comienza con 'region_prefijo' y cuyo 'timestamp' está dentro del rango especificado. r:rr rz$regex^r2r;)rrBr=r>rAresultrrrget_docs_by_regions  rEc Csz|}WnBtk rJ}z$td|jjd|iWYSd}~XYnXi}|D]j}|dd}||krvi||<|d}|d}|d|}|di}|d|i||||<qT|S) Nrrrrrrr2r)rrrrrrr4) r$r%r&r'r(r)rr6r7rrrfetch_analytic_region_datas"   rFc Csgggggggggd S)N) alarms_by_ton alarms_countalarms_thresholddelivered_food fasts_countperdidos_count sfr_value tasa_units visitas_countrrrrr_init_value_summary,srPcCs$dtddtddtddS)Nr)alarmtasas)altamediabaja)setrrrr_init_tasa_summary3s   rWcCsf|D]X\}}|dkr6|r,t|t|nd||<q|dkrT|rJ|dnd||<qt|||<q|S)N)rMrIrrN)itemssumr-validar_y_sumar)resumenkeyvalsrrr_postprocess_values;sr^cCs&|D]\}}t|d|d<q|S)NrR)rXr)Z ts_summaryZlvlr0rrr_postprocess_tasaFsr_c Cshzdd|D}t|WStk rbzdd|D}t|WYStk r\YYdSXYnXdS)NcSsg|] }t|qSr)int.0xrrr Nsz#validar_y_sumar..cSsg|] }t|qSr)floatrarrrrdSs)rY ValueError)listaZnumerosrrrrZKs rZN)r )shared_db_utilsrrr r*r1r8strr3rErFrPrWr^r_rZrrrrs"  p2 6