i*dZddlZddlZddlZddlZddlmZmZm Z m Z ddl m Z mZddl mZm Z ddlmZddlmZmZdd lmZdd lmZdd lmZdd lmZdd lmZmZm Z m!Z!m"Z"ddl#m$Z$ejJe&Z'eddgZ(dZ)ee$jTdZ+eZ,eZ-ee,Z.defdZ/defdZ0de1de2de3fdZ4e(jkdee jldefdZ7e(jkdee jlee/ee0fded ed!efd"Z8e(jkd#ee jlee/ee0fded ed!efd$Z9y)%u Endpoint de chat con búsqueda de productos via API externa (/chat/search). Flujo: - Solo saludo (sin producto) → Saludo cordial + pregunta qué producto busca - Saludo + producto (ej: "hola, busco cocina") → Saludo breve + búsqueda inmediata - Mensaje con producto (con historial) → Búsqueda directa sin saludo Tools integrados en /searchLhia: - get_payment_options: Opciones de pago via MCP - consultar_deuda_actual: Consulta de saldo (multi-paso: cédula → fecha → MCP) - redirect_to_agent: Redirección a agente humano (multi-paso: cédula → tipo_pago → MCP) - search_product_detail: Detalle de un producto específico via MCP N) APIRouterDepends HTTPExceptionstatus) HumanMessage AIMessage) SystemMessager) ChatOpenAI)SearchChatRequestSearchChatResponse)session_manager)IdentityService)ProductService) FlowService)SEARCH_GREETINGSEARCH_EXTRACT_QUERY_PROMPTSEARCH_RESPONSE_PROMPTSEARCH_NO_RESULTS_PROMPTMARCI_BASE_IDENTITY)settingsz/chatz chat-search)prefixtags)model temperature)identity_servicereturnctSN) _flow_svcy/home/jorge/Escritorio/TWS/DESARRROLLO TWS/PROYECTOS/0_PRO_MARCI/LHIA/python/lhiav3-marci-agent/api/routes/chat_search.pyget_flow_servicer%5s r#ctSr ) _product_svcr"r#r$get_product_servicer(9s r#querycountc@Ktj}||d}tjd4d{}|j ||d{}|j |j cdddd{S7P777 #1d{7swYyxYww)u1Llama a la API externa de búsqueda de productos.)qr*g>@)timeoutN)params)rPRODUCTS_SEARCH_API_URLhttpx AsyncClientgetraise_for_statusjson)r)r*urlr.clientresponses r$_search_products_apir8?s  * *C5 )F  .&C77!!#}}7sV0BBBB  B#B 1 B=B>BB B BB BBz/search)response_model status_coderequestcKtj}|j}|jxsdj}|j}t j d|dt j d|d|d| tj|d{}|jjdg}t|d k(}t j d |d t|d |d |s|rxt}|jtd|jt|||jd<tj ||d{t#||d gSt%t&j(dt j d|dt+t,g} |r| j/|dd| jt1|t2j5| } | j6j} t j d|d| d| j9dk(r|r t}t j d|dnd}t j d|d|jt||jt|t|t:kDr |t: d}||jd<tj ||d{t#||d gSt j d|d | d| t=| |d{} | jd&g}| jd'd }t j d(|d)t|d*||rd+}d}nd}d,}|rd-jM|Dcgc]P}d.|jd/d0d1|jd2xs|jd3d4d5|jd6d4Rc}}tOjPtR||| ||7}ntUjPtR||| 8}t+|g}t|d9kDr|d:dn|}|j/||jt1|t2j5|}|j6}d;|vr;|jWd;d j}t jYd<|d=t j d>|d?|dd@dAtZj]|}|}|rLdB}|D]@}|d.|j^dC|j`dD|jbdE|jdxsd4d- z }B||z }|jt||jt|t|t:kDr |t: d}||jd<tj ||d{tj|z }t j dF|dGt|dH|dIdJt#||t||S777V7#t>j@$rf} t jCd!|d"| jDjFt%t&jHd#| jDjFd} ~ wt>jJ$r;} t jCd!|d$| t%t&jHd%d} ~ wwxYwcc}w76#t$$rtf$rP} t jCd!|dKti| t%t&jjdLti| d} ~ wwxYww)MuQ Búsqueda conversacional de productos via API externa. Flujo inteligente: - Solo saludo (sin producto) → Saludo cordial + pregunta qué producto busca - Saludo + producto (ej: "hola, busco cocina") → Saludo breve + búsqueda inmediata - Mensaje con producto (con historial) → Búsqueda directa sin saludo 🔍 [z] === INICIO chat_search ===📥 [] Request: question=' ', count=Nmessagesr📜 [] Historial cargado:  mensajes (primera_vez=)iniciocontent)uuid_conversationanswertotalproducts+El texto de búsqueda no puede estar vacíor:detail🤖 [$] Extrayendo término de producto...i🔄 [] Query extraído: '' NO_PRODUCT👋 [6] Primera interacción sin producto, retornando saludou_¿Qué producto te gustaría buscar? Puedes decirme el nombre o tipo de producto que necesitas.❓ [u-] No se detectó producto, pidiendo más info🌐 [z] Buscando en API externa: q='❌ [u] API externa retornó error: u+Error en la API de búsqueda de productos: z"] Error conectando a API externa: u8No se pudo conectar con la API de búsqueda de productosrM totalFound📦 [u] API retornó:  productos, totalFound=uEs la PRIMERA interacción. Saluda brevemente (ej: '¡Hola!') y luego presenta los productos. No hagas una presentación larga.u`IMPORTANTE: Ya hay conversación previa. NO saludes ni digas 'Hola'. Ve directo a los productos. z- namez Sin nombrez | Precio: $ spotPricepricezN/Az | Marca: brand)marci_identity greeting_hint history_hintr)rLproducts_context)rdrerfr) iz[CONTEXTO DEL SISTEMA⚠️ [uB] Se eliminó texto '[CONTEXTO DEL SISTEMA...]' copiado por el LLM📝 [] Respuesta LLM generada: 'd...'z; [CONTEXTO DEL SISTEMA - PRODUCTOS MOSTRADOS AL USUARIO]: z (ID: z ) - Precio: $u - Categoría: 🏁 [z] === FIN chat_search:  productos. Tiempo: .2fs ===z] Error en chat_search: Error procesando búsqueda: )6timerJquestionstripr*loggerinfor get_sessionstater2lenrappendLCHumanMessage LCAIMessage save_sessionr rrHTTP_400_BAD_REQUESTr rextendrllminvokerIupperMAX_TOTAL_HISTORYr8r0HTTPStatusErrorerrorr7r:HTTP_502_BAD_GATEWAY RequestErrorjoinrformatrrsplitwarningr'parse_productsr` productIdrbcategory ExceptionstrHTTP_500_INTERNAL_SERVER_ERROR)r; start_timerJrtr*sessionhistory_messagesis_first_interactionrKextract_messagesextract_responseextracted_query api_resulte raw_products total_foundrerfprg system_prompt llm_messagesrecent_historyr7rMhistory_contentproduct_detailselapseds r$ chat_searchrMsJ11  &B--/H MME KK&*++GHI KK&*++@ )TYSZ[\Y '334EFF"==,,Z<"#349 f.//DSIYEZD[[rtHsIIJK L#( ''x(HI '' F(CD,< j)%223DgNNN)&7aZ\ "77D   f.//STU)2MNO   # #$4RS$9 : X >?::&67*2288: f.//COCTTUVW  "l 2#( f%6$77mnoz e$5#66cde  # #N8$D E  # #K$? @#$'88#35F4F4G#H (8GMM* %!../@'J J J%"3F!VX   f.//MoM^^ghmgnop 3OUKKJ"~~j"5  nn\15  f.//?L@Q?RRijuivwx ^MLM}L #yy%*QUU6<01aeeK>P>iTUTYTYZachTi=jjtuvuzuz|CEJvKuLM*  3992+)%!!1 M5;;2+)% M&m<= 367G3H23M)#$/ScN+L:;::l+!! "f ,\\"9:1=CCEF NNX&7%88z{ | f.//J6RVSV<.X\]^ ..|<! ^O @Rxvakk]-PQPWPWyXghihrhrh{v{g||~# @  .Ox @A O DE  #4 4/1B0B0CD $4 j!**+\'Y\'/^ 0F \';Y<\'^ \'.Y=Y>YA'\')A\>G0\'.\$/A\' ^  \'\'\'Y\*A![  \!6\\ \''^ 9A ^^  ^ z /searchLhiaflow_svc product_svcc pKtj}|j}|jxsdj}|j}d|}d|}t j d|dt j d|d|d| tjj|d {} | rhtj| } |j|| |d {} | r6tj|z } t j d |d | d d | Stjj|d {} | rhtj| }|j|||d {}|r6tj|z } t j d |d| d d |Stj|d {}|jjdg}t!|dk(}t j d|dt!|d|d|s|ryt"}|j%t'd|j%t)|||jd<tj*||d {t-||ddgSt/t0j2dt j d|d|j5||}t j d|d||dk(rjt j d |d!|j7|||d {}tj|z } t j d |d"| d d |S|d#k(rt j d$|d%|j8j;tj|d {}|j=|||||d {}tj|z } t j d |d&| d d |S|d'k(rt j d(|d)|j8j;tj|d {}|j?|||||d {}tj|z } t j d |d*| d d |S|dk(rt"}t j d+|d,|j%t'||j%t)|t!|t@kDr |t@ d }||jd<tj*||d {tj|z } t j d |d-| d d t-||ddgS|d.k(rt j d|d/|jC||\}}|rt j d0|d1|d2|d|jE||d {}|set jGd3|d4|jI|d5d {}|jd6g}|r|d}t j d|d7|r |jK|g}|r|dnd }|jM|||}|jO||d89}|j%t'||j%t)|t!|t@kDr |t@ d }||jd<tj*||d {tj|z } t j d |d:| d d t-||d.|rd5nd|St jGd3|d;|d<nt jGd3|d=t j d>|d?|jQ||} t j d@|dA| dB| jSdCk(r|r t"}t j d+|dDn+t j dE|dF|jU||}|j%t'||j%t)|t!|t@kDr |t@ d }||jd<tj*||d {t-|||dgSt j dG|dH| d||jI| |d {}!|!jd6g}"|!jdId}#t j d0|dJt!|"dK|#|jW|| |"|#||}t j dL|dM|d dNdO|jK|"}|jO||}|j%t'||j%t)|t!|t@kDr |t@ d }||jd<tj*||d {tj|z } t j d |dPt!|dQ| d d t-||dRt!||S7 7 7 `7 177#7|777\7B7l777777#t.$rtX$rP}$t j[dS|dTt]|$t/t0j^dUt]|$d }$~$wwxYww)Vu  Búsqueda conversacional de productos via MCP Tool (search_products). Soporta clasificación de intención con tools integrados: - PRODUCT → Búsqueda de productos via MCP (search_products) - PAYMENT → Opciones de pago via MCP (get_payment_options) - BALANCE → Consulta de saldo multi-paso via MCP (consultar_deuda_actual) - AGENT → Redirección a agente humano multi-paso via MCP (redirect_to_agent) - GREETING → Saludo + pregunta qué busca - OTHER → Respuesta genérica r=search_redirect_ctx:search_balance_ctx:r>z'] === INICIO chat_search_lhia (MCP) ===r?r@rANrn!] === FIN redirect flow. Tiempo: rprq ] === FIN balance flow. Tiempo: rBrrCrDrErFrGrHGREETINGrJrKintentrLrMrNrO 🏷️ [(] Clasificando intención del usuario...✅ [] Intención clasificada: PAYMENT💳 [] Redirigiendo a flujo de pago ] === FIN payment flow. Tiempo: BALANCE💰 [&] Iniciando flujo de consulta de saldo ] === FIN balance init. Tiempo: AGENT🚨 [*] Iniciando flujo de redirección a agente'] === FIN agent redirect init. Tiempo: rW] Saludo detectado] === FIN greeting. Tiempo: PRODUCT_DETAIL/] Solicitando detalle de producto del historialr]] Producto identificado: '' (ID: riB] MCP detail no retornó datos, intentando búsqueda por nombre...rM,] Producto encontrado via búsqueda fallbackT is_detail"] === FIN product detail. Tiempo: #] No se pudo obtener detalle para ''. Continuando con búsqueda.I] No se pudo identificar producto del historial, redirigiendo a búsquedarQrRrSrTrUrVrXrY9] No se detectó producto, generando respuesta contextualrZ] Buscando via MCP: q='r\] MCP retornó: r^rjrkrlrmz] === FIN chat_search_lhia: roPRODUCTr[z] Error en chat_search_lhia: rr0rsrJrtrur*rvrwrr6r2json_modloadshandle_redirect_flowhandle_balance_flowrxryrzrr{r|r}r~r rrrclassify_intenthandle_paymentidentity load_identityinit_balance_flowinit_redirect_flowr!extract_product_name_from_historyget_product_detail_mcprsearch_products_mcprgenerate_detail_responsebuild_history_contentextract_product_queryrgenerate_no_product_responsegenerate_search_responserrrr%r;rrrrJrtr*REDIRECT_CTX_KEYBALANCE_CTX_KEYredirect_ctx_raw redirect_ctxredirect_responserbalance_ctx_raw balance_ctxbalance_responserrrrKrpayment_responseexisting_identityagent_response product_name product_id detail_data search_resultsearch_products_listrMproductrrrrrrs% r$chat_search_lhiars "J11  &B--/H MME-.?-@A+,=+>?O KK&*++RST KK&*++@ )TYSZ[\V !0!7!7!;!;>*:;L&.&C&CDUWcem&n n  ))+ 2 f%6$77XY`adXeejkl((!0 6 6 : :? KK "..9K%-%A%ABSU`bj%kk ))+ 2 f%6$77WX_`cWddijk''(334EFF"==,,Z<"#349 f.//DSIYEZD[[rtHsIIJK L#( ''x(HI '' F(CD,< j)%223DgNNN)&7!%  "77D   i 122Z[\,,X7GH e-..HQR Y  KK&!2 33QR S%-%<%<=NPXZj%kk iikJ.G KK&!2 33ST[\_S``ef g# # Y  KK&!2 33YZ [&.&7&7&E&EoF\F\^o&p p %-%?%?!8-=wHY&  iikJ.G KK&!2 33ST[\_S``ef g# # W  KK&!2 33]^ _&.&7&7&E&EoF\F\^o&p p #+#>#>!8-=wHY$NiikJ.G KK&!2 33Z[bcfZgglm n! ! Z $F KK&!2 33EF G  # #N8$D E  # #K$? @#$'88#35F4F4G#H (8GMM* %!../@'J J JiikJ.G KK&!2 33OPWX[}\ab c%"3!   % % KK&!2 33bc d'2'T'TU]_o'p $L* f%6$77QR^Q__fgqfrrstu$/$F$F|U_$`` "NNX.?-@AC$DE*5*I*I,XY*Z$ZM+8+<+>j$kl*99;-HH-5hqk4G(AA(GU`aF&1&G&GPXdh&G&iO$++N8,LM$++K,PQ+,/@@+;=Nkj+ kl6Bk2j.39k,l6-A k8j19kj49kl6A kj7k8j:99k2l63Bkj=Akl6A+kk4k:k;C5k0k1A k<l6=Ekk k(l6)3kk D!k>k?Akl6kk"k%k(k+k.k1k4k7k:k=kkkk k kkl3#A l..l33l6z/searchProductsLhiac pKtj}|j}|jxsdj}|j}d|}d|}t j d|dt j d|d|d| tjj|d {} | rhtj| } |j|| |d {} | r6tj|z } t j d |d | d d | Stjj|d {} | rhtj| }|j|||d {}|r6tj|z } t j d |d| d d |Stj|d {}|jjdg}t!|dk(}t j d|dt!|d|d|s|ryt"}|j%t'd|j%t)|||jd<tj*||d {t-||ddgSt/t0j2dt j d|d|j5||}t j d|d||dk(rjt j d |d!|j7|||d {}tj|z } t j d |d"| d d |S|d#k(rt j d$|d%|j8j;tj|d {}|j=|||||d {}tj|z } t j d |d&| d d |S|d'k(rt j d(|d)|j8j;tj|d {}|j?|||||d {}tj|z } t j d |d*| d d |S|dk(rt"}t j d+|d,|j%t'||j%t)|t!|t@kDr |t@ d }||jd<tj*||d {tj|z } t j d |d-| d d t-||ddgS|d.k(rt j d|d/|jC||\}}|rt j d0|d1|d2|d|jE||d {}|set jGd3|d4|jI|d5d {}|jd6g}|r|d}t j d|d7|r |jK|g}|r|dnd }|jM|||}|jO||d89}|j%t'||j%t)|t!|t@kDr |t@ d }||jd<tj*||d {tj|z } t j d |d:| d d t-||d.|rd5nd|St jGd3|d;|d<nt jGd3|d=t j d>|d?|jQ||} t j d@|dA| dB| jSdCk(r|r t"}t j d+|dDn+t j dE|dF|jU||}|j%t'||j%t)|t!|t@kDr |t@ d }||jd<tj*||d {t-|||dgSt j dG|dH| d||jI| |d {}!|!jd6g}"|!jdId}#t j d0|dJt!|"dK|#|jW|| |"|#||}t j dL|dM|d dNdO|jK|"}|jO||}|j%t'||j%t)|t!|t@kDr |t@ d }||jd<tj*||d {tj|z } t j d |dPt!|dQ| d d t-||dRt!||S7 7 7 `7 177#7|777\7B7l777777#t.$rtX$rP}$t j[dS|dTt]|$t/t0j^dUt]|$d }$~$wwxYww)Vu Copia personalizable de searchLhia para experimentación. Misma lógica que /chat/searchProductsLhia — edita este endpoint sin afectar el original. r=rrr>z+] === INICIO chat_search_lhia_dev (MCP) ===r?r@rANrnrrprqrrBrrCrDrErFrGrHrrrNrOrrrrrrrrrrrrrrrrrWrrrrr]rrrirrrMrTrrrrrrQrRrSrTrUrVrXrYrrZrr\rr^rjrkrlrmz ] === FIN chat_search_lhia_dev: rorr[z!] Error en chat_search_lhia_dev: rrrrs% r$chat_search_products_lhiars J11  &B--/H MME-.?-@A+,=+>?O KK&*++VWX KK&*++@ )TYSZ[\V !0!7!7!;!;>*:;L&.&C&CDUWcem&n n  ))+ 2 f%6$77XY`adXeejkl((!0 6 6 : :? KK "..9K%-%A%ABSU`bj%kk ))+ 2 f%6$77WX_`cWddijk''(334EFF"==,,Z<"#349 f.//DSIYEZD[[rtHsIIJK L#( ''x(HI '' F(CD,< j)%223DgNNN)&7!%  "77D   i 122Z[\,,X7GH e-..HQR Y  KK&!2 33QR S%-%<%<=NPXZj%kk iikJ.G KK&!2 33ST[\_S``ef g# # Y  KK&!2 33YZ [&.&7&7&E&EoF\F\^o&p p %-%?%?!8-=wHY&  iikJ.G KK&!2 33ST[\_S``ef g# # W  KK&!2 33]^ _&.&7&7&E&EoF\F\^o&p p #+#>#>!8-=wHY$NiikJ.G KK&!2 33Z[bcfZgglm n! ! Z $F KK&!2 33EF G  # #N8$D E  # #K$? @#$'88#35F4F4G#H (8GMM* %!../@'J J JiikJ.G KK&!2 33OPWX[}\ab c%"3!   % % KK&!2 33bc d'2'T'TU]_o'p $L* f%6$77QR^Q__fgqfrrstu$/$F$F|U_$`` "NNX.?-@AC$DE*5*I*I,XY*Z$ZM+8+<+>j$kl*99;-HH-5hqk4G(AA(GU`aF&1&G&GPXdh&G&iO$++N8,LM$++K,PQ+,/@@+;=Nrs  ==\?':-75/%   8 $ ' 8x**: !   7 +^ c#$Y'9vGYGYZj 0j [j b]+=6K]K]^$$45")*=">q q q  q _q p "3ESYSeSef$$45")*=">k k k  k gk r#