h~#pddlZddlZddlmZddlmZddlZddlZejjdddl m Z ddl m Z ejjejjeZejjeZejjeZejj'edZejjeddlmZejjejjeZejjeZejj'ed d Zejj5ere eej6d enej8d edd edefdZddedefdZ y)N)Path)datetimez/var/www/html/config)get_connection) load_dotenvlanding)StorageFactoryconfiguracionesz.envu)✅ Variables de entorno cargadas desde: u(⚠ No se encontró el archivo .env en: page page_sizecKd}d} t}|*ddd|r|j|r|jSS|jd}|dz |z}d}|j||j d }d }|j|||f|j }t jfd tjd fd } |D cgc] } | | d} } tj| ddid{} i} | D]W}t|tr|jdr |d| |d<0t|tr|jdnd}g| |<Yg}|D]} | d| d| d| d| d| d| d| d| d| d| dr| djdndgd }| j| dg}|D]}|d j|d!|d"d#!|j|||zdz |z}dd$||||d%|r|j|r|jSScc} w7:#t $r~}t#d&t%||r$t'|d'rt#d(|j(dd)t%|gd*cYd}~|r|j|r|jSSd}~wwxYw#|r|j|r|jwwxYww)+u Obtiene las propuestas con sus archivos adjuntos de S3, paginadas. Args: page: Número de página (por defecto 1) page_size: Tamaño de página (por defecto 10) Returns: Dict con información paginada de propuestas y sus archivos NFuError de conexión)successmessageT) dictionaryz1SELECT COUNT(*) as total FROM propuesta_ciudadanototala SELECT id, nombre_completo, correo, tipo_documento, documento, telefono, ciudad, titulo, ambito, descripcion, fecha_hora FROM propuesta_ciudadano ORDER BY fecha_hora DESC LIMIT %s OFFSET %s cLK d|}tjj|ddd{}|jddr|jdr ||dd d S|gd d S76#tj$r |gdd cYSt $r}|gdd cYd}~Sd}~wwxYww) Nz propuestas/) max_filesg@)timeoutr FfilesT) propuesta_idarchivosr )asynciowait_forlist_files_with_metadataget TimeoutError Exception)r folder_patharchivos_resultestorages R/var/www/dev.api.imparables.com.co/api_imparables/crm/procesos/admin_propuestas.pyobtener_archivos_propuestazCobtener_propuestas_con_archivos..obtener_archivos_propuestacs  +L>: (/(8(844[A4N)# #&&y%8_=P=PQX=Y(4$3G$<#')5$&#'#$'' $0 "$  $0 "$ s\B$0A.A,/A.%B$&A.+B$,A..B!B$ B!BB!B$B!!B$rcK4d{|d{cdddd{S7%77 #1d{7swYyxYww)N)rr$ semaphores r#obtener_archivos_con_semaphorezGobtener_propuestas_con_archivos..obtener_archivos_con_semaphoresQ  F F7 EE F F FE F F F FsEA 0A  626 A 4A 6A A? AA idreturn_exceptionsr rrunknownnombre_completocorreotipo_documento documentotelefonociudadtituloambito descripcion fecha_horaz%Y-%m-%d %H:%M:%S) r)r,r-r.r/r0r1r2r3r4r5archivos_adjuntosr6filenames3_key)nombrer8zPropuestas encontradas)r rdata totalRecords totalPages currentPagez*Error al obtener propuestas con archivos: statementuÚltima consulta ejecutada: zError al obtener propuestas: r rr:)rclosecursorexecutefetchonefetchallr get_storager Semaphoregather isinstancedictrstrftimeappendrprintstrhasattrr>)r r conexionBDrAoffset count_query total_recordsquery propuestasr( propuestatasksarchivos_resultsarchivos_por_propuestaresultrpropuestas_con_archivospropuesta_datararchivo total_pagesr!r$r'r"s @@@r#obtener_propuestas_con_archivosr^)sJ FZ#%   /f  LLN      a""d"3(i'J {#)'2  $ uy&12__& !,,. F%%a(  F S]]Y/ $@]]!(!O$!OO"$& :F&$'FJJy,AAG AS&vn'=>=GPT=Uvzz.9[d 79&|4  :#%# ;I o#,->#?#H-"+,<"=&{3%j1#H-#H-#H-(7W`amWni 5>>?RStx%' N .11)D/2FH# 23::%j1%h/<  $ * *> :3 ;8%y014B /+)%  *  LLN      G^Oh   :3q6(CD gfk2 01A1A0BC D6s1vh?    LLN         LLN      srK<I&K<BII1I I DI&K<I KAK K K$&K< KK'K99K<r8 expirationcFK tj}|j||d{}|jddsd|jddidSdd||d ||jd d dS7I#t$r}dd t |idcYd}~Sd}~wwxYww) u Obtiene una URL firmada para un archivo específico en S3. Args: s3_key: Clave del archivo en S3 expiration: Tiempo de expiración en segundos (por defecto 1 hora) Returns: Dict con la URL firmada y metadatos del archivo Nr FrzError al generar URL firmadar?Tz!URL firmada generada exitosamente signed_url expires_at)r8ra expires_inrbzError al obtener URL firmada: )rrEget_signed_urlrrrM)r8r_r"signed_url_resultr!s r#obtener_url_firmadarfs  ,,.#*"8"8"LL $$Y6 ,00rsZ &'!ggoobggooh78 WW__[ ) 77??: &ggll8Y/  3 WW__RWW__X6 7  ''//* % 77<<!2F ;77>>(GLLxjIJhhChV) c) s) r