Method checkAndRepeat

autorepeat/autorepeat.ts:300–340

(message: Api.Message)

      // 检查开关
      if (!this.enabledGroups.has(chatId)) return;

      // 必须是文本消息
      const text = message.message;
      if (!text) return;

      const now = Math.floor(Date.now() / 1000);

      // 定期清理过期消息和重置每日记录
      this.maintenance(now);

      // 获取当前群组的消息记录
      let msgs = this.recentMessages.get(chatId) || [];

      // 添加新消息
      const senderId = message.senderId ? Number(message.senderId) : 0;
      if (senderId === 0) return; // 忽略匿名发送者

      msgs.push({
        userId: senderId,
        text: text,
        time: now
      });

      // 过滤掉超过配置时间的消息
      msgs = msgs.filter(m => now - m.time <= this.triggerConfig.timeWindow);
      this.recentMessages.set(chatId, msgs);

      // 检查是否满足复读条件
      await this.tryRepeat(chatId, text, msgs);

    } catch (e) {
      console.error(`[AutoRepeat] Error: ${e}`);
    }
  }

  private static async tryRepeat(chatId: number, text: string, msgs: Array<{ userId: number; text: string; time: number }>) {
    // 统计发送由于该内容的不同用户数量
    const senders = new Set<number>();
    for (const msg of msgs) {
      if (msg.text === text) {
        senders.add(msg.userId);
      }
    }