From 8da4ef9e932156128615a221d56dd8f2bae1c783 Mon Sep 17 00:00:00 2001
From: 16337 <1633794139@qq.com>
Date: Thu, 19 Mar 2026 10:56:28 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=EF=BC=9ARedis=20=E9=85=8D?=
 =?UTF-8?q?=E7=BD=AE=E5=8A=A0=E8=BD=BD=E6=97=B6=E4=BC=A0=E5=85=A5=20alarm?=
 =?UTF-8?q?=5Flevel=20=E5=88=B0=E7=AE=97=E6=B3=95=E5=AE=9E=E4=BE=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Redis 订阅路径初始化算法时漏传 alarm_level 参数，
导致前端配置的告警等级不生效，始终使用默认值。
---
 algorithms.py | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/algorithms.py b/algorithms.py
index c7f7ea2..1b39fbc 100644
--- a/algorithms.py
+++ b/algorithms.py
@@ -1347,6 +1347,7 @@ class AlgorithmManager:
                 key = f"{roi_id}_{bind_id}"
                 
                 if algo_code == "leave_post":
+                    configured_alarm_level = params.get("alarm_level")
                     algo_params = {
                         "confirm_on_duty_sec": params.get("confirm_on_duty_sec", 10),
                         "confirm_leave_sec": params.get("confirm_leave_sec", 30),
@@ -1360,6 +1361,8 @@ class AlgorithmManager:
                         algo.confirm_leave_sec = algo_params["confirm_leave_sec"]
                         algo.cooldown_sec = algo_params["cooldown_sec"]
                         algo.target_class = algo_params["target_class"]
+                        if configured_alarm_level is not None:
+                            algo._alarm_level = configured_alarm_level
                         if algo_params["working_hours"]:
                             algo.working_hours = algo_params["working_hours"]
                         logger.info(f"已热更新算法参数: {key}")
@@ -1368,13 +1371,15 @@ class AlgorithmManager:
                         self.algorithms[roi_id][key]["leave_post"] = LeavePostAlgorithm(
                             confirm_on_duty_sec=algo_params["confirm_on_duty_sec"],
                             confirm_leave_sec=algo_params["confirm_leave_sec"],
-                            leave_countdown_sec=algo_params.get("leave_countdown_sec", 300),  # 离岗倒计时，默认5分钟
+                            leave_countdown_sec=algo_params.get("leave_countdown_sec", 300),
                             cooldown_sec=algo_params["cooldown_sec"],
                             working_hours=algo_params["working_hours"],
                             target_class=algo_params["target_class"],
+                            alarm_level=configured_alarm_level,
                         )
                         logger.info(f"已从Redis加载算法: {key}")
                 elif algo_code == "intrusion":
+                    configured_alarm_level = params.get("alarm_level")
                     algo_params = {
                         "cooldown_seconds": params.get("cooldown_seconds", 300),
                         "confirm_seconds": params.get("confirm_seconds", 5),
@@ -1385,6 +1390,7 @@ class AlgorithmManager:
                         cooldown_seconds=algo_params["cooldown_seconds"],
                         confirm_seconds=algo_params["confirm_seconds"],
                         target_class=algo_params["target_class"],
+                        alarm_level=configured_alarm_level,
                     )
                     logger.info(f"已从Redis加载算法: {key}")