kki>2UddlZddlmZddlmZmZddlmZddlZddl Z ddl m Z ddl m Z mZddlmZmZddlmZdd lmZdd lmZmZmZddlZdd lmZeej=j>Z ee d z d ejBdZ"ejBdZ#da$edze%d<iZ&ee'efe%d<dZ(GddeZ)eddZ*eZ+ejBdZ#e#se,de-de e#ddZ.e j^ded d!ed" gZ0d#e'd$efd%Z1e+jed&d'e)fd(Z3e*jid)d*Z5d+Z6e*joe+e8d,k(rejre*d-d./yy)0N)Path)DictAny) load_dotenv) ChatOpenAI)ChatPromptTemplateMessagesPlaceholder) AgentExecutorcreate_openai_functions_agent)ConversationBufferMemory)MultiServerMCPClient)FastAPI HTTPException APIRouter) BaseModelz.envT)override MCP_HTTP_URLOPENAI_API_KEYAGENT_EXECUTORCONVERSATION_MEMORIESzRDEN_CREADA_EXITOSAMENTE]c"eZdZUeed<eed<y) UserMessage whatsapp_idmensajeN)__name__ __module__ __qualname__str__annotations__*/opt/movilizia/ClienteMCP/mcp-movilizia.pyrr"s  Lr!rz CLIENTE MCPz/mcp-movilizia)title root_pathu>❌ ERROR: OPENAI_API_KEY no está definido en el archivo .envu3OPENAI_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, eliminar su registro si ya no desea trabajar, o crear una orden de servicio para clientes. [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 - Ejemplo: "500 kilogramos" -> 0.5 *INFERENCIA DE PESO (CLAVE PARA ÓRDENES):* Si el usuario NO proporciona un peso explícito, debes estimar el peso total en toneladas según la descripción. - Ejemplo: "3 vacas" -> 0.5 ton/vaca * 3 = 1.5 ton. - *Prioridad:* Si el usuario da un peso explícito, usa el valor proporcionado. [REGLAS DE OPERACIÓN CONVERSACIONAL] 0. *Intención de Campaña (Máxima Prioridad):* * *Detección:* Si el usuario usa palabras como *"campaña"* o *"campañas"*, ignora otras intenciones. * *Acción:* Responde con: "*¡Claro! Las campañas de LHIA son iniciativas que lanzamos periódicamente para fomentar el transporte eficiente de productos agropecuarios. Actualmente no hay una activa, pero te avisaremos cuando lancemos la siguiente. ¿En qué otra cosa relacionada con transporte o registro de transportistas puedo ayudarte?*" *NO uses herramientas.* 1. *Intención de Registro (Transportista - Prioridad Alta):* * *Detección:* Si el usuario dice frases como: - "quiero registrarme" - "quiero ser transportista" - "soy transportista" - "quiero trabajar como transportista" Entonces asume intención de **registro**. * *Flujo de Lógica (con verificación previa):* 1. **Primero**, usa la herramienta `find_transporter_by_whatsapp` con el número extraído. 2. **Si ya existe un transportista**, responde amablemente: > "Ya estás registrado como transportista. No es necesario volver a hacerlo. En cuanto tengamos nuevas órdenes disponibles, te las enviaremos directamente." *NO continues pidiendo datos ni registres de nuevo.* 3. **Si NO existe el transportista**, continúa el flujo normal de registro: - Pide su *Nombre completo*. - Luego la *Placa del vehículo*. - Luego la *Carga Máxima* (en toneladas, pero acepta conversiones). 4. Cuando tengas todos los datos, usa `register_new_transporter`. - Respuesta final al usuario: > "Bienvenido a bordo, tu registro fue exitoso. En cuanto tengamos órdenes de transporte que coincidan con tus capacidades, te las enviaremos directamente." 1.1 *Intención de Baja (Eliminación de Registro):* * *Detección:* Si el usuario dice frases como: - "ya no quiero ser transportista" - "ya no quiero trabajar" - "ya no quiero brindar mis servicios" - "ya no quiero recibir órdenes" Entonces asume intención de **eliminar su registro**. * *Flujo de Lógica (Eliminación):* 1. Usa `find_transporter_by_whatsapp` para verificar si existe. 2. **Si existe**, usa la herramienta `delete_transporter_by_whatsapp`. - Luego responde con: > "Tu registro ha sido eliminado correctamente. Esperamos volver a trabajar contigo en el futuro." 3. **Si NO existe**, responde: > "Aún no estás registrado como transportista. Si deseas registrarte más adelante, puedo ayudarte con eso." 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. * *Flujo Conversacional:* - Si es el primer mensaje, pregunta directamente: > "¿Qué necesitas transportar? Por favor, describe la carga con detalle para estimar el vehículo adecuado." - Recolecta de forma secuencial: 1. Nombre del cliente. 2. Descripción de la carga. 3. Origen (con referencia precisa). 4. Destino. - No repitas preguntas si el usuario ya ha dado la información. - Calcula internamente el `peso_aproximado` en toneladas. - Cuando tengas todos los datos, usa `register_new_order`. - Mensaje final: > "Tu solicitud de transporte ha sido registrada exitosamente. Pronto un transportista se pondrá en contacto contigo." [REGLAS DE LOGS Y NOTIFICACIÓN] - *Antes de llamar a cualquier herramienta*, genera un log en el `agent_scratchpad` mostrando los parámetros exactos. - Para registros o eliminaciones, incluye el número de WhatsApp en el log. - Para órdenes, asegúrate de incluir `carga` y `peso_aproximado` correctamente. - En la respuesta final al usuario, **nunca muestres JSON ni etiquetas internas**. [RESUMEN DE TOOLS DISPONIBLES] - `find_transporter_by_whatsapp(whatsapp: str)` → Busca transportista por WhatsApp. - `delete_transporter_by_whatsapp(whatsapp: str)` → Elimina transportista por WhatsApp. - `register_new_transporter(transportista, vehiculo)` → Registra nuevo transportista. - `register_new_order(orden)` → Crea nueva orden de transporte. 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_memoryr2s>// / }=>-E  . k* ! --r!z/message user_messagecHKt tdd|j}|j}t dt d|d|t |}d|d |} |t_t d |tjd |id{}|d }t d |jdddt|vr |jtddj}tjd|tj}|rz|jd} |j| dj} t!j"| } | j%d| j%dd} t d|d| n/t d|jtdj} n|} t d|d| dddd|| d S7H#t j&$r<} t d| |jtdj} Yd} ~ hd} ~ wt($r<} t d| |jtdj} Yd} ~ d} ~ wwxYw#t($r%} d!| }t |td"d#| d} ~ wwxYww)$ul Endpoint para recibir mensajes entrantes de un usuario de WhatsApp. (Implementación con Logs) Niu#El Asistente no está inicializado.) status_codedetailu 🟡 LOG | Mensaje entranteu👤 Usuario (z) dijo: [z] u$🤖 Invocando al agente LHIA para: inputoutputu$🤖 LOG | Respuesta cruda del LLM: d...z(\{.*\})rid_ordenidzN/Au3🔔 NOTIFICACIÓN: Orden creada exitosamente para z. ID: uu⚠️ 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: u%✅ LOG | Enviando respuesta final a z . Contenido: 2success)statusrmensaje_respuestau=❌ ERROR INTERNO: Ocurrió un error al procesar el mensaje: iz6Error interno del asistente al procesar la solicitud: )rrrrr1r2memoryainvokestripNOTIFICATION_TAGsplitresearchDOTALLgroupreplacejsonloadsgetJSONDecodeError Exception)r3 user_inputrrD llm_inputresultassistant_responsejson_and_response json_match json_textclean_response order_dataorder_ide error_msgs r"receive_messager_s4YZZ%%J**K )+ N;-x | <="+ .FK=:,/IA & 4YK@A%--w .BCC#H- 45G5M5M5OPTQT5U4VVYZ[ 1 1 Z$6$<$<=Mq$QRS$T$Z$Z$\! YY{4EryyQ  * 0 0 3I%6%>%>y"%M%S%S%UN"&I!6J)~~j*..u:UVHOP[}\bckblmn RS%7%?%?@PRT%U%[%[%]N0N 5k]-P^_b`bPcOddghi&!/  _D@'' ZNqcRS!3!;!; XY sJC'B,B%B, B' B,)rs  'JI5>55 > ! ! # * * Hv - "))N # RYY' ( (, $+=?tC!99:?0) M-=>  RYY' (  JK J KK  *  ) )[ xi0&89`+` N.c..F.ZW W W |i "NH6 zGKK.r!