From 64135e089017c9ab6e0fbddefdb905d7d6a098ef Mon Sep 17 00:00:00 2001 From: sleikang <73560978@qq.com> Date: Sun, 10 Nov 2024 12:36:10 +0800 Subject: [PATCH] =?UTF-8?q?=E8=BF=98=E5=8E=9F=E7=AD=89=E5=BE=85=E6=97=B6?= =?UTF-8?q?=E9=97=B4=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- plugins.v2/filesoftlink/__init__.py | 13 ++++++------- plugins/filesoftlink/__init__.py | 12 ++++++------ 2 files changed, 12 insertions(+), 13 deletions(-) diff --git a/plugins.v2/filesoftlink/__init__.py b/plugins.v2/filesoftlink/__init__.py index 9adedc0..bd00115 100644 --- a/plugins.v2/filesoftlink/__init__.py +++ b/plugins.v2/filesoftlink/__init__.py @@ -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): """ diff --git a/plugins/filesoftlink/__init__.py b/plugins/filesoftlink/__init__.py index 7078878..4ff12d9 100644 --- a/plugins/filesoftlink/__init__.py +++ b/plugins/filesoftlink/__init__.py @@ -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):