U
|
O3;eø ã @ sL d dl mZ d dlmZ d dlmZmZ d dlmZ eG dd deZ dS )é )Ú singleton)Údb_conn)Ú RequestTaskÚRequestTaskLog)Údatetimec @ s< e Zd ZdZddddZedddZdd Zd
|
d ZdS ) ÚRequestTaskRepositoryu! ç¬åä»»å¡ç¸å
³æ°æ®åºæä½N)Úreturnc C s d S ©N© )Úselfr
|
r
|
úIe:\PycharmProject\fugitive_dust_new\src\db\repository\request_task_rep.pyÚ__init__ s z RequestTaskRepository.__init__c C sH t jdd dd}|dkr d}n
|
|jd }t|t ¡ d}t |¡ |S )u å建任å¡è®°å½c S s | t¡ tj ¡ ¡ ¡ S r )Úqueryr Úorder_byÚ
|
start_timeÚdescÚfirst)Úsessionr
|
r
|
r Ú<lambda> ó z3RequestTaskRepository.create_task.<locals>.<lambda>T©Ú new_sessionNé )Úidr )r Ú query_sqlr r r ÚnowÚinsert)r Útaskr Únew_taskr
|
r
|
r Ú create_task s
|
|
z!RequestTaskRepository.create_taskc s fdd}t j|ddS )u! å®æä»»å¡ï¼æ´æ°ä»»å¡ç¶æc s8 | t¡jd ¡ }t ¡ |_d|_ |_| ¡ d S )N)r F)
|
r r Ú filter_byÚoner r Úend_timeÚrunning_statusÚsuccessÚcommit)r r ©ÚsÚtask_idr
|
r Úf s
|
|
z.RequestTaskRepository.complete_task.<locals>.fTr )r r )r r( r' r) r
|
r& r Ú complete_task s z#RequestTaskRepository.complete_taskc C s, t }t ¡ |_||_||_||_t |¡S )u è®°å½ä»»å¡æ¥å¿) r r r Ú create_timeÚ
|
request_idÚlog_typeÚlogr r )r r( Útyper. Ztask_logr
|
r
|
r Ú
|
insert_log% s
|
z RequestTaskRepository.insert_log) Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__r Ústrr r* r0 r
|
r
|
r
|
r r s
|
|
r N)
|
Údecorator.singletonr Ú
|
db.db_connr Údb.models.tablesr r r Úobjectr r
|
r
|
r
|
r Ú<module> s
|
|
