From 74142a8a05270e5f5fa33f96c09a3b15ceb60927 Mon Sep 17 00:00:00 2001
From: ymq <ymq@opencomputing.net>
Date: Sat, 15 Aug 2026 19:15:34 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20v2=E9=93=BE=E8=B7=AF=E6=96=87=E4=BB=B6?=
 =?UTF-8?q?=E4=B8=8A=E4=BC=A0(cockpit=5Fchat=5Fv2.dspy=E6=8E=A5=E6=94=B6fi?=
 =?UTF-8?q?le=E6=8F=90=E5=8F=96=E6=96=87=E6=9C=AC=E6=B3=A8=E5=85=A5prompt)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 wwwroot/api/cockpit_chat_v2.dspy | 39 ++++++++++++++++++++++++++++++++
 1 file changed, 39 insertions(+)

diff --git a/wwwroot/api/cockpit_chat_v2.dspy b/wwwroot/api/cockpit_chat_v2.dspy
index 07b2f7c..a5cf997 100644
--- a/wwwroot/api/cockpit_chat_v2.dspy
+++ b/wwwroot/api/cockpit_chat_v2.dspy
@@ -2,6 +2,27 @@
 # 替代 cockpit_chat.dspy，使用 pipeline-core/pipeline-service v2 架构
 
 import aiohttp
+import os
+import re
+import zipfile
+from ahserver.filestorage import FileStorage
+
+
+def _extract_text(path, name):
+    """提取文件文本内容（docx/txt/md等），返回文本或空字符串。二进制/无法解析返回空。"""
+    ext = os.path.splitext(name)[1].lower()
+    try:
+        if ext in ('.txt', '.md', '.json', '.csv', '.py', '.log', '.yaml', '.yml', '.xml', '.html', '.ini'):
+            with open(path, 'r', encoding='utf-8', errors='ignore') as f:
+                return f.read()[:15000]
+        if ext == '.docx':
+            with zipfile.ZipFile(path) as z:
+                xml = z.read('word/document.xml').decode('utf-8', errors='ignore')
+                texts = re.findall(r'<w:t[^>]*>(.*?)</w:t>', xml)
+                return '\n'.join(texts)[:15000]
+    except Exception:
+        pass
+    return ''
 
 action = (params_kw or {}).get('action', 'send_message')
 msg = ''
@@ -37,6 +58,24 @@ if action == 'send_message':
     prompt = (params_kw or {}).get('prompt', '') or msg
     prompt = prompt.strip()
 
+    # 处理用户上传的文件（multipart file 字段 → web_path），提取文本作为中性上下文注入 prompt
+    file_ctx = ''
+    _fval = (params_kw or {}).get('file')
+    _fpaths = _fval if isinstance(_fval, list) else ([_fval] if _fval else [])
+    for _fp in _fpaths:
+        try:
+            _abs = FileStorage().realPath(_fp)
+            _name = os.path.basename(_abs)
+            _txt = _extract_text(_abs, _name)
+            if _txt:
+                file_ctx += f"【文件 {_name} 内容】\n{_txt}\n\n"
+            else:
+                file_ctx += f"【文件 {_name}】二进制文件，无法直接读取文本。\n\n"
+        except Exception:
+            pass
+    if file_ctx:
+        prompt = "用户本次上传了以下文件：\n\n" + file_ctx + "\n用户指令：" + prompt
+
     # ── 意图识别：停止类指令 ──
     stop_keywords = ['停止', '取消', '停下', '终止', '停', 'stop', 'cancel', 'abort']
     if any(kw == prompt.strip().lower() or kw in prompt.strip().lower() for kw in stop_keywords):