o di,@sddlZddlZddlZddlZddlmZmZddlmZddl m Z ddl m Z ej ejde eddZed d Zed d Zejd eeedZdZdddZdS)N) BotoCoreError ClientError)get_db_connection) load_dotenv) send_message)levelAWS_ACCESS_KEY_IDAKIAUWPMKLMSH5E4QMNYAWS_SECRET_ACCESS_KEYz(DgvVy4lGJfRyX689uzZXGVpFyo+S6Qx392M8tUpb AWS_REGIONz eu-north-1zbedrock-runtime) service_name region_nameaws_access_key_idaws_secret_access_keyzamazon.nova-lite-v1:0cCspt}|}|r|d}|d}nd}d}|d|d|f|}|D]}|d}td|d |r>|dd nd d |rL|d krUtd|q)d|d} td|d | dddddd| igdgd} ztdt | t j t ddt | d} | d d} td|d | d } | rt| }|d id!id"g}|rt|tr|d#dd } | std$|td%|| d&r| d&d d'd } n | d'r| d'd } | } td(|d | zt| }Wn$tjy5}ztd)|d t|td*| d}~wwt |d+g}t |d,g}t |d-g}|d.d }|d/d }t |d0i}|d1d }|d2d }|d3p|d4pi}t |}t |d5g}t |d6i}|d6id7d }td8|d9|d:|d;|d<|d=|d>|d?|d@|dA|dB|dC|dD||dE|dF||||| ||||||||||f|t||tdG|Wq)tttjtfy-}z#tdH|d t|tdId"tvr| ndJWYd}~q)d}~ww||dS)KN_sarvamresponse_calls7987_sarvamresponse 7987_callszSELECT * FROM z! WHERE callid = %s AND status = 1u%🔍 Retrieved transcript for callid z: dNonez...u+⚠️ Empty or null transcript for callid u Analyze the following customer call transcript and return the following in JSON format: 1. Top 5 Keywords 2. Overall Sentiment with all (Positive, Negative, Neutral) with percentage 3. Detected Emotions (e.g., Happy, Angry, Frustrated) 4. Summary of the Call 5. Sales Intent (High, Medium, Low) 6. Customer Details (name, phone, email if available) 7. Call Purpose / Issue Type 8. Call Outcome (Resolved, Partially Resolved, Escalated, Follow-up Needed, Unresolved) 9. Action Items for Agent and Customer (clear and actionable) 10. Customer Pain Points (specific problems expressed) 11. Quality of the Call: - Communication clarity (agent & customer) - Background noise or call quality issues - Long pauses or hold time - Interruptions / speaking over each other - Agent professionalism, politeness, and empathy - Overall pacing and structure - Provide a Call Quality Score (1–100) - Include a brief explanation for the score Transcript: "z" zSending prompt for callid igffffff?g?)max_new_tokens temperaturetop_pusertext)rolecontent)inferenceConfigmessageszRequest body: zapplication/json)modelId contentTypeacceptbodyr$zutf-8zRaw response body for callid outputmessagerrz"Empty content received for callid z8Empty content received from Bedrock response for callid z```jsonz```z$Cleaned response content for callid zJSON decode error for callid zInvalid content: zTop 5 KeywordszOverall SentimentzDetected EmotionszSummary of the Callz Sales IntentzCustomer DetailszCall Purpose / Issue Typez Call Outcomez#Action Items for Agent and Customerz Action ItemszCustomer Pain PointszQuality of the CallzCall Quality ScorezParsed data for callid z : Keywords: z , Sentiment: z , Emotions: z , Summary: z , Sales: z , Customer: z,Call Purpose: z,Call Outcome: z,Action Items: z,Pain Points: z,Call Quality: z,Call Quality Score: z UPDATE a SET status = 2, keywords = %s, sentiments = %s, emotions = %s, summary = %s, sand_logic_response = %s, sales_intent = %s, transcripts = %s, customer_details = %s, call_purpose = %s, call_outcome = %s, action_items = %s, pain_points = %s, call_quality = %s, call_quality_score = %s WHERE callid = %s u✅ Bedrock processed callid u❌ Bedrock error for callid u⚠️ Failed content: zNo content available)rcursorexecutefetchalllogginginfostripwarningjsondumpsbedrock invoke_modelMODEL_IDreaddecodeloadsget isinstancelisterror ValueError startswithreplaceJSONDecodeErrorstrcommitrrrlocalsclose)call_idbidconnr'sarvam_response_table calls_tablecallscall transcriptpromptr$response raw_responser response_body content_listparsedekeywords sentimentemotionssummary salesintentcustomer_details call_purpose call_outcomeaction_items_data action_items pain_points call_qualitycall_quality_scorer^9/home/aiteam/pcaa-dev/post call analysis/openai_helper.pysend_openai_analysisys   (         X , r`)N)osr.r*boto3botocore.exceptionsrr db_configrdotenvrmessage_helperr basicConfigINFOgetenvrr r clientr0r2r`r^r^r^r_s*^