style: 架构整理

Author: gaozhe

…ons/2026-02-19-21_21_46-e4c103e92f02_.py …ons/2026-02-20-16_20_28-e517b6c7fdb0_.pybackend/alembic/versions/2026-02-19-21_21_46-e4c103e92f02_.py renamed to backend/alembic/versions/2026-02-20-16_20_28-e517b6c7fdb0_.py backend/alembic/versions/2026-02-19-21_21_46-e4c103e92f02_.py renamed to backend/alembic/versions/2026-02-20-16_20_28-e517b6c7fdb0_.py

@@ -1,8 +1,8 @@
 """empty message
 
-Revision ID: e4c103e92f02
+Revision ID: e517b6c7fdb0
 Revises:
-Create Date: 2026-02-19 21:21:46.368852
+Create Date: 2026-02-20 16:20:28.792710
 
 """
 
@@ -12,7 +12,7 @@
 from sqlalchemy.dialects import mysql, postgresql
 
 # revision identifiers, used by Alembic.
-revision = 'e4c103e92f02'
+revision = 'e517b6c7fdb0'
 down_revision = None
 branch_labels = None
 depends_on = None
@@ -32,6 +32,20 @@ def upgrade():
         comment='agent category',
     )
     op.create_index(op.f('ix_agent_category_id'), 'agent_category', ['id'], unique=True)
