Browse Source

硬盘信息按端口号排序

懒得勤快 1 year ago
parent
commit
503ebf9f3c

+ 1 - 1
Directory.Build.props

@@ -1,6 +1,6 @@
 <Project>
  <PropertyGroup>
-   <Version>2024.4.3</Version>
+   <Version>2024.4.4</Version>
    <Deterministic>true</Deterministic>
  </PropertyGroup>
 </Project>

+ 26 - 22
Masuit.Tools.Abstractions/Hardware/DiskInfo.cs

@@ -7,25 +7,29 @@ namespace Masuit.Tools.Hardware;
 /// </summary>
 public class DiskInfo
 {
-    private static readonly List<DiskInfo> _locals = SystemInfo.GetDiskInfo();
-
-    /// <summary>
-    /// 本地实例
-    /// </summary>
-    public static List<DiskInfo> Locals => _locals;
-
-    /// <summary>
-    /// 序列号
-    /// </summary>
-    public string SerialNumber { get; set; }
-
-    /// <summary>
-    /// 型号
-    /// </summary>
-    public string Model { get; set; }
-
-    /// <summary>
-    /// 总容量
-    /// </summary>
-    public float Total { get; set; }
-}
+	internal int Index { get; set; }
+
+	private static readonly List<DiskInfo> _locals = SystemInfo.GetDiskInfo();
+
+	/// <summary>
+	/// 本地实例
+	/// </summary>
+	public static List<DiskInfo> Locals => _locals;
+
+	/// <summary>
+	/// 序列号
+	/// </summary>
+	public string SerialNumber { get; set; }
+
+	/// <summary>
+	/// 型号
+	/// </summary>
+	public string Model { get; set; }
+
+	/// <summary>
+	/// 总容量
+	/// </summary>
+	public long Total { get; set; }
+
+	public string MediaType { get; set; }
+}

+ 834 - 830
Masuit.Tools.Abstractions/Hardware/SystemInfo.cs

