B *gW@s`ddlmZddlmZddlmZddlmZddlm Z ddl Z ddl Z ddl Z ddl mZmZmZmZddlmmZGd d d Zd d ZGd ddZGdddZGdddZd-ddZddlm Z mZGdddZddZddZd d!Z e!ee!d"d#d$Z"e!eej#d%d&d'Z$d.ej#e!ee!e!feee!efd(d)d*Z%d+d,Z&dS)/)wraps)HttpResponseForbidden)redirect)Users)FTPN)DictAnyOptionalListc@seZdZdddZddZdS) TelegramLog.6723497869:AAEKCB3YJUGnUFeMihLlr-FHblTuvtoVUZA -4155125438cCs||_||_dS)N) BOT_TOKENGROUP_ID)selfrrr8/var/www/html/DAI27/Adtlas_DAI/DAIManagementApp/utils.py__init__szTelegramLog.__init__cCst|j}||j|dS)N)telebotZTeleBotr send_messager)rmessagebotrrrsend_telegram_logs zTelegramLog.send_telegram_logN)r r)__name__ __module__ __qualname__rrrrrrr s r cstfdd}|S)NcsVd|jkrJ|jdrJ|jddkrJtjj|jdddkrJ|f||StdSdS)Nid_user)rlogin)sessionrobjectsfilterr)requestargskwargs)funcrrwrappers:zcheck_user..wrapper)r)r%r&r)r%r check_usersr'c@seZdZddZdS) NoVastResultcCs||_||_t||_dS)N) id_campaign total_adsinttotal_impressions)rr)r*r,rrrr%szNoVastResult.__init__N)rrrrrrrrr($sr(c@seZdZddZdS) VastResultcCs||_||_t||_dS)N)r)r*r+r,)rr)r*r,rrrr+szVastResult.__init__N)rrrrrrrrr-*sr-c@s6eZdZd ddZddZddZd d Zd d ZdS) FTPClientNcCs&||_||_||_||_||_dS)N) ftp_serverportusernamepassword _setup_loggerlogger)rr0r1r2r3rrrr2s zFTPClient.__init__cCs@tt}|tjtd}t}|||||S)Nz)%(asctime)s - %(levelname)s - %(message)s) logging getLoggerrsetLevelINFO Formatter StreamHandler setFormatter addHandler)rr5 formatterchrrrr49s     zFTPClient._setup_loggercCs0t|_|j|j|j|j|j|jdS)N)rftpconnectr0r1rr2r3)rrrrrABszFTPClient.connectcCst|dr|jdS)Nr@)hasattrr@quit)rrrr disconnectGs zFTPClient.disconnectc Cszyj||j||dd}t|d}|jd||WdQRX|jd|d|ddStk r}z|j d |d Sd}~XYnXWd| XdS) N/rbzSTOR zFile 'z' uploaded successfully to ''TzFailed to upload file: F) rAr@cwdsplitopen storbinaryr5info ExceptionerrorrD)rlocal_file_path remote_dirfilename local_fileerrr upload_fileKs  zFTPClient.upload_file)r/NN)rrrrr4rArDrUrrrrr.0s   r.皙?皙?333333?皙?cCs$|||d|||||S)a Calculate the priority score for a campaign. Args: - TSA (float): Target Show Alignment value (between 0 and 1). - ARF (float): Airing Requirement Fulfillment value (between 0 and 1). - U (float): Urgency value (between 0 and 1). - P (float): Position value (between 0 and 1). - W_TSA (float): Weight for Target Show Alignment (default is 0.4). - W_ARF (float): Weight for Airing Requirement Fulfillment (default is 0.2). - W_U (float): Weight for Urgency (default is 0.3). - W_P (float): Weight for Position (default is 0.1). Returns: - float: Priority score for the campaign. rr)TSAARFUPZW_TSAZW_ARFZW_UZW_Prrrcalculate_priority_score[sr^)r error_permc@sbeZdZdZdddZddZddZd d Zd d Zd dZ ddZ ddZ ddZ ddZ dS) FTPConnectoraf A class to manage FTP connections and operations. Attributes: host (str): The FTP server hostname. port (int): The port number of the FTP server. username (str): The username for authentication. password (str): The password for authentication. ftp (FTP): An instance of the FTP class for FTP operations. NcCs"||_||_||_||_d|_dS)a Initializes the FTPConnector with server details. Args: host (str): The FTP server hostname. port (int, optional): The port number of the FTP server. Defaults to None. username (str, optional): The username for authentication. Defaults to None. password (str, optional): The password for authentication. Defaults to None. N)hostr1r2r3r@)rrar1r2r3rrrr}s zFTPConnector.__init__c CsyL|jr$t|_|j|j|jn t|j|_|j|j|jtdWn0t k r|}ztd|Wdd}~XYnXdS)zj Connects to the FTP server. Raises: Exception: If connection fails. zConnected to FTP server.z Error connecting to FTP server: N) r1rr@rArarr2r3printrN)rrTrrrrAs  zFTPConnector.connectc CsRy|jr|jtdWn0tk rL}ztd|Wdd}~XYnXdS)zr Disconnects from the FTP server. Raises: Exception: If disconnection fails. zDisconnected from FTP server.z%Error disconnecting from FTP server: N)r@rCrbrN)rrTrrrrDs   zFTPConnector.disconnectc CszzyD||jr<|j}tdx|D] }t|q*WntdWn0tk rv}ztd|Wdd}~XYnXWd|XdS)z0 Lists files on the FTP server. zList of files on server:zNot connected to FTP server.zError listing files: N)rAr@nlstrbrNrD)rfilesfilerTrrr list_filess   $zFTPConnector.list_filesc Cszyv||jrnt|d4}|dd}|j||jd||WdQRXtd|d|dntd Wn0tk r}ztd |Wdd}~XYnXWd|XdS) a Uploads a file to the FTP server. Args: local_path (str): The local path of the file to upload. remote_path (str): The remote path where the file will be uploaded. Raises: Exception: If file upload fails. rGrErFzSTOR Nz Uploaded z to .zNot connected to FTP server.zError uploading file: ) rAr@rKrJrIrLrbrNrD)r local_path remote_pathrSZremote_filenamerTrrrrUs    $zFTPConnector.upload_filec Cszy^||jrVt|d}|jd||jWdQRXtd|d|dntdWn0tk r}ztd|Wdd}~XYnXWd|XdS) a0 Downloads a file from the FTP server to the local machine. Args: remote_path (str): The remote path of the file on the server. local_path (str): The local path where the file will be saved. Raises: Exception: If file download fails. wbzRETR Nz Downloaded z to rgzNot connected to FTP server.zError downloading file: )rAr@rK retrbinarywriterbrNrD)rrirhrerTrrr download_files    $zFTPConnector.download_filec Cs~zny8||jr0|j|td|dntdWn0tk rj}ztd|Wdd}~XYnXWd|XdS)z Creates a directory on the FTP server. Args: directory (str): The directory path to be created. Raises: Exception: If directory creation fails. zCreated directory: rgzNot connected to FTP server.zError creating directory: N)rAr@mkdrbrNrD)r directoryrTrrrcreate_directorys   $zFTPConnector.create_directoryc Cs~zny8||jr0|j|td|dntdWn0tk rj}ztd|Wdd}~XYnXWd|XdS)z Deletes a file from the FTP server. Args: remote_path (str): The remote path of the file to be deleted. Raises: Exception: If file deletion fails. zDeleted file: rgzNot connected to FTP server.zError deleting file: N)rAr@deleterbrNrD)rrirTrrr delete_file s   $zFTPConnector.delete_filec Cs~zny8||jr0|j|td|dntdWn0tk rj}ztd|Wdd}~XYnXWd|XdS)z Deletes a directory from the FTP server. Args: directory (str): The directory path to be deleted. Raises: Exception: If directory deletion fails. zDeleted directory: rgzNot connected to FTP server.zError deleting directory: N)rAr@rmdrbrNrD)rrorTrrrdelete_directory!s   $zFTPConnector.delete_directoryc Cszvy@||jr8|j||td|d|dntdWn0tk rr}ztd|Wdd}~XYnXWd|XdS)z Renames a file on the FTP server. Args: from_name (str): The current name of the file. to_name (str): The new name for the file. Raises: Exception: If file renaming fails. zRenamed file from z to rgzNot connected to FTP server.zError renaming file: N)rAr@renamerbrNrD)r from_nameZto_namerTrrr rename_file7s  $zFTPConnector.rename_file)NNN)rrr__doc__rrArDrfrUrmrprrrtrwrrrrr`qs  r`cCs8tt|d\}}}}|d|d||d}|S)N:i<i@B)mapr+rJ)time_strhoursminutesseconds microseconds total_secondsrrrhhmmssf_to_secondsPsrc Cs4ddlm}m}||}ddi}||j}tj||d}|jdkr0t|j|d}d|krr|j|_| nd|kr|j|_ | nd |kr|j|_ | nd |kr|j|_ | nld |kr|j|_ | nRd |kr|j|_| n8d |krtd|j|j|_| n|j|_| |SdS)Nr)urlparseparse_qsz User-AgentzeMozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/103.0.0.0 Safari/537.36)urlheaderseventjs_startjs_first_quartile js_midpointjs_third_quartilevast_impression doubleclick js_completezCheck: ) urllib.parserrqueryrequestsgettextrbtracking_start_statussavetracking_firstquartile_statustracking_midpoint_statustracking_thirdquartile_statusimpression_sprintserve_statusimpression_double_click_statustracking_completed_status) rreplyrr parsed_urlr query_paramsresponse event_valuerrrvast_update_requests[sB             rcCs^ddlm}m}d}t|}|jdkrV|d}|dd}dd|D}|SdSdS)Nr)datetime timedeltazqhttps://almatv-stor.vizionr.fr/synthesia/almatv/playlist/manager/php/_getPlaylist.php?fields=title,isPub,durationdatacSs&g|]}d|kr|ddkr|qS)isPub1r).0itemrrr sz%visioner_playlist..)rrrr status_codejson)rrrr head_data playlist_dataprocessed_datarrrvisioner_playlists   r)rreturnc CsyFtj|dd}||jr2td||jStd|dSWn>tjjk r}ztd|dt|dSd}~XYnXdS)z Fetch XML content from a URL and check status code. Args: url: The URL to send the request to Returns: The XML content as string if successful, None otherwise )timeoutz"Successfully fetched content from zNo content received from NzError fetching URL z: ) rrraise_for_statuscontentrbr exceptionsRequestExceptionstr)rrrTrrrfetch_xml_from_urls r) xml_contentrc CsRyt|}td|Stjk rL}ztdt|dSd}~XYnXdS)z Parse XML content into an ElementTree. Args: xml_content: String containing XML data Returns: The root element of the parsed XML, or None if parsing failed zSuccessfully parsed XML contentzFailed to parse XML: N)ET fromstringrb ParseErrorr)rrootrTrrrparse_xml_contents  r)rtag_name attributesrc Cs g}g}|d|}tdt|d|dx|D]}d}|rnx(|D]\}} ||| krNd}PqNW|r8|jdd|jDgd } x:|D]2} | j| jd d| jDd } | d | qW|| ||q8W|rtd t|dntd t|d|d||fS)a Extract data from XML elements based on tag name and optional attributes. Args: root: The root XML element tag_name: The tag to search for attributes: Optional dictionary of attribute names and values to match If None, all elements with the tag_name will be returned Returns: List of dictionaries containing the matched elements' data z.//zFound z elements with tag 'rHTFcSsi|]\}}||qSrr)rkvrrr sz.extract_data_by_attributes..)rrchildrencSsi|]\}}||qSrr)rrrrrrrs)tagrrrz Extracted z% elements matching attribute criteria) findallrblenitemsrrattribrappend) rrrresultsZ elements_rootelementselementZmatches_criteria attr_nameZ attr_valueZ element_datachildZ child_datarrrextract_data_by_attributess4    rcCs<ddlm}ddl}ddlm}ddlm}ddlm}ddl }ddl }ddl }ddl m m}ddddddd d d d dd d d dd dddddddd} ddddddddd} d} d} ddi} |j| | | d }d!|d"d#d$d%|d"d#d$d&|d"d#d$d'|d"d#d$d(|d"d#d$g}d)d*id)d+id)d,id)d-id)d.ig}dS)/Nr) call_vastr) HTTPProxyAuth)ThreadPoolExecutor) parse_urli!i%i+i-i$i#i(i"i&i'i,i.) FeuilletonZMagazineu Mini-Sériez Magazine z Mini-SerieZSerieZ InformationzMagazine Sportifz Dessin AnimezMagazine Sportif ZTelefilmZ DocumentaireZ ReligieuxZSportz Long MetrageZNewsz Long-MetragezDes Histoires Et Des HommesuSérieZMusiqueZTheatreZ SpectacleZJeux720567z Dessin Animez Abtal albiharzar-MA2M_TVFrance)wh content_genre content_titlelanguage pod_max_dur channel_namecountryahttps://tv.springserve.com/vast/850576?w=1920&h=1080&cb={{CACHEBUSTER}}&ip={{IP}}&ua={{USER_AGENT}}&pod_max_dur={{POD_MAX_DUR}}&pod_ad_slots={{POD_AD_SLOTS}}&app_bundle={{APP_BUNDLE}}&app_name={{APP_NAME}}&app_store_url={{APP_STORE_URL}}&did={{DEVICE_ID}}&us_privacy={{US_PRIVACY}}z User-AgentzeMozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/103.0.0.0 Safari/537.36)r num_requestsparamsz185.124.241.179:12323Z 14a2f5dfde475Z 51ae51af21)httpauthz89.116.242.185:12323z45.140.244.198:12323z193.106.198.128:12323z136.175.224.210:12323rz5http://14a2f5dfde475:51ae51af21@185.124.241.179:12323z4http://14a2f5dfde475:51ae51af21@89.116.242.185:12323z4http://14a2f5dfde475:51ae51af21@45.140.244.198:12323z5http://14a2f5dfde475:51ae51af21@193.106.198.128:12323z5http://14a2f5dfde475:51ae51af21@136.175.224.210:12323)tasksrr requests.authrconcurrent.futuresr urllib3.utilrrandomrosxml.etree.ElementTreeetree ElementTreedelay)rrrrrrrrrZiab_catrrrrvastZ proxy_listZproxies0rrr call_vast_apisl       r)rVrWrXrY)N)' functoolsr django.httprdjango.shortcutsrmodelsrftplibrr6rrtypingrr r r rrrrr r'r(r-r.r^r_r`rrrrrElementrrrrrrrs2       + ` /,<