ó
|
®3je ã ó S SK r S SKrS SKJr S SKJr S SKJr S SKJ r S SK
|
J r \ R " \ 5 r " S S5 rg) é N)ÚAny)Úsettings)ÚInitTaskDispatcher)Ú MqttService)Ú InitRegistryc ó¾ \ rS rSrS\S\S\SS4S jrS\S\ \
|
\\ 4 4S jr S\S
|
\
|
\\ 4 S \ S\ \
|
\\ 4 S- 4S jrSS\S \S\\ \
|
\\ 4 \4 4S jjrSrg)ÚAutoInitServiceé ÚregistryÚ
|
dispatcherÚmqttÚreturnNc ó( Xl X l X0l g )N)r r r )Úselfr r r s Ú1E:\smartlearning\server\app\services\auto_init.pyÚ__init__ÚAutoInitService.__init__ s ð ! Ø$Ø ó Ú device_idc ó U R R U5 n[ R SU[ U5 5 U R R U5 nUR U5 [ R SU[ U5 5 U R R US[ [ R " 5 5 [ U5 S9 U$ )Nz+Device init dispatched for %s (%d commands)z<Base courses sync dispatched for %s (%d courseTask messages)T)Úcourses_syncedÚcourses_sync_atÚcourses_sync_count) r Údispatch_device_initÚloggerÚinfoÚlenÚdispatch_base_courses_syncÚextendr Ú update_recordÚintÚtime)r r ÚcommandsÚcourse_commandss r Ú_run_full_initÚ AutoInitService._run_full_init s¢ Ø??×7Ñ7¸ ÓBÜ ÐAÀ9ÌcÐRZËmÔ\à //×DÑDÀYÓOØÔ(Ü Ø JØ Ü Ó ô
|
ð ×#Ñ#Ø Ø Ü ¤§ ¢ £ Ó ,Ü " ?Ó 3ð $ñ
|
ð r ÚpayloadÚ timestampc ó [ R ( d g U R R U5 ( a g U R R
|
( d [ R SU5 g UR S5 nU R R USXCS9( d g U R U5 n[ R SU[ U5 5 U$ ! [ a3 U R R U5 [ R SU5 e f = f)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# s r Úon_device_stateÚ AutoInitService.on_device_state, sØ Ü×)×)Øà ==× 'Ñ '¨ × 2Ñ 2Øàyy×"×"Ü NNÐFÈ Ô RØà{{6Ó"Ø}}×&Ñ& y¸ÀdÐ&Ö`Øð Ø×*Ñ*¨9Ó5HÜ KKÐOÐQZÔ\_Ð`hÓ\iÔ jØOøÜó Ø MM× Ñ Ô +Ü × Ñ Ð YÐ[dÔ eØ ð ús  2C Ã=D Úforcec ób U R R U5 ( a U( d / S4$ U( a U R R U5 U R R USS9( d / S4$ U R U5 nUS4$ ! [
|
a U R R U5 e f = f)NÚalready_initializedÚmanual)r, Ú
|
dispatched)r r. r4 r2 r% r3 )r r r8 r# s r Údispatch_manual_initÚ$AutoInitService.dispatch_manual_initD s¡ Ø ==× 'Ñ '¨ × 2Ñ 2¾5ØÐ,Ð,Ð ,æ Ø MM× Ñ Ô +à}}×&Ñ& y¸Ð&ÖBØÐ,Ð,Ð ,ð Ø×*Ñ*¨9Ó5HØ\Ð)Ð )øÜó Ø MM× Ñ Ô +Ø ð ús Á2B Â'B.)r r r )F)Ú__name__Ú
|
__module__Ú __qualname__Ú__firstlineno__r r r r ÚstrÚlistÚdictr r% r! r6 ÚboolÚtupler= Ú__static_attributes__© r r r r sÍ ðà ðð 'ðð ð ð
|
|
ô ð¨ð °°T¸#¸s¸(±^Ñ0Dô ð(¨ð °t¸CÀ¸H±~ð ÐRUð ÐZ^Ð_cÐdgÐilÐdlÑ_mÑZnÐquÑZuô ñ0¨cð ¸$ð È5ÐQUÐVZÐ[^Ð`cÐ[cÑVdÑQeÐgjÐQjÑKk÷ ð r r )Úloggingr" Útypingr Ú
|
app.configr Úapp.mqtt.init_dispatcherr Úapp.mqtt.clientr Úapp.services.init_registryr Ú getLoggerr? r r rI r r Ú<module>rQ s6 ðÛ Û Ý å Ý 7Ý 'Ý 3à × Ò 8Ó $÷Fò Fr
|
