From 659f4f2b0d227ed0dcc716deb471edc919eb565d Mon Sep 17 00:00:00 2001
From: AkaiShuichi7 <wangdepeng7@gmail.com>
Date: Tue, 20 Jan 2026 23:43:51 +0800
Subject: [PATCH] =?UTF-8?q?fix(MediaServerMsg):=20=E4=BC=98=E5=8C=96?=
 =?UTF-8?q?=E5=8E=BB=E9=87=8D=E9=80=BB=E8=BE=91=E5=B9=B6=E4=BF=AE=E5=A4=8D?=
 =?UTF-8?q?=E6=BD=9C=E5=9C=A8=E5=86=85=E5=AD=98=E6=B3=84=E6=BC=8F=20(PR=20?=
 =?UTF-8?q?review)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 plugins.v2/mediaservermsg/__init__.py | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/plugins.v2/mediaservermsg/__init__.py b/plugins.v2/mediaservermsg/__init__.py
index f386f60..760d01a 100644
--- a/plugins.v2/mediaservermsg/__init__.py
+++ b/plugins.v2/mediaservermsg/__init__.py
@@ -29,6 +29,7 @@ class MediaServerMsg(_PluginBase):
     # 常量定义
     DEFAULT_EXPIRATION_TIME = 600                  # 默认过期时间（秒）
     DEFAULT_AGGREGATE_TIME = 15                   # 默认聚合时间（秒）
+    DEDUPE_EXPIRATION_TIME = 30                    # 去重缓存过期时间（秒）
 
     # 插件基本信息
     plugin_name = "媒体库服务器通知"
@@ -462,11 +463,11 @@ class MediaServerMsg(_PluginBase):
                 # 使用 server_name + event_type + item_id 作为唯一标识
                 dedupe_key = f"{server_name}-{event_type}-{item_id}" if server_name else f"{event_type}-{item_id}"
                 # 检查是否已处理过该事件
-                if dedupe_key in self._webhook_msg_keys:
+                if dedupe_key in self.__get_elements():
                     logger.debug(f"检测到重复Webhook事件，已处理过: {dedupe_key}")
                     return
                 # 添加到去重缓存（30秒过期）
-                self.__add_element(dedupe_key, duration=30)
+                self.__add_element(dedupe_key, duration=self.DEDUPE_EXPIRATION_TIME)
 
             # TV剧集结入库聚合处理
             logger.debug("检查是否需要进行TV剧集聚合处理")