3
7f                 @   s  d dl jjZd dlZd dlZd dlZd dlZd dlZejdej	dd dZ
dZdZdZeej Zddd d!d"d#d$d%d&d'g
Zi Zdd Zdd Zdd Zdd ZdZejjered ej  eedZejeej  W dQ R X z
e  W dejjer
ej e X dS )(    Nzmqtt_client.logz)%(asctime)s - %(levelname)s - %(message)s)filenamelevelformatz191.101.2.61i[  szmsdda8jKHks3grand_beton/ttn/1grand_beton/ttn/2grand_beton/ttn/4grand_beton/ttn/8grand_beton/ttn/16grand_beton/ttn/32grand_beton/ttn/64grand_beton/ttn/128grand_beton/ttn/256grand_beton/ttn/512c             C   sF   |dkr2t jd x.tD ]\}}| j|| qW nt jd|  d S )Nr   zConnected successfullyzConnection error: )logginginfoMQTT_TOPICS_SUB	subscribeerror)clientuserdataflagsrctopicqos r   :/home/mqttuser/mqtt_project/mqtt_processor/mqtt_deleter.py
on_connect#   s
    
r   c             C   s   ylt j|jj }|jd}|jd}|d k	rj|tkr>g t|< t| j|j||f |dkrjt||j|  W n2 t	k
r } zt
jd|  W Y d d }~X nX d S )Nidst   zMessage processing error: )jsonloadspayloaddecodegetobjects_by_idappendr   update_status_for_other_topics	Exceptionr   r   )r   r   msgr$   obj_idZ
obj_statuser   r   r   
on_message-   s    

r.   c             C   sj   | t krfx\t |  D ]P\}}}||kr|dkrd|d< |j|tj|dd tjd|  d| d qW d S )	Nr!      r    r   )r   zUpdated id=z
 in topic z
, set st=6)r'   publishr"   dumpsr   r   )r,   Ztopic_with_st_4r   r   statusr$   r   r   r   r)   C   s    r)   c              C   s>   t jtd} t| _t| _| jtt | jt	t
d | j  | S )N)	client_id<   )mqttClientMQTT_CLIENT_IDr   r.   username_pw_setMQTT_USERNAMEMQTT_PASSWORDconnectMQTT_BROKER	MQTT_PORT
loop_start)r   r   r   r   start_mqtt_client_delL   s    r?   z/tmp/mqtt_client_del.lockz$MQTT client is already running. PROJw)r   r   )r   r   )r	   r   )r
   r   )r   r   )r   r   )r   r   )r   r   )r   r   )r   r   )!paho.mqtt.clientr5   r   r"   uuidr   ossysbasicConfigINFOr<   r=   r9   r:   struuid4r7   r   r'   r   r.   r)   r?   	lock_filepathexistsprintexitopenfwritegetpidremover   r   r   r   <module>   sJ   

		
