idZddlZddlZddlZddlmZmZmZmZm Z ddl m Z m Z m Z ddlmZddlmZmZddlmZej*eZed d g Zej3d e eeg eddeddddeddfdededefdZej3de eeg defdZej=de eefd!efd"ZejAd#eeg$d'd%e!fd&Z"y)(u7 Endpoints de sincronización y gestión de productos. N) APIRouterDepends HTTPExceptionQuerystatus)SyncProductsResponseSearchProductItemNeo4jSearchResponse) sync_products)verify_api_key verify_token)parse_neo4j_productsz /productsproducts)prefixtagsz/search)response_model dependencies.uTexto de búsqueda) description 2uNúmero máximo de resultados)gelervectoru(Modo de búsqueda: 'vector' o 'fulltext'qlimitmodecKddlm}tjd|d|d|t j} |dk(r*t j |j||d{}n)t j |j||d{}tt j|z d }tjdt|d|dt|dD]\}} tjd|d| j!dd| j!dd| j!dd| j!dd| j!dd| j!ddt#|t||| S7&7#t$r5}tjd|d td t| d}~wwxYww)!u Busca productos en Neo4j directamente a partir de un texto. - mode=vector → búsqueda semántica por embeddings (default) - mode=fulltext → búsqueda por texto completo r neo4j_clientu 🔍 [search_products_neo4j] q='z' limit=z mode=fulltextNu#❌ [search_products_neo4j] Error: Texc_info status_codedetailu✅ [search_products_neo4j] z resultados en srz [z] id=idz | sku=sku_idz | nombre='namez ' | precio=pricez | marca=brandz | score=scorezN/A)querytotal elapsed_sr)rag_service.neo4j_clientr!loggerinfotimeasyncio to_threadfulltext_search_products_fullvector_search_products_full Exceptionerrorrstrroundlen enumerategetr ) rrrr!t0raweelapsedips 3/opt/lhia/marcimex/agent/app/api/routes/products.pysearch_products_neo4jrJs6 KK21#XeWF4&QR B< : )),*T*TVWY^__C)),*R*RTUW\]]C DIIK"$a(G KK.s3xjyPQRS#q! 1 1#U155;-wquuX.?@uuV}o[w0@AUU7^$IaeeGU.C-D F   Qc#h'TW XX!`] < :1#> NCF;;r?r)rKr!rCrDrErFs rIget_product_by_idrO9s 6 KK7 |1EF B<%%l&F&F SS 6G |Sb4cddDIIK"$a(G KK6zlBRSZR[[\]^  &q ))T < 6qc:T JCF;;CAD>C C> 0C99C>>Dz/sync)r_cK td{S7#t$rO}tjdt |dt t jdt |d}~wwxYww)u Sincroniza productos desde XML a Neo4j. - Si la BD está vacía: sube todos los productos con estado 'nuevo' - Si ya hay datos: sincronización incremental Nu❌ Error en sincronización: Tr#uError en sincronización: r&)r r<r5r=r>rrHTTP_500_INTERNAL_SERVER_ERROR)rPrEs rIsync_products_to_neo4jrSSsh "_$$$   5c!fX> N==/Ax8   s1A3 A3 A0A A++A00A3z/all)rconfirmcKddlm}|sttjdt j d|j |j}t j d|d|S#t$rM}t jdt|ttjd t|d }~wwxYww) ug Elimina todos los productos de Neo4j. ADVERTENCIA: operación destructiva e irreversible. rr uNDebes pasar confirm=true para confirmar la eliminación de todos los productosr&u!🗄️ Eliminando productos de: u🗑️ messageu ❌ Error eliminando productos: zError eliminando productos: N) r4r!rrHTTP_400_BAD_REQUESTr5r6get_current_databasedelete_all_productsr<r=r>rR)rTr!resultrEs rIrYrYes 6 33c   KK3L4U4U4W3XYZ  113 hvi0123   7Ax@A==1#a&:   s+A C ,A:9C: CAC  CC)F)#__doc__r8loggingr7fastapirrrrrmodelsr r r services.sync_servicer authr ragent.conversation_utilsr getLogger__name__r5routerrBr>intrJrOpostrSdeleteboolrYrIrksS DDQQ1/9   8 $ +ZL 9I&9Q]I^H_` 3$8 9raB4STh,VW!Y !Y !Y !Ya!YHO,=WUaMbLcd**e*2W%9:*1.*A C ; "vW\%:$;< t = rj