GithubBackup/MoviePilot
1
0
Fork 0
mirror of https://github.com/jxxghp/MoviePilot.git synced 2026-09-05 15:38:19 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat：分享订阅后清除缓存

Browse Source
This commit is contained in:
jxxghp
2025-01-09 16:01:52 +08:00
parent 0d8480769f
commit fabd9f2f75
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/helper/subscribe.py
+5 -1
View File
@@ -30,6 +30,8 @@ class SubscribeHelper(metaclass=Singleton):
_sub_fork = f"{settings.MP_SERVER_HOST}/subscribe/fork/%s" _sub_fork = f"{settings.MP_SERVER_HOST}/subscribe/fork/%s"
_shares_cache = TTLCache(maxsize=20, ttl=1800)
def __init__(self): def __init__(self):
self.systemconfig = SystemConfigOper() self.systemconfig = SystemConfigOper()
if settings.SUBSCRIBE_STATISTIC_SHARE: if settings.SUBSCRIBE_STATISTIC_SHARE:
@@ -136,6 +138,8 @@ class SubscribeHelper(metaclass=Singleton):
if res is None: if res is None:
return False, "连接MoviePilot服务器失败" return False, "连接MoviePilot服务器失败"
if res.ok: if res.ok:
# 清除 get_shares 的缓存，以便实时看到结果
self._shares_cache.clear()
return True, "" return True, ""
else: else:
return False, res.json().get("message") return False, res.json().get("message")
@@ -156,7 +160,7 @@ class SubscribeHelper(metaclass=Singleton):
else: else:
return False, res.json().get("message") 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]: def get_shares(self, name: str, page: int = 1, count: int = 30) -> List[dict]:
""" """
获取订阅分享数据 获取订阅分享数据