diff --git a/DESIGN.md b/DESIGN.md
index 576c75c..84b08f6 100644
--- a/DESIGN.md
+++ b/DESIGN.md
@@ -309,77 +309,87 @@ Store 只负责：
 
 ```
 ProxyPool/
-├── api/                          # FastAPI 入口和路由
-│   ├── __init__.py
-│   ├── main.py                   # 应用工厂
-│   ├── lifespan.py               # 生命周期管理
-│   ├── deps.py                   # 依赖注入
-│   ├── errors.py                 # 统一异常
-│   └── routes/
-│       ├── __init__.py
-│       ├── proxies.py
-│       ├── plugins.py
-│       ├── scheduler.py
-│       └── settings.py
+├── main.py                       # 项目入口
+├── requirements.txt              # Python 依赖
+├── .env.example                  # 环境变量示例
 │
-├── core/                         # 基础设施
-│   ├── __init__.py
-│   ├── config.py                 # Pydantic Settings
-│   ├── log.py                    # 日志
-│   ├── db.py                     # 数据库连接池/上下文
-│   └── exceptions.py             # 业务异常
-│
-├── models/                       # 数据模型
-│   ├── __init__.py
-│   ├── schemas.py                # Pydantic 模型
-│   └── domain.py                 # 领域模型（ProxyRaw, PluginInfo 等）
-│
-├── repositories/                 # 数据访问层
-│   ├── __init__.py
-│   └── proxy_repo.py             # ProxyRepository
-│
-├── services/                     # 业务逻辑层
-│   ├── __init__.py
-│   ├── proxy_service.py
-│   ├── plugin_service.py
-│   ├── scheduler_service.py
-│   └── validator_service.py
-│
-├── core/                         # 任务与插件系统
-│   ├── plugin_system/
+├── app/                          # 后端代码
+│   ├── api/                      # FastAPI 入口和路由
 │   │   ├── __init__.py
-│   │   ├── base.py               # BaseCrawlerPlugin
-│   │   └── registry.py           # 插件注册中心
-│   └── tasks/
+│   │   ├── main.py               # 应用工厂
+│   │   ├── lifespan.py           # 生命周期管理
+│   │   ├── deps.py               # 依赖注入
+│   │   ├── errors.py             # 统一异常
+│   │   └── routes/
+│   │       ├── __init__.py
+│   │       ├── proxies.py
+│   │       ├── plugins.py
+│   │       ├── scheduler.py
+│   │       └── settings.py
+│   │
+│   ├── core/                     # 基础设施
+│   │   ├── __init__.py
+│   │   ├── config.py             # Pydantic Settings
+│   │   ├── log.py                # 日志
+│   │   ├── db.py                 # 数据库连接池/上下文
+│   │   ├── exceptions.py         # 业务异常
+│   │   ├── plugin_system/        # 插件系统
+│   │   │   ├── __init__.py
+│   │   │   ├── base.py           # BaseCrawlerPlugin
+│   │   │   └── registry.py       # 插件注册中心
+│   │   └── tasks/                # 任务队列
+│   │       ├── __init__.py
+│   │       └── queue.py          # ValidationQueue
+│   │
+│   ├── models/                   # 数据模型
+│   │   ├── __init__.py
+│   │   ├── schemas.py            # Pydantic 模型
+│   │   └── domain.py             # 领域模型
+│   │
+│   ├── repositories/             # 数据访问层
+│   │   ├── __init__.py
+│   │   ├── proxy_repo.py
+│   │   ├── settings_repo.py
+│   │   └── task_repo.py
+│   │
+│   ├── services/                 # 业务逻辑层
+│   │   ├── __init__.py
+│   │   ├── proxy_service.py
+│   │   ├── plugin_service.py
+│   │   ├── scheduler_service.py
+│   │   └── validator_service.py
+│   │
+│   └── plugins/                  # 爬虫插件
 │       ├── __init__.py
-│       ├── queue.py              # ValidationQueue
-│       └── workers.py            # Worker Pool
+│       ├── base.py               # 通用抓取基类
+│       ├── fate0.py
+│       ├── kuaidaili.py
+│       ├── ip3366.py
+│       ├── ip89.py
+│       ├── speedx.py
+│       ├── yundaili.py
+│       ├── proxylist_download.py
+│       └── proxyscrape.py
 │
-├── plugins/                      # 爬虫插件
-│   ├── __init__.py
-│   ├── base.py                   # 通用抓取基类（HTTP 请求封装）
-│   ├── fate0.py
-│   ├── proxylist_download.py
-│   └── ...
-│
-├── frontend/                     # Vue3 前端
-│   └── src/
-│       ├── services/             # 新增
-│       ├── stores/
-│       ├── api/
-│       └── ...
+├── WebUI/                        # Vue3 前端
+│   ├── src/
+│   │   ├── api/                  # API 封装
+│   │   ├── stores/               # Pinia 状态管理
+│   │   ├── views/                # 页面组件
+│   │   ├── router/               # 路由配置
+│   │   ├── components/           # 通用组件
+│   │   └── style.css             # 全局样式
+│   ├── index.html
+│   └── package.json
 │
 ├── tests/                        # 测试目录
 │   ├── conftest.py
 │   ├── unit/
 │   └── integration/
 │
-├── script/
-├── data/
-├── db/
-├── logs/
-├── requirements.txt
-├── .env.example
+├── script/                       # 启动脚本
+├── db/                           # 数据存储
+├── logs/                         # 日志文件
 └── DESIGN.md                     # 本文档
 ```
 
@@ -426,11 +436,11 @@ ProxyPool/
 
 假设要添加一个名为 `mynewsource` 的爬虫：
 
-**Step 1**: 创建文件 `plugins/mynewsource.py`
+**Step 1**: 创建文件 `app/plugins/mynewsource.py`
 
 ```python
-from core.plugin_system import BaseCrawlerPlugin, ProxyRaw
-from plugins.base import BaseHTTPPlugin  # 可选：如果基于 HTTP 爬取
+from app.core.plugin_system import BaseCrawlerPlugin, ProxyRaw
+from app.plugins.base import BaseHTTPPlugin  # 可选：如果基于 HTTP 爬取
 
 class MyNewSourcePlugin(BaseHTTPPlugin):
     name = "mynewsource"
@@ -450,11 +460,11 @@ class MyNewSourcePlugin(BaseHTTPPlugin):
         return results
 ```
 
-**Step 2**: 在 `plugins/__init__.py` 中注册
+**Step 2**: 在 `app/plugins/__init__.py` 中注册
 
 ```python
 from .mynewsource import MyNewSourcePlugin
-from core.plugin_system import registry
+from app.core.plugin_system import registry
 
 registry.register(MyNewSourcePlugin)
 ```
diff --git a/README.md b/README.md
index ca1069c..f69e1e3 100644
--- a/README.md
+++ b/README.md
@@ -36,7 +36,7 @@ pip install -r requirements.txt
 ### 2. 安装前端依赖
 
 ```bash
-cd frontend
+cd WebUI
 npm install
 ```
 
@@ -58,7 +58,7 @@ python api_server.py
 
 **启动前端服务**（终端 2）
 ```bash
-cd frontend
+cd WebUI
 npm run dev
 ```
 
@@ -77,32 +77,35 @@ stop.bat
 
 ```
 ProxyPool/
-├── api_server.py          # FastAPI 后端服务器
-├── config.py              # 配置文件
+├── main.py                # 项目入口
 ├── requirements.txt       # Python 依赖
 ├── .env.example          # 环境变量示例
 │
-├── script/             # 启动脚本
-│   ├── start.bat       # Windows 启动脚本
-│   └── stop.bat       # Windows 停止脚本
+├── app/                # 后端代码
+│   ├── api/            # FastAPI 路由
+│   │   ├── main.py     # 应用工厂
+│   │   ├── routes/     # API 路由
+│   │   ├── deps.py     # 依赖注入
+│   │   └── ...
+│   ├── core/           # 核心模块
+│   │   ├── config.py   # 配置管理
+│   │   ├── db.py       # 数据库连接
+│   │   ├── log.py      # 日志配置
+│   │   ├── plugin_system/  # 插件系统
+│   │   └── tasks/      # 任务队列
+│   ├── models/         # 数据模型
+│   ├── repositories/   # 数据访问层
+│   ├── services/       # 业务逻辑层
+│   └── plugins/        # 代理源插件
+│       ├── fate0.py    # Fate0 代理源
+│       ├── ip3366.py   # IP3366 代理源
+│       ├── ip89.py     # IP89 代理源
+│       ├── kuaidaili.py # 快代理源
+│       ├── yundaili.py      # 云代理源
+│       ├── speedx.py        # SpeedX 代理源
+│       └── proxylist_download.py # ProxyList 代理源
 │
-├── core/             # 核心模块
-│   ├── crawler.py     # 爬虫基类
-│   ├── validator.py   # 代理验证器
-│   ├── sqlite.py      # 数据库管理
-│   ├── plugin_manager.py # 插件管理器
-│   └── log.py        # 日志配置
-│
-├── plugins/          # 代理源插件
-│   ├── fate0.py      # Fate0 代理源
-│   ├── ip3366.py    # IP3366 代理源
-│   ├── ip89.py      # IP89 代理源
-│   ├── kuaidaili.py # 快代理源
-│   ├── yundaili.py  # 云代理源
-│   ├── speedx.py     # SpeedX 代理源
-│   └── proxylist_download.py # ProxyList 代理源
-│
-├── frontend/         # Vue3 前端
+├── WebUI/            # Vue3 前端
 │   ├── src/
 │   │   ├── api/       # API 封装
 │   │   ├── stores/    # Pinia 状态管理
@@ -113,6 +116,10 @@ ProxyPool/
 │   ├── index.html
 │   └── package.json
 │
+├── script/           # 启动脚本
+│   ├── start.bat     # Windows 启动脚本
+│   └── stop.bat      # Windows 停止脚本
+│
 └── db/               # 数据存储目录
     └── proxies.sqlite  # SQLite 数据库
 ```
diff --git a/frontend/.eslintrc.json b/WebUI/.eslintrc.json
similarity index 100%
rename from frontend/.eslintrc.json
rename to WebUI/.eslintrc.json
diff --git a/frontend/.gitignore b/WebUI/.gitignore
similarity index 100%
rename from frontend/.gitignore
rename to WebUI/.gitignore
diff --git a/frontend/.prettierrc.json b/WebUI/.prettierrc.json
similarity index 100%
rename from frontend/.prettierrc.json
rename to WebUI/.prettierrc.json
diff --git a/frontend/index.html b/WebUI/index.html
similarity index 100%
rename from frontend/index.html
rename to WebUI/index.html
diff --git a/frontend/package.json b/WebUI/package.json
similarity index 100%
rename from frontend/package.json
rename to WebUI/package.json
diff --git a/frontend/public/vite.svg b/WebUI/public/vite.svg
similarity index 100%
rename from frontend/public/vite.svg
rename to WebUI/public/vite.svg
diff --git a/frontend/src/App.vue b/WebUI/src/App.vue
similarity index 100%
rename from frontend/src/App.vue
rename to WebUI/src/App.vue
diff --git a/frontend/src/api/index.js b/WebUI/src/api/index.js
similarity index 100%
rename from frontend/src/api/index.js
rename to WebUI/src/api/index.js
diff --git a/frontend/src/components/PageHeader.vue b/WebUI/src/components/PageHeader.vue
similarity index 100%
rename from frontend/src/components/PageHeader.vue
rename to WebUI/src/components/PageHeader.vue
diff --git a/frontend/src/components/ProtocolChart.vue b/WebUI/src/components/ProtocolChart.vue
similarity index 100%
rename from frontend/src/components/ProtocolChart.vue
rename to WebUI/src/components/ProtocolChart.vue
diff --git a/frontend/src/components/QuickActions.vue b/WebUI/src/components/QuickActions.vue
similarity index 100%
rename from frontend/src/components/QuickActions.vue
rename to WebUI/src/components/QuickActions.vue
diff --git a/frontend/src/components/StatCard.vue b/WebUI/src/components/StatCard.vue
similarity index 100%
rename from frontend/src/components/StatCard.vue
rename to WebUI/src/components/StatCard.vue
diff --git a/frontend/src/main.js b/WebUI/src/main.js
similarity index 100%
rename from frontend/src/main.js
rename to WebUI/src/main.js
diff --git a/frontend/src/router/index.js b/WebUI/src/router/index.js
similarity index 100%
rename from frontend/src/router/index.js
rename to WebUI/src/router/index.js
diff --git a/frontend/src/services/pluginService.js b/WebUI/src/services/pluginService.js
similarity index 100%
rename from frontend/src/services/pluginService.js
rename to WebUI/src/services/pluginService.js
diff --git a/frontend/src/services/proxyService.js b/WebUI/src/services/proxyService.js
similarity index 100%
rename from frontend/src/services/proxyService.js
rename to WebUI/src/services/proxyService.js
diff --git a/frontend/src/services/schedulerService.js b/WebUI/src/services/schedulerService.js
similarity index 100%
rename from frontend/src/services/schedulerService.js
rename to WebUI/src/services/schedulerService.js
diff --git a/frontend/src/services/settingService.js b/WebUI/src/services/settingService.js
similarity index 100%
rename from frontend/src/services/settingService.js
rename to WebUI/src/services/settingService.js
diff --git a/frontend/src/stores/plugins.js b/WebUI/src/stores/plugins.js
similarity index 100%
rename from frontend/src/stores/plugins.js
rename to WebUI/src/stores/plugins.js
diff --git a/frontend/src/stores/proxy.js b/WebUI/src/stores/proxy.js
similarity index 100%
rename from frontend/src/stores/proxy.js
rename to WebUI/src/stores/proxy.js
diff --git a/frontend/src/style.css b/WebUI/src/style.css
similarity index 100%
rename from frontend/src/style.css
rename to WebUI/src/style.css
diff --git a/frontend/src/styles/element-plus.css b/WebUI/src/styles/element-plus.css
similarity index 100%
rename from frontend/src/styles/element-plus.css
rename to WebUI/src/styles/element-plus.css
diff --git a/frontend/src/styles/utilities.css b/WebUI/src/styles/utilities.css
similarity index 100%
rename from frontend/src/styles/utilities.css
rename to WebUI/src/styles/utilities.css
diff --git a/frontend/src/styles/variables.css b/WebUI/src/styles/variables.css
similarity index 100%
rename from frontend/src/styles/variables.css
rename to WebUI/src/styles/variables.css
diff --git a/frontend/src/utils/clipboard.js b/WebUI/src/utils/clipboard.js
similarity index 100%
rename from frontend/src/utils/clipboard.js
rename to WebUI/src/utils/clipboard.js
diff --git a/frontend/src/utils/confirm.js b/WebUI/src/utils/confirm.js
similarity index 100%
rename from frontend/src/utils/confirm.js
rename to WebUI/src/utils/confirm.js
diff --git a/frontend/src/utils/format.js b/WebUI/src/utils/format.js
similarity index 100%
rename from frontend/src/utils/format.js
rename to WebUI/src/utils/format.js
diff --git a/frontend/src/utils/message.js b/WebUI/src/utils/message.js
similarity index 100%
rename from frontend/src/utils/message.js
rename to WebUI/src/utils/message.js
diff --git a/frontend/src/views/Dashboard.vue b/WebUI/src/views/Dashboard.vue
similarity index 100%
rename from frontend/src/views/Dashboard.vue
rename to WebUI/src/views/Dashboard.vue
diff --git a/frontend/src/views/Plugins.vue b/WebUI/src/views/Plugins.vue
similarity index 71%
rename from frontend/src/views/Plugins.vue
rename to WebUI/src/views/Plugins.vue
index 97cf040..8874b83 100644
--- a/frontend/src/views/Plugins.vue
+++ b/WebUI/src/views/Plugins.vue
@@ -74,26 +74,42 @@
           </template>
         </el-table-column>
 
-        <el-table-column label="操作" width="200" fixed="right" align="center">
+        <el-table-column label="操作" width="220" fixed="right" align="center">
           <template #default="{ row }">
