mirror of
https://github.com/thsrite/MoviePilot-Plugins.git
synced 2026-03-27 10:05:57 +00:00
793 lines
34 KiB
Python
793 lines
34 KiB
Python
import os
|
||
import shutil
|
||
import urllib.parse
|
||
from datetime import datetime, timedelta
|
||
from pathlib import Path
|
||
from typing import Any, List, Dict, Tuple, Optional
|
||
|
||
import pytz
|
||
from apscheduler.schedulers.background import BackgroundScheduler
|
||
from apscheduler.triggers.cron import CronTrigger
|
||
|
||
from app.core.config import settings
|
||
from app.core.event import eventmanager, Event
|
||
from app.log import logger
|
||
from app.plugins import _PluginBase
|
||
from app.schemas.types import EventType
|
||
from app.utils.system import SystemUtils
|
||
|
||
|
||
class CloudStrmIncrement(_PluginBase):
|
||
# 插件名称
|
||
plugin_name = "云盘Strm生成（增量版）"
|
||
# 插件描述
|
||
plugin_desc = "定时扫描云盘文件，生成Strm文件（增量版）。"
|
||
# 插件图标
|
||
plugin_icon = "https://raw.githubusercontent.com/thsrite/MoviePilot-Plugins/main/icons/create.png"
|
||
# 插件版本
|
||
plugin_version = "1.1.4"
|
||
# 插件作者
|
||
plugin_author = "thsrite"
|
||
# 作者主页
|
||
author_url = "https://github.com/thsrite"
|
||
# 插件配置项ID前缀
|
||
plugin_config_prefix = "cloudstrm_"
|
||
# 加载顺序
|
||
plugin_order = 26
|
||
# 可使用的用户级别
|
||
auth_level = 1
|
||
|
||
# 私有属性
|
||
_enabled = False
|
||
_cron = None
|
||
_monitor_confs = None
|
||
_onlyonce = False
|
||
_copy_files = False
|
||
_https = False
|
||
_del_source = False
|
||
_no_del_dirs = None
|
||
_rmt_mediaext = ".mp4, .mkv, .ts, .iso,.rmvb, .avi, .mov, .mpeg,.mpg, .wmv, .3gp, .asf, .m4v, .flv, .m2ts, .strm,.tp, .f4v"
|
||
_observer = []
|
||
|
||
# 公开属性
|
||
_increment_dir = {}
|
||
_dirconf = {}
|
||
_libraryconf = {}
|
||
_cloudtypeconf = {}
|
||
_cloudurlconf = {}
|
||
_cloudpathconf = {}
|
||
|
||
# 定时器
|
||
_scheduler: Optional[BackgroundScheduler] = None
|
||
|
||
def init_plugin(self, config: dict = None):
|
||
# 清空配置
|
||
self._dirconf = {}
|
||
self._libraryconf = {}
|
||
self._cloudtypeconf = {}
|
||
self._cloudurlconf = {}
|
||
self._cloudpathconf = {}
|
||
self._increment_dir = {}
|
||
|
||
if config:
|
||
self._enabled = config.get("enabled")
|
||
self._cron = config.get("cron")
|
||
self._onlyonce = config.get("onlyonce")
|
||
self._https = config.get("https")
|
||
self._copy_files = config.get("copy_files")
|
||
self._monitor_confs = config.get("monitor_confs")
|
||
self._no_del_dirs = config.get("no_del_dirs")
|
||
self._del_source = config.get("del_source")
|
||
self._rmt_mediaext = config.get(
|
||
"rmt_mediaext") or ".mp4, .mkv, .ts, .iso,.rmvb, .avi, .mov, .mpeg,.mpg, .wmv, .3gp, .asf, .m4v, .flv, .m2ts, .strm,.tp, .f4v"
|
||
|
||
# 停止现有任务
|
||
self.stop_service()
|
||
|
||
if self._enabled or self._onlyonce:
|
||
# 定时服务
|
||
self._scheduler = BackgroundScheduler(timezone=settings.TZ)
|
||
|
||
# 读取目录配置
|
||
monitor_confs = self._monitor_confs.split("\n")
|
||
if not monitor_confs:
|
||
return
|
||
for monitor_conf in monitor_confs:
|
||
# 格式 源目录:目的目录:媒体库内网盘路径:监控模式
|
||
if not monitor_conf:
|
||
continue
|
||
# 注释
|
||
if str(monitor_conf).startswith("#"):
|
||
continue
|
||
|
||
if str(monitor_conf).count("#") == 3:
|
||
increment_dir = str(monitor_conf).split("#")[0]
|
||
source_dir = str(monitor_conf).split("#")[1]
|
||
target_dir = str(monitor_conf).split("#")[2]
|
||
library_dir = str(monitor_conf).split("#")[3]
|
||
self._libraryconf[source_dir] = library_dir
|
||
elif str(monitor_conf).count("#") == 5:
|
||
increment_dir = str(monitor_conf).split("#")[0]
|
||
source_dir = str(monitor_conf).split("#")[1]
|
||
target_dir = str(monitor_conf).split("#")[2]
|
||
cloud_type = str(monitor_conf).split("#")[3]
|
||
cloud_path = str(monitor_conf).split("#")[4]
|
||
cloud_url = str(monitor_conf).split("#")[5]
|
||
self._cloudtypeconf[source_dir] = cloud_type
|
||
self._cloudpathconf[source_dir] = cloud_path
|
||
self._cloudurlconf[source_dir] = cloud_url
|
||
else:
|
||
logger.error(f"{monitor_conf} 格式错误")
|
||
continue
|
||
|
||
# 存储目录监控配置
|
||
self._dirconf[source_dir] = target_dir
|
||
|
||
# 增量配置
|
||
self._increment_dir[increment_dir] = source_dir
|
||
|
||
# 检查媒体库目录是不是下载目录的子目录
|
||
try:
|
||
if target_dir and Path(target_dir).is_relative_to(Path(source_dir)):
|
||
logger.warn(f"{target_dir} 是下载目录 {source_dir} 的子目录，无法监控")
|
||
self.systemmessage.put(f"{target_dir} 是下载目录 {source_dir} 的子目录，无法监控")
|
||
continue
|
||
except Exception as e:
|
||
logger.debug(str(e))
|
||
pass
|
||
|
||
# 运行一次定时服务
|
||
if self._onlyonce:
|
||
logger.info("云盘增量监控执行服务启动，立即运行一次")
|
||
self._scheduler.add_job(func=self.scan, trigger='date',
|
||
run_date=datetime.now(tz=pytz.timezone(settings.TZ)) + timedelta(seconds=3),
|
||
name="云盘增量监控")
|
||
# 关闭一次性开关
|
||
self._onlyonce = False
|
||
# 保存配置
|
||
self.__update_config()
|
||
|
||
# 周期运行
|
||
if self._cron:
|
||
try:
|
||
self._scheduler.add_job(func=self.scan,
|
||
trigger=CronTrigger.from_crontab(self._cron),
|
||
name="云盘增量监控")
|
||
except Exception as err:
|
||
logger.error(f"定时任务配置错误：{err}")
|
||
# 推送实时消息
|
||
self.systemmessage.put(f"执行周期配置错误：{err}")
|
||
|
||
# 启动任务
|
||
if self._scheduler.get_jobs():
|
||
self._scheduler.print_jobs()
|
||
self._scheduler.start()
|
||
|
||
@eventmanager.register(EventType.PluginAction)
|
||
def cloudstrm_file(self, event: Event = None):
|
||
if event:
|
||
event_data = event.event_data
|
||
if not event_data or event_data.get("action") != "cloudstrm_file":
|
||
return
|
||
|
||
file_path = event_data.get("file_path")
|
||
if not file_path:
|
||
logger.error(f"缺少参数：{event_data}")
|
||
return
|
||
|
||
self.__strm(source_file=file_path)
|
||
|
||
@eventmanager.register(EventType.PluginAction)
|
||
def scan(self, event: Event = None):
|
||
"""
|
||
扫描
|
||
"""
|
||
if not self._enabled:
|
||
logger.error("插件未开启")
|
||
return
|
||
if not self._dirconf or not self._dirconf.keys():
|
||
logger.error("未获取到可用目录监控配置，请检查")
|
||
return
|
||
|
||
if event:
|
||
event_data = event.event_data
|
||
if not event_data or event_data.get("action") != "cloud_strm_increment":
|
||
return
|
||
logger.info("收到命令，开始云盘strm生成 ...")
|
||
self.post_message(channel=event.event_data.get("channel"),
|
||
title="开始云盘strm生成 ...",
|
||
userid=event.event_data.get("user"))
|
||
|
||
logger.info("云盘strm生成任务开始")
|
||
for increment_dir in self._increment_dir.keys():
|
||
logger.info(f"正在扫描增量目录 {increment_dir}")
|
||
for root, dirs, files in os.walk(increment_dir):
|
||
# 如果遇到名为'extrafanart'的文件夹，则跳过处理该文件夹，继续处理其他文件夹
|
||
if "extrafanart" in dirs:
|
||
dirs.remove("extrafanart")
|
||
|
||
# 处理文件
|
||
for file in files:
|
||
increment_file = os.path.join(root, file)
|
||
if not Path(increment_file).exists():
|
||
continue
|
||
# 回收站及隐藏的文件不处理
|
||
if (increment_file.find("/@Recycle") != -1
|
||
or increment_file.find("/#recycle") != -1
|
||
or increment_file.find("/.") != -1
|
||
or increment_file.find("/@eaDir") != -1):
|
||
logger.info(f"{increment_file} 是回收站或隐藏的文件，跳过处理")
|
||
continue
|
||
|
||
# 不复制非媒体文件时直接过滤掉非媒体文件
|
||
if not self._copy_files and Path(file).suffix not in [ext.strip() for ext in
|
||
self._rmt_mediaext.split(",")]:
|
||
continue
|
||
|
||
logger.info(f"扫描到增量文件 {increment_file}，正在开始处理")
|
||
|
||
# 移动到目标目录
|
||
source_dir = self._increment_dir.get(increment_dir)
|
||
# 移动后文件
|
||
source_file = increment_file.replace(increment_dir, source_dir)
|
||
|
||
logger.info(f"移动后增量文件 {source_file}")
|
||
|
||
# 判断目标文件是否存在
|
||
if not Path(source_file).parent.exists():
|
||
Path(source_file).mkdir(parents=True, exist_ok=True)
|
||
logger.info(f"创建增量文件父目录 {str(Path(source_file).parent)}")
|
||
|
||
if self._del_source:
|
||
shutil.copy2(increment_file, source_file)
|
||
logger.info(f"移动增量文件 {increment_file} 到 {source_file}")
|
||
Path(increment_file).unlink()
|
||
else:
|
||
shutil.copy2(increment_file, source_file)
|
||
logger.info(f"复制增量文件 {increment_file} 到 {source_file}")
|
||
|
||
# 扫描云盘文件，判断是否有对应strm
|
||
self.__strm(source_file)
|
||
logger.info(f"增量文件 {increment_file} 处理完成")
|
||
|
||
# 判断当前媒体父路径下是否有媒体文件，如有则无需遍历父级
|
||
if not SystemUtils.exits_files(Path(increment_file).parent, []):
|
||
# 判断父目录是否为空, 为空则删除
|
||
for parent_path in Path(increment_file).parents:
|
||
if parent_path.name in self._no_del_dirs:
|
||
break
|
||
if str(parent_path.name) == str(increment_dir):
|
||
break
|
||
if str(parent_path.parent) != str(Path(increment_file).root):
|
||
# 父目录非根目录，才删除父目录
|
||
if not SystemUtils.exits_files(parent_path, []):
|
||
# 当前路径下没有媒体文件则删除
|
||
shutil.rmtree(parent_path)
|
||
logger.warn(f"增量非保留目录 {parent_path} 已删除")
|
||
|
||
logger.info("云盘strm生成任务完成")
|
||
if event:
|
||
self.post_message(channel=event.event_data.get("channel"),
|
||
title="云盘strm生成任务完成！",
|
||
userid=event.event_data.get("user"))
|
||
|
||
# def move_file(self,
|
||
# file_path: Path,
|
||
# dest_path: Path,
|
||
# is_check_disk_space: bool = True,
|
||
# min_free_space: int = 300,
|
||
# wait_time: int = 300,
|
||
# check_paths: Optional[List[Path]] = None,
|
||
# ) -> bool:
|
||
# """
|
||
# 移动文件,如果父文件夹为空,则删除空父文件夹
|
||
# """
|
||
# # 在目标路径存在时，会尝试覆盖它
|
||
# if not file_path.exists():
|
||
# logger.debug(f"move文件不存在,跳过处理: {file_path}")
|
||
#
|
||
# if is_check_disk_space:
|
||
# if not check_paths:
|
||
# check_paths = [dest_path.parent]
|
||
# check_paths.append(data_path)
|
||
#
|
||
# for check_path in check_paths:
|
||
# while check_disk_space(check_path, min_free_space):
|
||
# logger.warning(
|
||
# f"文件 {check_path} 空间不足,等待 {wait_time}s再处理:"
|
||
# f" {file_path}"
|
||
# )
|
||
# sleep(wait_time)
|
||
#
|
||
# logger.debug(f"移动文件: {file_path} -> {dest_path}")
|
||
#
|
||
# # # 改用copy2,避免移动文件夹时,程序中断导致文件丢失
|
||
# # is_copyed = copy(file_path, dest_path)
|
||
# # # 复制成功才继续执行
|
||
# # if not is_copyed:
|
||
# # logger.warning(f"移动文件失败: {file_path} -> {dest_path}")
|
||
# # return False
|
||
#
|
||
# # # 复制后再删除文件
|
||
# # logger.debug(f"已复制文件:{file_path}, 正在删除文件: {file_path}")
|
||
#
|
||
# try:
|
||
# if not dest_path.parent.exists():
|
||
# dest_path.parent.mkdir(parents=True, exist_ok=True)
|
||
#
|
||
# cloud_str = "/mnt/cloud"
|
||
# if str(file_path).startswith(cloud_str) and str(dest_path).startswith(
|
||
# cloud_str
|
||
# ):
|
||
# # 如果是云盘路径，则使用重命名
|
||
# file_path.rename(dest_path)
|
||
# else:
|
||
# shutil.move(file_path, dest_path, copy_function=shutil.copy2)
|
||
|
||
def __strm(self, source_file):
|
||
"""
|
||
判断文件是否有对应strm
|
||
"""
|
||
try:
|
||
# 获取文件的转移路径
|
||
for source_dir in self._dirconf.keys():
|
||
if str(source_file).startswith(source_dir):
|
||
# 转移路径
|
||
dest_dir = self._dirconf.get(source_dir)
|
||
# 媒体库容器内挂载路径
|
||
library_dir = self._libraryconf.get(source_dir)
|
||
# 云服务类型
|
||
cloud_type = self._cloudtypeconf.get(source_dir)
|
||
# 云服务挂载本地跟路径
|
||
cloud_path = self._cloudpathconf.get(source_dir)
|
||
# 云服务地址
|
||
cloud_url = self._cloudurlconf.get(source_dir)
|
||
|
||
# 转移后文件
|
||
dest_file = source_file.replace(source_dir, dest_dir)
|
||
# 如果是文件夹
|
||
if Path(dest_file).is_dir():
|
||
if not Path(dest_file).exists():
|
||
logger.info(f"创建目标文件夹 {dest_file}")
|
||
os.makedirs(dest_file)
|
||
continue
|
||
else:
|
||
# 非媒体文件
|
||
if Path(dest_file).exists():
|
||
logger.info(f"目标文件 {dest_file} 已存在")
|
||
continue
|
||
|
||
# 文件
|
||
if not Path(dest_file).parent.exists():
|
||
logger.info(f"创建目标文件夹 {Path(dest_file).parent}")
|
||
os.makedirs(Path(dest_file).parent)
|
||
|
||
# 视频文件创建.strm文件
|
||
if Path(dest_file).suffix in [ext.strip() for ext in self._rmt_mediaext.split(",")]:
|
||
# 创建.strm文件
|
||
self.__create_strm_file(scheme="https" if self._https else "http",
|
||
dest_file=dest_file,
|
||
dest_dir=dest_dir,
|
||
source_file=source_file,
|
||
library_dir=library_dir,
|
||
cloud_type=cloud_type,
|
||
cloud_path=cloud_path,
|
||
cloud_url=cloud_url)
|
||
else:
|
||
if self._copy_files:
|
||
# 其他nfo、jpg等复制文件
|
||
shutil.copy2(source_file, dest_file)
|
||
logger.info(f"复制其他文件 {source_file} 到 {dest_file}")
|
||
except Exception as e:
|
||
logger.error(f"create strm file error: {e}")
|
||
print(str(e))
|
||
|
||
@staticmethod
|
||
def __create_strm_file(dest_file: str, dest_dir: str, source_file: str, library_dir: str = None,
|
||
cloud_type: str = None, cloud_path: str = None, cloud_url: str = None,
|
||
scheme: str = None):
|
||
"""
|
||
生成strm文件
|
||
:param library_dir:
|
||
:param dest_dir:
|
||
:param dest_file:
|
||
"""
|
||
try:
|
||
# 获取视频文件名和目录
|
||
video_name = Path(dest_file).name
|
||
# 获取视频目录
|
||
dest_path = Path(dest_file).parent
|
||
|
||
if not dest_path.exists():
|
||
logger.info(f"创建目标文件夹 {dest_path}")
|
||
os.makedirs(str(dest_path))
|
||
|
||
# 构造.strm文件路径
|
||
strm_path = os.path.join(dest_path, f"{os.path.splitext(video_name)[0]}.strm")
|
||
# strm已存在跳过处理
|
||
if Path(strm_path).exists():
|
||
logger.info(f"strm文件已存在 {strm_path}")
|
||
return
|
||
|
||
logger.info(f"替换前本地路径:::{dest_file}")
|
||
|
||
# 云盘模式
|
||
if cloud_type:
|
||
# 替换路径中的\为/
|
||
dest_file = source_file.replace("\\", "/")
|
||
dest_file = dest_file.replace(cloud_path, "")
|
||
# 对盘符之后的所有内容进行url转码
|
||
dest_file = urllib.parse.quote(dest_file, safe='')
|
||
if str(cloud_type) == "cd2":
|
||
# 将路径的开头盘符"/mnt/user/downloads"替换为"http://localhost:19798/static/http/localhost:19798/False/"
|
||
dest_file = f"{scheme}://{cloud_url}/static/{scheme}/{cloud_url}/False/{dest_file}"
|
||
logger.info(f"替换后cd2路径:::{dest_file}")
|
||
elif str(cloud_type) == "alist":
|
||
dest_file = f"{scheme}://{cloud_url}/d/{dest_file}"
|
||
logger.info(f"替换后alist路径:::{dest_file}")
|
||
else:
|
||
logger.error(f"云盘类型 {cloud_type} 错误")
|
||
return
|
||
else:
|
||
# 本地挂载路径转为emby路径
|
||
dest_file = dest_file.replace(dest_dir, library_dir)
|
||
logger.info(f"替换后emby容器内路径:::{dest_file}")
|
||
|
||
# 写入.strm文件
|
||
with open(strm_path, 'w', encoding='utf-8') as f:
|
||
f.write(dest_file)
|
||
|
||
logger.info(f"创建strm文件 {strm_path}")
|
||
except Exception as e:
|
||
logger.error(f"创建strm文件失败")
|
||
print(str(e))
|
||
|
||
def __update_config(self):
|
||
"""
|
||
更新配置
|
||
"""
|
||
self.update_config({
|
||
"enabled": self._enabled,
|
||
"onlyonce": self._onlyonce,
|
||
"copy_files": self._copy_files,
|
||
"https": self._https,
|
||
"cron": self._cron,
|
||
"monitor_confs": self._monitor_confs,
|
||
"no_del_dirs": self._no_del_dirs,
|
||
"del_source": self._del_source,
|
||
"rmt_mediaext": self._rmt_mediaext
|
||
})
|
||
|
||
def get_state(self) -> bool:
|
||
return self._enabled
|
||
|
||
@staticmethod
|
||
def get_command() -> List[Dict[str, Any]]:
|
||
"""
|
||
定义远程控制命令
|
||
:return: 命令关键字、事件、描述、附带数据
|
||
"""
|
||
return [{
|
||
"cmd": "/cloud_strm_increment",
|
||
"event": EventType.PluginAction,
|
||
"desc": "云盘strm文件生成(增量版)",
|
||
"category": "",
|
||
"data": {
|
||
"action": "cloud_strm_increment"
|
||
}
|
||
}]
|
||
|
||
def get_service(self) -> List[Dict[str, Any]]:
|
||
"""
|
||
注册插件公共服务
|
||
[{
|
||
"id": "服务ID",
|
||
"name": "服务名称",
|
||
"trigger": "触发器：cron/interval/date/CronTrigger.from_crontab()",
|
||
"func": self.xxx,
|
||
"kwargs": {} # 定时器参数
|
||
}]
|
||
"""
|
||
if self._enabled and self._cron:
|
||
return [{
|
||
"id": "CloudStrm",
|
||
"name": "云盘strm文件生成服务",
|
||
"trigger": CronTrigger.from_crontab(self._cron),
|
||
"func": self.scan,
|
||
"kwargs": {}
|
||
}]
|
||
return []
|
||
|
||
def get_api(self) -> List[Dict[str, Any]]:
|
||
pass
|
||
|
||
def get_form(self) -> Tuple[List[dict], Dict[str, Any]]:
|
||
"""
|
||
拼装插件配置页面，需要返回两块数据：1、页面配置；2、数据结构
|
||
"""
|
||
return [
|
||
{
|
||
'component': 'VForm',
|
||
'content': [
|
||
{
|
||
'component': 'VRow',
|
||
'content': [
|
||
{
|
||
'component': 'VCol',
|
||
'props': {
|
||
'cols': 12,
|
||
'md': 3
|
||
},
|
||
'content': [
|
||
{
|
||
'component': 'VSwitch',
|
||
'props': {
|
||
'model': 'enabled',
|
||
'label': '启用插件',
|
||
}
|
||
}
|
||
]
|
||
},
|
||
{
|
||
'component': 'VCol',
|
||
'props': {
|
||
'cols': 12,
|
||
'md': 3
|
||
},
|
||
'content': [
|
||
{
|
||
'component': 'VSwitch',
|
||
'props': {
|
||
'model': 'onlyonce',
|
||
'label': '立即运行一次',
|
||
}
|
||
}
|
||
]
|
||
},
|
||
{
|
||
'component': 'VCol',
|
||
'props': {
|
||
'cols': 12,
|
||
'md': 3
|
||
},
|
||
'content': [
|
||
{
|
||
'component': 'VSwitch',
|
||
'props': {
|
||
'model': 'copy_files',
|
||
'label': '复制非媒体文件',
|
||
}
|
||
}
|
||
]
|
||
},
|
||
{
|
||
'component': 'VCol',
|
||
'props': {
|
||
'cols': 12,
|
||
'md': 3
|
||
},
|
||
'content': [
|
||
{
|
||
'component': 'VSwitch',
|
||
'props': {
|
||
'model': 'https',
|
||
'label': '启用https',
|
||
}
|
||
}
|
||
]
|
||
},
|
||
]
|
||
},
|
||
{
|
||
'component': 'VRow',
|
||
'content': [
|
||
{
|
||
'component': 'VCol',
|
||
'props': {
|
||
'cols': 12,
|
||
'md': 3
|
||
},
|
||
'content': [
|
||
{
|
||
'component': 'VSwitch',
|
||
'props': {
|
||
'model': 'del_source',
|
||
'label': '删除源文件',
|
||
}
|
||
}
|
||
]
|
||
},
|
||
]
|
||
},
|
||
{
|
||
'component': 'VRow',
|
||
'content': [
|
||
{
|
||
'component': 'VCol',
|
||
'props': {
|
||
'cols': 12,
|
||
'md': 6
|
||
},
|
||
'content': [
|
||
{
|
||
'component': 'VTextField',
|
||
'props': {
|
||
'model': 'cron',
|
||
'label': '生成周期',
|
||
'placeholder': '0 0 * * *'
|
||
}
|
||
}
|
||
]
|
||
},
|
||
{
|
||
'component': 'VCol',
|
||
'props': {
|
||
'cols': 12,
|
||
'md': 6
|
||
},
|
||
'content': [
|
||
{
|
||
'component': 'VTextField',
|
||
'props': {
|
||
'model': 'no_del_dirs',
|
||
'label': '保留路径',
|
||
'placeholder': 'series、movies、downloads、others'
|
||
}
|
||
}
|
||
]
|
||
},
|
||
]
|
||
},
|
||
{
|
||
'component': 'VRow',
|
||
'content': [
|
||
{
|
||
'component': 'VCol',
|
||
'props': {
|
||
'cols': 12
|
||
},
|
||
'content': [
|
||
{
|
||
'component': 'VTextarea',
|
||
'props': {
|
||
'model': 'monitor_confs',
|
||
'label': '监控目录',
|
||
'rows': 5,
|
||
'placeholder': '增量目录#监控目录#目的目录#媒体服务器内源文件路径'
|
||
}
|
||
}
|
||
]
|
||
}
|
||
]
|
||
},
|
||
{
|
||
'component': 'VRow',
|
||
'content': [
|
||
{
|
||
'component': 'VCol',
|
||
'props': {
|
||
'cols': 12
|
||
},
|
||
'content': [
|
||
{
|
||
'component': 'VTextarea',
|
||
'props': {
|
||
'model': 'rmt_mediaext',
|
||
'label': '视频格式',
|
||
'rows': 2,
|
||
'placeholder': ".mp4, .mkv, .ts, .iso,.rmvb, .avi, .mov, .mpeg,.mpg, .wmv, .3gp, .asf, .m4v, .flv, .m2ts, .strm,.tp, .f4v"
|
||
}
|
||
}
|
||
]
|
||
}
|
||
]
|
||
},
|
||
{
|
||
'component': 'VRow',
|
||
'content': [
|
||
{
|
||
'component': 'VCol',
|
||
'props': {
|
||
'cols': 12,
|
||
},
|
||
'content': [
|
||
{
|
||
'component': 'VAlert',
|
||
'props': {
|
||
'type': 'info',
|
||
'variant': 'tonal',
|
||
'text': '目录监控格式：'
|
||
'1.增量目录#监控目录#目的目录#媒体服务器内源文件路径；'
|
||
'2.增量目录#监控目录#目的目录#cd2#cd2挂载本地跟路径#cd2服务地址；'
|
||
'3.增量目录#监控目录#目的目录#alist#alist挂载本地跟路径#alist服务地址。'
|
||
}
|
||
}
|
||
]
|
||
}
|
||
]
|
||
},
|
||
{
|
||
'component': 'VRow',
|
||
'content': [
|
||
{
|
||
'component': 'VCol',
|
||
'props': {
|
||
'cols': 12,
|
||
},
|
||
'content': [
|
||
{
|
||
'component': 'VAlert',
|
||
'props': {
|
||
'type': 'info',
|
||
'variant': 'tonal',
|
||
'text': '媒体服务器内源文件路径：源文件目录即云盘挂载到媒体服务器的路径。'
|
||
}
|
||
}
|
||
]
|
||
}
|
||
]
|
||
},
|
||
{
|
||
'component': 'VRow',
|
||
'content': [
|
||
{
|
||
'component': 'VCol',
|
||
'props': {
|
||
'cols': 12,
|
||
},
|
||
'content': [
|
||
{
|
||
'component': 'VAlert',
|
||
'props': {
|
||
'type': 'success',
|
||
'variant': 'tonal'
|
||
},
|
||
'content': [
|
||
{
|
||
'component': 'span',
|
||
'text': '配置教程请参考：'
|
||
},
|
||
{
|
||
'component': 'a',
|
||
'props': {
|
||
'href': 'https://raw.githubusercontent.com/thsrite/MoviePilot-Plugins/main/docs/CloudStrm.md',
|
||
'target': '_blank'
|
||
},
|
||
'text': 'https://raw.githubusercontent.com/thsrite/MoviePilot-Plugins/main/docs/CloudStrm.md'
|
||
}
|
||
]
|
||
}
|
||
]
|
||
}
|
||
]
|
||
},
|
||
]
|
||
}
|
||
], {
|
||
"enabled": False,
|
||
"cron": "",
|
||
"onlyonce": False,
|
||
"copy_files": False,
|
||
"del_source": True,
|
||
"https": False,
|
||
"monitor_confs": "",
|
||
"no_del_dirs": "",
|
||
"rmt_mediaext": ".mp4, .mkv, .ts, .iso,.rmvb, .avi, .mov, .mpeg,.mpg, .wmv, .3gp, .asf, .m4v, .flv, .m2ts, .strm,.tp, .f4v"
|
||
}
|
||
|
||
def get_page(self) -> List[dict]:
|
||
pass
|
||
|
||
def stop_service(self):
|
||
"""
|
||
退出插件
|
||
"""
|
||
try:
|
||
if self._scheduler:
|
||
self._scheduler.remove_all_jobs()
|
||
if self._scheduler.running:
|
||
self._scheduler.shutdown()
|
||
self._scheduler = None
|
||
except Exception as e:
|
||
logger.error("退出插件失败：%s" % str(e))
|