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-14 10:51:16 +08:00
parent dd16d45784
commit 62c5fa2f1f
3 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
MQTT.py
View File

@ -60,7 +60,7 @@ class MQTTClient:
reload(client) reload(client)
elif data == "record_list": elif data == "record_list":
# 查看录像列表 # 查看录像列表
get_list_record() get_list_record(client)
elif data == "record": elif data == "record":
# 获取录像 # 获取录像
get_record(msg, client) get_record(msg, client)

3
data_upload.py
View File

@ -24,7 +24,8 @@ class DataUploadClient:
def on_connect(self, client, userdata, flags, rc): def on_connect(self, client, userdata, flags, rc):
global times global times
times = 6 times = 6
self.client.publish('success', payload='连接成功，执行数据推送和本地存储' + str(time.time()), qos=0) self.client.publish('success', payload=subscribe_topic + ':连接成功，执行数据推送和本地存储' + str(time.time()),
qos=0)
subprocess.Popen(['/usr/bin/bash /home/pi/lot_manager/bash/start_data_upload.sh'], shell=True) subprocess.Popen(['/usr/bin/bash /home/pi/lot_manager/bash/start_data_upload.sh'], shell=True)
def on_disconnect(self, client, userdata, rc): def on_disconnect(self, client, userdata, rc):

8
tool.py
View File

@ -72,11 +72,12 @@ def reload(client):
subprocess.Popen(['supervisorctl reload'], shell=True) subprocess.Popen(['supervisorctl reload'], shell=True)
def get_list_record(): def get_list_record(client):
data = { data = {
"data": os.listdir(mp4_path) "data": os.listdir(mp4_path)
} }
requests.post(post_record_list_url, json=data) r = requests.post(post_record_list_url, json=data)
client.publish('success', payload=str(r), qos=0)
def get_record(msg, client): def get_record(msg, client):
@ -86,4 +87,5 @@ def get_record(msg, client):
return return
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"}
requests.post(post_record_url, files=files) r = requests.post(post_record_url, files=files)
client.publish('success', payload=str(r), qos=0)