清理代码

Author: linyuan.yang

packages/sbot/src/Core/Database.ts

@@ -814,39 +814,6 @@ class Database {
     }
   }
 
-  /**
-   * scheduler 表旧版本字段是 targetId(TEXT)，存 channel_session.id 的字符串形式。
-   * 新版本拆为 channelSessionId(INT) + profileId(INT)。
-   * 在 sync({alter:true}) 重建表丢列之前，把数据搬过去。
-   * 已迁移的库（没 targetId 列）跳过。
-   */
-  private async migrateSchedulerColumns() {
-    const [cols] = await this.sequelize.query("PRAGMA table_info(scheduler)") as [any[], any];
-    const names = new Set(cols.map((c: any) => c.name));
-    if (!names.has("targetId")) return;
-
-    if (!names.has("channelSessionId")) {
-      await this.sequelize.query("ALTER TABLE scheduler ADD COLUMN channelSessionId INTEGER NOT NULL DEFAULT 0");
-    }
-    if (!names.has("profileId")) {
-      await this.sequelize.query("ALTER TABLE scheduler ADD COLUMN profileId INTEGER NOT NULL DEFAULT 0");
-    }
-    await this.sequelize.query(`
-      UPDATE scheduler
-      SET channelSessionId = CAST(targetId AS INTEGER)
-      WHERE channelSessionId = 0 AND targetId != ''
-    `);
-    await this.sequelize.query(`
-      UPDATE scheduler
-      SET profileId = COALESCE(
-        (SELECT cs.profileId FROM channel_session cs WHERE cs.id = scheduler.channelSessionId),
-        0
-      )
-      WHERE profileId = 0 AND channelSessionId > 0
-    `);
-    logger.info("Scheduler table migrated: targetId -> channelSessionId + profileId");
-  }
-
   async sync() {
     return this.withLock(async () => {
       await this.state.sync({ alter: true });
@@ -863,9 +830,6 @@ class Database {
       await this.channelUser.sync({ alter });
       await this.sessionProfile.sync({ alter });
       await this.channelSession.sync({ alter });
-      // scheduler 旧 schema 把 channel_session.id 存在 targetId(TEXT) 里。
-      // 新 schema 拆成 channelSessionId(INT) + profileId(INT)。在 sync 重建表前先迁移数据。
-      await this.migrateSchedulerColumns();
       await this.scheduler.sync({ alter });
       await this.usageLogs.sync({ alter });
       await this.heartbeat.sync({ alter });