Method tryRepeat

autorepeat/autorepeat.ts:342–379

(chatId: number, text: string, msgs: Array<{ userId: number; text: string; time: number }>)

      if (msg.text === text) {
        senders.add(msg.userId);
      }
    }

    // 条件：至少配置的人数在配置的时间内发送
    if (senders.size >= this.triggerConfig.minUsers) {
      // 检查今日是否已复读
      if (!this.dailyHistory.has(chatId)) {
        this.dailyHistory.set(chatId, new Set());
      }

      // 简单哈希（或直接用文本，如果文本不太长）
      const contentKey = text.length > 50 ? text.substring(0, 50) + text.length : text;

      if (!this.dailyHistory.get(chatId)?.has(contentKey)) {
        // [关键修改] 先标记为已复读，防止并发重复
        this.dailyHistory.get(chatId)?.add(contentKey);
        await this.saveDailyHistory();

        // 执行复读
        const client = await getGlobalClient();
        if (client) {
          try {
            await client.sendMessage(chatId, { message: text });
            console.log(`[AutoRepeat] Group ${chatId} repeated: ${contentKey}`);
          } catch (e) {
            // 发送失败则移除标记（可选，视需求而定，为了防刷通常不移除）
            console.error(`[AutoRepeat] Failed to send: ${e}`);
          }
        }
      }
    }
  }

  private static async saveDailyHistory() {
    const historyObj: Record<string, string[]> = {};
    for (const [gid, set] of this.dailyHistory) {
      historyObj[gid] = Array.from(set);
    }
    await this.cache.saveData({
      daily_history: historyObj,
      last_day_check: this.lastDayCheck