([]);
+
+ useEffect(() => {
+ fetchDevices();
+ fetchLogs();
+ }, []);
+
+ const fetchDevices = async () => {
+ try {
+ const res = await axios.get('http://localhost:8000/api/devices/');
+ setDevices(res.data);
+ } catch (e) {
+ console.error(e);
+ }
+ };
+
+ const fetchLogs = async () => {
+ try {
+ const res = await axios.get('http://localhost:8000/api/logs/');
+ setLogs(res.data);
+ } catch (e) {
+ console.error(e);
+ }
+ };
+
+ return (
+
+
+
+ {isAdmin ? 'Admin Dashboard' : `Welcome, ${user?.username}`}
+
+
+
+
+
+
+ Devices
+
+
+
+
+ Name
+ ID
+ Status
+ Last Seen
+
+
+
+ {devices.map((device) => (
+
+ {device.name}
+ {device.device_id}
+ {device.is_active ? 'Active' : 'Inactive'}
+ {new Date(device.last_seen).toLocaleString()}
+
+ ))}
+
+
+
+
+
+
+ Recent Logs
+
+
+
+
+ Time
+ Level
+ Message
+
+
+
+ {logs.slice(0, 10).map((log) => (
+
+ {new Date(log.timestamp).toLocaleTimeString()}
+ {log.level}
+ {log.message}
+
+ ))}
+
+
+
+
+
+
+ );
+}
diff --git a/ineedyou/full_stack_web/frontend/src/pages/Login.tsx b/ineedyou/full_stack_web/frontend/src/pages/Login.tsx
new file mode 100644
index 0000000..f8bdab4
--- /dev/null
+++ b/ineedyou/full_stack_web/frontend/src/pages/Login.tsx
@@ -0,0 +1,53 @@
+import { useState } from 'react';
+import { useNavigate } from 'react-router-dom';
+import { useAuth } from '../context/AuthContext';
+import { Box, Button, TextField, Typography, Container, Paper } from '@mui/material';
+
+export default function Login() {
+ const { login } = useAuth();
+ const navigate = useNavigate();
+ const [username, setUsername] = useState('');
+ const [password, setPassword] = useState('');
+ const [error, setError] = useState('');
+
+ const handleSubmit = async (e: React.FormEvent) => {
+ e.preventDefault();
+ const success = await login(username, password);
+ if (!success) {
+ setError('Invalid credentials');
+ } else {
+ // Login successful, redirect to dashboard
+ navigate('/');
+ }
+ };
+
+ return (
+
+
+ Sign in
+
+ setUsername(e.target.value)}
+ />
+ setPassword(e.target.value)}
+ />
+ {error && {error}}
+
+
+
+
+ );
+}
diff --git a/ineedyou/full_stack_web/frontend/tsconfig.json b/ineedyou/full_stack_web/frontend/tsconfig.json
new file mode 100644
index 0000000..a7fc6fb
--- /dev/null
+++ b/ineedyou/full_stack_web/frontend/tsconfig.json
@@ -0,0 +1,25 @@
+{
+ "compilerOptions": {
+ "target": "ES2020",
+ "useDefineForClassFields": true,
+ "lib": ["ES2020", "DOM", "DOM.Iterable"],
+ "module": "ESNext",
+ "skipLibCheck": true,
+
+ /* Bundler mode */
+ "moduleResolution": "bundler",
+ "allowImportingTsExtensions": true,
+ "resolveJsonModule": true,
+ "isolatedModules": true,
+ "noEmit": true,
+ "jsx": "react-jsx",
+
+ /* Linting */
+ "strict": true,
+ "noUnusedLocals": true,
+ "noUnusedParameters": true,
+ "noFallthroughCasesInSwitch": true
+ },
+ "include": ["src"],
+ "references": [{ "path": "./tsconfig.node.json" }]
+}
diff --git a/ineedyou/full_stack_web/frontend/tsconfig.node.json b/ineedyou/full_stack_web/frontend/tsconfig.node.json
new file mode 100644
index 0000000..42872c5
--- /dev/null
+++ b/ineedyou/full_stack_web/frontend/tsconfig.node.json
@@ -0,0 +1,10 @@
+{
+ "compilerOptions": {
+ "composite": true,
+ "skipLibCheck": true,
+ "module": "ESNext",
+ "moduleResolution": "bundler",
+ "allowSyntheticDefaultImports": true
+ },
+ "include": ["vite.config.ts"]
+}
diff --git a/ineedyou/full_stack_web/frontend/vite.config.ts b/ineedyou/full_stack_web/frontend/vite.config.ts
new file mode 100644
index 0000000..5a33944
--- /dev/null
+++ b/ineedyou/full_stack_web/frontend/vite.config.ts
@@ -0,0 +1,7 @@
+import { defineConfig } from 'vite'
+import react from '@vitejs/plugin-react'
+
+// https://vitejs.dev/config/
+export default defineConfig({
+ plugins: [react()],
+})
diff --git a/ineedyou/full_stack_web/renew.md b/ineedyou/full_stack_web/renew.md
new file mode 100644
index 0000000..071688d
--- /dev/null
+++ b/ineedyou/full_stack_web/renew.md
@@ -0,0 +1,33 @@
+# 更新日志 (Renew Log)
+
+本文件用于记录每次代码更新的内容，以及你需要执行的操作。
+
+## 2026-02-28 (修复前端登录成功后不跳转的问题，以及关于 API 401 的说明)
+
+### 我做了什么 (What I did):
+1. **解释后端的 401 状态**:
+ 你截图展示了 `http://localhost:8000/api/` 显示 `HTTP 401 Unauthorized`，这其实是个**天大的好消息**！这说明后端的 Django 服务器已经**完全正常运行**了，并且它的安全防护机制生效了（因为你直接在浏览器访问，没有携带 Token，所以它拒绝了你）。后端问题已经彻底解决。
+2. **修复前端登录按钮没反应的 Bug**:
+ 你输入了正确的账号密码点击登录后，页面没有任何反应，也没有报错。这是因为前端在接收到后端发来的 "登录成功" 信号后，**缺少了一行跳转页面的代码**。导致它虽然成功拿到了 Token，但就傻傻地停在登录页。我已经给 `frontend/src/pages/Login.tsx` 添加了跳转回首页（Dashboard）的逻辑。
+
+> **关于时间**: 哈哈，抱歉，之前我确实忘了看系统时钟，随手写了个 2024 年。现在已经矫正为 2026 年了。
+
+### 你需要做什么 (What you need to do):
+
+这次修改的是前端的 React 代码，如果你在 `docker-compose.yml` 中配置了热更新或者挂载，可能刷新页面就行了。但为了确保拿到最新的构建文件，请执行一次完整的重启：
+
+1. **拉取最新代码**：
+ ```bash
+ git pull
+ ```
+
+2. **重新构建前端并启动服务**：
+ ```bash
+ docker-compose up -d --build frontend
+ ```
+ *(这里加上了 `frontend` 参数，代表只重新构建前端，后端已经是完美的了，不需要再动)*
+
+3. **终极验证**：
+ - 打开 `http://localhost:3000/login`。
+ - 输入 `admin` 和 `admin123`，点击 SIGN IN。
+ - 网页应该会瞬间跳转到 Dashboard 仪表盘页面！
diff --git a/ineedyou/ocr_test/README.md b/ineedyou/ocr_test/README.md
new file mode 100644
index 0000000..7d300f4
--- /dev/null
+++ b/ineedyou/ocr_test/README.md
@@ -0,0 +1,55 @@
+# OCR Test with ESP32 Hardware
+
+This folder contains a simplified server-side script (`ocr_server.py`) to test OCR functionality using the ESP32-CAM hardware.
+
+## Prerequisites
+
+1. **Python Environment**: Ensure you have Python 3.9+ installed.
+2. **Dependencies**: Install the required packages using `pip`:
+ ```bash
+ pip install -r requirements.txt
+ ```
+ (Note: `requirements.txt` should contain `fastapi`, `uvicorn`, `openai`, `requests`, `python-dotenv`)
+
+3. **API Key**: You **must** set the `DASHSCOPE_API_KEY` environment variable.
+ - Create a `.env` file in this directory or set it in your shell:
+ ```bash
+ export DASHSCOPE_API_KEY="sk-your-api-key"
+ ```
+
+4. **ESP32 Firmware**: The ESP32 should be flashed with the firmware located in the root `compile/` directory of this repository. Specifically, `compile/compile.ino`.
+ - Open `compile/compile.ino` in Arduino IDE.
+ - Ensure `SERVER_HOST` is set to your computer's IP address (where you will run `ocr_server.py`).
+ - Ensure `SERVER_PORT` matches the port used by `ocr_server.py` (default: `8081`).
+ - Flash the firmware to your ESP32-CAM.
+
+## How to Run
+
+1. **Start the OCR Server**:
+ Run the `ocr_server.py` script. This will start a WebSocket server listening for video frames from the ESP32.
+ ```bash
+ python ocr_server.py
+ ```
+ By default, it listens on `0.0.0.0:8081`.
+
+2. **Power on the ESP32**:
+ Connect the ESP32 to power. It should automatically connect to the server's WebSocket endpoint (`/ws/camera`).
+
+3. **Observe OCR Results**:
+ - The server will receive video frames from the ESP32.
+ - Every 5 seconds (configurable via `OCR_INTERVAL` in `ocr_server.py`), it will capture the latest frame.
+ - It sends this frame to the Qwen-Omni API for OCR processing.
+ - The recognized text will be printed directly to the console running `ocr_server.py`.
+
+## Files in this Folder
+
+- `ocr_server.py`: The main server script. Handles WebSocket connection and triggers OCR.
+- `omni_client.py`: Client library for interacting with the Qwen-Omni multimodal model (async version).
+- `test_ocr.py`: A standalone script to test OCR with a static/downloaded image (no hardware required).
+- `requirements.txt`: Python dependencies.
+
+## Troubleshooting
+
+- **Connection Failed**: Check if the ESP32 and your computer are on the same Wi-Fi network. Check if `SERVER_HOST` in `compile.ino` is correct.
+- **API Key Error**: Ensure `DASHSCOPE_API_KEY` is set correctly. The script will skip OCR if the key is missing.
+- **No Video**: Check the ESP32 camera connection and serial output for errors.
diff --git a/ineedyou/ocr_test/ocr_server.py b/ineedyou/ocr_test/ocr_server.py
new file mode 100644
index 0000000..d669955
--- /dev/null
+++ b/ineedyou/ocr_test/ocr_server.py
@@ -0,0 +1,103 @@
+import asyncio
+import base64
+import os
+import time
+import uvicorn
+from fastapi import FastAPI, WebSocket, WebSocketDisconnect
+from fastapi.responses import HTMLResponse
+import omni_client
+
+# ===== 配置 =====
+HOST = "0.0.0.0"
+PORT = 8081
+OCR_INTERVAL = 5.0 # 每隔5秒进行一次OCR识别
+
+# 从环境变量获取 API Key，必须设置
+API_KEY = os.getenv("DASHSCOPE_API_KEY")
+if not API_KEY:
+ try:
+ from dotenv import load_dotenv
+ load_dotenv()
+ API_KEY = os.getenv("DASHSCOPE_API_KEY")
+ except ImportError:
+ pass
+
+if not API_KEY:
+ print("Warning: DASHSCOPE_API_KEY not set. OCR will fail.")
+
+# ===== FastAPI =====
+app = FastAPI()
+
+# ===== 全局变量 =====
+last_ocr_time = 0
+current_frame = None
+
+@app.get("/")
+async def root():
+ return HTMLResponse("OCR Test Server is Running
Connect your ESP32 to ws://SERVER_IP:8081/ws/camera
")
+
+@app.websocket("/ws/camera")
+async def websocket_endpoint(websocket: WebSocket):
+ global last_ocr_time, current_frame
+ await websocket.accept()
+ print(f"[SERVER] ESP32 Connected from {websocket.client}")
+
+ try:
+ while True:
+ # 接收二进制数据 (JPEG)
+ data = await websocket.receive_bytes()
+ current_frame = data
+
+ # 检查是否到了OCR识别的时间
+ now = time.time()
+ if now - last_ocr_time > OCR_INTERVAL:
+ last_ocr_time = now
+
+ # 启动异步OCR任务，不阻塞视频流接收
+ asyncio.create_task(process_ocr(data))
+
+ except WebSocketDisconnect:
+ print("[SERVER] ESP32 Disconnected")
+ except Exception as e:
+ print(f"[SERVER] Error: {e}")
+
+async def process_ocr(image_bytes):
+ if not API_KEY:
+ print("[OCR] Skipping: API Key not set.")
+ return
+
+ print(f"\n[OCR] Capture frame ({len(image_bytes)} bytes), sending to Qwen-Omni...")
+
+ try:
+ # 编码为Base64
+ encoded_string = base64.b64encode(image_bytes).decode('utf-8')
+
+ # 构建请求
+ content_list = [
+ {
+ "type": "image_url",
+ "image_url": {"url": f"data:image/jpeg;base64,{encoded_string}"}
+ },
+ {"type": "text", "text": "请读取这张图片里的所有文字，并直接输出原文，不要加任何修饰。"}
+ ]
+
+ print("[OCR] Waiting for response...")
+ full_text = ""
+ # 使用 async for 迭代异步生成器
+ async for piece in omni_client.stream_chat(content_list, voice="Cherry", audio_format="wav"):
+ if piece.text_delta:
+ print(piece.text_delta, end="", flush=True)
+ full_text += piece.text_delta
+
+ print("\n[OCR] Done.")
+
+ except Exception as e:
+ print(f"[OCR] Error processing image: {e}")
+
+if __name__ == "__main__":
+ if not API_KEY:
+ print("Error: DASHSCOPE_API_KEY not set. Please set it in environment variables or .env file.")
+ # exit(1) # 不强制退出，允许仅作为视频流服务器运行
+
+ print(f"Starting OCR Test Server on {HOST}:{PORT}")
+ uvicorn.run(app, host=HOST, port=PORT)
diff --git a/ineedyou/ocr_test/omni_client.py b/ineedyou/ocr_test/omni_client.py
new file mode 100644
index 0000000..6b17e66
--- /dev/null
+++ b/ineedyou/ocr_test/omni_client.py
@@ -0,0 +1,82 @@
+# omni_client.py
+# -*- coding: utf-8 -*-
+import os
+from typing import AsyncGenerator, Dict, Any, List, Optional
+
+from openai import AsyncOpenAI
+
+# ===== OpenAI 兼容（达摩院 DashScope 兼容模式）=====
+# 必须从环境变量获取 API Key，不再硬编码
+API_KEY = os.getenv("DASHSCOPE_API_KEY")
+if not API_KEY:
+ # 尝试从 .env 文件加载 (如果存在)
+ try:
+ from dotenv import load_dotenv
+ load_dotenv()
+ API_KEY = os.getenv("DASHSCOPE_API_KEY")
+ except ImportError:
+ pass
+
+if not API_KEY:
+ raise RuntimeError("未设置 DASHSCOPE_API_KEY 环境变量")
+
+QWEN_MODEL = "qwen-omni-turbo"
+
+# 兼容模式 (使用异步客户端)
+oai_client = AsyncOpenAI(
+ api_key=API_KEY,
+ base_url="https://dashscope.aliyuncs.com/compatible-mode/v1",
+)
+
+class OmniStreamPiece:
+ """对外的统一增量数据：text/audio 二选一或同时。"""
+ def __init__(self, text_delta: Optional[str] = None, audio_b64: Optional[str] = None):
+ self.text_delta = text_delta
+ self.audio_b64 = audio_b64
+
+async def stream_chat(
+ content_list: List[Dict[str, Any]],
+ voice: str = "Cherry",
+ audio_format: str = "wav",
+) -> AsyncGenerator[OmniStreamPiece, None]:
+ """
+ 发起一轮 Omni-Turbo ChatCompletions 流式对话：
+ - content_list: OpenAI chat 的 content，多模态（image_url/text）
+ - 以 stream=True 返回
+ - 增量产出：OmniStreamPiece(text_delta=?, audio_b64=?)
+ """
+ # 使用 await 调用异步客户端
+ completion = await oai_client.chat.completions.create(
+ model=QWEN_MODEL,
+ messages=[{"role": "user", "content": content_list}],
+ modalities=["text", "audio"],
+ audio={"voice": voice, "format": audio_format},
+ stream=True,
+ stream_options={"include_usage": True},
+ )
+
+ # 异步迭代
+ async for chunk in completion:
+ text_delta: Optional[str] = None
+ audio_b64: Optional[str] = None
+
+ if getattr(chunk, "choices", None):
+ c0 = chunk.choices[0]
+ delta = getattr(c0, "delta", None)
+ # 文本增量
+ if delta and getattr(delta, "content", None):
+ piece = delta.content
+ if piece:
+ text_delta = piece
+ # 音频分片
+ if delta and getattr(delta, "audio", None):
+ aud = delta.audio
+ audio_b64 = aud.get("data") if isinstance(aud, dict) else getattr(aud, "data", None)
+ if audio_b64 is None:
+ msg = getattr(c0, "message", None)
+ if msg and getattr(msg, "audio", None):
+ ma = msg.audio
+ audio_b64 = ma.get("data") if isinstance(ma, dict) else getattr(ma, "data", None)
+
+ if (text_delta is not None) or (audio_b64 is not None):
+ yield OmniStreamPiece(text_delta=text_delta, audio_b64=audio_b64)
diff --git a/ineedyou/ocr_test/requirements.txt b/ineedyou/ocr_test/requirements.txt
new file mode 100644
index 0000000..0781b8c
--- /dev/null
+++ b/ineedyou/ocr_test/requirements.txt
@@ -0,0 +1,6 @@
+openai
+requests
+fastapi
+uvicorn
+python-dotenv
+websockets
\ No newline at end of file
diff --git a/ineedyou/ocr_test/test_ocr.py b/ineedyou/ocr_test/test_ocr.py
new file mode 100644
index 0000000..6cc4be7
--- /dev/null
+++ b/ineedyou/ocr_test/test_ocr.py
@@ -0,0 +1,75 @@
+import asyncio
+import base64
+import os
+import requests
+from omni_client import stream_chat, OmniStreamPiece
+
+# Use a dummy image with text
+IMAGE_URL = "https://dummyimage.com/600x400/000/fff&text=HELLO+WORLD+OCR+TEST"
+IMAGE_PATH = "sample_text.png"
+
+# Ensure API Key is set
+if not os.getenv("DASHSCOPE_API_KEY"):
+ print("Error: DASHSCOPE_API_KEY environment variable is not set.")
+ print("Please set it before running this script.")
+ # We don't exit here because omni_client might have loaded it from .env
+
+def download_image():
+ if not os.path.exists(IMAGE_PATH):
+ print(f"Downloading sample image from {IMAGE_URL}...")
+ try:
+ headers = {'User-Agent': 'Mozilla/5.0'}
+ response = requests.get(IMAGE_URL, headers=headers, timeout=10)
+ if response.status_code == 200:
+ with open(IMAGE_PATH, 'wb') as f:
+ f.write(response.content)
+ print(f"Download complete: {IMAGE_PATH}")
+ return True
+ else:
+ print(f"Failed to download image: {response.status_code}")
+ return False
+ except Exception as e:
+ print(f"Error downloading image: {e}")
+ return False
+ return True
+
+async def main():
+ if not download_image():
+ print("Skipping OCR test because image download failed.")
+ return
+
+ try:
+ with open(IMAGE_PATH, "rb") as image_file:
+ encoded_string = base64.b64encode(image_file.read()).decode('utf-8')
+ except Exception as e:
+ print(f"Error reading image file: {e}")
+ return
+
+ # Construct the multimodal message
+ content_list = [
+ {
+ "type": "image_url",
+ "image_url": {"url": f"data:image/png;base64,{encoded_string}"}
+ },
+ {"type": "text", "text": "请读取这张图片里的所有文字，并直接输出原文，不要加任何修饰。"}
+ ]
+
+ print("Sending image to Qwen-Omni for OCR...")
+ print("-" * 40)
+
+ full_text = ""
+ try:
+ # Iterate over the async generator
+ async for piece in stream_chat(content_list, voice="Cherry", audio_format="wav"):
+ if piece.text_delta:
+ print(piece.text_delta, end="", flush=True)
+ full_text += piece.text_delta
+ except Exception as e:
+ print(f"\nError during API call: {e}")
+ print("Make sure DASHSCOPE_API_KEY is valid.")
+
+ print("\n" + "-" * 40)
+ print("OCR Test Finished.")
+
+if __name__ == "__main__":
+ asyncio.run(main())