Method restorePins

restore_pin/restore_pin.ts:108–161

* 批量恢复置顶

(msg: Api.Message, chatId: any, messageIds: number[])

      await msg.edit({ text: "✅ 没有需要恢复的置顶消息", parseMode: "html" });
      return;
    }

    await msg.edit({ 
      text: `🔄 正在恢复 ${messageIds.length} 条置顶消息...`, 
      parseMode: "html" 
    });

    let successCount = 0;
    let errorCount = 0;
    const errors: string[] = [];

    for (let i = 0; i < messageIds.length; i++) {
      const messageId = messageIds[i];
      
      // 每3条更新一次进度
      if ((i + 1) % 3 === 0) {
        await msg.edit({ 
          text: `🔄 正在恢复第 ${i + 1}/${messageIds.length} 条置顶消息...\n✅ 成功: ${successCount} ❌ 失败: ${errorCount}`, 
          parseMode: "html" 
        });
      }

      const success = await this.pinMessage(chatId, messageId);
      if (success) {
        successCount++;
      } else {
        errorCount++;
        errors.push(`消息 ${messageId} 恢复失败`);
      }

      // 延迟避免触发限制（减少到1秒）
      await new Promise(resolve => setTimeout(resolve, 1000));
    }

    let resultText = `📊 <b>恢复完成</b>\n\n`;
    resultText += `✅ 成功恢复: ${successCount} 条\n`;
    resultText += `❌ 恢复失败: ${errorCount} 条`;

    if (errors.length > 0) {
      resultText += `\n\n<b>失败详情：</b>\n`;
      errors.slice(0, 3).forEach(error => {
        resultText += `• ${htmlEscape(error)}\n`;
      });
      if (errors.length > 3) {
        resultText += `• ... 还有 ${errors.length - 3} 个错误`;
      }
    }

    await msg.edit({ text: resultText, parseMode: "html" });
  }

  /**
   * 主命令处理器
   */
  private async handleRestorePin(msg: Api.Message): Promise<void> {
    const client = await getGlobalClient();
    if (!client) {