o
|
®3je ã @ sh d dl Z d dlZd dlmZ d dlmZ d dlmZ d dlm Z d dl
|
m Z e e ¡ZG dd dZdS ) é N)ÚAny)Úsettings)ÚInitTaskDispatcher)Ú MqttService)Ú InitRegistryc @ s¢ e Zd ZdedededdfddZdedee ee
|
f fd d
|
Z ded e ee
|
f d e dee ee
|
f dB fd dZ ddededeee ee
|
f ef fddZdS )ÚAutoInitServiceÚregistryÚ
|
dispatcherÚmqttÚreturnNc C s || _ || _|| _d S )N)r r r
|
)Úselfr r r
|
© r ú6D:\apps\smartlearning\server\app\services\auto_init.pyÚ__init__ s
|
zAutoInitService.__init__Ú device_idc C sj | j |¡}t d|t|¡ | j |¡}| |¡ t d|t|¡ | jj|dt t
|
|
¡ t|d |S )Nz+Device init dispatched for %s (%d commands)z<Base courses sync dispatched for %s (%d courseTask messages)T)Zcourses_syncedZcourses_sync_atZcourses_sync_count) r Údispatch_device_initÚloggerÚinfoÚlenÚdispatch_base_courses_syncÚextendr Z update_recordÚintÚtime)r r ÚcommandsZcourse_commandsr r r Ú_run_full_init s
|
ý
|
üz AutoInitService._run_full_initÚpayloadÚ timestampc C s t jsd S | j |¡r d S | jjst d|¡ d S | d¡}| jj |d||ds*d S z|
|
|¡}t d|t |¡ |W S t yO | j |¡ t d|¡ w )Nz)Skip auto-init for %s: MQTT not connectedÚmodeÚauto)Úsourcer r z5Auto-init completed for device %s (total %d commands)z:Auto-init failed for device %s, registry entry rolled back)r Úauto_init_enabledr Úis_initializedr
|
Ú connectedr ÚwarningÚgetÚ try_claimr r r Ú ExceptionÚremoveÚ exception)r r r r r r r r r Úon_device_state, s&
|
|
ýz AutoInitService.on_device_stateFÚforcec C sr | j |¡r |s g dfS |r| j |¡ | j j|dds g dfS z
|
| |¡}|dfW S ty8 | j |¡ w )NZalready_initializedZmanual)r Ú
|
dispatched)r r! r' r% r r& )r r r* r r r r Údispatch_manual_initD s
|
|
þz$AutoInitService.dispatch_manual_init)F)Ú__name__Ú
|
__module__Ú __qualname__r r r r ÚstrÚlistÚdictr r r r) ÚboolÚtupler, r r r r r s þýü
|
û
|
20r )Úloggingr Útypingr Ú
|
app.configr Úapp.mqtt.init_dispatcherr Úapp.mqtt.clientr Úapp.services.init_registryr Ú getLoggerr- r r r r r r Ú<module> s
|
|
