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) => {