o Սdh~@sdZddlmZddlmZddlmZddlmZddl m Z ddl m Z ddl mZdd lmZdd lZdd lZdd lZdd lZdd lmZmZdd lmZmZdd lmZdd lZdd lZdd lZddlm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&ddl'm(Z(m)Z)m*Z*m+Z+m,Z,eZ-e.e/Z0edddddZ1eddZ2eddZ3d@ddZ4dAddZ5ed d!Z6ed"d#Z7ed$d%Z8d&d'Z9d(d)Z:d*d+Z;ed,d-Zed3d4Z?ed5d6Z@edBd7d8ZAedDd:d;ZBdd?ZDd S)EaiCreative Management Asynchronous Tasks Celery tasks for creative asset processing and management. Handles file processing, optimization, compliance checking, and notifications. Task Categories: - File Processing: Upload, conversion, optimization - Compliance: Automated compliance checking - Performance: Analytics and reporting - Notifications: Email and system notifications - Cleanup: File cleanup and maintenance - Batch Operations: Bulk processing tasks Tasks: - process_creative_file: Process uploaded creative files - optimize_creative: Optimize creative assets - check_compliance: Check creative compliance - generate_thumbnails: Generate preview thumbnails - extract_metadata: Extract file metadata - send_approval_notification: Send approval notifications - cleanup_old_versions: Clean up old file versions - batch_process_creatives: Process multiple creatives - update_performance_metrics: Update performance data - generate_creative_report: Generate performance reports Integrations: - FFmpeg for video processing - Pillow for image processing - External compliance APIs - Email services - Cloud storage services ) shared_task) send_mail)settings)timezone) ContentFile)default_storage)render_to_string)get_user_modelN)datetime timedelta)ImageImageOps)BytesIO)CreativeCreativeVersion CreativeAssetCreativeApprovalCreativePerformanceCreativeComplianceCreativeFormat)get_file_metadatavalidate_creative_filegenerate_thumbnailoptimize_imagecompress_videoT)bind max_retriesc Cs6ztjj|d}|jstdtd|jd|dd|_| ||jj gd}t |}|d d t |}|d d t|jj }|d s]d |_| td |d|d d|jdkrvt |}|d dn|jdkrt |}|d dt |}|d dd|_| t |ddtd|j|WStjytd|ty} zQtd|dt| ztjj|d}d|_| Wn tjyYnw|jj|jkr td||jd|jjdd t |d!d"t| d#} ~ ww)$z Process uploaded creative file. Args: creative_id (int): Creative instance ID Returns: dict: Processing results idNo file to processzProcessing creative file: z (ID: ) processing) creative_id file_pathprocessing_stepsr&Zmetadata_extractionZthumbnail_generationis_validrejectedzFile validation failed: errorsZfile_validationimageZimage_optimizationvideoZvideo_optimizationZcompliance_checkpending_review completedz&File processing completed successfullyz$Creative file processing completed: Creative not found: zError processing creative file : draftzRetrying creative processing: <r) countdownfailedzFile processing failed: N)robjectsget primary_file ValueErrorloggerinfonamecreative_statussavepathextract_metadatadelayappendgenerate_thumbnailsr creative_typeoptimize_image_taskoptimize_video_taskcheck_compliancesend_processing_notification DoesNotExisterror Exceptionstrrequestretriesrretry) selfr$creativeresultsZ metadata_taskZthumbnail_taskZvalidation_resultZ optimize_taskZcompliance_taskexcrRHC:\Users\vibe-look\OneDrive\Desktop\Adtlas_V\src\apps\creatives\tasks.pyprocess_creative_fileDsz           rTc CszItjj|d}|jsddiWStd|jt|jj}d|vr(|d|_ d|vr1|d|_ d|vr:|d|_ | td|j|WStj y_td |dd iYSty}ztd |d t|dt|iWYd }~Sd }~ww)z Extract metadata from creative file. Args: creative_id (int): Creative instance ID Returns: dict: Extracted metadata rrHr!z"Extracting metadata for creative: file_sizeduration dimensionsz!Metadata extracted for creative: r.Creative not foundz'Error extracting metadata for creative r/N)rr4r5r6r8r9r:rr=rUrVrWr<rGrHrIrJ)r$rOmetadatarQrRrRrSr>s.       r>c Cs`zutjj|d}|jsddiWStd|jd}|jdkr't|jj }n |jdkr2t |jj }|rqt |d}|j j d |jd t|d d Wdn1sVwYt|td |jd |j jdWSddiWStjytd|ddiYSty}ztd|dt|dt|iWYd}~Sd}~ww)z Generate thumbnails for creative. Args: creative_id (int): Creative instance ID Returns: dict: Thumbnail generation results rrHr!z$Generating thumbnails for creative: Nr*r+rbZthumb_.jpgTr<z"Thumbnail generated for creative: )successthumbnail_pathzCould not generate thumbnailr.rXz)Error generating thumbnails for creative r/)rr4r5r6r8r9r:rBgenerate_image_thumbnailr=generate_video_thumbnailopen thumbnailr<r rreadosremoveurlrGrHrIrJ)r$rOr^Z thumb_filerQrRrRrSrAs<           rA,rhc CszBt|2}|jdvr|d}||tjjdt|  d}|j |ddd|WdWS1s;wYWdSt y_}zt d t|WYd}~dSd}~ww) z Generate thumbnail for image file. Args: image_path (str): Path to image file size (tuple): Thumbnail size Returns: str: Path to generated thumbnail )ZRGBAZLAPRGB /tmp/thumb_r[ZJPEGU)qualityNz"Error generating image thumbnail: )r ramodeconvertrbZ ResamplingZLANCZOShashlibmd5encode hexdigestr<rIr8rHrJ)Z image_pathsizeimg thumb_pathrQrRrRrSr_ s   (r_00:00:01c Cszsz#check_compliance..drPrr compliant non_compliant)compliance_statuscompliance_scorecompliance_data checked_at)rOdefaultsz)Compliance check completed for creative: z (Score: z.1fr"r.rHrXz'Error checking compliance for creative r/N)rr4r5r8r9r:check_file_format_compliancer@rBcheck_content_compliancecheck_technical_compliancesumlenextendrrr<r get_or_creaternowrrrrGrHrIrJ) r$rOZcompliance_resultsZ format_checkZ content_checkZtechnical_checkZ total_scoreZ max_scorer compliancecreatedrQrRrRrSrEsb            rEc Csddgd}z|jsd|d<|dd|WStj|jjd}gd gd gd d d ggdd}|j|vrT|||jvrT|dd8<|dd||jrk|jdkrk|dd8<|dd|jdkr|j rt t |j d\}}|dks|dkr|dd8<|dd|WSt y}z"tdt|d|d<|ddt||WYd}~Sd}~ww)z Check file format compliance. Args: creative (Creative): Creative instance Returns: dict: Format compliance results Z file_formatrZ check_typerrrrrzNo file uploadedr)r[.jpeg.png.gif.webp)z.mp4z.movz.aviz.webm)z.mp3z.wavz.aacz.ogg.htmlz.htm)r[rrrrr)r*r+audiohtmlbannerzInvalid file extension: i zFile size exceeds 50MB limitr*xi z'Image dimensions exceed 4096x4096 limitz'Error in file format compliance check: zError checking file format: N)r6r@rdr=splitextr:lowerrBrUrWmapintsplitrIr8rHrJ)rOrfile_extallowed_extensionswidthheightrQrRrRrSr sH  rc Csddgd}zddl}|dd}|dkr!||d <|d d |WStyQ}z"td t|d|d <|d d t||WYd}~Sd}~ww)z Check content compliance using external API. Args: creative (Creative): Creative instance Returns: dict: Content compliance results contentrrrNr_rrrz%Content may violate platform policiesz#Error in content compliance check: zError checking content: )timesleepr@rIr8rHrJ)rOrrZ content_scorerQrRrRrSrDs&  rc Csddgd}z|jrWz4|jdkr,t|jj }|Wdn1s&wYn|jdkr=tj|jjs=tdWnt yV|dd 8<|d  d Ynw|j si|dd 8<|d  d |jdvr|j s|dd 8<|d  d|jdkr|j s|dd 8<|d  d|WSt y}z"tdt|d|d<|d  dt||WYd}~Sd}~ww)z Check technical compliance. Args: creative (Creative): Creative instance Returns: dict: Technical compliance results Z technicalrrr*Nr+zVideo file not foundr2rzFile appears to be corruptedrzMissing file size informationrzMissing dimensions informationzMissing duration informationz%Error in technical compliance check: rz%Error checking technical compliance: )r6rBr rar=verifyrdr~r7rIr@rUrWrVr8rHrJ)rOrrurQrRrRrSrlsH     rc CszOtjj|d}|jrI|jjrId|d|j}||||jd}td|}td|}t|||t j |jjgddt d |jd d d WSd dd d WStj yet d|ddiYSty}zt dt|dt|iWYd}~Sd}~ww)z Send processing notification. Args: creative_id (int): Creative instance ID status (str): Processing status message (str): Notification message Returns: dict: Notification results rzCreative Processing r/)rOstatusruserz-creatives/emails/processing_notification.htmlz,creatives/emails/processing_notification.txtFsubjectr html_message from_emailrecipient_list fail_silentlyz+Processing notification sent for creative: Tr] email_sentNo email addressr]rrr.rHrXz'Error sending processing notification: N)rr4r5 created_byemailtitler:rrrDEFAULT_FROM_EMAILr8r9rGrHrIrJ) r$rrrOrcontextr plain_messagerQrRrRrSrFs<     rFc Cs>zWtjj|d}tjj|d}|jrQ|jjrQd|d|j}|||||jd}td|}td|} t || |t j |jjgddt d |jd d d WSd dd d WStjtjfy}} zt dt| dt| iWYd} ~ Sd} ~ wty} zt dt| dt| iWYd} ~ Sd} ~ ww)a" Send approval notification. Args: creative_id (int): Creative instance ID approval_status (str): Approval status reviewer_id (int): Reviewer user ID comments (str): Optional comments Returns: dict: Notification results r Creative r/)rOapproval_statusreviewercommentsrz+creatives/emails/approval_notification.htmlz*creatives/emails/approval_notification.txtFrz)Approval notification sent for creative: TrrrzObject not found: rHNz%Error sending approval notification: )rr4r5Userrrrr:rrrrr8r9rGrHrJrI) r$r reviewer_idrrOrrrrrrQrRrRrSsend_approval_notificationsB   rrc Cszgtt|d}tjj|djdd}d}d}|D]9}|jrLz|jj}|j ||7}Wnt yK}zt dt |WYd}~nd}~ww| |d7}qt d|d |d d ||d WSt y}zt d t |dt |iWYd}~Sd}~ww)z Clean up old creative versions. Args: days (int): Number of days to keep versions Returns: dict: Cleanup results )days)Zcreated_at__ltr)Z"creative__versions__version_numberrzError deleting version file: Nz Cleaned up z old versions, freed z bytesT)r] deleted_count freed_spacez Error cleaning up old versions: rH)rrr rr4filterexcludefilertdeleterIr8warningrJr9rH)r cutoff_dateZ old_versionsrrversionrUrQrRrRrScleanup_old_versionss@     rc Cs\z tddddWSty-}ztdt|dt|iWYd}~Sd}~ww)z[ Clean up orphaned creative files. Returns: dict: Cleanup results zOrphaned file cleanup completedT)r]rz"Error cleaning up orphaned files: rHN)r8r9rIrHrJ)rQrRrRrScleanup_orphaned_files?s  rc CszTt|ddgd}|D]:}zt||dd7<Wq tyF}z|dd7<|dd|dt|WYd }~q d }~wwtd |dd |WStyv}ztd t|d t|iWYd }~Sd }~ww)z Process multiple creatives in batch. Args: creative_ids (list): List of creative IDs Returns: dict: Batch processing results r)total processedr3r)rrr3r)rr/NzBatch processing initiated for z creativeszError in batch processing: rH) rrTr?rIr@rJr8r9rH)Z creative_idsrPr$rQrRrRrSbatch_process_creativesTs,  *rc CsBzitjj|d}|rt|d}nt}dddddd}tjj |||d \}}tjj |d j t d t d t d d}|dpGd|_|dpNd|_|dpUd|_|td|jd|dWStjytd|ddiYSty}ztdt|dt|iWYd}~Sd}~ww)z Update performance metrics for creative. Args: creative_id (int): Creative instance ID date (str): Date for metrics (YYYY-MM-DD) Returns: dict: Update results rz%Y-%m-%dirgY@g@o@) impressionsclicks conversionsspendrevenue)rOdater)rOrrr)total_impressions total_clickstotal_conversionsrrrrz*Performance metrics updated for creative: T)r]rr.rHrXz$Error updating performance metrics: N)rr4r5r strptimerrrrupdate_or_creater aggregatemodelsSumrrrr<r8r9r:rGrHrIrJ) r$rrOZ metric_dateperformance_data performancerZtotal_performancerQrRrRrSupdate_performance_metricsxsL      rrc Csz;tjj|d}td|d|j|dkrt|}n|dkr&t|}ntd|td|jd|d WStj yQt d |d d iYSt yr}zt d t |d t |iWYd}~Sd}~ww)z Generate creative report. Args: creative_id (int): Creative instance ID report_type (str): Type of report to generate Returns: dict: Report generation results rz Generating z report for creative: rrzUnknown report type: zReport generated for creative: T)r] report_datar.rHrXzError generating report: N) rr4r5r8r9r:generate_performance_reportgenerate_compliance_reportr7rGrHrIrJ)r$Z report_typerOrrQrRrRrSgenerate_creative_reports$     rcCsR|jddd}|j|j|j|j|jr|j|jdnddd|DdS) z Generate performance report data. Args: creative (Creative): Creative instance Returns: dict: Performance report data z-dateNrrrcSs&g|]}|j|j|j|jdqS))rrrr)r isoformatrrr)rprRrRrS sz/generate_performance_report..) creative_namerrrctrZdaily_performance)rallorder_byr:rrr)rOrrRrRrSrs rcCs<|j}|j|j|j|r|jnd|r|jdSddS)z Generate compliance report data. Args: creative (Creative): Creative instance Returns: dict: Compliance report data N)rrrZcompliance_detailsZ last_checked)rfirstr:rrrr)rOrrRrRrSrs   r)rg)rw)N)r)r)E__doc__celeryrdjango.core.mailr django.confr django.utilsrdjango.core.files.baserdjango.core.files.storagerdjango.template.loaderrdjango.contrib.authr rdjsonloggingr{r r PILr r iorrequestsrp mimetypesrrrrrrrrutilsrrrrrr getLogger__name__r8rTr>rAr_r`rCrDrErrrrFrrrrrrrrrRrRrRrSsp !        $   d ,  3 & 2 3 R;(7 3 7 /  # > %