From 5447f4363b09c51327cb5170443dfce6cf7372ef Mon Sep 17 00:00:00 2001
From: zqc <835569504@qq.com>
Date: Fri, 27 Feb 2026 14:55:21 +0800
Subject: [PATCH] =?UTF-8?q?=E7=9B=91=E7=8B=B12=E6=B5=8B=E8=AF=95=E9=80=9A?=
 =?UTF-8?q?=E8=BF=87?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 biz/prison/trajectory02_biz.py | 5 ++++-
 hls_service_ws_kadian.py       | 3 ++-
 2 files changed, 6 insertions(+), 2 deletions(-)

diff --git a/biz/prison/trajectory02_biz.py b/biz/prison/trajectory02_biz.py
index 0ba05a3..15cf3d8 100644
--- a/biz/prison/trajectory02_biz.py
+++ b/biz/prison/trajectory02_biz.py
@@ -482,11 +482,14 @@ class FrameProcessorWorker(threading.Thread):
     def __init__(self,
                  raw_frame_queue: "queue.Queue[Dict[str, Any]]",
                  ws_send_queue: "queue.Queue[Dict[str, Any]]",
-                 stop_event: threading.Event):
+                 stop_event: threading.Event,
+                 cameras=None):
         super().__init__(daemon=True)
         self.raw_queue = raw_frame_queue
         self.ws_queue = ws_send_queue
         self.stop_event = stop_event
+        # 将摄像头列表转换为字典，key为id，方便通过camera_id快速查找
+        self.cameras = {cam.id: cam for cam in cameras} if cameras is not None else {}
 
         self.last_ts: Dict[int, float] = {}
 
diff --git a/hls_service_ws_kadian.py b/hls_service_ws_kadian.py
index a0af1ef..883898d 100644
--- a/hls_service_ws_kadian.py
+++ b/hls_service_ws_kadian.py
@@ -13,8 +13,9 @@ import sys
 
 from dataclasses import dataclass
 
-from biz.checkpoint.checkpoint_biz import FrameProcessorWorker
+# from biz.checkpoint.checkpoint_biz import FrameProcessorWorker
 # from biz.prison.prison_biz import FrameProcessorWorker
+from biz.prison.trajectory02_biz import FrameProcessorWorker
 from common.camera_config import CameraConfig, parse_cameras_from_json, parse_cameras_from_yaml
 from common.contants import init_config
 from utils.web_socket_sender import WebSocketSender