a
    }h                     @   s,  d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ d dlm	Z	 d dl
mZmZ d dlmZ d dlmZ d dlmZmZmZ d dlmZ d d	lmZ ed
Zejdkrd dlZeejedZne	d ZedddZ dee!dddZ"e!dddZ#dd Z$d ddZ%d!ddZ&d"ddZ'dS )#    N)imagecaptcha)caches)close_old_connections
connection)timezone)get_redis_connection)FifaAccountLogFifaAccountTelegramMessage)BASE_DIR)	SystemLog	print_logntz.data/console_worker_infodiskcache_alternative)fifa_accountc                 O   sf  | dg }|rt|ts$t|trg }|D ]\}d}t|tsHt|trd|D ]}|t|d 7 }qLn|t|d 7 }|t| j|d q,tj	dj
|d nd}|D ]}|t|d 7 }q| D ]$\}}	|t|d t|	 d 7 }qz(tdt| j|t  d	 W nL ty` }
 z2td
t| j|t  d	d|
 W Y d }
~
n
d }
~
0 0 d S )N	bulk_list  )fifa_account_iddescriptionlogs_pgbouncerobjs : Z
print_log2)r   r   log_timezcant save logs : z	 error : )get
isinstancetupleliststrappendr   idobjectsusingbulk_createitemsprint_cache2rpushjsondumpsr   	localtime	isoformat	Exceptionprint)r   argskwargsr   r   itemtextikeyvalueZ
save_error r5   MC:\Users\Administrator\Downloads\futplus_django\utils\realy_public_methods.py	new_print   s4    

r7   )r   linkc                 C   sf   |st   }n| }z tdt| j||d W n&   tdt| j||d Y n0 d S )NZrequest_log2)r   r8   create_timezcant save requests : )	r   r*   r+   r&   r'   r(   r)   r!   r-   )r   r8   r9   Z	save_timer5   r5   r6   save_account_request?   s    	

r:   )worker_namec           
      O   s   | dg }|rt|ts$t|trg }|D ]Z}d}t|tsHt|trd|D ]}|t|d 7 }qLn|t|d 7 }|t| |d q,tjj|d n\d}|D ]}|t|d 7 }q|	 D ]$\}}	|t|d t|	 d 7 }qtjj
| |d d S )Nr   r   r   )r;   r   r   r   )r   r   r   r   r   r    r   r"   r$   r%   create)
r;   r.   r/   r   r   r0   r1   r2   r3   r4   r5   r5   r6   sys_log_saved   s"    r=   c                 C   sX   t  }|d |d |d || }|dkrBdd|dS ddt|jd	S d S )
N   Z da2bf9e50b0d7e75a7c723a5d7b60f1ar   Tsuccess)status_boolstatuscaptcha_textFfailed)r@   rA   error)r   Zset_verboseZset_keyZset_soft_idZsolve_and_return_solutionr   
error_code)Zcaptcha_imageZsolverrB   r5   r5   r6   anticaptcha_text_captcha{   s    



rF   c                 C   sL   t   tjj| ||d zt||||W S    t| dt  Y d S 0 d S )N)r   message_typer1   zcant send telegram message , )r   r
   r"   r<   telegram_send_messager7   	traceback
format_exc)r   	bot_tokenr1   chat_idmessage_thread_idrG   r5   r5   r6   "telegram_send_message_fifa_account   s    rN   c                 C   s:   d|  d}||d}|r(| d|i tj||d}|S )Nzhttps://api.telegram.org/botz/sendMessage)rL   r1   rM   )params)updaterequestsr   )rK   r1   rL   rM   urlrO   resultr5   r5   r6   rH      s    rH   c                 C   sN   | sd} t  &}|d| g | }W d    n1 s<0    Y  |d S )NUTCzSELECT TIMEZONE(%s, NOW());r   )r   cursorexecutefetchone)	timezone_rU   rowr5   r5   r6   get_db_time   s    
&rZ   )N)NN)N)N)(r(   ostimerI   pytzrQ   Z anticaptchaofficial.imagecaptchar   django.core.cacher   	django.dbr   r   django.utilsr   Zdjango_redisr   accounts.modelsr   r	   r
   futplus.settingsr   Zutils.modelsr   r&   nameZ	diskcacheCachepathjoinconsole_worker_cacher7   r   r:   r=   rF   rN   rH   rZ   r5   r5   r5   r6   <module>   s2   
%%

