o PXhor@sjdZddlmZmZmZmZmZddlmZddl m Z ddl m Z ddl mZddlmZddlmZdd lmZdd lmZdd lZdd lZdd lmZmZdd lmZddlmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'ddl(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.ddl/m0Z0m1Z1eZ2e3e4Z5eeedddZ6eeedddZ7eeedddZ8eeedddZ9eeedddZ:eee dddZ;eee!ddd Zeee$dd%d&Z?eeej@jAdd'd(ZBeee&dd)d*ZCed+d,ZDed-d.ZEed/d0ZFd1d2ZGd9d3d4ZHeeedd5d6ZIed7d8ZJd S):aCreative Management Signal Handlers Django signal handlers for creative asset management. Handles automated tasks, logging, notifications, and data integrity. Signal Categories: - Model Signals: pre_save, post_save, pre_delete, post_delete - File Signals: File upload, deletion, and processing - Approval Signals: Approval workflow automation - Performance Signals: Performance data updates - Compliance Signals: Compliance checking automation - Notification Signals: Email and system notifications - Cache Signals: Cache invalidation and updates - Audit Signals: Activity logging and tracking Handlers: - creative_pre_save: Pre-save processing - creative_post_save: Post-save automation - creative_post_delete: Cleanup after deletion - file_upload_handler: Handle file uploads - approval_status_changed: Handle approval changes - performance_updated: Handle performance updates - compliance_checked: Handle compliance results - version_created: Handle version creation - asset_uploaded: Handle asset uploads Integrations: - Celery for async tasks - Email notifications - Cache management - File storage cleanup - Audit logging - Performance tracking )pre_save post_save pre_delete post_delete m2m_changed)receiver)cache)timezone)get_user_model) send_mail)render_to_string)settings) transactionN)datetime timedelta) shared_task) CreativeCreativeVersion CreativeAssetCreativeApprovalCreativePerformanceCreativeComplianceCreativeTemplate CreativeTagCreativeVariantCreativeFormat)process_creative_filecheck_compliancegenerate_thumbnailsextract_metadatasend_approval_notificationupdate_performance_metrics)get_file_metadatavalidate_creative_file)senderc KsDzt|_|js|jrtj|jj}tj|d|_|jr]|j r]tj|jjd }gdgdgdddggdd }|j |vr]|||j vr]t d |j d |d |j|j d ured|_ |jd urt|jrqd|_nd|_t d|jd|jdWd Sty}zt dt|WYd }~d Sd }~ww)z Handle creative pre-save operations. Args: sender: Model class instance: Creative instance **kwargs: Additional arguments rr).jpg.jpeg.png.gif.webp)z.mp4z.movz.aviz.webm)z.mp3z.wavz.aacz.ogg.htmlz.htm)r&r'r(r)r*r+)imageZvideoZaudioZhtmlZbannerzCreative type 'z ' doesn't match file extension 'z' for creative: NZ processingZdraftzCreative pre-save: z (Status: )zError in creative pre-save: )r nowZ updated_atname primary_fileospathbasenamesplitextZ creative_typelowerloggerwarningprioritypkcreative_statusinfo Exceptionerrorstr)r%instancekwargsfilenameZfile_extZtype_extensionsexcrDapps/creatives/signals.pycreative_pre_saveCs>      ""rFc sz|r?tdjdjdjr.tjjdjjpddj dt fdd j r>j j r>t fd d nLtd jdjdj d rwjrwjd}tjj|jjphdd jdt fdd j drjdkrt fdd djjrdjndddg}td|D]}t|qWdSty}ztdt|WYd}~dSd}~ww)z Handle creative post-save operations. Args: sender: Model class instance: Creative instance created: Whether instance was created **kwargs: Additional arguments zNew creative created:  (ID: r.rrzInitial version)creativeversion_numberfile file_sizeZchanges created_byc tjSNrdelayr:rDr@rDrE z$creative_post_save..crMrN)send_creation_notificationrPr:rDrQrDrErRrSzCreative updated: r1z File updatedcrMrNrOrDrQrDrErRrSr;approvedcstjdS)NrU)send_status_notificationrPr:rDrQrDrErR creative_creative_list_Ncreative_statsdashboard_statszError in creative post-save: )r7r<r0r:r1robjectsZcreaterKrLr on_commitemailZtrackerZ has_changedversionscountZ updated_byr; campaign_idfilterrdeleter=r>r?)r%r@createdrArI cache_keyskeyrCrDrQrEcreative_post_savezsh        "rgc KszNtd|jd|jdg}|jr||jj|jr%||jj|j D] }|j r6||j jq*|j D] }|j rH||j jq<||_ WdSt yk}ztdt|WYd}~dSd}~ww)z Handle creative pre-delete operations. Args: sender: Model class instance: Creative instance **kwargs: Additional arguments zCreative being deleted: rGr.zError in creative pre-delete: N)r7r<r0r:r1appendr3Z thumbnailr_allrJZassets_files_to_deleter=r>r?)r%r@rAfiles_to_deleteversionZassetrCrDrDrEcreative_pre_deletes(  "rmc Kszktd|jt|dg}|D]6}ztj|r(t|td|WqtyH}zt d|dt |WYd}~qd}~wwd|j |j rWd|j ndd d g}t d|D]}t|qaWdSty}ztd t |WYd}~dSd}~ww) z Handle creative post-delete cleanup. Args: sender: Model class instance: Creative instance **kwargs: Additional arguments zCreative deleted: rjzDeleted file: zCould not delete file : NrXrYrZr[zError in creative post-delete: )r7r<r0getattrr2r3existsremover=r8r?r:rarbrrcr>)r%r@rArkZ file_pathrCrerfrDrDrEcreative_post_deletes2    &  "rrc sz>|r9tdjjdjjjjkr*jr*jj_jjdgdj r.zError in version creation: N)r7r<rHr0rIr_r`rKsaverJrr]r=r>r?r%r@rdrArCrDrQrEversion_createds&     "rwc sz<|r4jr7tdjdjjjr#jj_jdgdjdkr:t fddWd SWd SWd SWd St yY}zt dt |WYd }~d Sd }~ww) z Handle creative asset upload. Args: sender: Model class instance: CreativeAsset instance created: Whether instance was created **kwargs: Additional arguments zNew asset uploaded:  for creative rKrsr,crtrN)rrPrHr:rDrQrDrErRVrWz asset_uploaded..zError in asset upload: N)rJr7r<r0rHsizerKruZ asset_typerr]r=r>r?rvrDrQrEasset_uploaded=s$      "rzc szP|rKtdjjdjjdkr.dj_jjdgdtfddWd SjdkrNdj_jjdgdtfd dWd SWd SWd St ym}zt d t |WYd }~d Sd }~ww) z Handle approval status changes. Args: sender: Model class instance: CreativeApproval instance created: Whether instance was created **kwargs: Additional arguments zApproval created:  - rUr;rsctjjjjjjSrNr!rPrHr:approval_statusZreviewerZcommentsrDrQrDrErRv z)approval_status_changed..Zrejectedcr|rNr}rDrQrDrErRrz!Error in approval status change: N) r7r<rHr0r~r;rurr]r=r>r?rvrDrQrEapproval_status_changed^s.      "rc KszQtd|jjd|j|j}|jjtdtdtdd}|dp)d|_ |d p0d|_ |d p7d|_ |j gd d t d |jt dWdStyn}ztdt|WYd}~dSd}~ww)z Handle performance data updates. Args: sender: Model class instance: CreativePerformance instance created: Whether instance was created **kwargs: Additional arguments zPerformance updated: r{ impressionsclicks conversions)total_impressions total_clickstotal_conversionsrrrr)rrrrscreative_performance_performance_statszError in performance update: N)r7r<rHr0dateperformance_data aggregatemodelsSumrrrrurrcr:r=r>r?)r%r@rdrArHrrCrDrDrEperformance_updateds( "rc sz7tdjjdjj}jdk|_j|_|jddgdjdkr5t fdd Wd SWd St yT}zt d t |WYd }~d Sd }~ww) z Handle compliance check results. Args: sender: Model class instance: CreativeCompliance instance created: Whether instance was created **kwargs: Additional arguments zCompliance checked: r{Z compliant is_compliantcompliance_scorersZ non_compliantcrMrN)send_compliance_notificationrPr:rDrQrDrErRrSz$compliance_checked..zError in compliance check: N) r7r<rHr0Zcompliance_statusrrrurr]r=r>r?)r%r@rdrArHrCrDrQrEcompliance_checkeds"     "rc Ksz&|r td|jn td|jtdtd|jWdStyC}ztdt|WYd}~dSd}~ww)z Handle template updates. Args: sender: Model class instance: CreativeTemplate instance created: Whether instance was created **kwargs: Additional arguments zNew template created: zTemplate updated: Z template_listZ template_zError in template update: N r7r<r0rrcr:r=r>r?rvrDrDrEtemplate_updateds  "rc Ksz'|dvr%td|d|jd|td|jtdWdSWdStyD}ztdt|WYd}~dSd}~ww) z Handle creative tag changes. Args: sender: Through model class instance: Creative instance action: M2M action (post_add, post_remove, etc.) pk_set: Set of tag PKs **kwargs: Additional arguments )Zpost_addZ post_removezTags z for creative: z - Tags: creative_tags_ tag_statszError in tag change: Nr)r%r@actionZpk_setrArCrDrDrEcreative_tags_changeds  "rc Ksz:|r5td|jd|jj|jjjtdddpd}|dkr8t d|jjd |d Wd SWd SWd St yW}zt d t |WYd }~d Sd }~ww) z Handle creative variant creation. Args: sender: Model class instance: CreativeVariant instance created: Whether instance was created **kwargs: Additional arguments zNew variant created: rxZtraffic_allocation)totalrrdz-Traffic allocation exceeds 100% for creative rn%zError in variant creation: N) r7r<Z variant_namerHr0Zvariantsrrrr8r=r>r?)r%r@rdrAZtotal_allocationrCrDrDrEvariant_created s,   "rc CszDtjj|d}|jr?|jjrBd|j}||jd}td|}td|}t|||tj |jjgddt d|jWd SWd SWd Stj yWt d |Yd Stys}zt d t|WYd }~d Sd }~ww) zd Send creative creation notification. Args: creative_id (int): Creative ID idzCreative Created: )rHuserz+creatives/emails/creation_notification.htmlz*creatives/emails/creation_notification.txtTsubjectmessage html_messageZ from_emailZrecipient_listZ fail_silentlyz)Creation notification sent for creative: Creative not found: z%Error sending creation notification: Nrr\getrLr^r0r r r DEFAULT_FROM_EMAILr7r< DoesNotExistr>r=r?) creative_idrHrcontextr plain_messagerCrDrDrErT-s2    "rTc CszEtjj|d}|jr@|jjrCd|j}|||jd}td|}td|}t|||tj |jjgddt d|jWd SWd SWd Stj yXt d |Yd Styt}zt d t|WYd }~d Sd }~ww) z Send creative status change notification. Args: creative_id (int): Creative ID status (str): New status rzCreative Status Changed: )rHstatusrz)creatives/emails/status_notification.htmlz(creatives/emails/status_notification.txtTrz'Status notification sent for creative: rz#Error sending status notification: Nr)rrrHrrrrrCrDrDrErVTs4     "rVc CszHtjj|d}|j}|jrC|jjrFd|j}|||jd}td|}td|}t|||t j |jjgddt d|jWd SWd SWd Stj y[t d |Yd Styw}zt d t|WYd }~d Sd }~ww) zi Send compliance notification. Args: compliance_id (int): CreativeCompliance ID rzCompliance Issue: )rH compliancerz-creatives/emails/compliance_notification.htmlz,creatives/emails/compliance_notification.txtTrz+Compliance notification sent for creative: zCompliance record not found: z'Error sending compliance notification: N)rr\rrHrLr^r0r r r rr7r<rr>r=r?)Z compliance_idrrHrrrrrCrDrDrEr}s6    "rcCsNd|d|d|dddddg}|D]}t|qtd |d S) zl Invalidate all caches related to a creative. Args: creative_id (int): Creative ID rXrrZ creative_listrZr[rrz!Caches invalidated for creative: N)rrcr7r<)rrerfrDrDrEinvalidate_creative_cachess rc Csz.t|j|j||r|jnd|r|jnd|pid}td|d|jd|WdStyK}zt dt |WYd}~dSd}~ww)z Log creative activity for audit purposes. Args: creative (Creative): Creative instance action (str): Action performed user (User): User who performed action details (dict): Additional details N)Z timestamprZ creative_namerZuser_idZ user_emaildetailszCreative activity: r{z by z!Error logging creative activity: ) r r/Z isoformatr:r0r^r7r<r=r>r?)rHrrrZ log_entryrCrDrDrElog_creative_activitys   $ "rc szm|sbjdkrejrjjdndjr jjdnddkr>tdjdddtfdd d krhjdkrktd jd ddtfd d WdSWdSWdSWdSWdSty}zt dt |WYd}~dSd}~ww)z Monitor creative performance and trigger alerts. Args: sender: Model class instance: Creative instance created: Whether instance was created **kwargs: Additional arguments rrg?zLow CTR alert: z - CTR: z.2frctjdS)NZlow_ctrsend_performance_alertrPr:rD)ctrr@rDrErRz.monitor_creative_performance..g?zLow conversion rate alert: z - Rate: cr)NZlow_conversionrrD)conversion_rater@rDrErRrz'Error monitoring creative performance: N) rrrr7r8r0rr]r=r>r?rvrD)rrr@rEmonitor_creative_performances0     "rc Csz]tjj|d}g}|jr|jjr||jj|jr,|jjr,|jjjr,||jjj|r[d|j}|||d}t d|}t d|}t |||t j |ddt d|jWd SWd Stjypt d |Yd Sty} zt d t| WYd } ~ d Sd } ~ ww) z Send performance alert notification. Args: creative_id (int): Creative ID alert_type (str): Type of alert metric_value (float): Metric value that triggered alert rzPerformance Alert: )rH alert_type metric_valuez'creatives/emails/performance_alert.htmlz&creatives/emails/performance_alert.txtTrz%Performance alert sent for creative: rz!Error sending performance alert: N)rr\rrLr^rhZcampaignZmanagerr0r r r rr7r<rr>r=r?) rrrrHZ recipientsrrrrrCrDrDrEr s>     "r)NN)K__doc__Zdjango.db.models.signalsrrrrrZdjango.dispatchrZdjango.core.cacherZ django.utilsr Zdjango.contrib.authr Zdjango.core.mailr Zdjango.template.loaderr Z django.confr Z django.dbrZloggingr2rrZceleryrrrrrrrrrrrrZtasksrrrr r!r"Zutilsr#r$ZUserZ getLogger__name__r7rFrgrmrrrwrzrrrrZtagsZthroughrrrTrVrrrrrrDrDrDrEsn#         0     6  Q  &  '  !   2  %      & ( )  )