Class DbdjPlugin

dbdj/dbdj.ts:88–224

  > = {
    dbdj: async (msg: Api.Message, trigger?: Api.Message) => {
      const startAt = Date.now();
      const replyAndDeleteMsg = async (message: string) => {
        const replyTarget = trigger || msg;
        await replyTarget.reply({
          message,
          parseMode: "html",
          linkPreview: false,
        });
        try {
          await msg.delete();
        } catch {}
      };

      try {
        const parts = msg.message.trim().split(/\s+/);
        // 期望格式: .dbdj 消息数 人数 文案...
        const countStr = parts[1];
        const pickStr = parts[2];
        const note = parts.slice(3).join(" ");

        const scanCount = toInt(countStr);
        const pickCount = toInt(pickStr);

        if (!scanCount || !pickCount || scanCount <= 0 || pickCount <= 0) {
          await replyAndDeleteMsg(
            `用法: <code>${mainPrefix}dbdj 消息数 人数 文案</code>\n例如: <code>${mainPrefix}dbdj 50 2 恭喜发财</code>`,
          );
          return;
        }

        await msg.edit({
          text: `点兵点将...`,
          parseMode: "html",
        });

        const client = msg.client!;
        const offsetId = (msg.id || 1) - 1; // 从命令消息之前开始
        const messages = await safeGetMessages(client, msg.peerId, {
          offsetId,
          limit: scanCount,
        });

        // 收集有效用户: 仅统计来自用户的消息, 排除自身(out)、无 fromId 的消息
        const uniqueUserIds: number[] = [];
        const seen = new Set<number>();
        const filtered = new Set<number>();

        for (const m of messages) {
          // 跳过自己发送的消息
          // if ((m as any).out) continue;
          const from = (m as any).fromId as any;
          const uid = from?.userId ? Number(from.userId) : undefined;
          if (!uid || !Number.isFinite(uid)) continue;

          if (!seen.has(uid) && !filtered.has(uid)) {
            const entity = (await formatEntity(uid))?.entity;

            if (