-            <el-button
-              type="primary"
-              size="small"
-              @click="handleOpenConfig(row)"
-            >
-              <el-icon class="btn-icon"><Setting /></el-icon>
-              配置
-            </el-button>
-            <el-button
-              type="success"
-              size="small"
-              @click="handleCrawl(row.id)"
-              :loading="crawlingPlugin === row.id"
-              :disabled="!row.enabled"
-            >
-              <el-icon class="btn-icon"><Promotion /></el-icon>
-              爬取
-            </el-button>
+            <div class="plugin-actions">
+              <el-button
+                type="primary"
+                size="small"
+                @click="handleOpenConfig(row)"
+              >
+                <el-icon class="btn-icon"><Setting /></el-icon>
+                配置
+              </el-button>
+              <el-button
+                type="success"
+                size="small"
+                @click="handleCrawl(row.id)"
+                :loading="crawlingPlugins.has(row.id)"
+                :disabled="!row.enabled"
+              >
+                <el-icon class="btn-icon"><Promotion /></el-icon>
+                爬取
+              </el-button>
+            </div>
+            <div v-if="crawlResults[row.id]" class="plugin-crawl-result">
+              <div class="result-mini" :class="crawlResults[row.id].type">
+                <el-icon v-if="crawlResults[row.id].type === 'success'" class="result-icon success"><CircleCheck /></el-icon>
+                <el-icon v-else class="result-icon failed"><CircleClose /></el-icon>
+                <span class="result-text">{{ crawlResults[row.id].message }}</span>
+                <span v-if="crawlResults[row.id].data?.valid_count !== undefined" class="result-count valid">
+                  有效 {{ crawlResults[row.id].data.valid_count }}
+                </span>
+                <span v-if="crawlResults[row.id].data?.invalid_count !== undefined" class="result-count invalid">
+                  无效 {{ crawlResults[row.id].data.invalid_count }}
+                </span>
+                <el-icon class="result-close" @click="clearCrawlResult(row.id)"><Close /></el-icon>
+              </div>
+            </div>
           </template>
         </el-table-column>
       </el-table>
@@ -104,28 +120,28 @@
         :image-size="120"
       />
 
-      <!-- 爬取结果提示 -->
+      <!-- 批量爬取结果提示 -->
       <el-alert
-        v-if="lastCrawlResult"
-        :title="lastCrawlResult.message"
-        :type="lastCrawlResult.type"
+        v-if="allCrawlResult"
+        :title="allCrawlResult.message"
+        :type="allCrawlResult.type"
         closable
         class="crawl-result"
-        @close="lastCrawlResult = null"
+        @close="allCrawlResult = null"
       >
-        <template v-if="lastCrawlResult.data">
+        <template v-if="allCrawlResult.data">
           <div class="crawl-stats">
-            <span v-if="lastCrawlResult.data.total_crawled !== undefined">
-              爬取: {{ lastCrawlResult.data.total_crawled }}
+            <span v-if="allCrawlResult.data.total_crawled !== undefined">
+              爬取: {{ allCrawlResult.data.total_crawled }}
             </span>
-            <span v-if="lastCrawlResult.data.proxy_count !== undefined">
-              爬取: {{ lastCrawlResult.data.proxy_count }}
+            <span v-if="allCrawlResult.data.proxy_count !== undefined">
+              爬取: {{ allCrawlResult.data.proxy_count }}
             </span>
-            <span v-if="lastCrawlResult.data.valid_count !== undefined" class="valid-count">
-              有效: {{ lastCrawlResult.data.valid_count }}
+            <span v-if="allCrawlResult.data.valid_count !== undefined" class="valid-count">
+              有效: {{ allCrawlResult.data.valid_count }}
             </span>
-            <span v-if="lastCrawlResult.data.invalid_count !== undefined" class="invalid-count">
-              无效: {{ lastCrawlResult.data.invalid_count }}
+            <span v-if="allCrawlResult.data.invalid_count !== undefined" class="invalid-count">
+              无效: {{ allCrawlResult.data.invalid_count }}
             </span>
           </div>
         </template>
@@ -183,7 +199,8 @@ import {
   CircleCheck, 
   CircleClose,
   Box,
-  Setting
+  Setting,
+  Close
 } from '@element-plus/icons-vue'
 import { usePluginsStore } from '../stores/plugins'
 import { pluginService } from '../services/pluginService'
@@ -191,9 +208,10 @@ import { formatTime } from '../utils/format'
 import PageHeader from '../components/PageHeader.vue'
 
 const pluginsStore = usePluginsStore()
-const crawlingPlugin = ref(null)
+const crawlingPlugins = ref(new Set())
 const crawlingAll = ref(false)
-const lastCrawlResult = ref(null)
+const crawlResults = ref({})
+const allCrawlResult = ref(null)
 
 // 配置对话框
 const configDialogVisible = ref(false)
