hfFnddlZddlZddlmZmZmZddlmZddlm Z ddl Z ddl Z ddl m Z ddlmZee jdZe eZed efd Zed Zed ed efdZed ed efdZed ed efdZededefdZededefdZededefdZedefdZeddeegZeddeegZ edd eegZ!ed!d"eegZ"ed#d$e!e"ee geeg%Z#dS)&N)AgentRunner function_tool) SQLDatabase)OpenAI) b64encode) load_dotenvOPENAI_API_KEY)api_keye_mailc pd}d|i}ddddddd d d }tj||| }t|S) Nz,https://api.sistemaml.net/app/password/emailemailno-cachePostmanRuntime/7.43.4*/*gzip, deflate, br keep-aliveuser_compratelia 1nt3l14p1$!application/x-www-form-urlencoded) Cache-Control User-AgentAcceptAccept-Encoding Connectionrpassword Content-Typedataheaders)requestspoststr)r urlpayloadr responses /var/www/FlaskApp/agent_test1.pyreset_passwordr(.s_ 8C G $-."":  G}Sw@@@H x==cdS)Nz2Please wait while your request its been processingr+r)r' wait_messager,Gs ? ?r) Access_tokenuser_idc \d|}d|dddddd}t|t|tj|| }|}g}|d gD]l}||d d |d d |dd |dd dmdt |dt ||d}tt |t |S)Nz,https://api.sistemaml.net/app/preAlert/list/Bearer rrrrr Authorizationrrrrrr rtracking descriptionprice instructions)r4r6r7r8Tz prealertas encontrados.)successmessagetotalr)printr!getjsonappendlenr#) r-r.r$r r& response_data prealertsitemoutputs r'prealertlist_processrEKsX C B BC.|--)* G 'NNN ,|C000HMMOOMI!!&"--  R0088M266XXgr** HH^R88       )nn>>>Y F  #f++ v;;r)cd|}d|dddddd}tj|| }|}g}d }|d gD]w}|d gD]^} | d d| dd| dd d} || |dz }_x||d} t t | t | S)Nz'https://api.sistemaml.net/app/shs/list/r0rrrrrr1r3rrshsubs contenidor5tipolibras)rHrIrJ) total_shsubspackages)r!r=r>r?r<r#) r-r.r$r r&rresultrLpackageshsubentryrDs r'shsList_processrRus> =G = =C.|--)* G|C000H ==??DFL88FB''  [[2..  E"YY{B77 &"--))Ha00E MM% A LL %F #f++ v;;r)c d|}d|dddddd}tj|| }t|j|}g}d }|d gD]}|d d } |dd } |dd } |dgD]a} | | | | dd | dd | dd d} || |dz }b||d}tt |t |S)Nz'https://api.sistemaml.net/app/wrs/list/r0rrrrrr1r3rrr4r5id verificadowrsubsrHrIrJ)r4 wr_numberrUrHrIrJrK) total_wrsubsrM)r!r=r<textr>r?r#)r-r.r$r r&rrNrXrOr4WRrUwrsubrQrDs r'wrsList_processr\s =G = =C.|--)* G|C000H (- ==??DFL88FB'';;z2.. ;;tB  ;;|B// [[2..  E$'"YY{B77 &"--))Ha00 E MM% A LL %F  #f++ v;;r)usrEmailusrPasscd}dd||d}ddi}tj|||}t|j |}|drd |vr|d d }|d d d }|d d d} |d d d} ||| | |dddSd|ddiS#t $r} ddt| icYd} ~ Sd} ~ wwxYw)Nz#https://api.sistemaml.net/app/loginrr)rr app_username app_passwordrrrr9r access_tokenuserrTagentidRnamer:zLogin success.)rbr.agent_id client_namer:errorzAuthentication failed.zFailed to parse response: )r!r"r<rYr>r= Exceptionr#) r]r^r$r%r r&rtokenr.rgrfes r'get_credentialsrms /C$   G ;G }Sw@@@H (- }} 88I   6T>>L$$^44E6l6*..t44GF|G,0077Hff%))&11D!&"$"88I/?@@  )-EFF     :#a&&::        s$CDD E#D<6E<Elatitude longitudecptjd|d|d}|}|dS)zNReturns the weather including temperature and wind speed for a given location.0https://api.open-meteo.com/v1/forecast?latitude= &longitude=z&¤t=temperature_2m,wind_speed_10mcurrentr!r=r>rnror&rs r' get_weatherrv sW| B8 B BPY B B BH ==??D  ?r)ctjd|d|d}|}d|ddiS)z1Returns only the wind speed for a given location.rqrrz¤t=wind_speed_10m wind_speedrswind_speed_10mrtrus r' get_windspeedrzsP|r8rrPYrrrH ==??D $y/*:; <1>>? ? ? ? ? ? ? @ 8 99s#C:: DD DD wrs_agenta5 You are responsible for processing warehouse receive services or "wrs", these are the information of the packages received in the warehouse that belong to the customer. Use the tool call `wrsList_process` to get the list of packages that the customer have in warehouse. The information need it to process the request is the "access_token": token and "user_id": user_id that were obtain in the respond of the get_credentials tool. Always request new "access_token" using the tool "get_credentials" before use "wrsList_process". )rfr8tools shs_agentaJ You are responsible for processing shipment services or "shs", these are the information of the packages that have been sent from the warehouse to the customer. Use the tool call `shsList_process` to get the list of packages that have been sent to the customer from the warehouse already. The information need it to process the request is the "access_token": token and "user_id": user_id that were obtain in the respond of the get_credentials tool Always request new "access_token" using the tool "get_credentials" before use "shsList_process" prealert_agentaJ You are responsible for processing prealert services. these are the information of the packages that are ready to be sent from the warehouse to the customer. Use the tool call `prealertlist_process` to get the list of packages that are ready to be sent to the customer from the warehouse. The information need it to process the request is the "access_token": token and "user_id": user_id that were obtain in the respond of the get_credentials tool Always request new "access_token" using the tool "get_credentials" before use "prealertlist_process" Weather_AgentzYou are a helpful agent to provide temperature and windspeed for any place in the world, using coordinates, find the coordinate of the location in the internet.z Triage agenta General Behavior Always maintain a polite, professional, and friendly tone when speaking with customers. Begin each interaction with a greeting and offer assistance. Never proceed with any service or action until the customer has been authenticated. --- 2. Authentication Flow Before taking any action, validate the customer using the following steps: **a. Request Credentials** Ask the customer to provide their username and password. Use the tool called `get_credentials` to validate the credentials once they are received. Example: "Before we proceed, could you please provide your username and password so I can verify your account?" **b. Use get_credentials Tool** Send the username and password to the `get_credentials` tool. Wait for the response. **c. Handle Response** - If the response indicates **valid credentials**: - Politely confirm to the customer that their credentials are valid. - Address the customer by their name going forward. - Save the `id` and `name` values returned in the JSON response for future reference in the session. Example: "Thank you, [Customer Name]. Your credentials are valid. How can I assist you today?" - If the response indicates **invalid credentials**: - Politely inform the customer and ask them to try again. Example: "It looks like the credentials you provided are not correct. Could you please try again?" - After **three failed attempts**, offer the customer the option to create a temporary password using their email. Example: "It seems you've entered invalid credentials multiple times. Would you like to reset your password and receive a temporary one via email?" - If the customer agrees: - Ask for their email address. - Use the `reset_password` tool with the provided email. - Inform the customer: "A temporary password has been sent to your email. Please check your inbox and provide the new credentials here so I can verify your account." --- 3. After Authentication Only after the customer has been successfully authenticated: - Extract from the JSON the `name` and `id` of the customer and save those values. - Proceed with handling their request or routing to a specialized agent. - Use their name in a respectful and personalized manner throughout the conversation. - Retain the authenticated `id` and `name` in memory during the session for logging and reference. --- 4. Routing to Specialized Agents - If the customer wants to know the list of packages they have already prealerted or uses phrases like "prealerta" or "obtener una lista de paquetes en prealerta", route the customer to the `prealert_agent`. - If the customer wants to know if they have packages currently in the warehouse, route them to the `wrs_agent`. Always ensure that the "verificado" value is included in the response for each package. Present the information as follows: - Tracking - WR_number - Weight (or "peso") - Content (or "contenido") - Verificado: include the value of the "verificado" variable: - If "verificado" is 0: "Customer needs to provide the invoice of the package." - If "verificado" is 1: "Waiting for customer to request shipment." - If the customer wants to know about packages that have already been sent from the warehouse, route them to the `shs_agent`. - Reroute all relevant request information to the last agent. )rfr8handoffsr)$asyncior!agentsrrrlangchain_community.utilitiesropenairosrbase64rdotenvr getenvr rr#r(r,intrErRr\rmfloatrvrzrrrr Weather_agent triage_agentr+r)r'rs///////////555555   ")$ % %  4#0@@@'c'3''''R))c))))X33c3333p+ S+ #+ + + + \%E=E=e====/:s/:/:/:/:d E  ? +     E  ? +      / 0   : t  & u Rf]9Y ? > *mWWW r)