thsrite/archived-MoviePilot-Plugins
1
0
Fork 0
mirror of https://github.com/thsrite/MoviePilot-Plugins.git synced 2026-03-27 10:05:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

还原等待时间接口

Browse Source
This commit is contained in:
sleikang
2024-11-10 12:36:10 +08:00
parent c99543c665
commit 64135e0890
2 changed files with 12 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
plugins.v2/filesoftlink/__init__.py
View File

@@ -4,7 +4,7 @@ import re
import shutil
import threading
import traceback
import asyncio
import time
from pathlib import Path
from typing import List, Tuple, Dict, Any, Optional
@@ -423,7 +423,7 @@ class FileSoftLink(_PluginBase):
event_path=str(src_file),
mon_path=mon_path,
)
asyncio.sleep(self._sync_interval)
time.sleep(self._sync_interval)
if event.event_data.get("user"):
self.post_message(
@@ -469,7 +469,7 @@ class FileSoftLink(_PluginBase):
event_path=str(src_file), mon_path=mon_path
)
logger.info(f"等待 {self._sync_interval} 秒")
asyncio.sleep(self._sync_interval)
time.sleep(self._sync_interval)
if event.event_data.get("user"):
self.post_message(
channel=event.event_data.get("channel"),
@@ -492,7 +492,7 @@ class FileSoftLink(_PluginBase):
event_path=str(src_file), mon_path=mon_path
)
logger.info(f"等待 {self._sync_interval} 秒")
asyncio.sleep(self._sync_interval)
time.sleep(self._sync_interval)
if event.event_data.get("user"):
self.post_message(
channel=event.event_data.get("channel"),
@@ -532,7 +532,7 @@ class FileSoftLink(_PluginBase):
if Path(src_file).is_file():
self.__handle_file(event_path=str(src_file), mon_path=mon_path)
logger.info(f"等待 {self._sync_interval} 秒")
asyncio.sleep(self._sync_interval)
time.sleep(self._sync_interval)
if event.event_data.get("user"):
self.post_message(
channel=event.event_data.get("channel"),
@@ -572,11 +572,10 @@ class FileSoftLink(_PluginBase):
if Path(path).is_file():
self.__handle_file(event_path=str(path), mon_path=mon_path)
logger.info(f"等待 {self._sync_interval} 秒")
asyncio.sleep(self._sync_interval)
time.sleep(self._sync_interval)
logger.info("全量同步监控目录完成！")
except Exception as result:
logger.error(f"全量同步监控目录失败：{result}")
self.systemmessage.put(f"全量同步监控目录失败：{result}")
def event_handler(self, event, mon_path: str, text: str, event_path: str):
"""

12
plugins/filesoftlink/__init__.py
View File

@@ -4,7 +4,7 @@ import re
import shutil
import threading
import traceback
import asyncio
import time
from pathlib import Path
from typing import List, Tuple, Dict, Any, Optional
@@ -408,7 +408,7 @@ class FileSoftLink(_PluginBase):
event_path=str(src_file),
mon_path=mon_path,
)
asyncio.sleep(self._sync_interval)
time.sleep(self._sync_interval)
if event.event_data.get("user"):
self.post_message(
@@ -453,7 +453,7 @@ class FileSoftLink(_PluginBase):
self.__handle_file(
event_path=str(src_file), mon_path=mon_path
)
asyncio.sleep(self._sync_interval)
time.sleep(self._sync_interval)
if event.event_data.get("user"):
self.post_message(
channel=event.event_data.get("channel"),
@@ -475,7 +475,7 @@ class FileSoftLink(_PluginBase):
self.__handle_file(
event_path=str(src_file), mon_path=mon_path
)
asyncio.sleep(self._sync_interval)
time.sleep(self._sync_interval)
if event.event_data.get("user"):
self.post_message(
channel=event.event_data.get("channel"),
@@ -514,7 +514,7 @@ class FileSoftLink(_PluginBase):
src_file = os.path.join(sroot, file_name)
if Path(src_file).is_file():
self.__handle_file(event_path=str(src_file), mon_path=mon_path)
asyncio.sleep(self._sync_interval)
time.sleep(self._sync_interval)
if event.event_data.get("user"):
self.post_message(
channel=event.event_data.get("channel"),
@@ -552,7 +552,7 @@ class FileSoftLink(_PluginBase):
path = os.path.join(root, name)
if Path(path).is_file():
self.__handle_file(event_path=str(path), mon_path=mon_path)
asyncio.sleep(self._sync_interval)
time.sleep(self._sync_interval)
logger.info("全量同步监控目录完成！")
def event_handler(self, event, mon_path: str, text: str, event_path: str):