o 1dhY@s*ddlmZmZmZmZddlmZddlmZddl m Z ddl m Z ddl mZmZmZmZmZmZddlZddlmZmZed Zeeed d ed efd dZeeed d efddZeeed d efddZeeed d ed efddZeeed d efddZeeed d ed efddZ eeed d efddZ!eeed d ed efddZ"eeed d efddZ#eeed d ed efdd Z$eeed d efd!d"Z%eeed d ed efd#d$Z&d%efd&d'Z'd(ed)efd*d+Z(d,efd-d.Z)d/e*d0e+fd1d2Z,dd3l m-Z-dS)4) post_save post_deletepre_save pre_delete)receiver)cache)timezone) transaction) TVChannelBroadcastNetworkGeographicZoneChannelCoverageContentScheduleAudienceDemographicsN)AnyOptionalzadtlas.channels.signals)senderinstancecreatedc s$zn|rtdjdjdjrjjndntdjdjdddjd jd d g}jrL|d jjd jjg|D]}t|qNjr^t j|rlt fddWdSWdSt y}ztj djdt|ddWYd}~dSd}~ww)a Handle post-save operations for TV channels. Performs the following actions: - Clear relevant cache entries - Log channel creation/updates - Update network statistics - Trigger analytics updates Args: sender: The model class (TVChannel) instance: The saved channel instance created: Whether this is a new instance **kwargs: Additional keyword arguments zNew TV channel created:  (z ) on network NonezTV channel updated: )channel_statisticschannel_detail_channel_schedule_active_channels_listnetwork_channel_countsnetwork_channels_network_detail_c tdjS)NZchannel_created_schedule_analytics_updateidrr#IC:\Users\vibe-look\OneDrive\Desktop\Adtlas_V\src\apps\channels\signals.pyP z#channel_post_save..z&Error in channel post_save signal for : Texc_infoN)loggerinfoname call_signnetworkr"extendrdelete_update_network_channel_countr on_commit Exceptionerrorstrrrrkwargscache_keys_to_clear cache_keyer#r$r%channel_post_savesJ         r<c Ksz?td|jd|jdt|dr|jr|jjnd|_|jj t d }|dkr=td|jd |d WdSWdSt yb}ztjd |jd t|d dWYd}~dSd}~ww)a Handle pre-delete operations for TV channels. Performs cleanup operations before channel deletion: - Log the deletion - Store related data for post-deletion cleanup - Validate deletion constraints Args: sender: The model class (TVChannel) instance: The channel instance being deleted **kwargs: Additional keyword arguments zTV channel being deleted: rr_network_id_for_cleanupN)Z end_time__gterzDeleting channel z with z active schedule entriesz'Error in channel pre_delete signal for r(Tr))r+warningr-r.hasattrr/r"r=schedule_entriesfilterrnowcountr4r5r6)rrr8Zactive_schedulesr;r#r#r%channel_pre_deleteZs.  rDc szStdjdjdddjdjddg}|D]}t|q td d }|rHz tj j |d }t |Wn tj yGYnwt fd d Wd Styr}ztjdt|ddWYd }~d Sd }~ww)aV Handle post-delete operations for TV channels. Performs cleanup after channel deletion: - Clear cache entries - Update network statistics - Log the completion Args: sender: The model class (TVChannel) instance: The deleted channel instance **kwargs: Additional keyword arguments zTV channel deleted: rrrrrrrr=Nr"cr)NZchannel_deletedr r#r$r#r%r&r'z%channel_post_delete..z%Error in channel post_delete signal: Tr))r+r,r-r.r"rr1getattrr objectsgetr2 DoesNotExistr r3r4r5r6)rrr8r9r: network_idr/r;r#r$r%channel_post_deletes<        rKc Ksz5|r td|jn td|jddd|jd|jdg}|D]}t|q't|Wd StyX}ztjd|jd t |d d WYd }~d Sd }~ww) a  Handle post-save operations for broadcast networks. Args: sender: The model class (BroadcastNetwork) instance: The saved network instance created: Whether this is a new instance **kwargs: Additional keyword arguments zNew broadcast network created: zBroadcast network updated: network_listnetwork_statisticsrractive_networks_listz&Error in network post_save signal for r(Tr)N) r+r,r-r"rr1r2r4r5r6r7r#r#r%network_post_saves(    rOc Ksz&td|jddd|jd|jddg}|D]}t|qWd StyE}ztjdt|d d WYd }~d Sd }~ww) z Handle post-delete operations for broadcast networks. Args: sender: The model class (BroadcastNetwork) instance: The deleted network instance **kwargs: Additional keyword arguments zBroadcast network deleted: rLrMrrrNrz%Error in network post_delete signal: Tr)N) r+r>r-r"rr1r4r5r6rrr8r9r:r;r#r#r%network_post_deletes&     rQc Ksz<|rtd|jd|jdntd|jd|jdddd|jd|jd d g}|D]}t|q2WdSty_}ztjd |jd t |d dWYd}~dSd}~ww)a Handle post-save operations for geographic zones. Args: sender: The model class (GeographicZone) instance: The saved zone instance created: Whether this is a new instance **kwargs: Additional keyword arguments zNew geographic zone created: rrzGeographic zone updated: zone_listzone_statistics zone_detail_zone_channels_coverage_map_dataactive_zones_listz#Error in zone post_save signal for r(Tr)N) r+r,r- zone_typer"rr1r4r5r6r7r#r#r%zone_post_saves2    rYc Ksz,td|jd|jdddd|jd|jdd d g}|D]}t|q"WdStyK}ztjd t |d d WYd}~dSd}~ww)z Handle post-delete operations for geographic zones. Args: sender: The model class (GeographicZone) instance: The deleted zone instance **kwargs: Additional keyword arguments zGeographic zone deleted: rrrRrSrTrUrVrWrz"Error in zone post_delete signal: Tr)N) r+r>r-rXr"rr1r4r5r6rPr#r#r%zone_post_delete1s,     rZc Ksz\|rtd|jjd|jjd|jdntd|jjd|jjd|jdddd|jjd |jjd |jjd |jjd g}|D]}t|qKt |j|jWdSt y{}ztj d t |ddWYd}~dSd}~ww)a  Handle post-save operations for channel coverage. Args: sender: The model class (ChannelCoverage) instance: The saved coverage instance created: Whether this is a new instance **kwargs: Additional keyword arguments z#New coverage relationship created:  in rz%)zCoverage relationship updated: rVcoverage_statisticschannel_coverage_zone_coverage_rrTrz$Error in coverage post_save signal: Tr)N) r+r,channelr-zonecoverage_percentager"rr1_update_coverage_statisticsr4r5r6r7r#r#r%coverage_post_saveYsD         rcc Ksz9td|jjd|jjddd|jjd|jjd|jjd|jjd g}|D]}t|q/Wd StyX}ztj d t |d d WYd }~d Sd }~ww)z Handle post-delete operations for channel coverage. Args: sender: The model class (ChannelCoverage) instance: The deleted coverage instance **kwargs: Additional keyword arguments zCoverage relationship deleted: r[rVr\r]r^rrTrz&Error in coverage post_delete signal: Tr)N) r+r,r_r-r`r"rr1r4r5r6rPr#r#r%coverage_post_deletes0        rdc Ksz:|rtd|jd|jjd|jd|jjd|jjddg}|D]}t|q'|r8t |Wd SWd St yY}ztj dt |d d WYd }~d Sd }~ww) a  Handle post-save operations for content schedules. Args: sender: The model class (ContentSchedule) instance: The saved schedule instance created: Whether this is a new instance **kwargs: Additional keyword arguments zNew schedule entry created:  on z at rrZupcoming_programsZschedule_statisticsz$Error in schedule post_save signal: Tr)N) r+r, program_titler_r- start_timer"rr1_check_schedule_conflictsr4r5r6r7r#r#r%schedule_post_saves4      ric KszH|jr@|jrC|j|jkrtd|jd|jd|jd|j|j}|dkrFtd|jd|dd d WdSWdSWdSWdStyg}ztjd t|d d WYd}~dSd}~ww)aw Handle pre-save operations for content schedules. Validates schedule data before saving: - Ensure end time is after start time - Check for reasonable duration - Validate time zones Args: sender: The model class (ContentSchedule) instance: The schedule instance being saved **kwargs: Additional keyword arguments zInvalid schedule timing for z : end time (z) is not after start time (riQz#Long program duration detected for r(z.1fz hoursz#Error in schedule pre_save signal: Tr)N) end_timergr+r5rf total_secondsr>r4r6)rrr8durationr;r#r#r%schedule_pre_saves4          rnc szE|rtdjjdjdjjdjjddg}|D]}t|q#t jj dkrCt fdd Wd SWd Styd}ztjd t|d d WYd }~d Sd }~ww)a Handle post-save operations for audience demographics. Args: sender: The model class (AudienceDemographics) instance: The saved demographics instance created: Whether this is a new instance **kwargs: Additional keyword arguments z"New demographics data created for reZchannel_demographics_rZdemographics_statisticsZaudience_trendscstdjjS)NZdemographics_updated)r!r_r"r#r$r#r%r&%sz(demographics_post_save..z(Error in demographics post_save signal: Tr)N)r+r,r_r-measurement_dater"rr1rrBdatedaysr r3r4r5r6r7r#r$r%demographics_post_saves4        rsr/c Csz0|jjdd}|j}tjd|j||dddtd|jd|d |d Wd St yQ}zt d |jdt |WYd }~d Sd }~ww) z{ Update the channel count for a broadcast network. Args: network: The broadcast network to update T) is_activeZnetwork_channel_count_)activetotalrjtimeoutz"Updated channel count for network r(z active, z totalz)Error updating network channel count for N) channelsrArCrsetr"r+debugr-r4r5r6)r/ active_count total_countr;r#r#r%r23s*    r2r_r`c CszOtjj|d}|r#|jtddd}tjd|j |ddtjj|d}|rM| |jtdddd }tjd |j |ddWd SWd St yl}zt d t|WYd }~d Sd }~ww) z Update coverage statistics for a channel and zone. Args: channel: The TV channel zone: The geographic zone )r_ra)avgr~Zchannel_avg_coverage_rjrw)r`) channel_count avg_coverageZzone_coverage_stats_z$Error updating coverage statistics: N)r rGrAexists aggregatemodelsAvgrrzr"rCr4r+r5r6)r_r`channel_coveragerZ zone_coverageZ zone_statsr;r#r#r%rbPsD    rbschedulec CszR|jsWdStjj|j|j|jdj|jd}|rM| }t d|j d|jj d|d|ddD]}t d |j d |jd |jd q8WdSWdStyo}zt d t|WYd}~dSd}~ww)z} Check for schedule conflicts with existing programs. Args: schedule: The content schedule to check N)r_Zstart_time__ltZ end_time__gtrEzSchedule conflict detected for rer(z overlapping programsz Conflicts with: rz - rz#Error checking schedule conflicts: )rkrrGrAr_rgexcluder"rrCr+r>rfr-r4r5r6)r conflictsZconflict_countZconflictr;r#r#r%rh|sF   rh event_type object_idc Cslztd|d|tdtdWdSty5}ztdt|WYd}~dSd}~ww)z Schedule an analytics update for background processing. Args: event_type: Type of event that triggered the update object_id: ID of the object that changed zAnalytics update scheduled: z for object Zanalytics_summaryZchannel_performance_metricsz#Error scheduling analytics update: N)r+r,rr1r4r5r6)rrr;r#r#r%r!s  r!)r).Zdjango.db.models.signalsrrrrdjango.dispatchrdjango.core.cacher django.utilsr django.dbr Zchannels.modelsr r r r rrloggingtypingrr getLoggerr+boolr<rDrKrOrQrYrZrcrdrirnrsr2rbrhr6intr!rr#r#r#r%sL        A ( 8 & $ ( ' . ( ' +-,&