riku
2024-01-10 a9e8e27e0503552b7b2a99c821da732175d4f071
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
U
Ö©fe­ã@sPddlmZddlmZddlmZddlmZddlm    Z    Gdd„de
ƒZ dS)    é)Ú MainScheduler)Ú TaskScheduler)ÚConfig)ÚJinShanRequestTask)ÚLogUtilsc@s0eZdZdZd ddœdd„Zdd„Zd    d
„ZdS) ÚMainControlleru程序主线程控制器FN)ÚreturncCs:||_|rt d¡tƒ|_tƒ|_tƒ|_t|ƒ|_    dS)Nu9!!!!!!当前为调试模式!!!!!!)
ÚdebugrrÚ_main_schedulerrÚ_request_task_schedulerrÚ_configrÚ _request_task)Úselfr    ©rúEE:\PycharmProject\fugitive_dust_new/src\controller\main_controller.pyÚ__init__ s
zMainController.__init__c
Csˆ|j ¡}|r„|j ¡r"|j ¡|jj}tjd|j›d|j    ›d|j
›d|j ›d    dd|j   |¡|j |j j|¡|j ¡ndS)    u数据爬取任务管理u新任务创建, ç‰ˆæœ¬: u  | èµ·å§‹ï¼šu  | ç»“束:u  | é—´éš”: u秒é)ÚprefixN)r Úcheck_request_configr Úhas_request_jobÚ
remove_jobÚrequest_configrÚinfoÚversionÚrequest_start_timeÚrequest_end_timeÚrequest_interval_secondsr Ú
set_configÚadd_task_by_configÚdo_request_taskÚ
start_task)rZhas_new_configZ
req_configrrrÚ_mains
 
 
$ÿ  zMainController._maincCs|j |j¡|j ¡dS)u主逻辑执行N)r
Úadd_taskr!r )rrrrÚexecute3szMainController.execute)F)Ú__name__Ú
__module__Ú __qualname__Ú__doc__rr!r#rrrrr    s
rN) Zscheduler.main_schedulerrÚscheduler.task_schedulerrÚ config.configrÚtask.request_taskrÚutils.log_utilsrÚobjectrrrrrÚ<module>s