4ʜhL NddlmZddlmZmZddlmZmZmZm Z ddl Z ddl m Z ddl m Z mZddlmZddlmZmZdd lmZdd lmZddlZddlZdd lmZmZd d lmZddlm Z e jBe"Z#e dgdZ$ d0dede%de%de&de&f dZ'dede%dejPfdZ)dede*deejPfdZ+dede*deejPfdZ,d1dedejZd ee*dejPfd!Z.dede%dej^dejPfd"Z0dede%de1fd#Z2ded$e%deejPfd%Z3dede%d&e%dejPfd'Z4dede%d(e&deejPfd)Z5dede%dee*e ffd*Z6dede*fd+Z7dedeee*e ffd,Z8d2d-Z9d.ejtdefd/Z;y)3)Session) HTTPExceptionstatus)ListOptionalDictAnyN) CryptContext)datetime timedelta)get_speech_to_text) CallSource CronJobStatus)get_call_recording_public_url)get_setting_value)modelsschemas)get_department)send_welcome_emailbcryptauto)schemes deprecateddbskiplimitorder_by_status order_by_namec|jtjtjjj tjtjj tjjk(jtjjjtjjj|j|}|j}g}|D]G\}} |jj!} | j#dd| | d<|j%| I|S)a Get all advisors with optional ordering by status and name. Args: db: Database session skip: Number of records to skip limit: Maximum number of records to return order_by_status: If True, order by status (available first) order_by_name: If True, order by full name Returns: List of advisors with the specified ordering _sa_instance_stateNaccount_status)queryrAdvisorUserr"joinuser_ididorder_byrdesc full_nameoffsetrall__dict__copypopappend) rrrrrr#resultsadvisorsadvisorr" advisor_dicts N/var/www/html/DP/alpha_backend/app/advisor_service/services/advisor_service.py get_advisorsr7s, HHV^^V[[%?%? @ fkk6>>11V[[^^C D &..'',,.0H0H I  u  iikGH#*'',,. -t4)7 %& % $+ O advisor_idreturnc<|jtjjtjj|k(j tjj jj}|s tdd|S)NStaff member not found status_codedetail) r#rr$filterr(r)r+ascfirstr)rr9r4s r6 get_advisorrDQsnhhv~~&--fnn.?.?:.MNWWX^XfXfXpXpXtXtXvw}}G 4LMM Nr8emailc|jtjjtjj|k(j SN)r#rr$rArErC)rrEs r6get_advisor_by_emailrHWs8 88FNN # * *6>>+?+?5+H I O O QQr8 phone_numberc|jtjjtjj|k(j SrG)r#rr$rArIrC)rrIs r6get_advisor_by_phonerKZs8 88FNN # * *6>>+F+F,+V W ] ] __r8r4passwordc lt||j}|r tdd|jtj j tj jj|jj}|r tdd|jtjj tjj|jk(j}|r tddt||j}|r tdd|jrt||jt}t j#|} t j|j|j|j||j$}|j'||j)t j |j*|j|j|j|j,|jd|j$}|j'||j/|jtj j tj j|jk(j}t1|j|j| }|S#t2$rE} |j5t7d t9| td d t9| d } ~ wwxYw)z Create a new advisor and corresponding user account Args: db: Database session advisor: Advisor data password: Password for the user account Returns: Created advisor object .A staff member with this email already exists.r>zJA staff member with this name already exists. Please use a different name.z5A staff member with this phone number already exists.)namerEphonerLtyper)r'r+rErIr department_id current_scorerR) recipientrPrLz!Error creating advisor and user: zFailed to create advisor: N)rHrErr#rr$rAr+ilikerCr%rKrIrSrgenerate_strong_password pwd_contexthashrRaddflushr(rcommitr Exceptionrollbackprintstr) rr4rL db_advisordb_usergenerated_passwordhashed_passwordcreated_advisor email_sentes r6create_advisorri]s&b'--8J4dee&..)00  &&w'8'89 eg_  hhv{{#**6;;+<+< +MNTTVG4dee&b'*>*>?J4kllr700123!&&'9:O0[++""--&&$   w  ^^JJ''-- -->>!//   z ((6>>299 NN GMM 1 %'  (mm""'  [  1#a&:;6PQTUVQWPX4YZZ[s9E+K%% L3.AL..L3ct||}|jr>|j|jk7r%t||j}|r tdd|jrt ||j|j |j |_|j|j|_|j|j|_|j|j|_|j|j|_ |j|j|_|j|j|_ |j}|jtjjtjj |k(j#}|r|j|j|_ |j%|j'||S)NrNrOr>)rDrErHrrSrr+rIrTrrRr'r#rr%rAr(rCr]refresh)rr9r4rbexistingr'rcs r6update_advisorrmsR,J}}**:*::'GMM: C8hi ir7001$&00 }} "== '")"6"6 (#*#8#8  ~~!#NN (#*#8#8  ||!,,   Ghhv{{#**6;;>>W+DEKKMG7<<+|| IIKJJz r8c*t||}|s tdd|j} |j||rj|j t j jt j j|k(j}|r|j||jddiS#t$rO}|jtjdt|tddt|d }~wwxYw) z Delete an advisor and their corresponding user account Args: db: Database session advisor_id: ID of the advisor to delete Returns: Message confirming deletion r<r=r>messagez8Advisor and associated user account deleted successfullyz!Error deleting advisor and user: rVzFailed to delete advisor: N)rDrr'deleter#rr%rAr(rCr]r^r_loggererrorra)rr9rbr'rcrhs r6delete_advisorrssR,J 4LMM  G[ * hhv{{+226;;>>W3LMSSUG '" UVV [  8QAB6PQTUVQWPX4YZZ[sBB:: DA D  DrSc|jtjjtjj|k(j SrG)r#rr$rArSr-)rrSs r6get_advisors_by_departmentru s8 88FNN # * *6>>+G+G=+X Y ] ] __r8scorecnt||}||_|j|j||SrG)rDrTr]rk)rr9rvrbs r6update_advisor_scorerx s1R,J$JIIKJJz r8 is_availablec |jtjjtjj|k(j }|st d|dy|rd|_nd|_|j|j||S#t$r-}|jt dt|d}~wwxYw)a) Update the availability status of an advisor. Args: db: Database session advisor_id: ID of the advisor to update is_available: True if advisor is available, False otherwise Returns: Updated Advisor object or None if advisor not found zAdvisor with ID z not foundN10z%Error updating advisor availability: ) r#rr$rAr(rCr`rr]rkr^r_ra)rr9ryr4rhs r6update_advisor_availabilityr}s((6>>*11&..2C2Cz2QRXXZ $ZL ; <  GN GN  7   5c!fX>? sA(B+3B C((CCc |jtjjtjj|k(j }t d|jd|sddddS|jdk7rdd|jdStj}|jtjjtjj|k(tjj|ktjj|k\j }|sdd |jdS|jd k7rdd |jdSd d |jdS#t$r=}t j#dt%|ddt%|ddcYd}~Sd}~wwxYw)a Check if an advisor is currently available based on their schedule and status Args: db: Database session advisor_id: ID of the advisor to check Returns: Dictionary with availability status and details z=-=-=-=-=-=-=-=Advisor status: =-=-=-=-=-=-=-=FzAdvisor not foundN) availablereasonrr{zAdvisor is not activez%Advisor is not scheduled at this timerz*Advisor's schedule status is not availableTzAdvisor is availablez%Error checking advisor availability: zError checking availability: )r#rr$rAr(rCr`rr nowAdvisorScheduler9shift_period_startshift_period_endadvisor_statusr^rqrrra)rr9r4rcurrent_schedulerhs r6is_advisor_availabler9s> ((6>>*11&..2C2Cz2QRXXZ //?OP"-  >>S "1!.. lln HHV++ , V&&11Z?&&99S@&&773> UW  "A!..   * *a /"F*99 ,nn       s7A7E=:E=B4E=E=-E== G2F>8G>Gc, |jtjjtjjdk(j }|r |j SdS#t$r!}tdt|Yd}~yd}~wwxYw)z Get timezone from alpha_settings table Args: db: Database session Returns: str: Timezone string (e.g., 'America/New_York') timezoneUTCz'Error fetching timezone from settings: N) r#r AlphaSettingsrAkeyrCvaluer^r`ra)rtimezone_settingrhs r6get_timezone_from_settingsrs88F$8$89@@  $ $ 2 %' *:%%DuD  7Ax@AsA$A)'A)) B2BBc  t|dd}t|}tj}|t |z}t d|d||j tjjtjtjjtjjk(jtjj|ktjj|k\tjj dk(tjj"dk(j%}g}|D]K}|j'|j|j(|j*|j,|j"dM|S#t.$r-}t0j3dt5|gcYd }~Sd }~wwxYw) z Get a list of all currently available advisors Args: db: Database session Returns: List of available advisors with their details TIMEZONE_OFFSETr|)hourszCurrent time with offset : r)r(rPrErIrz"Error getting available advisors: N)rintr utcnowr r`r#rr$r&rr9r(rArrrrr-r1rPrErIr^rqrrra) r offset_str offset_hoursutc_nowravailable_advisorsresultr4rhs r6get_all_available_advisorsrsx+&r+&&55:%%*  SU  )G MMjj   ' 4 4!..  *  9#a&BC sFF G'"G GGctj}tj}tj}d}t j |t j |t j |t j |g}|dz }||z|z|z|j fdt|Dt j|dj|S)z!Generate a strong random passwordz#$%&@*!c3HK|]}tjywrG)randomchoice).0_ all_charss r6 z+generate_strong_password..sN6MFMM),6Ms") stringascii_lowercaseascii_uppercasedigitsrrextendrangeshuffler&)length lowercase uppercaser special_charsrLremaining_lengthrs @r6rXrXs&&I&&I ]]FM  i  i  f m$ HzI%.>I OONers"),,((4:C. &.@   8 $H:&A ! && & & &  &rG RWRSRXfnn5MR`W`C`HV^^)>^[(SV-^[cicqcq^[@$w$C$':O:O$TZTbTb$L$[w$[C$[D$[L`7`3`4CW`W#cfnn$G$$D$U]^d^l^lUm$LI WI #I $sCx.I V7s&575tDcN/C5p68v8G8r8