六个活动的汇报界面与技能补齐;skill-engine 接上装配面

汇报界面(AM 07): · 视图外壳与卡片件提到 `@sdk`(viewShell / kvCard / tableCard / stagesCard / noteCard)—— 六个活动共用一套面貌,不各自发明;样式内联自带(沙箱页面不继承工作台 CSS)。 · flow 四活动按**步序位置**挂模版: A1 事态全景 / 打标判据 / 成果预览;A4 取价基准 / 定价与门禁 / 草案待放行; A6 正式报价单 / 放行即发出;A7 结果登记 / 闭环待放行。 · loop 两活动按**阶段与里程碑**组织:案例全景一屏,画阶段生命周期态、当下可为、目标缺口 —— 素材全部来自语义引擎,零 LLM 即可成屏;模型只决定下一步做什么,不负责画面。为此给 loop-engine 补了视图端口,与 flow 共用同一个网关。 · 每张模版都把「这一屏在说什么 / 放行意味着什么」写在数据旁边 —— 人要在数据上作判断,判据就得摆在手边。技能(AM 08): · 六个活动各写了 1–2 条真技能:适用描述 + 方法正文 + 结晶片段脚本。正文写的是**方法经验**而非流程复述(如「原文没写的不要补」「该等还是该问」「无基准不是异常,是一种基准」)。 · 资源声明放**技能 ID**(权力面),资产放**定义本体**(方法面),两处分清。 · **skill-engine 从来没有被构造过** —— 模块实现完整却无人调用,这是它一直没被用上的原因。容器里补上:目录与白名单都取自活动清单,装配前查扩权。 · loop 的叙事面接入**技能目录**(渐进披露:常驻上下文只给「有哪些方法、何时适用」, 正文等 AI 说要才加载),装配随即**盖戳入任务记忆** —— 回放与归因依赖之。 gates: tsc / eslint / depcruise(334 模块)/ 423 测试全绿 Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com> Claude-Session: https://claude.ai/code/session_01KeDBx2PHLavbURXB8LJJ7m
2026-07-27 10:59:13 +08:00
parent ac2fecd005
commit 374206b408
24 changed files with 848 additions and 187 deletions
@@ -47,6 +47,7 @@ import { createCardStore, createHumanToolService } from '@modules/human-tool';
 import type { InteractionService } from '@modules/interaction';
 import { createInteractionService, createInteractionStore, templateIsSafe } from '@modules/interaction';
 import type { ActivityRegistryService } from '@modules/activity-registry';
+import { createSkillEngineService } from '@modules/skill-engine';
 import { createRegistryService, createRegistryStore } from '@modules/activity-registry';
 import type { ReleaseService } from '@modules/release';
 import { createIntentStore, createReleaseService } from '@modules/release';
@@ -364,6 +365,30 @@ export async function createContainer(config: AppConfig): Promise<Container> {
    sdkVersion: '0.1.0-m5',
  });

