Upload 62 files

ai-routes.js

@@ -4,7 +4,19 @@ const router = express.Router();
 const OpenAI = require('openai');
 const { ConfigModel, User, AIUsageModel } = require('./models');
 
-// Fixed: Removed local database key pool and exclusively use process.env per guidelines
+// ... (Key Management, Usage Tracking, Helpers, Provider Management functions remain same as before)
+// Fetch keys from DB + merge with ENV variables
+async function getKeyPool(type) {
+    const config = await ConfigModel.findOne({ key: 'main' });
+    const pool = [];
+    if (config && config.apiKeys && config.apiKeys[type] && Array.isArray(config.apiKeys[type])) {
+        config.apiKeys[type].forEach(k => { if (k && k.trim()) pool.push(k.trim()); });
+    }
+    if (type === 'gemini' && process.env.API_KEY && !pool.includes(process.env.API_KEY)) pool.push(process.env.API_KEY);
+    if (type === 'openrouter' && process.env.OPENROUTER_API_KEY && !pool.includes(process.env.OPENROUTER_API_KEY)) pool.push(process.env.OPENROUTER_API_KEY);
+    return pool;
+}
+
 async function recordUsage(model, provider) {
     try {
         const today = new Date().toISOString().split('T')[0];
@@ -13,72 +25,48 @@ async function recordUsage(model, provider) {
     } catch (e) { console.error("Failed to record AI usage stats:", e); }
 }
 
-// Fallback Speech-to-Text using Hugging Face (Fixed 410 Error)
-async function transcribeAudioWithHF(audioBase64) {
-    // Fixed: Obtain HF token from environment variable directly
-    const token = process.env.HF_TOKEN;
-    if (!token) {
-        console.warn("[AI] No Hugging Face token found for fallback STT.");
-        return null;
-    }
-
-    try {
-        console.log("[AI] 🎤 Using Hugging Face ASR (Whisper v3)...");
-        const buffer = Buffer.from(audioBase64, 'base64');
-        
-        const response = await fetch(
-            "https://api-inference.huggingface.co/models/openai/whisper-large-v3",
-            {
-                headers: {
-                    Authorization: `Bearer ${token}`,
-                },
-                method: "POST",
-                body: buffer,
-            }
-        );
-
-        if (!response.ok) {
-            const errText = await response.text();
-            if (response.status === 503) {
-                console.log("[AI] HF Model loading, retrying...");
-                await new Promise(r => setTimeout(r, 3000));
-                return transcribeAudioWithHF(audioBase64);
-            }
-            throw new Error(`HF API Error: ${response.status} ${errText}`);
+const wait = (ms) => new Promise(resolve => setTimeout(resolve, ms));
+async function callAIWithRetry(aiModelCall, retries = 1) {
+    for (let i = 0; i < retries; i++) {
+        try { return await aiModelCall(); }
+        catch (e) {
+            if (e.status === 400 || e.status === 401 || e.status === 403) throw e;
+            if (i < retries - 1) { await wait(1000 * Math.pow(2, i)); continue; }
+            throw e;
         }
-
-        const result = await response.json();
-        console.log("[AI] HF Transcribed:", result.text);
-        return result.text;
-    } catch (e) {
-        console.error("[AI] HF STT Failed:", e.message);
-        return null;
     }
 }
 
 function convertGeminiToOpenAI(baseParams) {
     const messages = [];
     if (baseParams.config?.systemInstruction) messages.push({ role: 'system', content: baseParams.config.systemInstruction });
+    
+    // Normalize contents to array if it's a single object (Gemini allows shorthand, OpenAI/Middleware needs array)
     let contents = baseParams.contents;
-    if (contents && !Array.isArray(contents)) contents = [contents];
+    if (contents && !Array.isArray(contents)) {
+        contents = [contents];
+    }
 
     if (contents && Array.isArray(contents)) {
         contents.forEach(content => {
+            // Default to user role if not specified (common in short-hand calls)
             let role = (content.role === 'model' || content.role === 'assistant') ? 'assistant' : 'user';
+            
+            // Handle simple text shorthand if parts is missing but text exists (rare but possible in some SDK versions)
+            // But standard Gemini is { parts: [...] }
+            
             const messageContent = [];
             if (content.parts) {
                 content.parts.forEach(p => {
                     if (p.text) messageContent.push({ type: 'text', text: p.text });
-                    else if (p.inlineData) {
-                        if (p.inlineData.mimeType.startsWith('image/')) {
-                            messageContent.push({ type: 'image_url', image_url: { url: `data:${p.inlineData.mimeType};base64,${p.inlineData.data}` } });
-                        } else if (p.inlineData.mimeType.startsWith('audio/')) {
-                            messageContent.push({ type: 'audio_base64', data: p.inlineData.data });
-                        }
+                    else if (p.inlineData && p.inlineData.mimeType.startsWith('image/')) {
+                        messageContent.push({ type: 'image_url', image_url: { url: `data:${p.inlineData.mimeType};base64,${p.inlineData.data}` } });
                     }
                 });
             }
+            
             if (messageContent.length > 0) {
+                // If only one text part, send as string (cleaner for some weaker models)
                 if (messageContent.length === 1 && messageContent[0].type === 'text') {
                     messages.push({ role: role, content: messageContent[0].text });
                 } else {
@@ -93,11 +81,17 @@ function convertGeminiToOpenAI(baseParams) {
 const PROVIDERS = { GEMINI: 'GEMINI', OPENROUTER: 'OPENROUTER', GEMMA: 'GEMMA' };
 const DEFAULT_OPENROUTER_MODELS = ['qwen/qwen3-coder:free', 'openai/gpt-oss-120b:free', 'qwen/qwen3-235b-a22b:free', 'tngtech/deepseek-r1t-chimera:free'];
 
+// Runtime override logic
 let runtimeProviderOrder = [];
 
 function deprioritizeProvider(providerName) {
+    // If the provider is already last, do nothing
     if (runtimeProviderOrder.length > 0 && runtimeProviderOrder[runtimeProviderOrder.length - 1] === providerName) return;
+    
+    console.log(`[AI System] ⚠️ Deprioritizing ${providerName} due to errors. Moving to end of queue.`);
+    // Move to end
     runtimeProviderOrder = runtimeProviderOrder.filter(p => p !== providerName).concat(providerName);
+    console.log(`[AI System] 🔄 New Priority Order: ${runtimeProviderOrder.join(' -> ')}`);
 }
 
 function isQuotaError(e) {
@@ -105,121 +99,208 @@ function isQuotaError(e) {
     return e.status === 429 || e.status === 503 || msg.includes('quota') || msg.includes('overloaded') || msg.includes('resource_exhausted') || msg.includes('rate limit') || msg.includes('credits');
 }
 
+// Streaming Helpers
 async function streamGemini(baseParams, res) {
     const { GoogleGenAI } = await import("@google/genai");
-    // Fixed: Exclusively use process.env.API_KEY and gemini-3-flash-preview for text tasks
-    const apiKey = process.env.API_KEY;
-    if (!apiKey) throw new Error("API_KEY environment variable is not configured.");
+    const models = ['gemini-2.5-flash', 'gemini-2.5-flash-lite'];
+    const keys = await getKeyPool('gemini');
+    if (keys.length === 0) throw new Error("No Gemini API keys");
     
-    const modelName = 'gemini-3-flash-preview';
-    const client = new GoogleGenAI({ apiKey: process.env.API_KEY });
-    
-    try {
-        const result = await client.models.generateContentStream({ ...baseParams, model: modelName });
-        let hasStarted = false;
-        let fullText = "";
-        for await (const chunk of result) {
-            if (!hasStarted) { recordUsage(modelName, PROVIDERS.GEMINI); hasStarted = true; }
-            if (chunk.text) {
-                fullText += chunk.text;
-                res.write(`data: ${JSON.stringify({ text: chunk.text })}\n\n`);
+    for (const apiKey of keys) {
+        const client = new GoogleGenAI({ apiKey });
+        for (const modelName of models) {
+            try {
+                console.log(`[AI] 🚀 Attempting Gemini Model: ${modelName} (Key ends with ...${apiKey.slice(-4)})`);
+                const result = await client.models.generateContentStream({ ...baseParams, model: modelName });
+                
+                // First chunk check usually determines connection success
+                let hasStarted = false;
+                let fullText = "";
+                
+                for await (const chunk of result) {
+                    if (!hasStarted) {
+                        console.log(`[AI] ✅ Connected to Gemini: ${modelName}`);
+                        recordUsage(modelName, PROVIDERS.GEMINI);
+                        hasStarted = true;
+                    }
+                    if (chunk.text) {
+                        fullText += chunk.text;
+                        res.write(`data: ${JSON.stringify({ text: chunk.text })}\n\n`);
+                        if (res.flush) res.flush();
+                    }
+                }
+                return fullText;
+            } catch (e) {
+                console.warn(`[AI] ⚠️ Gemini ${modelName} Error: ${e.message}`);
+                if (isQuotaError(e)) {
+                    console.log(`[AI] 🔄 Quota exceeded for ${modelName}, trying next...`);
+                    continue; // Try next model or key
+                } 
+                throw e; // Non-quota errors bubble up to switch provider
             }
         }
-        return fullText;
-    } catch (e) {
-        throw e;
     }
+    throw new Error("Gemini streaming failed (All keys/models exhausted)");
 }
 
 async function streamOpenRouter(baseParams, res) {
     const config = await ConfigModel.findOne({ key: 'main' });
     const models = (config && config.openRouterModels?.length) ? config.openRouterModels.map(m => m.id) : DEFAULT_OPENROUTER_MODELS;
-    let messages = convertGeminiToOpenAI(baseParams);
-    // Use environment variable for OpenRouter key if available
-    const apiKey = process.env.OPENROUTER_API_KEY;
-    if (!apiKey) throw new Error("OPENROUTER_API_KEY environment variable is not configured.");
+    const messages = convertGeminiToOpenAI(baseParams);
+    const keys = await getKeyPool('openrouter');
+    if (keys.length === 0) throw new Error("No OpenRouter API keys");
     
-    for (let msg of messages) {
-        if (Array.isArray(msg.content)) {
-            for (let part of msg.content) {
-                if (part.type === 'audio_base64') {
-                    const text = await transcribeAudioWithHF(part.data);
+    if (messages.length === 0) {
+        throw new Error("Conversion resulted in empty messages array. Check input format.");
+    }
+
+    for (const apiKey of keys) {
+        for (const modelName of models) {
+            // Find specific model config to check for custom URL
+            const modelConfig = config?.openRouterModels?.find(m => m.id === modelName);
+            const baseURL = modelConfig?.apiUrl ? modelConfig.apiUrl : "https://openrouter.ai/api/v1";
+            const providerLabel = modelConfig?.apiUrl ? 'Custom API' : 'OpenRouter';
+            
+            const client = new OpenAI({ baseURL, apiKey, defaultHeaders: { "HTTP-Referer": "https://smart.com", "X-Title": "Smart School" } });
+            
+            try {
+                console.log(`[AI] 🚀 Attempting ${providerLabel} Model: ${modelName} (URL: ${baseURL})`);
+                // console.log(`[AI] Payload Messages:`, JSON.stringify(messages).substring(0, 200) + "..."); // Debug log
+                
+                const stream = await client.chat.completions.create({ model: modelName, messages, stream: true });
+                
+                console.log(`[AI] ✅ Connected to ${providerLabel}: ${modelName}`);
+                recordUsage(modelName, PROVIDERS.OPENROUTER);
+                
+                let fullText = '';
+                for await (const chunk of stream) {
+                    const text = chunk.choices[0]?.delta?.content || '';
                     if (text) {
-                        part.type = 'text';
-                        part.text = `[语音转文字]: ${text}`;
-                        delete part.data;
-                    } else {
-                        throw new Error("语音转文字失败 (请检查 HF_TOKEN)");
+                        fullText += text;
+                        res.write(`data: ${JSON.stringify({ text: text })}\n\n`);
+                        if (res.flush) res.flush();
                     }
                 }
-            }
-        }
-    }
-
-    for (const modelName of models) {
-        const modelConfig = config?.openRouterModels?.find(m => m.id === modelName);
-        const baseURL = modelConfig?.apiUrl ? modelConfig.apiUrl : "https://openrouter.ai/api/v1";
-        const client = new OpenAI({ baseURL, apiKey });
-        try {
-            const stream = await client.chat.completions.create({ model: modelName, messages, stream: true });
-            recordUsage(modelName, PROVIDERS.OPENROUTER);
-            let fullText = '';
-            for await (const chunk of stream) {
-                const text = chunk.choices[0]?.delta?.content || '';
-                if (text) {
-                    fullText += text;
-                    res.write(`data: ${JSON.stringify({ text: text })}\n\n`);
+                return fullText;
+            } catch (e) { 
+                console.warn(`[AI] ⚠️ ${providerLabel} ${modelName} Error: ${e.message}`);
+                if (isQuotaError(e)) {
+                    console.log(`[AI] 🔄 Rate limit/Quota for ${modelName}, switching...`);
+                    break; // Switch to next provider/model logic if implemented in loop, here break to next model in loop
                 }
+                // For OpenAI client, some errors might be specific
             }
-            return fullText;
-        } catch (e) { if (isQuotaError(e)) break; }
+        }
     }
-    throw new Error("OpenRouter exhausted or failed");
+    throw new Error("OpenRouter/Custom stream failed (All models exhausted)");
 }
 
 async function streamGemma(baseParams, res) {
     const { GoogleGenAI } = await import("@google/genai");
-    const apiKey = process.env.API_KEY;
-    if (!apiKey) throw new Error("API_KEY environment variable is not configured.");
-    
     const models = ['gemma-3-27b-it', 'gemma-3-12b-it'];
-    const client = new GoogleGenAI({ apiKey: process.env.API_KEY });
-    for (const modelName of models) {
-        try {
-            const result = await client.models.generateContentStream({ ...baseParams, model: modelName });
-            let hasStarted = false;
-            let fullText = "";
-            for await (const chunk of result) {
-                if (!hasStarted) { recordUsage(modelName, PROVIDERS.GEMMA); hasStarted = true; }
-                if (chunk.text) {
-                    fullText += chunk.text;
-                    res.write(`data: ${JSON.stringify({ text: chunk.text })}\n\n`);
+    const keys = await getKeyPool('gemini'); // Gemma uses Gemini keys
+    if (keys.length === 0) throw new Error("No keys for Gemma");
+    
+    for (const apiKey of keys) {
+        const client = new GoogleGenAI({ apiKey });
+        for (const modelName of models) {
+            try {
+                console.log(`[AI] 🚀 Attempting Gemma Model: ${modelName}`);
+                const result = await client.models.generateContentStream({ ...baseParams, model: modelName });
+                
+                let hasStarted = false;
+                let fullText = "";
+                for await (const chunk of result) {
+                    if (!hasStarted) {
+                        console.log(`[AI] ✅ Connected to Gemma: ${modelName}`);
+                        recordUsage(modelName, PROVIDERS.GEMMA);
+                        hasStarted = true;
+                    }
+                    if (chunk.text) {
+                        fullText += chunk.text;
+                        res.write(`data: ${JSON.stringify({ text: chunk.text })}\n\n`);
+                        if (res.flush) res.flush();
+                    }
                 }
+                return fullText;
+            } catch (e) { 
+                console.warn(`[AI] ⚠️ Gemma ${modelName} Error: ${e.message}`);
+                if (isQuotaError(e)) continue; 
             }
-            return fullText;
-        } catch (e) { if (isQuotaError(e)) continue; }
+        }
     }
-    throw new Error("Gemma failed");
+    throw new Error("Gemma stream failed");
 }
 
 async function streamContentWithSmartFallback(baseParams, res) {
+    let hasAudio = false;
+    
+    // Check if contents is array or object, handle accordingly
+    const contentsArray = Array.isArray(baseParams.contents) ? baseParams.contents : [baseParams.contents];
+    
+    contentsArray.forEach(c => {
+        if (c && c.parts) {
+            c.parts.forEach(p => { if (p.inlineData && p.inlineData.mimeType.startsWith('audio/')) hasAudio = true; });
+        }
+    });
+    
+    // Audio input currently forces Gemini
+    if (hasAudio) {
+        try { 
+            console.log(`[AI] 🎤 Audio detected, forcing Gemini provider.`);
+            return await streamGemini(baseParams, res); 
+        } catch(e) { 
+            console.error(`[AI] ❌ Audio Processing Failed: ${e.message}`);
+            deprioritizeProvider(PROVIDERS.GEMINI); 
+            throw new Error('QUOTA_EXCEEDED_AUDIO'); 
+        }
+    }
+    
+    // FETCH CONFIG AND SET PROVIDER ORDER
     const config = await ConfigModel.findOne({ key: 'main' });
-    const configuredOrder = config?.aiProviderOrder && config.aiProviderOrder.length > 0 ? config.aiProviderOrder : [PROVIDERS.GEMINI, PROVIDERS.OPENROUTER, PROVIDERS.GEMMA];
-    if (runtimeProviderOrder.length === 0) runtimeProviderOrder = [...configuredOrder];
+    const configuredOrder = config?.aiProviderOrder && config.aiProviderOrder.length > 0 
+        ? config.aiProviderOrder 
+        : [PROVIDERS.GEMINI, PROVIDERS.OPENROUTER, PROVIDERS.GEMMA];
+
+    // If runtime order is empty or contains different elements (e.g. config changed), reset it
+    const runtimeSet = new Set(runtimeProviderOrder);
+    const configSet = new Set(configuredOrder);
+    if (runtimeProviderOrder.length === 0 || runtimeProviderOrder.length !== configuredOrder.length || !configuredOrder.every(p => runtimeSet.has(p))) {
+        console.log(`[AI] 📋 Initializing Provider Order: ${configuredOrder.join(' -> ')}`);
+        runtimeProviderOrder = [...configuredOrder];
+    } else {
+        console.log(`[AI] 📋 Current Provider Priority: ${runtimeProviderOrder.join(' -> ')}`);
+    }
 
     let finalError = null;
+    
+    // Use runtimeProviderOrder which might have been adjusted due to quota errors in previous calls
     for (const provider of runtimeProviderOrder) {
         try {
+            console.log(`[AI] 👉 Trying Provider: ${provider}...`);
+            
             if (provider === PROVIDERS.GEMINI) return await streamGemini(baseParams, res);
             else if (provider === PROVIDERS.OPENROUTER) return await streamOpenRouter(baseParams, res);
             else if (provider === PROVIDERS.GEMMA) return await streamGemma(baseParams, res);
+            
         } catch (e) {
+            console.error(`[AI] ❌ Provider ${provider} Failed: ${e.message}`);
             finalError = e;
-            if (isQuotaError(e)) { deprioritizeProvider(provider); continue; }
+            
+            if (isQuotaError(e)) { 
+                console.log(`[AI] 📉 Quota/Rate Limit detected. Switching provider...`);
+                deprioritizeProvider(provider); 
+                continue; 
+            }
+            // If it's a hard error (e.g. network), we might also want to switch, 
+            // but strict quota error check usually suffices for fallback logic.
+            // For robustness, let's allow fallback on most errors in the loop:
             continue; 
         }
     }
-    throw finalError || new Error('All providers failed');
+    
+    console.error(`[AI] 💀 All providers failed.`);
+    throw finalError || new Error('All streaming models unavailable.');
 }
 
 const checkAIAccess = async (req, res, next) => {
@@ -234,11 +315,14 @@ const checkAIAccess = async (req, res, next) => {
     next();
 };
 
+// NEW: Endpoint to provide a temporary key for Client-Side Live API
 router.get('/live-access', checkAIAccess, async (req, res) => {
     try {
-        const key = process.env.API_KEY;
-        if (!key) return res.status(503).json({ error: 'No API key available in environment' });
-        res.json({ key });
+        const keys = await getKeyPool('gemini');
+        if (keys.length === 0) return res.status(503).json({ error: 'No API keys available' });
+        // Return the first available key. In a real prod environment, you might issue a short-lived proxy token.
+        // For this architecture, we return the key to allow direct WebSocket connection.
+        res.json({ key: keys[0] });
     } catch (e) { res.status(500).json({ error: e.message }); }
 });
 
@@ -260,7 +344,11 @@ router.get('/stats', checkAIAccess, async (req, res) => {
     } catch (e) { res.status(500).json({ error: e.message }); }
 });
 
-router.post('/reset-pool', checkAIAccess, (req, res) => { runtimeProviderOrder = []; res.json({ success: true }); });
+router.post('/reset-pool', checkAIAccess, (req, res) => { 
+    runtimeProviderOrder = []; // Will be re-initialized from DB on next call
+    console.log('[AI] 🔄 Provider priority pool reset.');
+    res.json({ success: true }); 
+});
 
 router.post('/chat', checkAIAccess, async (req, res) => {
     const { text, audio, history } = req.body;
@@ -281,34 +369,38 @@ router.post('/chat', checkAIAccess, async (req, res) => {
 
         const answerText = await streamContentWithSmartFallback({
             contents: fullContents, 
-            config: { systemInstruction: "你是一位友善且知识渊博的中小学AI助教。请用简洁、鼓励性的语言回答。支持 Markdown。" }
+            config: { systemInstruction: "你是一位友善、耐心且知识渊博的中小学AI助教。请用简洁、鼓励性的语言回答学生的问题。回复支持 Markdown 格式。" }
         }, res);
 
         if (answerText) {
             try {
                 const { GoogleGenAI } = await import("@google/genai");
-                const apiKey = process.env.API_KEY;
-                if (apiKey) {
-                    const client = new GoogleGenAI({ apiKey: process.env.API_KEY });
-                    const ttsResponse = await client.models.generateContent({
-                        model: "gemini-2.5-flash-preview-tts", 
-                        contents: [{ parts: [{ text: answerText }] }],
-                        config: { responseModalities: ['AUDIO'], speechConfig: { voiceConfig: { prebuiltVoiceConfig: { voiceName: 'Kore' } } } }
-                    });
-                    const audioBytes = ttsResponse.candidates?.[0]?.content?.parts?.[0]?.inlineData?.data;
-                    if (audioBytes) res.write(`data: ${JSON.stringify({ audio: audioBytes })}\n\n`);
-                    else res.write(`data: ${JSON.stringify({ ttsSkipped: true })}\n\n`);
-                } else {
-                    res.write(`data: ${JSON.stringify({ ttsSkipped: true })}\n\n`);
+                const keys = await getKeyPool('gemini');
+                let audioBytes = null;
+                for (const apiKey of keys) {
+                    try {
+                        const client = new GoogleGenAI({ apiKey });
+                        const ttsResponse = await client.models.generateContent({
+                            model: "gemini-2.5-flash-preview-tts", 
+                            contents: [{ parts: [{ text: answerText }] }],
+                            config: { responseModalities: ['AUDIO'], speechConfig: { voiceConfig: { prebuiltVoiceConfig: { voiceName: 'Kore' } } } }
+                        });
+                        audioBytes = ttsResponse.candidates?.[0]?.content?.parts?.[0]?.inlineData?.data;
+                        if (audioBytes) break;
+                    } catch(e) { if (isQuotaError(e)) continue; break; }
                 }
+                if (audioBytes) res.write(`data: ${JSON.stringify({ audio: audioBytes })}\n\n`);
+                else res.write(`data: ${JSON.stringify({ ttsSkipped: true })}\n\n`);
             } catch (ttsError) { res.write(`data: ${JSON.stringify({ ttsSkipped: true })}\n\n`); }
         }
         res.write('data: [DONE]\n\n'); res.end();
     } catch (e) {
+        console.error("[AI Chat Route Error]", e);
         res.write(`data: ${JSON.stringify({ error: true, message: e.message })}\n\n`); res.end();
     }
 });
 
+// STREAMING ASSESSMENT ENDPOINT
 router.post('/evaluate', checkAIAccess, async (req, res) => {
     const { question, audio, image, images } = req.body;
     res.setHeader('Content-Type', 'text/event-stream');
@@ -318,46 +410,81 @@ router.post('/evaluate', checkAIAccess, async (req, res) => {
 
     try {
         res.write(`data: ${JSON.stringify({ status: 'analyzing' })}\n\n`);
-        const evalParts = [{ text: `请对学生的回答评分。题目：${question}。` }];
-        if (audio) evalParts.push({ inlineData: { mimeType: 'audio/webm', data: audio } });
-        if (images && Array.isArray(images)) images.forEach(img => { if(img) evalParts.push({ inlineData: { mimeType: 'image/jpeg', data: img } }); });
-        else if (image) evalParts.push({ inlineData: { mimeType: 'image/jpeg', data: image } });
 
-        evalParts.push({ text: `格式:
+        const evalParts = [{ text: `请作为一名严谨的老师，对学生的回答进行评分。题目是：${question}。` }];
+        if (audio) {
+            evalParts.push({ text: "学生的回答在音频中。" });
+            evalParts.push({ inlineData: { mimeType: 'audio/webm', data: audio } });
+        }
+        
+        // Support multiple images
+        if (images && Array.isArray(images) && images.length > 0) {
+            evalParts.push({ text: "学生的回答写在以下图片中，请识别所有图片中的文字内容并进行批改：" });
+            images.forEach(img => {
+                if(img) evalParts.push({ inlineData: { mimeType: 'image/jpeg', data: img } });
+            });
+        } else if (image) {
+            // Legacy single image support
+            evalParts.push({ text: "学生的回答写在图片中，请识别图片中的文字内容并进行批改。" });
+            evalParts.push({ inlineData: { mimeType: 'image/jpeg', data: image } });
+        }
+
+        // Force structured markdown output for streaming parsing
+        evalParts.push({ text: `请分析：1. 内容准确性 2. 表达/书写规范。
+        必须严格按照以下格式输出(不要使用Markdown代码块包裹):
+        
         ## Transcription
-        (内容)
+        (在此处输出识别到的学生回答内容，如果是图片则为识别的文字)
+        
         ## Feedback
-        (评语)
+        (在此处输出简短的鼓励性评语和建议)
+        
         ## Score
-        (0-100数字)` });
+        (在此处仅输出一个0-100的数字)` });
 
-        const fullText = await streamContentWithSmartFallback({ contents: [{ role: 'user', parts: evalParts }] }, res);
+        // Stream Text
+        const fullText = await streamContentWithSmartFallback({
+            // CRITICAL FIX: Pass as array of objects for OpenRouter compatibility
+            contents: [{ role: 'user', parts: evalParts }],
+            // NO JSON MODE to allow progressive text streaming
+        }, res);
+
+        // Extract Feedback for TTS
         const feedbackMatch = fullText.match(/## Feedback\s+([\s\S]*?)(?=## Score|$)/i);
         const feedbackText = feedbackMatch ? feedbackMatch[1].trim() : "";
+
+        // Generate TTS if feedback exists
         if (feedbackText) {
             res.write(`data: ${JSON.stringify({ status: 'tts' })}\n\n`);
             try {
                 const { GoogleGenAI } = await import("@google/genai");
-                const apiKey = process.env.API_KEY;
-                if (apiKey) {
-                    const client = new GoogleGenAI({ apiKey: process.env.API_KEY });
-                    const ttsResponse = await client.models.generateContent({
-                        model: "gemini-2.5-flash-preview-tts",
-                        contents: [{ parts: [{ text: feedbackText }] }],
-                        config: { responseModalities: ['AUDIO'], speechConfig: { voiceConfig: { prebuiltVoiceConfig: { voiceName: 'Kore' } } } }
-                    });
-                    const feedbackAudio = ttsResponse.candidates?.[0]?.content?.parts?.[0]?.inlineData?.data;
-                    if (feedbackAudio) res.write(`data: ${JSON.stringify({ audio: feedbackAudio })}\n\n`);
-                    else res.write(`data: ${JSON.stringify({ ttsSkipped: true })}\n\n`);
-                } else {
-                    res.write(`data: ${JSON.stringify({ ttsSkipped: true })}\n\n`);
+                const keys = await getKeyPool('gemini');
+                let feedbackAudio = null;
+                for (const apiKey of keys) {
+                    try {
+                        const client = new GoogleGenAI({ apiKey });
+                        const ttsResponse = await client.models.generateContent({
+                            model: "gemini-2.5-flash-preview-tts",
+                            contents: [{ parts: [{ text: feedbackText }] }],
+                            config: { responseModalities: ['AUDIO'], speechConfig: { voiceConfig: { prebuiltVoiceConfig: { voiceName: 'Kore' } } } }
+                        });
+                        feedbackAudio = ttsResponse.candidates?.[0]?.content?.parts?.[0]?.inlineData?.data;
+                        if (feedbackAudio) break;
+                    } catch(e) { if (isQuotaError(e)) continue; break; }
                 }
+                if (feedbackAudio) res.write(`data: ${JSON.stringify({ audio: feedbackAudio })}\n\n`);
+                else res.write(`data: ${JSON.stringify({ ttsSkipped: true })}\n\n`);
             } catch (ttsErr) { res.write(`data: ${JSON.stringify({ ttsSkipped: true })}\n\n`); }
         }
-        res.write('data: [DONE]\n\n'); res.end();
+
+        res.write('data: [DONE]\n\n');
+        res.end();
+
     } catch (e) {
-        res.write(`data: ${JSON.stringify({ error: true, message: e.message })}\n\n`); res.end();
+        console.error("AI Eval Error:", e);
+        res.write(`data: ${JSON.stringify({ error: true, message: e.message || "Evaluation failed" })}\n\n`);
+        res.end();
     }
 });
 
-module.exports = router;
+module.exports = router;

components/ai/AdminPanel.tsx

@@ -28,7 +28,10 @@ export const AdminPanel: React.FC = () => {
     } | null>(null);
 
     // Key Management
-    // Fixed: Removed local key states to comply with guidelines prohibiting UI for entering keys
+    const [geminiKeys, setGeminiKeys] = useState<string[]>([]);
+    const [openRouterKeys, setOpenRouterKeys] = useState<string[]>([]);
+    const [newGeminiKey, setNewGeminiKey] = useState('');
+    const [newOpenRouterKey, setNewOpenRouterKey] = useState('');
     
     // Model Management
     const [orModels, setOrModels] = useState<OpenRouterModelConfig[]>([]);
@@ -47,7 +50,10 @@ export const AdminPanel: React.FC = () => {
         try {
             const cfg = await api.config.get();
             setSystemConfig(cfg);
-            
+            if (cfg.apiKeys) {
+                setGeminiKeys(cfg.apiKeys.gemini || []);
+                setOpenRouterKeys(cfg.apiKeys.openrouter || []);
+            }
             setOrModels(cfg.openRouterModels && cfg.openRouterModels.length > 0 ? cfg.openRouterModels : DEFAULT_OR_MODELS);
             
             if (cfg.aiProviderOrder && cfg.aiProviderOrder.length > 0) {
@@ -73,6 +79,18 @@ export const AdminPanel: React.FC = () => {
         }
     };
 
+    const handleAddKey = (type: 'gemini' | 'openrouter') => {
+        const key = type === 'gemini' ? newGeminiKey.trim() : newOpenRouterKey.trim();
+        if (!key) return;
+        if (type === 'gemini') { setGeminiKeys([...geminiKeys, key]); setNewGeminiKey(''); }
+        else { setOpenRouterKeys([...openRouterKeys, key]); setNewOpenRouterKey(''); }
+    };
+
+    const removeKey = (type: 'gemini' | 'openrouter', index: number) => {
+        if (type === 'gemini') setGeminiKeys(geminiKeys.filter((_, i) => i !== index));
+        else setOpenRouterKeys(openRouterKeys.filter((_, i) => i !== index));
+    };
+
     const handleAddModel = () => {
         if (!newModelId.trim()) return;
         setOrModels([...orModels, { 
@@ -99,16 +117,17 @@ export const AdminPanel: React.FC = () => {
         setProviderOrder(newArr);
     };
 
-    const saveSettings = async () => {
+    const saveApiKeys = async () => {
         if (!systemConfig) return;
         try {
             await api.config.save({ 
                 ...systemConfig, 
+                apiKeys: { gemini: geminiKeys, openrouter: openRouterKeys }, 
                 openRouterModels: orModels,
                 aiProviderOrder: providerOrder
             });
             await api.ai.resetPool();
-            setToast({ show: true, message: '模型列表及调用顺序已保存', type: 'success' });
+            setToast({ show: true, message: 'API 配置及模型列表已保存', type: 'success' });
         } catch (e) { setToast({ show: true, message: '保存失败', type: 'error' }); }
     };
 
@@ -121,7 +140,7 @@ export const AdminPanel: React.FC = () => {
                 </div>
                 <div>
                     <h1 className="text-2xl font-bold text-gray-800">AI 智能助教管理后台</h1>
-                    <p className="text-gray-500">监控 AI 服务状态与用量，管理模型调用逻辑。</p>
+                    <p className="text-gray-500">监控 AI 服务状态与用量，管理密钥池。</p>
                 </div>
             </div>
 
@@ -166,46 +185,51 @@ export const AdminPanel: React.FC = () => {
                     </div>
                 </div>
             </div>
-            
             <div className="bg-white p-6 rounded-xl border border-gray-100 shadow-sm">
-                <div className="flex justify-between items-center mb-6"><h3 className="font-bold text-gray-800 flex items-center"><Key className="mr-2 text-amber-500"/> 模型线路与优先级配置</h3><button onClick={saveSettings} className="bg-blue-600 text-white px-4 py-2 rounded-lg text-sm font-bold flex items-center gap-2 hover:bg-blue-700 shadow-sm"><Save size={16}/> 保存模型配置</button></div>
-                
-                {/* Fixed: Removed API Key Pool configuration section per guidelines */}
-
+                <div className="flex justify-between items-center mb-6"><h3 className="font-bold text-gray-800 flex items-center"><Key className="mr-2 text-amber-500"/> 多线路密钥池配置</h3><button onClick={saveApiKeys} className="bg-blue-600 text-white px-4 py-2 rounded-lg text-sm font-bold flex items-center gap-2 hover:bg-blue-700 shadow-sm"><Save size={16}/> 保存所有配置</button></div>
                 <div className="grid grid-cols-1 md:grid-cols-2 gap-8">
-                    {/* Provider Order Management */}
                     <div>
-                        <div className="flex justify-between items-center mb-4"><h4 className="font-bold text-gray-700 text-sm flex items-center"><Layers className="mr-2" size={16}/> 服务商调用优先级</h4></div>
-                        <div className="bg-amber-50 p-4 rounded-lg border border-amber-100 mb-4">
-                            <p className="text-xs text-amber-800">系统将按序尝试调用。如果前一个服务商(如 Gemini)报错，将自动切换到下一个。Gemini API 密钥由环境变量配置。</p>
-                        </div>
-                        <div className="space-y-2">
-                            {providerOrder.map((provider, idx) => (
-                                <div key={provider} className="flex items-center gap-3 bg-white p-3 rounded-lg border border-gray-200 shadow-sm">
-                                    <div className="bg-gray-100 text-gray-500 w-6 h-6 flex items-center justify-center rounded-full text-xs font-bold">{idx + 1}</div>
-                                    <div className="flex-1 font-bold text-gray-700">{provider}</div>
-                                    <div className="flex gap-1">
-                                        <button onClick={() => handleMoveProviderOrder(idx, -1)} disabled={idx === 0} className="p-1 hover:bg-gray-100 rounded text-gray-400 hover:text-blue-500 disabled:opacity-30"><ArrowUp size={16}/></button>
-                                        <button onClick={() => handleMoveProviderOrder(idx, 1)} disabled={idx === providerOrder.length - 1} className="p-1 hover:bg-gray-100 rounded text-gray-400 hover:text-blue-500 disabled:opacity-30"><ArrowDown size={16}/></button>
-                                    </div>
-                                </div>
-                            ))}
-                        </div>
+                        <div className="flex items-center justify-between mb-2"><label className="text-sm font-bold text-gray-700">Google Gemini / Gemma 密钥池</label><span className="text-xs bg-blue-100 text-blue-700 px-2 py-0.5 rounded-full">{geminiKeys.length} 个</span></div>
+                        <p className="text-xs text-gray-400 mb-3">当一个 Key 额度耗尽时，系统将自动切换至下一个。</p>
+                        <div className="space-y-2 mb-3">{geminiKeys.map((k, idx) => (<div key={idx} className="flex gap-2 items-center bg-gray-50 p-2 rounded border border-gray-200"><div className="flex-1 font-mono text-xs text-gray-600 truncate">{k.substring(0, 8)}...{k.substring(k.length - 6)}</div><button onClick={() => removeKey('gemini', idx)} className="text-gray-400 hover:text-red-500"><Trash2 size={14}/></button></div>))}</div>
+                        <div className="flex gap-2"><input className="flex-1 border border-gray-300 rounded px-3 py-1.5 text-sm outline-none focus:ring-2 focus:ring-blue-500" placeholder="输入 Gemini API Key" value={newGeminiKey} onChange={e => setNewGeminiKey(e.target.value)}/><button onClick={() => handleAddKey('gemini')} className="bg-gray-100 hover:bg-gray-200 text-gray-600 px-3 py-1.5 rounded border border-gray-300"><Plus size={16}/></button></div>
                     </div>
-
                     <div>
-                        <div className="flex justify-between items-center mb-4"><h4 className="font-bold text-gray-700 text-sm">OpenAI 格式大模型列表 (备用)</h4></div>
-                        <div className="space-y-2 mb-4 bg-gray-50 p-3 rounded-lg border border-gray-200 h-[300px] overflow-y-auto custom-scrollbar">
-                            {orModels.map((m, idx) => (<div key={idx} className="flex items-center gap-2 bg-white p-2 rounded border border-gray-100 shadow-sm"><div className="flex flex-col gap-0.5 px-1"><button onClick={()=>handleMoveModel(idx, -1)} className="text-gray-400 hover:text-blue-500 disabled:opacity-30" disabled={idx===0}><ArrowUp size={12}/></button><button onClick={()=>handleMoveModel(idx, 1)} className="text-gray-400 hover:text-blue-500 disabled:opacity-30" disabled={idx===orModels.length-1}><ArrowDown size={12}/></button></div><div className="flex-1 min-w-0"><div className="text-sm font-bold text-gray-800">{m.name || m.id}</div><div className="text-xs text-gray-400 font-mono truncate" title={m.id}>ID: {m.id}</div>{m.apiUrl && <div className="text-[10px] text-blue-500 truncate" title={m.apiUrl}>API: {m.apiUrl}</div>}</div><div className="flex items-center gap-2">{m.isCustom ? (<span className="text-[10px] bg-blue-50 text-blue-600 px-2 py-0.5 rounded">自定义</span>) : (<span className="text-[10px] bg-gray-100 text-gray-500 px-2 py-0.5 rounded">内置</span>)}<button onClick={() => handleRemoveModel(idx)} className={`p-1.5 rounded transition-colors ${m.isCustom ? 'text-gray-400 hover:text-red-500 hover:bg-red-50' : 'text-gray-200 cursor-not-allowed'}`} disabled={!m.isCustom}><Trash2 size={16}/></button></div></div>))}
-                        </div>
-                        <div className="flex flex-col gap-2 items-end bg-gray-50 p-3 rounded-lg border border-gray-200">
-                            <div className="grid grid-cols-2 gap-2 w-full">
-                                <div className="w-full"><label className="text-xs text-gray-500 mb-1 block">模型 ID *</label><input className="w-full border border-gray-300 rounded px-2 py-1.5 text-sm" value={newModelId} onChange={e=>setNewModelId(e.target.value)} placeholder="如: gpt-4o"/></div>
-                                <div className="w-full"><label className="text-xs text-gray-500 mb-1 block">显示名称</label><input className="w-full border border-gray-300 rounded px-2 py-1.5 text-sm" value={newModelName} onChange={e=>setNewModelName(e.target.value)} placeholder="如: GPT-4o"/></div>
+                        <div className="flex items-center justify-between mb-2"><label className="text-sm font-bold text-gray-700">OpenRouter (通用) 密钥池</label><span className="text-xs bg-purple-100 text-purple-700 px-2 py-0.5 rounded-full">{openRouterKeys.length} 个</span></div>
+                        <p className="text-xs text-gray-400 mb-3">备用线路。所有下方“大模型列表”中的模型都将使用这里的 Key。</p>
+                        <div className="space-y-2 mb-3">{openRouterKeys.map((k, idx) => (<div key={idx} className="flex gap-2 items-center bg-gray-50 p-2 rounded border border-gray-200"><div className="flex-1 font-mono text-xs text-gray-600 truncate">{k.substring(0, 8)}...{k.substring(k.length - 6)}</div><button onClick={() => removeKey('openrouter', idx)} className="text-gray-400 hover:text-red-500"><Trash2 size={14}/></button></div>))}</div>
+                        <div className="flex gap-2"><input className="flex-1 border border-gray-300 rounded px-3 py-1.5 text-sm outline-none focus:ring-2 focus:ring-purple-500" placeholder="输入 API Key" value={newOpenRouterKey} onChange={e => setNewOpenRouterKey(e.target.value)}/><button onClick={() => handleAddKey('openrouter')} className="bg-gray-100 hover:bg-gray-200 text-gray-600 px-3 py-1.5 rounded border border-gray-300"><Plus size={16}/></button></div>
+                    </div>
+                </div>
+                
+                {/* Provider Order Management */}
+                <div className="mt-8 border-t border-gray-100 pt-6">
+                    <div className="flex justify-between items-center mb-4"><h4 className="font-bold text-gray-700 text-sm flex items-center"><Layers className="mr-2" size={16}/> 大模型调用优先级</h4></div>
+                    <div className="bg-amber-50 p-4 rounded-lg border border-amber-100 mb-4">
+                        <p className="text-xs text-amber-800">系统将按照以下顺序尝试调用大模型。如果前一个服务商额度耗尽或报错，会自动切换到下一个。</p>
+                    </div>
+                    <div className="space-y-2 max-w-md">
+                        {providerOrder.map((provider, idx) => (
+                            <div key={provider} className="flex items-center gap-3 bg-white p-3 rounded-lg border border-gray-200 shadow-sm">
+                                <div className="bg-gray-100 text-gray-500 w-6 h-6 flex items-center justify-center rounded-full text-xs font-bold">{idx + 1}</div>
+                                <div className="flex-1 font-bold text-gray-700">{provider}</div>
+                                <div className="flex gap-1">
+                                    <button onClick={() => handleMoveProviderOrder(idx, -1)} disabled={idx === 0} className="p-1 hover:bg-gray-100 rounded text-gray-400 hover:text-blue-500 disabled:opacity-30"><ArrowUp size={16}/></button>
+                                    <button onClick={() => handleMoveProviderOrder(idx, 1)} disabled={idx === providerOrder.length - 1} className="p-1 hover:bg-gray-100 rounded text-gray-400 hover:text-blue-500 disabled:opacity-30"><ArrowDown size={16}/></button>
+                                </div>
                             </div>
-                            <div className="w-full"><label className="text-xs text-gray-500 mb-1 block">API URL (可选, 需环境变量支持对应的 KEY)</label><input className="w-full border border-gray-300 rounded px-2 py-1.5 text-sm" value={newModelApiUrl} onChange={e=>setNewModelApiUrl(e.target.value)} placeholder="https://api.openai.com/v1"/></div>
-                            <button onClick={handleAddModel} className="bg-indigo-600 text-white px-4 py-1.5 rounded text-sm hover:bg-indigo-700 h-9 w-full md:w-auto">添加至列表</button>
-                        </div>
+                        ))}
+                    </div>
+                </div>
+
+                <div className="mt-8 border-t border-gray-100 pt-6">
+                    <div className="flex justify-between items-center mb-4"><h4 className="font-bold text-gray-700 text-sm">OpenAI 格式大模型列表管理</h4></div>
+                    <div className="space-y-2 mb-4 bg-gray-50 p-3 rounded-lg border border-gray-200">{orModels.map((m, idx) => (<div key={idx} className="flex items-center gap-2 bg-white p-2 rounded border border-gray-100 shadow-sm"><div className="flex flex-col gap-0.5 px-1"><button onClick={()=>handleMoveModel(idx, -1)} className="text-gray-400 hover:text-blue-500 disabled:opacity-30" disabled={idx===0}><ArrowUp size={12}/></button><button onClick={()=>handleMoveModel(idx, 1)} className="text-gray-400 hover:text-blue-500 disabled:opacity-30" disabled={idx===orModels.length-1}><ArrowDown size={12}/></button></div><div className="flex-1 min-w-0"><div className="text-sm font-bold text-gray-800">{m.name || m.id}</div><div className="text-xs text-gray-400 font-mono truncate" title={m.id}>ID: {m.id}</div>{m.apiUrl && <div className="text-[10px] text-blue-500 truncate" title={m.apiUrl}>API: {m.apiUrl}</div>}</div><div className="flex items-center gap-2">{m.isCustom ? (<span className="text-[10px] bg-blue-50 text-blue-600 px-2 py-0.5 rounded">自定义</span>) : (<span className="text-[10px] bg-gray-100 text-gray-500 px-2 py-0.5 rounded">内置</span>)}<button onClick={() => handleRemoveModel(idx)} className={`p-1.5 rounded transition-colors ${m.isCustom ? 'text-gray-400 hover:text-red-500 hover:bg-red-50' : 'text-gray-200 cursor-not-allowed'}`} disabled={!m.isCustom}><Trash2 size={16}/></button></div></div>))}</div>
+                    <div className="flex flex-col md:flex-row gap-2 items-end bg-gray-50 p-3 rounded-lg border border-gray-200">
+                        <div className="flex-1 w-full"><label className="text-xs text-gray-500 mb-1 block">模型 ID *</label><input className="w-full border border-gray-300 rounded px-2 py-1.5 text-sm" value={newModelId} onChange={e=>setNewModelId(e.target.value)} placeholder="如: gpt-4o"/></div>
+                        <div className="flex-1 w-full"><label className="text-xs text-gray-500 mb-1 block">显示名称</label><input className="w-full border border-gray-300 rounded px-2 py-1.5 text-sm" value={newModelName} onChange={e=>setNewModelName(e.target.value)} placeholder="如: GPT-4o"/></div>
+                        <div className="flex-[1.5] w-full"><label className="text-xs text-gray-500 mb-1 block">API URL (选填, 默认 OpenRouter)</label><input className="w-full border border-gray-300 rounded px-2 py-1.5 text-sm" value={newModelApiUrl} onChange={e=>setNewModelApiUrl(e.target.value)} placeholder="https://api.openai.com/v1"/></div>
+                        <button onClick={handleAddModel} className="bg-indigo-600 text-white px-4 py-1.5 rounded text-sm hover:bg-indigo-700 h-9 w-full md:w-auto">添加</button>
                     </div>
                 </div>
             </div>

components/ai/AssessmentPanel.tsx

@@ -14,28 +14,30 @@ export const AssessmentPanel: React.FC<AssessmentPanelProps> = ({ currentUser })
     const [assessmentTopic, setAssessmentTopic] = useState('请背诵《静夜思》并解释其含义。');
     const [selectedImages, setSelectedImages] = useState<File[]>([]);
     const [isAssessmentRecording, setIsAssessmentRecording] = useState(false);
-    const [isWebSpeechListening, setIsWebSpeechListening] = useState(false);
     const [assessmentStatus, setAssessmentStatus] = useState<'IDLE' | 'UPLOADING' | 'ANALYZING' | 'TTS'>('IDLE');
-    const [recognizedText, setRecognizedText] = useState('');
-    const [streamedAssessment, setStreamedAssessment] = useState<{ transcription: string; feedback: string; score: number | null; audio?: string; }>({ transcription: '', feedback: '', score: null });
+    
+    const [streamedAssessment, setStreamedAssessment] = useState<{
+        transcription: string;
+        feedback: string;
+        score: number | null;
+        audio?: string;
+    }>({ transcription: '', feedback: '', score: null });
+
     const [toast, setToast] = useState<ToastState>({ show: false, message: '', type: 'success' });
 
     const mediaRecorderRef = useRef<MediaRecorder | null>(null);
     const audioChunksRef = useRef<Blob[]>([]);
     const audioContextRef = useRef<AudioContext | null>(null);
     const currentSourceRef = useRef<AudioBufferSourceNode | null>(null);
-    const recognitionRef = useRef<any>(null);
-
-    // Store recognized text in a ref for faster/reliable access during stop callback
-    const textRef = useRef('');
 
+    // Initialize AudioContext
     useEffect(() => {
         // @ts-ignore
         const AudioCtor = window.AudioContext || window.webkitAudioContext;
         audioContextRef.current = new AudioCtor();
         return () => {
             stopPlayback();
-            if (recognitionRef.current) recognitionRef.current.abort();
+            window.speechSynthesis.cancel();
         };
     }, []);
 
@@ -50,8 +52,13 @@ export const AssessmentPanel: React.FC<AssessmentPanelProps> = ({ currentUser })
     const speakWithBrowser = (text: string) => {
         if (!text) return;
         stopPlayback();
-        const utterance = new SpeechSynthesisUtterance(cleanTextForTTS(text));
+        const cleanText = cleanTextForTTS(text);
+        const utterance = new SpeechSynthesisUtterance(cleanText);
         utterance.lang = 'zh-CN';
+        utterance.rate = 1.0; 
+        const voices = window.speechSynthesis.getVoices();
+        const zhVoice = voices.find(v => v.lang === 'zh-CN' && !v.name.includes('Hong Kong') && !v.name.includes('Taiwan'));
+        if (zhVoice) utterance.voice = zhVoice;
         window.speechSynthesis.speak(utterance);
     };
 
@@ -63,6 +70,9 @@ export const AssessmentPanel: React.FC<AssessmentPanelProps> = ({ currentUser })
                 const AudioCtor = window.AudioContext || window.webkitAudioContext;
                 audioContextRef.current = new AudioCtor();
             }
+            if (audioContextRef.current?.state === 'suspended') {
+                await audioContextRef.current.resume();
+            }
             const bytes = base64ToUint8Array(base64Audio);
             const audioBuffer = decodePCM(bytes, audioContextRef.current!);
             const source = audioContextRef.current!.createBufferSource();
@@ -70,127 +80,52 @@ export const AssessmentPanel: React.FC<AssessmentPanelProps> = ({ currentUser })
             source.connect(audioContextRef.current!.destination);
             source.start(0);
             currentSourceRef.current = source;
-        } catch (e) { console.error("Audio playback error", e); }
-    };
-
-    const startRecording = async (e?: React.MouseEvent | React.TouchEvent) => {
-        if (e) { e.preventDefault(); e.stopPropagation(); }
-        console.log("[Assessment] Starting Recording...");
-        textRef.current = '';
-        setRecognizedText('');
-        
-        // @ts-ignore
-        const SpeechRecognition = window.SpeechRecognition || window.webkitSpeechRecognition;
-        if (SpeechRecognition) {
-            try {
-                if (recognitionRef.current) recognitionRef.current.abort();
-                const recognition = new SpeechRecognition();
-                recognition.lang = 'zh-CN';
-                recognition.interimResults = true;
-                recognition.continuous = true;
-                
-                recognition.onstart = () => {
-                    setIsWebSpeechListening(true);
-                    setIsAssessmentRecording(true);
-                };
-                
-                recognition.onresult = (event: any) => {
-                    let full = '';
-                    for (let i = 0; i < event.results.length; ++i) {
-                        full += event.results[i][0].transcript;
-                    }
-                    textRef.current = full;
-                    setRecognizedText(full);
-                };
-
-                recognition.onerror = (e: any) => {
-                    console.warn("[Assessment] Web Speech Error:", e.error);
-                    if (e.error !== 'aborted') {
-                        startAudioRecordingFallback();
-                    } else {
-                        setIsAssessmentRecording(false);
-                        setIsWebSpeechListening(false);
-                    }
-                };
-
-                recognition.onend = () => {
-                    setIsWebSpeechListening(false);
-                };
-                
-                recognitionRef.current = recognition;
-                recognition.start();
-                return;
-            } catch (e) {
-                console.error("[Assessment] Web Speech Failed", e);
-                startAudioRecordingFallback();
-            }
-        } else {
-            startAudioRecordingFallback();
+        } catch (e) {
+            console.error("Audio playback error", e);
+            setToast({ show: true, message: '语音播放失败', type: 'error' });
         }
     };
 
-    const startAudioRecordingFallback = async () => {
-        console.log("[Assessment] Falling back to MediaRecorder");
+    const startRecording = async () => {
         try {
             const stream = await navigator.mediaDevices.getUserMedia({ audio: true });
             const mediaRecorder = new MediaRecorder(stream);
             mediaRecorderRef.current = mediaRecorder;
             audioChunksRef.current = [];
-            
+
             mediaRecorder.ondataavailable = (event) => {
-                if (event.data.size > 0) audioChunksRef.current.push(event.data);
-            };
-            
-            mediaRecorder.onstop = async () => {
-                const audioBlob = new Blob(audioChunksRef.current, { type: 'audio/webm' });
-                const base64 = await blobToBase64(audioBlob);
-                handleAssessmentStreamingSubmit({ audio: base64 });
-                stream.getTracks().forEach(track => track.stop());
+                if (event.data.size > 0) {
+                    audioChunksRef.current.push(event.data);
+                }
             };
-            
+
             mediaRecorder.start();
             setIsAssessmentRecording(true);
-            setIsWebSpeechListening(false);
         } catch (e) {
             setToast({ show: true, message: '无法访问麦克风', type: 'error' });
-            setIsAssessmentRecording(false);
         }
     };
 
     const stopRecording = () => {
-        console.log("[Assessment] Stop recording requested");
-        const wasWebSpeech = isWebSpeechListening;
-        
-        if (wasWebSpeech && recognitionRef.current) {
-            recognitionRef.current.stop();
-            // Use current textRef because state might be stale
-            const finalSpeechText = textRef.current;
-            setTimeout(() => {
-                if (finalSpeechText.trim()) {
-                    handleAssessmentStreamingSubmit({ text: finalSpeechText });
-                } else {
-                    // Try fallback if no text captured but button was held
-                    setToast({ show: true, message: '未检测到有效语音内容', type: 'error' });
-                }
-            }, 300);
-        } else if (mediaRecorderRef.current && mediaRecorderRef.current.state !== 'inactive') {
+        if (mediaRecorderRef.current && isAssessmentRecording) {
             mediaRecorderRef.current.stop();
-            // handleAssessmentStreamingSubmit will be called by onstop
+            setIsAssessmentRecording(false);
+            
+            mediaRecorderRef.current.onstop = async () => {
+                const audioBlob = new Blob(audioChunksRef.current, { type: 'audio/webm' });
+                const base64 = await blobToBase64(audioBlob);
+                handleAssessmentStreamingSubmit({ audio: base64 });
+                mediaRecorderRef.current?.stream.getTracks().forEach(track => track.stop());
+            };
         }
-        
-        setIsAssessmentRecording(false);
-        setIsWebSpeechListening(false);
     };
 
-    const handleAssessmentStreamingSubmit = async ({ audio, images, text }: { audio?: string, images?: string[], text?: string }) => {
+    const handleAssessmentStreamingSubmit = async ({ audio, images }: { audio?: string, images?: string[] }) => {
         setAssessmentStatus('UPLOADING');
         setStreamedAssessment({ transcription: '', feedback: '', score: null, audio: undefined });
         stopPlayback();
 
         try {
-            let finalQuestion = assessmentTopic;
-            if (text) finalQuestion += `\n\n学生口述回答内容：${text}\n（请基于此文本进行评分）`;
-
             const response = await fetch('/api/ai/evaluate', {
                 method: 'POST',
                 headers: {
@@ -199,13 +134,15 @@ export const AssessmentPanel: React.FC<AssessmentPanelProps> = ({ currentUser })
                     'x-user-role': currentUser?.role || '',
                     'x-school-id': currentUser?.schoolId || ''
                 },
-                body: JSON.stringify({ question: finalQuestion, audio, images })
+                body: JSON.stringify({ question: assessmentTopic, audio, images })
             });
 
             if (!response.ok) throw new Error(response.statusText);
+            if (!response.body) throw new Error('No response body');
+
             setAssessmentStatus('ANALYZING');
 
-            const reader = response.body!.getReader();
+            const reader = response.body.getReader();
             const decoder = new TextDecoder();
             let accumulatedRaw = '';
             let buffer = '';
@@ -213,6 +150,7 @@ export const AssessmentPanel: React.FC<AssessmentPanelProps> = ({ currentUser })
             while (true) {
                 const { done, value } = await reader.read();
                 if (done) break;
+                
                 buffer += decoder.decode(value, { stream: true });
                 const parts = buffer.split('\n\n');
                 buffer = parts.pop() || ''; 
@@ -221,37 +159,52 @@ export const AssessmentPanel: React.FC<AssessmentPanelProps> = ({ currentUser })
                     if (line.startsWith('data: ')) {
                         const jsonStr = line.replace('data: ', '').trim();
                         if (jsonStr === '[DONE]') break;
+                        
                         try {
                             const data = JSON.parse(jsonStr);
-                            if (data.status === 'tts') setAssessmentStatus('TTS');
+                            
+                            if (data.status) {
+                                if (data.status === 'analyzing') setAssessmentStatus('ANALYZING');
+                                if (data.status === 'tts') setAssessmentStatus('TTS');
+                            }
+
                             if (data.text) {
                                 accumulatedRaw += data.text;
-                                const trMatch = accumulatedRaw.match(/## Transcription\s+([\s\S]*?)(?=## Feedback|$)/i);
-                                const fbMatch = accumulatedRaw.match(/## Feedback\s+([\s\S]*?)(?=## Score|$)/i);
-                                const scMatch = accumulatedRaw.match(/## Score\s+(\d+)/i);
+                                const transcriptionMatch = accumulatedRaw.match(/## Transcription\s+([\s\S]*?)(?=## Feedback|$)/i);
+                                const feedbackMatch = accumulatedRaw.match(/## Feedback\s+([\s\S]*?)(?=## Score|$)/i);
+                                const scoreMatch = accumulatedRaw.match(/## Score\s+(\d+)/i);
+
                                 setStreamedAssessment(prev => ({
                                     ...prev,
-                                    transcription: trMatch ? trMatch[1].trim() : (text || prev.transcription),
-                                    feedback: fbMatch ? fbMatch[1].trim() : prev.feedback,
-                                    score: scMatch ? parseInt(scMatch[1]) : prev.score
+                                    transcription: transcriptionMatch ? transcriptionMatch[1].trim() : prev.transcription,
+                                    feedback: feedbackMatch ? feedbackMatch[1].trim() : prev.feedback,
+                                    score: scoreMatch ? parseInt(scoreMatch[1]) : prev.score
                                 }));
                             }
+
                             if (data.audio) {
                                 setStreamedAssessment(prev => ({ ...prev, audio: data.audio }));
                                 playPCMAudio(data.audio);
                             }
+                            
                             if (data.ttsSkipped) {
                                 const fb = streamedAssessment.feedback || accumulatedRaw.match(/## Feedback\s+([\s\S]*?)(?=## Score|$)/i)?.[1] || '';
                                 if (fb) speakWithBrowser(fb);
                             }
-                            if (data.error) setToast({ show: true, message: data.message || '评分出错', type: 'error' });
+
+                            if (data.error) {
+                                setToast({ show: true, message: data.message || '评分出错', type: 'error' });
+                            }
+
                         } catch (e) {}
                     }
                 }
             }
             setAssessmentStatus('IDLE');
+
         } catch (error: any) {
-            setToast({ show: true, message: '评分失败', type: 'error' });
+            console.error("Assessment error", error);
+            setToast({ show: true, message: '评分失败: ' + error.message, type: 'error' });
             setAssessmentStatus('IDLE');
         }
     };
@@ -266,8 +219,9 @@ export const AssessmentPanel: React.FC<AssessmentPanelProps> = ({ currentUser })
         if (selectedImages.length === 0) return;
         setAssessmentStatus('UPLOADING');
         try {
-            const images = await Promise.all(selectedImages.map(f => compressImage(f)));
-            handleAssessmentStreamingSubmit({ images });
+            const base64Promises = selectedImages.map(file => compressImage(file));
+            const base64Images = await Promise.all(base64Promises);
+            handleAssessmentStreamingSubmit({ images: base64Images });
         } catch(e) {
             setAssessmentStatus('IDLE');
             setToast({ show: true, message: '图片压缩上传失败', type: 'error' });
@@ -280,6 +234,7 @@ export const AssessmentPanel: React.FC<AssessmentPanelProps> = ({ currentUser })
             <button onClick={stopPlayback} className="absolute top-4 right-4 z-50 bg-white/80 backdrop-blur p-2 rounded-full shadow-md text-red-500 hover:bg-white border border-gray-200" title="停止播放"><StopIcon size={20}/></button>
 
             <div className="max-w-3xl mx-auto space-y-6">
+                {/* Topic Card */}
                 <div className="bg-white p-6 rounded-2xl border border-purple-100 shadow-sm">
                     <h3 className="text-lg font-bold text-gray-800 mb-2 flex items-center justify-between">
                         <span className="flex items-center"><Brain className="mr-2 text-purple-600"/> 今日测评题目</span>
@@ -298,7 +253,7 @@ export const AssessmentPanel: React.FC<AssessmentPanelProps> = ({ currentUser })
                                 className={`px-8 py-4 rounded-full font-bold text-white flex items-center gap-3 shadow-lg transition-all ${isAssessmentRecording ? 'bg-red-500 scale-105' : 'bg-gradient-to-r from-purple-600 to-indigo-600 hover:shadow-purple-200 hover:scale-105 disabled:opacity-50'}`}
                             >
                                 {assessmentStatus !== 'IDLE' ? <Loader2 className="animate-spin"/> : (isAssessmentRecording ? <StopCircle/> : <Mic/>)}
-                                {assessmentStatus === 'UPLOADING' ? '上传中...' : assessmentStatus === 'ANALYZING' ? 'AI 正在分析...' : assessmentStatus === 'TTS' ? '生成语音...' : isAssessmentRecording ? (isWebSpeechListening ? '正在识别...' : '松开结束录音') : '按住开始回答'}
+                                {assessmentStatus === 'UPLOADING' ? '上传中...' : assessmentStatus === 'ANALYZING' ? 'AI 正在分析...' : assessmentStatus === 'TTS' ? '生成语音...' : isAssessmentRecording ? '松开结束录音' : '按住开始回答'}
                             </button>
                         ) : (
                             <div className="w-full">
@@ -315,6 +270,7 @@ export const AssessmentPanel: React.FC<AssessmentPanelProps> = ({ currentUser })
                                         <>
                                             <ImageIcon className="mx-auto text-purple-300 mb-2" size={40}/>
                                             <p className="text-purple-600 font-bold">点击上传作业图片</p>
+                                            <p className="text-xs text-gray-400">支持批量上传 • 自动压缩处理</p>
                                         </>
                                     ) : (
                                         <div className="z-0 w-full pointer-events-none opacity-50 flex items-center justify-center">
@@ -347,7 +303,7 @@ export const AssessmentPanel: React.FC<AssessmentPanelProps> = ({ currentUser })
                                         className="mt-6 w-full px-8 py-3 bg-purple-600 text-white rounded-lg font-bold hover:bg-purple-700 flex items-center justify-center gap-2 shadow-md transition-all"
                                     >
                                         {assessmentStatus !== 'IDLE' ? <Loader2 className="animate-spin" size={18}/> : <CheckCircle size={18}/>}
-                                        {assessmentStatus === 'UPLOADING' ? '压缩上传中...' : assessmentStatus === 'ANALYZING' ? 'AI 分析中...' : assessmentStatus === 'TTS' ? '生成语音...' : `开始批改 (${selectedImages.length}张)`}
+                                        {assessmentStatus === 'UPLOADING' ? '压缩上传中...' : assessmentStatus === 'ANALYZING' ? 'AI 正在分析...' : assessmentStatus === 'TTS' ? '生成语音...' : `开始批改 (${selectedImages.length}张)`}
                                     </button>
                                 )}
                             </div>
@@ -355,6 +311,7 @@ export const AssessmentPanel: React.FC<AssessmentPanelProps> = ({ currentUser })
                     </div>
                 </div>
 
+                {/* Streamed Result Card */}
                 {(streamedAssessment.transcription || streamedAssessment.feedback || streamedAssessment.score !== null) && (
                     <div className="bg-white p-6 rounded-2xl border border-gray-200 shadow-lg animate-in slide-in-from-bottom-4">
                         <div className="flex items-center justify-between border-b border-gray-100 pb-4 mb-4">
@@ -363,32 +320,34 @@ export const AssessmentPanel: React.FC<AssessmentPanelProps> = ({ currentUser })
                                 {assessmentStatus !== 'IDLE' && (
                                     <div className="flex items-center gap-1 text-xs px-2 py-1 bg-purple-50 text-purple-600 rounded-full animate-pulse">
                                         <Zap size={12}/>
-                                        正��处理中...
+                                        {assessmentStatus === 'ANALYZING' ? '正在智能分析内容...' : assessmentStatus === 'TTS' ? '正在生成语音点评...' : '处理中...'}
                                     </div>
                                 )}
                             </div>
                             <div className="flex items-center gap-4">
                                 {streamedAssessment.audio && (
-                                    <button onClick={() => playPCMAudio(streamedAssessment.audio!)} className="flex items-center gap-1 text-sm bg-purple-100 text-purple-700 px-3 py-1 rounded-full hover:bg-purple-200">
+                                    <button onClick={() => playPCMAudio(streamedAssessment.audio!)} className="flex items-center gap-1 text-sm bg-purple-100 text-purple-700 px-3 py-1 rounded-full hover:bg-purple-200 animate-in fade-in">
                                         <Volume2 size={16}/> 听AI点评
                                     </button>
                                 )}
-                                {streamedAssessment.score !== null && (
+                                {streamedAssessment.score !== null ? (
                                     <div className={`text-3xl font-black ${streamedAssessment.score >= 80 ? 'text-green-500' : streamedAssessment.score >= 60 ? 'text-yellow-500' : 'text-red-500'}`}>
                                         {streamedAssessment.score}<span className="text-sm text-gray-400 ml-1">分</span>
                                     </div>
+                                ) : (
+                                    <div className="text-sm text-gray-400 italic">评分中...</div>
                                 )}
                             </div>
                         </div>
                         <div className="space-y-4">
                             <div className="bg-gray-50 p-4 rounded-xl">
                                 <p className="text-xs font-bold text-gray-500 uppercase mb-1">AI 识别内容</p>
-                                <p className="text-gray-700 leading-relaxed text-sm whitespace-pre-wrap">{streamedAssessment.transcription || '正在识别...'}</p>
+                                <p className="text-gray-700 leading-relaxed text-sm whitespace-pre-wrap">{streamedAssessment.transcription || <span className="text-gray-400">正在识别...</span>}</p>
                             </div>
                             <div>
                                 <p className="text-xs font-bold text-gray-500 uppercase mb-2">AI 点评建议</p>
                                 <div className="p-4 bg-purple-50 text-purple-900 rounded-xl border border-purple-100 text-sm leading-relaxed whitespace-pre-wrap">
-                                    {streamedAssessment.feedback || 'AI 思考中...'}
+                                    {streamedAssessment.feedback || <span className="text-purple-300">AI 正在思考评语...</span>}
                                 </div>
                             </div>
                         </div>

components/ai/ChatPanel.tsx

@@ -1,7 +1,7 @@
 
 import React, { useState, useRef, useEffect } from 'react';
 import { AIChatMessage, User } from '../../types';
-import { Bot, Mic, Volume2, Send, Sparkles, Loader2, StopCircle, Trash2 } from 'lucide-react';
+import { Bot, Mic, Square, Volume2, Send, Sparkles, Loader2, StopCircle, Trash2 } from 'lucide-react';
 import ReactMarkdown from 'react-markdown';
 import remarkGfm from 'remark-gfm';
 import { blobToBase64, base64ToUint8Array, decodePCM, cleanTextForTTS } from '../../utils/mediaHelpers';
@@ -22,14 +22,18 @@ export const ChatPanel: React.FC<ChatPanelProps> = ({ currentUser }) => {
                 timestamp: Date.now() 
             }];
         } catch (e) {
-            return [{ id: 'welcome', role: 'model', text: '你好！我是你的 AI 智能助教。', timestamp: Date.now() }];
+            return [{ 
+                id: 'welcome', 
+                role: 'model', 
+                text: '你好！我是你的 AI 智能助教。有什么可以帮你的吗？', 
+                timestamp: Date.now() 
+            }];
         }
     });
-    
     const [textInput, setTextInput] = useState('');
+    const [inputMode, setInputMode] = useState<'text' | 'audio'>('text');
     const [isChatProcessing, setIsChatProcessing] = useState(false);
     const [isChatRecording, setIsChatRecording] = useState(false);
-    const [isWebSpeechListening, setIsWebSpeechListening] = useState(false);
     const [toast, setToast] = useState<ToastState>({ show: false, message: '', type: 'success' });
 
     const mediaRecorderRef = useRef<MediaRecorder | null>(null);
@@ -37,23 +41,31 @@ export const ChatPanel: React.FC<ChatPanelProps> = ({ currentUser }) => {
     const audioContextRef = useRef<AudioContext | null>(null);
     const currentSourceRef = useRef<AudioBufferSourceNode | null>(null);
     const messagesEndRef = useRef<HTMLDivElement>(null);
-    const recognitionRef = useRef<any>(null);
-    // Fixed: Added missing inputRef to fix the error in line 324
-    const inputRef = useRef<HTMLInputElement>(null);
-
-    // Track the text that was already in the box when we started speaking
-    const baseTextRef = useRef('');
 
+    // Initialize AudioContext
     useEffect(() => {
         // @ts-ignore
         const AudioCtor = window.AudioContext || window.webkitAudioContext;
         audioContextRef.current = new AudioCtor();
         return () => {
             stopPlayback();
-            if (recognitionRef.current) recognitionRef.current.abort();
+            window.speechSynthesis.cancel();
         };
     }, []);
 
+    // Persist messages
+    useEffect(() => {
+        try {
+            const MAX_COUNT = 50;
+            const welcome = messages.find(m => m.id === 'welcome');
+            const others = messages.filter(m => m.id !== 'welcome');
+            const recent = others.slice(-MAX_COUNT);
+            const messagesToSave = (welcome ? [welcome] : []).concat(recent);
+            localStorage.setItem('ai_chat_history', JSON.stringify(messagesToSave));
+        } catch (e) {}
+    }, [messages]);
+
+    // Scroll to bottom
     useEffect(() => {
         messagesEndRef.current?.scrollIntoView({ behavior: isChatProcessing ? 'auto' : 'smooth', block: 'end' });
     }, [messages, isChatProcessing]);
@@ -69,8 +81,13 @@ export const ChatPanel: React.FC<ChatPanelProps> = ({ currentUser }) => {
     const speakWithBrowser = (text: string) => {
         if (!text) return;
         stopPlayback();
-        const utterance = new SpeechSynthesisUtterance(cleanTextForTTS(text));
+        const cleanText = cleanTextForTTS(text);
+        const utterance = new SpeechSynthesisUtterance(cleanText);
         utterance.lang = 'zh-CN';
+        utterance.rate = 1.0; 
+        const voices = window.speechSynthesis.getVoices();
+        const zhVoice = voices.find(v => v.lang === 'zh-CN' && !v.name.includes('Hong Kong') && !v.name.includes('Taiwan'));
+        if (zhVoice) utterance.voice = zhVoice;
         window.speechSynthesis.speak(utterance);
     };
 
@@ -94,82 +111,11 @@ export const ChatPanel: React.FC<ChatPanelProps> = ({ currentUser }) => {
             currentSourceRef.current = source;
         } catch (e) {
             console.error("Audio playback error", e);
+            setToast({ show: true, message: '语音播放失败', type: 'error' });
         }
     };
 
-    const startRecording = async (e?: React.MouseEvent | React.TouchEvent) => {
-        if (e) { e.preventDefault(); e.stopPropagation(); }
-        
-        // Save what's already in the input so we can append to it
-        baseTextRef.current = textInput;
-        
-        console.log("[Voice] Start listening...");
-        // @ts-ignore
-        const SpeechRecognition = window.SpeechRecognition || window.webkitSpeechRecognition;
-        
-        if (SpeechRecognition) {
-            try {
-                if (recognitionRef.current) recognitionRef.current.abort();
-
-                const recognition = new SpeechRecognition();
-                recognition.lang = 'zh-CN';
-                recognition.interimResults = true;
-                recognition.continuous = true; 
-                
-                recognition.onstart = () => {
-                    setIsWebSpeechListening(true);
-                    setIsChatRecording(true);
-                };
-                
-                recognition.onresult = (event: any) => {
-                    let interimTranscript = '';
-                    let finalTranscript = '';
-
-                    for (let i = event.resultIndex; i < event.results.length; ++i) {
-                        const transcript = event.results[i][0].transcript;
-                        if (event.results[i].isFinal) {
-                            finalTranscript += transcript;
-                        } else {
-                            interimTranscript += transcript;
-                        }
-                    }
-
-                    // Always append newly finalized text to the base
-                    if (finalTranscript) {
-                        baseTextRef.current += finalTranscript;
-                    }
-
-                    // Update input box with: Old text + currently recognized final chunks + currently recognized interim chunks
-                    setTextInput(baseTextRef.current + interimTranscript);
-                };
-
-                recognition.onerror = (e: any) => {
-                    console.warn("[Voice] Web Speech Error:", e.error);
-                    if (e.error === 'not-allowed') {
-                        setToast({ show: true, message: '请允许麦克风访问', type: 'error' });
-                    }
-                    stopRecording();
-                };
-
-                recognition.onend = () => {
-                    setIsWebSpeechListening(false);
-                    setIsChatRecording(false);
-                };
-
-                recognitionRef.current = recognition;
-                recognition.start();
-                return;
-            } catch (e) {
-                console.error("[Voice] Web Speech Init Exception", e);
-                startAudioRecordingFallback();
-            }
-        } else {
-            startAudioRecordingFallback();
-        }
-    };
-
-    const startAudioRecordingFallback = async () => {
-        console.log("[Voice] Using MediaRecorder Fallback");
+    const startRecording = async () => {
         try {
             const stream = await navigator.mediaDevices.getUserMedia({ audio: true });
             const mediaRecorder = new MediaRecorder(stream);
@@ -177,51 +123,51 @@ export const ChatPanel: React.FC<ChatPanelProps> = ({ currentUser }) => {
             audioChunksRef.current = [];
 
             mediaRecorder.ondataavailable = (event) => {
-                if (event.data.size > 0) audioChunksRef.current.push(event.data);
-            };
-
-            mediaRecorder.onstop = async () => {
-                const audioBlob = new Blob(audioChunksRef.current, { type: 'audio/webm' });
-                const base64 = await blobToBase64(audioBlob);
-                handleChatSubmit(undefined, base64);
-                stream.getTracks().forEach(track => track.stop());
+                if (event.data.size > 0) {
+                    audioChunksRef.current.push(event.data);
+                }
             };
 
             mediaRecorder.start();
             setIsChatRecording(true);
-            setIsWebSpeechListening(false);
         } catch (e) {
-            setToast({ show: true, message: '麦克风不可用', type: 'error' });
+            setToast({ show: true, message: '无法访问麦克风', type: 'error' });
         }
     };
 
     const stopRecording = () => {
-        console.log("[Voice] Stopping...");
-        if (isWebSpeechListening && recognitionRef.current) {
-            recognitionRef.current.stop();
-        } else if (mediaRecorderRef.current && isChatRecording) {
+        if (mediaRecorderRef.current && isChatRecording) {
             mediaRecorderRef.current.stop();
+            setIsChatRecording(false);
+            
+            mediaRecorderRef.current.onstop = async () => {
+                const audioBlob = new Blob(audioChunksRef.current, { type: 'audio/webm' });
+                const base64 = await blobToBase64(audioBlob);
+                handleChatSubmit(undefined, base64);
+                mediaRecorderRef.current?.stream.getTracks().forEach(track => track.stop());
+            };
         }
-        setIsChatRecording(false);
-        setIsWebSpeechListening(false);
     };
 
     const handleChatSubmit = async (text?: string, audioBase64?: string) => {
-        const finalContent = text || textInput;
-        if (!finalContent && !audioBase64) return;
-        
+        if (!text && !audioBase64) return;
         stopPlayback();
         const historyPayload = messages.filter(m => m.id !== 'welcome').map(m => ({ role: m.role, text: m.text }));
         
         const newUserMsg: AIChatMessage = { 
             id: Date.now().toString(), 
             role: 'user', 
-            text: finalContent || '(语音消息)', 
+            text: text || '(语音消息)', 
             isAudioMessage: !!audioBase64, 
             timestamp: Date.now() 
         };
         const newAiMsgId = (Date.now() + 1).toString();
-        const newAiMsg: AIChatMessage = { id: newAiMsgId, role: 'model', text: '', timestamp: Date.now() };
+        const newAiMsg: AIChatMessage = { 
+            id: newAiMsgId, 
+            role: 'model', 
+            text: '', 
+            timestamp: Date.now() 
+        };
 
         setMessages(prev => [...prev, newUserMsg, newAiMsg]);
         setTextInput('');
@@ -236,11 +182,13 @@ export const ChatPanel: React.FC<ChatPanelProps> = ({ currentUser }) => {
                     'x-user-role': currentUser?.role || '',
                     'x-school-id': currentUser?.schoolId || ''
                 },
-                body: JSON.stringify({ text: finalContent, audio: audioBase64, history: historyPayload })
+                body: JSON.stringify({ text, audio: audioBase64, history: historyPayload })
             });
 
             if (!response.ok) throw new Error(response.statusText);
-            const reader = response.body!.getReader();
+            if (!response.body) throw new Error('No response body');
+
+            const reader = response.body.getReader();
             const decoder = new TextDecoder();
             let aiTextAccumulated = '';
             let buffer = '';
@@ -267,23 +215,36 @@ export const ChatPanel: React.FC<ChatPanelProps> = ({ currentUser }) => {
                                 playPCMAudio(data.audio);
                             }
                             if (data.ttsSkipped) {
+                                setToast({ show: true, message: 'AI 语音额度已用尽，已切换至本地语音播报', type: 'error' });
                                 speakWithBrowser(aiTextAccumulated);
                             }
+                            if (data.error) {
+                                setMessages(prev => prev.map(m => m.id === newAiMsgId ? { ...m, text: `⚠️ 错误: ${data.message || '未知错误'}` } : m));
+                            }
                         } catch (e) {}
                     }
                 }
             }
         } catch (error: any) {
-            setMessages(prev => prev.map(m => m.id === newAiMsgId ? { ...m, text: '抱歉，连接断开，请重试。' } : m));
+            setMessages(prev => prev.map(m => m.id === newAiMsgId ? { ...m, text: '抱歉，连接断开或发生错误，请重试。' } : m));
         } finally { setIsChatProcessing(false); }
     };
 
+    const clearHistory = () => {
+        setMessages([{ 
+            id: 'welcome', 
+            role: 'model', 
+            text: '你好！我是你的 AI 智能助教。有什么可以帮你的吗？', 
+            timestamp: Date.now() 
+        }]);
+    };
+
     return (
         <div className="flex-1 flex flex-col max-w-4xl mx-auto w-full min-h-0 relative overflow-hidden h-full">
             {toast.show && <Toast message={toast.message} type={toast.type} onClose={()=>setToast({...toast, show: false})}/>}
             
             <div className="absolute top-2 right-4 z-10">
-                <button onClick={() => setMessages([{ id: 'welcome', role: 'model', text: '你好！我是你的 AI 智能助教。有什么可以帮你的吗？', timestamp: Date.now() }])} className="text-xs text-gray-400 hover:text-red-500 flex items-center gap-1 bg-white/80 p-1.5 rounded-lg border border-transparent hover:border-red-100 transition-all shadow-sm backdrop-blur">
+                <button onClick={clearHistory} className="text-xs text-gray-400 hover:text-red-500 flex items-center gap-1 bg-white/80 p-1.5 rounded-lg border border-transparent hover:border-red-100 transition-all shadow-sm backdrop-blur">
                     <Trash2 size={14}/> 清除记录
                 </button>
             </div>
@@ -296,64 +257,20 @@ export const ChatPanel: React.FC<ChatPanelProps> = ({ currentUser }) => {
                         </div>
                         <div className={`max-w-[80%] p-3 rounded-2xl text-sm overflow-hidden ${msg.role === 'user' ? 'bg-blue-600 text-white rounded-tr-none' : 'bg-white border border-gray-200 text-gray-800 rounded-tl-none shadow-sm'}`}>
                             <div className="markdown-body"><ReactMarkdown remarkPlugins={[remarkGfm]}>{msg.text || ''}</ReactMarkdown></div>
-                            {msg.audio && <button onClick={() => playPCMAudio(msg.audio!)} className="mt-2 flex items-center gap-2 text-xs bg-blue-50 text-blue-600 px-3 py-1.5 rounded-full hover:bg-blue-100 border border-blue-100 transition-colors w-fit"><Volume2 size={14}/> 播放语音 (AI)</button>}
+                            {msg.role === 'model' && !msg.text && isChatProcessing && <div className="flex items-center gap-2 text-gray-400 py-1"><Loader2 className="animate-spin" size={14}/><span className="text-xs">思考中...</span></div>}
+                            {msg.audio ? (<button onClick={() => playPCMAudio(msg.audio!)} className="mt-2 flex items-center gap-2 text-xs bg-blue-50 text-blue-600 px-3 py-1.5 rounded-full hover:bg-blue-100 border border-blue-100 transition-colors w-fit"><Volume2 size={14}/> 播放语音 (AI)</button>) : (msg.role === 'model' && msg.text && !isChatProcessing) && (<button onClick={() => speakWithBrowser(msg.text!)} className="mt-2 flex items-center gap-2 text-xs bg-gray-50 text-gray-600 px-3 py-1.5 rounded-full hover:bg-gray-100 border border-gray-200 transition-colors w-fit"><Volume2 size={14}/> 朗读 (本地)</button>)}
                         </div>
                     </div>
                 ))}
-                {isChatProcessing && (
-                    <div className="flex gap-3">
-                         <div className="w-10 h-10 rounded-full bg-blue-100 text-blue-600 flex items-center justify-center shrink-0">
-                            <Loader2 className="animate-spin" size={20}/>
-                         </div>
-                         <div className="bg-white border border-gray-100 p-3 rounded-2xl rounded-tl-none shadow-sm flex items-center gap-2 text-gray-400 text-xs">
-                             思考中...
-                         </div>
-                    </div>
-                )}
                 <div ref={messagesEndRef} />
             </div>
             
             <div className="p-4 bg-white border-t border-gray-200 shrink-0 z-20">
-                <div className="flex items-center gap-3 max-w-4xl mx-auto bg-gray-50 p-2 rounded-2xl border border-gray-200">
-                    {isChatRecording && (
-                        <div className="flex items-center gap-1.5 px-3 py-1 bg-red-100 text-red-600 rounded-full animate-pulse text-[10px] font-bold shrink-0">
-                            <div className="w-2 h-2 bg-red-600 rounded-full"></div>
-                            {isWebSpeechListening ? '正在识别' : '正在录制'}
-                        </div>
-                    )}
-
-                    <input 
-                        ref={inputRef}
-                        className="flex-1 bg-transparent border-none outline-none px-3 text-sm py-2" 
-                        placeholder={isChatRecording ? "正在倾听..." : "输入问题..."}
-                        value={textInput} 
-                        onChange={e => setTextInput(e.target.value)} 
-                        onKeyDown={e => e.key === 'Enter' && !isChatProcessing && handleChatSubmit(textInput)}
-                        disabled={isChatProcessing}
-                    />
-
-                    <div className="flex items-center gap-2 shrink-0">
-                        <button 
-                            onMouseDown={startRecording} 
-                            onMouseUp={stopRecording} 
-                            onTouchStart={startRecording} 
-                            onTouchEnd={stopRecording}
-                            className={`p-3 rounded-xl transition-all ${isChatRecording ? 'bg-red-500 scale-110 shadow-lg text-white ring-4 ring-red-100' : 'bg-gray-100 text-gray-500 hover:bg-gray-200'}`}
-                            title="按住说话"
-                        >
-                            {isChatRecording ? <StopCircle size={22}/> : <Mic size={22}/>}
-                        </button>
-
-                        <button 
-                            onClick={() => handleChatSubmit(textInput)} 
-                            className={`p-3 rounded-xl transition-all ${!textInput.trim() || isChatProcessing ? 'bg-gray-100 text-gray-300' : 'bg-blue-600 text-white hover:bg-blue-700 shadow-md'}`} 
-                            disabled={!textInput.trim() || isChatProcessing}
-                        >
-                            <Send size={22}/>
-                        </button>
-                    </div>
+                <div className="flex items-center gap-2 max-w-4xl mx-auto bg-gray-100 p-1.5 rounded-full border border-gray-200">
+                    <button onClick={() => setInputMode(inputMode === 'text' ? 'audio' : 'text')} className="p-2 rounded-full hover:bg-white text-gray-500 transition-colors">{inputMode === 'text' ? <Mic size={20}/> : <Square size={20}/>}</button>
+                    {inputMode === 'text' ? (<input className="flex-1 bg-transparent border-none outline-none px-2 text-sm" placeholder="输入问题..." value={textInput} onChange={e => setTextInput(e.target.value)} onKeyDown={e => e.key === 'Enter' && handleChatSubmit(textInput)}/>) : (<div className="flex-1 text-center text-sm font-medium text-blue-600 animate-pulse">{isChatRecording ? '正在录音... 点击停止' : '点击麦克风开始说话'}</div>)}
+                    {inputMode === 'text' ? (<button onClick={() => handleChatSubmit(textInput)} className="p-2 bg-blue-600 rounded-full text-white hover:bg-blue-700 disabled:opacity-50" disabled={!textInput.trim() || isChatProcessing}><Send size={18}/></button>) : (<button onMouseDown={startRecording} onMouseUp={stopRecording} onTouchStart={startRecording} onTouchEnd={stopRecording} className={`p-3 rounded-full text-white transition-all ${isChatRecording ? 'bg-red-500 scale-110 shadow-lg ring-4 ring-red-200' : 'bg-blue-600 hover:bg-blue-700'}`}>{isChatRecording ? <StopCircle size={20}/> : <Mic size={20}/>}</button>)}
                 </div>
-                <div className="text-[10px] text-gray-400 text-center mt-2">支持文字输入或按住麦克风图标进行语音提问</div>
             </div>
         </div>
     );

models.js

@@ -123,7 +123,6 @@ const ConfigSchema = new mongoose.Schema({
     aiTotalCalls: { type: Number, default: 0 },
     aiProviderOrder: { type: [String], default: ['GEMINI', 'OPENROUTER', 'GEMMA'] }, // NEW
     periodConfig: [{ period: Number, name: String, startTime: String, endTime: String }],
-    hfToken: String, // NEW: Hugging Face Token for Fallback STT
     apiKeys: {
         gemini: [String],
         openrouter: [String]

server.js

@@ -73,19 +73,22 @@ wss.on('connection', async (ws, req) => {
     let isGeminiConnected = false;
 
     try {
-        // 1. Fixed: Obtain API key exclusively from environment variable as per guidelines
-        const apiKey = process.env.API_KEY;
+        // 1. Get API Key (Server-side Config)
+        const config = await ConfigModel.findOne({ key: 'main' });
+        let apiKey = process.env.API_KEY;
+        if (config && config.apiKeys && config.apiKeys.gemini && config.apiKeys.gemini.length > 0) {
+            apiKey = config.apiKeys.gemini[0]; 
+        }
 
         if (!apiKey) {
-            console.error('[Live] Error: API_KEY environment variable is not configured.');
-            ws.send(JSON.stringify({ type: 'error', message: 'Server API Key is missing in environment' }));
+            ws.send(JSON.stringify({ type: 'error', message: 'No Server API Key Configured' }));
             ws.close();
             return;
         }
 
         // 2. Initialize Gemini SDK
         const { GoogleGenAI } = await import("@google/genai");
-        const client = new GoogleGenAI({ apiKey: process.env.API_KEY });
+        const client = new GoogleGenAI({ apiKey });
 
         // 3. Connect to Gemini (Isolated Session per Connection)
         geminiSession = await client.live.connect({