mirror of
https://github.com/fastapiadmin/FastapiAdmin.git
synced 2026-09-20 20:39:55 +00:00
refactor(upload): 重构文件上传组件并优化相关逻辑
移除旧的FileUpload和MultiImageUpload组件,统一使用SingleImageUpload组件处理上传 重构SingleImageUpload组件,使用ConfigAPI替代FileAPI,优化上传逻辑和错误处理 更新用户头像上传逻辑,使用UserAPI处理上传并优化交互体验 优化数据库初始化流程,分离数据库操作和Redis相关操作 重构字典数据配置,合并重复的字典类型并更新相关视图组件 修复定时任务控制器参数类型,从Query改为Body 添加ElImageViewer组件类型声明 优化数据库连接错误处理和日志信息
This commit is contained in:
@@ -49,12 +49,17 @@ async def lifespan(app: FastAPI) -> AsyncGenerator[Any, Any]:
|
||||
|
||||
try:
|
||||
async with session_connect() as session:
|
||||
# 第一阶段:仅执行数据库相关初始化操作,确保数据库初始化完成
|
||||
async with session.begin():
|
||||
# 测试数据库连接
|
||||
await test_db_connection(session)
|
||||
logger.info("数据库连接成功...")
|
||||
await InitializeData().init_db(db=session)
|
||||
logger.info("初始化数据完成...")
|
||||
await session.commit()
|
||||
|
||||
# 第二阶段:执行依赖 redis 的操作,这些操作失败不会影响数据库初始化
|
||||
try:
|
||||
await import_modules_async(modules=settings.EVENT_LIST, desc="全局事件", app=app, status=True)
|
||||
await ConfigService().init_config_service(redis=app.state.redis, db=session)
|
||||
logger.info("初始化系统配置完成...")
|
||||
@@ -62,11 +67,16 @@ async def lifespan(app: FastAPI) -> AsyncGenerator[Any, Any]:
|
||||
logger.info('初始化数据字典完成...')
|
||||
await SchedulerUtil.init_system_scheduler(db=session)
|
||||
logger.info('初始化定时任务完成...')
|
||||
await session.commit()
|
||||
except Exception as e:
|
||||
# 这里不进行回滚,避免影响已完成的数据库初始化
|
||||
# 可以根据实际情况决定是否继续抛出异常,这里选择继续抛出
|
||||
raise e
|
||||
|
||||
logger.info(f'{settings.TITLE} 服务成功启动...')
|
||||
except Exception as e:
|
||||
await session.rollback()
|
||||
# 仅在第一阶段数据库操作出现错误时进行回滚
|
||||
if 'session' in locals() and session.in_transaction():
|
||||
await session.rollback()
|
||||
logger.error(f'{settings.TITLE} 服务启动失败: {str(e)}')
|
||||
raise e
|
||||
yield
|
||||
|
||||
Reference in New Issue
Block a user