@@ -16,843 +16,847 @@ using System.Threading.Tasks;
 
 namespace Masuit.Tools.Hardware
 {
-    /// <summary>
-    /// 硬件信息,部分功能需要C++支持,仅支持Windows系统
-    /// </summary>
-    public static partial class SystemInfo
-    {
-        #region 字段
-
-        private const int GwHwndfirst = 0;
-        private const int GwHwndnext = 2;
-        private const int GwlStyle = -16;
-        private const int WsVisible = 268435456;
-        private const int WsBorder = 8388608;
-        private static readonly PerformanceCounter PcCpuLoad; //CPU计数器
-
-        private static readonly PerformanceCounter IOCounter;
-
-        private static readonly string[] InstanceNames = { };
-        private static readonly PerformanceCounter[] NetRecvCounters;
-        private static readonly PerformanceCounter[] NetSentCounters;
-        private static readonly Dictionary<string, dynamic> Cache = new();
-
-        public static bool IsWinPlatform => Environment.OSVersion.Platform is PlatformID.Win32Windows
-            or PlatformID.Win32S or PlatformID.WinCE or PlatformID.Win32NT;
-
-        #endregion 字段
-
-        #region 构造函数
-
-        /// <summary>
-        /// 静态构造函数
-        /// </summary>
-        static SystemInfo()
-        {
-            if (IsWinPlatform)
-            {
-                IOCounter = new PerformanceCounter();
-
-                //初始化CPU计数器
-                PcCpuLoad = new PerformanceCounter("Processor", "% Processor Time", "_Total")
-                {
-                    MachineName = "."
-                };
-                PcCpuLoad.NextValue();
-
-                //获得物理内存
-                try
-                {
-                    using var mc = new ManagementClass("Win32_ComputerSystem");
-                    using var moc = mc.GetInstances();
-                    foreach (var mo in moc)
-                    {
-                        using (mo)
-                        {
-                            if (mo["TotalPhysicalMemory"] != null)
-                            {
-                                PhysicalMemory = long.Parse(mo["TotalPhysicalMemory"].ToString());
-                            }
-                        }
-                    }
-
-                    var cat = new PerformanceCounterCategory("Network Interface");
-                    InstanceNames = cat.GetInstanceNames();
-                    NetRecvCounters = new PerformanceCounter[InstanceNames.Length];
-                    NetSentCounters = new PerformanceCounter[InstanceNames.Length];
-                    for (int i = 0; i < InstanceNames.Length; i++)
-                    {
-                        NetRecvCounters[i] = new PerformanceCounter();
-                        NetSentCounters[i] = new PerformanceCounter();
-                    }
-
-                    CompactFormat = false;
-                }
-                catch (Exception e)
-                {
-                    LogManager.Error(e);
-                }
-            }
-
-            //CPU个数
-            ProcessorCount = Environment.ProcessorCount;
-        }
-
-        #endregion 构造函数
-
-        private static bool CompactFormat { get; set; }
-
-        #region CPU相关
-
-        /// <summary>
-        /// 获取CPU核心数
-        /// </summary>
-        public static int ProcessorCount { get; }
-
-        /// <summary>
-        /// 获取CPU占用率 %
-        /// </summary>
-        public static float CpuLoad => PcCpuLoad?.NextValue() ?? 0;
-
-        /// <summary>
-        /// 获取当前进程的CPU使用率(至少需要0.5s)
-        /// </summary>
-        /// <returns></returns>
-        public static async Task<double> GetCpuUsageForProcess()
-        {
-            var startTime = DateTime.UtcNow;
-            using var p1 = Process.GetCurrentProcess();
-            var startCpuUsage = p1.TotalProcessorTime;
-            await Task.Delay(500);
-            var endTime = DateTime.UtcNow;
-            using var p2 = Process.GetCurrentProcess();
-            var endCpuUsage = p2.TotalProcessorTime;
-            var cpuUsedMs = (endCpuUsage - startCpuUsage).TotalMilliseconds;
-            var totalMsPassed = (endTime - startTime).TotalMilliseconds;
-            return cpuUsedMs / (Environment.ProcessorCount * totalMsPassed) * 100;
-        }
-
-        /// <summary>
-        /// WMI接口获取CPU使用率
-        /// </summary>
-        /// <returns></returns>
-        public static string GetProcessorData()
-        {
-            var d = GetCounterValue(IOCounter, "Processor", "% Processor Time", "_Total");
-            return CompactFormat ? (int)d + "%" : d.ToString("F") + "%";
-        }
-
-        /// <summary>
-        /// 获取CPU温度
-        /// </summary>
-        /// <returns>CPU温度</returns>
-        public static float GetCPUTemperature()
-        {
-            if (!IsWinPlatform) return 0;
-
-            try
-            {
-                using var mos = new ManagementObjectSearcher(@"root\WMI", "select * from MSAcpi_ThermalZoneTemperature");
-                using var moc = mos.Get();
-                foreach (var mo in moc)
-                {
-                    using (mo)
-                    {
-                        //这就是CPU的温度了
-                        var temp = (float.Parse(mo.Properties["CurrentTemperature"].Value.ToString()) - 2732) / 10;
-                        return (float)Math.Round(temp, 2);
-                    }
-                }
-                return 0;
-            }
-            catch (Exception)
-            {
-                return -1;
-            }
-        }
-
-        /// <summary>
-        /// 获取CPU的数量
-        /// </summary>
-        /// <returns>CPU的数量</returns>
-        public static int GetCpuCount()
-        {
-            try
-            {
-                return Cache.GetOrAdd(nameof(GetCpuCount), () =>
-                {
-                    if (!IsWinPlatform)
-                    {
-                        return Environment.ProcessorCount;
-                    }
-
-                    using var m = new ManagementClass("Win32_Processor");
-                    using var moc = m.GetInstances();
-                    return moc.Count;
-                });
-            }
-            catch (Exception)
-            {
-                return -1;
-            }
-        }
-
-        private static readonly Lazy<List<ManagementBaseObject>> CpuObjects = new(() =>
-        {
-            using var mos = new ManagementObjectSearcher("SELECT * FROM Win32_Processor");
-            using var moc = mos.Get();
-            return moc.AsParallel().Cast<ManagementBaseObject>().ToList();
-        });
-
-        /// <summary>
-        /// 获取CPU信息
-        /// </summary>
-        /// <returns>CPU信息</returns>
-        public static List<CpuInfo> GetCpuInfo()
-        {
-            try
-            {
-                if (!IsWinPlatform) return [];
-                return CpuObjects.Value.Select(mo => new CpuInfo
-                {
-                    NumberOfLogicalProcessors = ProcessorCount,
-                    CurrentClockSpeed = mo.Properties["CurrentClockSpeed"].Value.ToString(),
-                    Manufacturer = mo.Properties["Manufacturer"].Value.ToString(),
-                    MaxClockSpeed = mo.Properties["MaxClockSpeed"].Value.ToString(),
-                    Type = mo.Properties["Name"].Value.ToString(),
-                    DataWidth = mo.Properties["DataWidth"].Value.ToString(),
-                    SerialNumber = mo.Properties["ProcessorId"].Value.ToString(),
-                    DeviceID = mo.Properties["DeviceID"].Value.ToString(),
-                    NumberOfCores = Convert.ToInt32(mo.Properties["NumberOfCores"].Value)
-                }).ToList();
-            }
-            catch (Exception)
-            {
-                return [];
-            }
-        }
-
-        #endregion CPU相关
-
-        #region 内存相关
-
-        /// <summary>
-        /// 获取可用内存
-        /// </summary>
-        public static long MemoryAvailable
-        {
-            get
-            {
-                if (!IsWinPlatform) return 0;
-
-                try
-                {
-                    using var mc = new ManagementClass("Win32_OperatingSystem");
-                    using var moc = mc.GetInstances();
-                    foreach (var mo in moc)
-                    {
-                        using (mo)
-                        {
-                            if (mo["FreePhysicalMemory"] != null)
-                            {
-                                return 1024 * long.Parse(mo["FreePhysicalMemory"].ToString());
-                            }
-                        }
-                    }
-
-                    return 0;
-                }
-                catch (Exception)
-                {
-                    return -1;
-                }
-            }
-        }
-
-        /// <summary>
-        /// 获取物理内存
-        /// </summary>
-        public static long PhysicalMemory { get; }
-
-        public static long CurrentProcessMemory
-        {
-            get
-            {
-                if (!IsWinPlatform) return 0;
-                using var process = Process.GetCurrentProcess();
-                return (long)GetCounterValue(IOCounter, "Process", "Working Set - Private", process.ProcessName);
-            }
-        }
-
-        /// <summary>
-        /// 获取内存信息
-        /// </summary>
-        /// <returns>内存信息</returns>
-        public static RamInfo GetRamInfo()
-        {
-            return new RamInfo
-            {
-                MemoryAvailable = GetFreePhysicalMemory(),
-                PhysicalMemory = GetTotalPhysicalMemory(),
-                TotalPageFile = GetTotalVirtualMemory(),
-                AvailablePageFile = GetTotalVirtualMemory() - GetUsedVirtualMemory(),
-                AvailableVirtual = 1 - GetUsageVirtualMemory(),
-                TotalVirtual = 1 - GetUsedPhysicalMemory()
-            };
-        }
-
-        /// <summary>
-        /// 获取虚拟内存使用率详情
-        /// </summary>
-        /// <returns></returns>
-        public static string GetMemoryVData()
-        {
-            if (!IsWinPlatform) return "";
-            float d = GetCounterValue(IOCounter, "Memory", "% Committed Bytes In Use", null);
-            var str = d.ToString("F") + "% (";
-            d = GetCounterValue(IOCounter, "Memory", "Committed Bytes", null);
-            str += FormatBytes(d) + " / ";
-            d = GetCounterValue(IOCounter, "Memory", "Commit Limit", null);
-            return str + FormatBytes(d) + ") ";
-        }
-
-        /// <summary>
-        /// 获取虚拟内存使用率
-        /// </summary>
-        /// <returns></returns>
-        public static float GetUsageVirtualMemory()
-        {
-            if (!IsWinPlatform) return 0;
-            return GetCounterValue(IOCounter, "Memory", "% Committed Bytes In Use", null);
-        }
-
-        /// <summary>
-        /// 获取虚拟内存已用大小
-        /// </summary>
-        /// <returns></returns>
-        public static float GetUsedVirtualMemory()
-        {
-            if (!IsWinPlatform) return 0;
-            return GetCounterValue(IOCounter, "Memory", "Committed Bytes", null);
-        }
-
-        /// <summary>
-        /// 获取虚拟内存总大小
-        /// </summary>
-        /// <returns></returns>
-        public static float GetTotalVirtualMemory()
-        {
-            if (!IsWinPlatform) return 0;
-            return GetCounterValue(IOCounter, "Memory", "Commit Limit", null);
-        }
-
-        /// <summary>
-        /// 获取物理内存使用率详情描述
-        /// </summary>
-        /// <returns></returns>
-        public static string GetMemoryPData()
-        {
-            if (!IsWinPlatform) return "";
-            string s = QueryComputerSystem("totalphysicalmemory");
-            if (string.IsNullOrEmpty(s)) return "";
-
-            var totalphysicalmemory = Convert.ToSingle(s);
-            var d = GetCounterValue(IOCounter, "Memory", "Available Bytes", null);
-            d = totalphysicalmemory - d;
-            s = CompactFormat ? "%" : "% (" + FormatBytes(d) + " / " + FormatBytes(totalphysicalmemory) + ")";
-            d /= totalphysicalmemory;
-            d *= 100;
-            return CompactFormat ? (int)d + s : d.ToString("F") + s;
-        }
-
-        /// <summary>
-        /// 获取物理内存总数,单位B
-        /// </summary>
-        /// <returns></returns>
-        public static float GetTotalPhysicalMemory()
-        {
-            return Cache.GetOrAdd(nameof(GetTotalPhysicalMemory), () =>
-            {
-                var s = QueryComputerSystem("totalphysicalmemory");
-                return s.TryConvertTo<float>();
-            });
-        }
-
-        /// <summary>
-        /// 获取空闲的物理内存数,单位B
-        /// </summary>
-        /// <returns></returns>
-        public static float GetFreePhysicalMemory()
-        {
-            if (!IsWinPlatform) return 0;
-            return GetCounterValue(IOCounter, "Memory", "Available Bytes", null);
-        }
-
-        /// <summary>
-        /// 获取已经使用了的物理内存数,单位B
-        /// </summary>
-        /// <returns></returns>
-        public static float GetUsedPhysicalMemory()
-        {
-            return GetTotalPhysicalMemory() - GetFreePhysicalMemory();
-        }
-
-        #endregion 内存相关
-
-        #region 硬盘相关
-
-        /// <summary>
-        /// 获取硬盘的读写速率
-        /// </summary>
-        /// <param name="dd">读或写</param>
-        /// <returns></returns>
-        public static float GetDiskData(DiskData dd)
-        {
-            if (!IsWinPlatform) return 0;
-            return dd switch
-            {
-                DiskData.Read => GetCounterValue(IOCounter, "PhysicalDisk", "Disk Read Bytes/sec", "_Total"),
-                DiskData.Write => GetCounterValue(IOCounter, "PhysicalDisk", "Disk Write Bytes/sec", "_Total"),
-                DiskData.ReadAndWrite => GetCounterValue(IOCounter, "PhysicalDisk", "Disk Read Bytes/sec", "_Total") + GetCounterValue(IOCounter, "PhysicalDisk", "Disk Write Bytes/sec", "_Total"),
-                _ => 0
-            };
-        }
-
-        private static readonly List<DiskInfo> DiskInfos = [];
-
-        /// <summary>
-        /// 获取磁盘可用空间
-        /// </summary>
-        /// <returns></returns>
-        public static List<DiskInfo> GetDiskInfo()
-        {
-            try
-            {
-                if (!IsWinPlatform || DiskInfos.Count > 0)
-                {
-                    return DiskInfos;
-                }
-
-                using var mc = new ManagementClass("Win32_DiskDrive");
-                using var moc = mc.GetInstances();
-                foreach (var mo in moc)
-                {
-                    using (mo)
-                    {
-                        DiskInfos.Add(new DiskInfo()
-                        {
-                            Total = float.Parse(mo["Size"].ToString()),
-                            Model = mo["Model"].ToString(),
-                            SerialNumber = mo["SerialNumber"].ToString(),
-                        });
-                    }
-                }
-
-                return DiskInfos;
-            }
-            catch (Exception)
-            {
-                return [];
-            }
-        }
-
-        #endregion 硬盘相关
-
-        #region 网络相关
-
-        /// <summary>
-        /// 获取网络的传输速率
-        /// </summary>
-        /// <param name="nd">上传或下载</param>
-        /// <returns></returns>
-        public static float GetNetData(NetData nd)
-        {
-            if (!IsWinPlatform) return 0;
-            if (InstanceNames is { Length: 0 }) return 0;
-
-            float d = 0;
-            for (int i = 0; i < InstanceNames.Length; i++)
-            {
-                float receied = GetCounterValue(NetRecvCounters[i], "Network Interface", "Bytes Received/sec", InstanceNames[i]);
-                float send = GetCounterValue(NetSentCounters[i], "Network Interface", "Bytes Sent/sec", InstanceNames[i]);
-                switch (nd)
-                {
-                    case NetData.Received:
-                        d += receied;
-                        break;
-
-                    case NetData.Sent:
-                        d += send;
-                        break;
-
-                    case NetData.ReceivedAndSent:
-                        d += receied + send;
-                        break;
-
-                    default:
-                        d += 0;
-                        break;
-                }
-            }
-
-            return d;
-        }
-
-        /// <summary>
-        /// 获取网卡硬件地址
-        /// </summary>
-        /// <returns></returns>
-        public static IEnumerable<PhysicalAddress> GetMacAddress()
-        {
-            return from adapter in NetworkInterface.GetAllNetworkInterfaces().Where(c => c.NetworkInterfaceType != NetworkInterfaceType.Loopback && c.OperationalStatus == OperationalStatus.Up)
-                   let properties = adapter.GetIPProperties()
-                   let unicastAddresses = properties.UnicastAddresses
-                   where unicastAddresses.Any(temp => temp.Address.AddressFamily == AddressFamily.InterNetwork)
-                   select adapter.GetPhysicalAddress() into address
-                   select address;
-        }
-
-        /// <summary>
-        /// 获取IP地址WMI
-        /// </summary>
-        /// <returns></returns>
-        public static string GetIPAddressWMI()
-        {
-            try
-            {
-                if (!IsWinPlatform) return "";
-
-                return Cache.GetOrAdd(nameof(GetIPAddressWMI), () =>
-                {
-                    using var mc = new ManagementClass("Win32_NetworkAdapterConfiguration");
-                    using var moc = mc.GetInstances();
-                    foreach (var mo in moc)
-                    {
-                        if ((bool)mo["IPEnabled"])
-                        {
-                            return ((string[])mo.Properties["IpAddress"].Value)[0];
-                        }
-                    }
-                    return "";
-                });
-            }
-            catch (Exception e)
-            {
-                Console.WriteLine(e.Message);
-            }
-
-            return "";
-        }
-
-        /// <summary>
-        /// 获取当前使用的IP
-        /// </summary>
-        /// <returns></returns>
-        public static IPAddress GetLocalUsedIP()
-        {
-            return GetLocalUsedIP(AddressFamily.InterNetwork);
-        }
-
-        /// <summary>
-        /// 获取当前使用的IP
-        /// </summary>
-        /// <returns></returns>
-        public static IPAddress GetLocalUsedIP(AddressFamily family)
-        {
-            if (!IsWinPlatform) return default;
-
-            return NetworkInterface.GetAllNetworkInterfaces().Where(c => c.NetworkInterfaceType != NetworkInterfaceType.Loopback && c.OperationalStatus == OperationalStatus.Up).OrderByDescending(c => c.Speed).Select(t => t.GetIPProperties()).Where(p => p.DhcpServerAddresses.Count > 0).SelectMany(p => p.UnicastAddresses).Select(p => p.Address).FirstOrDefault(p => !(p.IsIPv6Teredo || p.IsIPv6LinkLocal || p.IsIPv6Multicast || p.IsIPv6SiteLocal) && p.AddressFamily == family);
-        }
-
-        /// <summary>
-        /// 获取本机所有的ip地址
-        /// </summary>
-        /// <returns></returns>
-        public static List<UnicastIPAddressInformation> GetLocalIPs()
-        {
-            var interfaces = NetworkInterface.GetAllNetworkInterfaces().Where(c => c.NetworkInterfaceType != NetworkInterfaceType.Loopback && c.OperationalStatus == OperationalStatus.Up).OrderByDescending(c => c.Speed); //所有网卡信息
-            return interfaces.SelectMany(n => n.GetIPProperties().UnicastAddresses).ToList();
-        }
-
-        /// <summary>
-        /// 获取网卡地址
-        /// </summary>
-        /// <returns></returns>
-        public static string GetNetworkCardAddress()
-        {
-            try
-            {
-                if (!IsWinPlatform) return "";
-
-                return Cache.GetOrAdd(nameof(GetNetworkCardAddress), () =>
-                {
-                    using var mos = new ManagementObjectSearcher("select * from Win32_NetworkAdapter where ((MACAddress Is Not NULL) and (Manufacturer <> 'Microsoft'))");
-                    using var moc = mos.Get();
-                    foreach (var mo in moc)
-                    {
-                        return mo["MACAddress"].ToString().Trim();
-                    }
-                    return "";
-                });
-            }
-            catch (Exception e)
-            {
-                Console.WriteLine(e.Message);
-            }
-
-            return "";
-        }
-
-        #endregion 网络相关
-
-        #region 系统相关
-
-        /// <summary>
-        /// 获取计算机开机时间
-        /// </summary>
-        /// <returns>datetime</returns>
-        public static DateTime BootTime()
-        {
-            if (!IsWinPlatform) return default;
-
-            var query = new SelectQuery("SELECT LastBootUpTime FROM Win32_OperatingSystem WHERE Primary='true'");
-            using var searcher = new ManagementObjectSearcher(query);
-            using var moc = searcher.Get();
-            foreach (var mo in moc)
-            {
-                using (mo)
-                {
-                    return ManagementDateTimeConverter.ToDateTime(mo.Properties["LastBootUpTime"].Value.ToString());
-                }
-            }
-
-            return DateTime.Now - TimeSpan.FromMilliseconds(Environment.TickCount & int.MaxValue);
-        }
-
-        /// <summary>
-        /// 查询计算机系统信息
-        /// </summary>
-        /// <param name="type">类型名</param>
-        /// <returns></returns>
-        public static string QueryComputerSystem(string type)
-        {
-            try
-            {
-                if (!IsWinPlatform) return string.Empty;
-
-                var mos = new ManagementObjectSearcher("SELECT * FROM Win32_ComputerSystem");
-                using var moc = mos.Get();
-                foreach (var mo in moc)
-                {
-                    using (mo)
-                    {
-                        return mo[type].ToString();
-                    }
-                }
-            }
-            catch (Exception e)
-            {
-                return "未能获取到当前计算机系统信息,可能是当前程序无管理员权限,如果是web应用程序,请将应用程序池的高级设置中的进程模型下的标识设置为:LocalSystem;如果是普通桌面应用程序,请提升管理员权限后再操作。异常信息:" + e.Message;
-            }
-            return string.Empty;
-        }
-
-        /// <summary>
-        /// 查找所有应用程序标题
-        /// </summary>
-        /// <param name="handle">应用程序标题范型</param>
-        /// <returns>所有应用程序集合</returns>
-        public static List<string> FindAllApps(int handle)
-        {
-            if (!IsWinPlatform) return new List<string>(0);
-
-            var apps = new List<string>();
-            int hwCurr = GetWindow(handle, GwHwndfirst);
-            while (hwCurr > 0)
-            {
-                int IsTask = WsVisible | WsBorder;
-                int lngStyle = GetWindowLongA(hwCurr, GwlStyle);
-                bool taskWindow = (lngStyle & IsTask) == IsTask;
-                if (taskWindow)
-                {
-                    int length = GetWindowTextLength(new IntPtr(hwCurr));
-                    var sb = new StringBuilder(2 * length + 1);
-                    GetWindowText(hwCurr, sb, sb.Capacity);
-                    string strTitle = sb.ToString();
-                    if (!string.IsNullOrEmpty(strTitle))
-                    {
-                        apps.Add(strTitle);
-                    }
-                }
-
-                hwCurr = GetWindow(hwCurr, GwHwndnext);
-            }
-
-            return apps;
-        }
-
-        /// <summary>
-        /// 操作系统类型
-        /// </summary>
-        /// <returns></returns>
-        public static string GetSystemType()
-        {
-            try
-            {
-                return Cache.GetOrAdd(nameof(GetSystemType), () =>
-                {
-                    if (!IsWinPlatform)
-                    {
-                        return Environment.OSVersion.Platform.ToString();
-                    }
-
-                    using var mc = new ManagementClass("Win32_ComputerSystem");
-                    using var moc = mc.GetInstances();
-                    foreach (var mo in moc)
-                    {
-                        return mo["SystemType"].ToString().Trim();
-                    }
-                    return "";
-                });
-            }
-            catch (Exception e)
-            {
-                Console.WriteLine(e.Message);
-            }
-
-            return "";
-        }
-
-        #endregion 系统相关
-
-        #region 主板相关
-
-        /// <summary>
-        /// 获取主板序列号
-        /// </summary>
-        /// <returns></returns>
-        public static string GetBiosSerialNumber()
-        {
-            try
-            {
-                if (!IsWinPlatform) return "";
-
-                return Cache.GetOrAdd(nameof(GetBiosSerialNumber), () =>
-                {
-                    using var searcher = new ManagementObjectSearcher("select * from Win32_BIOS");
-                    using var mos = searcher.Get();
-                    foreach (var mo in mos)
-                    {
-                        return mo["SerialNumber"].ToString().Trim();
-                    }
-                    return "";
-                });
-            }
-            catch (Exception e)
-            {
-                Console.WriteLine(e.Message);
-            }
-
-            return "";
-        }
-
-        /// <summary>
-        /// 主板编号
-        /// </summary>
-        /// <returns></returns>
-        public static BiosInfo GetBiosInfo()
-        {
-            if (!IsWinPlatform) return new BiosInfo();
-
-            return Cache.GetOrAdd(nameof(GetBiosInfo), () =>
-            {
-                using var searcher = new ManagementObjectSearcher("select * from Win32_BaseBoard");
-                using var mos = searcher.Get();
-                using var reg = RegistryKey.OpenBaseKey(RegistryHive.LocalMachine, RegistryView.Registry64);
-                using var guidKey = reg.OpenSubKey(@"SOFTWARE\Microsoft\Cryptography");
-                using var uuidKey = reg.OpenSubKey(@"SYSTEM\HardwareConfig");
-                string guid = null;
-                string uuid = null;
-                string model = null;
-                if (guidKey != null) guid = guidKey.GetValue("MachineGuid") + "";
-                if (uuidKey != null) uuid = (uuidKey.GetValue("LastConfig") + "").Trim('{', '}').ToUpper();
-                var biosKey = Registry.LocalMachine.OpenSubKey(@"HARDWARE\DESCRIPTION\System\BIOS");
-                biosKey ??= Registry.LocalMachine.OpenSubKey(@"SYSTEM\HardwareConfig\Current");
-                if (biosKey != null)
-                {
-                    model = (biosKey.GetValue("SystemProductName") + "").Replace("System Product Name", null);
-                    if (model.IsNullOrEmpty()) model = biosKey.GetValue("BaseBoardProduct") + "";
-                    biosKey.Dispose();
-                }
-                foreach (var mo in mos)
-                {
-                    return new BiosInfo
-                    {
-                        Manufacturer = mo.GetPropertyValue("Manufacturer").ToString(),
-                        ID = mo["SerialNumber"].ToString(),
-                        Model = model,
-                        SerialNumber = GetBiosSerialNumber(),
-                        Guid = guid,
-                        UUID = uuid
-                    };
-                }
-
-                return new BiosInfo();
-            });
-        }
-
-        #endregion 主板相关
-
-        #region 公共函数
-
-        /// <summary>
-        /// 将速度值格式化成字节单位
-        /// </summary>
-        /// <param name="bytes"></param>
-        /// <returns></returns>
-        public static string FormatBytes(this double bytes)
-        {
-            int unit = 0;
-            while (bytes > 1024)
-            {
-                bytes /= 1024;
-                ++unit;
-            }
-
-            string s = CompactFormat ? ((int)bytes).ToString() : bytes.ToString("F") + " ";
-            return s + (Unit)unit;
-        }
-
-        private static float GetCounterValue(PerformanceCounter pc, string categoryName, string counterName, string instanceName)
-        {
-            if (!IsWinPlatform) return 0;
-
-            pc.CategoryName = categoryName;
-            pc.CounterName = counterName;
-            pc.InstanceName = instanceName;
-            return pc.NextValue();
-        }
-
-        #endregion 公共函数
-
-        #region Win32API声明
+	/// <summary>
+	/// 硬件信息,部分功能需要C++支持,仅支持Windows系统
+	/// </summary>
+	public static partial class SystemInfo
+	{
+		#region 字段
+
+		private const int GwHwndfirst = 0;
+		private const int GwHwndnext = 2;
+		private const int GwlStyle = -16;
+		private const int WsVisible = 268435456;
+		private const int WsBorder = 8388608;
+		private static readonly PerformanceCounter PcCpuLoad; //CPU计数器
+
+		private static readonly PerformanceCounter IOCounter;
+
+		private static readonly string[] InstanceNames = { };
+		private static readonly PerformanceCounter[] NetRecvCounters;
+		private static readonly PerformanceCounter[] NetSentCounters;
+		private static readonly Dictionary<string, dynamic> Cache = new();
+
+		public static bool IsWinPlatform => Environment.OSVersion.Platform is PlatformID.Win32Windows
+			or PlatformID.Win32S or PlatformID.WinCE or PlatformID.Win32NT;
+
+		#endregion 字段
+
+		#region 构造函数
+
+		/// <summary>
+		/// 静态构造函数
+		/// </summary>
+		static SystemInfo()
+		{
+			if (IsWinPlatform)
+			{
+				IOCounter = new PerformanceCounter();
+
+				//初始化CPU计数器
+				PcCpuLoad = new PerformanceCounter("Processor", "% Processor Time", "_Total")
+				{
+					MachineName = "."
+				};
+				PcCpuLoad.NextValue();
+
+				//获得物理内存
+				try
+				{
+					using var mc = new ManagementClass("Win32_ComputerSystem");
+					using var moc = mc.GetInstances();
+					foreach (var mo in moc)
+					{
+						using (mo)
+						{
+							if (mo["TotalPhysicalMemory"] != null)
+							{
+								PhysicalMemory = mo["TotalPhysicalMemory"].ChangeTypeTo<long>();
+							}
+						}
+					}
+
+					var cat = new PerformanceCounterCategory("Network Interface");
+					InstanceNames = cat.GetInstanceNames();
+					NetRecvCounters = new PerformanceCounter[InstanceNames.Length];
+					NetSentCounters = new PerformanceCounter[InstanceNames.Length];
+					for (int i = 0; i < InstanceNames.Length; i++)
+					{
+						NetRecvCounters[i] = new PerformanceCounter();
+						NetSentCounters[i] = new PerformanceCounter();
+					}
+
+					CompactFormat = false;
+				}
+				catch (Exception e)
+				{
+					LogManager.Error(e);
+				}
+			}
+
+			//CPU个数
+			ProcessorCount = Environment.ProcessorCount;
+		}
+
+		#endregion 构造函数
+
+		private static bool CompactFormat { get; set; }
+
+		#region CPU相关
+
+		/// <summary>
+		/// 获取CPU核心数
+		/// </summary>
+		public static int ProcessorCount { get; }
+
+		/// <summary>
+		/// 获取CPU占用率 %
+		/// </summary>
+		public static float CpuLoad => PcCpuLoad?.NextValue() ?? 0;
+
+		/// <summary>
+		/// 获取当前进程的CPU使用率(至少需要0.5s)
+		/// </summary>
+		/// <returns></returns>
+		public static async Task<double> GetCpuUsageForProcess()
+		{
+			var startTime = DateTime.UtcNow;
+			using var p1 = Process.GetCurrentProcess();
+			var startCpuUsage = p1.TotalProcessorTime;
+			await Task.Delay(500);
+			var endTime = DateTime.UtcNow;
+			using var p2 = Process.GetCurrentProcess();
+			var endCpuUsage = p2.TotalProcessorTime;
+			var cpuUsedMs = (endCpuUsage - startCpuUsage).TotalMilliseconds;
+			var totalMsPassed = (endTime - startTime).TotalMilliseconds;
+			return cpuUsedMs / (Environment.ProcessorCount * totalMsPassed) * 100;
+		}
+
+		/// <summary>
+		/// WMI接口获取CPU使用率
+		/// </summary>
+		/// <returns></returns>
+		public static string GetProcessorData()
+		{
+			var d = GetCounterValue(IOCounter, "Processor", "% Processor Time", "_Total");
+			return CompactFormat ? (int)d + "%" : d.ToString("F") + "%";
+		}
+
+		/// <summary>
+		/// 获取CPU温度
+		/// </summary>
+		/// <returns>CPU温度</returns>
+		public static float GetCPUTemperature()
+		{
+			if (!IsWinPlatform) return 0;
+
+			try
+			{
+				using var mos = new ManagementObjectSearcher(@"root\WMI", "select * from MSAcpi_ThermalZoneTemperature");
+				using var moc = mos.Get();
+				foreach (var mo in moc)
+				{
+					using (mo)
+					{
+						//这就是CPU的温度了
+						var temp = (mo["CurrentTemperature"].ChangeTypeTo<float>() - 2732) / 10;
+						return (float)Math.Round(temp, 2);
+					}
+				}
+				return 0;
+			}
+			catch (Exception)
+			{
+				return -1;
+			}
+		}
+
+		/// <summary>
+		/// 获取CPU的数量
+		/// </summary>
+		/// <returns>CPU的数量</returns>
+		public static int GetCpuCount()
+		{
+			try
+			{
+				return Cache.GetOrAdd(nameof(GetCpuCount), () =>
+				{
+					if (!IsWinPlatform)
+					{
+						return Environment.ProcessorCount;
+					}
+
+					using var m = new ManagementClass("Win32_Processor");
+					using var moc = m.GetInstances();
+					return moc.Count;
+				});
+			}
+			catch (Exception)
+			{
+				return -1;
+			}
+		}
+
+		private static readonly Lazy<List<ManagementBaseObject>> CpuObjects = new(() =>
+		{
+			using var mos = new ManagementObjectSearcher("SELECT * FROM Win32_Processor");
+			using var moc = mos.Get();
+			return moc.AsParallel().Cast<ManagementBaseObject>().ToList();
+		});
+
+		/// <summary>
+		/// 获取CPU信息
+		/// </summary>
+		/// <returns>CPU信息</returns>
+		public static List<CpuInfo> GetCpuInfo()
+		{
+			try
+			{
+				if (!IsWinPlatform) return [];
+				return CpuObjects.Value.Select(mo => new CpuInfo
+				{
+					NumberOfLogicalProcessors = ProcessorCount,
+					CurrentClockSpeed = mo["CurrentClockSpeed"].ToString(),
+					Manufacturer = mo["Manufacturer"].ToString(),
+					MaxClockSpeed = mo["MaxClockSpeed"].ToString(),
+					Type = mo["Name"].ToString(),
+					DataWidth = mo["DataWidth"].ToString(),
+					SerialNumber = mo["ProcessorId"].ToString(),
+					DeviceID = mo["DeviceID"].ToString(),
+					NumberOfCores = mo["NumberOfCores"].ChangeTypeTo<int>()
+				}).ToList();
+			}
+			catch (Exception)
+			{
+				return [];
+			}
+		}
+
+		#endregion CPU相关
+
+		#region 内存相关
+
+		/// <summary>
+		/// 获取可用内存
+		/// </summary>
+		public static long MemoryAvailable
+		{
+			get
+			{
+				if (!IsWinPlatform) return 0;
+
+				try
+				{
+					using var mc = new ManagementClass("Win32_OperatingSystem");
+					using var moc = mc.GetInstances();
+					foreach (var mo in moc)
+					{
+						using (mo)
+						{
+							if (mo["FreePhysicalMemory"] != null)
+							{
+								return 1024 * mo["FreePhysicalMemory"].ChangeTypeTo<long>();
+							}
+						}
+					}
+
+					return 0;
+				}
+				catch (Exception)
+				{
+					return -1;
+				}
+			}
+		}
+
+		/// <summary>
+		/// 获取物理内存
+		/// </summary>
+		public static long PhysicalMemory { get; }
+
+		public static long CurrentProcessMemory
+		{
+			get
+			{
+				if (!IsWinPlatform) return 0;
+				using var process = Process.GetCurrentProcess();
+				return (long)GetCounterValue(IOCounter, "Process", "Working Set - Private", process.ProcessName);
+			}
+		}
+
+		/// <summary>
+		/// 获取内存信息
+		/// </summary>
+		/// <returns>内存信息</returns>
+		public static RamInfo GetRamInfo()
+		{
+			return new RamInfo
+			{
+				MemoryAvailable = GetFreePhysicalMemory(),
+				PhysicalMemory = GetTotalPhysicalMemory(),
+				TotalPageFile = GetTotalVirtualMemory(),
+				AvailablePageFile = GetTotalVirtualMemory() - GetUsedVirtualMemory(),
+				AvailableVirtual = 1 - GetUsageVirtualMemory(),
+				TotalVirtual = 1 - GetUsedPhysicalMemory()
+			};
+		}
+
+		/// <summary>
+		/// 获取虚拟内存使用率详情
+		/// </summary>
+		/// <returns></returns>
+		public static string GetMemoryVData()
+		{
+			if (!IsWinPlatform) return "";
+			float d = GetCounterValue(IOCounter, "Memory", "% Committed Bytes In Use", null);
+			var str = d.ToString("F") + "% (";
+			d = GetCounterValue(IOCounter, "Memory", "Committed Bytes", null);
+			str += FormatBytes(d) + " / ";
+			d = GetCounterValue(IOCounter, "Memory", "Commit Limit", null);
+			return str + FormatBytes(d) + ") ";
+		}
+
+		/// <summary>
+		/// 获取虚拟内存使用率
+		/// </summary>
+		/// <returns></returns>
+		public static float GetUsageVirtualMemory()
+		{
+			if (!IsWinPlatform) return 0;
+			return GetCounterValue(IOCounter, "Memory", "% Committed Bytes In Use", null);
+		}
+
+		/// <summary>
+		/// 获取虚拟内存已用大小
+		/// </summary>
+		/// <returns></returns>
+		public static float GetUsedVirtualMemory()
+		{
+			if (!IsWinPlatform) return 0;
+			return GetCounterValue(IOCounter, "Memory", "Committed Bytes", null);
+		}
+
+		/// <summary>
+		/// 获取虚拟内存总大小
+		/// </summary>
+		/// <returns></returns>
+		public static float GetTotalVirtualMemory()
+		{
+			if (!IsWinPlatform) return 0;
+			return GetCounterValue(IOCounter, "Memory", "Commit Limit", null);
+		}
+
+		/// <summary>
+		/// 获取物理内存使用率详情描述
+		/// </summary>
+		/// <returns></returns>
+		public static string GetMemoryPData()
+		{
+			if (!IsWinPlatform) return "";
+			string s = QueryComputerSystem("totalphysicalmemory");
+			if (string.IsNullOrEmpty(s)) return "";
+
+			var totalphysicalmemory = Convert.ToSingle(s);
+			var d = GetCounterValue(IOCounter, "Memory", "Available Bytes", null);
+			d = totalphysicalmemory - d;
+			s = CompactFormat ? "%" : "% (" + FormatBytes(d) + " / " + FormatBytes(totalphysicalmemory) + ")";
+			d /= totalphysicalmemory;
+			d *= 100;
+			return CompactFormat ? (int)d + s : d.ToString("F") + s;
+		}
+
+		/// <summary>
+		/// 获取物理内存总数,单位B
+		/// </summary>
+		/// <returns></returns>
+		public static float GetTotalPhysicalMemory()
+		{
+			return Cache.GetOrAdd(nameof(GetTotalPhysicalMemory), () =>
+			{
+				var s = QueryComputerSystem("totalphysicalmemory");
+				return s.TryConvertTo<float>();
+			});
+		}
+
+		/// <summary>
+		/// 获取空闲的物理内存数,单位B
+		/// </summary>
+		/// <returns></returns>
+		public static float GetFreePhysicalMemory()
+		{
+			if (!IsWinPlatform) return 0;
+			return GetCounterValue(IOCounter, "Memory", "Available Bytes", null);
+		}
+
+		/// <summary>
+		/// 获取已经使用了的物理内存数,单位B
+		/// </summary>
+		/// <returns></returns>
+		public static float GetUsedPhysicalMemory()
+		{
+			return GetTotalPhysicalMemory() - GetFreePhysicalMemory();
+		}
+
+		#endregion 内存相关
+
+		#region 硬盘相关
+
+		/// <summary>
+		/// 获取硬盘的读写速率
+		/// </summary>
+		/// <param name="dd">读或写</param>
+		/// <returns></returns>
+		public static float GetDiskData(DiskData dd)
+		{
+			if (!IsWinPlatform) return 0;
+			return dd switch
+			{
+				DiskData.Read => GetCounterValue(IOCounter, "PhysicalDisk", "Disk Read Bytes/sec", "_Total"),
+				DiskData.Write => GetCounterValue(IOCounter, "PhysicalDisk", "Disk Write Bytes/sec", "_Total"),
+				DiskData.ReadAndWrite => GetCounterValue(IOCounter, "PhysicalDisk", "Disk Read Bytes/sec", "_Total") + GetCounterValue(IOCounter, "PhysicalDisk", "Disk Write Bytes/sec", "_Total"),
+				_ => 0
+			};
+		}
+
+		private static List<DiskInfo> _diskInfos = [];
+
+		/// <summary>
+		/// 获取磁盘可用空间
+		/// </summary>
+		/// <returns></returns>
+		public static List<DiskInfo> GetDiskInfo()
+		{
+			try
+			{
+				if (!IsWinPlatform || _diskInfos.Count > 0)
+				{
+					return _diskInfos;
+				}
+
+				using var mc = new ManagementClass("Win32_DiskDrive");
+				using var moc = mc.GetInstances();
+				var list = new List<DiskInfo>();
+				foreach (var mo in moc)
+				{
+					using (mo)
+					{
+						list.Add(new DiskInfo()
+						{
+							Index = mo["Index"].ChangeTypeTo<int>(),
+							Total = mo["Size"].ChangeTypeTo<long>(),
+							Model = mo["Model"].ToString(),
+							MediaType = mo["MediaType"].ToString(),
+							SerialNumber = mo["SerialNumber"].ToString(),
+						});
+					}
+				}
+
+				_diskInfos = list.OrderBy(x => x.Index).ToList();
+				return _diskInfos;
+			}
+			catch (Exception)
+			{
+				return [];
+			}
+		}
+
+		#endregion 硬盘相关
+
+		#region 网络相关
+
+		/// <summary>
+		/// 获取网络的传输速率
+		/// </summary>
+		/// <param name="nd">上传或下载</param>
+		/// <returns></returns>
+		public static float GetNetData(NetData nd)
+		{
+			if (!IsWinPlatform) return 0;
+			if (InstanceNames is { Length: 0 }) return 0;
+
+			float d = 0;
+			for (int i = 0; i < InstanceNames.Length; i++)
+			{
+				float receied = GetCounterValue(NetRecvCounters[i], "Network Interface", "Bytes Received/sec", InstanceNames[i]);
+				float send = GetCounterValue(NetSentCounters[i], "Network Interface", "Bytes Sent/sec", InstanceNames[i]);
+				switch (nd)
+				{
+					case NetData.Received:
+						d += receied;
+						break;
+
+					case NetData.Sent:
+						d += send;
+						break;
+
+					case NetData.ReceivedAndSent:
+						d += receied + send;
+						break;
+
+					default:
+						d += 0;
+						break;
+				}
+			}
+
+			return d;
+		}
+
+		/// <summary>
+		/// 获取网卡硬件地址
+		/// </summary>
+		/// <returns></returns>
+		public static IEnumerable<PhysicalAddress> GetMacAddress()
+		{
+			return from adapter in NetworkInterface.GetAllNetworkInterfaces().Where(c => c.NetworkInterfaceType != NetworkInterfaceType.Loopback && c.OperationalStatus == OperationalStatus.Up)
+				   let properties = adapter.GetIPProperties()
+				   let unicastAddresses = properties.UnicastAddresses
+				   where unicastAddresses.Any(temp => temp.Address.AddressFamily == AddressFamily.InterNetwork)
+				   select adapter.GetPhysicalAddress() into address
+				   select address;
+		}
+
+		/// <summary>
+		/// 获取IP地址WMI
+		/// </summary>
+		/// <returns></returns>
+		public static string GetIPAddressWMI()
+		{
+			try
+			{
+				if (!IsWinPlatform) return "";
+
+				return Cache.GetOrAdd(nameof(GetIPAddressWMI), () =>
+				{
+					using var mc = new ManagementClass("Win32_NetworkAdapterConfiguration");
+					using var moc = mc.GetInstances();
+					foreach (var mo in moc)
+					{
+						if ((bool)mo["IPEnabled"])
+						{
+							return ((string[])mo["IpAddress"])[0];
+						}
+					}
+					return "";
+				});
+			}
+			catch (Exception e)
+			{
+				Console.WriteLine(e.Message);
+			}
+
+			return "";
+		}
+
+		/// <summary>
+		/// 获取当前使用的IP
+		/// </summary>
+		/// <returns></returns>
+		public static IPAddress GetLocalUsedIP()
+		{
+			return GetLocalUsedIP(AddressFamily.InterNetwork);
+		}
+
+		/// <summary>
+		/// 获取当前使用的IP
+		/// </summary>
+		/// <returns></returns>
+		public static IPAddress GetLocalUsedIP(AddressFamily family)
+		{
+			if (!IsWinPlatform) return default;
+
+			return NetworkInterface.GetAllNetworkInterfaces().Where(c => c.NetworkInterfaceType != NetworkInterfaceType.Loopback && c.OperationalStatus == OperationalStatus.Up).OrderByDescending(c => c.Speed).Select(t => t.GetIPProperties()).Where(p => p.DhcpServerAddresses.Count > 0).SelectMany(p => p.UnicastAddresses).Select(p => p.Address).FirstOrDefault(p => !(p.IsIPv6Teredo || p.IsIPv6LinkLocal || p.IsIPv6Multicast || p.IsIPv6SiteLocal) && p.AddressFamily == family);
+		}
+
+		/// <summary>
+		/// 获取本机所有的ip地址
+		/// </summary>
+		/// <returns></returns>
+		public static List<UnicastIPAddressInformation> GetLocalIPs()
+		{
+			var interfaces = NetworkInterface.GetAllNetworkInterfaces().Where(c => c.NetworkInterfaceType != NetworkInterfaceType.Loopback && c.OperationalStatus == OperationalStatus.Up).OrderByDescending(c => c.Speed); //所有网卡信息
+			return interfaces.SelectMany(n => n.GetIPProperties().UnicastAddresses).ToList();
+		}
+
+		/// <summary>
+		/// 获取网卡地址
+		/// </summary>
+		/// <returns></returns>
+		public static string GetNetworkCardAddress()
+		{
+			try
+			{
+				if (!IsWinPlatform) return "";
+
+				return Cache.GetOrAdd(nameof(GetNetworkCardAddress), () =>
+				{
+					using var mos = new ManagementObjectSearcher("select * from Win32_NetworkAdapter where ((MACAddress Is Not NULL) and (Manufacturer <> 'Microsoft'))");
+					using var moc = mos.Get();
+					foreach (var mo in moc)
+					{
+						return mo["MACAddress"].ToString().Trim();
+					}
+					return "";
+				});
+			}
+			catch (Exception e)
+			{
+				Console.WriteLine(e.Message);
+			}
+
+			return "";
+		}
+
+		#endregion 网络相关
+
+		#region 系统相关
+
+		/// <summary>
+		/// 获取计算机开机时间
+		/// </summary>
+		/// <returns>datetime</returns>
+		public static DateTime BootTime()
+		{
+			if (!IsWinPlatform) return default;
+
+			var query = new SelectQuery("SELECT LastBootUpTime FROM Win32_OperatingSystem WHERE Primary='true'");
+			using var searcher = new ManagementObjectSearcher(query);
+			using var moc = searcher.Get();
+			foreach (var mo in moc)
+			{
+				using (mo)
+				{
+					return ManagementDateTimeConverter.ToDateTime(mo["LastBootUpTime"].ToString());
+				}
+			}
+
+			return DateTime.Now - TimeSpan.FromMilliseconds(Environment.TickCount & int.MaxValue);
+		}
+
+		/// <summary>
+		/// 查询计算机系统信息
+		/// </summary>
+		/// <param name="type">类型名</param>
+		/// <returns></returns>
+		public static string QueryComputerSystem(string type)
+		{
+			try
+			{
+				if (!IsWinPlatform) return string.Empty;
+
+				var mos = new ManagementObjectSearcher("SELECT * FROM Win32_ComputerSystem");
+				using var moc = mos.Get();
+				foreach (var mo in moc)
+				{
+					using (mo)
+					{
+						return mo[type].ToString();
+					}
+				}
+			}
+			catch (Exception e)
+			{
+				return "未能获取到当前计算机系统信息,可能是当前程序无管理员权限,如果是web应用程序,请将应用程序池的高级设置中的进程模型下的标识设置为:LocalSystem;如果是普通桌面应用程序,请提升管理员权限后再操作。异常信息:" + e.Message;
+			}
+			return string.Empty;
+		}
+
+		/// <summary>
+		/// 查找所有应用程序标题
+		/// </summary>
+		/// <param name="handle">应用程序标题范型</param>
+		/// <returns>所有应用程序集合</returns>
+		public static List<string> FindAllApps(int handle)
+		{
+			if (!IsWinPlatform) return new List<string>(0);
+
+			var apps = new List<string>();
+			int hwCurr = GetWindow(handle, GwHwndfirst);
+			while (hwCurr > 0)
+			{
+				int IsTask = WsVisible | WsBorder;
+				int lngStyle = GetWindowLongA(hwCurr, GwlStyle);
+				bool taskWindow = (lngStyle & IsTask) == IsTask;
+				if (taskWindow)
+				{
+					int length = GetWindowTextLength(new IntPtr(hwCurr));
+					var sb = new StringBuilder(2 * length + 1);
+					GetWindowText(hwCurr, sb, sb.Capacity);
+					string strTitle = sb.ToString();
+					if (!string.IsNullOrEmpty(strTitle))
+					{
+						apps.Add(strTitle);
+					}
+				}
+
+				hwCurr = GetWindow(hwCurr, GwHwndnext);
+			}
+
+			return apps;
+		}
+
+		/// <summary>
+		/// 操作系统类型
+		/// </summary>
+		/// <returns></returns>
+		public static string GetSystemType()
+		{
+			try
+			{
+				return Cache.GetOrAdd(nameof(GetSystemType), () =>
+				{
+					if (!IsWinPlatform)
+					{
+						return Environment.OSVersion.Platform.ToString();
+					}
+
+					using var mc = new ManagementClass("Win32_ComputerSystem");
+					using var moc = mc.GetInstances();
+					foreach (var mo in moc)
+					{
+						return mo["SystemType"].ToString().Trim();
+					}
+					return "";
+				});
+			}
+			catch (Exception e)
+			{
+				Console.WriteLine(e.Message);
+			}
+
+			return "";
+		}
+
+		#endregion 系统相关
+
+		#region 主板相关
+
+		/// <summary>
+		/// 获取主板序列号
+		/// </summary>
+		/// <returns></returns>
+		public static string GetBiosSerialNumber()
+		{
+			try
+			{
+				if (!IsWinPlatform) return "";
+
+				return Cache.GetOrAdd(nameof(GetBiosSerialNumber), () =>
+				{
+					using var searcher = new ManagementObjectSearcher("select * from Win32_BIOS");
+					using var mos = searcher.Get();
+					foreach (var mo in mos)
+					{
+						return mo["SerialNumber"].ToString().Trim();
+					}
+					return "";
+				});
+			}
+			catch (Exception e)
+			{
+				Console.WriteLine(e.Message);
+			}
+
+			return "";
+		}
+
+		/// <summary>
+		/// 主板编号
+		/// </summary>
+		/// <returns></returns>
+		public static BiosInfo GetBiosInfo()
+		{
+			if (!IsWinPlatform) return new BiosInfo();
+
+			return Cache.GetOrAdd(nameof(GetBiosInfo), () =>
+			{
+				using var searcher = new ManagementObjectSearcher("select * from Win32_BaseBoard");
+				using var mos = searcher.Get();
+				using var reg = RegistryKey.OpenBaseKey(RegistryHive.LocalMachine, RegistryView.Registry64);
+				using var guidKey = reg.OpenSubKey(@"SOFTWARE\Microsoft\Cryptography");
+				using var uuidKey = reg.OpenSubKey(@"SYSTEM\HardwareConfig");
+				string guid = null;
+				string uuid = null;
+				string model = null;
+				if (guidKey != null) guid = guidKey.GetValue("MachineGuid") + "";
+				if (uuidKey != null) uuid = (uuidKey.GetValue("LastConfig") + "").Trim('{', '}').ToUpper();
+				var biosKey = Registry.LocalMachine.OpenSubKey(@"HARDWARE\DESCRIPTION\System\BIOS");
+				biosKey ??= Registry.LocalMachine.OpenSubKey(@"SYSTEM\HardwareConfig\Current");
+				if (biosKey != null)
+				{
+					model = (biosKey.GetValue("SystemProductName") + "").Replace("System Product Name", null);
+					if (model.IsNullOrEmpty()) model = biosKey.GetValue("BaseBoardProduct") + "";
+					biosKey.Dispose();
+				}
+				foreach (var mo in mos)
+				{
+					return new BiosInfo
+					{
+						Manufacturer = mo["Manufacturer"].ToString(),
+						ID = mo["SerialNumber"].ToString(),
+						Model = model,
+						SerialNumber = GetBiosSerialNumber(),
+						Guid = guid,
+						UUID = uuid
+					};
+				}
+
+				return new BiosInfo();
+			});
+		}
+
+		#endregion 主板相关
+
+		#region 公共函数
+
+		/// <summary>
+		/// 将速度值格式化成字节单位
+		/// </summary>
+		/// <param name="bytes"></param>
+		/// <returns></returns>
+		public static string FormatBytes(this double bytes)
+		{
+			int unit = 0;
+			while (bytes > 1024)
+			{
+				bytes /= 1024;
+				++unit;
+			}
+
+			string s = CompactFormat ? ((int)bytes).ToString() : bytes.ToString("F") + " ";
+			return s + (Unit)unit;
+		}
+
+		private static float GetCounterValue(PerformanceCounter pc, string categoryName, string counterName, string instanceName)
+		{
+			if (!IsWinPlatform) return 0;
+
+			pc.CategoryName = categoryName;
+			pc.CounterName = counterName;
+			pc.InstanceName = instanceName;
+			return pc.NextValue();
+		}
+
+		#endregion 公共函数
+
+		#region Win32API声明
 
 #pragma warning disable 1591
 
-        [DllImport("User32")]
-        public static extern int GetWindow(int hWnd, int wCmd);
+		[DllImport("User32")]
+		public static extern int GetWindow(int hWnd, int wCmd);
 
-        [DllImport("User32")]
-        public static extern int GetWindowLongA(int hWnd, int wIndx);
+		[DllImport("User32")]
+		public static extern int GetWindowLongA(int hWnd, int wIndx);
 
-        [DllImport("user32.dll")]
-        public static extern bool GetWindowText(int hWnd, StringBuilder title, int maxBufSize);
+		[DllImport("user32.dll")]
+		public static extern bool GetWindowText(int hWnd, StringBuilder title, int maxBufSize);
 
-        [DllImport("user32", CharSet = CharSet.Auto)]
-        public static extern int GetWindowTextLength(IntPtr hWnd);
+		[DllImport("user32", CharSet = CharSet.Auto)]
+		public static extern int GetWindowTextLength(IntPtr hWnd);
 
 #pragma warning restore 1591
 
-        #endregion Win32API声明
-    }
+		#endregion Win32API声明
+	}
 }

