Diuse/zhenxun_bot
1
0
Fork 0
mirror of https://github.com/zhenxun-org/zhenxun_bot.git synced 2025-12-15 14:22:55 +08:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

🐛 修复所有插件关闭时缓存更新

Browse Source
This commit is contained in:
HibiKier 2025-04-19 21:45:11 +08:00
parent 99e09caf24
commit 25957f421d
1 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
zhenxun/builtin_plugins/admin/plugin_switch/_data_source.py
View File

@ -4,7 +4,8 @@ from zhenxun.configs.path_config import DATA_PATH, IMAGE_PATH
from zhenxun.models.group_console import GroupConsole from zhenxun.models.group_console import GroupConsole
from zhenxun.models.plugin_info import PluginInfo from zhenxun.models.plugin_info import PluginInfo
from zhenxun.models.task_info import TaskInfo from zhenxun.models.task_info import TaskInfo
from zhenxun.utils.enum import BlockType, PluginType from zhenxun.services.cache import Cache
from zhenxun.utils.enum import BlockType, CacheType, PluginType
from zhenxun.utils.exception import GroupInfoNotFound from zhenxun.utils.exception import GroupInfoNotFound
from zhenxun.utils.image_utils import BuildImage, ImageTemplate, RowStyle from zhenxun.utils.image_utils import BuildImage, ImageTemplate, RowStyle
@ -220,6 +221,8 @@ class PluginManage:
await PluginInfo.filter(plugin_type=PluginType.NORMAL).update( await PluginInfo.filter(plugin_type=PluginType.NORMAL).update(
status=status, block_type=None if status else BlockType.ALL status=status, block_type=None if status else BlockType.ALL
) )
cache = Cache[PluginInfo](CacheType.PLUGINS)
await cache.reload()
return f"成功将所有功能全局状态修改为: {'开启' if status else '关闭'}" return f"成功将所有功能全局状态修改为: {'开启' if status else '关闭'}"
@classmethod @classmethod
@ -271,7 +274,9 @@ class PluginManage:
参数: 参数:
module: 模块名 module: 模块名
""" """
await PluginInfo.filter(module=module).update(status=False) if plugin := await PluginInfo.get_plugin(module=module):
plugin.status = False
await plugin.save(update_fields=["status"])
@classmethod @classmethod
async def unblock(cls, module: str): async def unblock(cls, module: str):
@ -280,7 +285,9 @@ class PluginManage:
参数: 参数:
module: 模块名 module: 模块名
""" """
await PluginInfo.filter(module=module).update(status=True) if plugin := await PluginInfo.get_plugin(module=module):
plugin.status = True
await plugin.save(update_fields=["status"])
@classmethod @classmethod
async def block_group_plugin(cls, plugin_name: str, group_id: str) -> str: async def block_group_plugin(cls, plugin_name: str, group_id: str) -> str: