o
|
¬3jî ã @ sN d dl mZ d dlZd dlmZ d dlmZ d dlmZ dZ G dd dZ
|
dS ) é )ÚAnyN)Úsettings)Ú MqttService)Ú CourseServiceZSYNC_COURSE_TASKc @ s² e Zd ZdededdfddZdedeeee f fdd Z
|
dedeeee f fd
|
d Z ded edeeee f fd dZ dededeee f dede deee f f ddZdS )ÚInitTaskDispatcherÚmqttÚcourse_serviceÚreturnNc C s || _ || _d S )N)r r )Úselfr r © r ú8D:\apps\smartlearning\server\app\mqtt\init_dispatcher.pyÚ__init__ s
|
zInitTaskDispatcher.__init__Ú device_idc C s | j ¡ }g }| dg ¡D ]9}|d }t| di ¡}| dd¡}|dkr4| d¡dkr4tt ¡ |d< | ||||| d d
|
¡¡}| |¡ q |S ) NÚtasksÚactionÚpayloadÚchannelZctlZ SET_CLOCKÚtsr Úttlé< )r Z get_tasklistÚgetÚdictÚintÚtimeÚ_sendÚappend) r
|
r ZtasklistÚcommandsÚtaskr r r Úcmdr r r Údispatch_device_init s
|
z'InitTaskDispatcher.dispatch_device_initc C s: g }| j tj¡D ]}| jj|t|dd}| |¡ q |S ©Ni )r )r Z build_base_course_sync_payloadsr Úbase_urlr Ú publish_taskÚSYNC_COURSE_TASK_ACTIONr )r
|
r r r r r r r Údispatch_base_courses_sync! s
|
z-InitTaskDispatcher.dispatch_base_courses_syncÚ course_idc C s* | j |tj¡}| jj|t|dd}|gS r )r Z build_course_task_sync_payloadr r! r r" r# )r
|
r r% r r r r r Údispatch_course_init( s z'InitTaskDispatcher.dispatch_course_initr r r r c C s, |dkr | j ||||¡S | j ||||¡S )Nr )r r" Ú publish_ctl)r
|
r r r r r r r r r - s zInitTaskDispatcher._send)Ú__name__Ú
|
__module__Ú __qualname__r r r ÚstrÚlistr r r r$ r& r r r r r r r s "6r ) Útypingr r Ú
|
app.configr Úapp.mqtt.clientr Úapp.services.course_servicer r# r r r r r Ú<module> s
|
