Genshin-bots/gsuid_core
1
0
Fork 0
mirror of https://github.com/Genshin-bots/gsuid_core.git synced 2025-05-09 05:25:48 +08:00
Code Issues Packages Projects Releases Wiki Activity

🐛 修复下载时, 部分过长资源文件名报错

Browse Source
This commit is contained in:
‘KimigaiiWuyi’ 2024-02-06 16:48:01 +08:00
parent bc93c66bc6
commit 27f4b835d5
1 changed files with 11 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
gsuid_core/utils/download_resource/download_core.py
View File

@ -2,6 +2,7 @@ import os
import time import time
import asyncio import asyncio
from pathlib import Path from pathlib import Path
from urllib.parse import unquote
from typing import Dict, Optional from typing import Dict, Optional
import aiohttp import aiohttp
@ -117,7 +118,9 @@ async def download_all_file(
pre_data = content_bs.find_all('pre')[0] pre_data = content_bs.find_all('pre')[0]
data_list = pre_data.find_all('a') data_list = pre_data.find_all('a')
size_list = [i for i in content_bs.strings] size_list = [i for i in content_bs.strings]
logger.trace(f'{TAG} 数据库 {endpoint} 中存在 {len(data_list)} 个内容!') logger.trace(
f'{TAG} 数据库 {endpoint} 中存在 {len(data_list)} 个内容!'
)
temp_num = 0 temp_num = 0
size_temp = 0 size_temp = 0
@ -125,7 +128,7 @@ async def download_all_file(
if data['href'] == '../': if data['href'] == '../':
continue continue
file_url = f'{url}{data["href"]}' file_url = f'{url}{data["href"]}'
name: str = data.text name: str = unquote(file_url.split('/')[-1])
size = size_list[index * 2 + 6].split(' ')[-1] size = size_list[index * 2 + 6].split(' ')[-1]
size = int(size.replace('\r\n', '')) size = int(size.replace('\r\n', ''))
file_path = path / name file_path = path / name
@ -138,7 +141,9 @@ async def download_all_file(
or not os.stat(file_path).st_size or not os.stat(file_path).st_size
or not is_diff or not is_diff
): ):
logger.info(f'{TAG} {plugin_name} 开始下载 {endpoint}/{name}') logger.info(
f'{TAG} {plugin_name} 开始下载 {endpoint}/{name}'
)
temp_num += 1 temp_num += 1
size_temp += size size_temp += size
TASKS.append( TASKS.append(
@ -158,7 +163,9 @@ async def download_all_file(
logger.trace(f'{TAG} 数据库 {endpoint} 无需下载!') logger.trace(f'{TAG} 数据库 {endpoint} 无需下载!')
n += 1 n += 1
else: else:
logger.success(f'{TAG}数据库 {endpoint} 已下载{temp_num}个内容!') logger.success(
f'{TAG}数据库 {endpoint} 已下载{temp_num}个内容!'
)
temp_num = 0 temp_num = 0
if n == len(EPATH_MAP): if n == len(EPATH_MAP):
logger.success(f'插件 {plugin_name} 资源库已是最新!') logger.success(f'插件 {plugin_name} 资源库已是最新!')