fix FetchMedias Action

This commit is contained in:
jxxghp
2025-05-19 12:26:27 +08:00
parent 7c76c3ccd6
commit ae1a5460d4
+17 -3
View File
@@ -40,54 +40,67 @@ class FetchMediasAction(BaseAction):
{ {
"func": RecommendChain().tmdb_trending, "func": RecommendChain().tmdb_trending,
"name": '流行趋势', "name": '流行趋势',
"api_path": "recommend/tmdb_trending"
}, },
{ {
"func": RecommendChain().douban_movie_showing, "func": RecommendChain().douban_movie_showing,
"name": '正在热映', "name": '正在热映',
"api_path": "recommend/douban_showing"
}, },
{ {
"func": RecommendChain().bangumi_calendar, "func": RecommendChain().bangumi_calendar,
"name": 'Bangumi每日放送', "name": 'Bangumi每日放送',
"api_path": "recommend/bangumi_calendar"
}, },
{ {
"func": RecommendChain().tmdb_movies, "func": RecommendChain().tmdb_movies,
"name": 'TMDB热门电影', "name": 'TMDB热门电影',
"api_path": "recommend/tmdb_movies"
}, },
{ {
"func": RecommendChain().tmdb_tvs, "func": RecommendChain().tmdb_tvs,
"name": 'TMDB热门电视剧', "name": 'TMDB热门电视剧',
"api_path": "recommend/tmdb_tvs?with_original_language=zh|en|ja|ko"
}, },
{ {
"func": RecommendChain().douban_movie_hot, "func": RecommendChain().douban_movie_hot,
"name": '豆瓣热门电影', "name": '豆瓣热门电影',
"api_path": "recommend/douban_movie_hot"
}, },
{ {
"func": RecommendChain().douban_tv_hot, "func": RecommendChain().douban_tv_hot,
"name": '豆瓣热门电视剧', "name": '豆瓣热门电视剧',
"api_path": "recommend/douban_tv_hot"
}, },
{ {
"func": RecommendChain().douban_tv_animation, "func": RecommendChain().douban_tv_animation,
"name": '豆瓣热门动漫', "name": '豆瓣热门动漫',
"api_path": "recommend/douban_tv_animation"
}, },
{ {
"func": RecommendChain().douban_movies, "func": RecommendChain().douban_movies,
"name": '豆瓣最新电影', "name": '豆瓣最新电影',
"api_path": "recommend/douban_movies"
}, },
{ {
"func": RecommendChain().douban_tvs, "func": RecommendChain().douban_tvs,
"name": '豆瓣最新电视剧', "name": '豆瓣最新电视剧',
"api_path": "recommend/douban_tvs"
}, },
{ {
"func": RecommendChain().douban_movie_top250, "func": RecommendChain().douban_movie_top250,
"name": '豆瓣电影TOP250', "name": '豆瓣电影TOP250',
"api_path": "recommend/douban_movie_top250"
}, },
{ {
"func": RecommendChain().douban_tv_weekly_chinese, "func": RecommendChain().douban_tv_weekly_chinese,
"name": '豆瓣国产剧集榜', "name": '豆瓣国产剧集榜',
"api_path": "recommend/douban_tv_weekly_chinese"
}, },
{ {
"func": RecommendChain().douban_tv_weekly_global, "func": RecommendChain().douban_tv_weekly_global,
"name": '豆瓣全球剧集榜', "name": '豆瓣全球剧集榜',
"api_path": "recommend/douban_tv_weekly_global"
} }
] ]
@@ -124,7 +137,7 @@ class FetchMediasAction(BaseAction):
获取数据源 获取数据源
""" """
for s in self.__inner_sources: for s in self.__inner_sources:
if s['name'] == source: if s['api_path'] == source:
return s return s
return None return None
@@ -135,13 +148,14 @@ class FetchMediasAction(BaseAction):
params = FetchMediasParams(**params) params = FetchMediasParams(**params)
try: try:
if params.source_type == "ranking": if params.source_type == "ranking":
for name in params.sources: for api_path in params.sources:
if global_vars.is_workflow_stopped(workflow_id): if global_vars.is_workflow_stopped(workflow_id):
break break
source = self.__get_source(name) source = self.__get_source(api_path)
if not source: if not source:
continue continue
logger.info(f"获取媒体数据 {source} ...") logger.info(f"获取媒体数据 {source} ...")
name = source.get("name")
results = [] results = []
if source.get("func"): if source.get("func"):
results = source['func']() results = source['func']()