feat: 邮件发送历史记录 v1.9.2

xian_favor/db.py

@@ -90,6 +90,18 @@ class Database:
                 )
             """)
             
+            # 邮件发送记录表
+            cursor.execute("""
+                CREATE TABLE IF NOT EXISTS email_logs (
+                    id INTEGER PRIMARY KEY AUTOINCREMENT,
+                    item_id INTEGER NOT NULL,
+                    email TEXT NOT NULL,
+                    sent_at TEXT NOT NULL,
+                    success INTEGER DEFAULT 1,
+                    FOREIGN KEY (item_id) REFERENCES items(id) ON DELETE CASCADE
+                )
+            """)
+            
             # 创建索引
             cursor.execute("CREATE INDEX IF NOT EXISTS idx_items_type ON items(type)")
             cursor.execute("CREATE INDEX IF NOT EXISTS idx_items_status ON items(status)")
@@ -371,6 +383,31 @@ class Database:
             conn.commit()
             return cursor.rowcount > 0
     
+    # ============ 邮件日志 操作 ============
+    
+    def log_email_send(self, item_id: int, email: str, success: bool = True) -> int:
+        """记录邮件发送"""
+        now = datetime.now().isoformat()
+        with self.get_conn() as conn:
+            cursor = conn.cursor()
+            cursor.execute("""
+                INSERT INTO email_logs (item_id, email, sent_at, success)
+                VALUES (?, ?, ?, ?)
+            """, (item_id, email, now, 1 if success else 0))
+            conn.commit()
+            return cursor.lastrowid
+    
+    def get_email_logs(self, item_id: int) -> List[Dict[str, Any]]:
+        """获取收藏的邮件发送记录"""
+        with self.get_conn() as conn:
+            cursor = conn.cursor()
+            cursor.execute("""
+                SELECT * FROM email_logs 
+                WHERE item_id = ? 
+                ORDER BY sent_at DESC
+            """, (item_id,))
+            return [dict(row) for row in cursor.fetchall()]
+    
     def stats(self) -> Dict[str, Any]:
         """获取统计信息"""
         self._ensure_init()