fix: 修复 ruff lint 和格式化问题

- 修复 E712: 使用 .is_(True) 替代 == True
- 修复 N802: CORS_ORIGINS 改为 cors_origins
- 修复 UP035: 从 collections.abc 导入
- 修复 I001: 导入排序
- 格式化 33 个文件

Author: MKY508

apps/api/alembic/env.py

@@ -1,12 +1,13 @@
 """Alembic 环境配置"""
+
 import asyncio
 from logging.config import fileConfig
 
-from alembic import context
 from sqlalchemy import pool
 from sqlalchemy.engine import Connection
 from sqlalchemy.ext.asyncio import async_engine_from_config
 
+from alembic import context
 from app.core.config import settings
 from app.db.base import Base
 from app.db.tables import *  # noqa: F401, F403 - 导入所有表

apps/api/app/__init__.py

@@ -1,2 +1,3 @@
 """QueryGPT API Server"""
+
 __version__ = "2.0.0"

apps/api/app/api/deps.py

@@ -1,4 +1,5 @@
 """API 依赖注入"""
+
 from uuid import UUID
 
 from fastapi import Depends, HTTPException, status

apps/api/app/api/v1/__init__.py

@@ -1,4 +1,5 @@
 """API v1 路由"""
+
 from fastapi import APIRouter
 
 from app.api.v1 import auth, chat, connections, history, models, user_config

apps/api/app/api/v1/auth.py

@@ -1,17 +1,18 @@
 """认证 API"""
+
 from uuid import UUID
 
 from fastapi import APIRouter, Depends, HTTPException, status
 from sqlalchemy import select
 from sqlalchemy.ext.asyncio import AsyncSession
 
+from app.api.deps import get_current_user
 from app.core import create_access_token, create_refresh_token, get_password_hash, verify_password
 from app.core.config import settings
 from app.core.demo_db import get_demo_db_path
 from app.db import get_db
 from app.db.tables import Connection, User
 from app.models import APIResponse, Token, UserCreate, UserLogin, UserResponse
-from app.api.deps import get_current_user
 
 router = APIRouter()
 

apps/api/app/api/v1/chat.py

@@ -1,12 +1,13 @@
 """聊天 API"""
+
 import asyncio
-from typing import AsyncGenerator
-from uuid import UUID, uuid4
+from collections.abc import AsyncGenerator
+from uuid import UUID
 
 from fastapi import APIRouter, Depends, HTTPException, Query, status
 from sqlalchemy import select
-from sse_starlette.sse import EventSourceResponse
 from sqlalchemy.ext.asyncio import AsyncSession
+from sse_starlette.sse import EventSourceResponse
 
 from app.api.deps import get_current_user
 from app.core import decode_token

apps/api/app/api/v1/connections.py

@@ -1,4 +1,5 @@
 """数据库连接管理 API"""
+
 from uuid import UUID
 
 from fastapi import APIRouter, Depends, HTTPException, status
@@ -40,9 +41,7 @@ async def create_connection(
     # 如果设为默认，取消其他默认
     if conn_in.is_default:
         result = await db.execute(
-            select(Connection).where(
-                Connection.user_id == current_user.id, Connection.is_default == True
-            )
+            select(Connection).where(Connection.user_id == current_user.id, Connection.is_default)
         )
         for c in result.scalars():
             c.is_default = False
@@ -137,9 +136,7 @@ async def update_connection(
     # 如果设为默认，取消其他默认
     if conn_in.is_default and not connection.is_default:
         other_result = await db.execute(
-            select(Connection).where(
-                Connection.user_id == current_user.id, Connection.is_default == True
-            )
+            select(Connection).where(Connection.user_id == current_user.id, Connection.is_default)
         )
         for c in other_result.scalars():
             c.is_default = False

apps/api/app/api/v1/history.py

@@ -1,4 +1,5 @@
 """历史记录 API"""
+
 from uuid import UUID
 
 from fastapi import APIRouter, Depends, HTTPException, Query, status
@@ -40,7 +41,7 @@ async def list_conversations(
     )
 
     if favorites:
-        query = query.where(Conversation.is_favorite == True)
+        query = query.where(Conversation.is_favorite)
 
     if q:
         query = query.where(Conversation.title.ilike(f"%{q}%"))

apps/api/app/api/v1/models.py

@@ -1,4 +1,5 @@
 """模型配置管理 API"""
+
 import time
 from uuid import UUID
 
@@ -38,12 +39,9 @@ async def create_model(
     """添加模型配置"""
     # 如果设为默认，取消其他默认
     if model_in.is_default:
-        await db.execute(
-            select(Model)
-            .where(Model.user_id == current_user.id, Model.is_default == True)
-        )
+        await db.execute(select(Model).where(Model.user_id == current_user.id, Model.is_default))
         result = await db.execute(
-            select(Model).where(Model.user_id == current_user.id, Model.is_default == True)
+            select(Model).where(Model.user_id == current_user.id, Model.is_default)
         )
         for m in result.scalars():
             m.is_default = False
@@ -89,7 +87,7 @@ async def update_model(
     # 如果设为默认，取消其他默认
     if model_in.is_default and not model.is_default:
         other_result = await db.execute(
-            select(Model).where(Model.user_id == current_user.id, Model.is_default == True)
+            select(Model).where(Model.user_id == current_user.id, Model.is_default)
         )
         for m in other_result.scalars():
             m.is_default = False

apps/api/app/api/v1/user_config.py

@@ -1,4 +1,5 @@
 """用户配置 API"""
+
 from fastapi import APIRouter, Depends
 from sqlalchemy.ext.asyncio import AsyncSession