v2.3.12A

Author: KanoCifer

backend/app/main.py

@@ -39,6 +39,7 @@
     users,
     weread,
 )
+from app.tasks.aps_tasks import send_daily_summary
 from app.tasks.broker import broker
 from app.tasks.task import send_feishu_message
 from app.utils import close_cache_redis, get_redis_lock
@@ -81,6 +82,7 @@ async def lifespan(app: FastAPI):
             app.state.redis, "bootstrap_notification", ttl=600
         ):
             try:
+                await send_daily_summary.kiq()
                 await send_feishu_message.kiq()
                 # await send_bootstrap_emails.kiq(admin_email=admin_email)
                 app_logger.info("✅启动通知任务已添加到队列")

backend/app/models/mgmodel.py

@@ -128,3 +128,7 @@ class Settings:
         ]
         bson_encoders: ClassVar[dict] = {PydanticObjectId: str}
         model_config = ConfigDict(arbitrary_types_allowed=True)
+
+
+class RssArticleGuidProjection(BaseModel):
+    guid: str

backend/app/routers/rss.py

@@ -200,7 +200,21 @@ async def parse_rss(
         logger.info(f"Redis缓存命中: {rss_url}")
         return APIResponse.ok(data=json.loads(cached_data))
     try:
-        feed: feedparser.FeedParserDict = feedparser.parse(rss_url)
+        # 异步获取feed内容，带超时控制
+        async with httpx.AsyncClient(
+            timeout=httpx.Timeout(10.0, connect=5.0), follow_redirects=True
+        ) as client:
+            resp = await client.get(rss_url)
+            resp.raise_for_status()
+            content = resp.content
+
+        # 在线程池中解析内容
+        import asyncio
+
+        loop = asyncio.get_running_loop()
+        feed: feedparser.FeedParserDict = await loop.run_in_executor(
+            None, feedparser.parse, content
+        )
         if feed.bozo != 0:
             return APIResponse.error(message="无法解析RSS链接", code=400)
         feed_meta = _build_feed_meta(feed)
@@ -437,7 +451,21 @@ async def refresh_subscription(
     await redis.delete(redis_key)
 
     try:
-        feed: feedparser.FeedParserDict = feedparser.parse(rss_url)
+        # 异步获取feed内容，带超时控制
+        async with httpx.AsyncClient(
+            timeout=httpx.Timeout(10.0, connect=5.0), follow_redirects=True
+        ) as client:
+            resp = await client.get(rss_url)
+            resp.raise_for_status()
+            content = resp.content
+
+        # 在线程池中解析内容
+        import asyncio
+
+        loop = asyncio.get_running_loop()
+        feed: feedparser.FeedParserDict = await loop.run_in_executor(
+            None, feedparser.parse, content
+        )
         if feed.bozo != 0:
             return APIResponse.error(message="无法解析RSS链接", code=400)
         feed_meta = _build_feed_meta(feed)

backend/app/schemas/schemas.py

@@ -451,6 +451,8 @@ class RssMarkReadRequest(BaseModel):
 
 
 class TodoIn(BaseModel):
+    """Todo creation schema."""
+
     text: str
     description: str | None = None
     dueDate: str | None = None  # ISO date string  # noqa: N815
@@ -463,6 +465,8 @@ class TodoIn(BaseModel):
 
 
 class TodoUpdate(BaseModel):
+    """Todo update schema."""
+
     text: str | None = None
     description: str | None = None
     dueDate: str | None = None  # noqa: N815
@@ -474,6 +478,8 @@ class TodoUpdate(BaseModel):
 
 
 class TodoOut(BaseModel):
+    """Todo output schema."""
+
     id: str
     text: str
     completed: bool
@@ -484,3 +490,18 @@ class TodoOut(BaseModel):
     category: str | None = None
     archived: bool = False
     archivedAt: str | None = None  # noqa: N815
+
+
+# --** Feishu Message Schemas *---
+class FeishuMessageContent(BaseModel):
+    """飞书消息内容模型"""
+
+    msg_type: str = "text"
+    content: dict | None = None
+
+
+class FeishuRichTextContent(BaseModel):
+    """飞书富文本内容模型"""
+
+    msg_type: str = "post"
+    content: dict | None = None