From 7fc2eeaaa5d743c964806bbc768176733dcdc85c Mon Sep 17 00:00:00 2001
From: hrz <1710360675@qq.com>
Date: Sat, 13 Dec 2025 00:19:38 +0800
Subject: [PATCH] =?UTF-8?q?update:=E5=8F=91=E9=80=81=E8=AF=AD=E9=9F=B3?=
 =?UTF-8?q?=E6=B6=88=E6=81=AF=E6=97=B6=E6=89=93=E6=96=AD=E6=9C=BA=E5=99=A8?=
 =?UTF-8?q?=E4=BA=BA=E8=AF=B4=E8=AF=9D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../test/js/core/audio/recorder.js             | 18 ++++++++++++++++++
 1 file changed, 18 insertions(+)

diff --git a/main/xiaozhi-server/test/js/core/audio/recorder.js b/main/xiaozhi-server/test/js/core/audio/recorder.js
index 9f94f895..3fe785f0 100644
--- a/main/xiaozhi-server/test/js/core/audio/recorder.js
+++ b/main/xiaozhi-server/test/js/core/audio/recorder.js
@@ -240,6 +240,24 @@ export class AudioRecorder {
         if (this.isRecording) return false;
 
         try {
+            // 检查是否有WebSocketHandler实例
+            const { getWebSocketHandler } = await import('../network/websocket.js');
+            const wsHandler = getWebSocketHandler();
+
+            // 如果机器正在说话，发送打断消息
+            if (wsHandler && wsHandler.isRemoteSpeaking && wsHandler.currentSessionId) {
+                const abortMessage = {
+                    session_id: wsHandler.currentSessionId,
+                    type: 'abort',
+                    reason: 'wake_word_detected'
+                };
+
+                if (this.websocket && this.websocket.readyState === WebSocket.OPEN) {
+                    this.websocket.send(JSON.stringify(abortMessage));
+                    log('发送打断消息', 'info');
+                }
+            }
+
             if (!this.initEncoder()) {
                 log('无法启动录音: Opus编码器初始化失败', 'error');
                 return false;