o *gW @sjddlmZddlmZddlmZddlmZddlm Z ddl Z ddl Z ddl Z ddl mZmZmZmZddlmmZGd d d Zd d ZGd ddZGdddZGdddZd0ddZddlm Z mZGdddZddZddZd d!Z d"e!d#ee!fd$d%Z"d&e!d#eej#fd'd(Z$d1d)ej#d*e!d+ee!e!fd#eee!effd,d-Z%d.d/Z&dS)2wraps)HttpResponseForbidden)redirect)Users)FTPN)DictAnyOptionalListc@seZdZdddZddZdS) TelegramLog.6723497869:AAEKCB3YJUGnUFeMihLlr-FHblTuvtoVUZA -4155125438cCs||_||_dSN) BOT_TOKENGROUP_ID)selfrrr8/var/www/html/DAI27/Adtlas_DAI/DAIManagementApp/utils.py__init__s zTelegramLog.__init__cCst|j}||j|dSr)telebotZTeleBotr send_messager)rmessagebotrrrsend_telegram_logs zTelegramLog.send_telegram_logN)rr)__name__ __module__ __qualname__rrrrrrr s  r cstfdd}|S)NcsXd|jvr(|jdr(|jddkr(tjj|jdddkr(|g|Ri|StdS)Nid_user)rlogin)sessionrobjectsfilterr)requestargskwargsfuncrrwrappers:zcheck_user..wrapperr)r(r)rr'r check_usersr*c@eZdZddZdS) NoVastResultcC||_||_t||_dSr id_campaign total_adsinttotal_impressionsrr/r0r2rrrr%zNoVastResult.__init__Nrrrrrrrrr,$ r,c@r+) VastResultcCr-rr.r3rrrr+r4zVastResult.__init__Nr5rrrrr7*r6r7c@s6eZdZd ddZddZddZd d Zd d ZdS) FTPClientNcCs&||_||_||_||_||_dSr) ftp_serverportusernamepassword _setup_loggerlogger)rr:r;r<r=rrrr2s zFTPClient.__init__cCs@tt}|tjtd}t}|||||S)Nz)%(asctime)s - %(levelname)s - %(message)s) logging getLoggerrsetLevelINFO Formatter StreamHandler setFormatter addHandler)rr? formatterchrrrr>9s     zFTPClient._setup_loggercCs0t|_|j|j|j|j|j|jdSr)rftpconnectr:r;r r<r=rrrrrKBszFTPClient.connectcCst|dr |jdSdS)NrJ)hasattrrJquitrLrrr disconnectGs zFTPClient.disconnectc CszgzE||j||dd}t|d}|jd||Wdn1s-wY|jd|d|dWW|dSt yg}z|j d |WYd}~W|d Sd}~ww|w) N/rbSTOR zFile 'z' uploaded successfully to ''TzFailed to upload file: F) rKrJcwdsplitopen storbinaryr?inforO Exceptionerror)rlocal_file_path remote_dirfilename local_fileerrr upload_fileKs"      zFTPClient.upload_file)r9NN)rrrrr>rKrOrarrrrr80s    r8皙?皙?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[s$rj)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)hostr;r<r=rJ)rrmr;r<r=rrrr}s   zFTPConnector.__init__c Csz'|jrt|_|j|j|jnt|j|_|j|j|jtdWdSt yA}ztd|WYd}~dSd}~ww)zj Connects to the FTP server. Raises: Exception: If connection fails. zConnected to FTP server.z Error connecting to FTP server: N) r;rrJrKrmr r<r=printrZrr`rrrrKs zFTPConnector.connectc CsZz|jr|jtdWdSWdSty,}ztd|WYd}~dSd}~ww)zr Disconnects from the FTP server. Raises: Exception: If disconnection fails. zDisconnected from FTP server.z%Error disconnecting from FTP server: N)rJrNrnrZrorrrrOs zFTPConnector.disconnectc CszHz ||jr|j}td|D]}t|qntdWnty:}z td|WYd}~n d}~wwW|dSW|dS|w)z0 Lists files on the FTP server. zList of files on server:Not connected to FTP server.zError listing files: N)rKrJnlstrnrZrO)rfilesfiler`rrr list_filess$   zFTPConnector.list_filesc CszmzE||jrAt|d}|dd}|j||jd||Wdn1s0wYtd|d|dntd Wnty_}z td |WYd}~n d}~wwW|dSW|dS|w) 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. rRrPrQrSNz Uploaded  to .rpzError uploading file: ) rKrJrWrVrUrXrnrZrO)r local_path remote_pathr_Zremote_filenamer`rrrras&    zFTPConnector.upload_filec Cszaz9||jr5t|d}|jd||jWdn1s$wYtd|d|dntdWntyS}z td|WYd}~n d}~wwW|dSW|dS|w) 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 rurvrpzError downloading file: )rKrJrW retrbinarywriternrZrO)rrxrwrsr`rrr download_files"   zFTPConnector.download_filec CzDz||jr|j|td|dntdWnty6}z td|WYd}~n d}~wwW|dSW|dS|w)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: rvrpzError creating directory: N)rKrJmkdrnrZrOr directoryr`rrrcreate_directory   zFTPConnector.create_directoryc Cr})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: rvrpzError deleting file: N)rKrJdeleternrZrO)rrxr`rrr delete_file rzFTPConnector.delete_filec Cr})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: rvrpzError deleting directory: N)rKrJrmdrnrZrOrrrrdelete_directory!rzFTPConnector.delete_directoryc CszHz ||jr|j||td|d|dntdWnty:}z td|WYd}~n d}~wwW|dSW|dS|w)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 rurvrpzError renaming file: N)rKrJrenamernrZrO)r from_nameZto_namer`rrr rename_file7s  zFTPConnector.rename_file)NNN)rrr__doc__rrKrOrtrar|rrrrrrrrrlqs  rlcCs8tt|d\}}}}|d|d||d}|S)N:i<i@B)mapr1rV)time_strhoursminutesseconds microseconds total_secondsrrrhhmmssf_to_secondsPsrc Cs>ddlm}m}||}ddi}||j}tj||d}|jdkrt|j|d}d|vr9|j|_| |Sd|vrG|j|_ | |Sd |vrU|j|_ | |Sd |vrc|j|_ | |Sd |vrq|j|_ | |Sd |vr|j|_| |Sd |vrtd|j|j|_| |S|j|_| |SdS)Nr)urlparseparse_qs User-AgenteMozilla/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.parserrqueryrequestsgettextrntracking_start_statussavetracking_firstquartile_statustracking_midpoint_statustracking_thirdquartile_statusimpression_sprintserve_statusimpression_double_click_statustracking_completed_status) rreplyrr parsed_urlr query_paramsresponse event_valuerrrvast_update_requests[sT       rcCs\ddlm}m} d}t|}|jdkr,|d}|dd}dd|D}|SdS)Nr)datetime timedeltazqhttps://almatv-stor.vizionr.fr/synthesia/almatv/playlist/manager/php/_getPlaylist.php?fields=title,isPub,durationdatacSs(g|]}d|vr|ddkri|qS)isPub1r).0itemrrr s(z%visioner_playlist..)rrrr status_codejson)rrrr head_data playlist_dataprocessed_datarrrvisioner_playlists   rrreturnc Csz#tj|dd}||jrtd||jWStd|WdStjjyD}ztd|dt|WYd}~dSd}~ww)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: ) rrZraise_for_statuscontentrnr exceptionsZRequestExceptionstr)rrr`rrrfetch_xml_from_urls r xml_contentc CsTz t|}td|WStjy)}ztdt|WYd}~dSd}~ww)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 fromstringrn ParseErrorr)rrootr`rrrparse_xml_contents rrtag_name attributesc Csg}g}|d|}tdt|d|d|D]Q}d}|r5|D]\}} ||| kr4d}nq%|rl|jdd|jDgd } |D]} | j| jd d| jDd } | d | qH|| ||q|r}td t|d||fStd 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 'rTTFcSi|]\}}||qSrrrkvrrr z.extract_data_by_attributes..)rrchildrencSrrrrrrrrr)tagrrrz Extracted z% elements matching attribute criteria) findallrnlenitemsrrattribrappend) rrrresultsZ elements_rootelementselementZmatches_criteria attr_name attr_valueZ element_datachildZ child_datarrrextract_data_by_attributess>   rc Csddlm}ddl}ddlm}ddlm}ddlm}ddl }ddl }ddl }ddl m m}iddd d d dd d d dddddddddddddddddddddddddddd d!d"d#d$} d%d&dd'd(d)d*d+d,} d)} d-} d.d/i} |j| | | d0}d1|d2d3d4d5|d2d3d4d6|d2d3d4d7|d2d3d4d8|d2d3d4g}d9d:id9d;id9dig}dS)?Nr) call_vastr) HTTPProxyAuth)ThreadPoolExecutor) parse_url Feuilletoni!Magazinei%u Mini-Sériez Magazine z Mini-SerieSerie Informationi+zMagazine Sportifi-z Dessin Animei$zMagazine Sportif Telefilm Documentairei# Religieuxi(Sportz Long Metragei"Newsz Long-Metragei&i'i,i.)zDes Histoires Et Des HommesuSérieMusiqueTheatre SpectacleJeux720567z 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}}rr)r num_requestsparamsz185.124.241.179:12323 14a2f5dfde475 51ae51af21)httpauthz89.116.242.185:12323z45.140.244.198:12323z193.106.198.128:12323z136.175.224.210:12323r z5http://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)rrrrrrrrriab_catrrrrvast proxy_listproxies0rrr call_vast_apis            r)rbrcrdrer)' functoolsr django.httprdjango.shortcutsrmodelsrftplibrr@rrtypingr r r r rrrrr r*r,r7r8rjrkrlrrrrrElementrrrrrrrs4       +` /2 <