Method cleanDeletedMember

clean/clean.ts:259–324

(client: any, msg: Api.Message, cleanMembers: boolean = false)

  // 群组已注销账号清理
  private async cleanDeletedMember(client: any, msg: Api.Message, cleanMembers: boolean = false): Promise<void> {
    const chat = await msg.getChat();
    if (!chat || !(chat instanceof Api.Chat || chat instanceof Api.Channel)) {
      await this.sendError(msg, "此命令仅在群组中可用");
      return;
    }

    await this.editMessage(msg, cleanMembers 
      ? "🔍 正在扫描并清理群组已注销账号..." 
      : "🔍 正在扫描群组已注销账号...");

    const chatId = chat.id;
    if (cleanMembers && !await this.checkBanPermission(client, chatId)) {
      await this.sendError(msg, "没有封禁用户权限，无法执行清理");
      return;
    }

    let deletedCount = 0;
    const deletedUsers: Array<{id: string, username?: string}> = [];

    const participants = client.iterParticipants(chatId);
    for await (const participant of participants) {
      if (participant instanceof Api.User && participant.deleted) {
        deletedCount++;
        deletedUsers.push({ 
          id: participant.id.toString(), 
          username: participant.username || "未知" 
        });
        
        if (cleanMembers) {
          try {
            await banUser(client, chatId, participant.id);
            await sleep(100);
          } catch (error: any) {
            if (error.message?.includes("FLOOD_WAIT")) {
              await this.handleFloodWait(msg, error);
              return;
            }
          }
        }
      }
    }

    let result = "";
    if (deletedCount === 0) {
      result = "✅ <b>扫描完成</b>\n\n此群组中没有发现已注销账号。";
    } else {
      result = cleanMembers 
        ? `✅ <b>清理完成</b>\n\n已清理 <code>${deletedCount}</code> 个已注销账号:\n\n`
        : `✅ <b>扫描完成</b>\n\n此群组的已注销账号数: <code>${deletedCount}</code>:\n\n`;
      
      deletedUsers.slice(0, 15).forEach(user => {
        result += `• <a href="tg://user?id=${user.id}">${user.id}</a>\n`;
      });
      
      if (deletedCount > 15) {
        result += `\n... 还有 ${deletedCount - 15} 个未显示\n`;
      }