' +
- __("排队（无级别）", "queued (no level)") + "" +
+ h += '
' +
+ __("排队", "queued") + "" +
'' +
'' + ready + " · FIFO
";
@@ -1115,7 +1150,7 @@
put("levels", h);
// ---- 段 4：中断栈 ----
- h = '
' + __("中断栈", "Interrupt stack") + "
";
+ h = '
' + __("栈", "Stack") + "
";
// 深度先给一条进度条（"压了几层 / 上限几层"一眼可读），下面再列具体帧。
h += rtSlider(stack, maxStack, __("深度", "depth"), stack + " / " + maxStack);
if (frames.length) {
@@ -3487,6 +3522,21 @@
console.log("[SSE] stage event", phase, tool);
// 驱动总览页的"阶段管道"滑块：滑到当前阶段；一轮跑完（或 2.5s 无新
// 事件）自动回到空闲，避免留下一个永远停在 after_output 的假状态。
+ // 阶段轨迹：本轮真实发生过什么，交给阶段管道画成 chip 序列。
+ // 工具调用会反复出现（多轮 toolcall），output_* 单独配色。
+ if (phase === "on_input") {
+ state.stageTrail = [{ kind: "stage", label: __("输入", "input"), short: __("输入", "input") }];
+ } else if (phase === "before_toolcall" && tool) {
+ state.stageTrail.push({
+ kind: tool.indexOf("output_") === 0 ? "output" : "tool",
+ label: tool,
+ short: rtShortTool(tool),
+ });
+ if (state.stageTrail.length > 24) state.stageTrail.shift();
+ } else if (phase === "after_output") {
+ state.stageTrail.push({ kind: "stage", label: __("完成", "done"), short: __("完成", "done") });
+ if (state.stageTrail.length > 24) state.stageTrail.shift();
+ }
state.pipelinePhase = phase;
if (state.pipelineTimer) clearTimeout(state.pipelineTimer);
state.pipelineTimer = setTimeout(function () {
diff --git a/third_party/homeagent-sdk/example/qq/plugin.go b/third_party/homeagent-sdk/example/qq/plugin.go
index 5168d76..d7b5ca0 100644
--- a/third_party/homeagent-sdk/example/qq/plugin.go
+++ b/third_party/homeagent-sdk/example/qq/plugin.go
@@ -165,7 +165,7 @@ type Plugin struct {
batchMax time.Duration // 一批最长等多久（防持续刷屏时永远不投）
// injectHook 仅供测试：非 nil 时 injectInterrupt 走它而不是真实 SDK。
- injectHook func(text string)
+ injectHook func(text, level string)
}
// pendingBatch 是一批待投递的消息（同一会话、同一发送者、短时间内的连续消息）。
@@ -1356,7 +1356,7 @@ func (p *Plugin) enqueueInterrupt(msgType string, userID, groupID, messageID int
return
}
if p.batchWindow <= 0 {
- p.injectInterrupt(single)
+ p.injectInterrupt(single, p.interruptLevel(owner))
return
}
key := qqBatchKey(msgType, groupID, userID)
@@ -1392,14 +1392,32 @@ func (p *Plugin) enqueueInterrupt(msgType string, userID, groupID, messageID int
p.batchMu.Unlock()
}
-// injectInterrupt 投递一条中断提示（NoMemory：HTTP 侧来的不是对话内容；
-// Priority L1：QQ 消息是低级别中断，既非实时工作也非紧急工作，完全可等）。
-func (p *Plugin) injectInterrupt(text string) {
+// interruptLevel 决定一条 QQ 消息的中断级别。
+//
+// - Bot 所有者/管理员的消息 → **L2**（一般提醒）；
+// - 其他人的消息 → L1（后台，完全可等）。
+//
+// 为什么不能一律 L1：L1 之间可以随时互相抢占、也可以被任何更高一级打断，
+// 于是「老板发的话」会被路人的闲聊挤到后面，甚至对方持续刷屏时一直排在队尾。
+// 为什么也不该给 L3：L3 是时钟/终端那类"需要及时处理"的实时工作，QQ 是异步
+// 消息，抬到 L3 会反过来打断真正实时的事情。
+func (p *Plugin) interruptLevel(owner bool) string {
+ if owner {
+ return sdk.PriorityL2
+ }
+ return sdk.PriorityL1
+}
+
+// injectInterrupt 投递一条中断提示（NoMemory：HTTP 侧来的不是对话内容）。
+func (p *Plugin) injectInterrupt(text, level string) {
if text == "" {
return
}
+ if level == "" {
+ level = sdk.PriorityL1
+ }
if p.injectHook != nil {
- p.injectHook(text)
+ p.injectHook(text, level)
return
}
if p.sdk == nil {
@@ -1407,7 +1425,7 @@ func (p *Plugin) injectInterrupt(text string) {
}
p.sdk.InjectInterruptTextOpts(p.name, p.name, text, sdk.InjectOptions{
NoMemory: true,
- Priority: sdk.PriorityL1,
+ Priority: level,
})
}
@@ -1424,7 +1442,8 @@ func (p *Plugin) flushBatch(key string) {
if len(b.msgIDs) > 1 {
text = p.buildBatchInterrupt(b)
}
- p.injectInterrupt(text)
+ // 一批里只要有一条来自 Bot 所有者，整批按 L2 投递（不因混入路人消息而降低）。
+ p.injectInterrupt(text, p.interruptLevel(b.owner))
}
// flushAllBatches 停机前把未到点的批次立刻投出去（best effort）。
diff --git a/third_party/homeagent-sdk/example/qq/plugin_test.go b/third_party/homeagent-sdk/example/qq/plugin_test.go
index 04828b1..205214e 100644
--- a/third_party/homeagent-sdk/example/qq/plugin_test.go
+++ b/third_party/homeagent-sdk/example/qq/plugin_test.go
@@ -242,7 +242,7 @@ func TestDowngradedAuthStillAllowsQQOutput(t *testing.T) {
// collectInterrupts 用注入钩子收集中断文本（避免测试依赖真实 SDK）。
func collectInterrupts(p *Plugin) *[]string {
got := []string{}
- p.injectHook = func(s string) { got = append(got, s) }
+ p.injectHook = func(s, _ string) { got = append(got, s) }
return &got
}
@@ -312,3 +312,25 @@ func TestSingleMessageKeepsOriginalText(t *testing.T) {
t.Fatalf("单条消息应沿用原文（含所有者前缀），实际 %#v", *got)
}
}
+
+// Bot 所有者/管理员的消息给 L2，普通人的给 L1 —— 否则所有者的话会被路人
+// 的 L1 闲聊抢占/挤到队尾。
+func TestOwnerMessagesGetHigherInterruptLevel(t *testing.T) {
+ p := newPermissionTestPlugin(t)
+ got := []string{}
+ p.injectHook = func(text, level string) { got = append(got, text+"|"+level) }
+ p.batchWindow = 20 * time.Millisecond
+ p.batchMax = time.Second
+
+ p.enqueueInterrupt("private", 1, 0, 1, "owner", "owner-msg", true, false)
+ p.enqueueInterrupt("private", 2, 0, 2, "someone", "other-msg", false, false)
+ time.Sleep(120 * time.Millisecond)
+
+ joined := strings.Join(got, ",")
+ if !strings.Contains(joined, "owner-msg|L2") {
+ t.Fatalf("所有者消息应为 L2，实际 %q", joined)
+ }
+ if !strings.Contains(joined, "other-msg|L1") {
+ t.Fatalf("普通人消息应为 L1，实际 %q", joined)
+ }
+}