+  /*
+   * skill-engine(L4)—— 技能是活动内部的构件格式,由两个范式引擎装配。
+   * 目录与白名单都取自**活动清单**:技能提及的工具不在本活动白名单者不可调,
+   * 装配前查扩权 —— 载方法,不载权力(AM 08)。
+   */
+  const skills = createSkillEngineService({
+    catalog: {
+      skillsOf: async (activityId) => [...(await registry.manifestOf(activityId)).assets.skills],
+      allowlistOf: async (activityId) =>
+        (await registry.manifestOf(activityId)).declarations.tools.map((t) => t.name),
+    },
+    tools: {
+      invoke: (input) => toolInvoker.invoke(input),
+    },
+    memory: {
+      append: async (input) =>
+        void (await memory.append({
+          ...input,
+          stamp: { contractVersion: '1', businessModelVersion: '1', skillVersions: [] },
+        })),
+    },
+    clock: systemClock,
+  });
+
  const release = createReleaseService({
    intents: createIntentStore(db),
    ledger: {
@@ -489,6 +514,7 @@ export async function createContainer(config: AppConfig): Promise<Container> {
    modelGateway,
    registry,
    release,
+    skills,
    schemas,
  });

@@ -16,6 +16,7 @@ import type { MessageService } from '@modules/message';
 import type { OrgService } from '@modules/org';
 import type { LlmService, ModelGateway } from '@modules/llm';
 import type { ActivityRegistryService } from '@modules/activity-registry';
+import type { SkillEngineService } from '@modules/skill-engine';
 import type { ReleaseService } from '@modules/release';

 import { createFlowRunner, createFlowStateStore } from '@modules/flow-engine';
@@ -49,6 +50,7 @@ export type EngineWiringDeps = {
  readonly llm: LlmService;
  readonly modelGateway: ModelGateway;
  readonly registry: ActivityRegistryService;
+  readonly skills: SkillEngineService;
  readonly release: ReleaseService;
  readonly schemas: { validate(schema: Record<string, unknown>, value: unknown): { ok: boolean; errors: string[] } };
 };
@@ -115,6 +117,42 @@ export function wireEngines(deps: EngineWiringDeps): EngineWiring {
    },
  };

+  /*
+   * 视图流控网关 —— 两个范式共用一份。
+   * 按名取模版 → 填数 → 推给前端。模版取自**该任务装载时的资产版本**(经 registry),
+   * 不是「当前最新」:在途任务按其启动时版本跑完,呈现也该跟着那一版。
+   */
+  const viewGateway = {
+    async push({
+      taskId,
+      activityId,
+      template,
+      scope,
+    }: {
+      taskId: TaskId;
+      activityId: string;
+      template: string;
+      scope: Record<string, unknown>;
+    }): Promise<void> {
+      const manifest = await deps.registry.manifestOf(activityId);
+      const found = manifest.assets.viewTemplates.find((t) => t.name === template);
+      if (found === undefined) return;
+
+      /*
+       * 视图作用域 = 任务视图 + **本单自己写下的行**。
+       * 两者要分得开:任务视图里的 `域.对象` 是正式版 + 我的草稿的合并结果,
+       * 拿它画「本单交付」会把别单放行过的记录一并列出来。
+       * 本单的行放在 `mine:域.对象` 下 —— 整键,取值不歧义。
+       */
+      const own: Record<string, unknown[]> = {};
+      for (const draft of await deps.ledger.taskDrafts(taskId)) {
+        const key = `mine:${draft.domain}.${draft.object}`;
+        (own[key] ??= []).push({ ...draft.key, ...draft.patch });
+      }
+      await deps.interaction.pushViewHtml(taskId, renderView(found.html, { ...scope, ...own }));
+    },
+  };
+
  /* ── 任务数据:引擎读**任务视图** = 正式版 + 本任务草稿层 ───────── */
  const taskData = {
    /**
@@ -286,31 +324,7 @@ export function wireEngines(deps: EngineWiringDeps): EngineWiring {
    data: taskData,
    tools: { ...toolGateway, invoke: (i) => toolGateway.invoke(i) },
    schemas: deps.schemas,
-    views: {
-      /*
-       * 按名取模版 → 填数 → 推给前端。
-       * 模版取自**该任务装载时的资产版本**(经 registry),不是「当前最新」——
-       * 在途任务按其启动时版本跑完,呈现也该跟着那一版。
-       */
-      async push({ taskId, activityId, template, scope }) {
-        const manifest = await deps.registry.manifestOf(activityId);
-        const found = manifest.assets.viewTemplates.find((t) => t.name === template);
-        if (found === undefined) return;
-
-        /*
-         * 视图作用域 = 任务视图 + **本单自己写下的行**。
-         * 两者要分得开:任务视图里的 `域.对象` 是正式版 + 我的草稿的合并结果,
-         * 拿它画「本单交付」会把别单放行过的记录一并列出来。
-         * 本单的行放在 `mine:域.对象` 下 —— 整键,取值不歧义。
-         */
-        const own: Record<string, unknown[]> = {};
-        for (const draft of await deps.ledger.taskDrafts(taskId)) {
-          const key = `mine:${draft.domain}.${draft.object}`;
-          (own[key] ??= []).push({ ...draft.key, ...draft.patch });
-        }
-        await deps.interaction.pushViewHtml(taskId, renderView(found.html, { ...scope, ...own }));
-      },
-    },
+    views: viewGateway,
    llm: {
      async generate(input) {
        // LLM 在 flow 里只以「被调用的工具」出现,不是调度者
@@ -357,6 +371,11 @@ export function wireEngines(deps: EngineWiringDeps): EngineWiring {
    tools: toolGateway,
    cards,
    listeners,
+    views: viewGateway,
+    skills: {
+      index: (activityId) => deps.skills.index(activityId),
+      stamp: (activityId, ids) => deps.skills.stamp(activityId, ids),
+    },
    memory: {
      append: memoryRecorder.append as never,
      loadActivityMemory: async (activityId: string, limit: number) =>
@@ -14,6 +14,8 @@ import type {
  ListenerRegistrar,
  LoopStateStore,
  MemoryRecorder,
+  SkillGateway,
+  ViewGateway,
  Sfeel,
  TaskContext,
  TaskDataGateway,
@@ -41,6 +43,8 @@ export type TurnRunnerDeps = {
  readonly cards: CardGateway;
  readonly listeners: ListenerRegistrar;
  readonly memory: MemoryRecorder;
+  readonly views: ViewGateway;
+  readonly skills: SkillGateway;
  readonly tasks: TaskContext;
  readonly clock: Clock;
 };
@@ -232,12 +236,35 @@ export function createTurnRunner(deps: TurnRunnerDeps): LoopEngineService {
        });
      }

+      const activityId = (await deps.tasks.of(taskId)).activityId;
+      const catalog = await deps.skills.index(activityId);
+
+      /*
+       * 叙事面 = 案例说明书 + 活动记忆选摘 + **技能目录**。
+       * 渐进披露(AM 08):常驻上下文只给「有哪些方法、何时适用」,
+       * 正文与知识引用等 AI 说要才加载 —— 一次把所有正文塞进去,
+       * 上下文会被方法论淹掉,真正的局面反而看不见。
+       */
      const narrative = [
        model.narrative,
-        ...(await deps.memory.loadActivityMemory((await deps.tasks.of(taskId)).activityId, 20)).map(
-          (m) => `[${m.layer}] ${m.statement}`,
-        ),
-      ].join('\n\n');
+        ...(await deps.memory.loadActivityMemory(activityId, 20)).map((m) => `[${m.layer}] ${m.statement}`),
+        catalog.length === 0
+          ? ''
+          : `【可装配的技能(目录)】\n${catalog.map((s) => `- ${s.id} ${s.label}:${s.applicability}`).join('\n')}`,
+      ]
+        .filter((line) => line !== '')
+        .join('\n\n');
+
+      // 装配入信封:这一回合手上有哪些技能及其版本,记进任务记忆 —— 回放与归因依赖之
+      if (catalog.length > 0) {
+        const stamp = await deps.skills.stamp(activityId, catalog.map((s) => s.id));
+        await deps.memory.append({
+          taskId,
+          kind: 'thought',
+          title: `装配技能:${stamp.map((s) => `${s.id}@${s.version}`).join('、')}`,
+          detail: { skills: [...stamp] },
+        });
+      }

      const action = await deps.agent.decide({ taskId, narrative, enabled, scope });

@@ -250,6 +277,31 @@ export function createTurnRunner(deps: TurnRunnerDeps): LoopEngineService {
      const applied = await applyAction(taskId, action, runtime);
      await deps.state.save(taskId, model, parsed, applied.runtime);

+      /*
+       * 每回合推一次案例全景 —— 呈现是投影,失败只丢这一帧,不影响回路推进。
+       * 画面的素材全部来自语义引擎(阶段态 / 当下可为 / 缺口),零 LLM。
+       */
+      try {
+        await deps.views.push({
+          taskId,
+          activityId: (await deps.tasks.of(taskId)).activityId,
+          template: 'case-overview',
+          scope: {
+            ...scope,
+            'case:stages': parsed.items
+              .filter((i) => i.type === 'stage')
+              .map((i) => ({ name: i.name, state: applied.runtime.items.find((r) => r.id === i.id)?.state ?? '—' })),
+            'case:enabled': enabled.entries.map((e) => ({ name: e.name, state: e.requiresManualStart ? '待启动' : '可进行' })),
+            'case:gaps': enabled.gaps.map((g) => ({ name: g, state: '未满足' })),
+            gapCount: enabled.gaps.length,
+            enabledCount: enabled.entries.length,
+            activeStage: enabled.activeStages.join('、') || '—',
+          },
+        });
+      } catch {
+        // 呈现失败不影响回路:画面丢一帧,事实一件不少
+      }
+
      return {
        runtime: applied.runtime,
        enabled,
@@ -77,6 +77,32 @@ export type ListenerRegistrar = {
  }): Promise<{ id: string }>;
 };

+/**
+ * 视图流控 —— app 注入 `interaction`(L3)。
+ * 「loop:AI 按定位与局面临场组织视图流」(AM 07)。MVP 每回合推一次**案例全景**:
+ * 阶段与计划项的生命周期态、当下可为、目标缺口 —— 这些是语义引擎算出来的确定事实,
+ * 零 LLM 即可成屏;模型只决定「下一步做什么」,不负责画面。
+ */
+export type ViewGateway = {
+  push(input: {
+    taskId: TaskId;
+    activityId: string;
+    template: string;
+    scope: Record<string, unknown>;
+  }): Promise<void>;
+};
+
+/**
+ * 技能 —— app 注入 `skill-engine`(L4)。
+ * 「渐进披露:常驻上下文**仅有技能目录**,按事加载正文、按需下钻引用」(AM 08)。
+ */
+export type SkillGateway = {
+  /** 目录:id + 何时适用 —— 只给这些,正文等 AI 说要才加载 */
+  index(activityId: string): Promise<ReadonlyArray<{ id: string; label: string; applicability: string }>>;
+  /** 装配入信封:这一回合装配了哪些技能及其版本,记入任务记忆 */
+  stamp(activityId: string, skillIds: readonly string[]): Promise<ReadonlyArray<{ id: string; version: string }>>;
+};
+
 export type MemoryRecorder = {
  append(input: {
    taskId: TaskId;