Class NtpPlugin

ntp/ntp.ts:236–324

  > = {
    ntp: async (msg: Api.Message) => {
      const text = msg.message || "";
      const args = text.trim().split(/\s+/g).slice(1); // remove command

      // .ntp -> show current offset
      if (args.length === 0) {
        try {
          await msg.edit({ text: "⏳ 正在查询 NTP..." });
        } catch {}
        try {
          const result = await queryBest();
          const now = Date.now();
          const lines = [
            `🕒 NTP 查询完成`,
            `• 服务器: <code>${htmlEscape(result.server)}</code>${result.ip ? ` (${htmlEscape(result.ip)})` : ""}`,
            `• 分层: <code>${result.stratum ?? "-"}</code>`,
            `• 往返延迟: <code>${fmtMs(result.delayMs)}</code>`,
            `• 本地相对偏移: <code>${fmtMs(result.offsetMs)}</code>`,
            `• 本地时间: <code>${formatDateCN(new Date(now))}</code>`,
            result.serverTimeMs
              ? `• 服务器时间(估算): <code>${formatDateCN(
                  new Date(result.serverTimeMs)
                )}</code>`
              : undefined,
          ].filter(Boolean);
          await msg.edit({ text: lines.join("\n"), parseMode: "html" });
        } catch (e: any) {
          await msg.edit({ text: `❌ 查询失败：${htmlEscape(String(e?.message || e))}`, parseMode: "html" });
        }
        return;
      }

      // .ntp s -> sync time (best effort, requires privileges)
      if (args[0].toLowerCase() === "s") {
        try {
          await msg.edit({ text: "🔧 正在对时（NTP 查询）..." });
        } catch {}
        try {
          const result = await queryBest();
          if (!result.serverTimeMs) throw new Error("无法获取服务器时间");

          const now = Date.now();
          const beforeOffset = result.offsetMs ?? result.serverTimeMs - now;
          const header = [
            `🔧 NTP 对时`,
            `• 服务器: <code>${htmlEscape(result.server)}</code>${result.ip ? ` (${htmlEscape(result.ip)})` : ""}`,
            `• 估算偏移: <code>${fmtMs(beforeOffset)}</code>`,
            `• 往返延迟: <code>${fmtMs(result.delayMs)}</code>`,
          ].join("\n");

          // Try set system time
          const setRes = await setSystemTimeBestEffort(result.serverTimeMs);
          if (setRes.ok) {
            await msg.edit({
              text:
                header +
                `\n• 已尝试设置系统时间：<code>${htmlEscape(setRes.command || "")}</code>` +
                (setRes.stdout ? `\n<pre>${htmlEscape((setRes.stdout || "").trim())}</pre>` : ""),
              parseMode: "html",