+ diCr^RIHt^RIt^RIt^RIt^RIHt^RIHt^RIt^RI H t ^RI H t ^RIHt^RIHtHt^R IHtHtHt^R IHtHt^R IHt^R IHtHtHtH t H!t!H"t"^R I#H$t$^RI%H&t&H't']PP!])4t*RRRllt+R#)) annotationsN)datetime)Any)parser)text)Session)build_mcube_refurl get_settings)call_history_tablecampaign_contacts_tablecampaigns_table) has_column has_table) campaign_core)check_business_time_windowcheck_remaining_minutesfetch_dial_status_and_updateget_bot_concurrent_limitget_bot_connecting_countget_bot_id_from_campaign_did)trigger_call_history_sync) format_dtnow_appc4V^8dQhRRRRRRRRRRR RR R /#) session_defaultrsession_cluster campaign_idz int | None business_id retry_onlybool priority_onlyreturnzdict[str, Any])formats"%app\services\outbound_call_service.py __annotate__r' s`` M` M` M` M` M ` M  ` M  ` M` Mc`0\4pVPpV'g V'd\P!WV4pV'g#RV 2p\P V4RRRVRV/#VP ;'gRP4'g RRRRRV/#\V\V44p V R,'g$RRRV R ,R R R V PR ^4RV/#\V\V44p V R,'gERRRV R ,R RRV PR4RV PR4RV PR4RV/#\\V44p \\V44p \\V44p \W4'g#RV 2p\P V4RRRVRV /#RpV'EdVP!\#RV R24RV/4P%4P'4pV'g%RV 2p\P V4RRRVRVRV /#V'gVPR4R8XdRRRRRVRVPR4RR /#VPR4R9d9RRRR\)VPR44,RVRVPR4/#MVPR4R9dR\P+RW.PR44RRRRVPR4 R 2RVRVPR4/#\P+R!W.PR44\-4pVR",pVR#,p\/V\04'g \2P4!\)V44p\/V\04'g \2P4!\)V44pVP6fVP9VP6R$7pVP6fVP9VP6R$7p\VPR%4;'g^4^8XdOVVP;VP648d/RRRR&\=V4,R'R R"\=V4R\=V4/#VVP;VP648d/RRRR(\=V4,R)R R#\=V4R\=V4/#\W4'g RRRR*RV /#V'd%\VPR+4;'g^ 4M^ pV'd%\VPR,4;'g^4M^pV'd3\)VPR-4;'gR4P4MRp\?WR.4p\=\-44pR/.p\?WR04'dVPAR04MVPAR14VPAR2V R324R4V/pV'dVPAR54VVR&V'd.R6pV'dVR7V R82, pVPAR9V R:24M:R;pRV R?24V'd$\?WR04'dVPAR@4\?WR04'dVPARA4MVPARB4RPCV4pVP!\#V4V4P%4PE4p\GV4pVUu/uFFp\VRC,4\)VPRD4;'gR4P4bKH p pVUu.uF#p\)VRE,4P4NK% p!pVUu.uFp\VRC,4NK p"pV!'g RRRRFRV/#RGVRHV/p#^p$.p%\IV!4p&\K^\IV!4V4U'u.uFp'V!V'V'V,NK p(p'\IV(4p)^ p*^p+RIp,Rp-Rp.VR8wdJ\MV\V4V4p-V-e0\OV\V4V-4p.\P+RJVV-VV.4VP!\#RKV RL244PQ4p/\P+RMV/4V.e,VR8wd%\SWV4p0\P+RNVV0V.4Rp2\WT(4E Fwp3p4T'diTP!\#RPT R24RT/4P'4p5T5'd2T5^,R8Xd$\P+RQTT3^,4R p2E MT2'dE MT"T3T,T3T,T,p6\WT44E Fwp7p8T'daTP!\#RPT R24RT/4P'4p5T5'd*T5^,R8Xd\P+RRT4R p2E M\T\T44p9T9R,'g\PYRST4TP[4TP[4RRRT9R ,R RRT9PR4RT9PR4RT9PR4RT/uu#T2'dE MT3T,T7,p:T7\IT648d T6T7,MRp;T;'dT'dTP!\#RTT RU24RCT;RT/4P%4P'4p\^P^!4p=T'dITP!\#RPT R24RT/4P'4p5T5'dT5^,R8XdR p2MT2'dM\TP!\#RKT RL244PQ44p>T'd \SYT4M^p?T>T*8p@T.RJ;'gT?T.8pA\P+RZT:^,T>T*T?4X@'d XA'dMP\^P^!4T=, T,8d\PYR[4M\^P`!T+4EK=T2'dEMrT'dKTP!\#RPT R24RT/4P'4p5T5'dT5^,R8XdR p2EM T2'dEMT;'dT P\T;4R4MRpB\cT4pC/T#CR]T8R^XBR_XCR`T/CpDT'gjRapE\P TE4T%PATE4T;'d7T'd/TP!\#RbT Rc24Rd\-4RCT;RT/4EKT:^8d\^P`!Rf4^pF^pGRpHRpIRpJRpKXGXF8:EdXH'g\fPh!RgRh7;_uu_4pLTLPkTPlXDRiRjRGRkT 2/Rl7pRRR4XP"pITPnpJRpKXJ'd^XJu;8:dRI8dMMR pHKXJ'dRmXJu;8:dRn8dMMMXXJ'dPXJRn8dIXGXF8dBXG^, pGTG^,pM\P+RoTM4\^P`!TM4EKXH'gjXK'dbT%PARpT: RqT8 RrXK 24T;'d=T'd2TP!\#RbT Rc24Rd\-4RCT;RT/4EKEEKHEKKXH'EdXJ'Ed^XJu;8:d RI8EdMEM\pPr!XI;'gRs4pNXNPR4pOTNPRt4;'gRpPXORu8XEd-XNPRv4'EdT$^, p$XNPRv4pQ\P+RwT8XI4RpRT'gT;'dT'dTP!\#RxT RU24RCT;RT/4P'4pSTS'd\XS^,;'g^4M^pTTT^8d;XT^, pUTP!\#RbT Ry24RzTURd\-4RCT;RT/4R pRT;'d9T'd1\wTXQ\T;4\T4\T4T T T8T XR4 \P+R}4\^P`!^4\^P^!4pVT'dKTP!\#RPT R24RT/4P'4p5T5'dT5^,R8XdR p2EKT2'dEK\TP!\#RKT RL244PQ44pWT'd \SYT4M^pXXWT*8p@T.RJ;'gXXT.8pAX@'dXA'd\^P`!^4\TP!\#RKT RL244PQ44pYT'd \SYT4M^pZXYT*8d$T.eXZT.8d\P+R~4E KEK]\^P^!4XV, T,8d\PYR4E K\^P`!T+4EKRpT: RqT8 RXP RXI R:2 pET%PATE4T;'d=T'd2TP!\#RbT Rc24Rd\-4RCT;RT/4E KSE KVE KYXH'dE KdXI;'gRR,;'gRp[T%PARpT: RqT8 RXJ RT[ 24TJ'dXJRn8d\P RT8XI4T;'gE KT'gE KTP!\#RbT Rc24Rd\-4RCT;RT/4E K T2'dMT$^8d\y\T4R 4T'd[T2'gS\Pz!Y\T4\T44p\T\'d!\P+RTT3^,4MJT3T)^, 8gE KN\P+RT3^,T4\^P`!T4E K T'd3T2'g+\Pz!Y\T4\T44T$^8d(RR R RT$ R\IT!4 R2R.RT$R\IT!4RT%/#RRRRRT%/#uupiuupiuupiuup'i \Td"p1\P ROT14Rp1?1E L?Rp1?1ii;i \Td#p1\P R\T14Rp1?1E K+Rp1?1ii;i \dd p1RRR\)T14RT/uRp1?1uu#Rp1?1ii;i \Td"p1\PYReT14Rp1?1ELrRp1?1ii;i +'giEL;i \Tdp1\)T14pK^pJRpIRp1?1EL Rp1?1ii;i \TdE Kji;i \pPtd/pNELi;i \Td"p1\P R{T14Rp1?1ELRp1?1ii;i \Td"p1\PYR|T14Rp1?1ELRp1?1ii;i \Td#p1\P RT14Rp1?1EKRp1?1ii;i \TdEK)i;i \TdEK<i;i \Td"p1\PYRT14Rp1?1EL3Rp1?1ii;i)z] Port of CampaignController::initiateOutboundCall (synchronous, uses sleep/usleep like PHP). z4Business ID is required but not found. Campaign ID: successFerrorrzMCUBE_PUBLIC_WS_URL_BASE is not set (required for refurl). Copy MCUBE_PUBLIC_WS_URL_BASE from backend .env into campaign_port environment.validmessageinsufficient_minutesT remain_min error_codeBUSINESS_TIME_BLOCKED business_time current_time current_dayzCampaigns table not found: table_nameNzSELECT * FROM `z"` WHERE campaign_id = :cid LIMIT 1cidzCampaign not found: statuspausedz 0z AND (retry_at <= 'z' OR retry_at IS NULL)z AND ()z&(status = 'pending' OR status IS NULL)z](UPPER(COALESCE(status, '')) != 'ANSWER' AND call_id IS NOT NULL AND COALESCE(`retry`, 0) > 0z AND ((z) OR (z))z AND priority = 1z ORDER BY priority DESC, id ASCz ORDER BY id ASCidnamenumberz+No customer numbers found for this campaign Authorization exenumberi,zCBot concurrent limit campaign_id=%s bot_id=%s exenumber=%s limit=%szSELECT COUNT(*) FROM `z$` WHERE dialstatus IN ('CONNECTING')zInitial CONNECTING count: %sz,Initial bot CONNECTING for %s: %s (limit %s)z%Error checking initial CONNECTING: %szSELECT status FROM `zCampaign %s paused at batch %szCampaign %s paused at contactz!Campaign %s blocked business timez!SELECT id, status, `retry` FROM `z/` WHERE id = :id AND campaign_id = :cid LIMIT 1ANSWERzSkipping contact %s - ANSWERretryz Skipping contact %s - no retriesz/Concurrent check call %s: business=%s/%s bot=%szMax wait exceeded, proceedingzCONNECTING check error: %s custnumbercustnamerefurlrefidz1Missing required field for call. exenumber: emptyzUPDATE `zN` SET status = 'failed', updated_at = :u WHERE id = :id AND campaign_id = :ciduzFailed update contact: %sg?g>@)timeoutz Content-Typezapplication/jsonzBearer )jsonheadersiizRetrying after %s szCall z (Number: z) - cURL Error: z{}msgsucccallidz#Call placed successfully for %s: %szSELECT `retry` FROM `zJ` SET `retry` = :nr, updated_at = :u WHERE id = :id AND campaign_id = :cidnrzDecrement retry failed: %sz#fetchDialStatusAndUpdate failed: %sz,Waiting 5 seconds for call to be recorded...z)Concurrent counts OK; ready for next callzMax wait on disconnect exceededz Error re-checking CONNECTING: %sz) - API Error: z (Response: :NNzempty responsez) - HTTP Error z: z Full response failed call %s: %sz$trigger_call_history_sync failed: %sz+Campaign %s marked completed after batch %szBatch %s done; waiting %s szSuccessfully initiated z out of z callscall_ids success_count total_callserrorszAll calls failed)active processing) cancelledstopped)>r outbound_bearer_tokenr resolve_business_id_for_campaignloggerr+mcube_public_ws_url_basestriprintgetrr r r rexecutermappingsfirststrinfor isinstancer date_parserparser=replace astimezonerrappendjoinalllistlenrangerr scalar_oner Exception enumeratewarningcommituppertimesleepr ValueErrorhttpxClientpostoutbound_call_url status_coderUloadsJSONDecodeErrorrr!check_and_mark_campaign_completed)]rrrrr r"settings auth_tokenerr minutes_checkbusiness_time_checkcampaigns_table_namer6call_history_tblcampaignnowr;r<rArBrL has_retry_atnow_strq_partsparamssubpending retry_partsqlrowscustomer_contactsrcontact_names_mapcustomer_numbers contact_ids base_datar]r_total_contactsibatches total_batchesmax_connecting_callscheck_interval max_wait_timecampaign_bot_idbot_concurrent_limitinitial_connectingibe is_paused batch_indexbatchcurbatch_contact_idsindexrJbtc global_index contact_idct wait_startconnecting_countbot_connecting business_okbot_ok customer_namerQdataerrm max_retries retry_countcall_successful response_text http_code curl_errorclientdelay response_data api_status api_messagecall_idretry_already_decrementedcurrent_contact old_retry new_retrywait_for_disconnect_startcurrent_connecting current_botfinal_business final_botpreview was_completeds]&&&&&& r&initiate_outbound_callr s~H//J ;#DD_grs D[MR S5'3 {KK  - - 3 3 : : < < u ^ ;   ,OS=MNM  ! ! u ]9- "D -++L!< ;   5_c+FVW w ' ' u (3 1 044_E /33NC .22=A ;  +3{+;<([)9:J)#k*:; _ ; ;+,@+AB S5'3 >RSSH{"** ?#7"88Z[ \ K   (*UUW ( 6C LL 5{2  ||H%1u[!;$hll8&<d ||H%-EEuo(,,x012!;$hll8&< F||H%)AA NP[]i]ijr]stu|HLL,B+CCab!;$hll8&<  KKNP[]i]ijr]s til+ J'*h//$**3z?;J(H--"((X7H    $#++3::+>J ?? "''szz':H x||I&++! , 1cJG/z::z"' NN *_`$[1F01#u XC,WI5KLL NNVC5? +>Go  3G9 > @ D D FDT QbcQbAQtWs155=+>+>B'?'E'E'GGQbc:KL:KQAhK(..0:KL):;):A3qw<):K; 5'+XZgituu!0*k9 UIMF)*N=B1cJZF[]g=hi=hA N3=hGiLMNMOB6KHXZcd  &#;OSQ\M]_n#o KKU$   A,44 )*:);;_` a *,   24FG  + R)/YWB KKF SUWk lI'0 U !))+,@+AAcde $eg s1v) NOCw<<BKP&&(&&(uS^ "9#SWW_%="CGGN$;!377=#9!;&3e;L5:SAR=S5S*51Y]Jk$,,;J,C,C!(D]^I(1},5M / 7 7$(*2:,?P)P%&&*9c79dJX]_j$k !"=A 9"kU8 / ' #J #K 0 #K 0 * 4 & 0 9 KK NOJJqM6L48IIK1"*&5&=&=$(*>?S>TTv(w%&&+K$8 '" #(%' !$ $'3q6X+=04I$)( %14 / 7 7$(*@AQ@RRv(w%&!"#-*, 2.$-!9\e f%&( +=?S*SK%9T%A%g%g[SgEgF*v $ 1 14$3$;$;(,.DEUDVVz,{)*%&'1jl 2"(1%=_`i$j)*!* $24H#H$8$@IPdDd$*KK0[$\$) ( $ .G GMY &/P Q % JJ~6#<. 6(/R]Q^^jkxjyyz{DMM$'!k !+33 $&.zl;L%L!""%giz5+ V '2z%_(..B5II9I l^:fX_U^T__abiajklc!1LL!CV][:++ '// "*:,7H!H!')T:ukR y .L   1  J)#k*:DA y)KK#k2BC DTM I;XcfgXgh * * KK5{Q W JJ~ &Q 1T 977 c+.>K@P q t 0xL\H]G^^de  ] 3/0 f    ug'98V LLK dL;j: A _=A_>` A`-` A`(`(A`-)FF), __future__rrUloggingrrtypingrrdateutilrrq sqlalchemyrsqlalchemy.ormr app.configr r app.utils.cluster_table_namesr r r app.repositories.schema_helperrr app.servicesrapp.services.campaign_corerrrrrrapp.utils.rabbitmq_campaignrapp.utils.timezone_utilrr getLogger__name__rfrr$r(r&rsc"   *"7ff@&B6   8 $` M` Mr(