From 2d8623685f7cf452845dc9eff01ab68c5669d3a9 Mon Sep 17 00:00:00 2001 From: "qinyong@9artedu.com" Date: Thu, 18 Jun 2026 16:43:29 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E6=AF=8F=E5=A4=A9=E6=99=9A?= =?UTF-8?q?=E4=B8=8A2=E7=82=B9=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/summary/task.py | 25 +++++++------------------ 1 file changed, 7 insertions(+), 18 deletions(-) diff --git a/app/summary/task.py b/app/summary/task.py index 7a5349a..3197cc7 100644 --- a/app/summary/task.py +++ b/app/summary/task.py @@ -9,36 +9,25 @@ from app.client.milvus_client_manager import milvus_client from app.client.mysql_client_manager import db_assistant_mysql_client_manager from app.repository.archive_messages_repository import ArchiveMessagesRepository from app.repository.milvus.summary_repository import SummaryRepository -from app.summary.service import SummaryService +from app.summary.service import SummaryService, build from app.core.log import logger app = FastAPI(title="消息摘要服务", version="1.0") scheduler = AsyncIOScheduler(timezone='Asia/Shanghai') async def generate_daily_summary(date: Optional[str] = None): + logger.info("16:30分定时任务测试") if not date: yesterday = datetime.now() - timedelta(days=1) - date = yesterday.strftime("%Y-%-m-%-d") # 格式: 2026-6-15 + #date = yesterday.strftime("%Y-%-m-%-d") # 格式: 2026-6-15 + date = datetime(yesterday.year, yesterday.month, yesterday.day) - logger.info(f"开始生成 {date} 的消息摘要...") + # 按 年-月-日 无补零格式输出 + date_format = f"{date.year}-{date.month}-{date.day}" - try: - db_assistant_mysql_client_manager.init() - embedding_client.init() - milvus_client.init() - - async with db_assistant_mysql_client_manager.session_factory() as db_assistant: - archive_messages_repository = ArchiveMessagesRepository(db_assistant) - summary_repository = SummaryRepository() - service = SummaryService(archive_messages_repository, embedding_client, summary_repository) - await service.get_message_summary(date) + await build(date_format) logger.info(f"{date} 消息摘要生成完成") - except Exception as e: - logger.error(f"生成摘要失败: {str(e)}", exc_info=True) - raise - finally: - await embedding_client.close() @app.on_event("startup") async def startup_event():