From fabd9f2f75e8b495df360f1c05fc1dc536073222 Mon Sep 17 00:00:00 2001 From: jxxghp Date: Thu, 9 Jan 2025 16:01:52 +0800 Subject: [PATCH] =?UTF-8?q?feat=EF=BC=9A=E5=88=86=E4=BA=AB=E8=AE=A2?= =?UTF-8?q?=E9=98=85=E5=90=8E=E6=B8=85=E9=99=A4=E7=BC=93=E5=AD=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/helper/subscribe.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/app/helper/subscribe.py b/app/helper/subscribe.py index a9b56700..fe64022b 100644 --- a/app/helper/subscribe.py +++ b/app/helper/subscribe.py @@ -30,6 +30,8 @@ class SubscribeHelper(metaclass=Singleton): _sub_fork = f"{settings.MP_SERVER_HOST}/subscribe/fork/%s" + _shares_cache = TTLCache(maxsize=20, ttl=1800) + def __init__(self): self.systemconfig = SystemConfigOper() if settings.SUBSCRIBE_STATISTIC_SHARE: @@ -136,6 +138,8 @@ class SubscribeHelper(metaclass=Singleton): if res is None: return False, "连接MoviePilot服务器失败" if res.ok: + # 清除 get_shares 的缓存，以便实时看到结果 + self._shares_cache.clear() return True, "" else: return False, res.json().get("message") @@ -156,7 +160,7 @@ class SubscribeHelper(metaclass=Singleton): else: return False, res.json().get("message") - @cached(cache=TTLCache(maxsize=20, ttl=1800)) + @cached(cache=_shares_cache) def get_shares(self, name: str, page: int = 1, count: int = 30) -> List[dict]: """ 获取订阅分享数据