o
|
l13jç ã @ s d dl Z d dlZd dlZd dlZd dlmZ d dlm mZ d dl m
|
Z
|
d dl m Z e e¡ZdZdZdZdZd ZG d
|
d d ZdS ) é N)ÚAny)Úsettings)Ú DeviceStorezsnlp/v1/+/rpt/statezsnlp/v1/+/rpt/eventzsnlp/v1/+/rpt/ackzsnlp/v1/+/rpt/progresszsnlp/v1/+/rpt/logc @ sj e Zd Zd*dededB ddfddZd+ddZd+d d
|
Zd*d ej d e
|
d e
|
de
|
de
|
ddf ddZ d*d ej d e
|
d e
|
de
|
de
|
ddf ddZ d ej d e
|
dej ddfddZd,dededeee
|
f dedeee
|
f f
|
d d Zd-dededeee
|
f dedeee
|
f f
|
d d Zdededeee
|
f dedeee
|
f f
|
d!d"Zd.d$edeee
|
f d%eddfd&d'Zedefd(d)ZdS )/Ú MqttServiceNÚ device_storeÚ auto_initÚreturnc C s || _ || _d | _d| _d S )NF)r r Ú_clientÚ
|
_connected)Úselfr r © r ú/D:\apps\smartlearning\server\app\mqtt\client.pyÚ__init__ s
|
zMqttService.__init__c C s¸ t js
|
t d¡ d S tjtjjt jd| _ t j
|
r!| j t j
|
t j ¡ | j | j _| j| j _| j| j _z | j jt jt jdd | j ¡ t dt jt j¡ W d S ty[ t d¡ Y d S w )Nz MQTT disabled by configuration)Zcallback_api_versionÚ client_idé< )Z keepalivez MQTT client connecting to %s:%sz7Failed to connect MQTT broker; running in API-only mode)r Ú mqtt_enabledÚloggerÚinfoÚmqttÚClientZCallbackAPIVersionZVERSION2Úmqtt_client_idr Ú mqtt_usernameZusername_pw_setÚ mqtt_passwordÚ _on_connectZ
|
on_connectÚ _on_messageZ
|
on_messageÚ_on_disconnectZ on_disconnectÚconnectÚ mqtt_brokerÚ mqtt_portZ
|
loop_startÚ ExceptionÚ exception©r r r r Ústart s&
|
þ
|
|
|
|
ÿzMqttService.startc C s" | j r| j ¡ | j ¡ d S d S ©N)r Z loop_stopZ
|
disconnectr! r r r Ústop3 s
|
þzMqttService.stopÚclientÚuserdataÚflagsÚ reason_codeÚ
|
propertiesc C sf |dks
|
t |dkr+d| _tttttfD ]}|j|d|v r dndd qt d¡ d S t
|
d|¡ d S ) Nr ÚSuccessTÚacké ©Úqosz MQTT connected and subscribedzMQTT connect failed: %s) Ústrr
|
ÚTOPIC_RPT_STATEÚTOPIC_RPT_EVENTÚ TOPIC_RPT_ACKÚTOPIC_RPT_PROGRESSÚ TOPIC_RPT_LOGZ subscriber r Úerror)r r% r& r' r( r) Útopicr r r r 8 s zMqttService._on_connectc C s d| _ t d|¡ d S )NFzMQTT disconnected: %s)r
|
r Úwarning)r r% r& r' r( r) r r r r A s zMqttService._on_disconnectÚmsgc C sV zt |j d¡¡}|j d¡}t|dkr|d n | di ¡ dd¡}t|dkr.|d n| d d¡}| di ¡}t| d
|
t ¡ ¡} | d i ¡}
|
|d krg| j
|
||
|
| ¡ | j rd| j ||
|
| ¡ W d S W d S |d kru| j
|
||
|
¡ W d S |dv r| j
|
|i |
|
¥d|i¥¡ W d S |dkrt d||
|
¡ W d S W d S tyª t d|j¡ Y d S w )Nzutf-8ú/é ÚheaderÚ device_idÚunknowné éÿÿÿÿÚmsg_typeÚ timestampÚpayloadÚstater+ )ÚeventZprogressÚ_typeÚlogzDevice %s log: %sz#Failed to handle MQTT message on %s)ÚjsonÚloadsrB Údecoder6 ÚsplitÚlenÚgetÚintÚtimer Z update_stater Zon_device_stateZ
|
record_ackZ record_eventr r r r ) r r% r& r8 rB Úpartsr< r@ r; rA Úbodyr r r r E s. ( ÿ ÿ ÿzMqttService._on_messager r< ÚactionrB Úttlc C ó0 | ||||¡}d| d}| j||dd |S )Núsnlp/v1/z/cmd/ctlr, r- ©Ú_build_commandÚ_publish©r r< rQ rB rR Úcommandr6 r r r Ú publish_ctl\ ó zMqttService.publish_ctlé c C rS )NrT z /cmd/taskr, r- rU rX r r r Ú publish_taskb r[ zMqttService.publish_taskc C s( d|t t ¡ tt ¡ |d||dS )Nz1.0)Úversionr< Zreq_idrA rR )r; rQ rB )r/ ÚuuidÚuuid4rM rN )r r< rQ rB rR r r r rV h s
|
|
û÷zMqttService._build_commandr, r6 r. c C s< | j r| jst d|¡ d S | j j|tj|dd|d d S )Nz3MQTT not connected; command queued locally only: %sF)Ú ensure_asciir- )r r
|
r r7 ZpublishrG Údumps)r r6 rB r. r r r rW u s zMqttService._publishc C s | j S r# )r
|
r! r r r Ú connected{ s zMqttService.connectedr# )r N)r )r\ )r, )Ú__name__Ú
|
__module__Ú __qualname__r Úobjectr r" r$ r r r r r Z MQTTMessager r/ ÚdictrM rZ r] rV rW ÚpropertyÚboolrc r r r r r s
|
|
&& 00.$ r )rG ÚloggingrN r_ Útypingr Zpaho.mqtt.clientr r% Ú
|
app.configr Úapp.services.device_storer Ú getLoggerrd r r0 r1 r2 r3 r4 r r r r r Ú<module> s
|
|
