mirror of
https://github.com/zhenxun-org/zhenxun_bot.git
synced 2025-12-15 14:22:55 +08:00
🎨 优化GroupConsole设置插件默认状态代码结构
This commit is contained in:
parent
1563a8e8a5
commit
d8d044e3ea
@ -15,7 +15,8 @@ async def get_task() -> dict[str, str] | None:
|
|||||||
return {
|
return {
|
||||||
"name": "被动技能",
|
"name": "被动技能",
|
||||||
"description": "控制群组中的被动技能状态",
|
"description": "控制群组中的被动技能状态",
|
||||||
"usage": "通过 开启/关闭群被动 来控制群被<br>----------<br>"
|
"usage": "通过 开启/关闭群被动 来控制群被动 <br>"
|
||||||
|
+ " 示例:开启/关闭群被动早晚安 <br> ---------- <br> "
|
||||||
+ "<br>".join([task.name for task in task_list]),
|
+ "<br>".join([task.name for task in task_list]),
|
||||||
}
|
}
|
||||||
return None
|
return None
|
||||||
|
|||||||
@ -15,7 +15,8 @@ async def get_task() -> dict[str, str] | None:
|
|||||||
return {
|
return {
|
||||||
"name": "被动技能",
|
"name": "被动技能",
|
||||||
"description": "控制群组中的被动技能状态",
|
"description": "控制群组中的被动技能状态",
|
||||||
"usage": "通过 开启/关闭群被动 来控制群被动 <br> ---------- <br> "
|
"usage": "通过 开启/关闭群被动 来控制群被动 <br>"
|
||||||
|
+ " 示例:开启/关闭群被动早晚安 <br> ---------- <br> "
|
||||||
+ "<br>".join([task.name for task in task_list]),
|
+ "<br>".join([task.name for task in task_list]),
|
||||||
}
|
}
|
||||||
return None
|
return None
|
||||||
|
|||||||
@ -1,4 +1,4 @@
|
|||||||
from typing import Any, overload
|
from typing import Any, cast, overload
|
||||||
from typing_extensions import Self
|
from typing_extensions import Self
|
||||||
|
|
||||||
from tortoise import fields
|
from tortoise import fields
|
||||||
@ -79,24 +79,57 @@ class GroupConsole(Model):
|
|||||||
elif isinstance(data, list):
|
elif isinstance(data, list):
|
||||||
return "".join(cls.format(item) for item in data)
|
return "".join(cls.format(item) for item in data)
|
||||||
|
|
||||||
|
@classmethod
|
||||||
|
async def __set_default_plugin_status(cls, group: Self) -> list[str]:
|
||||||
|
"""设置新群组信息时默认插件关闭状态
|
||||||
|
|
||||||
|
参数:
|
||||||
|
group: GroupConsole对象
|
||||||
|
|
||||||
|
返回:
|
||||||
|
list[str]: 更新字段列表
|
||||||
|
"""
|
||||||
|
task_modules = cast(
|
||||||
|
list[str],
|
||||||
|
await TaskInfo.filter(default_status=False).values_list(
|
||||||
|
"module", flat=True
|
||||||
|
),
|
||||||
|
)
|
||||||
|
plugin_modules = cast(
|
||||||
|
list[str],
|
||||||
|
await PluginInfo.filter(
|
||||||
|
plugin_type__in=[PluginType.NORMAL, PluginType.DEPENDANT],
|
||||||
|
default_status=False,
|
||||||
|
load_status=True,
|
||||||
|
).values_list("module", flat=True),
|
||||||
|
)
|
||||||
|
|
||||||
|
if not task_modules and not plugin_modules:
|
||||||
|
return []
|
||||||
|
|
||||||
|
update_fields = []
|
||||||
|
|
||||||
|
if task_modules:
|
||||||
|
group.block_task = cls.convert_module_format(task_modules)
|
||||||
|
update_fields.append("block_task")
|
||||||
|
|
||||||
|
if plugin_modules:
|
||||||
|
group.block_plugin = cls.convert_module_format(list(plugin_modules))
|
||||||
|
update_fields.append("block_plugin")
|
||||||
|
|
||||||
|
return update_fields
|
||||||
|
|
||||||
@classmethod
|
@classmethod
|
||||||
async def create(
|
async def create(
|
||||||
cls, using_db: BaseDBAsyncClient | None = None, **kwargs: Any
|
cls, using_db: BaseDBAsyncClient | None = None, **kwargs: Any
|
||||||
) -> Self:
|
) -> Self:
|
||||||
"""覆盖create方法"""
|
"""覆盖create方法"""
|
||||||
group = await super().create(using_db=using_db, **kwargs)
|
group = await super().create(using_db=using_db, **kwargs)
|
||||||
if modules := await TaskInfo.filter(default_status=False).values_list(
|
|
||||||
"module", flat=True
|
update_fields = await cls.__set_default_plugin_status(group)
|
||||||
):
|
if update_fields:
|
||||||
group.block_task = cls.convert_module_format(modules) # type: ignore
|
await group.save(using_db=using_db, update_fields=update_fields)
|
||||||
if modules := await PluginInfo.filter(
|
|
||||||
plugin_type__in=[PluginType.NORMAL, PluginType.DEPENDANT],
|
|
||||||
default_status=False,
|
|
||||||
).values_list("module", flat=True):
|
|
||||||
group.block_plugin = cls.convert_module_format(modules) # type: ignore
|
|
||||||
await group.save(
|
|
||||||
using_db=using_db, update_fields=["block_plugin", "block_task"]
|
|
||||||
)
|
|
||||||
return group
|
return group
|
||||||
|
|
||||||
@classmethod
|
@classmethod
|
||||||
@ -110,20 +143,12 @@ class GroupConsole(Model):
|
|||||||
group, is_create = await super().get_or_create(
|
group, is_create = await super().get_or_create(
|
||||||
defaults=defaults, using_db=using_db, **kwargs
|
defaults=defaults, using_db=using_db, **kwargs
|
||||||
)
|
)
|
||||||
|
|
||||||
if is_create:
|
if is_create:
|
||||||
if modules := await TaskInfo.filter(default_status=False).values_list(
|
update_fields = await cls.__set_default_plugin_status(group)
|
||||||
"module", flat=True
|
if update_fields:
|
||||||
):
|
await group.save(using_db=using_db, update_fields=update_fields)
|
||||||
group.block_task = cls.convert_module_format(modules) # type: ignore
|
|
||||||
if modules := await PluginInfo.filter(
|
|
||||||
plugin_type__in=[PluginType.NORMAL, PluginType.DEPENDANT],
|
|
||||||
default_status=False,
|
|
||||||
load_status=True,
|
|
||||||
).values_list("module", flat=True):
|
|
||||||
group.block_plugin = cls.convert_module_format(modules) # type: ignore
|
|
||||||
await group.save(
|
|
||||||
using_db=using_db, update_fields=["block_plugin", "block_task"]
|
|
||||||
)
|
|
||||||
return group, is_create
|
return group, is_create
|
||||||
|
|
||||||
@classmethod
|
@classmethod
|
||||||
@ -137,20 +162,12 @@ class GroupConsole(Model):
|
|||||||
group, is_create = await super().update_or_create(
|
group, is_create = await super().update_or_create(
|
||||||
defaults=defaults, using_db=using_db, **kwargs
|
defaults=defaults, using_db=using_db, **kwargs
|
||||||
)
|
)
|
||||||
|
|
||||||
if is_create:
|
if is_create:
|
||||||
if modules := await TaskInfo.filter(default_status=False).values_list(
|
update_fields = await cls.__set_default_plugin_status(group)
|
||||||
"module", flat=True
|
if update_fields:
|
||||||
):
|
await group.save(using_db=using_db, update_fields=update_fields)
|
||||||
group.block_task = cls.convert_module_format(modules) # type: ignore
|
|
||||||
if modules := await PluginInfo.filter(
|
|
||||||
plugin_type__in=[PluginType.NORMAL, PluginType.DEPENDANT],
|
|
||||||
default_status=False,
|
|
||||||
load_status=True,
|
|
||||||
).values_list("module", flat=True):
|
|
||||||
group.block_plugin = cls.convert_module_format(modules) # type: ignore
|
|
||||||
await group.save(
|
|
||||||
using_db=using_db, update_fields=["block_plugin", "block_task"]
|
|
||||||
)
|
|
||||||
return group, is_create
|
return group, is_create
|
||||||
|
|
||||||
@classmethod
|
@classmethod
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user