aivfo-tl-3.0/Aivfo.OperationLog/OperationLogOptions.cs

using System;
using System.Collections.Concurrent;

namespace Aivfo.OperationLog
{
    /// <summary>
    /// 组件配置（14§10 可配置）。集中持有，支持运行时改（热生效简化为：直接改属性即下次记日志生效）。
    /// 模块级开关：默认全开，可按模块名设 开/关 + 最低级别。
    /// </summary>
    public sealed class OperationLogOptions
    {
        /// <summary>端/服务名（project 字段），如 "operate" / "front"。</summary>
        public string Project { get; set; } = "operate";

        /// <summary>Kafka 地址，如 "localhost:9092"。</summary>
        public string KafkaBootstrapServers { get; set; } = "localhost:9092";

        /// <summary>Kafka topic。</summary>
        public string Topic { get; set; } = "tl-oplog";

        /// <summary>全局总开关。关掉则完全不记（连入队都跳过）。</summary>
        public bool Enabled { get; set; } = true;

        /// <summary>
        /// 全局最低级别。低于此级别的日志不发 Kafka。
        /// 默认 Info：只发操作级；调试级（Debug）默认走本地文件、不入 Kafka。
        /// </summary>
        public OpLogLevel GlobalLevel { get; set; } = OpLogLevel.Info;

        /// <summary>内存队列上限。满了走降级（丢弃 Debug / 落本地兜底）。</summary>
        public int QueueCapacity { get; set; } = 10000;

        /// <summary>后台发送批量大小。</summary>
        public int BatchSize { get; set; } = 100;

        /// <summary>本地文件目录（调试级 + 兜底）。</summary>
        public string LocalLogDir { get; set; } = "oplog_local";

        /// <summary>设备上下文：培养箱 SN（可选，作为全局默认）。</summary>
        public string TlSn { get; set; }

        /// <summary>本机 host（默认取机器名）。</summary>
        public string Host { get; set; } = SafeMachineName();

        // 模块级开关：moduleName -> (enabled, minLevel)。缺省即全开、按 GlobalLevel。
        private readonly ConcurrentDictionary<string, ModuleSetting> _modules =
            new ConcurrentDictionary<string, ModuleSetting>();

        /// <summary>设置某模块的开关与最低级别（运行时可调，热生效）。</summary>
        public void SetModule(string module, bool enabled, OpLogLevel minLevel = OpLogLevel.Info)
        {
            if (string.IsNullOrEmpty(module)) return;
            _modules[module] = new ModuleSetting { Enabled = enabled, MinLevel = minLevel };
        }

        /// <summary>判断某模块是否启用（总开关 + 模块开关）。关闭则连本地调试文件也不写。</summary>
        public bool IsModuleEnabled(string module)
        {
            if (!Enabled) return false;
            if (!string.IsNullOrEmpty(module) && _modules.TryGetValue(module, out var s))
                return s.Enabled;
            return true;
        }

        /// <summary>
        /// 判断某模块某级别是否应**发 Kafka 入库**（操作级门槛）。
        /// 调试级（Debug）天然低于 Info，故默认不发 Kafka、走本地文件——这是 14§4 两级设计。
        /// 要让某模块的调试级也入库（很少用），把该模块 MinLevel 设为 Debug。
        /// </summary>
        public bool ShouldSendKafka(string module, OpLogLevel level)
        {
            if (!IsModuleEnabled(module)) return false;
            if (!string.IsNullOrEmpty(module) && _modules.TryGetValue(module, out var s))
                return level >= s.MinLevel;
            return level >= GlobalLevel;
        }

        private static string SafeMachineName()
        {
            try { return Environment.MachineName; }
            catch { return "unknown"; }
        }

        private sealed class ModuleSetting
        {
            public bool Enabled;
            public OpLogLevel MinLevel;
        }
    }
}