AiDOPWarehouse/server/Plugins/Admin.NET.Plugin.AiDOP/Infrastructure/AidopInstanceIdentity.cs

using System.Diagnostics;
using System.Reflection;

namespace Admin.NET.Plugin.AiDOP.Infrastructure;

/// <summary>
/// 本进程在 ETL 执行机注册表（<c>ado_etl_instance</c>）中的身份。
///
/// <para><b>为什么要进程级唯一</b>：同一台机器可能同时跑多个后端进程（开发时的
/// <c>dotnet run</c> + 已发布的服务），它们连的是同一个库。若只用机器名做标识，
/// 两个进程会抢同一行注册记录，指派给谁都说不清。故标识取
/// <c>机器名:进程ID:启动时间</c> 三段，进程重启后必然产生新行。</para>
///
/// <para><b>为什么用启动时间而不是随机 GUID</b>：运维要在页面上认出「这是哪台、什么时候起的」。
/// GUID 每次重启都变且不可读，排障时无法和服务器上的进程对上。</para>
///
/// <para><b>身份与角色是两件事</b>：<see cref="InstanceId"/> 只回答「我是哪次进程」，
/// 执行机角色则指派给 <see cref="SlotCode"/> 这个跨重启稳定的部署槽位
/// （见 <c>AdoEtlRunnerDesignation</c>）。把角色挂在进程级标识上会让每次重启都丢指派。</para>
///
/// <para>静态只读，进程生命周期内不变，可在任意线程反复读取。</para>
/// </summary>
public static class AidopInstanceIdentity
{
    static AidopInstanceIdentity()
    {
        MachineName = SafeGet(() => Environment.MachineName, "unknown-host");
        ProcessId = SafeGet(() => Environment.ProcessId, 0);
        StartedAt = SafeGet(() => Process.GetCurrentProcess().StartTime, DateTime.Now);
        AppVersion = SafeGet(
            () => Assembly.GetEntryAssembly()?.GetName().Version?.ToString(),
            null);

        // 长度受 ado_etl_instance.instance_id 的 200 字符约束；机器名过长时截断，
        // 进程ID + 启动时间仍能保证同机不同进程互不覆盖。
        var host = MachineName.Length > 120 ? MachineName[..120] : MachineName;
        InstanceId = $"{host}:{ProcessId}:{StartedAt:yyyyMMddHHmmss}";
    }

    /// <summary>注册表主键语义列，形如 <c>DESKTOP-ABC:12345:20260925071200</c>。</summary>
    public static string InstanceId { get; }

    public static string MachineName { get; }

    public static int ProcessId { get; }

    /// <summary>本进程启动时间。取不到时退化为静态构造时刻，不影响唯一性。</summary>
    public static DateTime StartedAt { get; }

    /// <summary>入口程序集版本，仅供页面展示与排障；取不到为 null。</summary>
    public static string AppVersion { get; }

    /// <summary>配置键：本进程所属的 ETL 执行机槽位。</summary>
    public const string SlotConfigKey = "AiDOP:Jobs:Slot";

    /// <summary>环境变量名：优先级高于配置，便于容器与服务单元各自声明。</summary>
    public const string SlotEnvName = "AIDOP_ETL_SLOT";

    /// <summary>
    /// 本进程所属的执行机槽位；未声明则为 null，**此时本进程永远不可能成为执行机**。
    ///
    /// <para>这比旧模型更严：旧模型下任何一台注册上来的进程都能被指派，
    /// 开发机被指派正是 2026-09-24 连接耗尽事故的成因之一。未声明槽位者连候选都不是。</para>
    ///
    /// <para><b>槽位不同于「配置里写自己是不是执行机」</b>：配置只声明身份（我是哪个槽位），
    /// 唯一权威仍在库里那条指派记录。这保留了 2026-09-25 治理的核心——
    /// 单一开关、页面可见、热切换无需重启——只是让指派能跨重启存活。</para>
    ///
    /// <para><b>为什么惰性求值</b>：静态构造可能早于宿主配置就绪，
    /// 那时读 <c>App.GetConfig</c> 会抛，若在构造里一次性定下来就会永久退化成 null。
    /// 首次访问来自心跳（启动后 5 秒），此时配置一定已就绪。</para>
    /// </summary>
    public static string SlotCode => _slotCode.Value;

    private static readonly Lazy<string> _slotCode = new(ResolveSlotCode, LazyThreadSafetyMode.ExecutionAndPublication);

    private static string ResolveSlotCode()
    {
        var fromEnv = SafeGet(() => Environment.GetEnvironmentVariable(SlotEnvName), null);
        if (!string.IsNullOrWhiteSpace(fromEnv))
            return Normalize(fromEnv);

        var fromConfig = SafeGet(() => Furion.App.GetConfig<string>(SlotConfigKey, true), null);
        return string.IsNullOrWhiteSpace(fromConfig) ? null : Normalize(fromConfig);
    }

    /// <summary>槽位码要能被人工比对，故统一去空白并折成小写，长度受 128 字符列约束。</summary>
    private static string Normalize(string raw)
    {
        var v = raw.Trim().ToLowerInvariant();
        return v.Length > 128 ? v[..128] : v;
    }

    /// <summary>
    /// 身份计算不得成为启动故障点：容器内取进程启动时间、受限环境取机器名都可能抛异常，
    /// 一旦抛出会让整个插件装配失败，而这里拿到的只是展示用信息。
    /// </summary>
    private static T SafeGet<T>(Func<T> get, T fallback)
    {
        try { return get(); }
        catch { return fallback; }
    }
}