3 -hh)@sddlmZddlZddlmZddlmZmZmZm Z m Z ddl Z ddl j jZ ddlmZddlZddlZddlZddlZddlmZejejjdd e_e jZd Zd Zd Zd Zee jZ d2d3d4d5d6d7d8d9d:d;dd?d@dAdBdCdDdEdFdGgZ!d$Z"dZ#d%d&Z$d'd(Z%d)d*Z&d+d,Z'd-d.Z(d/Z)ej*j+e)rBe,d0ej-e.e)d1Z/e/j0eej1WdQRXz e(Wdej2e)XdS)H)clientN)timezone)TtnstateReportProductReportcurrentloopTtn) connection)Qzutf-8)encodingz 191.101.2.61i[Zszm sdda8jKHks3grand_beton/report/1grand_beton/report/2grand_beton/report/4grand_beton/report/8grand_beton/report/16grand_beton/report/32grand_beton/report/64grand_beton/report/128grand_beton/report/256grand_beton/report/512grand_beton/report/1024grand_beton/production/1grand_beton/production/2grand_beton/production/4grand_beton/production/8grand_beton/production/16grand_beton/production/32grand_beton/production/64grand_beton/production/128grand_beton/production/256grand_beton/production/512grand_beton/production/1024zgrand_beton/ttn/backcCstjrtj rtjdS)N)r is_usablecloser&r&9/home/mqttuser/mqtt_project/mqtt_processor/mqtt_client.pyensure_connection3sr(c(Cs^ttj|}d|ks"d|kr |jdd}|jdd}t|tr^tjtjj |dtj }|j dd}|jdg}t|tjr|}ntjj |d}tj|tj }xN|D]D} | jdd} | jdd} y| dk rt | } tt jjt|d t| d @j} | s:t jj| |||d td | d |d|ntd| d |d|dttjj| djrd|i} | dk r| | d<tjj| djf| td| ntd| Wqtk r}ztd|WYdd}~XqXqW|dkr~|jdd}tj|}d|d<d|}|j|tj|jdtdd}|j}|dkrjtd|d ntd!|d"||d#krZ|jdd}|rZtj|}d#|d<d|}|j|tj|jdtdd}|j}|dkrtd$|ntd%|d&|nNd'|krZ|jd(g}|jd)g}|jd}x|D]}|jdpTd*}|jd+pdd*}|jd,ptd}|jd-pd}|jd.pd}|jd/pd0}|jd1pd0}|jd2pd0}|jd3pd0} |jd4pd0}!|jdpd} |jd5pd*}"|jd-pd}#|jdp$d}$t|rPtjj |d}%tj|%tj }tjj||$d6jsNt||||||||| |!| |"|#||$d7}&|&jx|D]}'|'jdd|jddkrttjj|'jd.d|'jd-d|'jd8d|'jd9d|'jd:d|'jd;d|'jdd|'jd?d|'jd@d|'jdAd|&j|$dBqWtq@WdS)CNttn productionstdatetimez%Y-%m-%d %H:%M:%S)tzinfoZind_ttnZ ind_product)state)idTtn)r/r.datejsonzSaved new Ttnstate: idTtn=z, state=z, date=zRecord with ttnState idTtn=z already exists)idr. idProductz Updated ttn: z!No record found in ttn for idTtn=zError: bsuzgrand_beton/ttn/zutf-8F)ZqosZretainrz Message with st=15 published to z ------z%Failed to send message with st=15 to z, BSU result code: z Message with st=13 published to z%Failed to send message with st=13 to z, result code: reportproduct current_loopz2025-01-01 00:00:00Z time_doneZ v_productnum_loopZv_loopdrivercarZ class_recipeZ name_reciperecipeZ time_start)idPlant indProduct) dateStarttimeEndvProduct loopNumbervLoopr<r> classRecipe nameReciper?r/ timeStartr;r@rAcode dispenserZ err_dosingZerr_dosing_persentZ korr_dosingZ korr_humidityZweight_fact_loopZweight_fact_m3Zweight_recipe_loopZweight_recipe_m3)rFrErJ dispencer doisingErrordoisingErrorPersent doisingKorr humidityKorrweightFactLoop weightFactM3weightRecipeLoopweightRecipeM3r3rA) r(r1loadsget isinstancestrr make_awarer,strptimeget_current_timezonereplaceintrobjectsfilterr existscreateprintr update ExceptionZpublishdumpsencodeMQTT_QOSrcrsaverr2)(rtopicpayloaddatarJr0Zttn_listZnaive_datetimeZaware_datetimer)r/r3Zexisting_recordZ update_dataer5Z new_payloadZ new_topicresultstatusZ product_listZcurrent_loop_listr@r9rBrCrDrErFr<r>rGrHr?rIr;rAZ naive_dateZ product_objloopr&r&r' save_message8s          $                             rqcCs tdt||j|jjdS)NzReceived message:-----otladka)rbrqrjrkdecode)ruserdatamsgr&r&r' on_messagesrucCstd||jtdS)Nz*Connected to MQTT broker with result code )rb subscribeMQTT_TOPICS_SUB)rrsflagsrhr&r&r' on_connectsrycCs>tjtd}t|_t|_|jtt|jt t d|j |S)N)Z client_id<) mqttClientMQTT_CLIENT_IDryruZusername_pw_set MQTT_USERNAME MQTT_PASSWORDconnect MQTT_BROKER MQTT_PORTZ loop_start)rr&r&r'start_mqtt_clients  rz/tmp/mqtt_client.lockzMQTT client is already running.w)rr)rr)rr)rr)rr)rr)rr)rr)rr)rr)rr)rr)rr)rr)rr)rr)rr)rr)r r)r!r)r"r)r#r)3httprr1 django.utilsrmodelsrrrrr uuidZpaho.mqtt.clientr{ django.dbr r,sysosiodjango.db.modelsr TextIOWrapperstdoutbufferr|rrr~rrXuuid4r}rwZMQTT_TOPIC_PUBrgr(rqruryrZ lock_filepathr`rbexitopenfwritegetpidremover&r&r&r'sr