diff --git a/services/game-service/deploy/mysql/initdb/001_game_service.sql b/services/game-service/deploy/mysql/initdb/001_game_service.sql
index 7762788f..5368cad0 100644
--- a/services/game-service/deploy/mysql/initdb/001_game_service.sql
+++ b/services/game-service/deploy/mysql/initdb/001_game_service.sql
@@ -168,6 +168,7 @@ CREATE TABLE IF NOT EXISTS game_level_event_outbox (
   UNIQUE KEY uk_game_level_event_order(app_code, order_id),
   KEY idx_game_level_event_pending(app_code, status, next_retry_at_ms, created_at_ms),
   KEY idx_game_level_event_claim(app_code, status, locked_until_ms, next_retry_at_ms, created_at_ms, event_id),
+  KEY idx_game_level_event_retention(app_code, status, updated_at_ms, event_id),
   KEY idx_game_level_event_user(app_code, user_id, created_at_ms)
 ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci COMMENT='游戏等级事件 outbox 表';
 
diff --git a/services/game-service/internal/storage/mysql/repository.go b/services/game-service/internal/storage/mysql/repository.go
index 57b3a998..05ccd9a3 100644
--- a/services/game-service/internal/storage/mysql/repository.go
+++ b/services/game-service/internal/storage/mysql/repository.go
@@ -215,6 +215,7 @@ func (r *Repository) Migrate(ctx context.Context) error {
 		  UNIQUE KEY uk_game_level_event_order(app_code, order_id),
 		  KEY idx_game_level_event_pending(app_code, status, next_retry_at_ms, created_at_ms),
 		  KEY idx_game_level_event_claim(app_code, status, locked_until_ms, next_retry_at_ms, created_at_ms, event_id),
+		  KEY idx_game_level_event_retention(app_code, status, updated_at_ms, event_id),
 		  KEY idx_game_level_event_user(app_code, user_id, created_at_ms)
 		) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci`,
 		`CREATE TABLE IF NOT EXISTS game_outbox (
@@ -281,6 +282,9 @@ func (r *Repository) Migrate(ctx context.Context) error {
 	if err := r.ensureIndexDefinition(ctx, "game_outbox", "idx_game_outbox_retention", []string{"app_code", "status", "updated_at_ms", "event_id"}, "ALTER TABLE game_outbox ADD INDEX idx_game_outbox_retention(app_code, status, updated_at_ms, event_id)"); err != nil {
 		return err
 	}
+	if err := r.ensureIndexDefinition(ctx, "game_level_event_outbox", "idx_game_level_event_retention", []string{"app_code", "status", "updated_at_ms", "event_id"}, "ALTER TABLE game_level_event_outbox ADD INDEX idx_game_level_event_retention(app_code, status, updated_at_ms, event_id)"); err != nil {
+		return err
+	}
 	return r.seedDefaults(ctx)
 }