mirror of
https://github.com/TeamPGM/PagerMaid_Plugins_Pyro.git
synced 2024-11-16 05:45:24 +00:00
auto_send_reactions
Co-authored-by: SuperManito <68613938+SuperManito@users.noreply.github.com> Co-authored-by: Sourcery AI <> Co-authored-by: omg-xtao <100690902+omg-xtao@users.noreply.github.com>
This commit is contained in:
sourcery-ai[bot]
GitHub
parent
994ee80bf4
commit
6cbaf243f5
1
auto_send_reactions/DES.md
Normal file
1
auto_send_reactions/DES.md
Normal file
@ -0,0 +1 @@
|
||||
向别人的消息自动回复Emoji
|
||||
263
auto_send_reactions/main.py
Normal file
263
auto_send_reactions/main.py
Normal file
@ -0,0 +1,263 @@
|
||||
"""
|
||||
自动回复Emoji插件
|
||||
Author: SuperManito
|
||||
"""
|
||||
|
||||
from pagermaid import bot, log
|
||||
from pagermaid.single_utils import sqlite
|
||||
from pagermaid.enums import Client, Message
|
||||
from pagermaid.utils import lang, edit_delete, pip_install
|
||||
from pagermaid.listener import listener
|
||||
|
||||
pip_install("emoji")
|
||||
|
||||
import emoji
|
||||
|
||||
|
||||
# 获取内容中的表情符号，并用|分割
|
||||
def get_emoji(text):
|
||||
if emojiArr := emoji.distinct_emoji_list(text):
|
||||
delimiter = '|'
|
||||
return delimiter.join(emojiArr)
|
||||
else:
|
||||
return False
|
||||
|
||||
|
||||
@listener(is_plugin=False,
|
||||
outgoing=True,
|
||||
command="auto_send_reactions",
|
||||
description='\n自动回复Emoji插件',
|
||||
parameters="`\n自动回复Emoji插件，支持同时设置多个目标生效用户，目前仅支持回复用户在群组中发送的消息，默认在所有已加入的群组中生效\n"
|
||||
"\n**设置插件状态**:"
|
||||
"\n启用：`,auto_send_reactions enable`"
|
||||
"\n停用：`,auto_send_reactions disable`"
|
||||
"\n\n**设置目标生效用户**:"
|
||||
"\n添加：`,auto_send_reactions set <用户id/用户名> <表情内容>`"
|
||||
"\n移除：`,auto_send_reactions unset <用户id/用户名>`"
|
||||
"\n支持直接回复消息以进行快速设置，可以省略用户标识参数"
|
||||
"\n\n**设置生效群组黑名单**:"
|
||||
"\n添加：`,auto_send_reactions block <群组id/群组用户名>`"
|
||||
"\n移除：`,auto_send_reactions unblock <群组id/群组用户名>\n")
|
||||
async def AutoSendReactions(client: Client, message: Message):
|
||||
reply = message.reply_to_message
|
||||
|
||||
# 启用插件
|
||||
if message.parameter[0] == "enable":
|
||||
# for ID in ID_FROM_ARRAY :
|
||||
# # 检查来源频道/群组
|
||||
# try:
|
||||
# channel = await bot.get_chat(ID)
|
||||
# except Exception as e:
|
||||
# errorMsg = f"第{e.__traceback__.tb_lineno}行：{e}"
|
||||
# await message.edit(f"出错了呜呜呜 ~ 无法识别的来源对话。\n\n{errorMsg}")
|
||||
# return
|
||||
|
||||
if not sqlite.get("AutoSendReactions.Enable"):
|
||||
sqlite["AutoSendReactions.Enable"] = 'yes'
|
||||
|
||||
# 返回消息
|
||||
await edit_delete(message, "✅ **已启用自动回复表情插件**")
|
||||
|
||||
elif message.parameter[0] == "disable":
|
||||
|
||||
if sqlite.get("AutoSendReactions.Enable"):
|
||||
del sqlite["AutoSendReactions.Enable"]
|
||||
|
||||
# 返回消息
|
||||
await edit_delete(message, "❌ **已停用自动回复表情插件**")
|
||||
|
||||
elif message.parameter[0] in ["set", "unset"]:
|
||||
|
||||
## 设置插件
|
||||
if (message.parameter[0] == "set"):
|
||||
|
||||
if not reply and (len(message.parameter) == 3):
|
||||
target = message.parameter[1]
|
||||
content = message.parameter[2]
|
||||
try:
|
||||
# 获取用户信息
|
||||
user_info = await bot.get_users(target)
|
||||
# 判断参数合法性
|
||||
if not user_info:
|
||||
return await message.edit("❌ **目标用户不存在或参数有误**")
|
||||
if not content or not get_emoji(content):
|
||||
return await message.edit("❌ **Emoji参数不能为空或不合法**")
|
||||
user_name = (
|
||||
f'{user_info.first_name} {user_info.last_name}'
|
||||
if user_info.last_name
|
||||
else user_info.first_name
|
||||
)
|
||||
# 设置或更新
|
||||
hasSetted = sqlite.get(f"AutoSendReactions.{target}")
|
||||
sqlite[f"AutoSendReactions.{target}"] = content
|
||||
await edit_delete(
|
||||
message,
|
||||
f"✅ 已{'更新' if hasSetted else '添加'}对 __{user_name}__ 的自动回复Emoji设置**"
|
||||
)
|
||||
except Exception as e:
|
||||
await message.edit(message, f"❌ **在设置中遇到了一些错误** > {e}")
|
||||
await log(e) # 打印错误日志
|
||||
|
||||
elif reply and (len(message.parameter) == 2):
|
||||
from_user = reply.from_user
|
||||
target = from_user.id
|
||||
content = message.parameter[1]
|
||||
try:
|
||||
# 判断参数合法性
|
||||
if not content or not get_emoji(content):
|
||||
return await message.edit("❌ **Emoji参数不能为空或不合法**")
|
||||
user_name = (
|
||||
f'{from_user.first_name} {from_user.last_name}'
|
||||
if from_user.last_name
|
||||
else from_user.first_name
|
||||
)
|
||||
# 设置或更新
|
||||
hasSetted = sqlite.get(f"AutoSendReactions.{target}")
|
||||
sqlite[f"AutoSendReactions.{target}"] = content
|
||||
await edit_delete(
|
||||
message,
|
||||
f"✅ 已{'更新' if hasSetted else '添加'}对 __{user_name}__ 的自动回复Emoji设置"
|
||||
)
|
||||
except Exception as e:
|
||||
await message.edit(message, f"❌ **在设置中遇到了一些错误** > {e}")
|
||||
await log(e) # 打印错误日志
|
||||
else:
|
||||
return await message.edit(
|
||||
f"{lang('error_prefix')}{lang('arg_error')}")
|
||||
|
||||
elif (message.parameter[0] == "unset"):
|
||||
|
||||
if not reply and (len(message.parameter) == 2):
|
||||
target = message.parameter[1]
|
||||
try:
|
||||
# 获取用户信息
|
||||
user_info = await bot.get_users(target)
|
||||
# 判断参数合法性
|
||||
if not user_info:
|
||||
return await message.edit("❌ **目标用户不存在或参数有误**")
|
||||
user_id = user_info.id
|
||||
user_name = (
|
||||
f'{user_info.first_name} {user_info.last_name}'
|
||||
if user_info.last_name
|
||||
else user_info.first_name
|
||||
)
|
||||
if hasSetted := sqlite.get(f"AutoSendReactions.{user_id}"):
|
||||
del sqlite[f"AutoSendReactions.{user_id}"]
|
||||
await edit_delete(
|
||||
message, f"✅ 对 __{user_name}__ 的自动回复Emoji设置已删除")
|
||||
else:
|
||||
await edit_delete(
|
||||
message, f"❌ 还没有对 __{user_name}__ 设置自动回复Emoji哦~")
|
||||
except Exception as e:
|
||||
await message.edit(message, f"❌ **在设置中遇到了一些错误** > {e}")
|
||||
await log(e) # 打印错误日志
|
||||
|
||||
elif reply and (len(message.parameter) == 1):
|
||||
from_user = reply.from_user
|
||||
target = from_user.id
|
||||
try:
|
||||
user_name = (
|
||||
f'{from_user.first_name} {from_user.last_name}'
|
||||
if from_user.last_name
|
||||
else from_user.first_name
|
||||
)
|
||||
if hasSetted := sqlite.get(f"AutoSendReactions.{target}"):
|
||||
del sqlite[f"AutoSendReactions.{target}"]
|
||||
await edit_delete(
|
||||
message, f"✅ 已删除对 __{user_name}__ 的自动回复Emoji设置")
|
||||
else:
|
||||
await edit_delete(
|
||||
message, f"❌ 还没有对 __{user_name}__ 设置自动回复Emoji哦~")
|
||||
except Exception as e:
|
||||
await message.edit(message, f"❌ **在设置中遇到了一些错误** > {e}")
|
||||
await log(e) # 打印错误日志
|
||||
else:
|
||||
return await message.edit(
|
||||
f"{lang('error_prefix')}{lang('arg_error')}")
|
||||
|
||||
else:
|
||||
return await message.edit(
|
||||
f"{lang('error_prefix')}{lang('arg_error')}")
|
||||
|
||||
elif (message.parameter[0]
|
||||
== "block") or (message.parameter[0] == "unblock") and (len(
|
||||
message.parameter) == 2):
|
||||
group = message.parameter[1]
|
||||
group_info = await bot.get_chat(chat_id=group)
|
||||
if not group_info:
|
||||
return await message.edit("❌ **目标群组不存在或参数有误**")
|
||||
group_id = group_info.id
|
||||
group_name = group_info.title
|
||||
|
||||
if (message.parameter[0] == "block"):
|
||||
if hasBlocked := sqlite.get(f"AutoSendReactionsBlock.{group_id}"):
|
||||
await edit_delete(
|
||||
message, f"❌ 已经将 __{group_name}__ 加入自动回复Emoji黑名单群组了哦~")
|
||||
else:
|
||||
sqlite[f"AutoSendReactionsBlock.{group_id}"] = 'yes'
|
||||
await edit_delete(message,
|
||||
f"✅ 已将 __{group_name}__ 加入至自动回复Emoji黑名单群组")
|
||||
elif (message.parameter[0] == "unblock"):
|
||||
if hasBlocked := sqlite.get(f"AutoSendReactionsBlock.{group_id}"):
|
||||
del sqlite[f"AutoSendReactionsBlock.{group_id}"]
|
||||
await edit_delete(message,
|
||||
f"✅ 已将 __{group_name}__ 从自动回复Emoji黑名单群组中移除")
|
||||
else:
|
||||
await edit_delete(
|
||||
message, f"❌ 还没有将 __{group_name}__ 加入进自动回复Emoji群组黑名单哦~")
|
||||
|
||||
else:
|
||||
return await message.edit(f"{lang('error_prefix')}{lang('arg_error')}"
|
||||
)
|
||||
|
||||
|
||||
@listener(is_plugin=False, incoming=True, ignore_edited=True)
|
||||
async def AutoSendReactions(message: Message):
|
||||
from_user = ''
|
||||
try:
|
||||
# 判断是否启用了本插件
|
||||
if not sqlite.get("AutoSendReactions.Enable"):
|
||||
return
|
||||
if 'GROUP' not in str(message.chat.type):
|
||||
return
|
||||
# 判断是否在黑名单中
|
||||
if sqlite.get(f"AutoSendReactionsBlock.{message.chat.id}"):
|
||||
return
|
||||
if not message.from_user:
|
||||
# 过滤匿名管理员
|
||||
return
|
||||
|
||||
from_user = message.from_user
|
||||
if not sqlite.get(f"AutoSendReactions.{from_user.id}"):
|
||||
return
|
||||
# 判断群组是否启用了表情回应功能
|
||||
group_info = await bot.get_chat(chat_id=message.chat.id)
|
||||
if not group_info.available_reactions:
|
||||
return
|
||||
|
||||
# 发送表情
|
||||
emoji = sqlite.get(f"AutoSendReactions.{from_user.id}").split('|')[0]
|
||||
user_name = (
|
||||
f'{from_user.first_name} {from_user.last_name}'
|
||||
if from_user.last_name
|
||||
else from_user.first_name
|
||||
)
|
||||
try:
|
||||
await bot.send_reaction(message.chat.id, message.id, emoji)
|
||||
|
||||
except Exception as e:
|
||||
errorMsg = f"❌ 自动回复Emoji失败（{user_name} {emoji}）> {e}"
|
||||
await log(errorMsg)
|
||||
return False
|
||||
|
||||
# 打印日志
|
||||
# text = message.text.markdown
|
||||
# await log(f"AutoSendReactions 监控到来自 {user_name} 的消息：{str(text)}")
|
||||
|
||||
except Exception as e:
|
||||
errorMsg = f"❌ 第{e.__traceback__.tb_lineno}行：{e}"
|
||||
await log(errorMsg)
|
||||
return False
|
||||
|
||||
|
||||
## ⬆️ 不懂勿动 ⬆️
|
||||
Loading…
Reference in New Issue
Block a user