Class CyPlugin

cy/cy.ts:385–504

}

class CyPlugin extends Plugin {
  description = `词云
<code>${mainPrefix}cy [消息数]</code> - 当前群立即生成
<code>${mainPrefix}cy help</code> - 查看词云帮助
<code>${mainPrefix}cy target here</code> - 设置当前群为定时目标
<code>${mainPrefix}cy time 09:00 500</code> - 设置定时发送
<code>${mainPrefix}cy on|off|status</code> - 开关/查看定时`;
  private timer?: NodeJS.Timeout;
  private lastRuns = new Set<string>();
  private runningRuns = new Set<string>();

  constructor() {
    super();
    this.timer = setInterval(() => {
      this.tickSchedule().catch((error) => console.error("[cy] 定时词云失败:", error));
    }, 30_000);
  }

  cleanup(): void {
    if (this.timer) clearInterval(this.timer);
  }

  private async tickSchedule(): Promise<void> {
    const config = readScheduleConfig();
    if (!config.enabled || !config.target || !config.times.length) return;
    const now = new Date();
    const hh = String(now.getHours()).padStart(2, "0");
    const mm = String(now.getMinutes()).padStart(2, "0");
    const current = `${hh}:${mm}`;
    if (!config.times.includes(current)) return;
    const day = `${now.getFullYear()}-${now.getMonth() + 1}-${now.getDate()}`;
    const key = `${day}:${current}`;
    if (this.lastRuns.has(key) || this.runningRuns.has(key)) return;
    this.runningRuns.add(key);
    if (this.lastRuns.size > 200) this.lastRuns = new Set([...this.lastRuns].slice(-80));
    try {
      const client = await getGlobalClient();
      if (!client) return;
      await sendCloudToTarget(client, config.target, config.limit);
      this.lastRuns.add(key);
    } finally {
      this.runningRuns.delete(key);
    }
  }

  cmdHandlers: Record<string, (msg: Api.Message, trigger?: Api.Message) => Promise<void>> = {
    cy: async (msg) => {
      const args = getArgs(String(msg.text || msg.message || ""));
      const [subCommand = "", ...restParts] = args.split(/\s+/).filter(Boolean);
      const rest = restParts.join(" ");
      const config = readScheduleConfig();

      if (["help", "?"].includes(subCommand)) {
        await msg.edit({ text: buildHelpText() });
        return;
      }
      if (["target", "chat", "group"].includes(subCommand)) {
        const target = rest.trim() === "here" || !rest.trim() ? targetFromCurrentChat(msg) : rest.trim();