-
+#### QQ交流群
+
+
+### 📧 联系方式
+- **技术支持**：遇到问题可在群内咨询
+- **功能建议**：欢迎提出改进建议
+- **Bug反馈**：发现问题请及时反馈
+
+---
+
+🎉 **开始使用闲鱼自动回复系统，让您的闲鱼店铺管理更加智能高效！**
diff --git a/REGISTER_PAGE_OPTIMIZATION.md b/REGISTER_PAGE_OPTIMIZATION.md
deleted file mode 100644
index cba7408..0000000
--- a/REGISTER_PAGE_OPTIMIZATION.md
+++ /dev/null
@@ -1,233 +0,0 @@
-# 注册页面布局优化
-
-## 🎯 优化目标
-
-将注册页面优化为一屏显示，消除垂直滚动条，提升用户体验。
-
-## 📊 优化前后对比
-
-### 优化前的问题
-- ❌ 页面过长，需要垂直滚动
-- ❌ 间距过大，浪费屏幕空间
-- ❌ 字体和元素尺寸偏大
-- ❌ 表单提示文字占用过多空间
-
-### 优化后的改进
-- ✅ 整个页面在一屏内显示完整
-- ✅ 紧凑而美观的布局
-- ✅ 适当的间距和字体大小
-- ✅ 简化的提示文字
-
-## 🔧 具体优化措施
-
-### 1. 容器和布局优化
-
-**优化前：**
-```css
-.register-container {
- max-width: 450px;
- padding: 2rem;
-}
-.register-header {
- padding: 2rem;
-}
-.register-body {
- padding: 2rem;
-}
-```
-
-**优化后：**
-```css
-.register-container {
- max-width: 420px;
- max-height: 95vh;
- overflow-y: auto;
-}
-.register-header {
- padding: 1.2rem;
-}
-.register-body {
- padding: 1.2rem;
-}
-```
-
-### 2. 表单元素优化
-
-**优化前：**
-```css
-.form-control {
- padding: 12px 15px;
- border: 2px solid #e9ecef;
- border-radius: 10px;
-}
-.mb-3 {
- margin-bottom: 1rem;
-}
-```
-
-**优化后：**
-```css
-.form-control {
- padding: 8px 12px;
- border: 1px solid #e9ecef;
- border-radius: 8px;
- font-size: 0.9rem;
-}
-.mb-3 {
- margin-bottom: 0.8rem !important;
-}
-```
-
-### 3. 文字和标签优化
-
-**优化前：**
-- 详细的表单提示文字
-- 较大的字体尺寸
-- 较多的说明文本
-
-**优化后：**
-- 简化的占位符文字
-- 适中的字体尺寸
-- 精简的说明文本
-
-```css
-.form-label {
- font-size: 0.85rem;
- margin-bottom: 0.3rem;
-}
-.form-text {
- font-size: 0.75rem;
- margin-top: 0.2rem;
-}
-```
-
-### 4. 按钮和交互元素优化
-
-**优化前：**
-```css
-.btn-register {
- padding: 12px;
- border-radius: 10px;
-}
-.btn-code {
- border-radius: 10px;
-}
-```
-
-**优化后：**
-```css
-.btn-register {
- padding: 10px;
- border-radius: 8px;
- font-size: 0.9rem;
-}
-.btn-code {
- padding: 8px 12px;
- border-radius: 8px;
- font-size: 0.85rem;
-}
-```
-
-### 5. 图形验证码优化
-
-**优化前：**
-- 验证码图片高度 38px
-- 较大的间距
-
-**优化后：**
-- 验证码图片高度 32px
-- 紧凑的布局
-- 使用 `g-2` 类减少列间距
-
-```html
-
-
-```
-
-### 6. 响应式优化
-
-添加了针对小屏幕的特殊优化：
-
-```css
-@media (max-height: 700px) {
- .register-header { padding: 1rem; }
- .mb-3 { margin-bottom: 0.6rem !important; }
- .form-control { padding: 6px 10px; }
-}
-
-@media (max-width: 480px) {
- .register-container { margin: 5px; }
- .row.g-2 > * { padding: 0.25rem; }
-}
-```
-
-## 📱 用户体验提升
-
-### 视觉效果
-- **更紧凑**：整个表单在一屏内完整显示
-- **更清晰**：减少了视觉噪音，重点突出
-- **更现代**：圆角和间距更加协调
-
-### 交互体验
-- **无滚动**：用户无需滚动即可看到所有内容
-- **快速填写**：表单元素紧凑，填写更高效
-- **移动友好**：在手机上也能良好显示
-
-### 功能完整性
-- ✅ 保持所有原有功能
-- ✅ 图形验证码正常工作
-- ✅ 邮箱验证码流程完整
-- ✅ 表单验证逻辑不变
-
-## 🎨 设计原则
-
-1. **简洁性**：去除不必要的装饰和间距
-2. **功能性**：保持所有功能完整可用
-3. **可读性**：确保文字清晰易读
-4. **一致性**：保持设计风格统一
-5. **响应性**：适配不同屏幕尺寸
-
-## 📏 尺寸对比
-
-| 元素 | 优化前 | 优化后 | 节省空间 |
-|------|--------|--------|----------|
-| 容器内边距 | 2rem | 1.2rem | 40% |
-| 表单间距 | 1rem | 0.8rem | 20% |
-| 输入框内边距 | 12px 15px | 8px 12px | 33% |
-| 按钮内边距 | 12px | 10px | 17% |
-| 验证码高度 | 38px | 32px | 16% |
-
-## 🔍 测试建议
-
-1. **不同分辨率测试**
- - 1920x1080 (桌面)
- - 1366x768 (笔记本)
- - 375x667 (手机)
-
-2. **不同浏览器测试**
- - Chrome
- - Firefox
- - Safari
- - Edge
-
-3. **功能完整性测试**
- - 图形验证码生成和验证
- - 邮箱验证码发送
- - 表单提交和验证
- - 错误提示显示
-
-## 🎉 优化成果
-
-- **✅ 一屏显示**：消除了垂直滚动条
-- **✅ 美观紧凑**：保持了视觉美感
-- **✅ 功能完整**：所有功能正常工作
-- **✅ 响应式**：适配各种屏幕尺寸
-- **✅ 用户友好**：提升了整体用户体验
-
-现在用户可以在一个屏幕内完成整个注册流程，无需滚动，大大提升了用户体验！
diff --git a/SYSTEM_IMPROVEMENTS_SUMMARY.md b/SYSTEM_IMPROVEMENTS_SUMMARY.md
deleted file mode 100644
index 930f8eb..0000000
--- a/SYSTEM_IMPROVEMENTS_SUMMARY.md
+++ /dev/null
@@ -1,298 +0,0 @@
-# 系统改进功能总结
-
-## 🎯 改进概述
-
-根据用户需求，对闲鱼自动回复系统进行了三项重要改进，提升了管理员的使用体验和数据管理能力。
-
-## ✅ 已完成的改进
-
-### 1. 📋 日志界面优化
-
-#### 改进内容
-- **最新日志置顶**：日志默认最新的显示在最上面
-- **自动滚动调整**：页面加载后自动滚动到顶部显示最新日志
-
-#### 技术实现
-```javascript
-// 反转日志数组，让最新的日志显示在最上面
-const reversedLogs = [...logs].reverse();
-
-// 自动滚动到顶部（显示最新日志）
-scrollToTop();
-```
-
-#### 用户体验提升
-- ✅ 最新日志一目了然
-- ✅ 无需手动滚动查看最新信息
-- ✅ 符合用户查看习惯
-
-### 2. 🗂️ 系统管理简化
-
-#### 改进内容
-- **删除JSON格式备份**：移除了兼容模式的JSON备份功能
-- **保留数据库模式**：只保留更高效的数据库文件备份
-- **界面简化**：备份管理界面更加简洁明了
-
-#### 删除的功能
-- ❌ JSON格式备份导出
-- ❌ JSON格式备份导入
-- ❌ 相关的JavaScript函数
-
-#### 保留的功能
-- ✅ 数据库文件直接下载
-- ✅ 数据库文件直接上传恢复
-- ✅ 备份文件列表查询
-
-#### 优势对比
-| 特性 | 数据库备份 | JSON备份（已删除） |
-|------|------------|-------------------|
-| 备份速度 | ⚡ 极快 | 🐌 较慢 |
-| 文件大小 | 📦 最小 | 📦 较大 |
-| 恢复速度 | ⚡ 极快 | 🐌 较慢 |
-| 操作复杂度 | 🟢 简单 | 🟡 复杂 |
-
-### 3. 🗄️ 数据管理功能（全新）
-
-#### 功能概述
-新增了完整的数据管理功能，允许管理员查看和管理数据库中的所有表数据。
-
-#### 主要特性
-
-##### 📊 表数据查看
-- **表选择器**：下拉框显示所有数据表及中文含义
-- **数据展示**：表格形式显示所有记录
-- **列信息**：自动获取表结构和列名
-- **记录统计**：实时显示记录数量
-
-##### 🗑️ 数据删除功能
-- **单条删除**：支持删除指定记录
-- **批量清空**：支持清空整个表（除用户表外）
-- **确认机制**：危险操作需要二次确认
-- **权限保护**：不能删除管理员自己
-
-##### 🔒 安全机制
-- **权限验证**：只有admin用户可以访问
-- **表名验证**：只允许操作预定义的安全表
-- **管理员保护**：不能删除管理员用户
-- **操作日志**：所有操作都有详细日志
-
-#### 支持的数据表
-
-| 表名 | 中文含义 | 支持操作 |
-|------|----------|----------|
-| users | 用户表 | 查看、删除（除管理员） |
-| cookies | Cookie账号表 | 查看、删除、清空 |
-| keywords | 关键字表 | 查看、删除、清空 |
-| default_replies | 默认回复表 | 查看、删除、清空 |
-| ai_reply_settings | AI回复设置表 | 查看、删除、清空 |
-| message_notifications | 消息通知表 | 查看、删除、清空 |
-| cards | 卡券表 | 查看、删除、清空 |
-| delivery_rules | 发货规则表 | 查看、删除、清空 |
-| notification_channels | 通知渠道表 | 查看、删除、清空 |
-| user_settings | 用户设置表 | 查看、删除、清空 |
-| email_verifications | 邮箱验证表 | 查看、删除、清空 |
-| captcha_codes | 验证码表 | 查看、删除、清空 |
-
-#### 界面设计
-
-```
-┌─────────────────────────────────────────────────────────────┐
-│ 数据管理 │
-├─────────────────────────┬───────────────────────────────────┤
-│ 选择数据表 │ 数据统计 │
-│ │ │
-│ [下拉框选择表] │ [记录数显示] [刷新按钮] │
-└─────────────────────────┴───────────────────────────────────┘
-
-┌─────────────────────────────────────────────────────────────┐
-│ 数据内容 │
-│ ┌─────┬─────────┬─────────┬─────────┬─────────┬─────────┐ │
-│ │ ID │ 字段1 │ 字段2 │ 字段3 │ 字段4 │ 操作 │ │
-│ ├─────┼─────────┼─────────┼─────────┼─────────┼─────────┤ │
-│ │ 1 │ 数据1 │ 数据2 │ 数据3 │ 数据4 │ [删除] │ │
-│ │ 2 │ 数据1 │ 数据2 │ 数据3 │ 数据4 │ [删除] │ │
-│ └─────┴─────────┴─────────┴─────────┴─────────┴─────────┘ │
-└─────────────────────────────────────────────────────────────┘
-```
-
-## 🔧 技术实现
-
-### 后端API接口
-
-#### 数据管理API
-```python
-# 获取表数据
-GET /admin/data/{table_name}
-
-# 删除单条记录
-DELETE /admin/data/{table_name}/{record_id}
-
-# 清空表数据
-DELETE /admin/data/{table_name}
-```
-
-#### 数据库方法
-```python
-# 获取表数据和结构
-def get_table_data(self, table_name: str)
-
-# 删除指定记录
-def delete_table_record(self, table_name: str, record_id: str)
-
-# 清空表数据
-def clear_table_data(self, table_name: str)
-```
-
-### 前端实现
-
-#### 页面路由
-- `/data_management.html` - 数据管理页面
-
-#### 核心功能
-```javascript
-// 加载表数据
-function loadTableData()
-
-// 显示表数据
-function displayTableData(data, columns)
-
-// 删除记录
-function deleteRecord(record, index)
-
-// 清空表数据
-function confirmDeleteAll()
-```
-
-## 🎨 用户界面
-
-### 管理员菜单更新
-在主页侧边栏的管理员功能区域新增：
-```
-管理员功能
-├── 用户管理
-├── 系统日志
-└── 数据管理 ← 新增
-```
-
-### 数据管理页面特性
-- **响应式设计**：适配各种屏幕尺寸
-- **表格滚动**：支持大量数据的滚动查看
-- **固定表头**：滚动时表头保持可见
-- **操作确认**：删除操作有确认对话框
-- **实时统计**：动态显示记录数量
-
-## 🛡️ 安全特性
-
-### 权限控制
-- **管理员专用**：所有功能只有admin用户可以访问
-- **前端验证**：页面加载时验证用户身份
-- **后端验证**：API接口严格验证管理员权限
-
-### 数据保护
-- **表名白名单**：只允许操作预定义的安全表
-- **管理员保护**：不能删除管理员用户记录
-- **操作确认**：危险操作需要用户确认
-- **详细日志**：所有操作都有完整的日志记录
-
-### 错误处理
-- **异常捕获**：完善的错误处理机制
-- **用户提示**：清晰的成功/失败提示
-- **数据回滚**：失败时自动回滚操作
-
-## 💡 使用方法
-
-### 访问数据管理
-1. 使用admin账号登录系统
-2. 在主页侧边栏点击"数据管理"
-3. 进入数据管理页面
-
-### 查看表数据
-1. 在下拉框中选择要查看的数据表
-2. 系统自动加载并显示表数据
-3. 查看记录数量和表信息
-
-### 删除数据
-1. 点击记录行的"删除"按钮
-2. 在确认对话框中查看记录详情
-3. 确认删除操作
-
-### 清空表数据
-1. 选择要清空的表
-2. 点击"清空表"按钮
-3. 确认清空操作（不可恢复）
-
-## 🎯 应用场景
-
-### 1. 数据维护
-- 清理测试数据
-- 删除无效记录
-- 维护数据质量
-
-### 2. 问题排查
-- 查看具体数据内容
-- 分析数据异常
-- 验证数据完整性
-
-### 3. 系统管理
-- 监控数据增长
-- 管理用户数据
-- 清理过期信息
-
-### 4. 开发调试
-- 查看数据结构
-- 验证功能效果
-- 测试数据操作
-
-## 📊 改进效果
-
-### 用户体验提升
-- ✅ 日志查看更直观（最新在上）
-- ✅ 备份操作更简单（只保留数据库模式）
-- ✅ 数据管理更方便（可视化操作）
-
-### 管理效率提升
-- ✅ 快速查看任意表数据
-- ✅ 便捷删除无效记录
-- ✅ 直观的数据统计信息
-
-### 系统维护能力增强
-- ✅ 完整的数据管理功能
-- ✅ 安全的操作权限控制
-- ✅ 详细的操作日志记录
-
-## 🚀 部署说明
-
-### 立即可用
-- 重启服务后所有功能立即生效
-- 无需额外配置
-- 兼容现有数据
-
-### 访问方式
-```
-数据管理: http://your-domain/data_management.html
-日志管理: http://your-domain/log_management.html
-用户管理: http://your-domain/user_management.html
-```
-
-### 权限要求
-- 只有username为'admin'的用户可以访问
-- 其他用户访问会自动跳转到首页
-
-## 🎉 总结
-
-通过本次改进，闲鱼自动回复系统现在具备了：
-
-### ✅ 主要成就
-1. **优化的日志体验**：最新日志优先显示
-2. **简化的备份管理**：只保留最高效的数据库备份
-3. **强大的数据管理**：可视化的数据库表管理功能
-4. **完善的权限控制**：严格的管理员权限验证
-5. **安全的操作机制**：完善的确认和保护机制
-
-### 🎯 实用价值
-- **提升效率**：管理员操作更加便捷高效
-- **增强安全**：严格的权限控制和操作保护
-- **便于维护**：直观的数据管理和日志查看
-- **优化体验**：符合用户习惯的界面设计
-
-现在您的多用户闲鱼自动回复系统具备了更加完善的管理功能！🎊
diff --git a/TOKEN_FIX_SUMMARY.md b/TOKEN_FIX_SUMMARY.md
deleted file mode 100644
index 9184741..0000000
--- a/TOKEN_FIX_SUMMARY.md
+++ /dev/null
@@ -1,192 +0,0 @@
-# Token认证问题修复总结
-
-## 🎯 问题描述
-
-用户反馈：管理员页面可以访问，但是点击功能时提示"未登录"，API调用返回401未授权错误。
-
-## 🔍 问题分析
-
-通过日志分析发现：
-```
-INFO: 127.0.0.1:63674 - "GET /admin/users HTTP/1.1" 401 Unauthorized
-INFO: 【未登录】 API响应: GET /admin/users - 401 (0.003s)
-```
-
-问题根源：**Token存储key不一致**
-
-### 🔧 具体问题
-
-1. **登录页面** (`login.html`) 设置token：
- ```javascript
- localStorage.setItem('auth_token', result.token);
- ```
-
-2. **主页面** (`index.html`) 读取token：
- ```javascript
- let authToken = localStorage.getItem('auth_token');
- ```
-
-3. **管理员页面** (`user_management.html`, `log_management.html`) 读取token：
- ```javascript
- const token = localStorage.getItem('token'); // ❌ 错误的key
- ```
-
-## ✅ 修复方案
-
-### 统一Token存储Key
-
-将所有管理员页面的token读取统一为 `auth_token`：
-
-#### 1. 用户管理页面修复
-```javascript
-// 修复前
-const token = localStorage.getItem('token');
-
-// 修复后
-const token = localStorage.getItem('auth_token');
-```
-
-修复的函数：
-- `checkAdminPermission()`
-- `loadSystemStats()`
-- `loadUsers()`
-- `confirmDeleteUser()`
-- `logout()`
-
-#### 2. 日志管理页面修复
-```javascript
-// 修复前
-const token = localStorage.getItem('token');
-
-// 修复后
-const token = localStorage.getItem('auth_token');
-```
-
-修复的函数：
-- `checkAdminPermission()`
-- `loadLogs()`
-- `logout()`
-
-### 🔄 修复的文件
-
-1. **static/user_management.html**
- - 5处token读取修复
- - 1处token删除修复
-
-2. **static/log_management.html**
- - 3处token读取修复
- - 1处token删除修复
-
-## 📊 Token流程图
-
-```
-登录页面 (login.html)
- ↓ 设置
-localStorage.setItem('auth_token', token)
- ↓ 读取
-主页面 (index.html)
- ↓ 读取
-管理员页面 (user_management.html, log_management.html)
- ↓ 使用
-API调用 (Authorization: Bearer token)
-```
-
-## 🧪 验证方法
-
-### 1. 手动验证
-1. 使用admin账号登录主页
-2. 点击侧边栏"用户管理"
-3. 页面应该正常加载用户列表和统计信息
-4. 点击侧边栏"系统日志"
-5. 页面应该正常显示系统日志
-
-### 2. 开发者工具验证
-1. 打开浏览器开发者工具
-2. 查看 Application → Local Storage
-3. 确认存在 `auth_token` 项
-4. 查看 Network 标签页
-5. API请求应该返回200状态码
-
-### 3. 日志验证
-服务器日志应该显示：
-```
-INFO: 【admin#1】 API请求: GET /admin/users
-INFO: 【admin#1】 API响应: GET /admin/users - 200 (0.005s)
-```
-
-## 🎯 修复效果
-
-### 修复前
-- ❌ 管理员页面API调用401错误
-- ❌ 日志显示"未登录"用户访问
-- ❌ 用户管理功能无法使用
-- ❌ 日志管理功能无法使用
-
-### 修复后
-- ✅ 管理员页面API调用正常
-- ✅ 日志显示正确的用户信息
-- ✅ 用户管理功能完全可用
-- ✅ 日志管理功能完全可用
-
-## 🔒 安全验证
-
-修复后的安全机制：
-
-1. **Token验证**：所有管理员API都需要有效token
-2. **权限检查**：只有admin用户可以访问管理员功能
-3. **自动跳转**：无效token自动跳转到登录页
-4. **统一认证**：所有页面使用相同的认证机制
-
-## 💡 最佳实践
-
-### 1. Token管理规范
-- 使用统一的token存储key
-- 在所有页面保持一致的token读取方式
-- 及时清理过期或无效的token
-
-### 2. 错误处理
-- API调用失败时提供明确的错误信息
-- 401错误自动跳转到登录页
-- 403错误提示权限不足
-
-### 3. 用户体验
-- 登录状态持久化
-- 页面间无缝跳转
-- 清晰的权限提示
-
-## 🚀 部署说明
-
-### 立即生效
-修复后无需重启服务器，刷新页面即可生效。
-
-### 用户操作
-1. 如果当前已登录，刷新管理员页面即可
-2. 如果遇到问题，重新登录即可
-3. 确保使用admin账号访问管理员功能
-
-## 📋 测试清单
-
-- [ ] admin用户可以正常登录
-- [ ] 主页侧边栏显示管理员菜单
-- [ ] 用户管理页面正常加载
-- [ ] 用户管理功能正常工作
-- [ ] 日志管理页面正常加载
-- [ ] 日志管理功能正常工作
-- [ ] 非admin用户无法访问管理员功能
-- [ ] 无效token被正确拒绝
-
-## 🎉 总结
-
-通过统一token存储key，成功修复了管理员页面的认证问题：
-
-### 核心改进
-- **统一认证**：所有页面使用相同的token key (`auth_token`)
-- **完整功能**：用户管理和日志管理功能完全可用
-- **安全保障**：权限验证和错误处理机制完善
-
-### 用户体验
-- **无缝使用**：登录后可以直接使用所有管理员功能
-- **清晰反馈**：错误信息明确，操作结果及时反馈
-- **安全可靠**：严格的权限控制和认证机制
-
-现在管理员功能已经完全正常工作，可以安全地管理用户和监控系统日志！🎊
diff --git a/UI_IMPROVEMENTS.md b/UI_IMPROVEMENTS.md
deleted file mode 100644
index 1ac59fc..0000000
--- a/UI_IMPROVEMENTS.md
+++ /dev/null
@@ -1,92 +0,0 @@
-# 🎨 界面优化总结
-
-## ✨ 主要改进
-
-### 1. 🎯 Cookie显示优化
-- **❌ 修改前**: Cookie值被隐藏为星号 (`****`)
-- **✅ 修改后**: 显示完整的Cookie内容，便于查看和调试
-
-### 2. 🎨 视觉设计升级
-- **现代化配色方案**: 使用更现代的紫色主题 (`#4f46e5`)
-- **渐变背景**: 美丽的渐变背景和卡片效果
-- **毛玻璃效果**: 卡片使用 `backdrop-filter: blur()` 实现毛玻璃效果
-- **阴影和动画**: 悬停时的阴影和位移动画效果
-
-### 3. 🔧 功能增强
-- **一键复制Cookie**: 点击Cookie值或复制按钮即可复制到剪贴板
-- **改进的按钮组**: 更紧凑的按钮布局，包含复制功能
-- **更好的空状态**: 当没有账号时显示更友好的提示
-
-### 4. 📱 响应式设计
-- **移动端优化**: 在小屏幕上按钮垂直排列
-- **自适应布局**: 表格和卡片在不同屏幕尺寸下的自适应
-
-## 🛠️ 技术改进
-
-### 新增API接口
-```javascript
-GET /cookies/details
-```
-返回包含Cookie ID和完整值的详细信息，而不仅仅是ID列表。
-
-### CSS样式优化
-- **CSS变量**: 统一的颜色管理
-- **现代字体**: 使用 Inter 字体提升可读性
-- **代码字体**: Cookie值使用等宽字体 (JetBrains Mono)
-- **流畅动画**: 所有交互都有平滑的过渡效果
-
-### JavaScript功能增强
-- **复制功能**: 支持现代浏览器的 Clipboard API
-- **降级方案**: 对于不支持的浏览器提供传统复制方法
-- **用户反馈**: 复制成功/失败的Toast提示
-
-## 🎯 用户体验提升
-
-### 1. Cookie管理
-- **完整显示**: 不再隐藏Cookie内容，便于调试
-- **一键复制**: 快速复制Cookie值到剪贴板
-- **格式化显示**: 使用等宽字体和适当的行高
-
-### 2. 视觉反馈
-- **悬停效果**: 所有可交互元素都有悬停反馈
-- **状态指示**: 清晰的按钮状态和颜色区分
-- **加载动画**: 优雅的加载状态显示
-
-### 3. 操作便利性
-- **按钮分组**: 相关操作按钮紧凑排列
-- **图标提示**: 每个按钮都有清晰的图标和提示
-- **确认对话框**: 危险操作有确认提示
-
-## 📊 界面对比
-
-| 功能 | 修改前 | 修改后 |
-|------|--------|--------|
-| Cookie显示 | 隐藏为星号 | 完整显示 |
-| 复制功能 | 无 | 一键复制 |
-| 视觉效果 | 基础Bootstrap | 现代化渐变设计 |
-| 响应式 | 基本支持 | 完全优化 |
-| 用户反馈 | 基础提示 | 丰富的Toast反馈 |
-
-## 🚀 使用说明
-
-### 访问界面
-1. 启动系统: `python Start.py`
-2. 打开浏览器: `http://localhost:8080`
-3. 登录: `admin` / `admin123`
-
-### 主要功能
-- **添加账号**: 在顶部表单中输入账号ID和Cookie值
-- **查看Cookie**: 完整的Cookie值显示在表格中
-- **复制Cookie**: 点击Cookie值或复制按钮
-- **管理关键词**: 点击关键词按钮设置自动回复
-- **删除账号**: 点击删除按钮（有确认提示）
-
-## 🎉 总结
-
-这次界面优化大幅提升了用户体验：
-- ✅ **Cookie不再隐藏**，便于查看和调试
-- ✅ **现代化设计**，视觉效果更佳
-- ✅ **功能增强**，操作更便利
-- ✅ **响应式优化**，支持各种设备
-
-界面现在更加美观、实用和用户友好！🎨✨
diff --git a/USER_LOGGING_IMPROVEMENT.md b/USER_LOGGING_IMPROVEMENT.md
deleted file mode 100644
index 26baac1..0000000
--- a/USER_LOGGING_IMPROVEMENT.md
+++ /dev/null
@@ -1,249 +0,0 @@
-# 用户日志显示改进总结
-
-## 🎯 改进目标
-
-在多用户系统中，原有的日志无法识别具体的操作用户，导致调试和监控困难。本次改进为所有系统日志添加了当前登录用户的信息。
-
-## 📊 改进内容
-
-### 1. API请求/响应日志增强
-
-#### 改进前
-```
-2025-07-25 15:40:28.714 | INFO | reply_server:log_requests:223 - 🌐 API请求: GET /keywords/执念小店70
-2025-07-25 15:40:28.725 | INFO | reply_server:log_requests:228 - ✅ API响应: GET /keywords/执念小店70 - 200 (0.011s)
-```
-
-#### 改进后
-```
-2025-07-25 15:40:28.714 | INFO | reply_server:log_requests:223 - 🌐 【admin#1】 API请求: GET /keywords/执念小店70
-2025-07-25 15:40:28.725 | INFO | reply_server:log_requests:228 - ✅ 【admin#1】 API响应: GET /keywords/执念小店70 - 200 (0.011s)
-```
-
-### 2. 业务操作日志增强
-
-#### 用户认证相关
-- ✅ 登录尝试: `【username】尝试登录`
-- ✅ 登录成功: `【username#user_id】登录成功`
-- ✅ 登录失败: `【username】登录失败: 用户名或密码错误`
-- ✅ 注册操作: `【username】尝试注册，邮箱: email`
-
-#### Cookie管理相关
-- ✅ 添加Cookie: `【username#user_id】尝试添加Cookie: cookie_id`
-- ✅ 操作成功: `【username#user_id】Cookie添加成功: cookie_id`
-- ✅ 权限冲突: `【username#user_id】Cookie ID冲突: cookie_id 已被其他用户使用`
-
-#### 卡券管理相关
-- ✅ 创建卡券: `【username#user_id】创建卡券: card_name`
-- ✅ 创建成功: `【username#user_id】卡券创建成功: card_name (ID: card_id)`
-- ✅ 创建失败: `【username#user_id】创建卡券失败: card_name - error`
-
-#### 关键字管理相关
-- ✅ 更新关键字: `【username#user_id】更新Cookie关键字: cookie_id, 数量: count`
-- ✅ 权限验证: `【username#user_id】尝试操作其他用户的Cookie关键字: cookie_id`
-
-#### 用户设置相关
-- ✅ 设置更新: `【username#user_id】更新用户设置: key = value`
-- ✅ 更新成功: `【username#user_id】用户设置更新成功: key`
-
-## 🔧 技术实现
-
-### 1. 中间件增强
-```python
-@app.middleware("http")
-async def log_requests(request, call_next):
- # 获取用户信息
- user_info = "未登录"
- try:
- auth_header = request.headers.get("Authorization")
- if auth_header and auth_header.startswith("Bearer "):
- token = auth_header.split(" ")[1]
- if token in SESSION_TOKENS:
- token_data = SESSION_TOKENS[token]
- if time.time() - token_data['timestamp'] <= TOKEN_EXPIRE_TIME:
- user_info = f"【{token_data['username']}#{token_data['user_id']}】"
- except Exception:
- pass
-
- logger.info(f"🌐 {user_info} API请求: {request.method} {request.url.path}")
- # ...
-```
-
-### 2. 统一日志工具函数
-```python
-def get_user_log_prefix(user_info: Dict[str, Any] = None) -> str:
- """获取用户日志前缀"""
- if user_info:
- return f"【{user_info['username']}#{user_info['user_id']}】"
- return "【系统】"
-
-def log_with_user(level: str, message: str, user_info: Dict[str, Any] = None):
- """带用户信息的日志记录"""
- prefix = get_user_log_prefix(user_info)
- full_message = f"{prefix} {message}"
-
- if level.lower() == 'info':
- logger.info(full_message)
- elif level.lower() == 'error':
- logger.error(full_message)
- # ...
-```
-
-### 3. 业务接口改进
-```python
-@app.post("/cookies")
-def add_cookie(item: CookieIn, current_user: Dict[str, Any] = Depends(get_current_user)):
- try:
- log_with_user('info', f"尝试添加Cookie: {item.id}", current_user)
- # 业务逻辑...
- log_with_user('info', f"Cookie添加成功: {item.id}", current_user)
- except Exception as e:
- log_with_user('error', f"添加Cookie失败: {item.id} - {str(e)}", current_user)
-```
-
-## 📋 修改的文件和接口
-
-### reply_server.py
-- **中间件**: `log_requests` - API请求/响应日志
-- **工具函数**: `get_user_log_prefix`, `log_with_user`
-- **认证接口**: 登录、注册接口
-- **业务接口**: Cookie管理、卡券管理、关键字管理、用户设置
-
-### 修改的接口数量
-- **API中间件**: 1个（影响所有接口）
-- **认证相关**: 2个接口（登录、注册）
-- **Cookie管理**: 1个接口（添加Cookie）
-- **卡券管理**: 1个接口（创建卡券）
-- **关键字管理**: 1个接口（更新关键字）
-- **用户设置**: 1个接口（更新设置）
-
-## 🎯 日志格式规范
-
-### 用户标识格式
-- **已登录用户**: `【username#user_id】`
-- **未登录用户**: `【未登录】`
-- **系统操作**: `【系统】`
-
-### 日志级别使用
-- **INFO**: 正常操作、成功操作
-- **WARNING**: 权限验证失败、业务规则冲突
-- **ERROR**: 系统错误、操作失败
-
-### 消息格式
-- **操作尝试**: `尝试{操作}: {对象}`
-- **操作成功**: `{操作}成功: {对象}`
-- **操作失败**: `{操作}失败: {对象} - {原因}`
-
-## 💡 日志分析技巧
-
-### 1. 按用户过滤
-```bash
-# 查看特定用户的所有操作
-grep '【admin#1】' logs/xianyu_2025-07-25.log
-
-# 查看特定用户的API请求
-grep '【admin#1】.*API请求' logs/xianyu_2025-07-25.log
-```
-
-### 2. 监控用户活动
-```bash
-# 统计用户活跃度
-grep -o '【[^】]*#[^】]*】' logs/xianyu_2025-07-25.log | sort | uniq -c
-
-# 查看登录活动
-grep '登录' logs/xianyu_2025-07-25.log
-```
-
-### 3. 权限验证监控
-```bash
-# 查看权限验证失败
-grep '无权限\|权限验证失败' logs/xianyu_2025-07-25.log
-
-# 查看跨用户访问尝试
-grep '尝试操作其他用户' logs/xianyu_2025-07-25.log
-```
-
-### 4. 错误追踪
-```bash
-# 查看特定用户的错误
-grep 'ERROR.*【admin#1】' logs/xianyu_2025-07-25.log
-
-# 查看操作失败
-grep '失败.*【.*】' logs/xianyu_2025-07-25.log
-```
-
-## 🔍 监控指标建议
-
-### 1. 用户活跃度指标
-- 每个用户的API调用频率
-- 用户登录频率和时长
-- 用户操作成功率
-
-### 2. 安全监控指标
-- 登录失败次数（按用户）
-- 权限验证失败次数
-- 跨用户访问尝试次数
-
-### 3. 业务监控指标
-- Cookie操作频率（按用户）
-- 卡券创建和使用情况
-- 用户设置修改频率
-
-## 🚀 部署和使用
-
-### 1. 立即生效
-重启服务后，新的日志格式立即生效：
-```bash
-# 重启服务
-docker-compose restart
-
-# 查看新的日志格式
-docker-compose logs -f | grep '【.*】'
-```
-
-### 2. 日志轮转配置
-确保日志轮转能够处理增加的日志内容：
-```python
-# loguru配置
-logger.add(
- "logs/xianyu_{time:YYYY-MM-DD}.log",
- rotation="100 MB",
- retention="7 days",
- compression="zip",
- format="{time:YYYY-MM-DD HH:mm:ss.SSS} | {level} | {name}:{function}:{line} - {message}"
-)
-```
-
-### 3. 监控工具集成
-如果使用ELK、Grafana等监控工具，可以基于用户标识创建仪表板：
-- 按用户分组的操作统计
-- 用户行为分析
-- 安全事件监控
-
-## 🎉 改进效果
-
-### 1. 调试效率提升
-- **问题定位**: 快速定位特定用户的问题
-- **操作追踪**: 完整的用户操作链路追踪
-- **权限验证**: 清晰的权限验证日志
-
-### 2. 监控能力增强
-- **用户行为**: 详细的用户行为分析
-- **安全监控**: 实时的安全事件监控
-- **性能分析**: 按用户维度的性能分析
-
-### 3. 运维管理优化
-- **故障排查**: 快速定位用户相关问题
-- **容量规划**: 基于用户活跃度的容量规划
-- **安全审计**: 完整的用户操作审计日志
-
-## 📞 使用建议
-
-1. **日志查看**: 使用 `grep` 命令按用户过滤日志
-2. **实时监控**: 使用 `tail -f` 实时监控特定用户操作
-3. **定期分析**: 定期分析用户活跃度和操作模式
-4. **安全审计**: 定期检查权限验证失败和异常操作
-
----
-
-**总结**: 通过本次改进，多用户系统的日志现在具备了完整的用户标识能力，大大提升了系统的可观测性和可维护性！
diff --git a/XianyuAutoAsync.py b/XianyuAutoAsync.py
index 6f62b45..cb03407 100644
--- a/XianyuAutoAsync.py
+++ b/XianyuAutoAsync.py
@@ -86,6 +86,10 @@ class XianyuLive:
# 通知防重复机制
self.last_notification_time = {} # 记录每种通知类型的最后发送时间
self.notification_cooldown = 300 # 5分钟内不重复发送相同类型的通知
+
+ # 自动发货防重复机制
+ self.last_delivery_time = {} # 记录每个商品的最后发货时间
+ self.delivery_cooldown = 60 # 1分钟内不重复发货
# 人工接管功能已禁用，永远走自动模式
# self.manual_mode_conversations = set() # 存储处于人工接管模式的会话ID
@@ -94,6 +98,22 @@ class XianyuLive:
# self.toggle_keywords = MANUAL_MODE.get('toggle_keywords', ['。']) # 切换关键词
self.session = None # 用于API调用的aiohttp session
+ def can_auto_delivery(self, item_id: str) -> bool:
+ """检查是否可以进行自动发货（防重复发货）"""
+ current_time = time.time()
+ last_delivery = self.last_delivery_time.get(item_id, 0)
+
+ if current_time - last_delivery < self.delivery_cooldown:
+ logger.info(f"【{self.cookie_id}】商品 {item_id} 在冷却期内，跳过自动发货")
+ return False
+
+ return True
+
+ def mark_delivery_sent(self, item_id: str):
+ """标记商品已发货"""
+ self.last_delivery_time[item_id] = time.time()
+ logger.debug(f"【{self.cookie_id}】标记商品 {item_id} 已发货")
+
# 人工接管功能已禁用，以下方法不再使用
# def check_toggle_keywords(self, message):
# """检查消息是否包含切换关键词"""
@@ -1147,10 +1167,13 @@ class XianyuLive:
delivery_content = db_manager.consume_batch_data(rule['card_id'])
if delivery_content:
+ # 处理备注信息和变量替换
+ final_content = self._process_delivery_content_with_description(delivery_content, rule.get('card_description', ''))
+
# 增加发货次数统计
db_manager.increment_delivery_times(rule['id'])
- logger.info(f"自动发货成功: 规则ID={rule['id']}, 内容长度={len(delivery_content)}")
- return delivery_content
+ logger.info(f"自动发货成功: 规则ID={rule['id']}, 内容长度={len(final_content)}")
+ return final_content
else:
logger.warning(f"获取发货内容失败: 规则ID={rule['id']}")
return None
@@ -1159,6 +1182,28 @@ class XianyuLive:
logger.error(f"自动发货失败: {self._safe_str(e)}")
return None
+ def _process_delivery_content_with_description(self, delivery_content: str, card_description: str) -> str:
+ """处理发货内容和备注信息，实现变量替换"""
+ try:
+ # 如果没有备注信息，直接返回发货内容
+ if not card_description or not card_description.strip():
+ return delivery_content
+
+ # 替换备注中的变量
+ processed_description = card_description.replace('{DELIVERY_CONTENT}', delivery_content)
+
+ # 如果备注中包含变量替换，返回处理后的备注
+ if '{DELIVERY_CONTENT}' in card_description:
+ return processed_description
+ else:
+ # 如果备注中没有变量，将备注和发货内容组合
+ return f"{processed_description}\n\n{delivery_content}"
+
+ except Exception as e:
+ logger.error(f"处理备注信息失败: {e}")
+ # 出错时返回原始发货内容
+ return delivery_content
+
async def _get_api_card_content(self, rule, retry_count=0):
"""调用API获取卡券内容，支持重试机制"""
max_retries = 3
@@ -1855,9 +1900,28 @@ class XianyuLive:
elif send_message == '[你关闭了订单，钱款已原路退返]':
logger.info(f'[{msg_time}] 【{self.cookie_id}】系统消息不处理')
return
+ elif send_message == '发来一条消息':
+ logger.info(f'[{msg_time}] 【{self.cookie_id}】系统通知消息不处理')
+ return
+ elif send_message == '发来一条新消息':
+ logger.info(f'[{msg_time}] 【{self.cookie_id}】系统通知消息不处理')
+ return
+ elif send_message == '[买家确认收货，交易成功]':
+ logger.info(f'[{msg_time}] 【{self.cookie_id}】交易完成消息不处理')
+ return
+ elif send_message == '快给ta一个评价吧~' or send_message == '快给ta一个评价吧～':
+ logger.info(f'[{msg_time}] 【{self.cookie_id}】评价提醒消息不处理')
+ return
+ elif send_message == '[你已发货]':
+ logger.info(f'[{msg_time}] 【{self.cookie_id}】发货确认消息不处理')
+ return
elif send_message == '[我已付款，等待你发货]':
logger.info(f'[{msg_time}] 【{self.cookie_id}】【系统】买家已付款，准备自动发货')
+ # 检查是否可以进行自动发货（防重复）
+ if not self.can_auto_delivery(item_id):
+ return
+
# 构造用户URL
user_url = f'https://www.goofish.com/personal?userId={send_user_id}'
@@ -1872,6 +1936,9 @@ class XianyuLive:
delivery_content = await self._auto_delivery(item_id, item_title)
if delivery_content:
+ # 标记已发货（防重复）
+ self.mark_delivery_sent(item_id)
+
# 发送发货内容给买家
await self.send_msg(websocket, chat_id, send_user_id, delivery_content)
logger.info(f'[{msg_time}] 【自动发货】已向 {user_url} 发送发货内容')
@@ -1890,6 +1957,10 @@ class XianyuLive:
elif send_message == '[已付款，待发货]':
logger.info(f'[{msg_time}] 【{self.cookie_id}】【系统】买家已付款，准备自动发货')
+ # 检查是否可以进行自动发货（防重复）
+ if not self.can_auto_delivery(item_id):
+ return
+
# 构造用户URL
user_url = f'https://www.goofish.com/personal?userId={send_user_id}'
@@ -1904,6 +1975,9 @@ class XianyuLive:
delivery_content = await self._auto_delivery(item_id, item_title)
if delivery_content:
+ # 标记已发货（防重复）
+ self.mark_delivery_sent(item_id)
+
# 发送发货内容给买家
await self.send_msg(websocket, chat_id, send_user_id, delivery_content)
logger.info(f'[{msg_time}] 【自动发货】已向 {user_url} 发送发货内容')
@@ -1919,6 +1993,76 @@ class XianyuLive:
await self.send_delivery_failure_notification(send_user_name, send_user_id, item_id, f"自动发货处理异常: {str(e)}")
return
+ elif send_message == '[卡片消息]':
+ # 检查是否为"我已小刀，待刀成"的卡片消息
+ try:
+ # 从消息中提取卡片内容
+ card_title = None
+ if isinstance(message, dict) and "1" in message and isinstance(message["1"], dict):
+ message_1 = message["1"]
+ if "6" in message_1 and isinstance(message_1["6"], dict):
+ message_6 = message_1["6"]
+ if "3" in message_6 and isinstance(message_6["3"], dict):
+ message_6_3 = message_6["3"]
+ if "5" in message_6_3:
+ # 解析JSON内容
+ try:
+ card_content = json.loads(message_6_3["5"])
+ if "dxCard" in card_content and "item" in card_content["dxCard"]:
+ card_item = card_content["dxCard"]["item"]
+ if "main" in card_item and "exContent" in card_item["main"]:
+ ex_content = card_item["main"]["exContent"]
+ card_title = ex_content.get("title", "")
+ except (json.JSONDecodeError, KeyError) as e:
+ logger.debug(f"解析卡片消息失败: {e}")
+
+ # 检查是否为"我已小刀，待刀成"
+ if card_title == "我已小刀，待刀成":
+ logger.info(f'[{msg_time}] 【{self.cookie_id}】【系统】检测到"我已小刀，待刀成"，准备自动发货')
+
+ # 检查是否可以进行自动发货（防重复）
+ if not self.can_auto_delivery(item_id):
+ return
+
+ # 构造用户URL
+ user_url = f'https://www.goofish.com/personal?userId={send_user_id}'
+
+ # 自动发货逻辑
+ try:
+ # 设置默认标题（将通过API获取真实商品信息）
+ item_title = "待获取商品信息"
+
+ logger.info(f"【{self.cookie_id}】准备自动发货: item_id={item_id}, item_title={item_title}")
+
+ # 调用自动发货方法
+ delivery_content = await self._auto_delivery(item_id, item_title)
+
+ if delivery_content:
+ # 标记已发货（防重复）
+ self.mark_delivery_sent(item_id)
+
+ # 发送发货内容给买家
+ await self.send_msg(websocket, chat_id, send_user_id, delivery_content)
+ logger.info(f'[{msg_time}] 【自动发货】已向 {user_url} 发送发货内容')
+ await self.send_delivery_failure_notification(send_user_name, send_user_id, item_id, "发货成功")
+ else:
+ logger.warning(f'[{msg_time}] 【自动发货】未找到匹配的发货规则或获取发货内容失败')
+ # 发送自动发货失败通知
+ await self.send_delivery_failure_notification(send_user_name, send_user_id, item_id, "未找到匹配的发货规则或获取发货内容失败")
+
+ except Exception as e:
+ logger.error(f"自动发货处理异常: {self._safe_str(e)}")
+ # 发送自动发货异常通知
+ await self.send_delivery_failure_notification(send_user_name, send_user_id, item_id, f"自动发货处理异常: {str(e)}")
+
+ return
+ else:
+ logger.info(f'[{msg_time}] 【{self.cookie_id}】收到卡片消息，标题: {card_title or "未知"}')
+
+ except Exception as e:
+ logger.error(f"处理卡片消息异常: {self._safe_str(e)}")
+
+ # 如果不是目标卡片消息，继续正常处理流程
# 记录回复来源
reply_source = 'API' # 默认假设是API回复
diff --git a/backup_import_update_summary.md b/backup_import_update_summary.md
deleted file mode 100644
index 710ae24..0000000
--- a/backup_import_update_summary.md
+++ /dev/null
@@ -1,193 +0,0 @@
-# 备份和导入功能更新总结
-
-## 📋 更新概述
-
-由于系统新增了多个AI相关的数据表，备份和导入功能需要更新以确保所有数据都能正确备份和恢复。
-
-## 🔧 更新内容
-
-### 1. **新增的表**
-
-在原有的10个表基础上，新增了3个AI相关表：
-
-#### 新增表列表：
-- `ai_reply_settings` - AI回复配置表
-- `ai_conversations` - AI对话历史表
-- `ai_item_cache` - AI商品信息缓存表
-
-### 2. **更新的备份表列表**
-
-#### 更新前（10个表）：
-```python
-tables = [
- 'cookies', 'keywords', 'cookie_status', 'cards',
- 'delivery_rules', 'default_replies', 'notification_channels',
- 'message_notifications', 'system_settings', 'item_info'
-]
-```
-
-#### 更新后（13个表）：
-```python
-tables = [
- 'cookies', 'keywords', 'cookie_status', 'cards',
- 'delivery_rules', 'default_replies', 'notification_channels',
- 'message_notifications', 'system_settings', 'item_info',
- 'ai_reply_settings', 'ai_conversations', 'ai_item_cache'
-]
-```
-
-### 3. **更新的删除顺序**
-
-考虑到外键依赖关系，更新了导入时的表删除顺序：
-
-#### 更新前：
-```python
-tables = [
- 'message_notifications', 'notification_channels', 'default_replies',
- 'delivery_rules', 'cards', 'item_info', 'cookie_status', 'keywords', 'cookies'
-]
-```
-
-#### 更新后：
-```python
-tables = [
- 'message_notifications', 'notification_channels', 'default_replies',
- 'delivery_rules', 'cards', 'item_info', 'cookie_status', 'keywords',
- 'ai_conversations', 'ai_reply_settings', 'ai_item_cache', 'cookies'
-]
-```
-
-### 4. **更新的验证列表**
-
-导入功能中的表验证列表也相应更新，确保新增的AI表能够正确导入。
-
-## ✅ 测试验证结果
-
-### 测试环境
-- 数据库表总数：13个
-- 测试数据：包含所有表类型的数据
-- 测试场景：导出、导入、文件操作
-
-### 测试结果
-```
-🎉 所有测试通过！备份和导入功能正常！
-
-✅ 功能验证:
- • 所有13个表都包含在备份中
- • 备份导出功能正常
- • 备份导入功能正常
- • 数据完整性保持
- • 文件操作正常
-```
-
-### 数据完整性验证
-所有13个表的数据在备份和导入过程中保持完整：
-
-| 表名 | 数据一致性 | 说明 |
-|------|------------|------|
-| ai_conversations | ✅ 一致 | AI对话历史 |
-| ai_item_cache | ✅ 一致 | AI商品缓存 |
-| ai_reply_settings | ✅ 一致 | AI回复配置 |
-| cards | ✅ 一致 | 卡券信息 |
-| cookie_status | ✅ 一致 | 账号状态 |
-| cookies | ✅ 一致 | 账号信息 |
-| default_replies | ✅ 一致 | 默认回复 |
-| delivery_rules | ✅ 一致 | 发货规则 |
-| item_info | ✅ 一致 | 商品信息 |
-| keywords | ✅ 一致 | 关键词 |
-| message_notifications | ✅ 一致 | 消息通知 |
-| notification_channels | ✅ 一致 | 通知渠道 |
-| system_settings | ✅ 一致 | 系统设置 |
-
-## 🎯 功能特性
-
-### 1. **完整性保证**
-- 包含所有13个数据表
-- 保持外键依赖关系
-- 数据完整性验证
-
-### 2. **安全性**
-- 事务性操作，确保数据一致性
-- 管理员密码保护（不会被覆盖）
-- 错误回滚机制
-
-### 3. **兼容性**
-- 向后兼容旧版本备份文件
-- 自动跳过不存在的表
-- 版本标识和时间戳
-
-### 4. **易用性**
-- 一键导出所有数据
-- 一键导入恢复数据
-- 详细的操作日志
-
-## 📊 使用方法
-
-### 导出备份
-```python
-from db_manager import db_manager
-
-# 导出备份数据
-backup_data = db_manager.export_backup()
-
-# 保存到文件
-import json
-with open('backup.json', 'w', encoding='utf-8') as f:
- json.dump(backup_data, f, indent=2, ensure_ascii=False)
-```
-
-### 导入备份
-```python
-from db_manager import db_manager
-import json
-
-# 从文件读取备份
-with open('backup.json', 'r', encoding='utf-8') as f:
- backup_data = json.load(f)
-
-# 导入备份数据
-success = db_manager.import_backup(backup_data)
-```
-
-## 🔄 升级说明
-
-### 对现有用户的影响
-- ✅ **无影响**：现有备份文件仍然可以正常导入
-- ✅ **自动兼容**：系统会自动跳过不存在的新表
-- ✅ **数据安全**：不会丢失任何现有数据
-
-### 新功能优势
-- ✅ **AI数据备份**：AI回复配置和对话历史得到保护
-- ✅ **完整备份**：所有功能数据都包含在备份中
-- ✅ **快速恢复**：可以完整恢复所有AI功能设置
-
-## 💡 建议
-
-### 1. **定期备份**
-建议用户定期进行数据备份，特别是在：
-- 重要配置更改后
-- 系统升级前
-- 大量数据操作前
-
-### 2. **备份验证**
-建议在重要操作前验证备份文件的完整性：
-- 检查文件大小
-- 验证JSON格式
-- 确认包含所需表
-
-### 3. **多重备份**
-建议保留多个备份版本：
-- 每日自动备份
-- 重要节点手动备份
-- 异地备份存储
-
-## 🎉 总结
-
-备份和导入功能已成功更新，现在能够：
-
-1. ✅ **完整备份**所有13个数据表
-2. ✅ **安全导入**保持数据完整性
-3. ✅ **向后兼容**旧版本备份文件
-4. ✅ **AI数据保护**包含所有AI功能数据
-
-用户可以放心使用备份和导入功能，所有数据都得到了完整的保护！
diff --git a/bargain_demo.py b/bargain_demo.py
deleted file mode 100644
index b2c0a36..0000000
--- a/bargain_demo.py
+++ /dev/null
@@ -1,180 +0,0 @@
-#!/usr/bin/env python3
-"""
-议价功能演示脚本
-展示AI回复的议价轮数限制功能
-"""
-
-import asyncio
-import sys
-import os
-
-# 添加项目根目录到Python路径
-sys.path.insert(0, os.path.dirname(os.path.abspath(__file__)))
-
-from ai_reply_engine import ai_reply_engine
-from db_manager import db_manager
-
-def simulate_bargain_conversation():
- """模拟议价对话流程"""
- print("🎭 模拟议价对话流程")
- print("=" * 50)
-
- # 测试参数
- cookie_id = "demo_account_001"
- chat_id = "demo_chat_001"
- user_id = "customer_001"
- item_id = "item_12345"
- user_name = "小明"
-
- # 商品信息
- item_info = {
- 'title': 'iPhone 14 Pro 256GB 深空黑色',
- 'price': 8999,
- 'desc': '全新未拆封，国行正品，支持全国联保'
- }
-
- # 设置AI回复配置（模拟）
- ai_settings = {
- 'ai_enabled': True,
- 'model_name': 'qwen-plus',
- 'api_key': 'demo-key',
- 'base_url': 'https://dashscope.aliyuncs.com/compatible-mode/v1',
- 'max_discount_percent': 10, # 最大优惠10%
- 'max_discount_amount': 500, # 最大优惠500元
- 'max_bargain_rounds': 3, # 最大议价3轮
- 'custom_prompts': ''
- }
-
- # 保存配置
- db_manager.save_ai_reply_settings(cookie_id, ai_settings)
-
- # 清理之前的对话
- try:
- with db_manager.lock:
- cursor = db_manager.conn.cursor()
- cursor.execute('DELETE FROM ai_conversations WHERE cookie_id = ? AND chat_id = ?',
- (cookie_id, chat_id))
- db_manager.conn.commit()
- except:
- pass
-
- print(f"📱 商品信息:")
- print(f" 标题: {item_info['title']}")
- print(f" 价格: ¥{item_info['price']}")
- print(f" 描述: {item_info['desc']}")
-
- print(f"\n⚙️ 议价设置:")
- print(f" 最大议价轮数: {ai_settings['max_bargain_rounds']}")
- print(f" 最大优惠百分比: {ai_settings['max_discount_percent']}%")
- print(f" 最大优惠金额: ¥{ai_settings['max_discount_amount']}")
-
- # 模拟议价对话
- bargain_messages = [
- "你好，这个iPhone能便宜点吗？",
- "8500能卖吗？",
- "8800行不行？最后一次了",
- "8700，真的不能再少了"
- ]
-
- print(f"\n💬 议价对话模拟:")
- print("-" * 30)
-
- for i, message in enumerate(bargain_messages, 1):
- print(f"\n第{i}轮议价:")
- print(f"👤 {user_name}: {message}")
-
- # 检查当前议价次数
- current_count = ai_reply_engine.get_bargain_count(chat_id, cookie_id)
- max_rounds = ai_settings['max_bargain_rounds']
-
- print(f"📊 当前议价次数: {current_count}/{max_rounds}")
-
- # 模拟意图检测为price
- intent = "price"
-
- # 检查是否超出限制
- if current_count >= max_rounds:
- print(f"🚫 已达到最大议价轮数限制！")
- refuse_reply = "抱歉，这个价格已经是最优惠的了，不能再便宜了哦！"
- print(f"🤖 AI回复: {refuse_reply}")
-
- # 保存对话记录
- ai_reply_engine.save_conversation(chat_id, cookie_id, user_id, item_id, "user", message, intent)
- ai_reply_engine.save_conversation(chat_id, cookie_id, user_id, item_id, "assistant", refuse_reply, intent)
-
- print(f"✋ 议价结束，系统拒绝继续议价")
- break
- else:
- # 模拟AI回复（因为没有真实API密钥，这里手动模拟）
- if i == 1:
- ai_reply = "您好！这个价格已经很优惠了，最多可以优惠200元，8799元怎么样？"
- elif i == 2:
- ai_reply = "8500太低了，我们再让一点，8699元，这已经是很大的优惠了！"
- elif i == 3:
- ai_reply = "好的，看您很有诚意，8799元成交，这真的是最低价了！"
- else:
- ai_reply = "抱歉，这个价格已经是最优惠的了！"
-
- print(f"🤖 AI回复: {ai_reply}")
-
- # 保存对话记录
- ai_reply_engine.save_conversation(chat_id, cookie_id, user_id, item_id, "user", message, intent)
- ai_reply_engine.save_conversation(chat_id, cookie_id, user_id, item_id, "assistant", ai_reply, intent)
-
- # 显示最终统计
- print(f"\n📈 最终统计:")
- final_count = ai_reply_engine.get_bargain_count(chat_id, cookie_id)
- print(f" 总议价轮数: {final_count}")
- print(f" 最大允许轮数: {max_rounds}")
- print(f" 是否达到限制: {'是' if final_count >= max_rounds else '否'}")
-
-def show_bargain_features():
- """展示议价功能特性"""
- print(f"\n🎯 议价功能特性说明:")
- print("=" * 50)
-
- features = [
- "✅ 智能议价轮数统计：自动统计用户的议价次数",
- "✅ 灵活轮数限制：可配置最大议价轮数（1-10轮）",
- "✅ 优惠金额控制：设置最大优惠百分比和金额",
- "✅ 友好拒绝回复：超出限制时礼貌拒绝继续议价",
- "✅ 上下文感知：AI了解完整的议价历史",
- "✅ 个性化策略：根据议价轮数调整回复策略",
- "✅ 数据持久化：议价记录永久保存",
- "✅ 实时生效：配置修改后立即生效"
- ]
-
- for feature in features:
- print(f" {feature}")
-
- print(f"\n💡 使用建议:")
- suggestions = [
- "设置合理的最大议价轮数（建议3-5轮）",
- "配合最大优惠百分比和金额使用",
- "在AI提示词中强调议价策略",
- "定期分析议价数据，优化策略",
- "根据商品类型调整议价参数"
- ]
-
- for suggestion in suggestions:
- print(f" • {suggestion}")
-
-def main():
- """主函数"""
- print("🚀 AI回复议价功能演示")
-
- # 模拟议价对话
- simulate_bargain_conversation()
-
- # 展示功能特性
- show_bargain_features()
-
- print(f"\n🎉 演示完成！")
- print(f"\n📋 下一步:")
- print(f" 1. 在Web界面配置真实的AI API密钥")
- print(f" 2. 为需要的账号启用AI回复功能")
- print(f" 3. 设置合适的议价参数")
- print(f" 4. 测试实际的议价效果")
-
-if __name__ == "__main__":
- main()
diff --git a/cookie_manager.py b/cookie_manager.py
index e742e6c..a901281 100644
--- a/cookie_manager.py
+++ b/cookie_manager.py
@@ -62,12 +62,12 @@ class CookieManager:
except Exception as e:
logger.error(f"XianyuLive 任务异常({cookie_id}): {e}")
- async def _add_cookie_async(self, cookie_id: str, cookie_value: str):
+ async def _add_cookie_async(self, cookie_id: str, cookie_value: str, user_id: int = None):
if cookie_id in self.tasks:
raise ValueError("Cookie ID already exists")
self.cookies[cookie_id] = cookie_value
- # 保存到数据库
- db_manager.save_cookie(cookie_id, cookie_value)
+ # 保存到数据库，如果没有指定user_id，则保持原有绑定关系
+ db_manager.save_cookie(cookie_id, cookie_value, user_id)
task = self.loop.create_task(self._run_xianyu(cookie_id, cookie_value))
self.tasks[cookie_id] = task
logger.info(f"已启动账号任务: {cookie_id}")
@@ -83,7 +83,7 @@ class CookieManager:
logger.info(f"已移除账号: {cookie_id}")
# ------------------------ 对外线程安全接口 ------------------------
- def add_cookie(self, cookie_id: str, cookie_value: str, kw_list: Optional[List[Tuple[str, str]]] = None):
+ def add_cookie(self, cookie_id: str, cookie_value: str, kw_list: Optional[List[Tuple[str, str]]] = None, user_id: int = None):
"""线程安全新增 Cookie 并启动任务"""
if kw_list is not None:
self.keywords[cookie_id] = kw_list
@@ -96,9 +96,9 @@ class CookieManager:
if current_loop and current_loop == self.loop:
# 同一事件循环中，直接调度
- return self.loop.create_task(self._add_cookie_async(cookie_id, cookie_value))
+ return self.loop.create_task(self._add_cookie_async(cookie_id, cookie_value, user_id))
else:
- fut = asyncio.run_coroutine_threadsafe(self._add_cookie_async(cookie_id, cookie_value), self.loop)
+ fut = asyncio.run_coroutine_threadsafe(self._add_cookie_async(cookie_id, cookie_value, user_id), self.loop)
return fut.result()
def remove_cookie(self, cookie_id: str):
diff --git a/db_manager.py b/db_manager.py
index 60e8a5a..2865649 100644
--- a/db_manager.py
+++ b/db_manager.py
@@ -182,11 +182,23 @@ class DBManager:
data_content TEXT,
description TEXT,
enabled BOOLEAN DEFAULT TRUE,
+ user_id INTEGER NOT NULL DEFAULT 1,
created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
- updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+ updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+ FOREIGN KEY (user_id) REFERENCES users (id)
)
''')
+ # 检查并添加 user_id 列（用于数据库迁移）
+ try:
+ cursor.execute("SELECT user_id FROM cards LIMIT 1")
+ except sqlite3.OperationalError:
+ # user_id 列不存在，需要添加
+ logger.info("正在为 cards 表添加 user_id 列...")
+ cursor.execute("ALTER TABLE cards ADD COLUMN user_id INTEGER NOT NULL DEFAULT 1")
+ cursor.execute("CREATE INDEX IF NOT EXISTS idx_cards_user_id ON cards(user_id)")
+ logger.info("cards 表 user_id 列添加完成")
+
# 创建商品信息表
cursor.execute('''
CREATE TABLE IF NOT EXISTS item_info (
@@ -271,6 +283,21 @@ class DBManager:
)
''')
+ # 创建用户设置表
+ cursor.execute('''
+ CREATE TABLE IF NOT EXISTS user_settings (
+ id INTEGER PRIMARY KEY AUTOINCREMENT,
+ user_id INTEGER NOT NULL,
+ key TEXT NOT NULL,
+ value TEXT NOT NULL,
+ description TEXT,
+ created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+ updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+ FOREIGN KEY (user_id) REFERENCES users(id) ON DELETE CASCADE,
+ UNIQUE(user_id, key)
+ )
+ ''')
+
# 插入默认系统设置
cursor.execute('''
INSERT OR IGNORE INTO system_settings (key, value, description) VALUES
@@ -301,6 +328,39 @@ class DBManager:
# user_id列存在，更新NULL值
cursor.execute("UPDATE cookies SET user_id = ? WHERE user_id IS NULL", (admin_user_id,))
+ # 为delivery_rules表添加user_id字段（如果不存在）
+ try:
+ cursor.execute("SELECT user_id FROM delivery_rules LIMIT 1")
+ except sqlite3.OperationalError:
+ # user_id列不存在，需要添加并更新历史数据
+ cursor.execute("ALTER TABLE delivery_rules ADD COLUMN user_id INTEGER")
+ cursor.execute("UPDATE delivery_rules SET user_id = ? WHERE user_id IS NULL", (admin_user_id,))
+ else:
+ # user_id列存在，更新NULL值
+ cursor.execute("UPDATE delivery_rules SET user_id = ? WHERE user_id IS NULL", (admin_user_id,))
+
+ # 为notification_channels表添加user_id字段（如果不存在）
+ try:
+ cursor.execute("SELECT user_id FROM notification_channels LIMIT 1")
+ except sqlite3.OperationalError:
+ # user_id列不存在，需要添加并更新历史数据
+ cursor.execute("ALTER TABLE notification_channels ADD COLUMN user_id INTEGER")
+ cursor.execute("UPDATE notification_channels SET user_id = ? WHERE user_id IS NULL", (admin_user_id,))
+ else:
+ # user_id列存在，更新NULL值
+ cursor.execute("UPDATE notification_channels SET user_id = ? WHERE user_id IS NULL", (admin_user_id,))
+
+ # 为email_verifications表添加type字段（如果不存在）
+ try:
+ cursor.execute("SELECT type FROM email_verifications LIMIT 1")
+ except sqlite3.OperationalError:
+ # type列不存在，需要添加并更新历史数据
+ cursor.execute("ALTER TABLE email_verifications ADD COLUMN type TEXT DEFAULT 'register'")
+ cursor.execute("UPDATE email_verifications SET type = 'register' WHERE type IS NULL")
+ else:
+ # type列存在，更新NULL值
+ cursor.execute("UPDATE email_verifications SET type = 'register' WHERE type IS NULL")
+
self.conn.commit()
logger.info(f"数据库初始化成功: {self.db_path}")
except Exception as e:
@@ -345,7 +405,15 @@ class DBManager:
(cookie_id, cookie_value, user_id)
)
self.conn.commit()
- logger.debug(f"Cookie保存成功: {cookie_id} (用户ID: {user_id})")
+ logger.info(f"Cookie保存成功: {cookie_id} (用户ID: {user_id})")
+
+ # 验证保存结果
+ cursor.execute("SELECT user_id FROM cookies WHERE id = ?", (cookie_id,))
+ saved_user_id = cursor.fetchone()
+ if saved_user_id:
+ logger.info(f"Cookie保存验证: {cookie_id} 实际绑定到用户ID: {saved_user_id[0]}")
+ else:
+ logger.error(f"Cookie保存验证失败: {cookie_id} 未找到记录")
return True
except Exception as e:
logger.error(f"Cookie保存失败: {e}")
@@ -713,15 +781,15 @@ class DBManager:
return False
# -------------------- 通知渠道操作 --------------------
- def create_notification_channel(self, name: str, channel_type: str, config: str) -> int:
+ def create_notification_channel(self, name: str, channel_type: str, config: str, user_id: int = None) -> int:
"""创建通知渠道"""
with self.lock:
try:
cursor = self.conn.cursor()
cursor.execute('''
- INSERT INTO notification_channels (name, type, config)
- VALUES (?, ?, ?)
- ''', (name, channel_type, config))
+ INSERT INTO notification_channels (name, type, config, user_id)
+ VALUES (?, ?, ?, ?)
+ ''', (name, channel_type, config, user_id))
self.conn.commit()
channel_id = cursor.lastrowid
logger.debug(f"创建通知渠道: {name} (ID: {channel_id})")
@@ -731,16 +799,24 @@ class DBManager:
self.conn.rollback()
raise
- def get_notification_channels(self) -> List[Dict[str, any]]:
+ def get_notification_channels(self, user_id: int = None) -> List[Dict[str, any]]:
"""获取所有通知渠道"""
with self.lock:
try:
cursor = self.conn.cursor()
- cursor.execute('''
- SELECT id, name, type, config, enabled, created_at, updated_at
- FROM notification_channels
- ORDER BY created_at DESC
- ''')
+ if user_id is not None:
+ cursor.execute('''
+ SELECT id, name, type, config, enabled, created_at, updated_at
+ FROM notification_channels
+ WHERE user_id = ?
+ ORDER BY created_at DESC
+ ''', (user_id,))
+ else:
+ cursor.execute('''
+ SELECT id, name, type, config, enabled, created_at, updated_at
+ FROM notification_channels
+ ORDER BY created_at DESC
+ ''')
channels = []
for row in cursor.fetchall():
@@ -1360,7 +1436,7 @@ class DBManager:
logger.error(f"验证图形验证码失败: {e}")
return False
- def save_verification_code(self, email: str, code: str, expires_minutes: int = 10) -> bool:
+ def save_verification_code(self, email: str, code: str, code_type: str = 'register', expires_minutes: int = 10) -> bool:
"""保存邮箱验证码"""
with self.lock:
try:
@@ -1368,19 +1444,19 @@ class DBManager:
expires_at = time.time() + (expires_minutes * 60)
cursor.execute('''
- INSERT INTO email_verifications (email, code, expires_at)
- VALUES (?, ?, ?)
- ''', (email, code, expires_at))
+ INSERT INTO email_verifications (email, code, type, expires_at)
+ VALUES (?, ?, ?, ?)
+ ''', (email, code, code_type, expires_at))
self.conn.commit()
- logger.info(f"保存验证码成功: {email}")
+ logger.info(f"保存验证码成功: {email} ({code_type})")
return True
except Exception as e:
logger.error(f"保存验证码失败: {e}")
self.conn.rollback()
return False
- def verify_email_code(self, email: str, code: str) -> bool:
+ def verify_email_code(self, email: str, code: str, code_type: str = 'register') -> bool:
"""验证邮箱验证码"""
with self.lock:
try:
@@ -1390,9 +1466,9 @@ class DBManager:
# 查找有效的验证码
cursor.execute('''
SELECT id FROM email_verifications
- WHERE email = ? AND code = ? AND expires_at > ? AND used = FALSE
+ WHERE email = ? AND code = ? AND type = ? AND expires_at > ? AND used = FALSE
ORDER BY created_at DESC LIMIT 1
- ''', (email, code, current_time))
+ ''', (email, code, code_type, current_time))
row = cursor.fetchone()
if row:
@@ -1401,10 +1477,10 @@ class DBManager:
UPDATE email_verifications SET used = TRUE WHERE id = ?
''', (row[0],))
self.conn.commit()
- logger.info(f"验证码验证成功: {email}")
+ logger.info(f"验证码验证成功: {email} ({code_type})")
return True
else:
- logger.warning(f"验证码验证失败: {email} - {code}")
+ logger.warning(f"验证码验证失败: {email} - {code} ({code_type})")
return False
except Exception as e:
logger.error(f"验证邮箱验证码失败: {e}")
@@ -1414,78 +1490,52 @@ class DBManager:
"""发送验证码邮件"""
try:
subject = "闲鱼自动回复系统 - 邮箱验证码"
- html_content = f"""
-
-
-
-
-
-
-
-
- ![]()
-
-
-
-
-
- """
+如果您在使用过程中遇到任何问题，请联系我们的技术支持团队。
+感谢您选择闲鱼自动回复系统！
- # 调用邮件发送API
+---
+此邮件由系统自动发送，请勿直接回复
+© 2025 闲鱼自动回复系统"""
+
+ # 使用GET请求发送邮件
api_url = "https://dy.zhinianboke.com/api/emailSend"
params = {
'subject': subject,
'receiveUser': email,
- 'sendHtml': html_content
+ 'sendHtml': text_content
}
async with aiohttp.ClientSession() as session:
- async with session.get(api_url, params=params) as response:
- if response.status == 200:
- logger.info(f"验证码邮件发送成功: {email}")
- return True
- else:
- logger.error(f"验证码邮件发送失败: {email}, 状态码: {response.status}")
- return False
+ try:
+ logger.info(f"发送验证码邮件: {email}")
+ async with session.get(api_url, params=params, timeout=15) as response:
+ response_text = await response.text()
+ logger.info(f"邮件API响应: {response.status}")
+
+ if response.status == 200:
+ logger.info(f"验证码邮件发送成功: {email}")
+ return True
+ else:
+ logger.error(f"验证码邮件发送失败: {email}, 状态码: {response.status}, 响应: {response_text[:200]}")
+ return False
+ except Exception as e:
+ logger.error(f"邮件发送异常: {email}, 错误: {e}")
+ return False
except Exception as e:
logger.error(f"发送验证码邮件异常: {e}")
@@ -1688,15 +1738,15 @@ class DBManager:
# ==================== 自动发货规则方法 ====================
def create_delivery_rule(self, keyword: str, card_id: int, delivery_count: int = 1,
- enabled: bool = True, description: str = None):
+ enabled: bool = True, description: str = None, user_id: int = None):
"""创建发货规则"""
with self.lock:
try:
cursor = self.conn.cursor()
cursor.execute('''
- INSERT INTO delivery_rules (keyword, card_id, delivery_count, enabled, description)
- VALUES (?, ?, ?, ?, ?)
- ''', (keyword, card_id, delivery_count, enabled, description))
+ INSERT INTO delivery_rules (keyword, card_id, delivery_count, enabled, description, user_id)
+ VALUES (?, ?, ?, ?, ?, ?)
+ ''', (keyword, card_id, delivery_count, enabled, description, user_id))
self.conn.commit()
rule_id = cursor.lastrowid
logger.info(f"创建发货规则成功: {keyword} -> 卡券ID {card_id} (规则ID: {rule_id})")
@@ -1705,19 +1755,30 @@ class DBManager:
logger.error(f"创建发货规则失败: {e}")
raise
- def get_all_delivery_rules(self):
+ def get_all_delivery_rules(self, user_id: int = None):
"""获取所有发货规则"""
with self.lock:
try:
cursor = self.conn.cursor()
- cursor.execute('''
- SELECT dr.id, dr.keyword, dr.card_id, dr.delivery_count, dr.enabled,
- dr.description, dr.delivery_times, dr.created_at, dr.updated_at,
- c.name as card_name, c.type as card_type
- FROM delivery_rules dr
- LEFT JOIN cards c ON dr.card_id = c.id
- ORDER BY dr.created_at DESC
- ''')
+ if user_id is not None:
+ cursor.execute('''
+ SELECT dr.id, dr.keyword, dr.card_id, dr.delivery_count, dr.enabled,
+ dr.description, dr.delivery_times, dr.created_at, dr.updated_at,
+ c.name as card_name, c.type as card_type
+ FROM delivery_rules dr
+ LEFT JOIN cards c ON dr.card_id = c.id
+ WHERE dr.user_id = ?
+ ORDER BY dr.created_at DESC
+ ''', (user_id,))
+ else:
+ cursor.execute('''
+ SELECT dr.id, dr.keyword, dr.card_id, dr.delivery_count, dr.enabled,
+ dr.description, dr.delivery_times, dr.created_at, dr.updated_at,
+ c.name as card_name, c.type as card_type
+ FROM delivery_rules dr
+ LEFT JOIN cards c ON dr.card_id = c.id
+ ORDER BY dr.created_at DESC
+ ''')
rules = []
for row in cursor.fetchall():
@@ -1750,7 +1811,7 @@ class DBManager:
SELECT dr.id, dr.keyword, dr.card_id, dr.delivery_count, dr.enabled,
dr.description, dr.delivery_times,
c.name as card_name, c.type as card_type, c.api_config,
- c.text_content, c.data_content, c.enabled as card_enabled
+ c.text_content, c.data_content, c.enabled as card_enabled, c.description as card_description
FROM delivery_rules dr
LEFT JOIN cards c ON dr.card_id = c.id
WHERE dr.enabled = 1 AND c.enabled = 1
@@ -1788,7 +1849,8 @@ class DBManager:
'card_api_config': api_config,
'card_text_content': row[10],
'card_data_content': row[11],
- 'card_enabled': bool(row[12])
+ 'card_enabled': bool(row[12]),
+ 'card_description': row[13] # 卡券备注信息
})
return rules
diff --git a/demo_captcha_registration.py b/demo_captcha_registration.py
deleted file mode 100644
index dcf2c43..0000000
--- a/demo_captcha_registration.py
+++ /dev/null
@@ -1,329 +0,0 @@
-#!/usr/bin/env python3
-"""
-图形验证码注册流程演示
-"""
-
-import requests
-import json
-import sqlite3
-import time
-
-def demo_complete_registration():
- """演示完整的注册流程"""
- print("🎭 图形验证码注册流程演示")
- print("=" * 60)
-
- session_id = f"demo_session_{int(time.time())}"
- test_email = "demo@example.com"
- test_username = "demouser"
- test_password = "demo123456"
-
- # 清理可能存在的测试数据
- try:
- conn = sqlite3.connect('xianyu_data.db')
- cursor = conn.cursor()
- cursor.execute('DELETE FROM users WHERE username = ? OR email = ?', (test_username, test_email))
- cursor.execute('DELETE FROM email_verifications WHERE email = ?', (test_email,))
- cursor.execute('DELETE FROM captcha_codes WHERE session_id = ?', (session_id,))
- conn.commit()
- conn.close()
- print("🧹 清理旧的测试数据")
- except:
- pass
-
- print("\n📋 注册流程步骤:")
- print("1. 生成图形验证码")
- print("2. 用户输入图形验证码")
- print("3. 验证图形验证码")
- print("4. 发送邮箱验证码")
- print("5. 用户输入邮箱验证码")
- print("6. 完成注册")
-
- # 步骤1: 生成图形验证码
- print("\n🔸 步骤1: 生成图形验证码")
- response = requests.post('http://localhost:8080/generate-captcha',
- json={'session_id': session_id})
-
- if response.status_code != 200:
- print(f"❌ 生成图形验证码失败: {response.status_code}")
- return False
-
- result = response.json()
- if not result['success']:
- print(f"❌ 生成图形验证码失败: {result['message']}")
- return False
-
- print("✅ 图形验证码生成成功")
-
- # 从数据库获取验证码文本（模拟用户看到图片并输入）
- conn = sqlite3.connect('xianyu_data.db')
- cursor = conn.cursor()
- cursor.execute('SELECT code FROM captcha_codes WHERE session_id = ? ORDER BY created_at DESC LIMIT 1',
- (session_id,))
- captcha_result = cursor.fetchone()
- conn.close()
-
- if not captcha_result:
- print("❌ 无法获取图形验证码")
- return False
-
- captcha_text = captcha_result[0]
- print(f"📷 图形验证码: {captcha_text}")
-
- # 步骤2-3: 验证图形验证码
- print("\n🔸 步骤2-3: 验证图形验证码")
- response = requests.post('http://localhost:8080/verify-captcha',
- json={
- 'session_id': session_id,
- 'captcha_code': captcha_text
- })
-
- if response.status_code != 200:
- print(f"❌ 验证图形验证码失败: {response.status_code}")
- return False
-
- result = response.json()
- if not result['success']:
- print(f"❌ 图形验证码验证失败: {result['message']}")
- return False
-
- print("✅ 图形验证码验证成功")
-
- # 步骤4: 发送邮箱验证码
- print("\n🔸 步骤4: 发送邮箱验证码")
- response = requests.post('http://localhost:8080/send-verification-code',
- json={'email': test_email})
-
- if response.status_code != 200:
- print(f"❌ 发送邮箱验证码失败: {response.status_code}")
- return False
-
- result = response.json()
- if not result['success']:
- print(f"❌ 发送邮箱验证码失败: {result['message']}")
- return False
-
- print("✅ 邮箱验证码发送成功")
-
- # 从数据库获取邮箱验证码（模拟用户收到邮件）
- conn = sqlite3.connect('xianyu_data.db')
- cursor = conn.cursor()
- cursor.execute('SELECT code FROM email_verifications WHERE email = ? ORDER BY created_at DESC LIMIT 1',
- (test_email,))
- email_result = cursor.fetchone()
- conn.close()
-
- if not email_result:
- print("❌ 无法获取邮箱验证码")
- return False
-
- email_code = email_result[0]
- print(f"📧 邮箱验证码: {email_code}")
-
- # 步骤5-6: 完成注册
- print("\n🔸 步骤5-6: 完成用户注册")
- response = requests.post('http://localhost:8080/register',
- json={
- 'username': test_username,
- 'email': test_email,
- 'verification_code': email_code,
- 'password': test_password
- })
-
- if response.status_code != 200:
- print(f"❌ 用户注册失败: {response.status_code}")
- return False
-
- result = response.json()
- if not result['success']:
- print(f"❌ 用户注册失败: {result['message']}")
- return False
-
- print("✅ 用户注册成功")
-
- # 验证登录
- print("\n🔸 验证登录功能")
- response = requests.post('http://localhost:8080/login',
- json={
- 'username': test_username,
- 'password': test_password
- })
-
- if response.status_code != 200:
- print(f"❌ 用户登录失败: {response.status_code}")
- return False
-
- result = response.json()
- if not result['success']:
- print(f"❌ 用户登录失败: {result['message']}")
- return False
-
- print("✅ 用户登录成功")
- print(f"🎫 Token: {result['token'][:20]}...")
- print(f"👤 用户ID: {result['user_id']}")
-
- return True
-
-def demo_security_features():
- """演示安全特性"""
- print("\n🔒 安全特性演示")
- print("-" * 40)
-
- session_id = f"security_test_{int(time.time())}"
-
- # 1. 测试错误的图形验证码
- print("1️⃣ 测试错误的图形验证码...")
-
- # 先生成一个验证码
- requests.post('http://localhost:8080/generate-captcha',
- json={'session_id': session_id})
-
- # 尝试用错误的验证码
- response = requests.post('http://localhost:8080/verify-captcha',
- json={
- 'session_id': session_id,
- 'captcha_code': 'WRONG'
- })
-
- result = response.json()
- if not result['success']:
- print(" ✅ 错误的图形验证码被正确拒绝")
- else:
- print(" ❌ 错误的图形验证码验证成功（安全漏洞）")
-
- # 2. 测试未验证图形验证码就发送邮件
- print("\n2️⃣ 测试未验证图形验证码发送邮件...")
-
- # 注意：当前实现中发送邮件接口没有检查图形验证码状态
- # 这是前端控制的，后端应该也要检查
- response = requests.post('http://localhost:8080/send-verification-code',
- json={'email': 'test@example.com'})
-
- result = response.json()
- if result['success']:
- print(" ⚠️ 未验证图形验证码也能发送邮件（建议后端也要检查）")
- else:
- print(" ✅ 未验证图形验证码无法发送邮件")
-
- # 3. 测试验证码重复使用
- print("\n3️⃣ 测试验证码重复使用...")
-
- # 生成新的验证码
- session_id2 = f"reuse_test_{int(time.time())}"
- requests.post('http://localhost:8080/generate-captcha',
- json={'session_id': session_id2})
-
- # 获取验证码
- conn = sqlite3.connect('xianyu_data.db')
- cursor = conn.cursor()
- cursor.execute('SELECT code FROM captcha_codes WHERE session_id = ? ORDER BY created_at DESC LIMIT 1',
- (session_id2,))
- result = cursor.fetchone()
- conn.close()
-
- if result:
- captcha_code = result[0]
-
- # 第一次验证
- response1 = requests.post('http://localhost:8080/verify-captcha',
- json={
- 'session_id': session_id2,
- 'captcha_code': captcha_code
- })
-
- # 第二次验证（重复使用）
- response2 = requests.post('http://localhost:8080/verify-captcha',
- json={
- 'session_id': session_id2,
- 'captcha_code': captcha_code
- })
-
- result1 = response1.json()
- result2 = response2.json()
-
- if result1['success'] and not result2['success']:
- print(" ✅ 验证码重复使用被正确阻止")
- else:
- print(" ❌ 验证码可以重复使用（安全漏洞）")
-
-def cleanup_demo_data():
- """清理演示数据"""
- print("\n🧹 清理演示数据")
- print("-" * 40)
-
- try:
- conn = sqlite3.connect('xianyu_data.db')
- cursor = conn.cursor()
-
- # 清理测试用户
- cursor.execute('DELETE FROM users WHERE username LIKE "demo%" OR email LIKE "demo%"')
- user_count = cursor.rowcount
-
- # 清理测试验证码
- cursor.execute('DELETE FROM email_verifications WHERE email LIKE "demo%"')
- email_count = cursor.rowcount
-
- # 清理测试图形验证码
- cursor.execute('DELETE FROM captcha_codes WHERE session_id LIKE "demo%" OR session_id LIKE "security%" OR session_id LIKE "reuse%"')
- captcha_count = cursor.rowcount
-
- conn.commit()
- conn.close()
-
- print(f"✅ 清理完成:")
- print(f" • 用户: {user_count} 条")
- print(f" • 邮箱验证码: {email_count} 条")
- print(f" • 图形验证码: {captcha_count} 条")
-
- except Exception as e:
- print(f"❌ 清理失败: {e}")
-
-def main():
- """主演示函数"""
- print("🎪 图形验证码系统完整演示")
- print("=" * 60)
-
- try:
- # 演示完整注册流程
- success = demo_complete_registration()
-
- if success:
- print("\n🎉 完整注册流程演示成功！")
- else:
- print("\n💥 注册流程演示失败！")
- return False
-
- # 演示安全特性
- demo_security_features()
-
- # 清理演示数据
- cleanup_demo_data()
-
- print("\n" + "=" * 60)
- print("🎊 图形验证码系统演示完成！")
-
- print("\n📋 功能总结:")
- print("✅ 图形验证码生成和验证")
- print("✅ 邮箱验证码发送")
- print("✅ 用户注册流程")
- print("✅ 用户登录验证")
- print("✅ 安全特性保护")
-
- print("\n🌐 使用方法:")
- print("1. 访问: http://localhost:8080/register.html")
- print("2. 查看图形验证码并输入")
- print("3. 输入邮箱地址")
- print("4. 点击发送验证码（需要先验证图形验证码）")
- print("5. 输入邮箱验证码")
- print("6. 设置密码并完成注册")
-
- return True
-
- except Exception as e:
- print(f"\n❌ 演示失败: {e}")
- import traceback
- traceback.print_exc()
- return False
-
-if __name__ == "__main__":
- main()
diff --git a/deploy.bat b/deploy.bat
deleted file mode 100644
index c10fd9d..0000000
--- a/deploy.bat
+++ /dev/null
@@ -1,298 +0,0 @@
-@echo off
-chcp 65001 >nul
-setlocal enabledelayedexpansion
-
-:: 闲鱼自动回复系统 Docker 部署脚本 (Windows版本)
-:: 作者: Xianyu Auto Reply System
-:: 版本: 1.0.0
-
-title 闲鱼自动回复系统 Docker 部署
-
-:: 颜色定义
-set "RED=[91m"
-set "GREEN=[92m"
-set "YELLOW=[93m"
-set "BLUE=[94m"
-set "NC=[0m"
-
-:: 打印带颜色的消息
-:print_info
-echo %BLUE%[INFO]%NC% %~1
-goto :eof
-
-:print_success
-echo %GREEN%[SUCCESS]%NC% %~1
-goto :eof
-
-:print_warning
-echo %YELLOW%[WARNING]%NC% %~1
-goto :eof
-
-:print_error
-echo %RED%[ERROR]%NC% %~1
-goto :eof
-
-:: 检查Docker是否安装
-:check_docker
-call :print_info "检查 Docker 环境..."
-
-docker --version >nul 2>&1
-if errorlevel 1 (
- call :print_error "Docker 未安装，请先安装 Docker Desktop"
- echo.
- echo 下载地址: https://www.docker.com/products/docker-desktop
- pause
- exit /b 1
-)
-
-docker-compose --version >nul 2>&1
-if errorlevel 1 (
- call :print_error "Docker Compose 未安装，请先安装 Docker Compose"
- pause
- exit /b 1
-)
-
-call :print_success "Docker 环境检查通过"
-goto :eof
-
-:: 创建必要的目录
-:create_directories
-call :print_info "创建必要的目录..."
-
-if not exist "data" mkdir data
-if not exist "logs" mkdir logs
-if not exist "backups" mkdir backups
-if not exist "nginx" mkdir nginx
-if not exist "nginx\ssl" mkdir nginx\ssl
-
-REM 检查目录是否创建成功
-if not exist "data" (
- call :print_error "data目录创建失败"
- pause
- exit /b 1
-)
-
-if not exist "logs" (
- call :print_error "logs目录创建失败"
- pause
- exit /b 1
-)
-
-call :print_success "目录创建完成"
-goto :eof
-
-:: 生成默认配置文件
-:generate_config
-REM 生成.env文件
-if not exist ".env" (
- if exist ".env.example" (
- call :print_info "从模板生成 .env 文件..."
- copy ".env.example" ".env" >nul
- call :print_success ".env 文件已生成"
- ) else (
- call :print_warning ".env.example 文件不存在，跳过 .env 文件生成"
- )
-) else (
- call :print_info ".env 文件已存在，跳过生成"
-)
-
-REM 生成global_config.yml文件
-if exist "global_config.yml" (
- call :print_info "配置文件已存在，跳过生成"
- goto :eof
-)
-
-call :print_info "生成默认配置文件..."
-
-(
-echo # 闲鱼自动回复系统配置文件
-echo API_ENDPOINTS:
-echo login_check: https://passport.goofish.com/newlogin/hasLogin.do
-echo message_headinfo: https://h5api.m.goofish.com/h5/mtop.idle.trade.pc.message.headinfo/1.0/
-echo token: https://h5api.m.goofish.com/h5/mtop.taobao.idlemessage.pc.login.token/1.0/
-echo.
-echo APP_CONFIG:
-echo api_version: '1.0'
-echo app_key: 444e9908a51d1cb236a27862abc769c9
-echo app_version: '1.0'
-echo platform: web
-echo.
-echo AUTO_REPLY:
-echo enabled: true
-echo default_message: '亲爱的"{send_user_name}" 老板你好！所有宝贝都可以拍，秒发货的哈~不满意的话可以直接申请退款哈~'
-echo max_retry: 3
-echo retry_interval: 5
-echo api:
-echo enabled: false
-echo host: 0.0.0.0 # 绑定所有网络接口，支持IP访问
-echo port: 8080 # Web服务端口
-echo url: http://0.0.0.0:8080/xianyu/reply
-echo timeout: 10
-echo.
-echo COOKIES:
-echo last_update_time: ''
-echo value: ''
-echo.
-echo DEFAULT_HEADERS:
-echo accept: application/json
-echo accept-language: zh-CN,zh;q=0.9
-echo cache-control: no-cache
-echo origin: https://www.goofish.com
-echo pragma: no-cache
-echo referer: https://www.goofish.com/
-echo user-agent: Mozilla/5.0 ^(Windows NT 10.0; Win64; x64^) AppleWebKit/537.36 ^(KHTML, like Gecko^) Chrome/119.0.0.0 Safari/537.36
-echo.
-echo WEBSOCKET_URL: wss://wss-goofish.dingtalk.com/
-echo HEARTBEAT_INTERVAL: 15
-echo HEARTBEAT_TIMEOUT: 5
-echo TOKEN_REFRESH_INTERVAL: 3600
-echo TOKEN_RETRY_INTERVAL: 300
-echo MESSAGE_EXPIRE_TIME: 300000
-echo.
-echo LOG_CONFIG:
-echo level: INFO
-echo format: '{time:YYYY-MM-DD HH:mm:ss.SSS} | {level} | {name}:{function}:{line} - {message}'
-echo rotation: '1 day'
-echo retention: '7 days'
-) > global_config.yml
-
-call :print_success "默认配置文件已生成"
-goto :eof
-
-:: 构建Docker镜像
-:build_image
-call :print_info "构建 Docker 镜像..."
-
-docker build -t xianyu-auto-reply:latest .
-if errorlevel 1 (
- call :print_error "Docker 镜像构建失败"
- pause
- exit /b 1
-)
-
-call :print_success "Docker 镜像构建完成"
-goto :eof
-
-:: 启动服务
-:start_services
-call :print_info "启动服务..."
-
-if "%~1"=="--with-nginx" (
- call :print_info "启动服务（包含 Nginx）..."
- docker-compose --profile with-nginx up -d
-) else (
- call :print_info "启动服务（不包含 Nginx）..."
- docker-compose up -d
-)
-
-if errorlevel 1 (
- call :print_error "服务启动失败"
- pause
- exit /b 1
-)
-
-call :print_success "服务启动完成"
-goto :eof
-
-:: 显示服务状态
-:show_status
-call :print_info "服务状态："
-docker-compose ps
-
-echo.
-call :print_info "服务日志（最近10行）："
-docker-compose logs --tail=10
-goto :eof
-
-:: 显示访问信息
-:show_access_info
-call :print_success "部署完成！"
-echo.
-call :print_info "访问信息："
-echo Web界面: http://localhost:8080
-echo 默认账号: admin
-echo 默认密码: admin123
-echo.
-call :print_info "常用命令："
-echo 查看日志: docker-compose logs -f
-echo 重启服务: docker-compose restart
-echo 停止服务: docker-compose down
-echo 更新服务: deploy.bat update
-echo.
-call :print_info "数据目录："
-echo 数据库: .\data\xianyu_data.db
-echo 日志: .\logs\
-echo 配置: .\global_config.yml
-echo.
-goto :eof
-
-:: 更新服务
-:update_services
-call :print_info "更新服务..."
-
-docker-compose down
-call :build_image
-call :start_services %~1
-
-call :print_success "服务更新完成"
-goto :eof
-
-:: 清理资源
-:cleanup
-call :print_warning "清理 Docker 资源..."
-
-docker-compose down --volumes --remove-orphans
-docker rmi xianyu-auto-reply:latest 2>nul
-
-call :print_success "清理完成"
-goto :eof
-
-:: 显示帮助
-:show_help
-echo 使用方法:
-echo %~nx0 # 首次部署
-echo %~nx0 with-nginx # 部署并启动 Nginx
-echo %~nx0 update # 更新服务
-echo %~nx0 update with-nginx # 更新服务并启动 Nginx
-echo %~nx0 status # 查看服务状态
-echo %~nx0 cleanup # 清理所有资源
-echo %~nx0 help # 显示帮助
-goto :eof
-
-:: 主函数
-:main
-echo ========================================
-echo 闲鱼自动回复系统 Docker 部署脚本
-echo ========================================
-echo.
-
-if "%~1"=="update" (
- call :print_info "更新模式"
- call :check_docker
- call :update_services %~2
- call :show_status
- call :show_access_info
-) else if "%~1"=="cleanup" (
- call :print_warning "清理模式"
- call :cleanup
-) else if "%~1"=="status" (
- call :show_status
-) else if "%~1"=="help" (
- call :show_help
-) else (
- call :print_info "首次部署模式"
- call :check_docker
- call :create_directories
- call :generate_config
- call :build_image
- call :start_services %~1
- call :show_status
- call :show_access_info
-)
-
-echo.
-pause
-goto :eof
-
-:: 执行主函数
-call :main %*
diff --git a/deploy.sh b/deploy.sh
deleted file mode 100644
index 75f3d0b..0000000
--- a/deploy.sh
+++ /dev/null
@@ -1,288 +0,0 @@
-#!/bin/bash
-
-# 闲鱼自动回复系统 Docker 部署脚本
-# 作者: Xianyu Auto Reply System
-# 版本: 1.0.0
-
-set -e
-
-# 颜色定义
-RED='\033[0;31m'
-GREEN='\033[0;32m'
-YELLOW='\033[1;33m'
-BLUE='\033[0;34m'
-NC='\033[0m' # No Color
-
-# 打印带颜色的消息
-print_info() {
- echo -e "${BLUE}[INFO]${NC} $1"
-}
-
-print_success() {
- echo -e "${GREEN}[SUCCESS]${NC} $1"
-}
-
-print_warning() {
- echo -e "${YELLOW}[WARNING]${NC} $1"
-}
-
-print_error() {
- echo -e "${RED}[ERROR]${NC} $1"
-}
-
-# 检查Docker是否安装
-check_docker() {
- if ! command -v docker &> /dev/null; then
- print_error "Docker 未安装，请先安装 Docker"
- exit 1
- fi
-
- if ! command -v docker-compose &> /dev/null; then
- print_error "Docker Compose 未安装，请先安装 Docker Compose"
- exit 1
- fi
-
- print_success "Docker 环境检查通过"
-}
-
-# 创建必要的目录
-create_directories() {
- print_info "创建必要的目录..."
-
- # 创建目录
- mkdir -p data
- mkdir -p logs
- mkdir -p backups
- mkdir -p nginx/ssl
-
- # 设置权限 (确保Docker容器可以写入)
- chmod 755 data logs backups
-
- # 检查权限
- if [ ! -w "data" ]; then
- print_error "data目录没有写权限"
- exit 1
- fi
-
- if [ ! -w "logs" ]; then
- print_error "logs目录没有写权限"
- exit 1
- fi
-
- print_success "目录创建完成"
-}
-
-# 生成默认配置文件
-generate_config() {
- # 生成.env文件
- if [ ! -f ".env" ]; then
- if [ -f ".env.example" ]; then
- print_info "从模板生成 .env 文件..."
- cp .env.example .env
- print_success ".env 文件已生成"
- else
- print_warning ".env.example 文件不存在，跳过 .env 文件生成"
- fi
- else
- print_info ".env 文件已存在，跳过生成"
- fi
-
- # 生成global_config.yml文件
- if [ ! -f "global_config.yml" ]; then
- print_info "生成默认配置文件..."
-
- cat > global_config.yml << EOF
-# 闲鱼自动回复系统配置文件
-API_ENDPOINTS:
- login_check: https://passport.goofish.com/newlogin/hasLogin.do
- message_headinfo: https://h5api.m.goofish.com/h5/mtop.idle.trade.pc.message.headinfo/1.0/
- token: https://h5api.m.goofish.com/h5/mtop.taobao.idlemessage.pc.login.token/1.0/
-
-APP_CONFIG:
- api_version: '1.0'
- app_key: 444e9908a51d1cb236a27862abc769c9
- app_version: '1.0'
- platform: web
-
-AUTO_REPLY:
- enabled: true
- default_message: '亲爱的"{send_user_name}" 老板你好！所有宝贝都可以拍，秒发货的哈~不满意的话可以直接申请退款哈~'
- max_retry: 3
- retry_interval: 5
- api:
- enabled: false
- host: 0.0.0.0 # 绑定所有网络接口，支持IP访问
- port: 8080 # Web服务端口
- url: http://0.0.0.0:8080/xianyu/reply
- timeout: 10
-
-COOKIES:
- last_update_time: ''
- value: ''
-
-DEFAULT_HEADERS:
- accept: application/json
- accept-language: zh-CN,zh;q=0.9
- cache-control: no-cache
- origin: https://www.goofish.com
- pragma: no-cache
- referer: https://www.goofish.com/
- sec-ch-ua: '"Google Chrome";v="119", "Chromium";v="119", "Not?A_Brand";v="24"'
- sec-ch-ua-mobile: '?0'
- sec-ch-ua-platform: '"Windows"'
- sec-fetch-dest: empty
- sec-fetch-mode: cors
- sec-fetch-site: same-site
- user-agent: Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/119.0.0.0 Safari/537.36
-
-WEBSOCKET_URL: wss://wss-goofish.dingtalk.com/
-HEARTBEAT_INTERVAL: 15
-HEARTBEAT_TIMEOUT: 5
-TOKEN_REFRESH_INTERVAL: 3600
-TOKEN_RETRY_INTERVAL: 300
-MESSAGE_EXPIRE_TIME: 300000
-
-LOG_CONFIG:
- level: INFO
- format: '{time:YYYY-MM-DD HH:mm:ss.SSS} | {level} | {name}:{function}:{line} - {message}'
- rotation: '1 day'
- retention: '7 days'
-EOF
-
- print_success "默认配置文件已生成"
- else
- print_info "配置文件已存在，跳过生成"
- fi
-}
-
-# 构建Docker镜像
-build_image() {
- print_info "构建 Docker 镜像..."
-
- docker build -t xianyu-auto-reply:latest .
-
- print_success "Docker 镜像构建完成"
-}
-
-# 启动服务
-start_services() {
- print_info "启动服务..."
-
- # 检查是否需要启动 Nginx
- if [ "$1" = "--with-nginx" ]; then
- print_info "启动服务（包含 Nginx）..."
- docker-compose --profile with-nginx up -d
- else
- print_info "启动服务（不包含 Nginx）..."
- docker-compose up -d
- fi
-
- print_success "服务启动完成"
-}
-
-# 显示服务状态
-show_status() {
- print_info "服务状态："
- docker-compose ps
-
- print_info "服务日志（最近10行）："
- docker-compose logs --tail=10
-}
-
-# 显示访问信息
-show_access_info() {
- print_success "部署完成！"
- echo ""
- print_info "访问信息："
- echo " Web界面: http://localhost:8080"
- echo " 默认账号: admin"
- echo " 默认密码: admin123"
- echo ""
- print_info "常用命令："
- echo " 查看日志: docker-compose logs -f"
- echo " 重启服务: docker-compose restart"
- echo " 停止服务: docker-compose down"
- echo " 更新服务: ./deploy.sh --update"
- echo ""
- print_info "数据目录："
- echo " 数据库: ./data/xianyu_data.db"
- echo " 日志: ./logs/"
- echo " 配置: ./global_config.yml"
-}
-
-# 更新服务
-update_services() {
- print_info "更新服务..."
-
- # 停止服务
- docker-compose down
-
- # 重新构建镜像
- build_image
-
- # 启动服务
- start_services $1
-
- print_success "服务更新完成"
-}
-
-# 清理资源
-cleanup() {
- print_warning "清理 Docker 资源..."
-
- # 停止并删除容器
- docker-compose down --volumes --remove-orphans
-
- # 删除镜像
- docker rmi xianyu-auto-reply:latest 2>/dev/null || true
-
- print_success "清理完成"
-}
-
-# 主函数
-main() {
- echo "========================================"
- echo " 闲鱼自动回复系统 Docker 部署脚本"
- echo "========================================"
- echo ""
-
- case "$1" in
- --update)
- print_info "更新模式"
- check_docker
- update_services $2
- show_status
- show_access_info
- ;;
- --cleanup)
- print_warning "清理模式"
- cleanup
- ;;
- --status)
- show_status
- ;;
- --help)
- echo "使用方法:"
- echo " $0 # 首次部署"
- echo " $0 --with-nginx # 部署并启动 Nginx"
- echo " $0 --update # 更新服务"
- echo " $0 --update --with-nginx # 更新服务并启动 Nginx"
- echo " $0 --status # 查看服务状态"
- echo " $0 --cleanup # 清理所有资源"
- echo " $0 --help # 显示帮助"
- ;;
- *)
- print_info "首次部署模式"
- check_docker
- create_directories
- generate_config
- build_image
- start_services $1
- show_status
- show_access_info
- ;;
- esac
-}
-
-# 执行主函数
-main "$@"
diff --git a/docker-deploy.bat b/docker-deploy.bat
deleted file mode 100644
index 671acb9..0000000
--- a/docker-deploy.bat
+++ /dev/null
@@ -1,301 +0,0 @@
-@echo off
-chcp 65001 >nul
-setlocal enabledelayedexpansion
-
-:: 闲鱼自动回复系统 Docker 部署脚本 (Windows版本)
-:: 支持快速部署和管理
-
-set PROJECT_NAME=xianyu-auto-reply
-set COMPOSE_FILE=docker-compose.yml
-set ENV_FILE=.env
-
-:: 颜色定义 (Windows 10+ 支持ANSI颜色)
-set "RED=[31m"
-set "GREEN=[32m"
-set "YELLOW=[33m"
-set "BLUE=[34m"
-set "NC=[0m"
-
-:: 打印带颜色的消息
-:print_info
-echo %BLUE%ℹ️ %~1%NC%
-goto :eof
-
-:print_success
-echo %GREEN%✅ %~1%NC%
-goto :eof
-
-:print_warning
-echo %YELLOW%⚠️ %~1%NC%
-goto :eof
-
-:print_error
-echo %RED%❌ %~1%NC%
-goto :eof
-
-:: 检查依赖
-:check_dependencies
-call :print_info "检查系统依赖..."
-
-docker --version >nul 2>&1
-if errorlevel 1 (
- call :print_error "Docker 未安装，请先安装 Docker Desktop"
- exit /b 1
-)
-
-docker-compose --version >nul 2>&1
-if errorlevel 1 (
- call :print_error "Docker Compose 未安装，请先安装 Docker Compose"
- exit /b 1
-)
-
-call :print_success "系统依赖检查通过"
-goto :eof
-
-:: 初始化配置
-:init_config
-call :print_info "初始化配置文件..."
-
-if not exist "%ENV_FILE%" (
- if exist ".env.example" (
- copy ".env.example" "%ENV_FILE%" >nul
- call :print_success "已创建 %ENV_FILE% 配置文件"
- ) else (
- call :print_error ".env.example 文件不存在"
- exit /b 1
- )
-) else (
- call :print_warning "%ENV_FILE% 已存在，跳过创建"
-)
-
-:: 创建必要的目录
-if not exist "data" mkdir data
-if not exist "logs" mkdir logs
-if not exist "backups" mkdir backups
-call :print_success "已创建必要的目录"
-goto :eof
-
-:: 构建镜像
-:build_image
-call :print_info "构建 Docker 镜像..."
-docker-compose build --no-cache
-if errorlevel 1 (
- call :print_error "镜像构建失败"
- exit /b 1
-)
-call :print_success "镜像构建完成"
-goto :eof
-
-:: 启动服务
-:start_services
-set "profile="
-if "%~1"=="with-nginx" (
- set "profile=--profile with-nginx"
- call :print_info "启动服务（包含 Nginx）..."
-) else (
- call :print_info "启动基础服务..."
-)
-
-docker-compose %profile% up -d
-if errorlevel 1 (
- call :print_error "服务启动失败"
- exit /b 1
-)
-call :print_success "服务启动完成"
-
-:: 等待服务就绪
-call :print_info "等待服务就绪..."
-timeout /t 10 /nobreak >nul
-
-:: 检查服务状态
-docker-compose ps | findstr "Up" >nul
-if errorlevel 1 (
- call :print_error "服务启动失败"
- docker-compose logs
- exit /b 1
-) else (
- call :print_success "服务运行正常"
- call :show_access_info "%~1"
-)
-goto :eof
-
-:: 停止服务
-:stop_services
-call :print_info "停止服务..."
-docker-compose down
-call :print_success "服务已停止"
-goto :eof
-
-:: 重启服务
-:restart_services
-call :print_info "重启服务..."
-docker-compose restart
-call :print_success "服务已重启"
-goto :eof
-
-:: 查看日志
-:show_logs
-if "%~1"=="" (
- docker-compose logs -f
-) else (
- docker-compose logs -f "%~1"
-)
-goto :eof
-
-:: 查看状态
-:show_status
-call :print_info "服务状态:"
-docker-compose ps
-
-call :print_info "资源使用:"
-for /f "tokens=*" %%i in ('docker-compose ps -q') do (
- docker stats --no-stream %%i
-)
-goto :eof
-
-:: 显示访问信息
-:show_access_info
-echo.
-call :print_success "🎉 部署完成！"
-echo.
-
-if "%~1"=="with-nginx" (
- echo 📱 访问地址:
- echo HTTP: http://localhost
- echo HTTPS: https://localhost ^(如果配置了SSL^)
-) else (
- echo 📱 访问地址:
- echo HTTP: http://localhost:8080
-)
-
-echo.
-echo 🔐 默认登录信息:
-echo 用户名: admin
-echo 密码: admin123
-echo.
-echo 📊 管理命令:
-echo 查看状态: %~nx0 status
-echo 查看日志: %~nx0 logs
-echo 重启服务: %~nx0 restart
-echo 停止服务: %~nx0 stop
-echo.
-goto :eof
-
-:: 健康检查
-:health_check
-call :print_info "执行健康检查..."
-
-set "url=http://localhost:8080/health"
-set "max_attempts=30"
-set "attempt=1"
-
-:health_loop
-curl -f -s "%url%" >nul 2>&1
-if not errorlevel 1 (
- call :print_success "健康检查通过"
- goto :eof
-)
-
-call :print_info "等待服务就绪... (!attempt!/%max_attempts%)"
-timeout /t 2 /nobreak >nul
-set /a attempt+=1
-
-if !attempt! leq %max_attempts% goto health_loop
-
-call :print_error "健康检查失败"
-exit /b 1
-
-:: 备份数据
-:backup_data
-call :print_info "备份数据..."
-
-for /f "tokens=2 delims==" %%i in ('wmic OS Get localdatetime /value') do set datetime=%%i
-set backup_dir=backups\%datetime:~0,8%_%datetime:~8,6%
-mkdir "%backup_dir%" 2>nul
-
-:: 备份数据库
-if exist "data\xianyu_data.db" (
- copy "data\xianyu_data.db" "%backup_dir%\" >nul
- call :print_success "数据库备份完成"
-)
-
-:: 备份配置
-copy "%ENV_FILE%" "%backup_dir%\" >nul
-copy "global_config.yml" "%backup_dir%\" >nul 2>&1
-
-call :print_success "数据备份完成: %backup_dir%"
-goto :eof
-
-:: 显示帮助信息
-:show_help
-echo 闲鱼自动回复系统 Docker 部署脚本 ^(Windows版本^)
-echo.
-echo 用法: %~nx0 [命令] [选项]
-echo.
-echo 命令:
-echo init 初始化配置文件
-echo build 构建 Docker 镜像
-echo start [with-nginx] 启动服务^(可选包含 Nginx^)
-echo stop 停止服务
-echo restart 重启服务
-echo status 查看服务状态
-echo logs [service] 查看日志
-echo health 健康检查
-echo backup 备份数据
-echo help 显示帮助信息
-echo.
-echo 示例:
-echo %~nx0 init # 初始化配置
-echo %~nx0 start # 启动基础服务
-echo %~nx0 start with-nginx # 启动包含 Nginx 的服务
-echo %~nx0 logs xianyu-app # 查看应用日志
-echo.
-goto :eof
-
-:: 主函数
-:main
-if "%~1"=="init" (
- call :check_dependencies
- call :init_config
-) else if "%~1"=="build" (
- call :check_dependencies
- call :build_image
-) else if "%~1"=="start" (
- call :check_dependencies
- call :init_config
- call :build_image
- call :start_services "%~2"
-) else if "%~1"=="stop" (
- call :stop_services
-) else if "%~1"=="restart" (
- call :restart_services
-) else if "%~1"=="status" (
- call :show_status
-) else if "%~1"=="logs" (
- call :show_logs "%~2"
-) else if "%~1"=="health" (
- call :health_check
-) else if "%~1"=="backup" (
- call :backup_data
-) else if "%~1"=="help" (
- call :show_help
-) else if "%~1"=="-h" (
- call :show_help
-) else if "%~1"=="--help" (
- call :show_help
-) else if "%~1"=="" (
- call :print_info "快速部署模式"
- call :check_dependencies
- call :init_config
- call :build_image
- call :start_services
-) else (
- call :print_error "未知命令: %~1"
- call :show_help
- exit /b 1
-)
-
-goto :eof
-
-:: 执行主函数
-call :main %*
diff --git a/docker_deployment_update.md b/docker_deployment_update.md
deleted file mode 100644
index b68877b..0000000
--- a/docker_deployment_update.md
+++ /dev/null
@@ -1,207 +0,0 @@
-# Docker部署更新检查报告
-
-## 📋 检查概述
-
-对Docker部署配置进行了全面检查，评估是否需要更新以支持新增的AI回复功能和其他改进。
-
-## ✅ 当前状态评估
-
-### 🎯 **结论：Docker部署配置已经完善，无需重大更新**
-
-所有新增功能都已经在现有的Docker配置中得到支持。
-
-## 📊 详细检查结果
-
-### 1. **依赖包检查** ✅
-#### requirements.txt 状态：**完整**
-```
-✅ openai>=1.65.5 # AI回复功能
-✅ python-dotenv>=1.0.1 # 环境变量支持
-✅ python-multipart>=0.0.6 # 文件上传支持
-✅ fastapi>=0.111 # Web框架
-✅ uvicorn[standard]>=0.29 # ASGI服务器
-✅ 其他所有必要依赖
-```
-
-### 2. **环境变量配置** ✅
-#### .env.example 状态：**完整**
-```
-✅ AI_REPLY_ENABLED=false
-✅ DEFAULT_AI_MODEL=qwen-plus
-✅ DEFAULT_AI_BASE_URL=https://dashscope.aliyuncs.com/compatible-mode/v1
-✅ AI_REQUEST_TIMEOUT=30
-✅ AI_MAX_TOKENS=100
-✅ 所有基础配置变量
-```
-
-### 3. **Docker Compose配置** ✅
-#### docker-compose.yml 状态：**完整**
-```
-✅ AI回复相关环境变量映射
-✅ 数据持久化配置 (/app/data, /app/logs, /app/backups)
-✅ 健康检查配置
-✅ 资源限制配置
-✅ 网络配置
-✅ Nginx反向代理支持
-```
-
-### 4. **Dockerfile配置** ✅
-#### Dockerfile 状态：**完整**
-```
-✅ Python 3.11基础镜像
-✅ 所有系统依赖安装
-✅ 应用依赖安装
-✅ 工作目录配置
-✅ 端口暴露配置
-✅ 启动命令配置
-```
-
-### 5. **数据持久化** ✅
-#### 挂载点配置：**完整**
-```
-✅ ./data:/app/data:rw # 数据库文件
-✅ ./logs:/app/logs:rw # 日志文件
-✅ ./backups:/app/backups:rw # 备份文件
-✅ ./global_config.yml:/app/global_config.yml:ro # 配置文件
-```
-
-### 6. **健康检查** ✅
-#### 健康检查配置：**完整**
-```
-✅ HTTP健康检查端点 (/health)
-✅ 检查间隔：30秒
-✅ 超时时间：10秒
-✅ 重试次数：3次
-✅ 启动等待：40秒
-```
-
-## 🔍 新功能支持验证
-
-### AI回复功能 ✅
-- **依赖支持**：openai库已包含
-- **配置支持**：所有AI相关环境变量已配置
-- **数据支持**：AI数据表会自动创建
-- **API支持**：FastAPI框架支持所有新接口
-
-### 备份功能增强 ✅
-- **存储支持**：备份目录已挂载
-- **数据支持**：所有新表都包含在备份中
-- **权限支持**：容器有读写权限
-
-### 商品管理功能 ✅
-- **文件上传**：python-multipart依赖已包含
-- **数据存储**：数据库挂载支持新表
-- **API支持**：FastAPI支持文件上传接口
-
-## 💡 可选优化建议
-
-虽然当前配置已经完善，但可以考虑以下优化：
-
-### 1. **添加AI服务健康检查**
-```yaml
-# 可选：添加AI服务连通性检查
-healthcheck:
- test: ["CMD", "python", "-c", "import requests; requests.get('http://localhost:8080/api/ai/health', timeout=5)"]
-```
-
-### 2. **添加更多监控指标**
-```yaml
-# 可选：添加Prometheus监控
-environment:
- - ENABLE_METRICS=true
- - METRICS_PORT=9090
-```
-
-### 3. **添加AI配置验证**
-```yaml
-# 可选：启动时验证AI配置
-environment:
- - VALIDATE_AI_CONFIG=true
-```
-
-## 🚀 部署建议
-
-### 生产环境部署
-1. **使用强密码**
- ```bash
- ADMIN_PASSWORD=$(openssl rand -base64 32)
- JWT_SECRET_KEY=$(openssl rand -base64 32)
- ```
-
-2. **配置AI服务**
- ```bash
- AI_REPLY_ENABLED=true
- # 配置真实的API密钥
- ```
-
-3. **启用HTTPS**
- ```bash
- docker-compose --profile with-nginx up -d
- ```
-
-4. **配置资源限制**
- ```bash
- MEMORY_LIMIT=1024 # 如果使用AI功能，建议增加内存
- CPU_LIMIT=1.0
- ```
-
-### 开发环境部署
-```bash
-# 克隆项目
-git clone
-
+ # 使用简单的纯文本邮件内容
+ text_content = f"""【闲鱼自动回复系统】邮箱验证码
- 🤖 闲鱼自动回复系统
- 邮箱验证码
-
- 您好！
- 您正在注册闲鱼自动回复系统账号，请使用以下验证码完成邮箱验证： -
+您好！
- - 您正在注册闲鱼自动回复系统账号，请使用以下验证码完成邮箱验证： -
-
+感谢您使用闲鱼自动回复系统。为了确保账户安全，请使用以下验证码完成邮箱验证：
- {code}
-
- ⚠️ 重要提醒：
- • 验证码有效期为 10 分钟
- • 请勿将验证码告诉他人
- • 如果您没有进行此操作，请忽略此邮件 -
+验证码：{code}
- - • 验证码有效期为 10 分钟
- • 请勿将验证码告诉他人
- • 如果您没有进行此操作，请忽略此邮件 -
- 如有任何问题，请联系系统管理员。
- 感谢您使用闲鱼自动回复系统！ -
+重要提醒：
+• 验证码有效期为 10 分钟，请及时使用
+• 请勿将验证码分享给任何人
+• 如非本人操作，请忽略此邮件
+• 系统不会主动索要您的验证码
-
- - 感谢您使用闲鱼自动回复系统！ -