+ 3 - 3
Masuit.Tools.Abstractions/Masuit.Tools.Abstractions.csproj

@@ -79,17 +79,17 @@
 
     <ItemGroup Condition=" '$(TargetFramework)' == 'net6'">
         <PackageReference Include="System.Diagnostics.PerformanceCounter" Version="7.0.0" />
-        <PackageReference Include="SixLabors.ImageSharp.Drawing" Version="2.1.3" />
+        <PackageReference Include="SixLabors.ImageSharp.Drawing" Version="2.1.4" />
     </ItemGroup>
 
     <ItemGroup Condition=" '$(TargetFramework)' == 'net7'">
         <PackageReference Include="System.Diagnostics.PerformanceCounter" Version="7.0.0" />
-        <PackageReference Include="SixLabors.ImageSharp.Drawing" Version="2.1.3" />
+        <PackageReference Include="SixLabors.ImageSharp.Drawing" Version="2.1.4" />
     </ItemGroup>
 
     <ItemGroup Condition=" '$(TargetFramework)' == 'net8'">
         <PackageReference Include="System.Diagnostics.PerformanceCounter" Version="8.0.0" />
-        <PackageReference Include="SixLabors.ImageSharp.Drawing" Version="2.1.3" />
+        <PackageReference Include="SixLabors.ImageSharp.Drawing" Version="2.1.4" />
     </ItemGroup>
 
     <ItemGroup Condition=" '$(TargetFramework)' == 'net461' ">

