From b0e63bc5b537081d381c28a5c548fa0fe3b26346 Mon Sep 17 00:00:00 2001 From: xyj <1090822794@qq.com> Date: Wed, 27 Dec 2023 11:24:37 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0=20tool.py?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- tool.py | 244 ++++++++++++++++++++++++++++---------------------------- 1 file changed, 122 insertions(+), 122 deletions(-) diff --git a/tool.py b/tool.py index 702a6ba..0d1e894 100755 --- a/tool.py +++ b/tool.py @@ -1,122 +1,122 @@ -import json -import os -import subprocess -import threading - -import requests - -from config import mp4_path, post_record_list_url, post_record_url, info_topic - - -# 统一返回 -def publish_payload(code, msg): - return json.dumps({ - "code": code, - "msg": msg - }, ensure_ascii=False) - - -def exception_handler(func): - def wrapper(*args, **kwargs): - try: - return func(*args, **kwargs) - except Exception as e: - print(f"函数{func.__name__}中发生了异常：{e}") - - return wrapper - - -def push_stream(client): - p = subprocess.Popen(['/bin/bash /home/pi/lot_manager/bash/start_push_stream.sh'], - shell=True, - stdout=subprocess.PIPE, - stderr=subprocess.PIPE) - out, err = p.communicate() - output = out.decode('utf-8').strip() - client.publish(info_topic, payload=publish_payload(200, output), qos=0) - - -def close_stream(client): - p = subprocess.Popen(['/bin/bash /home/pi/lot_manager/bash/stop_push_stream.sh'], - shell=True, - stdout=subprocess.PIPE, - stderr=subprocess.PIPE) - out, err = p.communicate() - output = out.decode('utf-8').strip() - client.publish(info_topic, payload=publish_payload(code=200, msg=output), qos=0) - - -def exec_sh(msg, client): - origin_data = json.loads(msg.payload.decode('utf-8')) - if 'data' not in origin_data: - client.publish(info_topic, payload=publish_payload(code=404, msg='data must be supplied'), qos=0) - return - cmd = origin_data["data"] - if cmd in ["supervisorctl stop __mqtt__", - "supervisorctl restart __mqtt__", - "supervisorctl stop all"]: - return - if cmd == "supervisorctl reload": - client.publish(info_topic, payload=publish_payload(code=200, msg='reloading'), qos=0) - subprocess.Popen([cmd], shell=True) - return - subprocess.Popen([cmd], shell=True) - # p = subprocess.Popen([cmd], shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE) - # out, err = p.communicate() - # output = out.decode('utf-8').strip() - # client.publish(info_topic, payload=publish_payload(code=200, msg=output), qos=0) - - -def get_status(client): - p = subprocess.Popen(['supervisorctl status'], - shell=True, - stdout=subprocess.PIPE, - stderr=subprocess.PIPE) - out, err = p.communicate() - output = out.decode('utf-8').strip() - client.publish(info_topic, payload=publish_payload(code=200, msg=output), qos=0) - - -def update(client): - p = subprocess.Popen(['/bin/bash /home/pi/lot_manager/git_update.sh'], - shell=True, - stdout=subprocess.PIPE, - stderr=subprocess.PIPE) - out, err = p.communicate() - output = out.decode('utf-8').strip() - client.publish(info_topic, payload=publish_payload(code=200, msg=output), - qos=0) - - -def reload(client): - client.publish(info_topic, payload=publish_payload(200, "reloading"), qos=0) - subprocess.Popen(['supervisorctl reload'], shell=True) - - -def get_list_record(client): - try: - data = { - "data": os.listdir(mp4_path) - } - r = requests.post(post_record_list_url, json=data) - client.publish(info_topic, payload=publish_payload(code=200, msg=str(r)), qos=0) - except: - pass - - -def up(msg, client): - try: - filename = json.loads(msg.payload.decode('utf-8'))["data"] - if filename is None or filename == '': - client.publish(info_topic, payload=publish_payload(code=404, msg='没有该文件'), qos=0) - return - - files = {filename: open(os.path.join(mp4_path, filename), 'rb'), "Content-Type": "application/octet-stream"} - r = requests.post(post_record_url, files=files) - client.publish(info_topic, payload=publish_payload(code=200, msg=str(r)), qos=0) - except: - pass - - -def get_record(msg, client): - threading.Thread(target=up, args=(msg, client)).start() +import json +import os +import subprocess +import threading + +import requests + +from config import mp4_path, post_record_list_url, post_record_url, info_topic + + +# 统一返回 +def publish_payload(code, msg): + return json.dumps({ + "code": code, + "msg": msg + }, ensure_ascii=False) + + +def exception_handler(func): + def wrapper(*args, **kwargs): + try: + return func(*args, **kwargs) + except Exception as e: + print(f"函数{func.__name__}中发生了异常：{e}") + + return wrapper + + +def push_stream(client): + p = subprocess.Popen(['/bin/bash /home/pi/lot_manager/bash/start_push_stream.sh'], + shell=True, + stdout=subprocess.PIPE, + stderr=subprocess.PIPE) + out, err = p.communicate() + output = out.decode('utf-8').strip() + client.publish(info_topic, payload=publish_payload(200, output), qos=0) + + +def close_stream(client): + p = subprocess.Popen(['/bin/bash /home/pi/lot_manager/bash/stop_push_stream.sh'], + shell=True, + stdout=subprocess.PIPE, + stderr=subprocess.PIPE) + out, err = p.communicate() + output = out.decode('utf-8').strip() + client.publish(info_topic, payload=publish_payload(code=200, msg=output), qos=0) + + +def exec_sh(msg, client): + origin_data = json.loads(msg.payload.decode('utf-8')) + if 'data' not in origin_data: + client.publish(info_topic, payload=publish_payload(code=404, msg='data must be supplied'), qos=0) + return + cmd = origin_data["data"] + if cmd in ["supervisorctl stop __mqtt__", + "supervisorctl restart __mqtt__", + "supervisorctl stop all"]: + return + if cmd == "supervisorctl reload": + client.publish(info_topic, payload=publish_payload(code=200, msg='reloading'), qos=0) + subprocess.Popen([cmd], shell=True) + return + # subprocess.Popen([cmd], shell=True) + p = subprocess.Popen([cmd], shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE) + out, err = p.communicate() + output = out.decode('utf-8').strip() + client.publish(info_topic, payload=publish_payload(code=200, msg=output), qos=0) + + +def get_status(client): + p = subprocess.Popen(['supervisorctl status'], + shell=True, + stdout=subprocess.PIPE, + stderr=subprocess.PIPE) + out, err = p.communicate() + output = out.decode('utf-8').strip() + client.publish(info_topic, payload=publish_payload(code=200, msg=output), qos=0) + + +def update(client): + p = subprocess.Popen(['/bin/bash /home/pi/lot_manager/git_update.sh'], + shell=True, + stdout=subprocess.PIPE, + stderr=subprocess.PIPE) + out, err = p.communicate() + output = out.decode('utf-8').strip() + client.publish(info_topic, payload=publish_payload(code=200, msg=output), + qos=0) + + +def reload(client): + client.publish(info_topic, payload=publish_payload(200, "reloading"), qos=0) + subprocess.Popen(['supervisorctl reload'], shell=True) + + +def get_list_record(client): + try: + data = { + "data": os.listdir(mp4_path) + } + r = requests.post(post_record_list_url, json=data) + client.publish(info_topic, payload=publish_payload(code=200, msg=str(r)), qos=0) + except: + pass + + +def up(msg, client): + try: + filename = json.loads(msg.payload.decode('utf-8'))["data"] + if filename is None or filename == '': + client.publish(info_topic, payload=publish_payload(code=404, msg='没有该文件'), qos=0) + return + + files = {filename: open(os.path.join(mp4_path, filename), 'rb'), "Content-Type": "application/octet-stream"} + r = requests.post(post_record_url, files=files) + client.publish(info_topic, payload=publish_payload(code=200, msg=str(r)), qos=0) + except: + pass + + +def get_record(msg, client): + threading.Thread(target=up, args=(msg, client)).start()