From 69945b730fd3f6b6138ce50e49fc3392fcd74d71 Mon Sep 17 00:00:00 2001
From: yj <2077506045@qq.com>
Date: 星期一, 28 七月 2025 18:16:52 +0800
Subject: [PATCH] 新增关键词过滤；新增活跃客服统计；新增掉线通知
---
main.py | 30 +++++++++++++++++++++++++++++-
1 files changed, 29 insertions(+), 1 deletions(-)
diff --git a/main.py b/main.py
index dd776b7..cba621f 100644
--- a/main.py
+++ b/main.py
@@ -7,10 +7,13 @@
from fastapi.middleware.cors import CORSMiddleware
from contextlib import asynccontextmanager
from loguru import logger
+import time
from config import settings
from app.api.callback import router as callback_router
+from app.api.friend_ignore import router as friend_ignore_router
from app.models.database import create_tables
from app.workers.message_worker import message_worker
+from app.services.contact_sync import contact_sync_service
@asynccontextmanager
@@ -32,6 +35,20 @@
logger.info("娑堟伅宸ヤ綔杩涚▼鍚姩鎴愬姛")
except Exception as e:
logger.error(f"娑堟伅宸ヤ綔杩涚▼鍚姩澶辫触: {str(e)}")
+
+ # 鍚屾鑱旂郴浜轰俊鎭苟寤虹珛濂藉弸蹇界暐鍒楄〃
+ try:
+ if settings.ecloud_w_id:
+ logger.info("寮�濮嬪悓姝ヨ仈绯讳汉淇℃伅...")
+ success = contact_sync_service.sync_contacts_on_startup(settings.ecloud_w_id)
+ if success:
+ logger.info("鑱旂郴浜哄悓姝ュ畬鎴愶紝濂藉弸蹇界暐鍒楄〃宸插缓绔�")
+ else:
+ logger.warning("鑱旂郴浜哄悓姝ュけ璐�")
+ else:
+ logger.warning("鏈厤缃甧cloud_w_id锛岃烦杩囪仈绯讳汉鍚屾")
+ except Exception as e:
+ logger.error(f"鑱旂郴浜哄悓姝ュ紓甯�: {str(e)}")
logger.info("搴旂敤鍚姩瀹屾垚")
@@ -69,6 +86,7 @@
# 娉ㄥ唽璺敱
app.include_router(callback_router, prefix="/api/v1", tags=["鍥炶皟鎺ュ彛"])
+app.include_router(friend_ignore_router, prefix="/api/v1", tags=["濂藉弸蹇界暐绠＄悊"])
@app.get("/")
@@ -81,12 +99,22 @@
}
+@app.get("/health")
+async def health_check():
+ """鍋ュ悍妫�鏌ユ帴鍙�"""
+ return {
+ "status": "healthy",
+ "message": "E浜戠瀹�-DifyAI瀵规帴鏈嶅姟杩愯姝ｅ父",
+ "timestamp": int(time.time()),
+ }
+
+
if __name__ == "__main__":
# 閰嶇疆鏃ュ織
logger.add(
settings.log_file,
rotation="1 day",
- retention="30 days",
+ retention="7 days",
level=settings.log_level,
format="{time:YYYY-MM-DD HH:mm:ss} | {level} | {name}:{function}:{line} - {message}",
)
--
Gitblit v1.9.1