+ 562 - 465
Masuit.Tools.Core/Database/DbContextExt.cs

@@ -4,473 +4,570 @@ using System.Linq.Expressions;
 using System.Text;
 using System.Transactions;
 using Masuit.Tools.Systems;
+using Masuit.Tools.Reflection;
+using Microsoft.EntityFrameworkCore.Query.Internal;
+using Microsoft.EntityFrameworkCore.Query;
 
 namespace Masuit.Tools.Core;
 
 public static class DbContextExt
 {
-    /// <summary>
-    /// 获取变化的实体信息
-    /// </summary>
-    /// <typeparam name="T"></typeparam>
-    /// <param name="db"></param>
-    /// <returns></returns>
-    public static IEnumerable<ChangeEntry<T>> GetChanges<T>(this DbContext db)
-    {
-        return db.ChangeTracker.Entries().Where(e => e is { State: EntityState.Modified, Entity: T }).Select(e =>
-        {
-            NullableDictionary<string, object> originalObject = e.OriginalValues.ToObject() as Dictionary<string, object> ?? new NullableDictionary<string, object>();
-            NullableDictionary<string, object> currentObject = e.CurrentValues.ToObject() as Dictionary<string, object> ?? new NullableDictionary<string, object>();
-            return new ChangeEntry<T>
-            {
-                EntityState = e.State,
-                Entity = (T)e.Entity,
-                EntityType = e.OriginalValues.EntityType.ClrType,
-                ChangeProperties = e.OriginalValues.Properties.Select(p => (Property: p, Value: originalObject[p.PropertyInfo?.Name])).Zip(e.CurrentValues.Properties.Select(p => (Property: p, Value: currentObject[p.PropertyInfo?.Name])), (t1, t2) => new ChangePropertyInfo
-                {
-                    PropertyInfo = t1.Property.PropertyInfo,
-                    OriginalValue = t1.Value,
-                    CurrentValue = t2.Value,
-                    IsPrimaryKey = t1.Property.IsPrimaryKey(),
-                    IsForeignKey = t1.Property.IsForeignKey()
-                }).Where(t => Comparer.Default.Compare(t.OriginalValue, t.CurrentValue) != 0).ToList()
-            };
-        });
-    }
-
-    /// <summary>
-    /// 获取变化的实体信息
-    /// </summary>
-    /// <param name="db"></param>
-    /// <returns></returns>
-    public static IEnumerable<ChangeEntry> GetChanges(this DbContext db)
-    {
-        return db.ChangeTracker.Entries().Where(e => e.State == EntityState.Modified).Select(e =>
-        {
-            NullableDictionary<string, object> originalObject = e.OriginalValues.ToObject() as Dictionary<string, object> ?? new NullableDictionary<string, object>();
-            NullableDictionary<string, object> currentObject = e.CurrentValues.ToObject() as Dictionary<string, object> ?? new NullableDictionary<string, object>();
-            return new ChangeEntry
-            {
-                EntityState = e.State,
-                Entity = e.Entity,
-                EntityType = e.OriginalValues.EntityType.ClrType,
-                ChangeProperties = e.OriginalValues.Properties.Select(p => (Property: p, Value: originalObject[p.PropertyInfo?.Name])).Zip(e.CurrentValues.Properties.Select(p => (Property: p, Value: currentObject[p.PropertyInfo?.Name])), (t1, t2) => new ChangePropertyInfo
-                {
-                    PropertyInfo = t1.Property.PropertyInfo,
-                    OriginalValue = t1.Value,
-                    CurrentValue = t2.Value,
-                    IsPrimaryKey = t1.Property.IsPrimaryKey(),
-                    IsForeignKey = t1.Property.IsForeignKey()
-                }).Where(t => Comparer.Default.Compare(t.OriginalValue, t.CurrentValue) != 0).ToList()
-            };
-        });
-    }
-
-    /// <summary>
-    /// 获取添加的实体信息
-    /// </summary>
-    /// <typeparam name="T"></typeparam>
-    /// <param name="db"></param>
-    /// <returns></returns>
-    public static IEnumerable<ChangeEntry<T>> GetAdded<T>(this DbContext db)
-    {
-        return db.ChangeTracker.Entries().Where(e => e.State == EntityState.Added && e.Entity is T).Select(e =>
-        {
-            NullableDictionary<string, object> currentObject = e.CurrentValues.ToObject() as Dictionary<string, object> ?? new NullableDictionary<string, object>();
-            return new ChangeEntry<T>
-            {
-                EntityState = e.State,
-                Entity = (T)e.Entity,
-                EntityType = e.CurrentValues.EntityType.ClrType,
-                ChangeProperties = e.CurrentValues.Properties.Select(p => new ChangePropertyInfo()
-                {
-                    PropertyInfo = p.PropertyInfo,
-                    CurrentValue = currentObject[p.PropertyInfo?.Name],
-                    IsPrimaryKey = p.IsPrimaryKey(),
-                    IsForeignKey = p.IsForeignKey(),
-                }).ToList()
-            };
-        });
-    }
-
-    /// <summary>
-    /// 获取添加的实体信息
-    /// </summary>
-    /// <param name="db"></param>
-    /// <returns></returns>
-    public static IEnumerable<ChangeEntry> GetAdded(this DbContext db)
-    {
-        return db.ChangeTracker.Entries().Where(e => e.State == EntityState.Added).Select(e =>
-        {
-            NullableDictionary<string, object> currentObject = e.CurrentValues.ToObject() as Dictionary<string, object> ?? new NullableDictionary<string, object>();
-            return new ChangeEntry
-            {
-                EntityState = e.State,
-                Entity = e.Entity,
-                EntityType = e.CurrentValues.EntityType.ClrType,
-                ChangeProperties = e.CurrentValues.Properties.Select(p => new ChangePropertyInfo
-                {
-                    PropertyInfo = p.PropertyInfo,
-                    CurrentValue = currentObject[p.PropertyInfo?.Name],
-                    IsPrimaryKey = p.IsPrimaryKey(),
-                    IsForeignKey = p.IsForeignKey(),
-                }).ToList()
-            };
-        });
-    }
-
-    /// <summary>
-    /// 获取移除的实体信息
-    /// </summary>
-    /// <typeparam name="T"></typeparam>
-    /// <param name="db"></param>
-    /// <returns></returns>
-    public static IEnumerable<ChangeEntry<T>> GetRemoved<T>(this DbContext db)
-    {
-        return db.ChangeTracker.Entries().Where(e => e.State == EntityState.Deleted && e.Entity is T).Select(e =>
-        {
-            NullableDictionary<string, object> originalObject = e.OriginalValues.ToObject() as Dictionary<string, object> ?? new NullableDictionary<string, object>();
-            return new ChangeEntry<T>
-            {
-                EntityState = e.State,
-                Entity = (T)e.Entity,
-                EntityType = e.OriginalValues.EntityType.ClrType,
-                ChangeProperties = e.OriginalValues.Properties.Select(p => new ChangePropertyInfo
-                {
-                    PropertyInfo = p.PropertyInfo,
-                    OriginalValue = originalObject[p.PropertyInfo?.Name],
-                    IsPrimaryKey = p.IsPrimaryKey(),
-                    IsForeignKey = p.IsForeignKey(),
-                }).ToList()
-            };
-        });
-    }
-
-    /// <summary>
-    /// 获取移除的实体信息
-    /// </summary>
-    /// <param name="db"></param>
-    /// <returns></returns>
-    public static IEnumerable<ChangeEntry> GetRemoved(this DbContext db)
-    {
-        return db.ChangeTracker.Entries().Where(e => e.State == EntityState.Deleted).Select(e =>
-        {
-            NullableDictionary<string, object> originalObject = e.OriginalValues.ToObject() as Dictionary<string, object> ?? new NullableDictionary<string, object>();
-            return new ChangeEntry
-            {
-                EntityState = e.State,
-                Entity = e.Entity,
-                EntityType = e.OriginalValues.EntityType.ClrType,
-                ChangeProperties = e.OriginalValues.Properties.Select(p => new ChangePropertyInfo
-                {
-                    PropertyInfo = p.PropertyInfo,
-                    OriginalValue = originalObject[p.PropertyInfo?.Name],
-                    IsPrimaryKey = p.IsPrimaryKey(),
-                    IsForeignKey = p.IsForeignKey(),
-                }).ToList()
-            };
-        });
-    }
-
-    /// <summary>
-    /// 获取所有的变更信息
-    /// </summary>
-    /// <typeparam name="T"></typeparam>
-    /// <param name="db"></param>
-    /// <returns></returns>
-    public static IEnumerable<ChangeEntry<T>> GetAllChanges<T>(this DbContext db)
-    {
-        return GetChanges<T>(db).Union(GetAdded<T>(db)).Union(GetRemoved<T>(db));
-    }
-
-    /// <summary>
-    /// 获取所有的变更信息
-    /// </summary>
-    /// <param name="db"></param>
-    /// <returns></returns>
-    public static IEnumerable<ChangeEntry> GetAllChanges(this DbContext db)
-    {
-        return GetChanges(db).Union(GetAdded(db)).Union(GetRemoved(db));
-    }
-
-    public static IQueryable<TEntity> IncludeRecursive<TEntity>(this IQueryable<TEntity> source, int levelIndex, Expression<Func<TEntity, ICollection<TEntity>>> expression) where TEntity : class
-    {
-        if (levelIndex < 0)
-            throw new ArgumentOutOfRangeException(nameof(levelIndex));
-        var member = (MemberExpression)expression.Body;
-        var property = member.Member.Name;
-        var sb = new StringBuilder();
-        for (int i = 0; i < levelIndex; i++)
-        {
-            if (i > 0)
-                sb.Append(Type.Delimiter);
-            sb.Append(property);
-        }
-
-        return source.Include(sb.ToString());
-    }
-
-    public static async Task<List<T>> ToListWithNoLockAsync<T>(this IQueryable<T> query, CancellationToken cancellationToken = default)
-    {
-        using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
-        {
-            IsolationLevel = IsolationLevel.ReadUncommitted
-        }, TransactionScopeAsyncFlowOption.Enabled);
-        var result = await query.ToListAsync(cancellationToken);
-        scope.Complete();
-        return result;
-    }
-
-    public static List<T> ToListWithNoLock<T>(this IQueryable<T> query)
-    {
-        using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
-        {
-            IsolationLevel = IsolationLevel.ReadUncommitted
-        }, TransactionScopeAsyncFlowOption.Enabled);
-        var result = query.ToList();
-        scope.Complete();
-        return result;
-    }
-
-    public static async Task<int> CountWithNoLockAsync<T>(this IQueryable<T> query, CancellationToken cancellationToken = default)
-    {
-        using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
-        {
-            IsolationLevel = IsolationLevel.ReadUncommitted
-        }, TransactionScopeAsyncFlowOption.Enabled);
-        var result = await query.CountAsync(cancellationToken);
-        scope.Complete();
-        return result;
-    }
-
-    public static int CountWithNoLock<T>(this IQueryable<T> query)
-    {
-        using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
-        {
-            IsolationLevel = IsolationLevel.ReadUncommitted
-        }, TransactionScopeAsyncFlowOption.Enabled);
-        var result = query.Count();
-        scope.Complete();
-        return result;
-    }
-
-    public static async Task<int> CountWithNoLockAsync<T>(this IQueryable<T> query, Expression<Func<T, bool>> where, CancellationToken cancellationToken = default)
-    {
-        using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
-        {
-            IsolationLevel = IsolationLevel.ReadUncommitted
-        }, TransactionScopeAsyncFlowOption.Enabled);
-        var result = await query.CountAsync(where, cancellationToken);
-        scope.Complete();
-        return result;
-    }
-
-    public static int CountWithNoLock<T>(this IQueryable<T> query, Expression<Func<T, bool>> where)
-    {
-        using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
-        {
-            IsolationLevel = IsolationLevel.ReadUncommitted
-        }, TransactionScopeAsyncFlowOption.Enabled);
-        var result = query.Count(where);
-        scope.Complete();
-        return result;
-    }
-
-    public static async Task<bool> AnyWithNoLockAsync<T>(this IQueryable<T> query, CancellationToken cancellationToken = default)
-    {
-        using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
-        {
-            IsolationLevel = IsolationLevel.ReadUncommitted
-        }, TransactionScopeAsyncFlowOption.Enabled);
-        var result = await query.AnyAsync(cancellationToken);
-        scope.Complete();
-        return result;
-    }
-
-    public static bool AnyWithNoLock<T>(this IQueryable<T> query)
-    {
-        using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
-        {
-            IsolationLevel = IsolationLevel.ReadUncommitted
-        }, TransactionScopeAsyncFlowOption.Enabled);
-        var result = query.Any();
-        scope.Complete();
-        return result;
-    }
-
-    public static async Task<bool> AnyWithNoLockAsync<T>(this IQueryable<T> query, Expression<Func<T, bool>> where, CancellationToken cancellationToken = default)
-    {
-        using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
-        {
-            IsolationLevel = IsolationLevel.ReadUncommitted
-        }, TransactionScopeAsyncFlowOption.Enabled);
-        var result = await query.AnyAsync(where, cancellationToken);
-        scope.Complete();
-        return result;
-    }
-
-    public static bool AnyWithNoLock<T>(this IQueryable<T> query, Expression<Func<T, bool>> where)
-    {
-        using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
-        {
-            IsolationLevel = IsolationLevel.ReadUncommitted
-        }, TransactionScopeAsyncFlowOption.Enabled);
-        var result = query.Any(where);
-        scope.Complete();
-        return result;
-    }
-
-    public static async Task<T> FirstOrDefaultWithNoLockAsync<T>(this IQueryable<T> query, Expression<Func<T, bool>> where, CancellationToken cancellationToken = default)
-    {
-        using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
-        {
-            IsolationLevel = IsolationLevel.ReadUncommitted
-        }, TransactionScopeAsyncFlowOption.Enabled);
-        var result = await query.FirstOrDefaultAsync(where, cancellationToken);
-        scope.Complete();
-        return result;
-    }
-
-    public static T FirstOrDefaultWithNoLock<T>(this IQueryable<T> query, Expression<Func<T, bool>> where)
-    {
-        using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
-        {
-            IsolationLevel = IsolationLevel.ReadUncommitted
-        }, TransactionScopeAsyncFlowOption.Enabled);
-        var result = query.FirstOrDefault(where);
-        scope.Complete();
-        return result;
-    }
-
-    public static async Task<T> FirstOrDefaultWithNoLockAsync<T>(this IQueryable<T> query, CancellationToken cancellationToken = default)
-    {
-        using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions
-        {
-            IsolationLevel = IsolationLevel.ReadUncommitted
-        }, TransactionScopeAsyncFlowOption.Enabled);
-        var result = await query.FirstOrDefaultAsync(cancellationToken);
-        scope.Complete();
-        return result;
-    }
-
-    public static T FirstOrDefaultWithNoLock<T>(this IQueryable<T> query)
-    {
-        using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions
-        {
-            IsolationLevel = IsolationLevel.ReadUncommitted
-        }, TransactionScopeAsyncFlowOption.Enabled);
-        var result = query.FirstOrDefault();
-        scope.Complete();
-        return result;
-    }
-
-    public static async Task<T> SingleOrDefaultWithNoLockAsync<T>(this IQueryable<T> query, Expression<Func<T, bool>> where, CancellationToken cancellationToken = default)
-    {
-        using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions
-        {
-            IsolationLevel = IsolationLevel.ReadUncommitted
-        }, TransactionScopeAsyncFlowOption.Enabled);
-        var result = await query.SingleOrDefaultAsync(where, cancellationToken);
-        scope.Complete();
-        return result;
-    }
-
-    public static T SingleOrDefaultWithNoLock<T>(this IQueryable<T> query, Expression<Func<T, bool>> where)
-    {
-        using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
-        {
-            IsolationLevel = IsolationLevel.ReadUncommitted
-        }, TransactionScopeAsyncFlowOption.Enabled);
-        var result = query.SingleOrDefault(where);
-        scope.Complete();
-        return result;
-    }
-
-    public static async Task<T> SingleOrDefaultWithNoLockAsync<T>(this IQueryable<T> query, CancellationToken cancellationToken = default)
-    {
-        using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
-        {
-            IsolationLevel = IsolationLevel.ReadUncommitted
-        }, TransactionScopeAsyncFlowOption.Enabled);
-        var result = await query.SingleOrDefaultAsync(cancellationToken);
-        scope.Complete();
-        return result;
-    }
-
-    public static T SingleOrDefaultWithNoLock<T>(this IQueryable<T> query)
-    {
-        using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
-        {
-            IsolationLevel = IsolationLevel.ReadUncommitted
-        }, TransactionScopeAsyncFlowOption.Enabled);
-        var result = query.SingleOrDefault();
-        scope.Complete();
-        return result;
-    }
-
-    public static async Task<bool> AllWithNoLockAsync<T>(this IQueryable<T> query, Expression<Func<T, bool>> where, CancellationToken cancellationToken = default)
-    {
-        using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
-        {
-            IsolationLevel = IsolationLevel.ReadUncommitted
-        }, TransactionScopeAsyncFlowOption.Enabled);
-        var result = await query.AllAsync(where, cancellationToken);
-        scope.Complete();
-        return result;
-    }
-
-    public static bool AllWithNoLock<T>(this IQueryable<T> query, Expression<Func<T, bool>> where)
-    {
-        using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
-        {
-            IsolationLevel = IsolationLevel.ReadUncommitted
-        }, TransactionScopeAsyncFlowOption.Enabled);
-        var result = query.All(where);
-        scope.Complete();
-        return result;
-    }
-
-    public static T NoLock<T, TDbContext>(this TDbContext dbContext, Func<TDbContext, T> func) where TDbContext : DbContext
-    {
-        var strategy = dbContext.Database.CreateExecutionStrategy();
-        return strategy.Execute(() =>
-        {
-            var transactionOptions = new TransactionOptions
-            {
-                IsolationLevel = IsolationLevel.ReadUncommitted
-            };
-            using var scope = new TransactionScope(TransactionScopeOption.Required, transactionOptions);
-            var result = func(dbContext);
-            scope.Complete();
-            return result;
-        });
-    }
-
-    public static Task<T> NoLock<T, TDbContext>(this TDbContext dbContext, Func<TDbContext, Task<T>> func) where TDbContext : DbContext
-    {
-        var strategy = dbContext.Database.CreateExecutionStrategy();
-        return strategy.ExecuteAsync(async () =>
-        {
-            var transactionOptions = new TransactionOptions
-            {
-                IsolationLevel = IsolationLevel.ReadUncommitted
-            };
-            using var scope = new TransactionScope(TransactionScopeOption.Required, transactionOptions);
-            var result = await func(dbContext);
-            scope.Complete();
-            return result;
-        });
-    }
-
-    public static T ExecutionStrategy<T, TDbContext>(this TDbContext dbContext, Func<TDbContext, T> func) where TDbContext : DbContext
-    {
-        var strategy = dbContext.Database.CreateExecutionStrategy();
-        return strategy.Execute(() => func(dbContext));
-    }
-
-    public static Task<T> ExecutionStrategy<T, TDbContext>(this TDbContext dbContext, Func<TDbContext, Task<T>> func) where TDbContext : DbContext
-    {
-        var strategy = dbContext.Database.CreateExecutionStrategy();
-        return strategy.ExecuteAsync(() => func(dbContext));
-    }
-}
+	/// <summary>
+	/// 获取变化的实体信息
+	/// </summary>
+	/// <typeparam name="T"></typeparam>
+	/// <param name="db"></param>
+	/// <returns></returns>
+	public static IEnumerable<ChangeEntry<T>> GetChanges<T>(this DbContext db)
+	{
+		return db.ChangeTracker.Entries().Where(e => e is { State: EntityState.Modified, Entity: T }).Select(e =>
+		{
+			NullableDictionary<string, object> originalObject = e.OriginalValues.ToObject() as Dictionary<string, object> ?? new NullableDictionary<string, object>();
+			NullableDictionary<string, object> currentObject = e.CurrentValues.ToObject() as Dictionary<string, object> ?? new NullableDictionary<string, object>();
+			return new ChangeEntry<T>
+			{
+				EntityState = e.State,
+				Entity = (T)e.Entity,
+				EntityType = e.OriginalValues.EntityType.ClrType,
+				ChangeProperties = e.OriginalValues.Properties.Select(p => (Property: p, Value: originalObject[p.PropertyInfo?.Name])).Zip(e.CurrentValues.Properties.Select(p => (Property: p, Value: currentObject[p.PropertyInfo?.Name])), (t1, t2) => new ChangePropertyInfo
+				{
+					PropertyInfo = t1.Property.PropertyInfo,
+					OriginalValue = t1.Value,
+					CurrentValue = t2.Value,
+					IsPrimaryKey = t1.Property.IsPrimaryKey(),
+					IsForeignKey = t1.Property.IsForeignKey()
+				}).Where(t => Comparer.Default.Compare(t.OriginalValue, t.CurrentValue) != 0).ToList()
+			};
+		});
+	}
+
+	/// <summary>
+	/// 获取变化的实体信息
+	/// </summary>
+	/// <param name="db"></param>
+	/// <returns></returns>
+	public static IEnumerable<ChangeEntry> GetChanges(this DbContext db)
+	{
+		return db.ChangeTracker.Entries().Where(e => e.State == EntityState.Modified).Select(e =>
+		{
+			NullableDictionary<string, object> originalObject = e.OriginalValues.ToObject() as Dictionary<string, object> ?? new NullableDictionary<string, object>();
+			NullableDictionary<string, object> currentObject = e.CurrentValues.ToObject() as Dictionary<string, object> ?? new NullableDictionary<string, object>();
+			return new ChangeEntry
+			{
+				EntityState = e.State,
+				Entity = e.Entity,
+				EntityType = e.OriginalValues.EntityType.ClrType,
+				ChangeProperties = e.OriginalValues.Properties.Select(p => (Property: p, Value: originalObject[p.PropertyInfo?.Name])).Zip(e.CurrentValues.Properties.Select(p => (Property: p, Value: currentObject[p.PropertyInfo?.Name])), (t1, t2) => new ChangePropertyInfo
+				{
+					PropertyInfo = t1.Property.PropertyInfo,
+					OriginalValue = t1.Value,
+					CurrentValue = t2.Value,
+					IsPrimaryKey = t1.Property.IsPrimaryKey(),
+					IsForeignKey = t1.Property.IsForeignKey()
+				}).Where(t => Comparer.Default.Compare(t.OriginalValue, t.CurrentValue) != 0).ToList()
+			};
+		});
+	}
+
+	/// <summary>
+	/// 获取添加的实体信息
+	/// </summary>
+	/// <typeparam name="T"></typeparam>
+	/// <param name="db"></param>
+	/// <returns></returns>
+	public static IEnumerable<ChangeEntry<T>> GetAdded<T>(this DbContext db)
+	{
+		return db.ChangeTracker.Entries().Where(e => e.State == EntityState.Added && e.Entity is T).Select(e =>
+		{
+			NullableDictionary<string, object> currentObject = e.CurrentValues.ToObject() as Dictionary<string, object> ?? new NullableDictionary<string, object>();
+			return new ChangeEntry<T>
+			{
+				EntityState = e.State,
+				Entity = (T)e.Entity,
+				EntityType = e.CurrentValues.EntityType.ClrType,
+				ChangeProperties = e.CurrentValues.Properties.Select(p => new ChangePropertyInfo()
+				{
+					PropertyInfo = p.PropertyInfo,
+					CurrentValue = currentObject[p.PropertyInfo?.Name],
+					IsPrimaryKey = p.IsPrimaryKey(),
+					IsForeignKey = p.IsForeignKey(),
+				}).ToList()
+			};
+		});
+	}
+
+	/// <summary>
+	/// 获取添加的实体信息
+	/// </summary>
+	/// <param name="db"></param>
+	/// <returns></returns>
+	public static IEnumerable<ChangeEntry> GetAdded(this DbContext db)
+	{
+		return db.ChangeTracker.Entries().Where(e => e.State == EntityState.Added).Select(e =>
+		{
+			NullableDictionary<string, object> currentObject = e.CurrentValues.ToObject() as Dictionary<string, object> ?? new NullableDictionary<string, object>();
+			return new ChangeEntry
+			{
+				EntityState = e.State,
+				Entity = e.Entity,
+				EntityType = e.CurrentValues.EntityType.ClrType,
+				ChangeProperties = e.CurrentValues.Properties.Select(p => new ChangePropertyInfo
+				{
+					PropertyInfo = p.PropertyInfo,
+					CurrentValue = currentObject[p.PropertyInfo?.Name],
+					IsPrimaryKey = p.IsPrimaryKey(),
+					IsForeignKey = p.IsForeignKey(),
+				}).ToList()
+			};
+		});
+	}
+
+	/// <summary>
+	/// 获取移除的实体信息
+	/// </summary>
+	/// <typeparam name="T"></typeparam>
+	/// <param name="db"></param>
+	/// <returns></returns>
+	public static IEnumerable<ChangeEntry<T>> GetRemoved<T>(this DbContext db)
+	{
+		return db.ChangeTracker.Entries().Where(e => e.State == EntityState.Deleted && e.Entity is T).Select(e =>
+		{
+			NullableDictionary<string, object> originalObject = e.OriginalValues.ToObject() as Dictionary<string, object> ?? new NullableDictionary<string, object>();
+			return new ChangeEntry<T>
+			{
+				EntityState = e.State,
+				Entity = (T)e.Entity,
+				EntityType = e.OriginalValues.EntityType.ClrType,
+				ChangeProperties = e.OriginalValues.Properties.Select(p => new ChangePropertyInfo
+				{
+					PropertyInfo = p.PropertyInfo,
+					OriginalValue = originalObject[p.PropertyInfo?.Name],
+					IsPrimaryKey = p.IsPrimaryKey(),
+					IsForeignKey = p.IsForeignKey(),
+				}).ToList()
+			};
+		});
+	}
+
+	/// <summary>
+	/// 获取移除的实体信息
+	/// </summary>
+	/// <param name="db"></param>
+	/// <returns></returns>
+	public static IEnumerable<ChangeEntry> GetRemoved(this DbContext db)
+	{
+		return db.ChangeTracker.Entries().Where(e => e.State == EntityState.Deleted).Select(e =>
+		{
+			NullableDictionary<string, object> originalObject = e.OriginalValues.ToObject() as Dictionary<string, object> ?? new NullableDictionary<string, object>();
+			return new ChangeEntry
+			{
+				EntityState = e.State,
+				Entity = e.Entity,
+				EntityType = e.OriginalValues.EntityType.ClrType,
+				ChangeProperties = e.OriginalValues.Properties.Select(p => new ChangePropertyInfo
+				{
+					PropertyInfo = p.PropertyInfo,
+					OriginalValue = originalObject[p.PropertyInfo?.Name],
+					IsPrimaryKey = p.IsPrimaryKey(),
+					IsForeignKey = p.IsForeignKey(),
+				}).ToList()
+			};
+		});
+	}
+
+	/// <summary>
+	/// 获取所有的变更信息
+	/// </summary>
+	/// <typeparam name="T"></typeparam>
+	/// <param name="db"></param>
+	/// <returns></returns>
+	public static IEnumerable<ChangeEntry<T>> GetAllChanges<T>(this DbContext db)
+	{
+		return GetChanges<T>(db).Union(GetAdded<T>(db)).Union(GetRemoved<T>(db));
+	}
+
+	/// <summary>
+	/// 获取所有的变更信息
+	/// </summary>
+	/// <param name="db"></param>
+	/// <returns></returns>
+	public static IEnumerable<ChangeEntry> GetAllChanges(this DbContext db)
+	{
+		return GetChanges(db).Union(GetAdded(db)).Union(GetRemoved(db));
+	}
+
+	public static IQueryable<TEntity> IncludeRecursive<TEntity>(this IQueryable<TEntity> source, int levelIndex, Expression<Func<TEntity, ICollection<TEntity>>> expression) where TEntity : class
+	{
+		if (levelIndex < 0)
+			throw new ArgumentOutOfRangeException(nameof(levelIndex));
+		var member = (MemberExpression)expression.Body;
+		var property = member.Member.Name;
+		var sb = new StringBuilder();
+		for (int i = 0; i < levelIndex; i++)
+		{
+			if (i > 0)
+				sb.Append(Type.Delimiter);
+			sb.Append(property);
+		}
+
+		return source.Include(sb.ToString());
+	}
+
+	public static Task<List<T>> ToListWithNoLockAsync<T>(this IQueryable<T> query, CancellationToken cancellationToken = default)
+	{
+		return ExecuteStrategyAsync(query, async (q) =>
+		{
+			using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
+			{
+				IsolationLevel = IsolationLevel.ReadUncommitted
+			}, TransactionScopeAsyncFlowOption.Enabled);
+			var result = await q.ToListAsync(cancellationToken);
+			scope.Complete();
+			return result;
+		});
+	}
+
+	public static List<T> ToListWithNoLock<T>(this IQueryable<T> query)
+	{
+		return ExecuteStrategy(query, q =>
+		{
+			using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
+			{
+				IsolationLevel = IsolationLevel.ReadUncommitted
+			}, TransactionScopeAsyncFlowOption.Enabled);
+			var result = q.ToList();
+			scope.Complete();
+			return result;
+		});
+	}
+
+	public static Task<int> CountWithNoLockAsync<T>(this IQueryable<T> query, CancellationToken cancellationToken = default)
+	{
+		return ExecuteStrategyAsync(query, async q =>
+		{
+			using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
+			{
+				IsolationLevel = IsolationLevel.ReadUncommitted
+			}, TransactionScopeAsyncFlowOption.Enabled);
+			var result = await q.CountAsync(cancellationToken);
+			scope.Complete();
+			return result;
+		});
+	}
+
+	public static int CountWithNoLock<T>(this IQueryable<T> query)
+	{
+		return ExecuteStrategy(query, q =>
+		{
+			using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
+			{
+				IsolationLevel = IsolationLevel.ReadUncommitted
+			}, TransactionScopeAsyncFlowOption.Enabled);
+			var result = q.Count();
+			scope.Complete();
+			return result;
+		});
+	}
+
+	public static Task<int> CountWithNoLockAsync<T>(this IQueryable<T> query, Expression<Func<T, bool>> where, CancellationToken cancellationToken = default)
+	{
+		return ExecuteStrategyAsync(query, async q =>
+		{
+			using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
+			{
+				IsolationLevel = IsolationLevel.ReadUncommitted
+			}, TransactionScopeAsyncFlowOption.Enabled);
+			var result = await q.CountAsync(where, cancellationToken);
+			scope.Complete();
+			return result;
+		});
+	}
+
+	public static int CountWithNoLock<T>(this IQueryable<T> query, Expression<Func<T, bool>> where)
+	{
+		return ExecuteStrategy(query, q =>
+		{
+			using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
+			{
+				IsolationLevel = IsolationLevel.ReadUncommitted
+			}, TransactionScopeAsyncFlowOption.Enabled);
+			var result = q.Count(where);
+			scope.Complete();
+			return result;
+		});
+	}
+
+	public static Task<bool> AnyWithNoLockAsync<T>(this IQueryable<T> query, CancellationToken cancellationToken = default)
+	{
+		return ExecuteStrategyAsync(query, async q =>
+		{
+			using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
+			{
+				IsolationLevel = IsolationLevel.ReadUncommitted
+			}, TransactionScopeAsyncFlowOption.Enabled);
+			var result = await q.AnyAsync(cancellationToken);
+			scope.Complete();
+			return result;
+		});
+	}
+
+	public static bool AnyWithNoLock<T>(this IQueryable<T> query)
+	{
+		return ExecuteStrategy(query, q =>
+		{
+			using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
+			{
+				IsolationLevel = IsolationLevel.ReadUncommitted
+			}, TransactionScopeAsyncFlowOption.Enabled);
+			var result = q.Any();
+			scope.Complete();
+			return result;
+		});
+	}
+
+	public static Task<bool> AnyWithNoLockAsync<T>(this IQueryable<T> query, Expression<Func<T, bool>> where, CancellationToken cancellationToken = default)
+	{
+		return ExecuteStrategyAsync(query, async q =>
+		{
+			using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
+			{
+				IsolationLevel = IsolationLevel.ReadUncommitted
+			}, TransactionScopeAsyncFlowOption.Enabled);
+			var result = await q.AnyAsync(where, cancellationToken);
+			scope.Complete();
+			return result;
+		});
+	}
+
+	public static bool AnyWithNoLock<T>(this IQueryable<T> query, Expression<Func<T, bool>> where)
+	{
+		return ExecuteStrategy(query, q =>
+		{
+			using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
+			{
+				IsolationLevel = IsolationLevel.ReadUncommitted
+			}, TransactionScopeAsyncFlowOption.Enabled);
+			var result = q.Any(where);
+			scope.Complete();
+			return result;
+		});
+	}
+
+	public static Task<T> FirstOrDefaultWithNoLockAsync<T>(this IQueryable<T> query, Expression<Func<T, bool>> where, CancellationToken cancellationToken = default)
+	{
+		return ExecuteStrategyAsync(query, async q =>
+		{
+			using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
+			{
+				IsolationLevel = IsolationLevel.ReadUncommitted
+			}, TransactionScopeAsyncFlowOption.Enabled);
+			var result = await q.FirstOrDefaultAsync(where, cancellationToken);
+			scope.Complete();
+			return result;
+		});
+	}
+
+	public static T FirstOrDefaultWithNoLock<T>(this IQueryable<T> query, Expression<Func<T, bool>> where)
+	{
+		return ExecuteStrategy(query, q =>
+		{
+			using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
+			{
+				IsolationLevel = IsolationLevel.ReadUncommitted
+			}, TransactionScopeAsyncFlowOption.Enabled);
+			var result = q.FirstOrDefault(where);
+			scope.Complete();
+			return result;
+		});
+	}
+
+	public static Task<T> FirstOrDefaultWithNoLockAsync<T>(this IQueryable<T> query, CancellationToken cancellationToken = default)
+	{
+		return ExecuteStrategyAsync(query, async q =>
+		{
+			using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions
+			{
+				IsolationLevel = IsolationLevel.ReadUncommitted
+			}, TransactionScopeAsyncFlowOption.Enabled);
+			var result = await q.FirstOrDefaultAsync(cancellationToken);
+			scope.Complete();
+			return result;
+		});
+	}
+
+	public static T FirstOrDefaultWithNoLock<T>(this IQueryable<T> query)
+	{
+		return ExecuteStrategy(query, q =>
+		{
+			using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions
+			{
+				IsolationLevel = IsolationLevel.ReadUncommitted
+			}, TransactionScopeAsyncFlowOption.Enabled);
+			var result = q.FirstOrDefault();
+			scope.Complete();
+			return result;
+		});
+	}
+
+	public static Task<T> SingleOrDefaultWithNoLockAsync<T>(this IQueryable<T> query, Expression<Func<T, bool>> where, CancellationToken cancellationToken = default)
+	{
+		return ExecuteStrategyAsync(query, async q =>
+		{
+			using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions
+			{
+				IsolationLevel = IsolationLevel.ReadUncommitted
+			}, TransactionScopeAsyncFlowOption.Enabled);
+			var result = await q.SingleOrDefaultAsync(where, cancellationToken);
+			scope.Complete();
+			return result;
+		});
+	}
+
+	public static T SingleOrDefaultWithNoLock<T>(this IQueryable<T> query, Expression<Func<T, bool>> where)
+	{
+		return ExecuteStrategy(query, q =>
+		{
+			using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
+			{
+				IsolationLevel = IsolationLevel.ReadUncommitted
+			}, TransactionScopeAsyncFlowOption.Enabled);
+			var result = q.SingleOrDefault(where);
+			scope.Complete();
+			return result;
+		});
+	}
+
+	public static Task<T> SingleOrDefaultWithNoLockAsync<T>(this IQueryable<T> query, CancellationToken cancellationToken = default)
+	{
+		return ExecuteStrategyAsync(query, async q =>
+		{
+			using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
+			{
+				IsolationLevel = IsolationLevel.ReadUncommitted
+			}, TransactionScopeAsyncFlowOption.Enabled);
+			var result = await q.SingleOrDefaultAsync(cancellationToken);
+			scope.Complete();
+			return result;
+		});
+	}
+
+	public static T SingleOrDefaultWithNoLock<T>(this IQueryable<T> query)
+	{
+		return ExecuteStrategy(query, q =>
+		{
+			using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
+			{
+				IsolationLevel = IsolationLevel.ReadUncommitted
+			}, TransactionScopeAsyncFlowOption.Enabled);
+			var result = q.SingleOrDefault();
+			scope.Complete();
+			return result;
+		});
+	}
+
+	public static Task<bool> AllWithNoLockAsync<T>(this IQueryable<T> query, Expression<Func<T, bool>> where, CancellationToken cancellationToken = default)
+	{
+		return ExecuteStrategyAsync(query, async q =>
+		{
+			using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
+			{
+				IsolationLevel = IsolationLevel.ReadUncommitted
+			}, TransactionScopeAsyncFlowOption.Enabled);
+			var result = await q.AllAsync(where, cancellationToken);
+			scope.Complete();
+			return result;
+		});
+	}
+
+	public static bool AllWithNoLock<T>(this IQueryable<T> query, Expression<Func<T, bool>> where)
+	{
+		return ExecuteStrategy(query, q =>
+		{
+			using var scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions()
+			{
+				IsolationLevel = IsolationLevel.ReadUncommitted
+			}, TransactionScopeAsyncFlowOption.Enabled);
+			var result = query.All(where);
+			scope.Complete();
+			return result;
+		});
+	}
+
+	public static T NoLock<T, TDbContext>(this TDbContext dbContext, Func<TDbContext, T> func) where TDbContext : DbContext
+	{
+		var strategy = dbContext.Database.CreateExecutionStrategy();
+		return strategy.Execute(() =>
+		{
+			var transactionOptions = new TransactionOptions
+			{
+				IsolationLevel = IsolationLevel.ReadUncommitted
+			};
+			using var scope = new TransactionScope(TransactionScopeOption.Required, transactionOptions);
+			var result = func(dbContext);
+			scope.Complete();
+			return result;
+		});
+	}
+
+	public static Task<T> NoLock<T, TDbContext>(this TDbContext dbContext, Func<TDbContext, Task<T>> func) where TDbContext : DbContext
+	{
+		var strategy = dbContext.Database.CreateExecutionStrategy();
+		return strategy.ExecuteAsync(async () =>
+		{
+			var transactionOptions = new TransactionOptions
+			{
+				IsolationLevel = IsolationLevel.ReadUncommitted
+			};
+			using var scope = new TransactionScope(TransactionScopeOption.Required, transactionOptions);
+			var result = await func(dbContext);
+			scope.Complete();
+			return result;
+		});
+	}
+
+	public static T ExecuteStrategy<T, TDbContext>(this TDbContext dbContext, Func<TDbContext, T> func) where TDbContext : DbContext
+	{
+		var strategy = dbContext.Database.CreateExecutionStrategy();
+		return strategy.Execute(() => func(dbContext));
+	}
+
+	public static Task<T> ExecuteStrategy<T, TDbContext>(this TDbContext dbContext, Func<TDbContext, Task<T>> func) where TDbContext : DbContext
+	{
+		var strategy = dbContext.Database.CreateExecutionStrategy();
+		return strategy.ExecuteAsync(() => func(dbContext));
+	}
+
+	public static TResult ExecuteStrategy<T, TResult>(this IQueryable<T> query, Func<IQueryable<T>, TResult> func)
+	{
+		if (query.Provider is not EntityQueryProvider)
+		{
+			return func(query);
+		}
+
+		var dependencies = query.Provider.GetField<QueryCompiler>("_queryCompiler").GetField<CompiledQueryCacheKeyGenerator>("_compiledQueryCacheKeyGenerator").GetField<CompiledQueryCacheKeyGeneratorDependencies>("Dependencies");
+#if NETSTANDARD2_0
+		var context = dependencies.Context.Context;
+#else
+		var context = dependencies.CurrentContext.Context;
+#endif
+		var strategy = context.Database.CreateExecutionStrategy();
+		return strategy.Execute(() => func(query));
+	}
+
+	public static Task<TResult> ExecuteStrategyAsync<T, TResult>(this IQueryable<T> query, Func<IQueryable<T>, Task<TResult>> func)
+	{
+		if (query.Provider is not EntityQueryProvider)
+		{
+			return func(query);
+		}
+
+		var dependencies = query.Provider.GetField<QueryCompiler>("_queryCompiler").GetField<CompiledQueryCacheKeyGenerator>("_compiledQueryCacheKeyGenerator").GetField<CompiledQueryCacheKeyGeneratorDependencies>("Dependencies");
+#if NETSTANDARD2_0
+		var context = dependencies.Context.Context;
+#else
+		var context = dependencies.CurrentContext.Context;
+#endif
+		var strategy = context.Database.CreateExecutionStrategy();
+		return strategy.ExecuteAsync(() => func(query));
+	}
+}

