♻️ 优化任务插件选项读取逻辑

This commit is contained in:
Cp0204 2024-11-27 01:10:25 +08:00
parent 9d599b5e64
commit 10030346d0
2 changed files with 17 additions and 12 deletions

View File

@ -58,9 +58,11 @@ class Alist_strm_gen:
self.strm_server = f"{self.url.strip()}/d" self.strm_server = f"{self.url.strip()}/d"
def run(self, task, **kwargs): def run(self, task, **kwargs):
if task_config := task.get("addition", {}).get(self.plugin_name, {}): task_config = task.get("addition", {}).get(
if not task_config.get("auto_gen"): self.plugin_name, self.default_task_config
return )
if not task_config.get("auto_gen"):
return
if task.get("savepath") and task.get("savepath").startswith( if task.get("savepath") and task.get("savepath").startswith(
self.quark_root_dir self.quark_root_dir
): ):

View File

@ -26,15 +26,18 @@ class Emby:
self.is_active = True self.is_active = True
def run(self, task, **kwargs): def run(self, task, **kwargs):
if task_config := task.get("addition", {}).get(self.plugin_name, {}): task_config = task.get("addition", {}).get(
if media_id := task_config.get("media_id"): self.plugin_name, self.default_task_config
if media_id != "0": )
self.refresh(media_id) if media_id := task_config.get("media_id"):
elif task_config.get("try_match"): if media_id != "0":
if match_media_id := self.search(task["taskname"]): self.refresh(media_id)
self.refresh(match_media_id) elif task_config.get("try_match"):
task["addition"][self.plugin_name]["media_id"] = match_media_id if match_media_id := self.search(task["taskname"]):
return task self.refresh(match_media_id)
task_config["media_id"] = match_media_id
task.setdefault("addition", {})[self.plugin_name] = task_config
return task
def get_info(self): def get_info(self):
url = f"{self.url}/emby/System/Info" url = f"{self.url}/emby/System/Info"