diff --git a/reproject/main.py b/reproject/main.py index 39e9155..294308e 100644 --- a/reproject/main.py +++ b/reproject/main.py @@ -17,7 +17,7 @@ from HeartRateMonitor import HeartRateMonitor SERVER_HOST = "10.128.50.6" SERVER_PORT = 65432 API_URL = "http://10.128.50.6:5000/api/states" -CAMERA_ID = "23373333" +CAMERA_ID = 5 BASIC_FACE_DB = { "Zhihang": {"name": "Zhihang Deng", "age": 20, "image-path": "zhihang.png"}, @@ -125,7 +125,7 @@ def analysis_thread(): payload = { "seat_id": CAMERA_ID, - "timestamp": time.strftime("%Y-%m-%d %H:%M:%S"), + "timestamp": int(time.time()), "heart_rate": 0, "emo_v": 0, "emo_a": 0, @@ -135,14 +135,14 @@ def analysis_thread(): "ear": 0, "mar": 0, "label": "", - "eye_close_freq": 0.0, + "eye_close_freq": 0, "iris_ratio_x": 0, "iris_ratio_y": 0, } front_data = { "seat_id": CAMERA_ID, - "timestamp": time.strftime("%Y-%m-%d %H:%M:%S"), + "timestamp": int(time.time()), "label": "", "eye_close_freq": 0.0, "iris_ratio_x": 0, @@ -299,7 +299,6 @@ def video_stream_thread(): server.provide_frame(frame) data = front_data_queue.get(timeout=1) server.send_data(json.dumps(data)) - out1.write(frame) # out2.write(frame) except queue.Empty: @@ -405,9 +404,11 @@ def data_upload_thread(): print( f"[Data Upload {i+1}/{BURST_COUNT}] {id_info} | Time:{data['time']}" ) + # print(json.dumps(data, indent=2)) except Exception as e: print(f"[Data] Upload Error: {e}") + # print(json.dumps(data, indent=2)) except queue.Empty: print(f"[Data] 队列为空,跳过第 {i+1} 次发送")