xyj
/
lot_manager
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

update

This commit is contained in:
xyj 2023-12-18 11:28:45 +08:00
parent 8db51ceb4d
commit 1b8690bc2e
2 changed files with 19 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
MQTT.py
View File

@ -1,4 +1,4 @@
import json
import time import time
import paho.mqtt.client as mqtt import paho.mqtt.client as mqtt

6
tool.py
View File

@ -92,14 +92,18 @@ def reload(client):
def get_list_record(client): def get_list_record(client):
try:
data = { data = {
"data": os.listdir(mp4_path) "data": os.listdir(mp4_path)
} }
r = requests.post(post_record_list_url, json=data) r = requests.post(post_record_list_url, json=data)
client.publish(info_topic, payload=publish_payload(code=200, msg=str(r)), qos=0) client.publish(info_topic, payload=publish_payload(code=200, msg=str(r)), qos=0)
except:
pass
def get_record(msg, client): def get_record(msg, client):
try:
filename = json.loads(msg.payload.decode('utf-8'))["data"] filename = json.loads(msg.payload.decode('utf-8'))["data"]
if filename is None or filename == '': if filename is None or filename == '':
client.publish(info_topic, payload=publish_payload(code=404, msg='没有该文件'), qos=0) client.publish(info_topic, payload=publish_payload(code=404, msg='没有该文件'), qos=0)
@ -108,3 +112,5 @@ def get_record(msg, client):
files = {filename: open(os.path.join(mp4_path, filename), 'rb'), "Content-Type": "application/octet-stream"} files = {filename: open(os.path.join(mp4_path, filename), 'rb'), "Content-Type": "application/octet-stream"}
r = requests.post(post_record_url, files=files) r = requests.post(post_record_url, files=files)
client.publish(info_topic, payload=publish_payload(code=200, msg=str(r)), qos=0) client.publish(info_topic, payload=publish_payload(code=200, msg=str(r)), qos=0)
except:
pass