10

src/api/Webhook.py

@@ -9,14 +9,13 @@ from datetime import datetime
 import json
 import hmac
 import hashlib
-import logging
+from loguru import logger
 from fastapi.responses import PlainTextResponse
 import os
 from src.utils.websocket_logger_fixed import manager, test_websocket_logging
 
 # 设置日志配置
-logging.basicConfig(level=logging.INFO)
-logger = logging.getLogger(__name__)
+logger.add("logs/app.log", rotation="500 MB", retention="10 days")
 
 def detect_webhook_source(data: dict, headers: dict) -> str:
     """检测webhook来源平台"""
@@ -98,7 +97,7 @@ def get_webhook_event_info(data: dict, source: str) -> dict:
                 event_info["user"] = pr.get("user", {}).get("name", "unknown")
                 
     except Exception as e:
-        logger.error(f"解析webhook事件信息失败: {e}")
+        logger.error(f"❌ 解析webhook事件信息失败: {e}")
     
     return event_info
 
@@ -1000,7 +999,7 @@ async def logs_viewer():
 @WEBHOOK.get("/health")
 async def health_check():
     """健康检查接口"""
-    logger.info("💚 Webhook健康检查")
+    logger.info("💚 Webhook健康检查请求")
     return {"status": "healthy", "message": "Webhook service is running"} 
 
 @WEBHOOK.post("/admin/logs/test")