Function da

da/da.ts:286–588

(msg: Api.Message)

  const lines = msg.text?.trim()?.split(/\r?\n/g) || [];
  const parts = lines?.[0]?.split(/\s+/) || [];
  const [, ...args] = parts; // 跳过命令本身
  const sub = (args[0] || "").toLowerCase();

  const client = await getGlobalClient();
  if (!client) {
    await msg.edit({ text: "❌ 客户端错误", parseMode: "html" });
    return;
  }

  if (!msg.chatId || msg.isPrivate) {
    await msg.edit({ text: "❌ 仅群组可用", parseMode: "html" });
    return;
  }

  const taskId = msg.chatId.toString();

  try {
    // 无参数时显示帮助
    if (!sub) {
      await msg.edit({ text: help_text, parseMode: "html" });
      return;
    }

    // 处理 help 命令
    if (sub === "help" || sub === "h") {
      await msg.edit({ text: help_text, parseMode: "html" });
      return;
    }

    // 处理停止命令
    if (sub === "stop") {
      const task = await getTask(taskId);
      
      if (!task) {
        await msg.delete();
        return;
      }
      
      task.isRunning = false;
      task.isPaused = true;
      await saveTask(task);
      
      const msgId = await sendProgressToSaved(client, task, "已手动停止");
      if (msgId && !task.savedMessageId) {
        task.savedMessageId = msgId;
        await saveTask(task);
      }
      
      await msg.delete();
      return;
    }

    // 处理状态查询
    if (sub === "status") {
      const task = await getTask(taskId);
      
      if (!task) {
        await msg.delete();