Revert "fix 卸载插件时删除插件配置"
This reverts commit dd7803c90af439a9a891b352cd5cc2de7ff934a5.
This commit is contained in:
parent
ac11d4eb30
commit
f38defb515
@ -101,8 +101,6 @@ def uninstall_plugin(plugin_id: str,
|
|||||||
if plugin == plugin_id:
|
if plugin == plugin_id:
|
||||||
install_plugins.remove(plugin)
|
install_plugins.remove(plugin)
|
||||||
break
|
break
|
||||||
# 删除插件配置
|
|
||||||
SystemConfigOper().delete_by_key(plugin_id)
|
|
||||||
# 保存
|
# 保存
|
||||||
SystemConfigOper().set(SystemConfigKey.UserInstalledPlugins, install_plugins)
|
SystemConfigOper().set(SystemConfigKey.UserInstalledPlugins, install_plugins)
|
||||||
# 重载插件管理器
|
# 重载插件管理器
|
||||||
|
@ -26,11 +26,6 @@ class PluginData(Base):
|
|||||||
db.query(PluginData).filter(PluginData.plugin_id == plugin_id, PluginData.key == key).delete()
|
db.query(PluginData).filter(PluginData.plugin_id == plugin_id, PluginData.key == key).delete()
|
||||||
Base.commit(db)
|
Base.commit(db)
|
||||||
|
|
||||||
@staticmethod
|
|
||||||
def del_plugin_data_by_plugin_id(db: Session, plugin_id: str):
|
|
||||||
db.query(PluginData).filter(PluginData.plugin_id == plugin_id).delete()
|
|
||||||
Base.commit(db)
|
|
||||||
|
|
||||||
@staticmethod
|
@staticmethod
|
||||||
def get_plugin_data_by_plugin_id(db: Session, plugin_id: str):
|
def get_plugin_data_by_plugin_id(db: Session, plugin_id: str):
|
||||||
return db.query(PluginData).filter(PluginData.plugin_id == plugin_id).all()
|
return db.query(PluginData).filter(PluginData.plugin_id == plugin_id).all()
|
||||||
|
@ -43,16 +43,13 @@ class PluginDataOper(DbOper):
|
|||||||
return json.loads(data.value)
|
return json.loads(data.value)
|
||||||
return data.value
|
return data.value
|
||||||
|
|
||||||
def del_data(self, plugin_id: str, key: str = None) -> Any:
|
def del_data(self, plugin_id: str, key: str) -> Any:
|
||||||
"""
|
"""
|
||||||
删除插件数据
|
删除插件数据
|
||||||
:param plugin_id: 插件id
|
:param plugin_id: 插件id
|
||||||
:param key: 数据key
|
:param key: 数据key
|
||||||
"""
|
"""
|
||||||
if key:
|
PluginData.del_plugin_data_by_key(self._db, plugin_id, key)
|
||||||
PluginData.del_plugin_data_by_key(self._db, plugin_id, key)
|
|
||||||
else:
|
|
||||||
PluginData.del_plugin_data_by_plugin_id(self._db, plugin_id)
|
|
||||||
|
|
||||||
def truncate(self):
|
def truncate(self):
|
||||||
"""
|
"""
|
||||||
|
@ -3,7 +3,6 @@ from typing import Any, Union
|
|||||||
|
|
||||||
from app.db import DbOper, SessionFactory
|
from app.db import DbOper, SessionFactory
|
||||||
from app.db.models.systemconfig import SystemConfig
|
from app.db.models.systemconfig import SystemConfig
|
||||||
from app.db.plugindata_oper import PluginDataOper
|
|
||||||
from app.schemas.types import SystemConfigKey
|
from app.schemas.types import SystemConfigKey
|
||||||
from app.utils.object import ObjectUtils
|
from app.utils.object import ObjectUtils
|
||||||
from app.utils.singleton import Singleton
|
from app.utils.singleton import Singleton
|
||||||
@ -18,11 +17,8 @@ class SystemConfigOper(DbOper, metaclass=Singleton):
|
|||||||
加载配置到内存
|
加载配置到内存
|
||||||
"""
|
"""
|
||||||
self._db = SessionFactory()
|
self._db = SessionFactory()
|
||||||
self._syscomconfig = SystemConfig()
|
|
||||||
# 插件数据
|
|
||||||
self.plugindata = PluginDataOper(self._db)
|
|
||||||
super().__init__(self._db)
|
super().__init__(self._db)
|
||||||
for item in self._syscomconfig.list(self._db):
|
for item in SystemConfig.list(self._db):
|
||||||
if ObjectUtils.is_obj(item.value):
|
if ObjectUtils.is_obj(item.value):
|
||||||
self.__SYSTEMCONF[item.key] = json.loads(item.value)
|
self.__SYSTEMCONF[item.key] = json.loads(item.value)
|
||||||
else:
|
else:
|
||||||
@ -41,7 +37,7 @@ class SystemConfigOper(DbOper, metaclass=Singleton):
|
|||||||
value = json.dumps(value)
|
value = json.dumps(value)
|
||||||
elif value is None:
|
elif value is None:
|
||||||
value = ''
|
value = ''
|
||||||
conf = self._syscomconfig.get_by_key(self._db, key)
|
conf = SystemConfig.get_by_key(self._db, key)
|
||||||
if conf:
|
if conf:
|
||||||
if value:
|
if value:
|
||||||
conf.update(self._db, {"value": value})
|
conf.update(self._db, {"value": value})
|
||||||
@ -61,17 +57,6 @@ class SystemConfigOper(DbOper, metaclass=Singleton):
|
|||||||
return self.__SYSTEMCONF
|
return self.__SYSTEMCONF
|
||||||
return self.__SYSTEMCONF.get(key)
|
return self.__SYSTEMCONF.get(key)
|
||||||
|
|
||||||
def delete_by_key(self, key: str = None) -> Any:
|
|
||||||
"""
|
|
||||||
删除系统设置
|
|
||||||
"""
|
|
||||||
if self.__SYSTEMCONF.get(f"plugin.{key}"):
|
|
||||||
del self.__SYSTEMCONF[f"plugin.{key}"]
|
|
||||||
# 删除系统配置
|
|
||||||
self._syscomconfig.delete_by_key(db=self._db, key=f"plugin.{key}")
|
|
||||||
# 删除插件数据
|
|
||||||
self.plugindata.del_data(plugin_id=key)
|
|
||||||
|
|
||||||
def __del__(self):
|
def __del__(self):
|
||||||
if self._db:
|
if self._db:
|
||||||
self._db.close()
|
self._db.close()
|
||||||
|
Loading…
x
Reference in New Issue
Block a user