o zSoj] @sUdZddlmZddlZddlZddlZddlmZmZm Z m Z m Z m Z e eZdZdZehdZdZd Zd d d id d id gd dd ddgdd d id d dgid did d dgidgdddZded<Gddde ZdS)uLLLM vía OpenAI Responses API (cloud) o Chat Completions (Ollama / proxies).) annotationsN) ChatMessageConversationContext LanguageModel LlmFatalErrorLlmQuotaExceededLlmReplyuSos un asistente telefónico en español rioplatense. Respondé de forma breve y clara, apto para voz (1-3 oraciones). No uses markdown ni listas largas.) idnombreapellidopolizaproducto plan_actual precio_actual plan_ofrecidoprecio_ofrecidoplan_retencionmonto_aseguradomonedacreado>quota_exceededinsufficient_quotarate_limit_exceededbilling_hard_limit_reachedresultado_llamadau5Extrae el resultado de la conversación de retención telefónica. Usá los datos de póliza conocidos cuando estén disponibles; no inventes id ni número de póliza. Clasificá motivo como uno de: Economicos, Desconocimiento, Fallecimiento, Otro. resultado es "retencion" si el cliente aceptó cambio de plan o descuento; "baja" si se confirmó la baja del seguro. plan_anterior es el plan que tenía al inicio. plan_nuevo es el plan aceptado o null. descuento_aceptado es true solo si aceptó la bonificación; descuento_aplicado es "20" en ese caso, si no null.objecttypestring) EconomicosDesconocimiento FallecimientoOtro)renumbaja retencionnullboolean)r r motivo resultado plan_anterior plan_nuevodescuento_aceptadodescuento_aplicadoF)r propertiesrequiredadditionalPropertiesdictRESULTADO_LLAMADA_SCHEMAc@s`eZdZUdZdZded<dZded<dd d d d d ddd ddddd dfd$d%Zdgd&d'Zdhd(d)Z did,d-Z e djd/d0Z e did1d2Ze dkd5d6Ze dld8d9Zdmdr?r@rArBrCrDrE bool | NonerFreturnNonecCsp| pd|_| p dd|_|pd}|s%|jdkr!d}ntd||_||_||_||_ ||_ ||_ ||_ | p=t |_|durKt||_n |jdkoTd|jv|_|ra|ratd| rhtd d|_i|_t|_d |jd d }|jrtd |j|j|jn td|j|j|jtj|j|| d|_d|jvo|j |_|jdkrdt_dt_dSdS)Nr3r9/r6ollamaz6OPENAI_API_KEY es obligatorio para LLM_PROVIDER=openaizapi.openai.comuOPENAI_ASSISTANT_ID está definido pero se ignora: Assistants API deprecada; se usa Responses API. La personalidad va en BOT_SYSTEM_PROMPT / bot_system_prompt.txt.zFuse_assistants=True ignorado: Assistants API reemplazada por ResponseszBearer zapplication/json) Authorizationz Content-Typez/LLM provider=%s modo=responses model=%s base=%sz6LLM provider=%s modo=chat.completions model=%s base=%s)rBheadersrCF)striplowerrDrstriprB ValueErrorrGr:r;r<r=r>r?DEFAULT_SYSTEMrAr4_use_responsesloggerwarningr@ _response_idsset_poliza_seededinfohttpx AsyncClient_client_send_penaltiesr2r5r8)selfrGr:r;r<r=r>r?r@rArBrCrDrErFkeyrPrc8/var/www/html/bot-asterisk-ari/backend/llm/openai_llm.py__init__gsv        zOpenAiLanguageModel.__init__c s|jdkrdSz%|jjd|jdddgddd d IdH}|td |j|jWdStyH}zt d |j|WYd}~dSd}~ww) zHPing corto a chat.completions para cargar el modelo en memoria (Ollama).rNN/chat/completionsuserokrolecontentr)r:messagesr<r;jsonz.LLM warmup OK provider=ollama model=%s base=%su.LLM warmup falló provider=ollama model=%s: %s) rDr_postr:raise_for_statusrWr\rB ExceptionrX)raresponseexcrcrcrdwarmups4     zOpenAiLanguageModel.warmupcCs|jS)z?Solo comportamiento permanente (Responses: campo instructions).)rArarcrcrd_build_instructionssz'OpenAiLanguageModel._build_instructionscontextConversationContext | NonecCs4|jg}||}|r||ddd|DS)uISystem message para Chat Completions (Ollama): prompt + datos dinámicos. css|]}|r|VqdSNrc).0prcrcrd sz4OpenAiLanguageModel._build_system..)rA_context_input_textappendjoin)rarxparts context_blockrcrcrd _build_systems   z!OpenAiLanguageModel._build_system dict | NonecCsV|r|jsdS|j}i}tD]}|dkr!|dp|jpd||<q||||<q|S)Nr r6)r _POLIZA_INPUT_KEYSget document_id)rxdatapayloadrbrcrcrd_poliza_payloads z#OpenAiLanguageModel._poliza_payloadcCstg}||}|r|dtj|dddn|r&|jr&|d|jd|r5|jr5|d|jdd|S) uQTexto de contexto dinámico (póliza / documento / llamante) para input o system.uHDatos del cliente (fuente CRM; usá estos valores y no inventes otros): F ensure_asciiindentz,El documento/DNI asociado a esta llamada es .uNúmero del llamante: rz)rrrodumpsr caller_numberr)clsrxrr rcrcrdrs     z'OpenAiLanguageModel._context_input_textrmlist[ChatMessage]cCs4t|D]}|jdkr|jr|jSqdS)Nrgr6)reversedrjrkrQ)rmmsgrcrcrd_latest_user_texts z%OpenAiLanguageModel._latest_user_text list[dict]cCsPg}|D]!}|jdkr q|jpd}|sq|jdvrq||j|dq|S)Nsystemr6)rg assistant developerri)rjrkrQr)rmitemsrrkrcrcrd_history_as_inputs  z%OpenAiLanguageModel._history_as_inputcall_id input_itemscCsH||jvr|S||}|s|S|j|dd|dd}|g|S)uIInyecta el JSON de póliza una sola vez al inicio de la cadena Responses.rgz}z| |d}~ww)Nz5OpenAI bloqueado por cuota agotada (circuito abierto)r) r2r5rr8rV_reply_responses _reply_chatrr]HTTPStatusError_raise_if_quota_http)rarmrxrtrcrcrdreplyGs"  zOpenAiLanguageModel.replyrthttpx.HTTPStatusErrorcCsd}|jjdd}z |j}|dpi}t|dpd}t|dp'|}Wn ty3Ynw|d|}|jjdvsO|tvsOd|vsOd |vrdd t _ |t _ t d |t||p`d d |dS)Nr6,errorcoder )iizexceeded your current quotarTu?OpenAI CUOTA AGOTADA — circuito abierto, no más requests: %srr)rsrrorr7rrrR status_code _QUOTA_CODESr2r5r8rWrr)rartrrrerrloweredrcrcrdr\s.   z(OpenAiLanguageModel._raise_if_quota_httpc sR|r|jndp d}|j|}|r!||}|stddS|}n||}|s-tddS||||}|j|||j |j |j dd}|rJ||d<| d|IdH} | d } | r| d vr| d pdi} t d | d | dd| dt| dp| pdd| d} t| tr| r| |j|<td|| |pd|| } t| | dS)uKResponses API: instructions fijas + input dinámico + previous_response_id.r6_default)rT)r: instructionsinputr;max_output_tokensr=storeprevious_response_id /responsesNstatus completedrzOpenAI Responses status= code=r msg=rresponse_failedrr z4OpenAI response chain call=%s response_id=%s prev=%s-rraw)rrYrrrrrr:rwr;r<r= _post_jsonrr7rrWdebugr)rarmrxr previous_id user_text input_payloadrbodyrrr response_idrrcrcrdrusZ            z$OpenAiLanguageModel._reply_responsesrx transcriptrlist[str] | Nonec Csg}||}|r|dtj|dddn|r%|jr%|d|j|r2|dd|n6g}|D]%}|jdkr>q6|jpBd }|sHq6|jd krOd nd } || d |q6|rh|dd||sldS|dd|S)NuDatos de póliza conocidos: FrrzDocumento/DNI: uTranscripción de la llamada: rzrr6rgclienteagentez: ufNo hay transcripción. Extraé el mejor resultado posible con campos vacíos o null según el esquema.u2Extraé el resultado estructurado de esta llamada.z ) rrrorrrrjrkrQ) rarmrxrrr linesrrkspeakerrcrcrd_build_extract_inputs:      z(OpenAiLanguageModel._build_extract_inputc sJtjr tddS|s|sdS|j|||d}z.|jr+||IdH}||}n||IdH}| digd di dd }Wn3t yOt j yl}z||td WYd}~dSd}~wtyztd YdSw|sdSzt|}Wntjytd |dd YdSwt|tsdS|S) z;Fin de llamada: Responses con text.format.type=json_schema.z4extract_call_result omitido: circuito OpenAI abiertoNrchoicesrrrkr6zextract_call_result HTTP erroruextract_call_result fallóu'extract_call_result: JSON inválido: %sr)r2r5rWrXrrV_extract_responsesr _extract_chatrrQrr]rr exceptionrrroloadsJSONDecodeErrorrr0) rarmrxr input_textrrrtparsedrcrcrdextract_call_results\        z'OpenAiLanguageModel.extract_call_resultrc s|jt|dtd|jdddtdtdid}|d|Id H}|d }|rP|d vrP|d p1i}td |d|dd|dt |dpL|pLdd|S)zAPOST /responses con text.format json_schema (structured outputs).rTformat json_schema)rnamestrictschema)r:rrr;rrrrNrrrzOpenAI extract status=rrrrrr) r:RESULTADO_LLAMADA_INSTRUCTIONSminr<RESULTADO_LLAMADA_NAMEr1rrrr7)rarrrrrrcrcrdr s8   z&OpenAiLanguageModel._extract_responsesc s|jdtdd|dgdtd|jdtdtdd d }|jjd |d Id H}|jdkr>ddi|d<|jjd |d Id H}|jdkrS| t j d|j|j |d| |S)zLChat Completions (Ollama): pide JSON; schema estricto si el proxy lo acepta.rrirgrrrT)rrr)rr)r:rmr;r<response_formatrfrnNr json_objectrHTTP requestrs)r:rrr<rr1r_rprrr]rrrqro)rarrrsrcrcrdr(s8     z!OpenAiLanguageModel._extract_chatc sd||dg}|D]}|jdkrq ||j|jdq |j||j|j|jd}|jr8|j |d<|j |d<|j j d|dIdH}|j d krX|tjd |j |j|d ||}|d igd didd}t||dS)z6Chat Completions: Ollama y proxies compatibles OpenAI.rri)r:rmr;r<r=r>r?rfrnNrrrrrrrkr6r)rrjrrkr:r;r<r=r`r>r?r_rprrr]rrrqrorrQr) rarmrxpayload_messagesrrrsrrrcrcrdrKsB      zOpenAiLanguageModel._reply_chat)paramspathrrcs|jj|||dIdH}|jdkr;td||j|jddz|tjd|j|j |dWnt y:w| | S)N)rorruOpenAI POST %s → %s %srrr) r_rprrWrrrr]rrrrqro)rarrrrsrcrcrdrws,    zOpenAiLanguageModel._post_jsoncCs|j|d|j|dS)zELimpia la cadena previous_response_id de una llamada (nombre legacy).NrYpopr[discardrarrcrcrd drop_threadszOpenAiLanguageModel.drop_threadcCs|j|d|j|dSr{rrrcrcrddrop_response_chainsz'OpenAiLanguageModel.drop_response_chaincs*|j|j|jIdHdSr{)rYclearr[r_acloservrcrcrdcloses  zOpenAiLanguageModel.close)rGr7r:r7r;rHr<rIr=rHr>rHr?rHr@r7rAr7rBr7rCrHrDr7rErJrFrJrKrL)rKrL)rKr7)rxryrKr7)rxryrKr)rmrrKr7)rmrrKr)rr7rxryrrrKr)rr0rKr7)rmrrxryrKr)rtrrKrL)rmrrxryrrrKr7)rmrrxryrrrKr)rr7rKr0)rr7rr0rrrKr0)rr7rKrL)__name__ __module__ __qualname__rDr5__annotations__r8rerurwr staticmethodr classmethodrrrrrrrrrrrrrrrrrrcrcrcrdr2ash    Z         <+ 6 '-  r2)__doc__ __future__rrologgingr] llm.protocolsrrrrrr getLoggerrrWrUr frozensetrrrr1rr2rcrcrcrdsD