mirror of
https://github.com/zhenxun-org/zhenxun_bot.git
synced 2026-10-03 02:30:01 +08:00
Compare commits
15
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
d594d17bf6 | ||
|
|
4e33bf3a50 | ||
|
|
daa40ae8b8 | ||
|
|
21bdb011e0 | ||
|
|
47f3518b04 | ||
|
|
997ce52d69 | ||
|
|
4bc433f049 | ||
|
|
4d6013ca02 | ||
|
|
f09f2c3162 | ||
|
|
67fdbb824b | ||
|
|
b4ccbb0f80 | ||
|
|
6326d888c8 | ||
|
|
e32f3dd22a | ||
|
|
c7e073baea | ||
|
|
1be99ac64d |
@@ -8,19 +8,12 @@ NICKNAME=["真寻", "小真寻", "绪山真寻", "小寻子"]
|
|||||||
|
|
||||||
SESSION_EXPIRE_TIMEOUT=30
|
SESSION_EXPIRE_TIMEOUT=30
|
||||||
|
|
||||||
ALCONNA_USE_COMMAND_START=True
|
|
||||||
|
|
||||||
# 全局图片统一使用bytes发送,当真寻与协议端不在同一服务器上时为True
|
# 全局图片统一使用bytes发送,当真寻与协议端不在同一服务器上时为True
|
||||||
IMAGE_TO_BYTES = True
|
IMAGE_TO_BYTES = False
|
||||||
|
|
||||||
# 回复消息时自称
|
# 回复消息时自称
|
||||||
SELF_NICKNAME="小真寻"
|
SELF_NICKNAME="小真寻"
|
||||||
|
|
||||||
# 官bot appid:bot账号
|
|
||||||
QBOT_ID_DATA = '{
|
|
||||||
|
|
||||||
}'
|
|
||||||
|
|
||||||
# 数据库配置
|
# 数据库配置
|
||||||
# 示例: "postgres://user:password@127.0.0.1:5432/database"
|
# 示例: "postgres://user:password@127.0.0.1:5432/database"
|
||||||
# 示例: "mysql://user:password@127.0.0.1:3306/database"
|
# 示例: "mysql://user:password@127.0.0.1:3306/database"
|
||||||
|
|||||||
@@ -0,0 +1,65 @@
|
|||||||
|
name: Update Version
|
||||||
|
|
||||||
|
on:
|
||||||
|
pull_request_target:
|
||||||
|
paths:
|
||||||
|
- zhenxun/**
|
||||||
|
- resources/**
|
||||||
|
- bot.py
|
||||||
|
types:
|
||||||
|
- opened
|
||||||
|
- synchronize
|
||||||
|
branches:
|
||||||
|
- main
|
||||||
|
- dev
|
||||||
|
|
||||||
|
jobs:
|
||||||
|
update-version:
|
||||||
|
runs-on: ubuntu-latest
|
||||||
|
steps:
|
||||||
|
- name: Checkout repository
|
||||||
|
uses: actions/checkout@v4
|
||||||
|
with:
|
||||||
|
ref: ${{ github.event.pull_request.head.sha }}
|
||||||
|
|
||||||
|
- name: Read current version
|
||||||
|
id: read_version
|
||||||
|
run: |
|
||||||
|
version_line=$(grep '__version__' __version__)
|
||||||
|
version=$(echo $version_line | sed -E 's/__version__:\s*v([0-9]+\.[0-9]+\.[0-9]+)(-.+)?/\1/')
|
||||||
|
echo "Current version: $version"
|
||||||
|
echo "current_version=$version" >> $GITHUB_OUTPUT
|
||||||
|
|
||||||
|
- name: Check for version file changes
|
||||||
|
id: check_diff
|
||||||
|
run: |
|
||||||
|
if git diff --name-only HEAD~1 HEAD | grep -q '__version__'; then
|
||||||
|
echo "Version file has changes"
|
||||||
|
echo "version_changed=true" >> $GITHUB_OUTPUT
|
||||||
|
else
|
||||||
|
echo "Version file has no changes"
|
||||||
|
echo "version_changed=false" >> $GITHUB_OUTPUT
|
||||||
|
fi
|
||||||
|
|
||||||
|
- name: Get commit hash
|
||||||
|
id: get_commit_hash
|
||||||
|
run: echo "commit_hash=$(git rev-parse --short HEAD)" >> $GITHUB_OUTPUT
|
||||||
|
|
||||||
|
- name: Update version file
|
||||||
|
if: steps.check_diff.outputs.version_changed == 'false'
|
||||||
|
run: |
|
||||||
|
current_version="${{ steps.read_version.outputs.current_version }}"
|
||||||
|
commit_hash="${{ steps.get_commit_hash.outputs.commit_hash }}"
|
||||||
|
new_version="v${current_version}-${commit_hash}"
|
||||||
|
echo "Updating version to: $new_version"
|
||||||
|
echo "__version__: $new_version" > __version__
|
||||||
|
git config --global user.name "${{ github.event.pull_request.user.login }}"
|
||||||
|
git config --global user.email "${{ github.event.pull_request.user.login }}@users.noreply.github.com"
|
||||||
|
git add __version__
|
||||||
|
git remote set-url origin https://github.com/${{ github.event.pull_request.head.repo.full_name }}.git
|
||||||
|
git commit -m "chore(version): Update version to $new_version"
|
||||||
|
git push origin HEAD:${{ github.event.pull_request.head.ref }}
|
||||||
|
|
||||||
|
- name: Check updated version
|
||||||
|
if: steps.check_diff.outputs.version_changed == 'false'
|
||||||
|
run: cat __version__
|
||||||
Vendored
+2
-3
@@ -13,19 +13,18 @@
|
|||||||
"getbbox",
|
"getbbox",
|
||||||
"hibiapi",
|
"hibiapi",
|
||||||
"httpx",
|
"httpx",
|
||||||
"jsdelivr",
|
|
||||||
"kaiheila",
|
"kaiheila",
|
||||||
"lolicon",
|
"lolicon",
|
||||||
"nonebot",
|
"nonebot",
|
||||||
"onebot",
|
"onebot",
|
||||||
"pixiv",
|
"pixiv",
|
||||||
"qbot",
|
|
||||||
"Setu",
|
"Setu",
|
||||||
"tobytes",
|
"tobytes",
|
||||||
"ujson",
|
"ujson",
|
||||||
"unban",
|
"unban",
|
||||||
"userinfo",
|
"userinfo",
|
||||||
"zhenxun"
|
"zhenxun",
|
||||||
|
"jsdelivr"
|
||||||
],
|
],
|
||||||
"python.analysis.autoImportCompletions": true,
|
"python.analysis.autoImportCompletions": true,
|
||||||
"python.testing.pytestArgs": ["tests"],
|
"python.testing.pytestArgs": ["tests"],
|
||||||
|
|||||||
+1
-1
@@ -1 +1 @@
|
|||||||
__version__: v0.2.4-fix1
|
__version__: v0.2.4
|
||||||
|
|||||||
Binary file not shown.
@@ -19,8 +19,6 @@ require("nonebot_plugin_htmlrender")
|
|||||||
from zhenxun.services.log import logger
|
from zhenxun.services.log import logger
|
||||||
from zhenxun.models.sign_user import SignUser
|
from zhenxun.models.sign_user import SignUser
|
||||||
from zhenxun.models.goods_info import GoodsInfo
|
from zhenxun.models.goods_info import GoodsInfo
|
||||||
from zhenxun.utils.platform import PlatformUtils
|
|
||||||
from zhenxun.models.bot_console import BotConsole
|
|
||||||
from zhenxun.models.user_console import UserConsole
|
from zhenxun.models.user_console import UserConsole
|
||||||
from zhenxun.utils.decorator.shop import shop_register
|
from zhenxun.utils.decorator.shop import shop_register
|
||||||
from zhenxun.models.bot_connect_log import BotConnectLog
|
from zhenxun.models.bot_connect_log import BotConnectLog
|
||||||
@@ -35,10 +33,6 @@ async def _(bot: Bot):
|
|||||||
await BotConnectLog.create(
|
await BotConnectLog.create(
|
||||||
bot_id=bot.self_id, platform=bot.adapter, connect_time=datetime.now(), type=1
|
bot_id=bot.self_id, platform=bot.adapter, connect_time=datetime.now(), type=1
|
||||||
)
|
)
|
||||||
if not await BotConsole.exists(bot_id=bot.self_id):
|
|
||||||
await BotConsole.create(
|
|
||||||
bot_id=bot.self_id, platform=PlatformUtils.get_platform(bot)
|
|
||||||
)
|
|
||||||
|
|
||||||
|
|
||||||
@driver.on_bot_disconnect
|
@driver.on_bot_disconnect
|
||||||
|
|||||||
@@ -11,7 +11,6 @@ from zhenxun.services.log import logger
|
|||||||
from zhenxun.configs.config import Config
|
from zhenxun.configs.config import Config
|
||||||
from zhenxun.utils.message import MessageUtils
|
from zhenxun.utils.message import MessageUtils
|
||||||
from zhenxun.models.level_user import LevelUser
|
from zhenxun.models.level_user import LevelUser
|
||||||
from zhenxun.models.bot_console import BotConsole
|
|
||||||
from zhenxun.models.plugin_info import PluginInfo
|
from zhenxun.models.plugin_info import PluginInfo
|
||||||
from zhenxun.models.plugin_limit import PluginLimit
|
from zhenxun.models.plugin_limit import PluginLimit
|
||||||
from zhenxun.models.user_console import UserConsole
|
from zhenxun.models.user_console import UserConsole
|
||||||
@@ -245,7 +244,6 @@ class AuthChecker:
|
|||||||
if not plugin.limit_superuser:
|
if not plugin.limit_superuser:
|
||||||
cost_gold = 0
|
cost_gold = 0
|
||||||
raise IsSuperuserException()
|
raise IsSuperuserException()
|
||||||
await self.auth_bot(plugin, bot.self_id)
|
|
||||||
await self.auth_group(plugin, session, message)
|
await self.auth_group(plugin, session, message)
|
||||||
await self.auth_admin(plugin, session)
|
await self.auth_admin(plugin, session)
|
||||||
await self.auth_plugin(plugin, session, event)
|
await self.auth_plugin(plugin, session, event)
|
||||||
@@ -280,16 +278,6 @@ class AuthChecker:
|
|||||||
if is_ignore:
|
if is_ignore:
|
||||||
raise IgnoredException("权限检测 ignore")
|
raise IgnoredException("权限检测 ignore")
|
||||||
|
|
||||||
async def auth_bot(self, plugin: PluginInfo, bot_id: str):
|
|
||||||
"""机器人权限
|
|
||||||
|
|
||||||
参数:
|
|
||||||
plugin: PluginInfo
|
|
||||||
bot_id: bot_id
|
|
||||||
"""
|
|
||||||
if await BotConsole.is_block_plugin(plugin.module, bot_id):
|
|
||||||
raise IgnoredException("机器人权限检测 ignore")
|
|
||||||
|
|
||||||
async def auth_limit(self, plugin: PluginInfo, session: EventSession):
|
async def auth_limit(self, plugin: PluginInfo, session: EventSession):
|
||||||
"""插件限制
|
"""插件限制
|
||||||
|
|
||||||
|
|||||||
@@ -0,0 +1,321 @@
|
|||||||
|
import os
|
||||||
|
import re
|
||||||
|
import random
|
||||||
|
from datetime import datetime
|
||||||
|
|
||||||
|
import ujson as json
|
||||||
|
from nonebot.adapters import Bot
|
||||||
|
from nonebot_plugin_alconna import At
|
||||||
|
from nonebot import on_notice, on_request
|
||||||
|
from nonebot.plugin import PluginMetadata
|
||||||
|
from nonebot.adapters.onebot.v11 import (
|
||||||
|
GroupDecreaseNoticeEvent,
|
||||||
|
GroupIncreaseNoticeEvent,
|
||||||
|
)
|
||||||
|
from nonebot.adapters.onebot.v12 import (
|
||||||
|
GroupMemberDecreaseEvent,
|
||||||
|
GroupMemberIncreaseEvent,
|
||||||
|
)
|
||||||
|
|
||||||
|
from zhenxun.services.log import logger
|
||||||
|
from zhenxun.utils.utils import FreqLimiter
|
||||||
|
from zhenxun.utils.message import MessageUtils
|
||||||
|
from zhenxun.models.fg_request import FgRequest
|
||||||
|
from zhenxun.models.level_user import LevelUser
|
||||||
|
from zhenxun.models.plugin_info import PluginInfo
|
||||||
|
from zhenxun.utils.common_utils import CommonUtils
|
||||||
|
from zhenxun.configs.config import Config, BotConfig
|
||||||
|
from zhenxun.models.group_console import GroupConsole
|
||||||
|
from zhenxun.models.group_member_info import GroupInfoUser
|
||||||
|
from zhenxun.utils.enum import PluginType, RequestHandleType
|
||||||
|
from zhenxun.configs.path_config import DATA_PATH, IMAGE_PATH
|
||||||
|
from zhenxun.configs.utils import Task, RegisterConfig, PluginExtraData
|
||||||
|
|
||||||
|
__plugin_meta__ = PluginMetadata(
|
||||||
|
name="QQ群事件处理",
|
||||||
|
description="群事件处理",
|
||||||
|
usage="",
|
||||||
|
extra=PluginExtraData(
|
||||||
|
author="HibiKier",
|
||||||
|
version="0.1",
|
||||||
|
plugin_type=PluginType.HIDDEN,
|
||||||
|
configs=[
|
||||||
|
RegisterConfig(
|
||||||
|
module="invite_manager",
|
||||||
|
key="message",
|
||||||
|
value=f"请不要未经同意就拉{BotConfig.self_nickname}入群!告辞!",
|
||||||
|
help="强制拉群后进群回复的内容",
|
||||||
|
),
|
||||||
|
RegisterConfig(
|
||||||
|
module="invite_manager",
|
||||||
|
key="flag",
|
||||||
|
value=True,
|
||||||
|
help="强制拉群后进群退出并回复内容",
|
||||||
|
default_value=True,
|
||||||
|
type=bool,
|
||||||
|
),
|
||||||
|
RegisterConfig(
|
||||||
|
module="invite_manager",
|
||||||
|
key="welcome_msg_cd",
|
||||||
|
value=5,
|
||||||
|
help="群欢迎消息cd",
|
||||||
|
default_value=5,
|
||||||
|
type=int,
|
||||||
|
),
|
||||||
|
RegisterConfig(
|
||||||
|
module="_task",
|
||||||
|
key="DEFAULT_GROUP_WELCOME",
|
||||||
|
value=True,
|
||||||
|
help="被动 进群欢迎 进群默认开关状态",
|
||||||
|
default_value=True,
|
||||||
|
type=bool,
|
||||||
|
),
|
||||||
|
RegisterConfig(
|
||||||
|
module="_task",
|
||||||
|
key="DEFAULT_REFUND_GROUP_REMIND",
|
||||||
|
value=True,
|
||||||
|
help="被动 退群提醒 进群默认开关状态",
|
||||||
|
default_value=True,
|
||||||
|
type=bool,
|
||||||
|
),
|
||||||
|
],
|
||||||
|
tasks=[
|
||||||
|
Task(module="group_welcome", name="进群欢迎"),
|
||||||
|
Task(module="refund_group_remind", name="退群提醒"),
|
||||||
|
],
|
||||||
|
).dict(),
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
|
base_config = Config.get("invite_manager")
|
||||||
|
|
||||||
|
|
||||||
|
limit_cd = base_config.get("welcome_msg_cd")
|
||||||
|
|
||||||
|
_flmt = FreqLimiter(limit_cd)
|
||||||
|
|
||||||
|
|
||||||
|
group_increase_handle = on_notice(priority=1, block=False)
|
||||||
|
"""群员增加处理"""
|
||||||
|
group_decrease_handle = on_notice(priority=1, block=False)
|
||||||
|
"""群员减少处理"""
|
||||||
|
add_group = on_request(priority=1, block=False)
|
||||||
|
"""加群同意请求"""
|
||||||
|
|
||||||
|
|
||||||
|
@group_increase_handle.handle()
|
||||||
|
async def _(bot: Bot, event: GroupIncreaseNoticeEvent | GroupMemberIncreaseEvent):
|
||||||
|
superusers = BotConfig.get_superuser("qq")
|
||||||
|
user_id = str(event.user_id)
|
||||||
|
group_id = str(event.group_id)
|
||||||
|
if user_id == bot.self_id:
|
||||||
|
"""新成员为bot本身"""
|
||||||
|
group = await GroupConsole.get_or_none(
|
||||||
|
group_id=group_id, channel_id__isnull=True
|
||||||
|
)
|
||||||
|
if not group or group.group_flag == 0:
|
||||||
|
"""群聊不存在或被强制拉群"""
|
||||||
|
if base_config.get("flag"):
|
||||||
|
"""退出群组"""
|
||||||
|
try:
|
||||||
|
if result_msg := base_config.get("message"):
|
||||||
|
await bot.send_group_msg(
|
||||||
|
group_id=event.group_id, message=result_msg
|
||||||
|
)
|
||||||
|
await bot.set_group_leave(group_id=event.group_id)
|
||||||
|
if superusers:
|
||||||
|
await bot.send_private_msg(
|
||||||
|
user_id=int(superusers[0]),
|
||||||
|
message=f"触发强制入群保护,已成功退出群聊 {group_id}...",
|
||||||
|
)
|
||||||
|
logger.info(
|
||||||
|
"强制拉群或未有群信息,退出群聊成功",
|
||||||
|
"入群检测",
|
||||||
|
group_id=event.group_id,
|
||||||
|
)
|
||||||
|
if req := await FgRequest.get_or_none(
|
||||||
|
group_id=group_id, handle_type__isnull=True
|
||||||
|
):
|
||||||
|
req.handle_type = RequestHandleType.IGNORE
|
||||||
|
await req.save(update_fields=["handle_type"])
|
||||||
|
except Exception as e:
|
||||||
|
logger.error(
|
||||||
|
"强制拉群或未有群信息,退出群聊失败",
|
||||||
|
"入群检测",
|
||||||
|
group_id=event.group_id,
|
||||||
|
e=e,
|
||||||
|
)
|
||||||
|
if superusers:
|
||||||
|
await bot.send_private_msg(
|
||||||
|
user_id=int(superusers[0]),
|
||||||
|
message="触发强制入群保护,"
|
||||||
|
f"退出群聊 {event.group_id} 失败...",
|
||||||
|
)
|
||||||
|
await GroupConsole.filter(group_id=group_id).delete()
|
||||||
|
else:
|
||||||
|
"""允许群组并设置群认证,默认群功能开关"""
|
||||||
|
if group:
|
||||||
|
await GroupConsole.filter(
|
||||||
|
group_id=group_id, channel_id__isnull=True
|
||||||
|
).update(group_flag=1)
|
||||||
|
else:
|
||||||
|
block_plugin = ""
|
||||||
|
if plugin_list := await PluginInfo.filter(
|
||||||
|
default_status=False
|
||||||
|
).all():
|
||||||
|
for plugin in plugin_list:
|
||||||
|
block_plugin += f"{plugin.module},"
|
||||||
|
group_info = await bot.get_group_info(group_id=event.group_id)
|
||||||
|
await GroupConsole.create(
|
||||||
|
group_id=group_info["group_id"],
|
||||||
|
group_name=group_info["group_name"],
|
||||||
|
max_member_count=group_info["max_member_count"],
|
||||||
|
member_count=group_info["member_count"],
|
||||||
|
group_flag=1,
|
||||||
|
block_plugin=block_plugin,
|
||||||
|
platform="qq",
|
||||||
|
)
|
||||||
|
"""刷新群管理员权限"""
|
||||||
|
admin_default_auth = Config.get_config(
|
||||||
|
"admin_bot_manage", "ADMIN_DEFAULT_AUTH"
|
||||||
|
)
|
||||||
|
# 即刻刷新权限
|
||||||
|
for user_info in await bot.get_group_member_list(
|
||||||
|
group_id=event.group_id
|
||||||
|
):
|
||||||
|
"""即刻刷新权限"""
|
||||||
|
if (
|
||||||
|
user_info["role"]
|
||||||
|
in [
|
||||||
|
"owner",
|
||||||
|
"admin",
|
||||||
|
]
|
||||||
|
and not await LevelUser.is_group_flag(
|
||||||
|
user_info["user_id"], group_id
|
||||||
|
)
|
||||||
|
and admin_default_auth is not None
|
||||||
|
):
|
||||||
|
await LevelUser.set_level(
|
||||||
|
user_info["user_id"],
|
||||||
|
user_info["group_id"],
|
||||||
|
admin_default_auth,
|
||||||
|
)
|
||||||
|
logger.debug(
|
||||||
|
f"添加默认群管理员权限: {admin_default_auth}",
|
||||||
|
"入群检测",
|
||||||
|
session=user_info["user_id"],
|
||||||
|
group_id=user_info["group_id"],
|
||||||
|
)
|
||||||
|
if str(user_info["user_id"]) in bot.config.superusers:
|
||||||
|
await LevelUser.set_level(
|
||||||
|
user_info["user_id"], user_info["group_id"], 9
|
||||||
|
)
|
||||||
|
logger.debug(
|
||||||
|
"添加超级用户权限: 9",
|
||||||
|
"入群检测",
|
||||||
|
session=user_info["user_id"],
|
||||||
|
group_id=user_info["group_id"],
|
||||||
|
)
|
||||||
|
else:
|
||||||
|
join_time = datetime.now()
|
||||||
|
user_info = await bot.get_group_member_info(
|
||||||
|
group_id=event.group_id, user_id=event.user_id
|
||||||
|
)
|
||||||
|
await GroupInfoUser.update_or_create(
|
||||||
|
user_id=str(user_info["user_id"]),
|
||||||
|
group_id=str(user_info["group_id"]),
|
||||||
|
defaults={"user_name": user_info["nickname"], "user_join_time": join_time},
|
||||||
|
)
|
||||||
|
logger.info(f"用户{user_info['user_id']} 所属{user_info['group_id']} 更新成功")
|
||||||
|
|
||||||
|
if _flmt.check(group_id):
|
||||||
|
"""群欢迎消息"""
|
||||||
|
_flmt.start_cd(group_id)
|
||||||
|
path = DATA_PATH / "welcome_message" / "qq" / f"{group_id}"
|
||||||
|
file = path / "text.json"
|
||||||
|
msg_list = []
|
||||||
|
if file.exists():
|
||||||
|
data = json.load((path / "text.json").open(encoding="utf-8"))
|
||||||
|
message = data["message"]
|
||||||
|
msg_split = re.split(r"\[image:\d+\]", message)
|
||||||
|
if data["at"]:
|
||||||
|
msg_list.append(At(flag="user", target=user_id))
|
||||||
|
for i, text in enumerate(msg_split):
|
||||||
|
msg_list.append(text)
|
||||||
|
img_file = path / f"{i}.png"
|
||||||
|
if img_file.exists():
|
||||||
|
msg_list.append(img_file)
|
||||||
|
if not await CommonUtils.task_is_block("group_welcome", group_id):
|
||||||
|
logger.info("发送群欢迎消息...", "入群检测", group_id=group_id)
|
||||||
|
if msg_list:
|
||||||
|
await MessageUtils.build_message(msg_list).send()
|
||||||
|
else:
|
||||||
|
image = (
|
||||||
|
IMAGE_PATH
|
||||||
|
/ "qxz"
|
||||||
|
/ random.choice(os.listdir(IMAGE_PATH / "qxz"))
|
||||||
|
)
|
||||||
|
await MessageUtils.build_message(
|
||||||
|
[
|
||||||
|
"新人快跑啊!!本群现状↓(快使用自定义!)",
|
||||||
|
image,
|
||||||
|
]
|
||||||
|
).send()
|
||||||
|
|
||||||
|
|
||||||
|
@group_decrease_handle.handle()
|
||||||
|
async def _(bot: Bot, event: GroupDecreaseNoticeEvent | GroupMemberDecreaseEvent):
|
||||||
|
if event.sub_type == "kick_me":
|
||||||
|
"""踢出Bot"""
|
||||||
|
group_id = event.group_id
|
||||||
|
operator_id = event.operator_id
|
||||||
|
if user := await GroupInfoUser.get_or_none(
|
||||||
|
user_id=str(event.operator_id), group_id=str(event.group_id)
|
||||||
|
):
|
||||||
|
operator_name = user.user_name
|
||||||
|
else:
|
||||||
|
operator_name = "None"
|
||||||
|
group = await GroupConsole.filter(group_id=str(group_id)).first()
|
||||||
|
group_name = group.group_name if group else ""
|
||||||
|
if superusers := BotConfig.get_superuser("qq"):
|
||||||
|
coffee = int(superusers[0])
|
||||||
|
await bot.send_private_msg(
|
||||||
|
user_id=coffee,
|
||||||
|
message=f"****呜..一份踢出报告****\n"
|
||||||
|
f"我被 {operator_name}({operator_id})\n"
|
||||||
|
f"踢出了 {group_name}({group_id})\n"
|
||||||
|
f"日期:{str(datetime.now()).split('.')[0]}",
|
||||||
|
)
|
||||||
|
if group:
|
||||||
|
await group.delete()
|
||||||
|
return
|
||||||
|
if str(event.user_id) == bot.self_id:
|
||||||
|
"""踢出Bot"""
|
||||||
|
await GroupConsole.filter(group_id=str(event.group_id)).delete()
|
||||||
|
return
|
||||||
|
if user := await GroupInfoUser.get_or_none(
|
||||||
|
user_id=str(event.user_id), group_id=str(event.group_id)
|
||||||
|
):
|
||||||
|
user_name = user.user_name
|
||||||
|
else:
|
||||||
|
user_name = f"{event.user_id}"
|
||||||
|
await GroupInfoUser.filter(
|
||||||
|
user_id=str(event.user_id), group_id=str(event.group_id)
|
||||||
|
).delete()
|
||||||
|
logger.info(
|
||||||
|
f"名称: {user_name} 退出群聊",
|
||||||
|
"group_decrease_handle",
|
||||||
|
session=event.user_id,
|
||||||
|
group_id=event.group_id,
|
||||||
|
)
|
||||||
|
result = ""
|
||||||
|
if event.sub_type == "leave":
|
||||||
|
result = f"{user_name}离开了我们..."
|
||||||
|
if event.sub_type == "kick":
|
||||||
|
operator = await bot.get_group_member_info(
|
||||||
|
user_id=event.operator_id, group_id=event.group_id
|
||||||
|
)
|
||||||
|
operator_name = operator["card"] or operator["nickname"]
|
||||||
|
result = f"{user_name} 被 {operator_name} 送走了."
|
||||||
|
if not await CommonUtils.task_is_block("refund_group_remind", str(event.group_id)):
|
||||||
|
await group_decrease_handle.send(f"{result}")
|
||||||
@@ -1,30 +0,0 @@
|
|||||||
import os
|
|
||||||
import time
|
|
||||||
|
|
||||||
from nonebot.rule import to_me
|
|
||||||
from nonebot.utils import run_sync
|
|
||||||
from nonebot.permission import SUPERUSER
|
|
||||||
from nonebot.plugin import PluginMetadata
|
|
||||||
from nonebot_plugin_session import EventSession
|
|
||||||
from nonebot_plugin_apscheduler import scheduler
|
|
||||||
from nonebot_plugin_alconna import Alconna, on_alconna
|
|
||||||
|
|
||||||
from zhenxun.services.log import logger
|
|
||||||
from zhenxun.utils.enum import PluginType
|
|
||||||
from zhenxun.utils.message import MessageUtils
|
|
||||||
from zhenxun.configs.path_config import TEMP_PATH
|
|
||||||
from zhenxun.configs.utils import PluginExtraData
|
|
||||||
from zhenxun.utils.utils import ResourceDirManager
|
|
||||||
|
|
||||||
__plugin_meta__ = PluginMetadata(
|
|
||||||
name="Bot管理",
|
|
||||||
description="指定bot对象的功能/被动开关和状态",
|
|
||||||
usage="""
|
|
||||||
清理临时数据
|
|
||||||
""".strip(),
|
|
||||||
extra=PluginExtraData(
|
|
||||||
author="",
|
|
||||||
version="0.1",
|
|
||||||
plugin_type=PluginType.SUPERUSER,
|
|
||||||
).dict(),
|
|
||||||
)
|
|
||||||
@@ -1,60 +0,0 @@
|
|||||||
from tortoise import fields
|
|
||||||
|
|
||||||
from zhenxun.services.db_context import Model
|
|
||||||
|
|
||||||
|
|
||||||
class BotConsole(Model):
|
|
||||||
id = fields.IntField(pk=True, generated=True, auto_increment=True)
|
|
||||||
"""自增id"""
|
|
||||||
bot_id = fields.CharField(255, unique=True, description="bot_id")
|
|
||||||
"""bot_id"""
|
|
||||||
status = fields.BooleanField(default=True, description="Bot状态")
|
|
||||||
"""Bot状态"""
|
|
||||||
block_plugin = fields.TextField(default="", description="禁用插件")
|
|
||||||
"""禁用插件"""
|
|
||||||
block_task = fields.TextField(default="", description="禁用被动技能")
|
|
||||||
"""禁用被动技能"""
|
|
||||||
create_time = fields.DatetimeField(auto_now_add=True, description="创建时间")
|
|
||||||
"""创建时间"""
|
|
||||||
platform = fields.CharField(255, null=True, description="平台")
|
|
||||||
"""平台"""
|
|
||||||
|
|
||||||
class Meta: # type: ignore
|
|
||||||
table = "bot_console"
|
|
||||||
table_description = "Bot数据表"
|
|
||||||
|
|
||||||
@classmethod
|
|
||||||
async def get_bot_status(cls, bot_id: str) -> bool:
|
|
||||||
result = await cls.get_or_none(bot_id=bot_id)
|
|
||||||
return result.status if result else False
|
|
||||||
|
|
||||||
@classmethod
|
|
||||||
async def set_block_plugin(cls, bot_id: str, module: str):
|
|
||||||
bot_data, _ = await cls.get_or_create(bot_id=bot_id)
|
|
||||||
if f"<{module}," not in bot_data.block_plugin:
|
|
||||||
bot_data.block_plugin += f"<{module},"
|
|
||||||
await bot_data.save(update_fields=["block_plugin"])
|
|
||||||
|
|
||||||
@classmethod
|
|
||||||
async def set_unblock_plugin(cls, bot_id: str, module: str):
|
|
||||||
bot_data, _ = await cls.get_or_create(bot_id=bot_id)
|
|
||||||
if f"<{module}," in bot_data.block_plugin:
|
|
||||||
bot_data.block_plugin = bot_data.block_plugin.replace(f"<{module},", "")
|
|
||||||
await bot_data.save(update_fields=["block_plugin"])
|
|
||||||
|
|
||||||
@classmethod
|
|
||||||
async def set_block_task(cls, bot_id: str, task: str):
|
|
||||||
bot_data, _ = await cls.get_or_create(bot_id=bot_id)
|
|
||||||
if f"<{task}," not in bot_data.block_task:
|
|
||||||
bot_data.block_plugin += f"<{task},"
|
|
||||||
await bot_data.save(update_fields=["block_task"])
|
|
||||||
|
|
||||||
@classmethod
|
|
||||||
async def is_block_plugin(cls, bot_id: str, task: str) -> bool:
|
|
||||||
bot_data, _ = await cls.get_or_create(bot_id=bot_id)
|
|
||||||
return f"<{task}," in bot_data.block_plugin
|
|
||||||
|
|
||||||
@classmethod
|
|
||||||
async def is_block_task(cls, bot_id: str, task: str) -> bool:
|
|
||||||
bot_data, _ = await cls.get_or_create(bot_id=bot_id)
|
|
||||||
return f"<{task}," in bot_data.block_task
|
|
||||||
@@ -37,8 +37,8 @@ class GroupConsole(Model):
|
|||||||
default="", description="超级用户禁用插件"
|
default="", description="超级用户禁用插件"
|
||||||
)
|
)
|
||||||
"""超级用户禁用插件"""
|
"""超级用户禁用插件"""
|
||||||
block_task = fields.TextField(default="", description="禁用被动技能")
|
block_task = fields.TextField(default="", description="禁用插件")
|
||||||
"""禁用被动技能"""
|
"""禁用插件"""
|
||||||
superuser_block_task = fields.TextField(default="", description="超级用户禁用被动")
|
superuser_block_task = fields.TextField(default="", description="超级用户禁用被动")
|
||||||
"""超级用户禁用被动"""
|
"""超级用户禁用被动"""
|
||||||
platform = fields.CharField(255, default="qq", description="所属平台")
|
platform = fields.CharField(255, default="qq", description="所属平台")
|
||||||
|
|||||||
@@ -0,0 +1,35 @@
|
|||||||
|
import re
|
||||||
|
|
||||||
|
GITHUB_REPO_URL_PATTERN = re.compile(
|
||||||
|
r"^https://github.com/(?P<owner>[^/]+)/(?P<repo>[^/]+)(/tree/(?P<branch>[^/]+))?$"
|
||||||
|
)
|
||||||
|
"""github仓库地址正则"""
|
||||||
|
|
||||||
|
JSD_PACKAGE_API_FORMAT = (
|
||||||
|
"https://data.jsdelivr.com/v1/packages/gh/{owner}/{repo}@{branch}"
|
||||||
|
)
|
||||||
|
"""jsdelivr包地址格式"""
|
||||||
|
|
||||||
|
GIT_API_TREES_FORMAT = (
|
||||||
|
"https://api.github.com/repos/{owner}/{repo}/git/trees/{branch}?recursive=1"
|
||||||
|
)
|
||||||
|
"""git api trees地址格式"""
|
||||||
|
|
||||||
|
CACHED_API_TTL = 300
|
||||||
|
"""缓存api ttl"""
|
||||||
|
|
||||||
|
RAW_CONTENT_FORMAT = "https://raw.githubusercontent.com/{owner}/{repo}/{branch}/{path}"
|
||||||
|
"""raw content格式"""
|
||||||
|
|
||||||
|
ARCHIVE_URL_FORMAT = "https://github.com/{owner}/{repo}/archive/refs/heads/{branch}.zip"
|
||||||
|
"""archive url格式"""
|
||||||
|
|
||||||
|
RELEASE_ASSETS_FORMAT = (
|
||||||
|
"https://github.com/{owner}/{repo}/releases/download/{version}/{filename}"
|
||||||
|
)
|
||||||
|
"""release assets格式"""
|
||||||
|
|
||||||
|
RELEASE_SOURCE_FORMAT = (
|
||||||
|
"https://codeload.github.com/{owner}/{repo}/legacy.{compress}/refs/tags/{version}"
|
||||||
|
)
|
||||||
|
"""release 源码格式"""
|
||||||
@@ -390,7 +390,7 @@ def get_img_hash(image_file: str | Path) -> str:
|
|||||||
return str(hash_value)
|
return str(hash_value)
|
||||||
|
|
||||||
|
|
||||||
async def get_download_image_hash(url: str, mark: str, use_proxy: bool = False) -> str:
|
async def get_download_image_hash(url: str, mark: str) -> str:
|
||||||
"""下载图片获取哈希值
|
"""下载图片获取哈希值
|
||||||
|
|
||||||
参数:
|
参数:
|
||||||
@@ -402,7 +402,7 @@ async def get_download_image_hash(url: str, mark: str, use_proxy: bool = False)
|
|||||||
"""
|
"""
|
||||||
try:
|
try:
|
||||||
if await AsyncHttpx.download_file(
|
if await AsyncHttpx.download_file(
|
||||||
url, TEMP_PATH / f"compare_download_{mark}_img.jpg", use_proxy=use_proxy
|
url, TEMP_PATH / f"compare_download_{mark}_img.jpg"
|
||||||
):
|
):
|
||||||
img_hash = get_img_hash(TEMP_PATH / f"compare_download_{mark}_img.jpg")
|
img_hash = get_img_hash(TEMP_PATH / f"compare_download_{mark}_img.jpg")
|
||||||
return str(img_hash)
|
return str(img_hash)
|
||||||
|
|||||||
@@ -27,14 +27,14 @@ def admin_check(a: int | str, key: str | None = None) -> Rule:
|
|||||||
if PlatformUtils.is_qbot(session):
|
if PlatformUtils.is_qbot(session):
|
||||||
"""官bot接口,放弃所有权限检查"""
|
"""官bot接口,放弃所有权限检查"""
|
||||||
return False
|
return False
|
||||||
if session.group:
|
if session.id and session.group:
|
||||||
level = a
|
level = a
|
||||||
if isinstance(a, str) and key:
|
if isinstance(a, str) and key:
|
||||||
level = Config.get_config(a, key)
|
level = Config.get_config(a, key)
|
||||||
if level is not None:
|
if level is not None:
|
||||||
return bool(
|
return bool(
|
||||||
await LevelUser.check_level(
|
await LevelUser.check_level(
|
||||||
session.user.id, session.group.id, int(level)
|
session.id, session.group.id, int(level)
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
return False
|
return False
|
||||||
|
|||||||
Reference in New Issue
Block a user