+ 1 - 1
Masuit.Tools.Excel/Masuit.Tools.Excel.csproj

@@ -37,7 +37,7 @@
       </None>
     </ItemGroup>
     <ItemGroup>
-        <PackageReference Include="EPPlus" Version="7.2.1" />
+        <PackageReference Include="EPPlus" Version="7.2.2" />
         <PackageReference Include="Microsoft.SourceLink.GitHub" Version="8.0.0" PrivateAssets="All" />
     </ItemGroup>
     <ItemGroup>

+ 1 - 1
Masuit.Tools.Net45/package.nuspec

@@ -2,7 +2,7 @@
 <package>
     <metadata>
         <id>Masuit.Tools.Net45</id>
-        <version>2024.4.2</version>
+        <version>2024.4.4</version>
         <title>Masuit.Tools</title>
         <authors>懒得勤快</authors>
         <owners>masuit.com</owners>

+ 1 - 1
Masuit.Tools.NoSQL.MongoDBClient/Masuit.Tools.NoSQL.MongoDBClient.csproj

@@ -38,7 +38,7 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="MongoDB.Driver" Version="2.27.0" />
+    <PackageReference Include="MongoDB.Driver" Version="2.28.0" />
   </ItemGroup>
 
 </Project>

+ 1 - 1
Masuit.Tools/package.nuspec

@@ -2,7 +2,7 @@
 <package>
     <metadata>
         <id>Masuit.Tools.Net</id>
-        <version>2024.4.2</version>
+        <version>2024.4.4</version>
         <title>Masuit.Tools</title>
         <authors>懒得勤快</authors>
         <owners>masuit.com</owners>