/cj(ndZddlZddlmZddlZddlZejejjdZdZ dS)a5 ACRS (Automated Complaint Resolution System) dispatch logic. Classifies conversations via LLM and POSTs to ACRS API. Extracted from PipelineSession for maintainability. All functions take `p` (pipeline session instance) as first argument to access session state (conversation_log, acrs config, llm, etc.). N)datetimec  |jsdddSdd|jD}d}|jD]\}dd|d gD}|d |d d |d z }|r |d|dz }|dz }]dd|jD}dd|jD}dd|jD}d|r|ndd|r|ndd|r|ndd|r|ndd|d }tdt|jd |j j j |j d|dgd} | jd jj} | d!r=| d!dd"d} n=| d"r(| d"d} t)j| } td#t)j| d$%n1#t.$r$} td&| dd'| dcYd(} ~ Sd(} ~ wwxYw|jpd)t3jd*| d+| d,| d-| d.|jpd/|| d0d| d1d| d2d3 } |jD]\}}|| vr|| |<td4t)j| d$%|jd5d5d6} tAj!|j"| |d7d8}td9|j#|j#d:vrwi} |}n#t.$rYnwxYw|d;|d d}td<|d=d>tI|d?S|j%d(d@}tdA|j#dB|ddC|j#dS#t.$r$} tdD| ddE| dcYd(} ~ Sd(} ~ wwxYw)Fz}Classify conversation via LLM and POST to ACRS API. Returns result dict. Args: p: PipelineSession instance. FzNo conversation to dispatchsuccessmessage c3PK|]!}d|dd|dd|dV"dS[ timestampz] speaker: textN.0ms K/home/m1-ai/DEPLOYMENTS/AI-PHONE/ZACK-UPDATE/fixing_leaked/acrs_dispatch.py z#dispatch_to_acrs..Z""  :AkN99a l99ai99""""""z, c3>K|]}d|dd|dVdS)zID idrnameNrrcs rrz#dispatch_to_acrs..%s;WW!5qw55!F)55WWWWWWr categoriesz - Department ID rrrz (Categories: )c3>K|]}d|dd|dVdS)z - Type ID rrrNr)rts rrz#dispatch_to_acrs..+s;VVA?4??AfI??VVVVVVrc3>K|]}d|dd|dVdSz - Subcategory ID rrrNrrss rrz#dispatch_to_acrs..,;ggQH!D'HHQvYHHggggggrc3>K|]}d|dd|dVdS)z - Rating ID rrrNr)rrs rrz#dispatch_to_acrs..-s;\\CQtWCC& CC\\\\\\raAnalyze this customer service conversation and classify it. Your response MUST be a valid JSON object with these fields: { "departmentId": , "typeId": , "categoryId": , "subCategoryId": , "ratingId": , "summary": "<1-2 sentence summary>", "emailSubject": "" } AVAILABLE OPTIONS: Departments and their categories:  (none configured)z Types:  Subcategories: z Ratings: ai RULES: - You MUST pick IDs from the options above. Do not invent new IDs. - If no clear match, pick the closest available option. - "summary" should be a concise 1-2 sentence description of the conversation. - "emailSubject" should be a short topic/subject (max 100 chars). - Response must be valid JSON only, no additional text. Conversation to analyze: """"""z![ACRS] Classifying conversation (z messages)...userrolecontent皙?modelmessages temperaturer```json```z[ACRS] Classification: indentz[ACRS] Classification error: zClassification failed: Nadmin%Y-%m-%d departmentIdtypeId categoryId subCategoryIdUnknownsummary emailSubjectratingId) spAccount incidentDater<r=r>r?roriginalEmailContentnocrBrCz[ACRS] Payload: application/jsonz X-API-KEYz Content-TypeAccept jsonheaderstimeoutverifyz[ACRS] Response: caseNoz"[ACRS] Dispatch successful. Case: TzDispatch successfulrrcase_norRz[ACRS] Dispatch failed (): API returned z[ACRS] Request error: Request failed: )&conversation_logjoinacrs_departmentsget acrs_typesacrs_subcategories acrs_ratingsprintlenllmchat completionscreate llm_modelchoicesrr/strip startswithreplacerMloadsdumps Exceptionacrs_sp_accountrnowstrftimesession_profileacrs_custom_fieldsitems acrs_api_keyrequestspost acrs_api_url status_codestrr)pconversation_text dept_descdcats type_desc subcat_desc rating_descpromptresponserawclassificationepayloadkvrNresp resp_datarVbodys rdispatch_to_acrsrs" L -JKKK ""#""" I  yyWWquu\SU?V?VWWWWW@!D'@@QvY@@@  2 1$111 1IT  VVVVVVVI))ggRSRfgggggK))\\Q^\\\\\K## 22!####&22'####,6!6-####26!63####FG######FL Tc!2D.E.E T T TUUUL5:)00+%&99:1   q!)17799 >>) $ $ 1++i,,44UB??EEGGCC ^^E " " 1++eR((..00CC N >!(L(L(LNNOOOO LLL 1a11222 -Jq-J-JKKKKKKKKL &1' // ;;&**>:: $$X..$((66'++O<<!.Y 1!!)R00&**>2>>"&&z22  G$**,,1 G  GAJ .rrrNrrc3>K|]}d|dd|dVdS)z - Category ID rrrNrrs rrz,dispatch_callback_to_acrs..s;VVqBAdGBBqyBBVVVVVVrc3>K|]}d|dd|dVdSr#rr$s rrz,dispatch_callback_to_acrs..r&rzClassify this callback request into a category and subcategory. Your response MUST be a valid JSON object: {"categoryId": , "subCategoryId": } AVAILABLE OPTIONS: Categories: r)r*z RULES: - Pick IDs from the options above only. Do not invent new IDs. - If no clear match, pick the closest available option. - Response must be valid JSON only, no additional text. Callback reason: z Conversation: """r+z3[ACRS Callback] Classifying category/subcategory...r,r-r0r1rr5r6r>r?z+[ACRS Callback] Classification: categoryId=z, subCategoryId=z;[ACRS Callback] Classification error (proceeding without): r:r;r@z Callback: z (z ). Reason: zCallback Request: P) rDrEr<r=r>r?rCrrFrGrBz[ACRS Callback] Payload: r7r8rHrIrKFrLz[ACRS Callback] Response: rQrTz+[ACRS Callback] Dispatch successful. Case: TzCallback dispatch successfulrUrRz![ACRS Callback] Dispatch failed (rWrXrz[ACRS Callback] Request error: rY)&rZr[r\r]acrs_callback_dept_idr_rarcrdrerfrgrhrr/rirjrkrMrlrnrorrprqacrs_callback_type_idacrs_callback_rating_idrrrsrtrmrurvrwrxryrzr)r{ customer_namecustomer_phonereasonr| category_idsubcategory_id dept_catsr~cat_descrrrrrrrrrrNrrrVrs rdispatch_callback_to_acrsrs $ ""#""""$ KNI   55;;!1 1 1lB//I E 2yyVVIVVVVVH))ggRSRfgggggK)UQ))U0A)UV)U#00##6!6##$%##*+###. DEEE Uuz-44k#)f==>5H "1%-5;;==C~~i(( 5kk)R0088CCIIKK&& 5kk%,,2244!Z__N(,,\::K+//@@N m mm]kmm n n n n U U U SPQSS T T T T T T T T U&1' // ;;/)!'-?!2?i 1PMPP^PPPP:VCRC[::  G$**,,1 G  GAJ Edj&C&C&C E EFFF^*$G E} NR    =4+;==>>>  z ) )I  IIKK     mmHimmD".E.EFFG III J J J#0N[^_f[g[ghh h9TcT?D Qd6FQQ4QQ R R R$1SAQ1S1STT T EEE 333444 -C-C-CDDDDDDDDEsc-D;H)) I3I  IAO<M'&O<' M41O<3M44AO<5O<< P*P%P*%P*) __doc__rMrrvurllib3disable_warnings exceptionsInsecureRequestWarningrrrrrrs +BCCCDEDEDENvEvEvEvEvEr