Method unblockMember

clean/clean.ts:408–474

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

            if (error.message?.includes('FLOOD_WAIT_')) {
              await this.handleFloodWait(msg, error);
              continue;
            } else {
              failed++;
              consecutiveErrors++;
              await sleep(this.getDynamicDelay(user, includeAll, consecutiveErrors));
            }
          }

          // 更新进度
          if (processedUsers % 10 === 0) {
            await this.updateBlockedProgress(msg, processedUsers, totalUsers, success, failed, skipped, includeAll);
          }
        }

        offset += 100;
        if (blocked.className === 'contacts.BlockedSlice' && offset >= (blocked as any).count) break;
        
        // 批次间延迟
        const batchDelay = consecutiveErrors > 0 ? 3000 + (consecutiveErrors * 1000) : 2000;
        await sleep(Math.min(batchDelay, 10000));

      } catch (error: any) {
        console.error("获取拉黑列表失败:", error);
        if (error.message?.includes('FLOOD_WAIT')) {
          await this.handleFloodWait(msg, error);
          continue;
        }
        break;
      }
    }

    const result = this.buildBlockedResult(success, failed, skipped, totalUsers, includeAll);
    await this.editMessage(msg, result);
  }

  // 群组解封
  private async unblockMember(client: any, msg: Api.Message, includeAll: boolean = false): Promise<void> {
    if (!msg.isChannel && !msg.isGroup) {
      await this.sendError(msg, "此命令只能在群组中使用");
      return;
    }

    await this.editMessage(msg, "🔓 正在获取被封禁实体列表...");

    const me = await safeGetMe(client);
    if (!me) {
      await this.sendError(msg, "无法获取当前账号信息");
      return;
    }
    const myId = Number(me.id);
    const chatEntity = msg.peerId;
    
    let bannedUsers = await getBannedUsers(client, chatEntity);
    if (!includeAll) {
      bannedUsers = bannedUsers.filter((u: any) => u.kickedBy === myId);
    }
    
    if (bannedUsers.length === 0) {