fix 首页继续观看、最近添加排除黑名单媒体库

This commit is contained in:
thsrite
2024-01-08 13:05:09 +08:00
parent 8aa1027aae
commit c674e32046
5 changed files with 26 additions and 2 deletions

View File

@ -48,13 +48,33 @@ class MediaServerChain(ChainBase):
"""
获取媒体服务器正在播放信息
"""
return self.run_module("mediaserver_playing", count=count, server=server, username=username)
playing_items = self.run_module("mediaserver_playing", count=100, server=server, username=username)
# 判断是否在同步的媒体数据中
exists_items = []
for item in playing_items:
if self.dboper.exists(mtype=item.type,
title=item.title,
year=item.year):
exists_items.append(item)
if len(exists_items) == count:
break
return exists_items
def latest(self, count: int = 20, server: str = None, username: str = None) -> List[schemas.MediaServerPlayItem]:
"""
获取媒体服务器最新入库条目
"""
return self.run_module("mediaserver_latest", count=count, server=server, username=username)
latest_items = self.run_module("mediaserver_latest", count=100, server=server, username=username)
# 判断是否在同步的媒体数据中
exists_items = []
for item in latest_items:
if self.dboper.exists(mtype=item.type,
title=item.title,
year=item.subtitle):
exists_items.append(item)
if len(exists_items) == count:
break
return exists_items
def get_play_url(self, server: str, item_id: Union[str, int]) -> Optional[str]:
"""