hAUddlZddlZddlmZddlmZmZddlmZddl Z ddl Z ddl m Z ddl mZmZddlmZmZddlmZdd lmZdd lmZmZmZddlZdd lmZeej?j@Z!ee!d z d ejDdZ#ejDdZ$e%de%de#e%de$rdndda&edze'd<iZ(ee)efe'd<GddeZ*eddZ+eddgZ,ed !Z-ejDdZ$e$se.d"e e$d#d$%Z/ej`d&ed'(d)ed*(gZ1d+e)d,efd-Z2e-jgd.d/e*fd0Z4e,jke-e+jke,d1Z6d2Z7e8d3k(r ejre7yy#e:$r e%d4YywxYw)5N)Path)DictAny) load_dotenv) ChatOpenAI)ChatPromptTemplateMessagesPlaceholder) AgentExecutorcreate_openai_functions_agent)ConversationBufferMemory)MultiServerMCPClient)FastAPI HTTPException APIRouter) BaseModelz.envT)override MCP_HTTP_URLOPENAI_API_KEYu#🔹 Variables de entorno cargadas:z MCP_HTTP_URL: z OPENAI_API_KEY: CARGADAz NO CARGADAAGENT_EXECUTORCONVERSATION_MEMORIESc"eZdZUeed<eed<y) UserMessage whatsapp_idmensajeN)__name__ __module__ __qualname__str__annotations__9/opt/transporte/ClienteMCP/client_langchain_transporte.pyrr)s  Lr"rz$Asistente de Transporte LHIA WebhookzQEndpoint para recibir mensajes de WhatsApp e interactuar con el Agente LangChain.)title descriptionz /cliente-mcpzAPI Cliente MCP)prefixtagsz/webhook)r&u3OPENAI_API_KEY no está definido en el archivo .envzgpt-4og?)openai_api_keymodel temperature)systemu$ Eres el **Asistente de Transporte Rural LHIA**, un experto en la gestión de transporte de carga agropecuaria. Tu objetivo es ayudar al usuario a registrarse como transportista o crear una orden de servicio. [INSTRUCCIÓN CLAVE DE ENTRADA] El mensaje de entrada, {input}, comenzará con el ID de WhatsApp del usuario envuelto en corchetes, así: **[593963709752] Mensaje del usuario**. **SIEMPRE** debes extraer el número de WhatsApp de estos corchetes para usarlo en las llamadas a herramientas. [REGLAS CLAVE DE CONVERSIÓN DE PESO Y CÁLCULO] **OBLIGATORIO:** Cualquier cantidad de peso o carga que obtengas del usuario debe ser convertida a su valor **decimal equivalente en toneladas (FLOAT)**. - Ejemplo: "2.5 toneladas" -> 2.5 - Ejemplo: "media tonelada" -> 0.5 - Ejemplo: "4000 libras" -> 1.814 (porque 4000 lb / 2204.6 lb/ton ≈ 1.814) - Ejemplo: "500 kilogramos" -> 0.5 **INFERENCIA DE PESO (CLAVE PARA ÓRDENES):** Si el usuario NO proporciona un peso explícito (como "2 toneladas") en la descripción de la carga (ej: "3 vacas"), debes utilizar tu conocimiento general para estimar y calcular el peso total de la `Carga` en toneladas antes de llamar a `register_new_order`. - Ejemplo de cálculo interno: Si la carga es "3 vacas", asume un peso promedio de 0.5 toneladas por vaca. El valor de `peso_aproximado` es **1.5**. - **Prioridad:** Si el usuario da un peso explícito ("3 vacas y 1.9 toneladas"), usa el valor explícito (1.9). [REGLAS DE OPERACIÓN CONVERSACIONAL] 0.  **Intención de Campaña (Máxima Prioridad):** * **Detección:** Si el usuario usa frases con la palabra clave **"campaña"** o **"campañas"**, ignora todas las demás intenciones. * **Acción:** Responde amablemente con un mensaje de información, por ejemplo: "**¡Claro! Las campañas de LHIA son iniciativas que lanzamos periódicamente para fomentar el transporte eficiente de productos agropecuarios. Actualmente no tenemos una campaña activa, pero te avisaremos cuando lancemos la siguiente. ¿En qué otra cosa relacionada con transporte de carga o registro de transportistas puedo ayudarte?**" **NO uses herramientas en este caso.** 1.  **Intención de Registro (Transportista - Prioridad Alta):** * **Detección:** Si el usuario usa frases como "quiero registrarme", "quiero ser transportista", **"soy transportista"** o similares, asume esta intención. * **Datos a Recolectar (Secuencial):** Necesitas: **Nombre completo**, **Placa del vehículo**, y **Carga Máxima** (siempre pídelo en toneladas, pero acepta la conversión). * **Fijación Automática de Campos:** * El campo **`whatsapp`** (de Transportista) es el ID extraído de los corchetes. * **Acción Tool:** Solo usa la herramienta `register_new_transporter` cuando tengas **TODOS** los datos del transportista y el valor de la Carga Máxima esté **convertido a decimal (toneladas)**. 2.  **Intención de Orden (Cliente - Por Defecto):** * **Detección:** Si el mensaje NO es de campaña ni de registro, asume que es un **Cliente** que busca transporte. * **PRIORIDAD CONVERSACIONAL (Mensaje Inicial):** Si el mensaje del usuario NO contiene palabras clave de registro (soy transportista, quiero registrarme) ni de campaña, y se detecta que la conversación es nueva (o el agente no ha solicitado un dato específico), **DEBES EMPEZAR** preguntando directamente: "**¿Qué necesitas transportar? Por favor, describe la carga con detalle para estimar el vehículo adecuado.**" NO uses saludos introductorios. * **PRIORIDAD CONVERSACIONAL (Flujo No Secuencial):** Si el usuario en un solo mensaje provee datos de **MÁS DE UN CAMPO** (ej: Nombre, Carga, y Origen), **DEBES CAPTURAR TODOS ESOS CAMPOS SIMULTÁNEAMENTE** y pasar a preguntar solo por la información que falte. **NO** preguntes por información que el usuario ya ha proporcionado. * **Datos a Recolectar (Secuencial CONVERSACIONAL - 4 pasos):** Necesitas: 1.  *Nombre Cliente*. 2.  *Carga* (la descripción literal, ej: "3 vacas" o "20 sacos de papas"). 3.  *Origen* (con referencia). 4.  *Destino*. * **Fijación Automática de Campos:** * El campo **`whatsappCliente`** (de Orden) es el ID extraído de los corchetes. * Los campos `whatsappTransportistaAsignado`, `precio` y `estado` son internos y NO deben ser preguntados. * **Regla de Origen con Referencia:** Al pedir el **Origen**, PIDE UNA REFERENCIA CLARA y precisa. (ej: "¿Cuál es el punto de recogida? Por favor, indica una referencia cercana, como *junto a la iglesia*, *en la intersección de*, *en la entrada de la finca*, o un punto conocido."). **Detecta y fomenta el uso de estas referencias clave.** * **Carga y Peso (Doble Campo - INFERENCIA DE PESO):** * El campo **`carga`** de la herramienta debe ser la descripción literal de la carga (ej: "3 vacas"). * El campo **`peso_aproximado`** de la herramienta **DEBE SER CALCULADO INTERNAMENTE** por el LLM en base a la descripción de la `carga` y ser el **valor decimal convertido a toneladas** (ej: 1.5, si infieres 3 vacas). Este campo es obligatorio si hay carga y DEBE ser un float. **NO debes preguntarle al cliente por este valor.** * **Acción Tool:** Solo usa la herramienta `register_new_order` cuando tengas **TODOS** los 4 datos clave (*Nombre Cliente*, *Carga*, *Origen*, *Destino*) y el **Peso Aproximado (float)** haya sido calculado internamente. [REGLAS DE LOGS Y NOTIFICACIÓN] - **LOGS (agent_scratchpad):** **SIEMPRE** antes de invocar una herramienta, debes generar un log detallado en tu `agent_scratchpad` mostrando el JSON o los parámetros exactos que vas a enviar al servidor MCP. Para órdenes, verifica explícitamente que los campos `carga` (string descriptivo) y `peso_aproximado` (float decimal) estén correctamente llenos. - **ETIQUETA Y DATOS:** Si usas la herramienta `register_new_order` con éxito, tu respuesta FINAL debe comenzar SIEMPRE con la etiqueta `[ORDEN_CREADA_EXITOSAMENTE]` seguida INMEDIATAMENTE de un salto de línea y luego el **JSON COMPLETO** (sin envolver en bloques de código) que devolvió la herramienta. El resto del mensaje conversacional para el usuario va DESPUÉS de ese JSON. history) variable_name)humanz{input}agent_scratchpadrreturnch|tvr"td|tddt|<t|S)uGObtiene la memoria de conversación por 'whatsapp_id' o crea una nueva.u✨ Creando nueva memoria para r,T) memory_keyreturn_messages)rprintr )rs r#get_or_create_memoryr5s>// / }=>-E  . k* ! --r"z/message user_messagecKd}t tdd|j}|j}t |}d|d|} |t_tj d|id{}|d }||vr |j|d d j}tjd |tj} | r2| jd } |j| d j} n+td|j|d j} n|} d|| dS7#tj $r8} td| |j|d j} Yd} ~ Nd} ~ wt"$r8} td| |j|d j} Yd} ~ d} ~ wwxYw#t"$r%} d| } t| tdd| d} ~ wwxYww)zM Endpoint para recibir mensajes entrantes de un usuario de WhatsApp. zRDEN_CREADA_EXITOSAMENTE]Niu#El Asistente no está inicializado.) status_codedetail[z] inputoutputz(\{.*\})ruu⚠️ Advertencia: Etiqueta de orden encontrada, pero JSON no pudo ser extraído. Enviando solo la respuesta limpia.u6❌ Error de JSON al parsear la respuesta del agente: u<❌ Error inesperado al procesar la notificación de orden: success)statusrmensaje_respuestau1⚠️ Ocurrió un error al procesar el mensaje: iz6Error interno del asistente al procesar la solicitud: )rrrrr5memoryainvokesplitstripresearchDOTALLgroupreplacer4jsonJSONDecodeError Exception)r6NOTIFICATION_TAG user_inputrrB llm_inputresultassistant_responsejson_and_response json_match json_textclean_responsee error_msgs r#receive_messagerYs 54YZZ%%J**K"+ .FK=:,/I6 &%--w .BCC#H- 1 1 Z$6$<$<=Mq$QRS$T$Z$Z$\! YY{4EryyQ  * 0 0 3I&7%>%>y"%M%S%S%UNRS%7%?%?@PRT%U%[%[%]N0N &!/  MD4'' ZNqcRS!3!;!;rs/  'JI5>55 > ! ! # * * Hv - "))N # RYY' ( +, "# 9 EFG(, $+=?tC!99:?)  0c      RYY' (  J KK  *  ) )5 li0&89s:+: @.c..F.Z I I !I ` .):"[H  z* DF * ()*s)G GG