@@ -248,34 +266,36 @@ async function handleSaveConfig() {
 
 async function handleCrawl(pluginId) {
   try {
-    crawlingPlugin.value = pluginId
-    lastCrawlResult.value = null
+    crawlingPlugins.value.add(pluginId)
     
     const response = await pluginService.crawlPlugin(pluginId)
     
     if (response.code === 200) {
-      lastCrawlResult.value = {
+      crawlResults.value[pluginId] = {
         type: 'success',
         message: response.message,
         data: response.data
       }
-      await pluginsStore.fetchPlugins()
     } else {
-      lastCrawlResult.value = {
+      crawlResults.value[pluginId] = {
         type: 'error',
         message: response.message || '爬取失败'
       }
     }
   } catch (error) {
-    lastCrawlResult.value = {
+    crawlResults.value[pluginId] = {
       type: 'error',
       message: '爬取过程出错'
     }
   } finally {
-    crawlingPlugin.value = null
+    crawlingPlugins.value.delete(pluginId)
   }
 }
 
+function clearCrawlResult(pluginId) {
+  delete crawlResults.value[pluginId]
+}
+
 async function handleCrawlAll() {
   try {
     const enabledPlugins = pluginsStore.plugins.filter(p => p.enabled)
@@ -295,20 +315,19 @@ async function handleCrawlAll() {
     )
     
     crawlingAll.value = true
-    lastCrawlResult.value = null
+    allCrawlResult.value = null
     
     const response = await pluginService.crawlAll()
     
     if (response.code === 200) {
-      lastCrawlResult.value = {
+      allCrawlResult.value = {
         type: 'success',
         message: response.message,
         data: response.data
       }
       ElMessage.success('批量爬取完成')
-      await pluginsStore.fetchPlugins()
     } else {
-      lastCrawlResult.value = {
+      allCrawlResult.value = {
         type: 'error',
         message: response.message || '批量爬取失败'
       }
@@ -316,7 +335,7 @@ async function handleCrawlAll() {
   } catch (error) {
     if (error !== 'cancel') {
       console.error('批量爬取失败:', error)
-      lastCrawlResult.value = {
+      allCrawlResult.value = {
         type: 'error',
         message: '批量爬取过程出错'
       }
@@ -460,4 +479,70 @@ onMounted(async () => {
   margin-bottom: 16px;
   color: var(--text-primary);
 }
+
+.plugin-actions {
+  display: flex;
+  justify-content: center;
+  gap: 8px;
+}
+
+.plugin-crawl-result {
+  margin-top: 8px;
+}
+
+.result-mini {
+  display: inline-flex;
+  align-items: center;
+  gap: 6px;
+  padding: 4px 8px;
+  border-radius: 4px;
+  font-size: 12px;
+  line-height: 1.4;
+}
+
+.result-mini.success {
+  background: rgba(103, 194, 58, 0.15);
+  color: var(--success);
+}
+
+.result-mini.error {
+  background: rgba(245, 108, 108, 0.15);
+  color: var(--danger);
+}
+
+.result-icon {
+  font-size: 13px;
+}
+
+.result-text {
+  font-weight: 500;
+}
+
+.result-count {
+  font-weight: 600;
+  padding: 0 4px;
+  border-radius: 3px;
+}
+
+.result-count.valid {
+  background: rgba(103, 194, 58, 0.2);
+  color: var(--success);
+}
+
+.result-count.invalid {
+  background: rgba(245, 108, 108, 0.2);
+  color: var(--danger);
+}
+
+.result-close {
+  margin-left: 4px;
+  cursor: pointer;
+  font-size: 12px;
+  opacity: 0.7;
+  transition: opacity 0.2s;
+}
+
+.result-close:hover {
+  opacity: 1;
+}
 </style>
diff --git a/frontend/src/views/ProxyList.vue b/WebUI/src/views/ProxyList.vue
similarity index 100%
rename from frontend/src/views/ProxyList.vue
rename to WebUI/src/views/ProxyList.vue
diff --git a/frontend/src/views/Settings.vue b/WebUI/src/views/Settings.vue
similarity index 100%
rename from frontend/src/views/Settings.vue
rename to WebUI/src/views/Settings.vue
diff --git a/frontend/vite.config.js b/WebUI/vite.config.js
similarity index 100%
rename from frontend/vite.config.js
rename to WebUI/vite.config.js
diff --git a/api/routes/proxies.py b/api/routes/proxies.py
deleted file mode 100644
index 57b5258..0000000
--- a/api/routes/proxies.py
+++ /dev/null
@@ -1,130 +0,0 @@
-"""代理相关路由（含统计信息）"""
-from typing import Optional
-from fastapi import APIRouter, Depends, Query
-from services.proxy_service import ProxyService
-from services.scheduler_service import SchedulerService
-from models.schemas import ProxyListRequest, BatchDeleteRequest
-from api.deps import get_proxy_service, get_scheduler_service
-from core.log import logger
-
-router = APIRouter(prefix="/api/proxies", tags=["proxies"])
-
-
-def success_response(message: str, data=None):
-    return {"code": 200, "message": message, "data": data}
-
-
-def error_response(message: str, code: int = 500):
-    return {"code": code, "message": message, "data": None}
-
-
-@router.get("/stats")
-async def get_stats(
-    proxy_service: ProxyService = Depends(get_proxy_service),
-    scheduler_service: SchedulerService = Depends(get_scheduler_service),
-):
-    try:
-        stats = await proxy_service.get_stats()
-        stats["scheduler_running"] = scheduler_service.running
-        return success_response("获取统计信息成功", stats)
-    except Exception as e:
-        logger.error(f"Get stats failed: {e}")
-        return error_response("获取统计信息失败")
-
-
-@router.post("")
-async def list_proxies(
-    request: ProxyListRequest,
-    service: ProxyService = Depends(get_proxy_service),
-):
-    proxies, total = await service.list_proxies(
-        page=request.page,
-        page_size=request.page_size,
-        protocol=request.protocol,
-        min_score=request.min_score,
-        max_score=request.max_score,
-        sort_by=request.sort_by,
-        sort_order=request.sort_order,
-    )
-    return success_response(
-        "获取代理列表成功",
-        {
-            "list": [
-                {
-                    "ip": p.ip,
-                    "port": p.port,
-                    "protocol": p.protocol,
-                    "score": p.score,
-                    "last_check": p.last_check.isoformat() if p.last_check else None,
-                }
-                for p in proxies
-            ],
-            "total": total,
-            "page": request.page,
-            "page_size": request.page_size,
-        },
-    )
-
-
-@router.get("/random")
-async def get_random_proxy(service: ProxyService = Depends(get_proxy_service)):
-    proxy = await service.get_random_proxy()
-    if not proxy:
-        return error_response("没有找到可用的代理", 404)
-    return success_response(
-        "获取随机代理成功",
-        {
-            "ip": proxy.ip,
-            "port": proxy.port,
-            "protocol": proxy.protocol,
-            "score": proxy.score,
-            "last_check": proxy.last_check.isoformat() if proxy.last_check else None,
-        },
-    )
-
-
-@router.get("/export/{fmt}")
-async def export_proxies(
-    fmt: str,
-    protocol: Optional[str] = None,
-    limit: int = Query(default=10000, ge=1, le=100000),
-    service: ProxyService = Depends(get_proxy_service),
-):
-    if fmt not in ("csv", "txt", "json"):
-        return error_response("不支持的导出格式", 400)
-
-    from fastapi.responses import StreamingResponse
-
-    media_types = {"csv": "text/csv", "txt": "text/plain", "json": "application/json"}
-
-    async def generate():
-        async for chunk in service.export_proxies(fmt, protocol, limit):
-            yield chunk
-
-    return StreamingResponse(
-        generate(),
-        media_type=media_types[fmt],
-        headers={"Content-Disposition": f"attachment; filename=proxies.{fmt}"},
-    )
-
-
-@router.delete("/{ip}/{port}")
-async def delete_proxy(ip: str, port: int, service: ProxyService = Depends(get_proxy_service)):
-    await service.delete_proxy(ip, port)
-    return success_response("删除代理成功")
-
-
-@router.post("/batch-delete")
-async def batch_delete(
-    request: BatchDeleteRequest,
-    service: ProxyService = Depends(get_proxy_service),
-):
-    proxies = [(item.ip, item.port) for item in request.proxies]
-    deleted = await service.batch_delete(proxies)
-    return success_response(f"批量删除 {deleted} 个代理成功", {"deleted_count": deleted})
-
-
-@router.delete("/clean-invalid")
-async def clean_invalid(service: ProxyService = Depends(get_proxy_service)):
-    count = await service.clean_invalid()
-    return success_response(f"清理了 {count} 个无效代理", {"deleted_count": count})
diff --git a/api/routes/scheduler.py b/api/routes/scheduler.py
deleted file mode 100644
index 20f13a5..0000000
--- a/api/routes/scheduler.py
+++ /dev/null
@@ -1,80 +0,0 @@
-"""调度器相关路由"""
-from fastapi import APIRouter, Depends
-from services.scheduler_service import SchedulerService
-from repositories.settings_repo import SettingsRepository
-from core.db import get_db
-from api.deps import get_scheduler_service
-from core.log import logger
-
-router = APIRouter(prefix="/api/scheduler", tags=["scheduler"])
-settings_repo = SettingsRepository()
-
-
-def success_response(message: str, data=None):
-    return {"code": 200, "message": message, "data": data}
-
-
-def error_response(message: str, code: int = 500):
-    return {"code": code, "message": message, "data": None}
-
-
-@router.post("/start")
-async def start_scheduler(
-    scheduler: SchedulerService = Depends(get_scheduler_service),
-):
-    try:
-        if scheduler.running:
-            return success_response("验证调度器已在运行", {"running": True})
-        await scheduler.start()
-        # 持久化设置
-        async with get_db() as db:
-            settings = await settings_repo.get_all(db)
-            settings["auto_validate"] = True
-            from models.schemas import SettingsSchema
-            await settings_repo.save(db, SettingsSchema(**settings).model_dump())
-        return success_response("验证调度器已启动", {"running": True})
-    except Exception as e:
-        logger.error(f"Start scheduler failed: {e}")
-        return error_response(f"启动调度器失败: {str(e)}")
-
-
-@router.post("/stop")
-async def stop_scheduler(
-    scheduler: SchedulerService = Depends(get_scheduler_service),
-):
-    try:
-        if not scheduler.running:
-            return success_response("验证调度器未运行", {"running": False})
-        await scheduler.stop()
-        # 持久化设置
-        async with get_db() as db:
-            settings = await settings_repo.get_all(db)
-            settings["auto_validate"] = False
-            from models.schemas import SettingsSchema
-            await settings_repo.save(db, SettingsSchema(**settings).model_dump())
-        return success_response("验证调度器已停止", {"running": False})
-    except Exception as e:
-        logger.error(f"Stop scheduler failed: {e}")
-        return error_response(f"停止调度器失败: {str(e)}")
-
-
-@router.post("/validate-now")
-async def validate_now(
-    scheduler: SchedulerService = Depends(get_scheduler_service),
-):
-    try:
-        scheduler.validate_all_now()
-        return success_response("已开始全量验证", {"started": True})
-    except Exception as e:
-        logger.error(f"Validate now failed: {e}")
-        return error_response(f"启动验证失败: {str(e)}")
-
-
-@router.get("/status")
-async def scheduler_status(
-    scheduler: SchedulerService = Depends(get_scheduler_service),
-):
-    return success_response(
-        "获取状态成功",
-        {"running": scheduler.running, "interval_minutes": scheduler.interval_minutes},
-    )
diff --git a/api/__init__.py b/app/api/__init__.py
similarity index 79%
rename from api/__init__.py
rename to app/api/__init__.py
index 813f14c..47c4180 100644
--- a/api/__init__.py
+++ b/app/api/__init__.py
@@ -1,3 +1,4 @@
+"""API 包"""
 from .main import create_app
 
 __all__ = ["create_app"]
diff --git a/app/api/common.py b/app/api/common.py
new file mode 100644
index 0000000..fc47fee
--- /dev/null
+++ b/app/api/common.py
@@ -0,0 +1,41 @@
+"""API 通用工具函数"""
+from typing import Any, Optional
+from fastapi.responses import JSONResponse
+
+
+def success_response(message: str, data: Any = None) -> dict:
+    """成功响应"""
+    return {"code": 200, "message": message, "data": data}
+
+
+def error_response(message: str, code: int = 500) -> JSONResponse:
+    """错误响应"""
+    return JSONResponse(
+        status_code=code,
+        content={"code": code, "message": message, "data": None},
+    )
+
+
+def format_proxy(proxy) -> dict:
+    """格式化代理对象"""
+    return {
+        "ip": proxy.ip,
+        "port": proxy.port,
+        "protocol": proxy.protocol,
+        "score": proxy.score,
+        "last_check": proxy.last_check.isoformat() if proxy.last_check else None,
+    }
+
+
+def format_plugin(plugin) -> dict:
+    """格式化插件对象"""
+    return {
+        "id": plugin.id,
+        "name": plugin.display_name,
+        "display_name": plugin.display_name,
+        "description": plugin.description,
+        "enabled": plugin.enabled,
+        "last_run": plugin.last_run.isoformat() if plugin.last_run else None,
+        "success_count": plugin.success_count,
+        "failure_count": plugin.failure_count,
+    }
diff --git a/api/deps.py b/app/api/deps.py
similarity index 75%
rename from api/deps.py
rename to app/api/deps.py
index 4cab0a5..d3127e5 100644
--- a/api/deps.py
+++ b/app/api/deps.py
@@ -1,12 +1,12 @@
 """依赖注入"""
 from fastapi import Request
-from services.proxy_service import ProxyService
-from services.plugin_service import PluginService
-from services.scheduler_service import SchedulerService
-from services.validator_service import ValidatorService
-from repositories.proxy_repo import ProxyRepository
-from core.tasks.queue import ValidationQueue
-from core.config import settings as app_settings
+from app.services.proxy_service import ProxyService
+from app.services.plugin_service import PluginService
+from app.services.scheduler_service import SchedulerService
+from app.services.validator_service import ValidatorService
+from app.repositories.proxy_repo import ProxyRepository
+from app.core.tasks.queue import ValidationQueue
+from app.core.config import settings as app_settings
 
 
 def get_proxy_service() -> ProxyService:
diff --git a/api/errors.py b/app/api/errors.py
similarity index 91%
rename from api/errors.py
rename to app/api/errors.py
index 0c38b56..fb653aa 100644
--- a/api/errors.py
+++ b/app/api/errors.py
@@ -2,8 +2,8 @@
 from fastapi import Request
 from fastapi.responses import JSONResponse
 from pydantic import ValidationError
-from core.exceptions import ProxyPoolException
-from core.log import logger
+from app.core.exceptions import ProxyPoolException
+from app.core.log import logger
 
 
 async def proxy_pool_exception_handler(request: Request, exc: ProxyPoolException):
diff --git a/api/lifespan.py b/app/api/lifespan.py
similarity index 82%
rename from api/lifespan.py
rename to app/api/lifespan.py
index 7ab0bcd..1b859d5 100644
--- a/api/lifespan.py
+++ b/app/api/lifespan.py
@@ -1,11 +1,11 @@
 """应用生命周期管理"""
 from contextlib import asynccontextmanager
 from fastapi import FastAPI
-from core.db import init_db, get_db
-from core.config import settings as app_settings
-from core.log import logger
-from api.deps import create_scheduler_service
-from repositories.settings_repo import SettingsRepository
+from app.core.db import init_db, get_db
+from app.core.config import settings as app_settings
+from app.core.log import logger
+from app.api.deps import create_scheduler_service
+from app.repositories.settings_repo import SettingsRepository
 
 settings_repo = SettingsRepository()
 
diff --git a/api/main.py b/app/api/main.py
similarity index 81%
rename from api/main.py
rename to app/api/main.py
index 4690da7..c5c2bc4 100644
--- a/api/main.py
+++ b/app/api/main.py
@@ -1,15 +1,15 @@
 """FastAPI 应用工厂"""
 from fastapi import FastAPI
 from fastapi.middleware.cors import CORSMiddleware
-from api.lifespan import lifespan
-from api.routes import api_router
-from api.errors import proxy_pool_exception_handler, pydantic_validation_handler, general_exception_handler
-from core.exceptions import ProxyPoolException
+from app.api.lifespan import lifespan
+from app.api.routes import api_router
+from app.api.errors import proxy_pool_exception_handler, pydantic_validation_handler, general_exception_handler
+from app.core.exceptions import ProxyPoolException
 from pydantic import ValidationError
-from core.config import settings as app_settings
+from app.core.config import settings as app_settings
 
 # 导入并注册所有插件（显式注册模式）
-import plugins
+import app.plugins
 
 
 def create_app() -> FastAPI:
diff --git a/api/routes/__init__.py b/app/api/routes/__init__.py
similarity index 73%
rename from api/routes/__init__.py
rename to app/api/routes/__init__.py
index 67697cf..f1c78a7 100644
--- a/api/routes/__init__.py
+++ b/app/api/routes/__init__.py
@@ -1,5 +1,6 @@
+"""路由包"""
 from fastapi import APIRouter
-from . import proxies, plugins, scheduler, settings
+from app.api.routes import proxies, plugins, scheduler, settings
 
 api_router = APIRouter()
 api_router.include_router(proxies.router)
diff --git a/api/routes/plugins.py b/app/api/routes/plugins.py
similarity index 56%
rename from api/routes/plugins.py
rename to app/api/routes/plugins.py
index 57856ce..877ea05 100644
--- a/api/routes/plugins.py
+++ b/app/api/routes/plugins.py
@@ -1,42 +1,23 @@
 """插件相关路由"""
+import asyncio
 from fastapi import APIRouter, Depends
-from services.plugin_service import PluginService
-from services.scheduler_service import SchedulerService
-from api.deps import get_plugin_service, get_scheduler_service
-from core.log import logger
+from app.services.plugin_service import PluginService
+from app.services.scheduler_service import SchedulerService
+from app.api.deps import get_plugin_service, get_scheduler_service
+from app.api.common import success_response, error_response, format_plugin
+from app.core.log import logger
 
 router = APIRouter(prefix="/api/plugins", tags=["plugins"])
 
 
-def success_response(message: str, data=None):
-    return {"code": 200, "message": message, "data": data}
-
-
-def error_response(message: str, code: int = 500):
-    return {"code": code, "message": message, "data": None}
-
-
 @router.get("")
 async def list_plugins(service: PluginService = Depends(get_plugin_service)):
-    plugins = await service.list_plugins()
-    return success_response(
-        "获取插件列表成功",
-        {
-            "plugins": [
-                {
-                    "id": p.id,
-                    "name": p.display_name,
-                    "display_name": p.display_name,
-                    "description": p.description,
-                    "enabled": p.enabled,
-                    "last_run": p.last_run.isoformat() if p.last_run else None,
-                    "success_count": p.success_count,
-                    "failure_count": p.failure_count,
-                }
-                for p in plugins
-            ]
-        },
-    )
+    try:
+        plugins = await service.list_plugins()
+        return success_response("获取插件列表成功", {"plugins": [format_plugin(p) for p in plugins]})
+    except Exception as e:
+        logger.error(f"List plugins failed: {e}")
+        return error_response("获取插件列表失败", 500)
 
 
 @router.put("/{plugin_id}/toggle")
@@ -48,13 +29,18 @@ async def toggle_plugin(
     enabled = request.get("enabled")
     if enabled is None:
         return error_response("缺少 enabled 参数", 400)
-    success = await service.toggle_plugin(plugin_id, enabled)
-    if not success:
-        return error_response("插件不存在", 404)
-    return success_response(
-        f"插件 {plugin_id} 已{'启用' if enabled else '禁用'}",
-        {"plugin_id": plugin_id, "enabled": enabled},
-    )
+    
+    try:
+        success = await service.toggle_plugin(plugin_id, enabled)
+        if not success:
+            return error_response("插件不存在", 404)
+        return success_response(
+            f"插件 {plugin_id} 已{'启用' if enabled else '禁用'}",
+            {"plugin_id": plugin_id, "enabled": enabled},
+        )
+    except Exception as e:
+        logger.error(f"Toggle plugin failed: {e}")
+        return error_response("切换插件状态失败", 500)
 
 
 @router.get("/{plugin_id}/config")
@@ -62,10 +48,14 @@ async def get_plugin_config(
     plugin_id: str,
     service: PluginService = Depends(get_plugin_service),
 ):
-    config = await service.get_plugin_config(plugin_id)
-    if config is None:
-        return error_response("插件不存在", 404)
-    return success_response("获取插件配置成功", {"plugin_id": plugin_id, "config": config})
+    try:
+        config = await service.get_plugin_config(plugin_id)
+        if config is None:
+            return error_response("插件不存在", 404)
+        return success_response("获取插件配置成功", {"plugin_id": plugin_id, "config": config})
+    except Exception as e:
+        logger.error(f"Get plugin config failed: {e}")
+        return error_response("获取插件配置失败", 500)
 
 
 @router.post("/{plugin_id}/config")
@@ -77,10 +67,15 @@ async def update_plugin_config(
     config = request.get("config", {})
     if not isinstance(config, dict):
         return error_response("config 必须是对象", 400)
-    success = await service.update_plugin_config(plugin_id, config)
-    if not success:
-        return error_response("插件不存在或配置无效", 404)
-    return success_response("保存插件配置成功", {"plugin_id": plugin_id, "config": config})
+    
+    try:
+        success = await service.update_plugin_config(plugin_id, config)
+        if not success:
+            return error_response("插件不存在或配置无效", 404)
+        return success_response("保存插件配置成功", {"plugin_id": plugin_id, "config": config})
+    except Exception as e:
+        logger.error(f"Update plugin config failed: {e}")
+        return error_response("保存插件配置失败", 500)
 
 
 @router.post("/{plugin_id}/crawl")
@@ -101,30 +96,27 @@ async def crawl_plugin(
                 {"plugin_id": plugin_id, "proxy_count": 0, "valid_count": 0},
             )
 
-        logger.info(f"Plugin {plugin_id} crawled {len(results)} proxies, sending to validation queue")
+        logger.info(f"Plugin {plugin_id} crawled {len(results)} proxies")
         scheduler_service.validation_queue.reset_stats()
         await scheduler_service.validation_queue.submit(results)
-        # 等待队列排空（最多等 30 秒，避免前端超时）
+        
         try:
             await asyncio.wait_for(scheduler_service.validation_queue.drain(), timeout=30.0)
         except asyncio.TimeoutError:
             pass
 
-        valid_count = scheduler_service.validation_queue.valid_count
-        invalid_count = scheduler_service.validation_queue.invalid_count
-
         return success_response(
             f"插件 {plugin_id} 爬取并验证完成",
             {
                 "plugin_id": plugin_id,
                 "proxy_count": len(results),
-                "valid_count": valid_count,
-                "invalid_count": invalid_count,
+                "valid_count": scheduler_service.validation_queue.valid_count,
+                "invalid_count": scheduler_service.validation_queue.invalid_count,
             },
         )
     except Exception as e:
         logger.error(f"Crawl plugin {plugin_id} failed: {e}")
-        return error_response(f"插件爬取失败: {str(e)}")
+        return error_response(f"插件爬取失败: {str(e)}", 500)
 
 
 @router.post("/crawl-all")
@@ -140,28 +132,23 @@ async def crawl_all(
                 {"total_crawled": 0, "valid_count": 0, "invalid_count": 0},
             )
 
-        logger.info(f"All plugins crawled {len(results)} unique proxies, sending to validation queue")
+        logger.info(f"All plugins crawled {len(results)} unique proxies")
         scheduler_service.validation_queue.reset_stats()
         await scheduler_service.validation_queue.submit(results)
+        
         try:
             await asyncio.wait_for(scheduler_service.validation_queue.drain(), timeout=60.0)
         except asyncio.TimeoutError:
             pass
 
-        valid_count = scheduler_service.validation_queue.valid_count
-        invalid_count = scheduler_service.validation_queue.invalid_count
-
         return success_response(
             "所有插件爬取并验证完成",
             {
                 "total_crawled": len(results),
-                "valid_count": valid_count,
-                "invalid_count": invalid_count,
+                "valid_count": scheduler_service.validation_queue.valid_count,
+                "invalid_count": scheduler_service.validation_queue.invalid_count,
             },
         )
     except Exception as e:
         logger.error(f"Crawl all failed: {e}")
-        return error_response(f"批量爬取失败: {str(e)}")
-
-
-import asyncio
+        return error_response(f"批量爬取失败: {str(e)}", 500)
diff --git a/app/api/routes/proxies.py b/app/api/routes/proxies.py
new file mode 100644
index 0000000..a82c62a
--- /dev/null
+++ b/app/api/routes/proxies.py
@@ -0,0 +1,125 @@
+"""代理相关路由（含统计信息）"""
+from typing import Optional
+from fastapi import APIRouter, Depends, Query
+from app.services.proxy_service import ProxyService
+from app.services.scheduler_service import SchedulerService
+from app.models.schemas import ProxyListRequest, BatchDeleteRequest
+from app.api.deps import get_proxy_service, get_scheduler_service
+from app.api.common import success_response, error_response, format_proxy
+from app.core.log import logger
+
+router = APIRouter(prefix="/api/proxies", tags=["proxies"])
+
+
+@router.get("/stats")
+async def get_stats(
+    proxy_service: ProxyService = Depends(get_proxy_service),
+    scheduler_service: SchedulerService = Depends(get_scheduler_service),
+):
+    try:
+        stats = await proxy_service.get_stats()
+        stats["scheduler_running"] = scheduler_service.running
+        return success_response("获取统计信息成功", stats)
+    except Exception as e:
+        logger.error(f"Get stats failed: {e}")
+        return error_response("获取统计信息失败", 500)
+
+
+@router.post("")
+async def list_proxies(
+    request: ProxyListRequest,
+    service: ProxyService = Depends(get_proxy_service),
+):
+    try:
+        proxies, total = await service.list_proxies(
+            page=request.page,
+            page_size=request.page_size,
+            protocol=request.protocol,
+            min_score=request.min_score,
+            max_score=request.max_score,
+            sort_by=request.sort_by,
+            sort_order=request.sort_order,
+        )
+        return success_response(
+            "获取代理列表成功",
+            {
+                "list": [format_proxy(p) for p in proxies],
+                "total": total,
+                "page": request.page,
+                "page_size": request.page_size,
+            },
+        )
+    except Exception as e:
+        logger.error(f"List proxies failed: {e}")
+        return error_response("获取代理列表失败", 500)
+
+
+@router.get("/random")
+async def get_random_proxy(service: ProxyService = Depends(get_proxy_service)):
+    try:
+        proxy = await service.get_random_proxy()
+        if not proxy:
+            return error_response("没有找到可用的代理", 404)
+        return success_response("获取随机代理成功", format_proxy(proxy))
+    except Exception as e:
+        logger.error(f"Get random proxy failed: {e}")
+        return error_response("获取随机代理失败", 500)
+
+
+@router.get("/export/{fmt}")
+async def export_proxies(
+    fmt: str,
+    protocol: Optional[str] = None,
+    limit: int = Query(default=10000, ge=1, le=100000),
+    service: ProxyService = Depends(get_proxy_service),
+):
+    if fmt not in ("csv", "txt", "json"):
+        return error_response("不支持的导出格式", 400)
+
+    from fastapi.responses import StreamingResponse
+
+    media_types = {"csv": "text/csv", "txt": "text/plain", "json": "application/json"}
+
+    async def generate():
+        async for chunk in service.export_proxies(fmt, protocol, limit):
+            yield chunk
+
+    return StreamingResponse(
+        generate(),
+        media_type=media_types[fmt],
+        headers={"Content-Disposition": f"attachment; filename=proxies.{fmt}"},
+    )
+
+
+@router.delete("/{ip}/{port}")
+async def delete_proxy(ip: str, port: int, service: ProxyService = Depends(get_proxy_service)):
+    try:
+        await service.delete_proxy(ip, port)
+        return success_response("删除代理成功")
+    except Exception as e:
+        logger.error(f"Delete proxy failed: {e}")
+        return error_response("删除代理失败", 500)
+
+
+@router.post("/batch-delete")
+async def batch_delete(
+    request: BatchDeleteRequest,
+    service: ProxyService = Depends(get_proxy_service),
+):
+    try:
+        proxies = [(item.ip, item.port) for item in request.proxies]
+        deleted = await service.batch_delete(proxies)
+        return success_response(f"批量删除 {deleted} 个代理成功", {"deleted_count": deleted})
+    except Exception as e:
+        logger.error(f"Batch delete failed: {e}")
+        return error_response("批量删除失败", 500)
+
+
+@router.delete("/clean-invalid")
+async def clean_invalid(service: ProxyService = Depends(get_proxy_service)):
+    try:
+        count = await service.clean_invalid()
+        return success_response(f"清理了 {count} 个无效代理", {"deleted_count": count})
+    except Exception as e:
+        logger.error(f"Clean invalid failed: {e}")
+        return error_response("清理无效代理失败", 500)
diff --git a/app/api/routes/scheduler.py b/app/api/routes/scheduler.py
new file mode 100644
index 0000000..fa3b903
--- /dev/null
+++ b/app/api/routes/scheduler.py
@@ -0,0 +1,64 @@
+"""调度器相关路由"""
+from fastapi import APIRouter, Depends
+from app.services.scheduler_service import SchedulerService
+from app.repositories.settings_repo import SettingsRepository
+from app.core.db import get_db
+from app.api.deps import get_scheduler_service
+from app.api.common import success_response, error_response
+from app.core.log import logger
+
+router = APIRouter(prefix="/api/scheduler", tags=["scheduler"])
+settings_repo = SettingsRepository()
+
+
+async def _save_auto_validate_setting(enabled: bool):
+    """保存自动验证设置"""
+    async with get_db() as db:
+        settings = await settings_repo.get_all(db)
+        settings["auto_validate"] = enabled
+        from app.models.schemas import SettingsSchema
+        await settings_repo.save(db, SettingsSchema(**settings).model_dump())
+
+
+@router.post("/start")
+async def start_scheduler(scheduler: SchedulerService = Depends(get_scheduler_service)):
+    try:
+        if scheduler.running:
+            return success_response("验证调度器已在运行", {"running": True})
+        await scheduler.start()
+        await _save_auto_validate_setting(True)
+        return success_response("验证调度器已启动", {"running": True})
+    except Exception as e:
+        logger.error(f"Start scheduler failed: {e}")
+        return error_response(f"启动调度器失败: {str(e)}", 500)
+
+
+@router.post("/stop")
+async def stop_scheduler(scheduler: SchedulerService = Depends(get_scheduler_service)):
+    try:
+        if not scheduler.running:
+            return success_response("验证调度器未运行", {"running": False})
+        await scheduler.stop()
+        await _save_auto_validate_setting(False)
+        return success_response("验证调度器已停止", {"running": False})
+    except Exception as e:
+        logger.error(f"Stop scheduler failed: {e}")
+        return error_response(f"停止调度器失败: {str(e)}", 500)
+
+
+@router.post("/validate-now")
+async def validate_now(scheduler: SchedulerService = Depends(get_scheduler_service)):
+    try:
+        scheduler.validate_all_now()
+        return success_response("已开始全量验证", {"started": True})
+    except Exception as e:
+        logger.error(f"Validate now failed: {e}")
+        return error_response(f"启动验证失败: {str(e)}", 500)
+
+
+@router.get("/status")
+async def scheduler_status(scheduler: SchedulerService = Depends(get_scheduler_service)):
+    return success_response(
+        "获取状态成功",
+        {"running": scheduler.running, "interval_minutes": scheduler.interval_minutes},
+    )
diff --git a/api/routes/settings.py b/app/api/routes/settings.py
similarity index 59%
rename from api/routes/settings.py
rename to app/api/routes/settings.py
index 3f60548..a84eadb 100644
--- a/api/routes/settings.py
+++ b/app/api/routes/settings.py
@@ -1,22 +1,15 @@
 """设置相关路由"""
 from fastapi import APIRouter
-from core.db import get_db
-from repositories.settings_repo import SettingsRepository
-from models.schemas import SettingsSchema
-from core.log import logger
+from app.core.db import get_db
+from app.repositories.settings_repo import SettingsRepository
+from app.models.schemas import SettingsSchema
+from app.api.common import success_response, error_response
+from app.core.log import logger
 
 router = APIRouter(prefix="/api/settings", tags=["settings"])
 settings_repo = SettingsRepository()
 
 
-def success_response(message: str, data=None):
-    return {"code": 200, "message": message, "data": data}
-
-
-def error_response(message: str, code: int = 500):
-    return {"code": code, "message": message, "data": None}
-
-
 @router.get("")
 async def get_settings():
     try:
@@ -25,7 +18,7 @@ async def get_settings():
         return success_response("获取设置成功", settings)
     except Exception as e:
         logger.error(f"Get settings failed: {e}")
-        return error_response("获取设置失败")
+        return error_response("获取设置失败", 500)
 
 
 @router.post("")
@@ -34,8 +27,8 @@ async def save_settings(request: SettingsSchema):
         async with get_db() as db:
             success = await settings_repo.save(db, request.model_dump())
         if not success:
-            return error_response("保存设置失败")
+            return error_response("保存设置失败", 500)
         return success_response("保存设置成功", request.model_dump())
     except Exception as e:
         logger.error(f"Save settings failed: {e}")
-        return error_response(f"保存设置失败: {str(e)}")
+        return error_response(f"保存设置失败: {str(e)}", 500)
diff --git a/app/core/__init__.py b/app/core/__init__.py
new file mode 100644
index 0000000..ccae523
--- /dev/null
+++ b/app/core/__init__.py
@@ -0,0 +1,13 @@
+"""核心基础设施包"""
+from .config import settings
+from .log import logger
+from .exceptions import ProxyPoolException, PluginNotFoundException, ProxyNotFoundException, ValidationException
+
+__all__ = [
+    "settings",
+    "logger",
+    "ProxyPoolException",
+    "PluginNotFoundException",
+    "ProxyNotFoundException",
+    "ValidationException",
+]
diff --git a/core/config.py b/app/core/config.py
similarity index 93%
rename from core/config.py
rename to app/core/config.py
index 7d67ba7..6b596a6 100644
--- a/core/config.py
+++ b/app/core/config.py
@@ -52,7 +52,7 @@ class Settings(BaseSettings):
 
     @property
     def base_dir(self) -> str:
-        return os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
+        return os.path.dirname(os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
 
 
 # 全局配置实例（启动时加载一次）
diff --git a/core/db.py b/app/core/db.py
similarity index 98%
rename from core/db.py
rename to app/core/db.py
index 4a577d0..c811999 100644
--- a/core/db.py
+++ b/app/core/db.py
@@ -3,8 +3,8 @@ import os
 import aiosqlite
 from contextlib import asynccontextmanager
 from typing import AsyncIterator
-from core.config import settings
-from core.log import logger
+from app.core.config import settings
+from app.core.log import logger
 
 
 DB_PATH = os.path.join(settings.base_dir, settings.db_path)
diff --git a/core/exceptions.py b/app/core/exceptions.py
similarity index 100%
rename from core/exceptions.py
rename to app/core/exceptions.py
diff --git a/core/log.py b/app/core/log.py
similarity index 93%
rename from core/log.py
rename to app/core/log.py
index 45d75b8..3e056e7 100644
--- a/core/log.py
+++ b/app/core/log.py
@@ -3,12 +3,13 @@ import os
 from logging.handlers import RotatingFileHandler
 from datetime import datetime
 
+
 class LogHandler(logging.Logger):
     def __init__(self, name='ProxyPool', level=logging.INFO):
         super().__init__(name, level)
         
         # 获取项目根目录并创建 logs 目录
-        base_dir = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
+        base_dir = os.path.dirname(os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
         log_dir = os.path.join(base_dir, 'logs')
         if not os.path.exists(log_dir):
             os.makedirs(log_dir)
@@ -38,6 +39,7 @@ class LogHandler(logging.Logger):
         console_handler.setFormatter(formatter)
         self.addHandler(console_handler)
 
+
 # 实例化一个默认 logger 供外部直接使用
 logger = LogHandler()
 
diff --git a/core/plugin_system/__init__.py b/app/core/plugin_system/__init__.py
similarity index 85%
rename from core/plugin_system/__init__.py
rename to app/core/plugin_system/__init__.py
index c50e13a..d77d962 100644
--- a/core/plugin_system/__init__.py
+++ b/app/core/plugin_system/__init__.py
@@ -1,3 +1,4 @@
+"""插件系统包"""
 from .base import BaseCrawlerPlugin, ProxyRaw
 from .registry import registry
 
diff --git a/core/plugin_system/base.py b/app/core/plugin_system/base.py
similarity index 100%
rename from core/plugin_system/base.py
rename to app/core/plugin_system/base.py
diff --git a/core/plugin_system/registry.py b/app/core/plugin_system/registry.py
similarity index 97%
rename from core/plugin_system/registry.py
rename to app/core/plugin_system/registry.py
index fe40a30..9494b83 100644
--- a/core/plugin_system/registry.py
+++ b/app/core/plugin_system/registry.py
@@ -3,8 +3,8 @@ import importlib
 import inspect
 import os
 from typing import Dict, List, Type, Optional
-from core.plugin_system.base import BaseCrawlerPlugin
-from core.log import logger
+from app.core.plugin_system.base import BaseCrawlerPlugin
+from app.core.log import logger
 
 
 class PluginRegistry:
diff --git a/core/tasks/__init__.py b/app/core/tasks/__init__.py
similarity index 75%
rename from core/tasks/__init__.py
rename to app/core/tasks/__init__.py
index 0eadd5c..1d81ecd 100644
--- a/core/tasks/__init__.py
+++ b/app/core/tasks/__init__.py
@@ -1,3 +1,4 @@
+"""任务队列包"""
 from .queue import ValidationQueue
 
 __all__ = ["ValidationQueue"]
diff --git a/core/tasks/queue.py b/app/core/tasks/queue.py
similarity index 96%
rename from core/tasks/queue.py
rename to app/core/tasks/queue.py
index 072453d..1336f0e 100644
--- a/core/tasks/queue.py
+++ b/app/core/tasks/queue.py
@@ -1,10 +1,10 @@
 """验证任务队列 - 解耦爬取与验证，支持背压控制和持久化"""
 import asyncio
 from typing import Optional
-from models.domain import ProxyRaw
-from repositories.task_repo import ValidationTaskRepository
-from core.db import get_db
-from core.log import logger
+from app.models.domain import ProxyRaw
+from app.repositories.task_repo import ValidationTaskRepository
+from app.core.db import get_db
+from app.core.log import logger
 
 
 class ValidationQueue:
diff --git a/app/models/__init__.py b/app/models/__init__.py
new file mode 100644
index 0000000..f42e11f
--- /dev/null
+++ b/app/models/__init__.py
@@ -0,0 +1,30 @@
+"""数据模型包"""
+from .domain import ProxyRaw, Proxy, PluginInfo
+from .schemas import (
+    ProxyCreate,
+    ProxyResponse,
+    PluginResponse,
+    SettingsSchema,
+    CrawlResult,
+    ProxyListRequest,
+    ProxyDeleteItem,
+    BatchDeleteRequest,
+    PluginToggleRequest,
+    ExportRequest,
+)
+
+__all__ = [
+    "ProxyRaw",
+    "Proxy",
+    "PluginInfo",
+    "ProxyCreate",
+    "ProxyResponse",
+    "PluginResponse",
+    "SettingsSchema",
+    "CrawlResult",
+    "ProxyListRequest",
+    "ProxyDeleteItem",
+    "BatchDeleteRequest",
+    "PluginToggleRequest",
+    "ExportRequest",
+]
diff --git a/models/domain.py b/app/models/domain.py
similarity index 100%
rename from models/domain.py
rename to app/models/domain.py
diff --git a/models/schemas.py b/app/models/schemas.py
similarity index 100%
rename from models/schemas.py
rename to app/models/schemas.py
diff --git a/plugins/__init__.py b/app/plugins/__init__.py
similarity index 93%
rename from plugins/__init__.py
rename to app/plugins/__init__.py
index d22a516..3f702fc 100644
--- a/plugins/__init__.py
+++ b/app/plugins/__init__.py
@@ -1,5 +1,5 @@
 """插件包 - 在这里显式注册所有爬虫插件"""
-from core.plugin_system import registry
+from app.core.plugin_system import registry
 
 from .fate0 import Fate0Plugin
 from .proxylist_download import ProxyListDownloadPlugin
diff --git a/plugins/base.py b/app/plugins/base.py
similarity index 97%
rename from plugins/base.py
rename to app/plugins/base.py
index eede0b1..749d97d 100644
--- a/plugins/base.py
+++ b/app/plugins/base.py
@@ -3,7 +3,7 @@ import random
 import asyncio
 import aiohttp
 from typing import List
-from core.plugin_system import BaseCrawlerPlugin
+from app.core.plugin_system import BaseCrawlerPlugin
 
 
 class BaseHTTPPlugin(BaseCrawlerPlugin):
diff --git a/plugins/fate0.py b/app/plugins/fate0.py
similarity index 90%
rename from plugins/fate0.py
rename to app/plugins/fate0.py
index cb2cc6d..1c359b8 100644
--- a/plugins/fate0.py
+++ b/app/plugins/fate0.py
@@ -1,8 +1,8 @@
 import json
 from typing import List
-from core.plugin_system import ProxyRaw
-from plugins.base import BaseHTTPPlugin
-from core.log import logger
+from app.core.plugin_system import ProxyRaw
+from app.plugins.base import BaseHTTPPlugin
+from app.core.log import logger
 
 
 class Fate0Plugin(BaseHTTPPlugin):
diff --git a/plugins/ip3366.py b/app/plugins/ip3366.py
similarity index 93%
rename from plugins/ip3366.py
rename to app/plugins/ip3366.py
index da56052..e2dbec4 100644
--- a/plugins/ip3366.py
+++ b/app/plugins/ip3366.py
@@ -1,9 +1,9 @@
 import re
 from typing import List
 from bs4 import BeautifulSoup
-from core.plugin_system import ProxyRaw
-from plugins.base import BaseHTTPPlugin
-from core.log import logger
+from app.core.plugin_system import ProxyRaw
+from app.plugins.base import BaseHTTPPlugin
+from app.core.log import logger
 
 VALID_PROTOCOLS = ("http", "https", "socks4", "socks5")
 
diff --git a/plugins/ip89.py b/app/plugins/ip89.py
similarity index 91%
rename from plugins/ip89.py
rename to app/plugins/ip89.py
index a5bbc70..2b99add 100644
--- a/plugins/ip89.py
+++ b/app/plugins/ip89.py
@@ -1,9 +1,9 @@
 import re
 from typing import List
 from bs4 import BeautifulSoup
-from core.plugin_system import ProxyRaw
-from plugins.base import BaseHTTPPlugin
-from core.log import logger
+from app.core.plugin_system import ProxyRaw
+from app.plugins.base import BaseHTTPPlugin
+from app.core.log import logger
 
 
 class Ip89Plugin(BaseHTTPPlugin):
diff --git a/plugins/kuaidaili.py b/app/plugins/kuaidaili.py
similarity index 93%
rename from plugins/kuaidaili.py
rename to app/plugins/kuaidaili.py
index 2c2fbba..74efed8 100644
--- a/plugins/kuaidaili.py
+++ b/app/plugins/kuaidaili.py
@@ -1,9 +1,9 @@
 import re
 from typing import List
 from bs4 import BeautifulSoup
-from core.plugin_system import ProxyRaw
-from plugins.base import BaseHTTPPlugin
-from core.log import logger
+from app.core.plugin_system import ProxyRaw
+from app.plugins.base import BaseHTTPPlugin
+from app.core.log import logger
 
 VALID_PROTOCOLS = ("http", "https", "socks4", "socks5")
 
diff --git a/plugins/proxylist_download.py b/app/plugins/proxylist_download.py
similarity index 93%
rename from plugins/proxylist_download.py
rename to app/plugins/proxylist_download.py
index 0456c84..4c7883c 100644
--- a/plugins/proxylist_download.py
+++ b/app/plugins/proxylist_download.py
@@ -1,7 +1,7 @@
 from typing import List
-from core.plugin_system import ProxyRaw
-from plugins.base import BaseHTTPPlugin
-from core.log import logger
+from app.core.plugin_system import ProxyRaw
+from app.plugins.base import BaseHTTPPlugin
+from app.core.log import logger
 
 
 class ProxyListDownloadPlugin(BaseHTTPPlugin):
diff --git a/plugins/proxyscrape.py b/app/plugins/proxyscrape.py
similarity index 96%
rename from plugins/proxyscrape.py
rename to app/plugins/proxyscrape.py
index 9a252f6..e02bd60 100644
--- a/plugins/proxyscrape.py
+++ b/app/plugins/proxyscrape.py
@@ -1,8 +1,8 @@
 """ProxyScrape 测试爬虫 - 用于验证架构，支持全协议类型"""
 from typing import List
-from core.plugin_system import ProxyRaw
-from plugins.base import BaseHTTPPlugin
-from core.log import logger
+from app.core.plugin_system import ProxyRaw
+from app.plugins.base import BaseHTTPPlugin
+from app.core.log import logger
 
 
 class ProxyScrapePlugin(BaseHTTPPlugin):
diff --git a/plugins/speedx.py b/app/plugins/speedx.py
similarity index 93%
rename from plugins/speedx.py
rename to app/plugins/speedx.py
index 5fc897d..0e86e0c 100644
--- a/plugins/speedx.py
+++ b/app/plugins/speedx.py
@@ -1,8 +1,8 @@
 import re
 from typing import List
-from core.plugin_system import ProxyRaw
-from plugins.base import BaseHTTPPlugin
-from core.log import logger
+from app.core.plugin_system import ProxyRaw
+from app.plugins.base import BaseHTTPPlugin
+from app.core.log import logger
 
 
 class SpeedXPlugin(BaseHTTPPlugin):
diff --git a/plugins/yundaili.py b/app/plugins/yundaili.py
similarity index 93%
rename from plugins/yundaili.py
rename to app/plugins/yundaili.py
index 2e5435e..c5bc2f2 100644
--- a/plugins/yundaili.py
+++ b/app/plugins/yundaili.py
@@ -1,9 +1,9 @@
 import re
 from typing import List
 from bs4 import BeautifulSoup
-from core.plugin_system import ProxyRaw
-from plugins.base import BaseHTTPPlugin
-from core.log import logger
+from app.core.plugin_system import ProxyRaw
+from app.plugins.base import BaseHTTPPlugin
+from app.core.log import logger
 
 VALID_PROTOCOLS = ("http", "https", "socks4", "socks5")
 
diff --git a/repositories/__init__.py b/app/repositories/__init__.py
similarity index 51%
rename from repositories/__init__.py
rename to app/repositories/__init__.py
index cb9907c..774d2d5 100644
--- a/repositories/__init__.py
+++ b/app/repositories/__init__.py
@@ -1,5 +1,11 @@
+"""数据访问层包"""
 from .proxy_repo import ProxyRepository
 from .settings_repo import SettingsRepository, PluginSettingsRepository
 from .task_repo import ValidationTaskRepository
 
-__all__ = ["ProxyRepository", "SettingsRepository", "PluginSettingsRepository", "ValidationTaskRepository"]
+__all__ = [
+    "ProxyRepository",
+    "SettingsRepository",
+    "PluginSettingsRepository",
+    "ValidationTaskRepository",
+]
diff --git a/repositories/proxy_repo.py b/app/repositories/proxy_repo.py
similarity index 99%
rename from repositories/proxy_repo.py
rename to app/repositories/proxy_repo.py
index 6a3c2ce..0ee418c 100644
--- a/repositories/proxy_repo.py
+++ b/app/repositories/proxy_repo.py
@@ -2,8 +2,8 @@
 import aiosqlite
 from datetime import datetime, timedelta
 from typing import List, Optional, Tuple, Union
-from models.domain import Proxy
-from core.log import logger
+from app.models.domain import Proxy
+from app.core.log import logger
 
 
 VALID_PROTOCOLS = ("http", "https", "socks4", "socks5")
diff --git a/repositories/settings_repo.py b/app/repositories/settings_repo.py
similarity index 99%
rename from repositories/settings_repo.py
rename to app/repositories/settings_repo.py
index b114c57..b2a0994 100644
--- a/repositories/settings_repo.py
+++ b/app/repositories/settings_repo.py
@@ -2,7 +2,7 @@
 import json
 import aiosqlite
 from typing import Optional, Dict, Any
-from core.log import logger
+from app.core.log import logger
 
 
 DEFAULT_SETTINGS = {
diff --git a/repositories/task_repo.py b/app/repositories/task_repo.py
similarity index 98%
rename from repositories/task_repo.py
rename to app/repositories/task_repo.py
index 778c1bc..b682019 100644
--- a/repositories/task_repo.py
+++ b/app/repositories/task_repo.py
@@ -1,8 +1,8 @@
 """验证任务队列持久化层"""
 import aiosqlite
 from typing import List, Optional
-from models.domain import ProxyRaw
-from core.log import logger
+from app.models.domain import ProxyRaw
+from app.core.log import logger
 
 
 class ValidationTaskRepository:
diff --git a/app/services/__init__.py b/app/services/__init__.py
new file mode 100644
index 0000000..059e07d
--- /dev/null
+++ b/app/services/__init__.py
@@ -0,0 +1,12 @@
+"""业务逻辑层包"""
+from .proxy_service import ProxyService
+from .plugin_service import PluginService
+from .scheduler_service import SchedulerService
+from .validator_service import ValidatorService
+
+__all__ = [
+    "ProxyService",
+    "PluginService",
+    "SchedulerService",
+    "ValidatorService",
+]
diff --git a/services/plugin_service.py b/app/services/plugin_service.py
similarity index 94%
rename from services/plugin_service.py
rename to app/services/plugin_service.py
index 17b487e..8071cac 100644
--- a/services/plugin_service.py
+++ b/app/services/plugin_service.py
@@ -1,12 +1,12 @@
 """插件业务服务"""
 from datetime import datetime
 from typing import List, Optional
-from core.db import get_db
-from core.plugin_system.registry import registry
-from core.plugin_system.base import BaseCrawlerPlugin
-from repositories.settings_repo import PluginSettingsRepository
-from models.domain import PluginInfo, ProxyRaw
-from core.log import logger
+from app.core.db import get_db
+from app.core.plugin_system.registry import registry
+from app.core.plugin_system.base import BaseCrawlerPlugin
+from app.repositories.settings_repo import PluginSettingsRepository
+from app.models.domain import PluginInfo, ProxyRaw
+from app.core.log import logger
 
 
 class PluginService:
diff --git a/services/proxy_service.py b/app/services/proxy_service.py
similarity index 95%
rename from services/proxy_service.py
rename to app/services/proxy_service.py
index 6f002b0..4340a73 100644
--- a/services/proxy_service.py
+++ b/app/services/proxy_service.py
@@ -4,10 +4,10 @@ import json
 import io
 from datetime import datetime
 from typing import List, Optional, Tuple, AsyncIterator
-from core.db import get_db
-from repositories.proxy_repo import ProxyRepository
-from models.domain import Proxy
-from core.log import logger
+from app.core.db import get_db
+from app.repositories.proxy_repo import ProxyRepository
+from app.models.domain import Proxy
+from app.core.log import logger
 
 
 class ProxyService:
diff --git a/services/scheduler_service.py b/app/services/scheduler_service.py
similarity index 91%
rename from services/scheduler_service.py
rename to app/services/scheduler_service.py
index 5d9e402..aedfd1a 100644
--- a/services/scheduler_service.py
+++ b/app/services/scheduler_service.py
@@ -1,11 +1,11 @@
 """调度器服务 - 定时验证存量代理"""
 import asyncio
 from datetime import datetime
-from core.db import get_db
-from repositories.proxy_repo import ProxyRepository
-from core.tasks.queue import ValidationQueue
-from core.config import settings as app_settings
-from core.log import logger
+from app.core.db import get_db
+from app.repositories.proxy_repo import ProxyRepository
+from app.core.tasks.queue import ValidationQueue
+from app.core.config import settings as app_settings
+from app.core.log import logger
 
 
 class SchedulerService:
@@ -70,7 +70,7 @@ class SchedulerService:
             return
 
         logger.info(f"Validating {len(proxies)} proxies from database")
-        from models.domain import ProxyRaw
+        from app.models.domain import ProxyRaw
 
         # 批量提交到验证队列
         batch_size = 100
diff --git a/services/validator_service.py b/app/services/validator_service.py
similarity index 77%
rename from services/validator_service.py
rename to app/services/validator_service.py
index 4b86137..7aeaf19 100644
--- a/services/validator_service.py
+++ b/app/services/validator_service.py
@@ -5,12 +5,18 @@ import time
 import aiohttp
 import aiohttp_socks
 from typing import Tuple
-from core.log import logger
+from app.core.log import logger
 
 
 class ValidatorService:
     """代理验证器"""
 
+    # 测试 URL
+    TEST_URLS = {
+        "http": ["http://httpbin.org/ip", "http://api.ipify.org"],
+        "https": ["https://httpbin.org/ip", "https://api.ipify.org"],
+    }
+
     def __init__(
         self,
         timeout: float = 5.0,
@@ -20,33 +26,23 @@ class ValidatorService:
         self.timeout = timeout
         self.connect_timeout = connect_timeout
         self.semaphore = asyncio.Semaphore(max_concurrency)
-        self.http_sources = [
-            "http://httpbin.org/ip",
-            "http://api.ipify.org",
-        ]
-        self.https_sources = [
-            "https://httpbin.org/ip",
-            "https://api.ipify.org",
-        ]
 
     def _get_test_url(self, protocol: str) -> str:
-        protocol = protocol.lower()
-        if protocol == "https":
-            return random.choice(self.https_sources)
-        return random.choice(self.http_sources)
+        """获取测试 URL"""
+        urls = self.TEST_URLS.get(protocol.lower(), self.TEST_URLS["http"])
+        return random.choice(urls)
 
     async def validate(self, ip: str, port: int, protocol: str = "http") -> Tuple[bool, float]:
         """验证单个代理，返回 (是否有效, 延迟毫秒)"""
         protocol = protocol.lower()
-        test_url = self._get_test_url(protocol)
-
+        
         async with self.semaphore:
             start = time.time()
             try:
                 if protocol in ("socks4", "socks5"):
-                    return await self._validate_socks(ip, port, protocol, test_url, start)
+                    return await self._validate_socks(ip, port, protocol, start)
                 else:
-                    return await self._validate_http(ip, port, protocol, test_url, start)
+                    return await self._validate_http(ip, port, protocol, start)
             except asyncio.TimeoutError:
                 logger.debug(f"Validation timeout: {ip}:{port} ({protocol})")
                 return False, 0.0
@@ -54,18 +50,16 @@ class ValidatorService:
                 logger.debug(f"Validation error {ip}:{port} ({protocol}): {e}")
                 return False, 0.0
 
-    async def _validate_http(
-        self, ip: str, port: int, protocol: str, test_url: str, start: float
-    ) -> Tuple[bool, float]:
+    async def _validate_http(self, ip: str, port: int, protocol: str, start: float) -> Tuple[bool, float]:
+        """验证 HTTP/HTTPS 代理"""
         proxy_url = f"http://{ip}:{port}"
         connector = aiohttp.TCPConnector(ssl=False, limit=0, force_close=True)
         timeout = aiohttp.ClientTimeout(total=self.timeout, connect=self.connect_timeout)
+        test_url = self._get_test_url(protocol)
 
         try:
             async with aiohttp.ClientSession(connector=connector, timeout=timeout) as session:
-                async with session.get(
-                    test_url, proxy=proxy_url, allow_redirects=True
-                ) as response:
+                async with session.get(test_url, proxy=proxy_url, allow_redirects=True) as response:
                     if response.status in (200, 301, 302):
                         latency = round((time.time() - start) * 1000, 2)
                         logger.info(f"HTTP valid: {ip}:{port} ({protocol}) {latency}ms")
@@ -74,9 +68,8 @@ class ValidatorService:
         finally:
             await connector.close()
 
-    async def _validate_socks(
-        self, ip: str, port: int, protocol: str, test_url: str, start: float
-    ) -> Tuple[bool, float]:
+    async def _validate_socks(self, ip: str, port: int, protocol: str, start: float) -> Tuple[bool, float]:
+        """验证 SOCKS4/SOCKS5 代理"""
         proxy_type = (
             aiohttp_socks.ProxyType.SOCKS4
             if protocol == "socks4"
@@ -90,6 +83,7 @@ class ValidatorService:
             ssl=False,
         )
         timeout = aiohttp.ClientTimeout(total=self.timeout, connect=self.connect_timeout)
+        test_url = self._get_test_url("http")
 
         try:
             async with aiohttp.ClientSession(connector=connector, timeout=timeout) as session:
diff --git a/main.py b/main.py
index f2381bb..be6ed3b 100644
--- a/main.py
+++ b/main.py
@@ -1,7 +1,7 @@
 """项目入口"""
 import uvicorn
-from api import create_app
-from core.config import settings
+from app.api import create_app
+from app.core.config import settings
 
 app = create_app()
 
diff --git a/models/__init__.py b/models/__init__.py
deleted file mode 100644
index 7302f2b..0000000
--- a/models/__init__.py
+++ /dev/null
@@ -1,13 +0,0 @@
-from .domain import ProxyRaw, Proxy, PluginInfo
-from .schemas import ProxyCreate, ProxyResponse, PluginResponse, SettingsSchema, CrawlResult
-
-__all__ = [
-    "ProxyRaw",
-    "Proxy",
-    "PluginInfo",
-    "ProxyCreate",
-    "ProxyResponse",
-    "PluginResponse",
-    "SettingsSchema",
-    "CrawlResult",
-]
diff --git a/pytest.ini b/pytest.ini
new file mode 100644
index 0000000..98047b6
--- /dev/null
+++ b/pytest.ini
@@ -0,0 +1,17 @@
+[tool:pytest]
+testpaths = tests
+python_files = test_*.py
+python_classes = Test*
+python_functions = test_*
+addopts = 
+    -v
+    --tb=short
+    --strict-markers
+    -p no:warnings
+markers =
+    unit: 单元测试
+    integration: 集成测试
+    e2e: 端到端测试
+    slow: 慢速测试
+    async_test: 异步测试
+asyncio_mode = auto
diff --git a/script/start.bat b/script/start.bat
index 80fa8d7..ef21249 100644
--- a/script/start.bat
+++ b/script/start.bat
@@ -74,7 +74,7 @@ echo.
 
 REM 4. Start Frontend
 echo [4/4] Starting frontend (Vite)...
-cd /d "%ROOT_PATH%\frontend"
+cd /d "%ROOT_PATH%\WebUI"
 start /B "" cmd /c "npm run dev"
 cd /d "%ROOT_PATH%"
 echo   Frontend started
diff --git a/tests/README.md b/tests/README.md
new file mode 100644
index 0000000..1d0a869
--- /dev/null
+++ b/tests/README.md
@@ -0,0 +1,159 @@
+# 测试说明
+
+## 测试结构
+
+```
+tests/
+├── conftest.py              # pytest 配置和 fixtures
+├── README.md                # 本文件
+├── unit/                    # 单元测试
+│   ├── test_models.py       # 模型测试
+│   └── test_repositories.py # 仓库层测试
+├── integration/             # 集成测试
+│   ├── test_proxies_api.py  # 代理 API 测试
+│   ├── test_plugins_api.py  # 插件 API 测试
+│   ├── test_scheduler_api.py # 调度器 API 测试
+│   ├── test_settings_api.py # 设置 API 测试
+│   └── test_health_api.py   # 健康检查测试
+└── e2e/                     # 端到端测试
+    └── test_full_workflow.py # 完整工作流测试
+```
+
+## 运行测试
+
+### 安装测试依赖
+
+```bash
+pip install pytest pytest-asyncio httpx
+```
+
+### 运行所有测试
+
+```bash
+pytest
+```
+
+### 运行特定类型的测试
+
+```bash
+# 仅运行单元测试
+pytest tests/unit -v
+
+# 仅运行集成测试
+pytest tests/integration -v
+
+# 仅运行 E2E 测试
+pytest tests/e2e -v
+```
+
+### 运行特定测试文件
+
+```bash
+pytest tests/integration/test_proxies_api.py -v
+```
+
+### 运行特定测试函数
+
+```bash
+pytest tests/integration/test_proxies_api.py::TestProxiesAPI::test_get_stats -v
+```
+
+## 测试覆盖的 API
+
+### 代理 API (`/api/proxies/*`)
+
+- ✅ `GET /api/proxies/stats` - 获取统计信息
+- ✅ `POST /api/proxies` - 列出代理
+- ✅ `GET /api/proxies/random` - 获取随机代理
+- ✅ `GET /api/proxies/export/{format}` - 导出代理 (csv, txt, json)
+- ✅ `DELETE /api/proxies/{ip}/{port}` - 删除代理
+- ✅ `POST /api/proxies/batch-delete` - 批量删除
+- ✅ `DELETE /api/proxies/clean-invalid` - 清理无效代理
+
+### 插件 API (`/api/plugins/*`)
+
+- ✅ `GET /api/plugins` - 列出插件
+- ✅ `PUT /api/plugins/{id}/toggle` - 切换插件状态
+- ✅ `GET /api/plugins/{id}/config` - 获取插件配置
+- ✅ `POST /api/plugins/{id}/config` - 更新插件配置
+- ✅ `POST /api/plugins/{id}/crawl` - 触发单个插件爬取
+- ✅ `POST /api/plugins/crawl-all` - 触发所有插件爬取
+
+### 调度器 API (`/api/scheduler/*`)
+
+- ✅ `GET /api/scheduler/status` - 获取调度器状态
+- ✅ `POST /api/scheduler/start` - 启动调度器
+- ✅ `POST /api/scheduler/stop` - 停止调度器
+- ✅ `POST /api/scheduler/validate-now` - 立即验证
+
+### 设置 API (`/api/settings`)
+
+- ✅ `GET /api/settings` - 获取设置
+- ✅ `POST /api/settings` - 保存设置
+
+### 健康检查
+
+- ✅ `GET /` - 根端点
+- ✅ `GET /health` - 健康检查
+
+## 测试 Fixtures
+
+### `client`
+
+异步 HTTP 客户端，用于发送请求到测试应用。
+
+```python
+async def test_example(client):
+    response = await client.get("/api/proxies/stats")
+    assert response.status_code == 200
+```
+
+### `db`
+
+数据库连接 fixture。
+
+```python
+async def test_example(db, proxy_repo):
+    await proxy_repo.insert_or_update(db, "192.168.1.1", 8080, "http", 50)
+```
+
+### `sample_proxy`
+
+创建一个测试代理并自动清理。
+
+```python
+async def test_example(client, sample_proxy):
+    # sample_proxy = {"ip": "192.168.1.1", "port": 8080, "protocol": "http", "score": 50}
+    response = await client.delete(f"/api/proxies/{sample_proxy['ip']}/{sample_proxy['port']}")
+    assert response.status_code == 200
+```
+
+## 编写新测试
+
+### 单元测试示例
+
+```python
+# tests/unit/test_new_feature.py
+import pytest
+from app.models.domain import ProxyRaw
+
+
+class TestProxyRaw:
+    def test_create(self):
+        proxy = ProxyRaw("192.168.1.1", 8080, "http")
+        assert proxy.ip == "192.168.1.1"
+```
+
+### 集成测试示例
+
+```python
+# tests/integration/test_new_api.py
+import pytest
+
+
+class TestNewAPI:
+    @pytest.mark.asyncio
+    async def test_new_endpoint(self, client):
+        response = await client.get("/api/new-endpoint")
+        assert response.status_code == 200
+```
diff --git a/tests/__init__.py b/tests/__init__.py
new file mode 100644
index 0000000..4540de9
--- /dev/null
+++ b/tests/__init__.py
@@ -0,0 +1 @@
+"""测试包"""
diff --git a/tests/__main__.py b/tests/__main__.py
new file mode 100644
index 0000000..7d9caeb
--- /dev/null
+++ b/tests/__main__.py
@@ -0,0 +1,5 @@
+"""直接运行 python -m tests 时执行的入口"""
+from .run_tests import main
+import sys
+
+sys.exit(main())
diff --git a/tests/__pycache__/conftest.cpython-311.pyc b/tests/__pycache__/conftest.cpython-311.pyc
new file mode 100644
index 0000000..be7c139
Binary files /dev/null and b/tests/__pycache__/conftest.cpython-311.pyc differ
diff --git a/tests/conftest.py b/tests/conftest.py
new file mode 100644
index 0000000..dc299a7
--- /dev/null
+++ b/tests/conftest.py
@@ -0,0 +1,56 @@
+"""pytest 配置文件和 fixtures"""
+import pytest
+import asyncio
+from typing import AsyncGenerator, Generator
+from httpx import AsyncClient, ASGITransport
+
+from app.api import create_app
+from app.core.db import init_db, get_db
+from app.repositories.proxy_repo import ProxyRepository
+
+
+@pytest.fixture(scope="session")
+def event_loop() -> Generator[asyncio.AbstractEventLoop, None, None]:
+    """创建事件循环"""
+    loop = asyncio.get_event_loop_policy().new_event_loop()
+    yield loop
+    loop.close()
+
+
+@pytest.fixture(scope="session")
+async def app():
+    """创建应用实例"""
+    # 初始化测试数据库
+    await init_db()
+    app = create_app()
+    return app
+
+
+@pytest.fixture
+async def client(app) -> AsyncGenerator[AsyncClient, None]:
+    """创建异步 HTTP 客户端"""
+    transport = ASGITransport(app=app)
+    async with AsyncClient(transport=transport, base_url="http://test") as client:
+        yield client
+
+
+@pytest.fixture
+async def db():
+    """获取数据库连接"""
+    async with get_db() as db:
+        yield db
+
+
+@pytest.fixture
+async def proxy_repo():
+    """获取代理仓库"""
+    return ProxyRepository()
+
+
+@pytest.fixture
+async def sample_proxy(db, proxy_repo):
+    """创建一个测试代理"""
+    await proxy_repo.insert_or_update(db, "192.168.1.1", 8080, "http", 50)
+    yield {"ip": "192.168.1.1", "port": 8080, "protocol": "http", "score": 50}
+    # 清理
+    await proxy_repo.delete(db, "192.168.1.1", 8080)
diff --git a/tests/e2e/__init__.py b/tests/e2e/__init__.py
new file mode 100644
index 0000000..6416e9d
--- /dev/null
+++ b/tests/e2e/__init__.py
@@ -0,0 +1 @@
+"""端到端测试"""
diff --git a/tests/e2e/__pycache__/test_full_workflow.cpython-311.pyc b/tests/e2e/__pycache__/test_full_workflow.cpython-311.pyc
new file mode 100644
index 0000000..b366646
Binary files /dev/null and b/tests/e2e/__pycache__/test_full_workflow.cpython-311.pyc differ
diff --git a/tests/e2e/test_full_workflow.py b/tests/e2e/test_full_workflow.py
new file mode 100644
index 0000000..8115122
--- /dev/null
+++ b/tests/e2e/test_full_workflow.py
@@ -0,0 +1,182 @@
+"""完整工作流 E2E 测试
+
+这些测试模拟真实用户场景，验证整个系统的集成功能。
+"""
+import pytest
+
+
+class TestFullWorkflow:
+    """测试完整工作流"""
+
+    @pytest.mark.asyncio
+    async def test_proxy_management_workflow(self, client):
+        """测试代理管理完整工作流
+        
+        场景：
+        1. 查看统计信息
+        2. 列出代理
+        3. 触发爬取
+        4. 查看更新后的统计
+        5. 导出代理
+        6. 清理无效代理
+        """
+        # 1. 获取初始统计
+        response = await client.get("/api/proxies/stats")
+        assert response.status_code == 200
+        initial_stats = response.json()["data"]
+        
+        # 2. 列出代理
+        response = await client.post("/api/proxies", json={
+            "page": 1,
+            "page_size": 20,
+        })
+        assert response.status_code == 200
+        
+        # 3. 触发所有插件爬取
+        response = await client.post("/api/plugins/crawl-all")
+        assert response.status_code == 200
+        crawl_result = response.json()["data"]
+        
+        # 4. 获取更新后的统计
+        response = await client.get("/api/proxies/stats")
+        updated_stats = response.json()["data"]
+        
+        # 5. 导出代理（所有格式）
+        for fmt in ["csv", "txt", "json"]:
+            response = await client.get(f"/api/proxies/export/{fmt}")
+            assert response.status_code == 200
+        
+        # 6. 清理无效代理
+        response = await client.delete("/api/proxies/clean-invalid")
+        assert response.status_code == 200
+
+    @pytest.mark.asyncio
+    async def test_plugin_management_workflow(self, client):
+        """测试插件管理完整工作流
+        
+        场景：
+        1. 列出所有插件
+        2. 禁用某个插件
+        3. 更新插件配置
+        4. 启用插件
+        5. 触发单个插件爬取
+        """
+        # 1. 列出插件
+        response = await client.get("/api/plugins")
+        assert response.status_code == 200
+        plugins = response.json()["data"]["plugins"]
+        
+        if not plugins:
+            pytest.skip("没有可用的插件")
+        
+        plugin_id = plugins[0]["id"]
+        
+        # 2. 禁用插件
+        response = await client.put(f"/api/plugins/{plugin_id}/toggle", json={"enabled": False})
+        assert response.status_code == 200
+        
+        # 3. 获取插件配置
+        response = await client.get(f"/api/plugins/{plugin_id}/config")
+        assert response.status_code == 200
+        
+        # 4. 更新插件配置
+        response = await client.post(
+            f"/api/plugins/{plugin_id}/config",
+            json={"config": {"max_pages": 3}}
+        )
+        assert response.status_code == 200
+        
+        # 5. 启用插件
+        response = await client.put(f"/api/plugins/{plugin_id}/toggle", json={"enabled": True})
+        assert response.status_code == 200
+        
+        # 6. 触发爬取
+        response = await client.post(f"/api/plugins/{plugin_id}/crawl")
+        assert response.status_code == 200
+
+    @pytest.mark.asyncio
+    async def test_scheduler_workflow(self, client):
+        """测试调度器工作流
+        
+        场景：
+        1. 启动调度器
+        2. 触发立即验证
+        3. 检查状态
+        4. 停止调度器
+        """
+        # 1. 启动调度器
+        response = await client.post("/api/scheduler/start")
+        assert response.status_code == 200
+        
+        # 2. 触发立即验证
+        response = await client.post("/api/scheduler/validate-now")
+        assert response.status_code == 200
+        
+        # 3. 检查状态
+        response = await client.get("/api/scheduler/status")
+        assert response.status_code == 200
+        assert response.json()["data"]["running"] is True
+        
+        # 4. 停止调度器
+        response = await client.post("/api/scheduler/stop")
+        assert response.status_code == 200
+        assert response.json()["data"]["running"] is False
+
+    @pytest.mark.asyncio
+    async def test_settings_workflow(self, client):
+        """测试设置工作流
+        
+        场景：
+        1. 获取当前设置
+        2. 修改设置
+        3. 验证设置已保存
+        4. 恢复默认设置
+        """
+        # 1. 获取当前设置
+        response = await client.get("/api/settings")
+        assert response.status_code == 200
+        original_settings = response.json()["data"]
+        
+        # 2. 修改设置
+        new_settings = original_settings.copy()
+        new_settings["crawl_timeout"] = 45
+        new_settings["auto_validate"] = not original_settings["auto_validate"]
+        
+        response = await client.post("/api/settings", json=new_settings)
+        assert response.status_code == 200
+        
+        # 3. 验证设置已保存
+        response = await client.get("/api/settings")
+        saved_settings = response.json()["data"]
+        assert saved_settings["crawl_timeout"] == 45
+        
+        # 4. 恢复原始设置
+        response = await client.post("/api/settings", json=original_settings)
+        assert response.status_code == 200
+
+    @pytest.mark.asyncio
+    async def test_batch_operations_workflow(self, client):
+        """测试批量操作工作流
+        
+        场景：
+        1. 批量删除不存在的代理（幂等性测试）
+        2. 导出所有代理
+        3. 获取随机代理
+        """
+        # 1. 批量删除（幂等性）
+        response = await client.post("/api/proxies/batch-delete", json={
+            "proxies": [
+                {"ip": "192.168.100.1", "port": 8080},
+                {"ip": "192.168.100.2", "port": 8081},
+            ]
+        })
+        assert response.status_code == 200
+        
+        # 2. 导出所有格式
+        for fmt in ["csv", "txt", "json"]:
+            response = await client.get(f"/api/proxies/export/{fmt}")
+            assert response.status_code == 200
+        
+        # 3. 获取随机代理（可能返回 200 或 404）
+        response = await client.get("/api/proxies/random")
+        assert response.status_code in [200, 404]
diff --git a/tests/integration/__init__.py b/tests/integration/__init__.py
new file mode 100644
index 0000000..bb85141
--- /dev/null
+++ b/tests/integration/__init__.py
@@ -0,0 +1 @@
+"""集成测试"""
diff --git a/tests/integration/__pycache__/test_health_api.cpython-311.pyc b/tests/integration/__pycache__/test_health_api.cpython-311.pyc
new file mode 100644
index 0000000..6cb3af8
Binary files /dev/null and b/tests/integration/__pycache__/test_health_api.cpython-311.pyc differ
diff --git a/tests/integration/__pycache__/test_plugins_api.cpython-311.pyc b/tests/integration/__pycache__/test_plugins_api.cpython-311.pyc
new file mode 100644
index 0000000..d570926
Binary files /dev/null and b/tests/integration/__pycache__/test_plugins_api.cpython-311.pyc differ
diff --git a/tests/integration/__pycache__/test_proxies_api.cpython-311.pyc b/tests/integration/__pycache__/test_proxies_api.cpython-311.pyc
new file mode 100644
index 0000000..4162714
Binary files /dev/null and b/tests/integration/__pycache__/test_proxies_api.cpython-311.pyc differ
diff --git a/tests/integration/__pycache__/test_scheduler_api.cpython-311.pyc b/tests/integration/__pycache__/test_scheduler_api.cpython-311.pyc
new file mode 100644
index 0000000..170990e
Binary files /dev/null and b/tests/integration/__pycache__/test_scheduler_api.cpython-311.pyc differ
diff --git a/tests/integration/__pycache__/test_settings_api.cpython-311.pyc b/tests/integration/__pycache__/test_settings_api.cpython-311.pyc
new file mode 100644
index 0000000..265741f
Binary files /dev/null and b/tests/integration/__pycache__/test_settings_api.cpython-311.pyc differ
diff --git a/tests/integration/test_health_api.py b/tests/integration/test_health_api.py
new file mode 100644
index 0000000..5b977e8
--- /dev/null
+++ b/tests/integration/test_health_api.py
@@ -0,0 +1,47 @@
+"""健康检查 API 测试"""
+import pytest
+
+
+class TestHealthAPI:
+    """测试健康检查端点"""
+
+    @pytest.mark.asyncio
+    async def test_root_endpoint(self, client):
+        """测试根端点 /"""
+        response = await client.get("/")
+        assert response.status_code == 200
+        data = response.json()
+        assert "message" in data
+        assert "status" in data
+        assert data["status"] == "running"
+
+    @pytest.mark.asyncio
+    async def test_health_endpoint(self, client):
+        """测试健康检查端点 /health"""
+        response = await client.get("/health")
+        assert response.status_code == 200
+        data = response.json()
+        assert data["status"] == "healthy"
+        assert "timestamp" in data
+        assert "database" in data
+        assert "scheduler" in data
+        assert "version" in data
+
+    @pytest.mark.asyncio
+    async def test_health_endpoint_structure(self, client):
+        """测试健康检查端点返回结构"""
+        response = await client.get("/health")
+        data = response.json()
+        
+        assert "status" in data
+        assert "timestamp" in data
+        assert "database" in data
+        assert "scheduler" in data
+        assert "version" in data
+        
+        # 验证数据类型
+        assert isinstance(data["status"], str)
+        assert isinstance(data["timestamp"], str)
+        assert isinstance(data["database"], str)
+        assert isinstance(data["scheduler"], str)
+        assert isinstance(data["version"], str)
diff --git a/tests/integration/test_plugins_api.py b/tests/integration/test_plugins_api.py
new file mode 100644
index 0000000..fa0dde7
--- /dev/null
+++ b/tests/integration/test_plugins_api.py
@@ -0,0 +1,147 @@
+"""插件 API 集成测试 - 测试 /api/plugins/* 所有接口"""
+import pytest
+
+
+class TestPluginsAPI:
+    """测试插件相关 API"""
+
+    @pytest.mark.asyncio
+    async def test_list_plugins(self, client):
+        """测试 GET /api/plugins"""
+        response = await client.get("/api/plugins")
+        assert response.status_code == 200
+        data = response.json()
+        assert data["code"] == 200
+        assert "plugins" in data["data"]
+        assert isinstance(data["data"]["plugins"], list)
+
+    @pytest.mark.asyncio
+    async def test_list_plugins_structure(self, client):
+        """测试 GET /api/plugins 返回结构"""
+        response = await client.get("/api/plugins")
+        data = response.json()
+        if data["data"]["plugins"]:
+            plugin = data["data"]["plugins"][0]
+            assert "id" in plugin
+            assert "name" in plugin
+            assert "display_name" in plugin
+            assert "description" in plugin
+            assert "enabled" in plugin
+
+    @pytest.mark.asyncio
+    async def test_toggle_plugin_enable(self, client):
+        """测试 PUT /api/plugins/{id}/toggle - 启用"""
+        # 先获取一个插件 ID
+        response = await client.get("/api/plugins")
+        plugins = response.json()["data"]["plugins"]
+        if not plugins:
+            pytest.skip("没有可用的插件")
+        
+        plugin_id = plugins[0]["id"]
+        response = await client.put(f"/api/plugins/{plugin_id}/toggle", json={"enabled": True})
+        assert response.status_code == 200
+        data = response.json()
+        assert data["code"] == 200
+        assert data["data"]["enabled"] is True
+
+    @pytest.mark.asyncio
+    async def test_toggle_plugin_disable(self, client):
+        """测试 PUT /api/plugins/{id}/toggle - 禁用"""
+        response = await client.get("/api/plugins")
+        plugins = response.json()["data"]["plugins"]
+        if not plugins:
+            pytest.skip("没有可用的插件")
+        
+        plugin_id = plugins[0]["id"]
+        response = await client.put(f"/api/plugins/{plugin_id}/toggle", json={"enabled": False})
+        assert response.status_code == 200
+        data = response.json()
+        assert data["code"] == 200
+        assert data["data"]["enabled"] is False
+
+    @pytest.mark.asyncio
+    async def test_toggle_plugin_missing_enabled(self, client):
+        """测试 PUT /api/plugins/{id}/toggle - 缺少 enabled 参数"""
+        response = await client.get("/api/plugins")
+        plugins = response.json()["data"]["plugins"]
+        if not plugins:
+            pytest.skip("没有可用的插件")
+        
+        plugin_id = plugins[0]["id"]
+        response = await client.put(f"/api/plugins/{plugin_id}/toggle", json={})
+        assert response.status_code == 400
+
+    @pytest.mark.asyncio
+    async def test_toggle_nonexistent_plugin(self, client):
+        """测试 PUT /api/plugins/{id}/toggle - 不存在的插件"""
+        response = await client.put("/api/plugins/nonexistent_plugin/toggle", json={"enabled": True})
+        assert response.status_code == 404
+
+    @pytest.mark.asyncio
+    async def test_get_plugin_config(self, client):
+        """测试 GET /api/plugins/{id}/config"""
+        response = await client.get("/api/plugins")
+        plugins = response.json()["data"]["plugins"]
+        if not plugins:
+            pytest.skip("没有可用的插件")
+        
+        plugin_id = plugins[0]["id"]
+        response = await client.get(f"/api/plugins/{plugin_id}/config")
+        assert response.status_code == 200
+        data = response.json()
+        assert data["code"] == 200
+        assert "config" in data["data"]
+
+    @pytest.mark.asyncio
+    async def test_get_nonexistent_plugin_config(self, client):
+        """测试 GET /api/plugins/{id}/config - 不存在的插件"""
+        response = await client.get("/api/plugins/nonexistent_plugin/config")
+        assert response.status_code == 404
+
+    @pytest.mark.asyncio
+    async def test_update_plugin_config(self, client):
+        """测试 POST /api/plugins/{id}/config"""
+        response = await client.get("/api/plugins")
+        plugins = response.json()["data"]["plugins"]
+        if not plugins:
+            pytest.skip("没有可用的插件")
+        
+        plugin_id = plugins[0]["id"]
+        response = await client.post(
+            f"/api/plugins/{plugin_id}/config",
+            json={"config": {"max_pages": 3}}
+        )
+        assert response.status_code == 200
+        data = response.json()
+        assert data["code"] == 200
+
+    @pytest.mark.asyncio
+    async def test_crawl_plugin(self, client):
+        """测试 POST /api/plugins/{id}/crawl"""
+        response = await client.get("/api/plugins")
+        plugins = response.json()["data"]["plugins"]
+        if not plugins:
+            pytest.skip("没有可用的插件")
+        
+        plugin_id = plugins[0]["id"]
+        # 这个测试可能需要较长时间，设置较短的超时
+        response = await client.post(f"/api/plugins/{plugin_id}/crawl")
+        assert response.status_code == 200
+        data = response.json()
+        assert data["code"] == 200
+        assert "proxy_count" in data["data"]
+
+    @pytest.mark.asyncio
+    async def test_crawl_nonexistent_plugin(self, client):
+        """测试 POST /api/plugins/{id}/crawl - 不存在的插件"""
+        response = await client.post("/api/plugins/nonexistent_plugin/crawl")
+        assert response.status_code == 404
+
+    @pytest.mark.asyncio
+    async def test_crawl_all_plugins(self, client):
+        """测试 POST /api/plugins/crawl-all"""
+        response = await client.post("/api/plugins/crawl-all")
+        assert response.status_code == 200
+        data = response.json()
+        assert data["code"] == 200
+        assert "total_crawled" in data["data"]
diff --git a/tests/integration/test_proxies_api.py b/tests/integration/test_proxies_api.py
new file mode 100644
index 0000000..06b494c
--- /dev/null
+++ b/tests/integration/test_proxies_api.py
@@ -0,0 +1,144 @@
+"""代理 API 集成测试 - 测试 /api/proxies/* 所有接口"""
+import pytest
+
+
+class TestProxiesAPI:
+    """测试代理相关 API"""
+
+    @pytest.mark.asyncio
+    async def test_get_stats(self, client):
+        """测试 GET /api/proxies/stats"""
+        response = await client.get("/api/proxies/stats")
+        assert response.status_code == 200
+        data = response.json()
+        assert data["code"] == 200
+        assert "data" in data
+        assert "total" in data["data"]
+        assert "available" in data["data"]
+        assert "scheduler_running" in data["data"]
+
+    @pytest.mark.asyncio
+    async def test_list_proxies(self, client):
+        """测试 POST /api/proxies"""
+        request_data = {
+            "page": 1,
+            "page_size": 10,
+            "protocol": None,
+            "min_score": 0,
+            "sort_by": "last_check",
+            "sort_order": "DESC"
+        }
+        response = await client.post("/api/proxies", json=request_data)
+        assert response.status_code == 200
+        data = response.json()
+        assert data["code"] == 200
+        assert "list" in data["data"]
+        assert "total" in data["data"]
+        assert "page" in data["data"]
+
+    @pytest.mark.asyncio
+    async def test_list_proxies_with_protocol_filter(self, client):
+        """测试 POST /api/proxies 带协议过滤"""
+        request_data = {
+            "page": 1,
+            "page_size": 10,
+            "protocol": "http",
+            "min_score": 0,
+        }
+        response = await client.post("/api/proxies", json=request_data)
+        assert response.status_code == 200
+        data = response.json()
+        assert data["code"] == 200
+
+    @pytest.mark.asyncio
+    async def test_list_proxies_invalid_protocol(self, client):
+        """测试 POST /api/proxies 无效协议"""
+        request_data = {
+            "page": 1,
+            "page_size": 10,
+            "protocol": "invalid",
+        }
+        response = await client.post("/api/proxies", json=request_data)
+        assert response.status_code == 422  # 验证错误
+
+    @pytest.mark.asyncio
+    async def test_get_random_proxy_empty(self, client):
+        """测试 GET /api/proxies/random - 空数据库"""
+        response = await client.get("/api/proxies/random")
+        # 可能返回 200(有数据) 或 404(无数据)
+        assert response.status_code in [200, 404]
+
+    @pytest.mark.asyncio
+    async def test_delete_proxy(self, client, sample_proxy):
+        """测试 DELETE /api/proxies/{ip}/{port}"""
+        response = await client.delete(f"/api/proxies/{sample_proxy['ip']}/{sample_proxy['port']}")
+        assert response.status_code == 200
+        data = response.json()
+        assert data["code"] == 200
+
+    @pytest.mark.asyncio
+    async def test_delete_nonexistent_proxy(self, client):
+        """测试 DELETE /api/proxies/{ip}/{port} - 不存在的代理"""
+        response = await client.delete("/api/proxies/999.999.999.999/99999")
+        # 即使代理不存在也返回成功（幂等删除）
+        assert response.status_code == 200
+
+    @pytest.mark.asyncio
+    async def test_batch_delete_proxies(self, client):
+        """测试 POST /api/proxies/batch-delete"""
+        request_data = {
+            "proxies": [
+                {"ip": "192.168.1.1", "port": 8080},
+                {"ip": "192.168.1.2", "port": 8081},
+            ]
+        }
+        response = await client.post("/api/proxies/batch-delete", json=request_data)
+        assert response.status_code == 200
+        data = response.json()
+        assert data["code"] == 200
+        assert "deleted_count" in data["data"]
+
+    @pytest.mark.asyncio
+    async def test_batch_delete_too_many(self, client):
+        """测试 POST /api/proxies/batch-delete - 超过限制"""
+        request_data = {
+            "proxies": [{"ip": f"192.168.1.{i}", "port": 8080} for i in range(1001)]
+        }
+        response = await client.post("/api/proxies/batch-delete", json=request_data)
+        assert response.status_code == 422  # 验证错误
+
+    @pytest.mark.asyncio
+    async def test_clean_invalid_proxies(self, client):
+        """测试 DELETE /api/proxies/clean-invalid"""
+        response = await client.delete("/api/proxies/clean-invalid")
+        assert response.status_code == 200
+        data = response.json()
+        assert data["code"] == 200
+        assert "deleted_count" in data["data"]
+
+    @pytest.mark.asyncio
+    async def test_export_proxies_csv(self, client):
+        """测试 GET /api/proxies/export/csv"""
+        response = await client.get("/api/proxies/export/csv")
+        assert response.status_code == 200
+        assert response.headers["content-type"] == "text/csv"
+
+    @pytest.mark.asyncio
+    async def test_export_proxies_txt(self, client):
+        """测试 GET /api/proxies/export/txt"""
+        response = await client.get("/api/proxies/export/txt")
+        assert response.status_code == 200
+        assert response.headers["content-type"] == "text/plain"
+
+    @pytest.mark.asyncio
+    async def test_export_proxies_json(self, client):
+        """测试 GET /api/proxies/export/json"""
+        response = await client.get("/api/proxies/export/json")
+        assert response.status_code == 200
+        assert response.headers["content-type"] == "application/json"
+
+    @pytest.mark.asyncio
+    async def test_export_proxies_invalid_format(self, client):
+        """测试 GET /api/proxies/export/invalid - 无效格式"""
+        response = await client.get("/api/proxies/export/invalid")
+        assert response.status_code == 400  # 错误响应
diff --git a/tests/integration/test_scheduler_api.py b/tests/integration/test_scheduler_api.py
new file mode 100644
index 0000000..e52bb43
--- /dev/null
+++ b/tests/integration/test_scheduler_api.py
@@ -0,0 +1,101 @@
+"""调度器 API 集成测试 - 测试 /api/scheduler/* 所有接口"""
+import pytest
+
+
+class TestSchedulerAPI:
+    """测试调度器相关 API"""
+
+    @pytest.mark.asyncio
+    async def test_get_scheduler_status(self, client):
+        """测试 GET /api/scheduler/status"""
+        response = await client.get("/api/scheduler/status")
+        assert response.status_code == 200
+        data = response.json()
+        assert data["code"] == 200
+        assert "running" in data["data"]
+        assert "interval_minutes" in data["data"]
+        assert isinstance(data["data"]["running"], bool)
+
+    @pytest.mark.asyncio
+    async def test_start_scheduler(self, client):
+        """测试 POST /api/scheduler/start"""
+        response = await client.post("/api/scheduler/start")
+        assert response.status_code == 200
+        data = response.json()
+        assert data["code"] == 200
+        assert data["data"]["running"] is True
+
+    @pytest.mark.asyncio
+    async def test_start_scheduler_already_running(self, client):
+        """测试 POST /api/scheduler/start - 已经运行"""
+        # 先启动
+        await client.post("/api/scheduler/start")
+        # 再次启动
+        response = await client.post("/api/scheduler/start")
+        assert response.status_code == 200
+        data = response.json()
+        assert data["code"] == 200
+        assert "已在运行" in data["message"] or data["data"]["running"] is True
+
+    @pytest.mark.asyncio
+    async def test_stop_scheduler(self, client):
+        """测试 POST /api/scheduler/stop"""
+        # 先确保调度器在运行
+        await client.post("/api/scheduler/start")
+        
+        response = await client.post("/api/scheduler/stop")
+        assert response.status_code == 200
+        data = response.json()
+        assert data["code"] == 200
+        assert data["data"]["running"] is False
+
+    @pytest.mark.asyncio
+    async def test_stop_scheduler_already_stopped(self, client):
+        """测试 POST /api/scheduler/stop - 已经停止"""
+        # 先停止
+        await client.post("/api/scheduler/stop")
+        # 再次停止
+        response = await client.post("/api/scheduler/stop")
+        assert response.status_code == 200
+        data = response.json()
+        assert data["code"] == 200
+        assert "未运行" in data["message"] or data["data"]["running"] is False
+
+    @pytest.mark.asyncio
+    async def test_validate_now(self, client):
+        """测试 POST /api/scheduler/validate-now"""
+        # 先启动调度器
+        await client.post("/api/scheduler/start")
+        
+        response = await client.post("/api/scheduler/validate-now")
+        assert response.status_code == 200
+        data = response.json()
+        assert data["code"] == 200
+        assert data["data"]["started"] is True
+
+    @pytest.mark.asyncio
+    async def test_scheduler_full_workflow(self, client):
+        """测试调度器完整工作流"""
+        # 1. 获取初始状态
+        response = await client.get("/api/scheduler/status")
+        initial_status = response.json()["data"]
+        
+        # 2. 启动调度器
+        response = await client.post("/api/scheduler/start")
+        assert response.json()["data"]["running"] is True
+        
+        # 3. 验证状态
+        response = await client.get("/api/scheduler/status")
+        assert response.json()["data"]["running"] is True
+        
+        # 4. 触发立即验证
+        response = await client.post("/api/scheduler/validate-now")
+        assert response.json()["data"]["started"] is True
+        
+        # 5. 停止调度器
+        response = await client.post("/api/scheduler/stop")
+        assert response.json()["data"]["running"] is False
+        
+        # 6. 验证最终状态
+        response = await client.get("/api/scheduler/status")
+        assert response.json()["data"]["running"] is False
diff --git a/tests/integration/test_settings_api.py b/tests/integration/test_settings_api.py
new file mode 100644
index 0000000..1bc23ec
--- /dev/null
+++ b/tests/integration/test_settings_api.py
@@ -0,0 +1,137 @@
+"""设置 API 集成测试 - 测试 /api/settings 接口"""
+import pytest
+
+
+class TestSettingsAPI:
+    """测试设置相关 API"""
+
+    @pytest.mark.asyncio
+    async def test_get_settings(self, client):
+        """测试 GET /api/settings"""
+        response = await client.get("/api/settings")
+        assert response.status_code == 200
+        data = response.json()
+        assert data["code"] == 200
+        assert "crawl_timeout" in data["data"]
+        assert "validation_timeout" in data["data"]
+        assert "auto_validate" in data["data"]
+
+    @pytest.mark.asyncio
+    async def test_get_settings_structure(self, client):
+        """测试 GET /api/settings 返回结构"""
+        response = await client.get("/api/settings")
+        data = response.json()["data"]
+        
+        # 验证所有预期的设置项
+        expected_keys = [
+            "crawl_timeout",
+            "validation_timeout",
+            "max_retries",
+            "default_concurrency",
+            "min_proxy_score",
+            "proxy_expiry_days",
+            "auto_validate",
+            "validate_interval_minutes",
+        ]
+        for key in expected_keys:
+            assert key in data, f"缺少设置项: {key}"
+
+    @pytest.mark.asyncio
+    async def test_save_settings(self, client):
+        """测试 POST /api/settings"""
+        settings = {
+            "crawl_timeout": 45,
+            "validation_timeout": 15,
+            "max_retries": 5,
+            "default_concurrency": 100,
+            "min_proxy_score": 10,
+            "proxy_expiry_days": 14,
+            "auto_validate": True,
+            "validate_interval_minutes": 60,
+        }
+        response = await client.post("/api/settings", json=settings)
+        assert response.status_code == 200
+        data = response.json()
+        assert data["code"] == 200
+        # 验证返回的数据与提交的一致
+        for key, value in settings.items():
+            assert data["data"][key] == value
+
+    @pytest.mark.asyncio
+    async def test_save_settings_partial(self, client):
+        """测试 POST /api/settings - 部分更新（实际上会替换所有）"""
+        # 先获取当前设置
+        response = await client.get("/api/settings")
+        current_settings = response.json()["data"]
+        
+        # 修改部分设置
+        new_settings = current_settings.copy()
+        new_settings["crawl_timeout"] = 60
+        new_settings["auto_validate"] = False
+        
+        response = await client.post("/api/settings", json=new_settings)
+        assert response.status_code == 200
+        data = response.json()
+        assert data["data"]["crawl_timeout"] == 60
+        assert data["data"]["auto_validate"] is False
+
+    @pytest.mark.asyncio
+    async def test_save_settings_validation_error(self, client):
+        """测试 POST /api/settings - 验证错误"""
+        # crawl_timeout 必须在 5-120 之间
+        invalid_settings = {
+            "crawl_timeout": 200,  # 超出范围
+            "validation_timeout": 10,
+            "max_retries": 3,
+            "default_concurrency": 50,
+            "min_proxy_score": 0,
+            "proxy_expiry_days": 7,
+            "auto_validate": True,
+            "validate_interval_minutes": 30,
+        }
+        response = await client.post("/api/settings", json=invalid_settings)
+        assert response.status_code == 422  # 验证错误
+
+    @pytest.mark.asyncio
+    async def test_save_settings_invalid_type(self, client):
+        """测试 POST /api/settings - 无效类型"""
+        invalid_settings = {
+            "crawl_timeout": "invalid",  # 应该是整数
+            "validation_timeout": 10,
+            "max_retries": 3,
+            "default_concurrency": 50,
+            "min_proxy_score": 0,
+            "proxy_expiry_days": 7,
+            "auto_validate": True,
+            "validate_interval_minutes": 30,
+        }
+        response = await client.post("/api/settings", json=invalid_settings)
+        assert response.status_code == 422
+
+    @pytest.mark.asyncio
+    async def test_settings_roundtrip(self, client):
+        """测试设置读写一致性"""
+        # 生成随机但有效的设置
+        import random
+        test_settings = {
+            "crawl_timeout": random.randint(10, 60),
+            "validation_timeout": random.randint(5, 30),
+            "max_retries": random.randint(1, 5),
+            "default_concurrency": random.randint(20, 100),
+            "min_proxy_score": random.randint(0, 50),
+            "proxy_expiry_days": random.randint(1, 14),
+            "auto_validate": random.choice([True, False]),
+            "validate_interval_minutes": random.randint(10, 120),
+        }
+        
+        # 写入设置
+        response = await client.post("/api/settings", json=test_settings)
+        assert response.status_code == 200
+        
+        # 读取设置
+        response = await client.get("/api/settings")
+        saved_settings = response.json()["data"]
+        
+        # 验证一致性
+        for key, value in test_settings.items():
+            assert saved_settings[key] == value, f"设置项 {key} 不一致"
diff --git a/tests/run_tests.py b/tests/run_tests.py
new file mode 100644
index 0000000..59db326
--- /dev/null
+++ b/tests/run_tests.py
@@ -0,0 +1,89 @@
+#!/usr/bin/env python
+"""测试运行脚本 - 方便运行各种类型的测试"""
+import sys
+import subprocess
+import argparse
+
+
+def run_command(cmd, description):
+    """运行命令并打印结果"""
+    print(f"\n{'='*60}")
+    print(f"运行: {description}")
+    print(f"命令: {' '.join(cmd)}")
+    print('='*60)
+    
+    result = subprocess.run(cmd, shell=False)
+    return result.returncode
+
+
+def main():
+    parser = argparse.ArgumentParser(description='运行 ProxyPool 测试')
+    parser.add_argument(
+        'type',
+        nargs='?',
+        default='all',
+        choices=['all', 'unit', 'integration', 'e2e', 'coverage'],
+        help='测试类型 (默认: all)'
+    )
+    parser.add_argument(
+        '-v', '--verbose',
+        action='store_true',
+        help='详细输出'
+    )
+    parser.add_argument(
+        '-k',
+        metavar='EXPRESSION',
+        help='只运行匹配表达式的测试 (pytest -k 选项)'
+    )
+    
+    args = parser.parse_args()
+    
+    # 基础命令
+    base_cmd = [sys.executable, "-m", "pytest"]
+    
+    if args.verbose:
+        base_cmd.append("-v")
+    
+    if args.k:
+        base_cmd.extend(["-k", args.k])
+    
+    exit_code = 0
+    
+    if args.type == 'all':
+        exit_code = run_command(
+            base_cmd + ["tests/"],
+            "所有测试"
+        )
+    elif args.type == 'unit':
+        exit_code = run_command(
+            base_cmd + ["tests/unit/"],
+            "单元测试"
+        )
+    elif args.type == 'integration':
+        exit_code = run_command(
+            base_cmd + ["tests/integration/"],
+            "集成测试"
+        )
+    elif args.type == 'e2e':
+        exit_code = run_command(
+            base_cmd + ["tests/e2e/"],
+            "端到端测试"
+        )
+    elif args.type == 'coverage':
+        exit_code = run_command(
+            [sys.executable, "-m", "pytest", "tests/", "--cov=app", "--cov-report=html", "--cov-report=term"] + (["-v"] if args.verbose else []),
+            "覆盖率测试"
+        )
+    
+    print(f"\n{'='*60}")
+    if exit_code == 0:
+        print("✅ 所有测试通过!")
+    else:
+        print(f"❌ 测试失败 (退出码: {exit_code})")
+    print('='*60)
+    
+    return exit_code
+
+
+if __name__ == "__main__":
+    sys.exit(main())
diff --git a/tests/unit/__init__.py b/tests/unit/__init__.py
new file mode 100644
index 0000000..f8431e4
--- /dev/null
+++ b/tests/unit/__init__.py
@@ -0,0 +1 @@
+"""单元测试"""
diff --git a/tests/unit/__pycache__/test_models.cpython-311.pyc b/tests/unit/__pycache__/test_models.cpython-311.pyc
new file mode 100644
index 0000000..b72e1ad
Binary files /dev/null and b/tests/unit/__pycache__/test_models.cpython-311.pyc differ
diff --git a/tests/unit/__pycache__/test_repositories.cpython-311.pyc b/tests/unit/__pycache__/test_repositories.cpython-311.pyc
new file mode 100644
index 0000000..dec936f
Binary files /dev/null and b/tests/unit/__pycache__/test_repositories.cpython-311.pyc differ
diff --git a/tests/unit/test_models.py b/tests/unit/test_models.py
new file mode 100644
index 0000000..f39f217
--- /dev/null
+++ b/tests/unit/test_models.py
@@ -0,0 +1,136 @@
+"""模型单元测试"""
+import pytest
+from datetime import datetime
+from app.models.domain import ProxyRaw, Proxy, PluginInfo
+from app.models.schemas import (
+    ProxyCreate,
+    ProxyListRequest,
+    SettingsSchema,
+    BatchDeleteRequest,
+)
+
+
+class TestProxyRaw:
+    """测试 ProxyRaw 领域模型"""
+
+    def test_create_proxy_raw(self):
+        """测试创建原始代理"""
+        proxy = ProxyRaw("192.168.1.1", 8080, "http")
+        assert proxy.ip == "192.168.1.1"
+        assert proxy.port == 8080
+        assert proxy.protocol == "http"
+
+    def test_protocol_normalization(self):
+        """测试协议标准化"""
+        proxy = ProxyRaw("192.168.1.1", 8080, "HTTP")
+        assert proxy.protocol == "http"
+
+    def test_invalid_protocol_defaults_to_http(self):
+        """测试无效协议默认为 http"""
+        proxy = ProxyRaw("192.168.1.1", 8080, "invalid")
+        assert proxy.protocol == "http"
+
+
+class TestProxy:
+    """测试 Proxy 领域模型"""
+
+    def test_create_proxy(self):
+        """测试创建代理实体"""
+        proxy = Proxy(
+            ip="192.168.1.1",
+            port=8080,
+            protocol="http",
+            score=50,
+            response_time_ms=100.5,
+            last_check=datetime.now(),
+            created_at=datetime.now(),
+        )
+        assert proxy.ip == "192.168.1.1"
+        assert proxy.score == 50
+
+
+class TestPluginInfo:
+    """测试 PluginInfo 领域模型"""
+
+    def test_create_plugin_info(self):
+        """测试创建插件信息"""
+        plugin = PluginInfo(
+            id="test_plugin",
+            name="test_plugin",
+            display_name="测试插件",
+            description="用于测试",
+            enabled=True,
+            success_count=10,
+            failure_count=2,
+        )
+        assert plugin.id == "test_plugin"
+        assert plugin.enabled is True
+        assert plugin.success_count == 10
+
+
+class TestProxyCreateSchema:
+    """测试 ProxyCreate Pydantic 模型"""
+
+    def test_valid_proxy_create(self):
+        """测试有效的代理创建"""
+        proxy = ProxyCreate(ip="192.168.1.1", port=8080, protocol="http")
+        assert proxy.ip == "192.168.1.1"
+        assert proxy.port == 8080
+
+    def test_port_validation(self):
+        """测试端口验证"""
+        with pytest.raises(Exception):
+            ProxyCreate(ip="192.168.1.1", port=70000)  # 超出范围
+
+    def test_protocol_validation(self):
+        """测试协议验证"""
+        with pytest.raises(Exception):
+            ProxyCreate(ip="192.168.1.1", port=8080, protocol="invalid")
+
+
+class TestProxyListRequest:
+    """测试 ProxyListRequest 模式"""
+
+    def test_default_values(self):
+        """测试默认值"""
+        request = ProxyListRequest()
+        assert request.page == 1
+        assert request.page_size == 20
+        assert request.sort_by == "last_check"
+        assert request.sort_order == "DESC"
+
+    def test_custom_values(self):
+        """测试自定义值"""
+        request = ProxyListRequest(page=2, page_size=50, protocol="https")
+        assert request.page == 2
+        assert request.page_size == 50
+        assert request.protocol == "https"
+
+
+class TestSettingsSchema:
+    """测试 SettingsSchema"""
+
+    def test_default_settings(self):
+        """测试默认设置"""
+        settings = SettingsSchema()
+        assert settings.crawl_timeout == 30
+        assert settings.validation_timeout == 10
+        assert settings.auto_validate is True
+
+    def test_custom_settings(self):
+        """测试自定义设置"""
+        settings = SettingsSchema(crawl_timeout=60, auto_validate=False)
+        assert settings.crawl_timeout == 60
+        assert settings.auto_validate is False
+
+
+class TestBatchDeleteRequest:
+    """测试 BatchDeleteRequest"""
+
+    def test_valid_batch_delete(self):
+        """测试有效的批量删除"""
+        request = BatchDeleteRequest(proxies=[
+            {"ip": "192.168.1.1", "port": 8080},
+            {"ip": "192.168.1.2", "port": 8081},
+        ])
+        assert len(request.proxies) == 2
diff --git a/tests/unit/test_repositories.py b/tests/unit/test_repositories.py
new file mode 100644
index 0000000..dc99a67
--- /dev/null
+++ b/tests/unit/test_repositories.py
@@ -0,0 +1,95 @@
+"""仓库层单元测试"""
+import pytest
+import asyncio
+from datetime import datetime
+
+
+class TestProxyRepository:
+    """测试 ProxyRepository"""
+
+    @pytest.mark.asyncio
+    async def test_insert_or_update(self, db, proxy_repo):
+        """测试插入或更新代理"""
+        result = await proxy_repo.insert_or_update(db, "192.168.1.1", 8080, "http", 50)
+        assert result is True
+        
+        # 验证插入成功
+        proxy = await proxy_repo.get_by_ip_port(db, "192.168.1.1", 8080)
+        assert proxy is not None
+        assert proxy.ip == "192.168.1.1"
+        assert proxy.port == 8080
+        
+        # 清理
+        await proxy_repo.delete(db, "192.168.1.1", 8080)
+
+    @pytest.mark.asyncio
+    async def test_get_random(self, db, proxy_repo):
+        """测试获取随机代理"""
+        # 先插入一个代理
+        await proxy_repo.insert_or_update(db, "192.168.1.1", 8080, "http", 50)
+        
+        proxy = await proxy_repo.get_random(db)
+        # 可能有也可能没有（取决于数据库状态）
+        if proxy:
+            assert hasattr(proxy, 'ip')
+            assert hasattr(proxy, 'port')
+        
+        # 清理
+        await proxy_repo.delete(db, "192.168.1.1", 8080)
+
+    @pytest.mark.asyncio
+    async def test_list_all(self, db, proxy_repo):
+        """测试列出所有代理"""
+        # 插入测试数据
+        await proxy_repo.insert_or_update(db, "192.168.1.1", 8080, "http", 50)
+        await proxy_repo.insert_or_update(db, "192.168.1.2", 8081, "https", 60)
+        
+        proxies = await proxy_repo.list_all(db, limit=100)
+        assert isinstance(proxies, list)
+        
+        # 清理
+        await proxy_repo.delete(db, "192.168.1.1", 8080)
+        await proxy_repo.delete(db, "192.168.1.2", 8081)
+
+    @pytest.mark.asyncio
+    async def test_update_score(self, db, proxy_repo):
+        """测试更新分数"""
+        # 插入代理
+        await proxy_repo.insert_or_update(db, "192.168.1.1", 8080, "http", 50)
+        
+        # 更新分数
+        result = await proxy_repo.update_score(db, "192.168.1.1", 8080, 10)
+        assert result is True
+        
+        # 验证
+        proxy = await proxy_repo.get_by_ip_port(db, "192.168.1.1", 8080)
+        assert proxy.score == 60
+        
+        # 清理
+        await proxy_repo.delete(db, "192.168.1.1", 8080)
+
+    @pytest.mark.asyncio
+    async def test_batch_delete(self, db, proxy_repo):
+        """测试批量删除"""
+        # 插入测试数据
+        await proxy_repo.insert_or_update(db, "192.168.1.1", 8080, "http", 50)
+        await proxy_repo.insert_or_update(db, "192.168.1.2", 8081, "http", 50)
+        
+        # 批量删除
+        count = await proxy_repo.batch_delete(db, [("192.168.1.1", 8080), ("192.168.1.2", 8081)])
+        assert count == 2
+        
+        # 验证删除
+        proxy1 = await proxy_repo.get_by_ip_port(db, "192.168.1.1", 8080)
+        proxy2 = await proxy_repo.get_by_ip_port(db, "192.168.1.2", 8081)
+        assert proxy1 is None
+        assert proxy2 is None
+
+    @pytest.mark.asyncio
+    async def test_get_stats(self, db, proxy_repo):
+        """测试获取统计信息"""
+        stats = await proxy_repo.get_stats(db)
+        assert "total" in stats
+        assert "available" in stats
+        assert "avg_score" in stats
+        assert "http_count" in stats