From ebae393e908fc5dedeb0351238657a93465bd14a Mon Sep 17 00:00:00 2001 From: iven Date: Fri, 1 May 2026 17:44:00 +0800 Subject: [PATCH] =?UTF-8?q?chore(server):=20domain=5Fevents=20=E6=B8=85?= =?UTF-8?q?=E7=90=86=E5=91=A8=E6=9C=9F=E4=BB=8E=2090=20=E5=A4=A9=E7=BC=A9?= =?UTF-8?q?=E7=9F=AD=E4=B8=BA=207=20=E5=A4=A9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- crates/erp-server/src/tasks.rs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/crates/erp-server/src/tasks.rs b/crates/erp-server/src/tasks.rs index d9cf993..0dd5b1a 100644 --- a/crates/erp-server/src/tasks.rs +++ b/crates/erp-server/src/tasks.rs @@ -3,7 +3,7 @@ use std::time::Duration; /// 启动事件清理后台任务。 /// /// 每日执行一次: -/// - 调用 `cleanup_old_published_events()` 归档 >90 天的已发布事件 +/// - 调用 `cleanup_old_published_events()` 归档 >7 天的已发布事件 /// - 调用 `cleanup_old_processed_events()` 清理 >7 天的去重记录 pub fn start_event_cleanup(db: sea_orm::DatabaseConnection) { tokio::spawn(async move { @@ -21,9 +21,9 @@ pub fn start_event_cleanup(db: sea_orm::DatabaseConnection) { async fn run_cleanup(db: &sea_orm::DatabaseConnection) -> Result<(), sea_orm::DbErr> { use sea_orm::ConnectionTrait; - // 归档 >90 天的已发布事件 + // 归档 >7 天的已发布事件 match db - .execute_unprepared("SELECT cleanup_old_published_events(90, 1000)") + .execute_unprepared("SELECT cleanup_old_published_events(7, 1000)") .await { Ok(result) => {