chenxin
c63b75152a
- 天工阁域 domains/tiangong：backstage_tasks（委托包+验收标准+结果证据）；有限分解（parent 链）与受控并行（各自后台 Run）；子任务全终态级联父任务进入待验收；按证据 accept/reject - kernel.start_backstage_run（kind=background_task）：loop 后台分支不占前台席位、与前台对话并行；断言放宽容纳无人物功能任务；结果只经回调回呈任务——无身份写入路径 - 叩心域 domains/kouxin：knocking_candidates（event/time_anchor/manual 触发 + 草稿 + 裁决快照）；四约束裁决（总开关→静默窗口【本地时区判定】→24h 频率→预算），dispatch 未过 429 且快照留痕；候选默认不自动发送；expire_stale 过期推进不触碰缘契 - 辰正 domains/zhengchen：temporal_context() 复用 time_sense 计算核（快照/农历/季节），产出【时态感知】投影段接入镜树生成 prompt（客观时间语境，不附情绪臆测——守一纪律） - 退役：modules/goal_orchestrator|planner|perception|big_cycle、application/planning、services/governance|goal_persist、candidates 表链（imports 候选抽取 API 面）、goals/plans/agent_roster/perception_channels/big_cycles/旧候选表（迁移 009）；前端 admin goals/plans/agents/perception/world 页与六组件；governance 只留 GenerationPreferences；admin 治理面收敛为司命+百工两枢；pivots 健康以域表计数重建 - 验收（test_m8_tiangong 五用例）：后台任务无身份写入（记忆/魂籍/缘契零新增）；后台与前台并行；分解级联；叩心四约束逐项；不回应不降低关系（缘契维度/状态/版本零变化） - 四套件：后端 345、前端 203、BFF 4、神识 5 包全绿（2 个预存环境失败不变）；迁移 009 净库干净
69 lines
2.1 KiB
Python
69 lines
2.1 KiB
Python
"""天工阁 API：受托任务（分解/派发/验收）。"""
|
|
|
|
from fastapi import APIRouter, Depends, Request
|
|
from pydantic import BaseModel, Field
|
|
|
|
from app.api.v1.deps import get_current_user
|
|
from app.domains.tiangong import service
|
|
from app.schemas.auth import CurrentUser
|
|
|
|
task_router = APIRouter(prefix="/tasks", tags=["tiangong"])
|
|
|
|
|
|
class TaskCreateRequest(BaseModel):
|
|
character_id: str | None = None
|
|
title: str = Field(min_length=1, max_length=200)
|
|
brief: str = ""
|
|
acceptance_criteria: str = ""
|
|
parent_task_id: str | None = None
|
|
|
|
|
|
class DecomposeRequest(BaseModel):
|
|
subtasks: list[dict]
|
|
|
|
|
|
class AcceptRequest(BaseModel):
|
|
accepted: bool
|
|
|
|
|
|
@task_router.post("", status_code=201)
|
|
async def create_task_api(
|
|
payload: TaskCreateRequest, user: CurrentUser = Depends(get_current_user)
|
|
) -> dict:
|
|
return await service.create_task(
|
|
owner_scope=user.owner_scope,
|
|
character_id=payload.character_id,
|
|
title=payload.title,
|
|
brief=payload.brief,
|
|
acceptance_criteria=payload.acceptance_criteria,
|
|
parent_task_id=payload.parent_task_id,
|
|
)
|
|
|
|
|
|
@task_router.get("")
|
|
async def list_tasks_api(
|
|
user: CurrentUser = Depends(get_current_user), parent: str | None = "root"
|
|
) -> list[dict]:
|
|
return await service.list_tasks(user.owner_scope, parent=None if parent == "all" else parent)
|
|
|
|
|
|
@task_router.post("/{task_id}/decompose", status_code=201)
|
|
async def decompose_api(
|
|
task_id: str, payload: DecomposeRequest, user: CurrentUser = Depends(get_current_user)
|
|
) -> list[dict]:
|
|
return await service.decompose(task_id, user.owner_scope, payload.subtasks)
|
|
|
|
|
|
@task_router.post("/{task_id}/dispatch")
|
|
async def dispatch_api(
|
|
task_id: str, request: Request, user: CurrentUser = Depends(get_current_user)
|
|
) -> dict:
|
|
return await service.dispatch(task_id, user.owner_scope, request.app.state)
|
|
|
|
|
|
@task_router.post("/{task_id}/accept")
|
|
async def accept_api(
|
|
task_id: str, payload: AcceptRequest, user: CurrentUser = Depends(get_current_user)
|
|
) -> dict:
|
|
return await service.accept(task_id, user.owner_scope, accepted=payload.accepted)
|