diff --git a/internal/coordinator/engine.go b/internal/coordinator/engine.go index b2a14b94..43c4972c 100644 --- a/internal/coordinator/engine.go +++ b/internal/coordinator/engine.go @@ -7,8 +7,8 @@ import ( "chat-agent-system/internal/agent" "chat-agent-system/internal/app/stageflow" + "chat-agent-system/internal/contracts/vocabulary" "chat-agent-system/internal/ctxmgr" - "chat-agent-system/internal/docgov" "chat-agent-system/internal/intent" "chat-agent-system/internal/kb" "chat-agent-system/internal/projectinstance" @@ -33,7 +33,7 @@ type PendingAction struct { WorkDir string Reason string Comment string - Rollback docgov.DocumentState + Rollback vocabulary.DocumentState TaskKey string } diff --git a/internal/coordinator/engine_docgov.go b/internal/coordinator/engine_docgov.go index 9a9089fb..5a936ae1 100644 --- a/internal/coordinator/engine_docgov.go +++ b/internal/coordinator/engine_docgov.go @@ -1,12 +1,12 @@ package coordinator import ( + "chat-agent-system/internal/contracts/vocabulary" "context" "fmt" "strings" "time" - "chat-agent-system/internal/docgov" "chat-agent-system/internal/intent" ) @@ -323,9 +323,9 @@ func (e *CoordinatorEngine) handleDocGovProposalDecide(ctx context.Context, cand } userCtx.applyPending(nil) - rollback := docgov.StateDrafting + rollback := vocabulary.StateDrafting if userCtx.InteractiveCard != nil && strings.Contains(userCtx.InteractiveCard.ImpactRisk, "reviewing") { - rollback = docgov.StateDrafting + rollback = vocabulary.StateDrafting } return &CoordinationResult{ diff --git a/internal/coordinator/engine_task.go b/internal/coordinator/engine_task.go index e262dd23..41e9de0f 100644 --- a/internal/coordinator/engine_task.go +++ b/internal/coordinator/engine_task.go @@ -8,7 +8,7 @@ import ( "strings" "chat-agent-system/internal/app/stageflow" - "chat-agent-system/internal/docgov" + "chat-agent-system/internal/contracts/vocabulary" "chat-agent-system/internal/intent" "chat-agent-system/internal/stream" "chat-agent-system/internal/workflowscope" @@ -100,7 +100,7 @@ func (e *CoordinatorEngine) handleTriggerTask(ctx context.Context, cand *intent. UserID: userID, }) if err != nil { - if errors.Is(err, docgov.ErrDocumentBusy) { + if errors.Is(err, vocabulary.ErrDocumentBusy) { msg := "该文档正在由项目助手生成或他人编辑中,请稍后再发起更新。您可以先继续对话或处理其他文档。" if taskRes != nil && taskRes.ErrorReason != "" { msg = taskRes.ErrorReason + "。您可以先继续对话或处理其他文档。" @@ -114,7 +114,7 @@ func (e *CoordinatorEngine) handleTriggerTask(ctx context.Context, cand *intent. UpdatedContext: userCtx, }, nil } - if errors.Is(err, docgov.ErrDocumentLocked) { + if errors.Is(err, vocabulary.ErrDocumentLocked) { return &CoordinationResult{ Status: StatusRejected, Intent: cand.Intent,