nas/MoviePilot
1
0
Fork 0
mirror of https://github.com/jxxghp/MoviePilot.git synced 2026-04-24 18:52:07 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(sync): skip disabled mediaservers and empty libraries

Browse Source
This commit is contained in:
InfinityPacer
2024-09-13 00:58:03 +08:00
parent 9a62feb9a9
commit 9129de1720
1 changed files with 14 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
app/chain/mediaserver.py
View File

@@ -80,27 +80,31 @@ class MediaServerChain(ChainBase):
for mediaserver in mediaservers:
if not mediaserver:
continue
logger.info(f"正在准备同步媒体服务器 {mediaserver.name} 的数据")
if not mediaserver.enabled:
logger.info(f"媒体服务器 {mediaserver.name} 未启用，跳过")
continue
server_name = mediaserver.name
sync_libraries = mediaserver.sync_libraries or []
logger.info(f"开始同步媒体库 {server_name} 的数据 ...")
if not sync_libraries:
logger.info(f"媒体服务器 {server_name} 的同步媒体库为空，跳过")
continue
logger.info(f"开始同步媒体服务器 {server_name} 的数据 ...")
for library in self.librarys(server_name):
# 同步黑名单 跳过
if sync_libraries and library.id not in sync_libraries:
logger.info(f"{server_name} 未在同步媒体库列表中，跳过")
logger.info(f"{library.name} 未在 {server_name} 同步媒体库列表中，跳过")
continue
logger.info(f"正在同步 {server_name} 媒体库 {library.name} ...")
library_count = 0
for item in self.items(server_name, library.id):
if not item:
continue
if not item.item_id:
if not item or not item.item_id:
continue
logger.debug(f"正在同步 {item.title} ...")
# 计数
library_count += 1
seasoninfo = {}
# 类型
item_type = "电视剧" if item.item_type in ['Series', 'show'] else "电影"
item_type = "电视剧" if item.item_type in ["Series", "show"] else "电影"
if item_type == "电视剧":
# 查询剧集信息
espisodes_info = self.episodes(server_name, item.item_id) or []
@@ -108,10 +112,10 @@ class MediaServerChain(ChainBase):
seasoninfo[episode.season] = episode.episodes
# 插入数据
item_dict = item.dict()
item_dict['seasoninfo'] = json.dumps(seasoninfo)
item_dict['item_type'] = item_type
item_dict["seasoninfo"] = json.dumps(seasoninfo)
item_dict["item_type"] = item_type
self.dboper.add(**item_dict)
logger.info(f"{server_name} 媒体库 {library.name} 同步完成，共同步数量：{library_count}")
# 总数累加
total_count += library_count
logger.info(f"媒体库 {server_name} 数据同步完成，同步数量：%s" % total_count)
logger.info(f"媒体服务器 {server_name} 数据同步完成，总同步数量：{total_count}")