o <6jU@sddlZddlZddlmZmZmZddlmZddlm Z m Z ddl m Z m Z ddlmZddlmZmZmZmZddlmZdd lmZmZmZdd lmZmZdd lmZed d Z da!Gddde Z"dddddddZ#ej$ej%ej&ej'ej(ej)dZ*e +ej,dkde dede-deddf ddZ.e +e"j/ej,0d de d!ede-deddf d"d#Z1e 2e"j3d$e de-deddfd%d&Z4e +e"j5ej,d'kde d!edede-ded(eddfd)d*Z6e +e"j5ej,d+kde de-deddfd,d-Z7dS).N)RouterFBot) FSMContext)State StatesGroup)Message CallbackQuery) AsyncSession)BroadcastMessageBroadcastTarget MediaTypeUser)is_admin)build_broadcast_target_keyboard build_broadcast_confirm_keyboardbuild_back_to_panel_keyboard)get_target_user_ids run_broadcast)get_textadmin_broadcast)nameFc@seZdZeZeZeZdS)BroadcastStateN)__name__ __module__ __qualname__rchoosing_targetwaiting_message confirmingrrI/var/www/www-root/data/www/ai-bot.pdev.uz/bot/handlers/admin/broadcast.pyrs rzBarcha foydalanuvchilarz Faol (7 kun)z Faol (30 kun)u🇺🇿 O'zbeklaru🇷🇺 Ruslaru🇺🇸 Inglizlar)all active_7d active_30dlang_uzlang_rulang_enzadmin:broadcastcallbackdb_userlangstatereturncst|jj|s|jtd|ddIdHdStr%|jdddIdHdS|jjtd|t|dIdH| t j IdH|IdHdS)Nz access-deniedT show_alertu)⏳ Hozir broadcast ishlayapti, kuting...zbroadcast-choose-target reply_markup) r from_useridanswerr_broadcast_runningmessage edit_textr set_staterr)r'r(r)r*rrr callback_broadcast_start6s  r7zbroadcast:target:sessioncs|jdd}|tvr|dIdHdSt|}t||IdH}t|}|j||j||dIdH|j t d|IdH| t j IdH|IdHdS)N:u❌ Noto'g'ri target) target_keytargetuser_idscountzbroadcast-send-message)datasplit TARGET_MAPr2rlen update_datavaluer4r5rr6rr)r'r8r)r*r;r<r=r>rrr callback_broadcast_targetQs&   rEr4c s|IdH}d}d}|jp|jpd}|jr"|jdj}tjj}n#|jr.|jj}tj j}n|j r:|j j}tj j}n |j rE|j j}tj j}|j||||rNdnddIdHt|ddd }|d d }td |||d } |j| t|dIdH|tjIdHdS)z5Broadcast xabarini qabul qilish va preview ko'rsatishNmediatext)broadcast_text media_file_id media_typemsg_typer;r!?r>rzbroadcast-preview)r<r>r.)get_datarIcaptionphotofile_idr PHOTOrDvideoVIDEOdocumentDOCUMENT animation ANIMATIONrC TARGET_LABELSgetrr2rr6rr) r4r)r*r?rKrLrI target_labelr> preview_textrrr process_broadcast_messagewsF        r^zbroadcast:confirm:yesbotcs|IdH}|IdHtr|jdddIdHdS|dg}|dtjj}|dd} |d} |d } |sH|j d IdHdSt | | | rQt | nt j t||j jd } || |IdH|| IdHt|} |j td | d IdH|IdHdat}dtdtffdd }z/t||| ||dIdH}tt|d}j td|j|j|dtdIdHWdadSdaw)Nu&⏳ Hozir boshqa broadcast ishlayapti!Tr,r=r<rJrFrKrLu📭 Maqsad auditoriya bo'sh.)rIrKrLr< created_byzbroadcast-started)totalsentracs:ztd||dIdHWdStyYdSw)Nzbroadcast-progressrbra)r5r Exceptionrcr) status_msgrr progress_updates z3callback_broadcast_confirm..progress_update)r_r8 broadcastr=progress_callbackzbroadcast-done)rbfaileddurationr.F)rOclearr3r2r[r ALLrDr4r5r r TEXTr0r1addcommitrefreshrBrtimeintrround total_sent total_failedr)r'r8r(r)r*r_r?r= target_rawrIrKmedia_type_rawrhra start_timergresultrlrrer callback_broadcast_confirmsf         r|zbroadcast:confirm:nocs<|IdH|jjdt|dIdH|IdHdS)Nu❌ Broadcast bekor qilindi.r.)rmr4r5rr2)r'r)r*rrr callback_broadcast_cancels  r})8asynciorsaiogramrrraiogram.fsm.contextraiogram.fsm.staterr aiogram.typesrr sqlalchemy.ext.asyncior bot.database.modelsr r r rbot.handlers.admin.panelrbot.keyboards.admin_kbrrrbot.services.broadcasterrrbot.services.i18nrrouterr3rrZrn ACTIVE_7D ACTIVE_30DLANG_UZLANG_RULANG_ENrAcallback_queryr?strr7r startswithrEr4rr^rr|r}rrrr s          " 3 O