+    op.create_table(
+        'agent_chat',
+        sa.Column('thread_id', sa.String(length=64), nullable=False),
+        sa.Column('user_id', sa.String(length=64), nullable=False),
+        sa.Column('first_query', sa.Text(), nullable=True),
+        sa.Column('start_time', sa.DateTime(), nullable=False),
+        sa.Column('end_time', sa.DateTime(), nullable=True),
+        sa.Column('chat_title', sa.String(length=200), nullable=False),
+        sa.Column('title_generated', sa.Boolean(), nullable=False),
+        sa.Column('created_time', sa.DateTime(timezone=True), nullable=False, comment='创建时间'),
+        sa.Column('updated_time', sa.DateTime(timezone=True), nullable=True, comment='更新时间'),
+        sa.PrimaryKeyConstraint('thread_id'),
+    )
+    op.create_index(op.f('ix_agent_chat_user_id'), 'agent_chat', ['user_id'], unique=False)
     op.create_table(
         'agent_server',
         sa.Column('id', sa.BigInteger(), autoincrement=True, nullable=False, comment='主键 ID'),
@@ -459,6 +473,8 @@ def downgrade():
     op.drop_index(op.f('ix_agent_server_id'), table_name='agent_server')
     op.drop_index(op.f('ix_agent_server_category_id'), table_name='agent_server')
     op.drop_table('agent_server')
+    op.drop_index(op.f('ix_agent_chat_user_id'), table_name='agent_chat')
+    op.drop_table('agent_chat')
     op.drop_index(op.f('ix_agent_category_id'), table_name='agent_category')
     op.drop_table('agent_category')
     # ### end Alembic commands ###

backend/app/admin/api/router.py

@@ -1,14 +1,18 @@
+from app.admin.api.v1.agent import router as agent_router
 from app.admin.api.v1.auth import router as auth_router
 from app.admin.api.v1.log import router as log_router
 from app.admin.api.v1.mcp import router as mcp_router
 from app.admin.api.v1.oauth import router as oauth_router
+from app.admin.api.v1.skill import router as skill_router
 from app.admin.api.v1.sys import router as sys_router
 from core.conf import settings
 from fastapi import APIRouter
 
 v1 = APIRouter(prefix=settings.FASTAPI_API_V1_PATH + '/admin')
 v1.include_router(log_router)
 v1.include_router(mcp_router)
+v1.include_router(agent_router)
+v1.include_router(skill_router)
 v1.include_router(auth_router)
 v1.include_router(oauth_router)
 v1.include_router(sys_router)

backend/app/admin/api/v1/agent/__init__.py

@@ -0,0 +1,8 @@
+from app.admin.api.v1.agent.category import router as agent_category_router
+from app.admin.api.v1.agent.server import router as agent_server_router
+from fastapi import APIRouter
+
+router = APIRouter(prefix='/agent')
+
+router.include_router(agent_server_router, prefix='/servers', tags=['admin agent server'])
+router.include_router(agent_category_router, prefix='/categories', tags=['admin agent category'])

backend/app/admin/api/v1/agent/category.py

@@ -0,0 +1,32 @@
+from app.admin.schema.category import AddCategoryParam, CategoryDetail, GetAllCategoryParam
+from app.admin.service.admin_agent_category_service import agent_admin_category_service
+from common.pagination import DependsPagination, PageData, paging_data
+from common.response.response_schema import ResponseModel, ResponseSchemaModel, response_base
+from common.security.jwt import DependsJwtAuth
+from database.db import CurrentSession
+from fastapi import APIRouter, Request
+
+router = APIRouter()
+
+
+@router.post(
+    '/create',
+    summary='创建 agent 分类',
+    dependencies=[DependsJwtAuth],
+)
+async def add_agent_category(request: Request, obj: AddCategoryParam) -> ResponseModel:
+    await agent_admin_category_service.create(request=request, obj=obj)
+    return response_base.success()
+
+
+@router.post(
+    '/get',
+    summary='返回所有 agent 分类',
+    dependencies=[DependsPagination, DependsJwtAuth],
+)
+async def get_all_agent_category(
+    db: CurrentSession, obj: GetAllCategoryParam
+) -> ResponseSchemaModel[PageData[CategoryDetail]]:
+    result = await agent_admin_category_service.get_list(obj.is_recommend)
+    page_data = await paging_data(db, result)
+    return response_base.success(data=page_data)

backend/app/admin/api/v1/agent/server.py

@@ -0,0 +1,67 @@
+from typing import Annotated
+
+from app.admin.schema.agent import AdminAgentBaseDetail, AdminSearchAgentParam, GetAdminAgentDetail, UpdateAgentParam
+from app.admin.service.admin_agent_service import agent_admin_server_service
+from common.pagination import DependsPagination, PageData, paging_data
+from common.response.response_schema import ResponseModel, ResponseSchemaModel, response_base
+from common.security.jwt import DependsJwtAuth
+from database.db import CurrentSession, CurrentSessionTransaction
+from fastapi import APIRouter, Path
+
+router = APIRouter()
+
+
+@router.post(
+    '',
+    summary='返回所有 agent',
+    dependencies=[DependsPagination, DependsJwtAuth],
+)
+async def get_all_agent(
+    db: CurrentSession, obj: AdminSearchAgentParam
+) -> ResponseSchemaModel[PageData[AdminAgentBaseDetail]]:
+    agent_select = await agent_admin_server_service.get_all_select(**obj.model_dump())
+    page_data = await paging_data(db, agent_select)
+    return response_base.success(data=page_data)
+
+
+@router.get(
+    '/{agent_id}',
+    summary='查询 agent 详情',
+    dependencies=[DependsJwtAuth],
+)
+async def get_agent(
+    agent_id: Annotated[int, Path(description='agent_id')],
+) -> ResponseSchemaModel[GetAdminAgentDetail | None]:
+    result = await agent_admin_server_service.get_agent(agent_id)
+    return response_base.success(data=result)
+
+
+@router.put(
+    '/{agent_id}',
+    summary='更新 agent',
+    dependencies=[DependsJwtAuth],
+)
+async def put_agent(
+    db: CurrentSessionTransaction,
+    agent_id: Annotated[int, Path(description='agent_id')],
+    obj: UpdateAgentParam,
+) -> ResponseModel:
+    count = await agent_admin_server_service.update_agent(db=db, agent_id=agent_id, **obj.model_dump())
+    if count > 0:
+        return response_base.success()
+    return response_base.fail()
+
+
+@router.delete(
+    '/{agent_id}',
+    summary='删除 agent',
+    dependencies=[DependsJwtAuth],
+)
+async def delete_agent(
+    db: CurrentSessionTransaction,
+    agent_id: Annotated[int, Path(description='agent_id')],
+) -> ResponseModel:
+    count = await agent_admin_server_service.delete_agent(db=db, agent_id=agent_id)
+    if count > 0:
+        return response_base.success()
+    return response_base.fail()

backend/app/admin/api/v1/ops/__init__.py

@@ -0,0 +1,8 @@
+from app.admin.api.v1.skill.category import router as skill_category_router
+from app.admin.api.v1.skill.server import router as skill_server_router
+from fastapi import APIRouter
+
+router = APIRouter(prefix='/skill')
+
+router.include_router(skill_server_router, prefix='/servers', tags=['admin skill server'])
+router.include_router(skill_category_router, prefix='/categories', tags=['admin skill category'])