o L½iY.ã@sdZddlZddlZddlmZmZmZmZmZddl m Z m Z m Z m Z mZedeƒZdd„Zdd „Ze d ¡d d „ƒZe d ¡dd„ƒZdd„Zdd„Zejddgddd„ƒZejdddgddd„ƒZejdddgddd„ƒZejd ddgdd!d"„ƒZdS)#a Temps dashboard: latest record per unit_id from MySQL shop_stats.Temps. Editable unit_id and node_name via PUT endpoints. Receives sensor readings via POST /reading (device_command for sleep toggle). MySQL entry_date is stored as local datetime (not UTC). éN)Ú BlueprintÚrender_templateÚjsonifyÚrequestÚResponse©Ú MYSQL_HOSTÚ MYSQL_PORTÚMYSQL_DATABASEÚ MYSQL_USERÚMYSQL_PASSWORDÚtempscCstttttdœS)N)ÚhostÚportÚdatabaseÚuserÚpasswordr©rrú(/var/www/html/Server/blueprints/temps.pyÚ _get_configs ûrc Cs tƒ}|ds dSd}ztj|d|d|d|d|dtjjd}Wntjy=}z d t|ƒfWYd }~Sd }~wwzBt|ƒ| ¡}|  |¡|  ¡}Wd ƒn1s[wY|D]}|  d ¡pjd   ¡  ¡}|d vrwd |d <qbW| ¡|d fS| ¡w) z= NOW() - INTERVAL 20 MINUTE GROUP BY unit_id ) latest ON t.unit_id = latest.unit_id AND t.entry_date = latest.max_entry_date LEFT JOIN device_command dc ON dc.device_id = t.unit_id WHERE t.entry_date >= NOW() - INTERVAL 20 MINUTE ORDER BY t.unit_id rrrr©rrrrrÚ cursorclassNÚcommandÚnosleep©ÚsleeprÚreboot)rÚpymysqlÚconnectÚcursorsÚ DictCursorÚErrorÚstrÚ_ensure_device_commandÚcursorÚexecuteÚfetchallÚgetÚstripÚlowerÚclose)ÚcfgÚqueryÚconnÚeÚcurÚrowsÚrÚcmdrrrÚget_latest_per_units@ ú€ÿ   þ€ý ÿr3ú/cCstdƒS)Nztemps/index.html)rrrrrÚindexGsr5z /api/latestcCsPtƒ\}}|rtd|iƒdfS|D]}| d¡}|dur#| d¡|d<qt|ƒS)NÚerroréôÚ entry_datez%Y-%m-%d %H:%M:%S)r3rr'Ústrftime)r0Úerrr1ÚedrrrÚ api_latestLs  €r<cCs4tƒ}tj|d|d|d|d|dtjjdS)Nrrrrrr)rrrrr )r+rrrÚ _get_connYsúr=c Csb| ¡}| d¡z| d¡Wn tjyYnwWdƒn1s&wY| ¡dS)zDEnsure device_command table exists (shared with moisture blueprint).a/ CREATE TABLE IF NOT EXISTS device_command ( device_id VARCHAR(16) PRIMARY KEY, command VARCHAR(20) NOT NULL DEFAULT 'sleep', new_device_id VARCHAR(16) DEFAULT NULL, new_node_name VARCHAR(50) DEFAULT NULL ) zFALTER TABLE Temps ADD COLUMN firmware_version VARCHAR(24) DEFAULT NULLN)r$r%rÚOperationalErrorÚcommit)r-r/rrrr#es  ÿ€õ r#z/readingÚPOST)Úmethodsc Cs¾z¬tjddd}|stdddœƒdfWS| d¡}| d¡}| d ¡}| d ¡}| d ¡}| d ¡}| d ¡}| d¡}|dusI|dusI|durStdddœƒdfWSt|tƒr\| ¡sftdddœƒdfWS| ¡dd…}t|tƒru|nd ¡dd…p~d}|durt|ƒ ¡dd…nd}|durt|ƒ ¡dd…nd}t|tƒr¦|nd ¡dd…p¯d}t|tƒr·|nd ¡dd…pÀd}|durÖt|tƒrÌ|nt|ƒ ¡dd…nd}t|tƒrß|nd ¡dd…pèd}tƒ} z¨t| ƒ|   ¡} |   d|f¡|   ¡} | r| dnd ¡  ¡} | dvrd} | r&|  d¡pd ¡dd…nd} | r9|  d¡p2d ¡dd…nd}|   d||||||| ||f ¡| rO| n|}|rV|n|pZd}| re|   d |f¡|ro|   d!|f¡| d"kr{|   d#|f¡Wdƒn 1s†wY|   ¡W|  ¡n|  ¡wtjd| ||d$œd%d&}t|d'd(d)WStjyÁtdd*dœƒd+fYStyÞ}ztdt|ƒdœƒd+fWYd}~Sd}~ww),zjAccept temp/humidity reading from WifiTemps device; insert into Temps; return command/device_id/node_name.T©ÚforceÚsilentFzInvalid or missing JSON©Úokr6éÚunit_idÚ node_nameÚtempÚhumidÚmacÚipÚbatÚfirmware_versionNzMissing unit_id, temp, or humidz"unit_id must be a non-empty stringé Úé2éézUSELECT command, new_device_id, new_node_name FROM device_command WHERE device_id = %srrrÚ new_device_idéÚ new_node_namez²INSERT INTO Temps (unit_id, entry_date, temp, humid, mac, ip, bat, command, node_name, firmware_version) VALUES (%s, NOW(), %s, %s, %s, %s, %s, %s, %s, %s)ÚNEWzCUPDATE device_command SET new_device_id = NULL WHERE device_id = %szCUPDATE device_command SET new_node_name = NULL WHERE device_id = %srzBUPDATE device_command SET command = 'nosleep' WHERE device_id = %s)rFrÚ device_idrI)ú,ú:)Ú separatorséÈzapplication/json)ÚstatusÚmimetypezDatabase errorr7)rÚget_jsonrr'Ú isinstancer"r(r=r#r$r%Úfetchoner)r?r*ÚjsonÚdumpsrrr!Ú Exception)ÚdatarHrIrJrKrLrMrNrOr-r/ÚrowÚcurrent_commandrUrWÚresp_device_idÚresp_node_nameÚbodyr.rrrÚreadingws”        "  ""." þ &&ýþþ þ€á # þ"€ÿrlz/sensor//unit_idÚPUTc Cs2tjdddpi}| d¡pd ¡}|stdddœƒdfS|p d ¡}|s.tdd dœƒdfS|d d …}zFtƒ}z=t|ƒ| ¡}| d ||f¡| d |||f¡Wd ƒn1s]wY|  ¡td||dœƒdfW|  ¡WS|  ¡wt j y˜}ztdt |ƒdœƒdfWYd }~Sd }~ww)zSet new unit_id for this sensor: body {"unit_id": "NEW_ID"}. Updates Temps rows and pushes new_id to device via device_command.TrBrHrQFzunit_id requiredrErGúinvalid unit_id in URLNrPz0UPDATE Temps SET unit_id = %s WHERE unit_id = %sz„INSERT INTO device_command (device_id, command, new_device_id) VALUES (%s, 'nosleep', %s) ON DUPLICATE KEY UPDATE new_device_id = %s)rFÚ previous_idÚnew_idr]r7©rr`r'r(rr=r#r$r%r?r*rr!r")rHrfrpr-r/r.rrrÚ set_unit_idËs4   þþ"€ÿrrz/sensor//commandc Cs(tjdddpi}| d¡pd ¡ ¡}|dvr!tdddœƒd fS|p$d ¡}|s2tdd dœƒd fS|d d …}z=tƒ}z4t|ƒ| ¡}|  d |||f¡Wd ƒn1sYwY|  ¡td|dœƒdfW|  ¡WS|  ¡wt j y“}ztdt|ƒdœƒdfWYd }~Sd }~ww)zESet command for sensor: body {"command": "sleep"|"nosleep"|"reboot"}.TrBrrQrFz/command must be 'sleep', 'nosleep', or 'reboot'rErGrnNrVzdINSERT INTO device_command (device_id, command) VALUES (%s, %s) ON DUPLICATE KEY UPDATE command = %s)rFrr]r7)rr`r'r(r)rr=r#r$r%r?r*rr!r")rHrfr2r-r/r.rrrÚ set_commandès2   þÿ"€ÿrsz/sensor//node_namec Cs(tjdddpi}| d¡pd ¡dd…}|pd ¡}|s'tddd œƒd fSzNtƒ}zEt|ƒ| ¡}| d |p;d|f¡| d ||pFd|pIdf¡Wdƒn1sVwY|  ¡td||pedd œƒdfW|  ¡WS|  ¡wt j y“}ztdt |ƒd œƒdfWYd}~Sd}~ww)zqSet node_name for this sensor: body {"node_name": "Name"}. Updates Temps and pushes to device via device_command.TrBrIrQNrRFrnrErGz2UPDATE Temps SET node_name = %s WHERE unit_id = %sz„INSERT INTO device_command (device_id, command, new_node_name) VALUES (%s, 'nosleep', %s) ON DUPLICATE KEY UPDATE new_node_name = %s)rFrHrIr]r7rq)rHrfÚnew_namer-r/r.rrrÚ set_node_names.  þþ"€ÿru)Ú__doc__rcrÚflaskrrrrrÚconfigrr r r r Ú__name__Úbprr3Úrouter5r<r=r#rlrrrsrurrrrÚs,  -     S