mirror of
https://github.com/TeamPGM/PagerMaid_Plugins_Pyro.git
synced 2024-12-01 01:57:55 +00:00
75 lines
2.9 KiB
Python
75 lines
2.9 KiB
Python
import zipfile
|
|
import os
|
|
from os.path import exists, isfile
|
|
|
|
from pagermaid.enums import Client, Message
|
|
from pagermaid.listener import listener
|
|
|
|
from pathlib import Path
|
|
|
|
|
|
async def make_zip(source_dir, output_filename):
|
|
zipf = zipfile.ZipFile(output_filename, "w")
|
|
pre_len = len(os.path.dirname(source_dir))
|
|
for parent, dirnames, filenames in os.walk(source_dir):
|
|
for filename in filenames:
|
|
pathfile = os.path.join(parent, filename)
|
|
arcname = pathfile[pre_len:].strip(os.path.sep)
|
|
zipf.write(pathfile, arcname)
|
|
zipf.close()
|
|
|
|
|
|
@listener(
|
|
command="transfer",
|
|
description="上传 / 下载文件",
|
|
parameters="upload [filepath]` 或 `download [filepath]",
|
|
)
|
|
async def transfer(bot: Client, message: Message):
|
|
params = message.parameter
|
|
if len(params) < 2:
|
|
message: Message = await message.edit(
|
|
"参数缺失，请使用 `upload [filepath (包括扩展名)]` 或 `download [filepath (包括扩展名)]`"
|
|
)
|
|
await message.delay_delete(3)
|
|
return
|
|
params[1] = " ".join(params[1:])
|
|
file_list = params[1].split("\n")
|
|
chat_id = message.chat.id
|
|
if params[0] == "upload":
|
|
index = 1
|
|
for file_path in file_list:
|
|
message: Message = await message.edit(f"正在上传第 {index} 个文件")
|
|
if exists(file_path):
|
|
if isfile(file_path):
|
|
await bot.send_document(chat_id, file_path, force_document=True)
|
|
else:
|
|
token = file_path.split("/")
|
|
token = token[len(token) - 1]
|
|
await make_zip(file_path, f"/tmp/{token}.zip")
|
|
await bot.send_document(
|
|
chat_id, f"/tmp/{token}.zip", force_document=True
|
|
)
|
|
os.remove(f"/tmp/{token}.zip")
|
|
index += 1
|
|
message: Message = await message.edit("上传完毕")
|
|
elif params[0] == "download":
|
|
if reply := message.reply_to_message:
|
|
file_path = Path(file_list[0])
|
|
if exists(file_path):
|
|
message: Message = await message.edit("路径已存在文件")
|
|
else:
|
|
message: Message = await message.edit("下载中。。。")
|
|
try:
|
|
_file = await reply.download(file_name=file_list[0])
|
|
except Exception:
|
|
await message.edit("无法下载此类型的文件。")
|
|
return
|
|
message: Message = await message.edit(f"保存成功, 保存路径 `{file_list[0]}`")
|
|
else:
|
|
message: Message = await message.edit("未回复消息或回复消息中不包含文件")
|
|
else:
|
|
message: Message = await message.edit(
|
|
"未知命令，请使用 `upload [filepath]` 或 `download [filepath]`"
|
|
)
|
|
await message.delay_delete(3)
|