GithubBackup/MoviePilot
1
0
Fork 0
mirror of https://github.com/jxxghp/MoviePilot.git synced 2026-09-05 23:47:41 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(u115): refresh delay

Browse Source
This commit is contained in:
DDSRem
2025-05-18 10:03:36 +08:00
parent 2f4072da0d
commit 861453c1a8
1 changed files with 15 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/modules/filemanager/storages/u115.py
+15 -4
View File
@@ -306,6 +306,17 @@ class U115Pan(StorageBase, metaclass=Singleton):
sha1.update(chunk) sha1.update(chunk)
return sha1.hexdigest() return sha1.hexdigest()
def _delay_get_item(self, path: Path) -> List[schemas.FileItem]:
"""
自动延迟重试 get_item 模块
"""
for _ in range(2):
time.sleep(2)
fileitem = self.get_item(path)
if fileitem:
return fileitem
return None
def init_storage(self): def init_storage(self):
pass pass
@@ -513,7 +524,7 @@ class U115Pan(StorageBase, metaclass=Singleton):
# Step 3: 秒传 # Step 3: 秒传
if init_result.get("status") == 2: if init_result.get("status") == 2:
logger.info(f"【115】{target_name} 秒传成功") logger.info(f"【115】{target_name} 秒传成功")
return self.get_item(target_path) return self._delay_get_item(target_path)
# Step 4: 获取上传凭证 # Step 4: 获取上传凭证
token_resp = self._request_api( token_resp = self._request_api(
@@ -618,7 +629,7 @@ class U115Pan(StorageBase, metaclass=Singleton):
logger.error(f"【115】{target_name} 上传失败: {e.status}, 错误码: {e.code}, 详情: {e.message}") logger.error(f"【115】{target_name} 上传失败: {e.status}, 错误码: {e.code}, 详情: {e.message}")
return None return None
# 返回结果 # 返回结果
return self.get_item(target_path) return self._delay_get_item(target_path)
def download(self, fileitem: schemas.FileItem, path: Path = None) -> Optional[Path]: def download(self, fileitem: schemas.FileItem, path: Path = None) -> Optional[Path]:
""" """
@@ -783,7 +794,7 @@ class U115Pan(StorageBase, metaclass=Singleton):
return False return False
if resp["state"]: if resp["state"]:
new_path = Path(path) / fileitem.name new_path = Path(path) / fileitem.name
new_item = self.get_item(new_path) new_item = self._delay_get_item(new_path)
self.rename(new_item, new_name) self.rename(new_item, new_name)
# 更新缓存 # 更新缓存
del self._id_cache[fileitem.path] del self._id_cache[fileitem.path]
@@ -811,7 +822,7 @@ class U115Pan(StorageBase, metaclass=Singleton):
return False return False
if resp["state"]: if resp["state"]:
new_path = Path(path) / fileitem.name new_path = Path(path) / fileitem.name
new_file = self.get_item(new_path) new_file = self._delay_get_item(new_path)
self.rename(new_file, new_name) self.rename(new_file, new_name)
# 更新缓存 # 更新缓存
del self._id_cache[fileitem.path] del self._id_cache[fileitem.path]