*WiwddlmZddlmZddlmZmZddlmZddlm Z m Z m Z m Z ddl mZddlmZedd d ed efd Zedd d efdZy)) shared_task)Session)datetime timedelta) SessionLocal) NotificationCustomerDeliverySegment)deliver_message) get_settingsTz.app.workers.notifications.enqueue_notification)bindnamenotification_idreturnc Nt} |jtjtj|k(j }|sd|d|j Sg}|jrS|jtjtj|jk(j }|r|g}n|jr|jtjtj|jk(j }|r|jxsi}|jtjtj|jk(}d|vr1|jtjj|d}|j}|s-d|_|j!d|d|j S|j"j$xsddgi} | j'ddg} d} |D]}| D]} d } | d k(r|j(r |j(} n;| d k(r|j*r |j*} n| dk(r|j,r |j,} | sat/|j| | d d }|j1||j3t5j6|j| dz } d|_|j!d|d| |j S#|j wxYw)aO Expand notification to individual deliveries per customer and channel Args: notification_id: Notification record ID Flow: 1. Resolve segment or single customer 2. For each customer, create Delivery records per channel (based on template.channel_strategy) 3. Enqueue deliver_message tasks z notification:z :not_foundtagsfailedz:no_recipientsprimaryemailrNtelegramvkpending)rchanneltargetstatusattempts processingz :enqueued:)rqueryrfilteridfirstclose customer_idr segment_idr tenant_idroverlapallrcommittemplatechannel_strategyget tg_chat_id vk_user_idrr addflushr delay)selfrdb notification customerscustomersegment filter_configr r,channelsdelivery_countrrdeliverys 3/var/www/notifications/app/workers/notifications.pyenqueue_notificationr> s.BCxx -44\__5WX^^` "?"3:>@  {  # #xx)00 @X@X1XY__aH%J  $ $hhw'..wzz\=T=T/TU[[]G ' 4" *11(2D2D H^H^2^_]*!LL)>)>}V?T)UVE!IIK "*L  IIK"?"3>BR  M(00AARYQZE[#'' G9=! (H# (j(X-@-@%00F_)<)<%00F'HNN%^^F'(4 '%(!"  HFF8$HHJ$))(++6"a'N3 ( (8+  /z.9IJ   s!A L'E.L&BLBLL$z&app.workers.notifications.cleanup_logscrt} t}|j}tjt |z }|j tjtjjdtj|kjd}|jd|d|d|jd|jS#t$r8}|j!d t#|cYd}~|jSd}~wwxYw#|jwxYw) uE Periodic task to clean up old delivery logs (retention policy) Удаляет записи доставки старше указанного периода (по умолчанию 90 дней). Использует поле sent_at для определения возраста записи. Удаляет только записи с установленным sent_at (завершенные доставки). Записи без sent_at (pending) не удаляются, так как они могут быть еще в обработке. )daysNF)synchronize_sessionz ok: deleted z delivery logs older than z days (cutoff: )zerror: )rr DELIVERY_LOG_RETENTION_DAYSrutcnowrr r r!sent_atisnotdeleter*dater$ Exceptionrollbackstr)r3r4settingsretention_days cutoff_date deleted_countes r= cleanup_logsrQ_s.B>!==oo')*HH *11    " "4 (   { *  &U& +  m_,F~FVVefqfvfvfxeyyz{  " Q!!  "  s0CC D!)DD!D$D!!D$$D6N)celeryrsqlalchemy.ormrrrapp.db.sessionr app.db.modelsrr r r app.workers.deliveriesr app.core.configr intrKr>rQr=r[sq"('CC2( $MNQQQOQh $EF###G#rZ