!Ti%ddlZddlZddlZddlZddlZddlZddlmZddlm Z ddl m Z ddl m Z ddlmZddlmZd d lmZd d lmZej,eZd ZGd dZddefdZy)N)datetime)settings)log_step)get_twilio_client)ModelJSONParser)RecordingService)TRANSFER_STATUS)CallcVtjd|}|r|jdSy)zCExtract datetime in YYYY-MM-DD HH:MM:SS format from any messy text.#\d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2}rN)researchgroup)textmatchs H/var/www/html/dp2/backend_v2.1/server/apps/calls/services/assembly_ai.pyextract_datetime_strrs' II-> &  ! .    !??,.0!12C2E!F rcVtjd}tj|SN US/Pacific)pytztimezonernow)r0psts rget_current_time_pstz&AssemblyAIService.get_current_time_pst9smmL)||C  rc|jsytjd}|jj|}|Sr3)r+r5r6 astimezone)r0r8 call_time_psts rget_call_date_time_pstz(AssemblyAIService.get_call_date_time_pst=s8!!mmL)**55c: rc|jj|j}|j|_|jj |j }|jSr)r/get_latest_call_recordingr* start_timer+downloadsidcontent)r0 recordingresponses rdownload_recordingz$AssemblyAIService.download_recordingEsP**DDT]]S &11))229==Arc"tjdddd}tjdddd}d}d} td|j|j }|r=t j dd5}|j||j}dddtd |jt| |jj|| }d} |r)|jj|| } | j}|r5tjj|rtj | || r|fSdfS#1swYxYw#|r6tjj|rtj |wwwxYw) NFT)speaker_labels punctuate format_text disfluenciesr )rHrIrJspeakers_expectedDOWNLOAD_RECORDINGz.mp3)suffixdeleteSTART_TRANSCRIBE)bytes)config)r(TranscriptionConfigrr*rFtempfileNamedTemporaryFilewritenamelenr- transcribe utterancesospathexistsunlink) r0use_speaker_labelsraw_cfg labeled_cfgtemp_file_pathspeaker_utterances audio_bytesfraw_transcriptlabeleds rtranscribe_audioz"AssemblyAIService.transcribe_audioKsg))   --  ! * )4== 9113K00uMQRGGK(%&VVNN 'c+>N O!--88W8UNG!**55k+5V%,%7%7""''.."@ .)W1FF$FF#NM"''.."@ .)#A~s$?E7EA3EE E:Fc|syt||ddD]9\}}|j|jz |jk\s-|jcSy)Nr)zipstartendPAUSE_THRESHOLD_SECONDS)r0rZprevcurrs rdetect_transfer_timez&AssemblyAIService.detect_transfer_timeusMj*QR.9JD$ TXX%$*F*FFzz!:rcg}|D]o}|jdk(rd}n'|jdk(r|r|j|k\rd}nd}n<|j||j|j|jdq|S)NBUserAAdvisorAgent)rolerrkrl)speakerrkappendrrl)r0rZ transfer_timeresulturws r assign_roleszAssemblyAIService.assign_roles~s{AyyCc! QWW %=$D"D MMuu  ( rctjd|}|stjd|y|j dS)Nrz%No valid datetime found in response: r)rrloggerwarningr)r0rrs rextract_datetime_from_textz,AssemblyAIService.extract_datetime_from_texts; @$G NNB4&I J{{1~rc|j}||jjd}d|jd|d}|jj ||j j}tj|}|stjdddd|fS|jd d}|jd d}|jd d}tjd |||||fS) N%Y-%m-%d %H:%M:%Sz You are an AI assistant analyzing a phone call transcript. Your job is to extract booking intent with extremely high accuracy. TRANSCRIPT: """z""" CURRENT PST TIME: u RULES: 1. booking_intent MUST be 1 or 0 ONLY. 2. booking_datetime MUST be in exact format "YYYY-MM-DD HH:MM:SS" or null. 3. If customer expresses ANY intent to schedule, set booking_intent = 1. 4. Consider phrases: - "yes let's book" - "I want an appointment" - "schedule me" - "come tomorrow", "next Monday", "after 2 hours" - ANY mention of date/time relating to booking. 5. You MUST convert relative times (tomorrow, next Sunday, in 3 hours) using PST timezone. 6. If date but no time → use "00:00:00". 7. If unclear → booking_intent = 0 and booking_datetime = null. OUTPUT STRICTLY IN JSON: { "booking_intent": <1 or 0>, "booking_datetime": "", "summary": "" } ) final_modelzLLM returned invalid JSONrbooking_intentbooking_datetimesummaryz$booking_datetime directly from LLM: )r=r9strftimerlemurtaskMODELrErparserrgetinfo) r0 transcriptr<promptr{parsedrrrs ranalyze_transcriptz$AssemblyAIService.analyze_transcripts 335  !668AABUV]  /"@!!&&v4::&FOO &&v. NN6 7dB& &$4a8!::&8$?**Y+ :;K:LMN/&@@rc|r|jdvry tj|d}tjd}|j |}|j tj}|jdS#t$r%}tjd|d|Yd}~yd}~wt$r"}tjd|Yd}~yd}~wwxYw)N)nononezn/arrr4z"Invalid datetime format received: z . Error: zError converting datetime: )lowerrstrptimer5r6localizer;UTCr ValueErrorrr Exceptionerror)r0rdtr8dt_pstdt_utces rconvert_booking_datetime_to_utcz1AssemblyAIService.convert_booking_datetime_to_utcs#3#9#9#;?X#X ""#35HIB-- -C\\"%F&&txx0F??#67 7  NN?@P?QQZ[\Z]^ _  LL6qc: ; s$A+B C B,, C8CCc||_ |j|\}}td||j|\}}}}td|||j |} |j |} t jj|j} | r'| jtjjk7rd} |j|| } td|| tj!d|tj!d ||j"|| | ||d d S#t$$r)} td |t'|  dddddd cYd} ~ Sd} ~ wwxYw)N)r_ TRANSCRIBED AI_ANALYSIS)r)twilio_call_sidDATETIME_CONVERTED)utcz summary: z llm_raw: )rllm_raw)rrrrHresultsTRANSCRIPTION_FAILED)rrr)r*rhrrrrpr objectsfilterfirsttransfer_statusr SUCCESSFULvaluer}rrrrrepr)r0r* use_speakerrfrZrdt_rawrrrrzcallfinal_utterancesrs rprocess_transcriptionz'AssemblyAIService.process_transcriptionsl  , )-)>)>#.*?* &NJ ]H -7;7N7N~7^ 4NFGW ]H^ L#CCFK  55jAM<<&&x&@FFHD4//?3M3M3S3SS $ #00]K  )89I J KK)G9- . KK)G9- .-11"0$4"2&&    +XT!W E "#$("&   sD$D.. E 7EE E F)__name__ __module__ __qualname__r( LemurModelclaude3_7_sonnet_20250219rrrmrr1r9r=rFrhrpr}rrrr __classcell__)r!s@rrrs] NN 4 4EI! !$! (GT22Ah".rrr*c|AtjdtjtttttfSt }|j ||}|d|d|d|d|dfS)NzNo Twilio call ID for call )rrrrrHr)rrrid_rr)r*rservicer{s rget_speech_to_textrs 1$'';<1Qqy!G  * *8 * MF | !" y  rr)rr[r5loggingrT assemblyair(r django.confr utils.loggerrtwiliorjson_sanitizerrr/r constantsr modelsr getLoggerrrrrstrrrrrs_  !%+/'   8 $wwrr