From e1a89e7c70629c4912007ef033a7bf6c57e697a6 Mon Sep 17 00:00:00 2001 From: "David P.G" Date: Sat, 19 Jul 2025 09:24:35 +0800 Subject: [PATCH] =?UTF-8?q?=E9=87=8D=E6=9E=84=E9=A1=B9=E7=9B=AE=E4=B8=AD(?= =?UTF-8?q?=E4=B8=B4=E6=97=B6=E6=8F=90=E4=BA=A4)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../{DbContext.cs => SqlSugarDbContext.cs} | 0 DMS.WPF/App.xaml | 26 +- DMS.WPF/App.xaml.cs | 264 +++++++++++++++++- 3 files changed, 274 insertions(+), 16 deletions(-) rename DMS.Infrastructure/Data/{DbContext.cs => SqlSugarDbContext.cs} (100%) diff --git a/DMS.Infrastructure/Data/DbContext.cs b/DMS.Infrastructure/Data/SqlSugarDbContext.cs similarity index 100% rename from DMS.Infrastructure/Data/DbContext.cs rename to DMS.Infrastructure/Data/SqlSugarDbContext.cs diff --git a/DMS.WPF/App.xaml b/DMS.WPF/App.xaml index ee0bcda..5da72cb 100644 --- a/DMS.WPF/App.xaml +++ b/DMS.WPF/App.xaml @@ -1,9 +1,21 @@ - + - + + + + + + + + + + + + - + \ No newline at end of file diff --git a/DMS.WPF/App.xaml.cs b/DMS.WPF/App.xaml.cs index 0f78989..4936bc0 100644 --- a/DMS.WPF/App.xaml.cs +++ b/DMS.WPF/App.xaml.cs @@ -1,14 +1,260 @@ -using System.Configuration; -using System.Data; -using System.Windows; +using System.Windows; +using DMS.Infrastructure; +using DMS.Infrastructure.Entities; +using DMS.Infrastructure.Repositories; +using DMS.Enums; +using DMS.Helper; +using DMS.Services; +using DMS.Services.Processors; +using DMS.ViewModels; +using DMS.Views; +using iNKORE.UI.WPF.Modern.Common.IconKeys; +using Microsoft.Extensions.DependencyInjection; +using Microsoft.Extensions.Logging; +using NLog; +using NLog.Extensions.Logging; +using DMS.Extensions; +using Microsoft.Extensions.Hosting; +using DMS.Config; +using SqlSugar; +using LogLevel = Microsoft.Extensions.Logging.LogLevel; -namespace DMS.WPF +namespace DMS; + +/// +/// Interaction logic for App.xaml +/// +public partial class App : Application { - /// - /// Interaction logic for App.xaml - /// - public partial class App : Application + public IServiceProvider Services { get; } + + public App() { + Host = Microsoft.Extensions.Hosting.Host.CreateDefaultBuilder() + .ConfigureServices((context, services) => + { + ConfigureServices(services); + }) + .ConfigureLogging(loggingBuilder => + { + ConfigureLogging(loggingBuilder); + }) + .Build(); + Services = Host.Services; } -} + public new static App Current => (App)Application.Current; + public IHost Host { get; } + + protected override async void OnStartup(StartupEventArgs e) + { + base.OnStartup(e); + ShutdownMode = ShutdownMode.OnExplicitShutdown; + ThemeHelper.InitializeTheme(); + await Host.StartAsync(); + + try + { + InitializeDataBase(); + InitializeMenu() + .Await((e) => { NotificationHelper.ShowError($"初始化主菜单失败：{e.Message}", e); }, + () => { MessageHelper.SendLoadMessage(LoadTypes.Menu); }); + Host.Services.GetRequiredService(); + + // 初始化数据处理链 + var dataProcessingService = Host.Services.GetRequiredService(); + dataProcessingService.AddProcessor(Host.Services.GetRequiredService()); + dataProcessingService.AddProcessor(Host.Services.GetRequiredService()); + dataProcessingService.AddProcessor(Host.Services.GetRequiredService()); + dataProcessingService.AddProcessor(Host.Services.GetRequiredService()); + dataProcessingService.AddProcessor(Host.Services.GetRequiredService()); + } + catch (Exception exception) + { + NotificationHelper.ShowError("加载数据时发生错误，如果是连接字符串不正确，可以在设置界面更改：{exception.Message}", exception); + } + + MainWindow = Host.Services.GetRequiredService(); + MainWindow.Show(); + + // 根据配置启动服务 + // var connectionSettings = DMS.Config.ConnectionSettings.Load(); + // if (connectionSettings.EnableMqttService) + // { + // Host.Services.GetRequiredService().StartService(); + // } + // if (connectionSettings.EnableOpcUaService) + // { + // Host.Services.GetRequiredService().StartService(); + // } + } + + protected override async void OnExit(ExitEventArgs e) + { + // 停止服务 + await Host.StopAsync(); + Host.Dispose(); + LogManager.Shutdown(); + base.OnExit(e); + } + + private void ConfigureServices(IServiceCollection services) + { + services.AddSingleton(); + services.AddSingleton(); + services.AddSingleton(); + services.AddSingleton(); + services.AddHostedService(); + services.AddHostedService(); + services.AddSingleton(); + services.AddHostedService(provider => provider.GetRequiredService()); + services.AddSingleton(); + + // 注册 AutoMapper + services.AddAutoMapper(typeof(App).Assembly); + + // 注册数据处理服务和处理器 + services.AddSingleton(); + services.AddHostedService(provider => (DataProcessingService)provider.GetRequiredService()); + services.AddSingleton(); + services.AddSingleton(); + services.AddSingleton(); + services.AddSingleton(); + services.AddSingleton(); + + // 注册数据仓库 + services.AddSingleton(); + services.AddSingleton(); + services.AddSingleton(); + services.AddSingleton(); + services.AddSingleton(); + services.AddSingleton(); + services.AddSingleton(); + // 注册视图模型 + services.AddSingleton(); + services.AddSingleton(); + services.AddSingleton(); + services.AddSingleton(); + services.AddSingleton(); + services.AddSingleton(); + services.AddSingleton(); + services.AddScoped(); + services.AddSingleton(); + services.AddScoped(); + //注册View视图 + services.AddSingleton(); + services.AddSingleton(); + services.AddSingleton(); + services.AddSingleton(); + services.AddSingleton(); + services.AddScoped(); + services.AddScoped(); + } + + private void ConfigureLogging(ILoggingBuilder loggingBuilder) + { + LogManager.Setup().LoadConfigurationFromFile("Config/nlog.config"); + loggingBuilder.ClearProviders(); + loggingBuilder.SetMinimumLevel(LogLevel.Trace); + loggingBuilder.AddNLog(); + + // 捕获未处理的异常并记录 + AppDomain.CurrentDomain.UnhandledException += (sender, args) => + { + var ex = args.ExceptionObject as Exception; + if (ex != null) + { + // 可以使用一个专用的 Logger 来记录未处理异常 + LogManager.GetLogger("UnhandledExceptionLogger") + .Fatal($"应用程序发生未处理的异常:{ex}"); + } + }; + + // 捕获 Dispatcher 线程上的未处理异常 (UI 线程) + this.DispatcherUnhandledException += (sender, args) => + { + LogManager.GetLogger("DispatcherExceptionLogger") + .Fatal($"UI 线程发生未处理的异常:{args.Exception}"); + // 标记为已处理，防止应用程序崩溃 (生产环境慎用，可能掩盖问题) + // args.Handled = true; + }; + + // 如果您使用 Task (异步方法) 并且没有正确 await，可能会导致异常丢失， + // 可以通过以下方式捕获 Task 中的异常。 + TaskScheduler.UnobservedTaskException += (sender, args) => + { + LogManager.GetLogger("UnobservedTaskExceptionLogger") + .Fatal($"异步任务发生未观察到的异常:{args.Exception}"); + // args.SetObserved(); // 标记为已观察，防止进程终止 + }; + } + + /// + /// 初始化菜单 + /// + private async Task InitializeMenu() + { + using (var db = DbContext.GetInstance()) + { + var homeMenu = new DbMenu() + { Name = "主页", Type = MenuType.MainMenu, Icon = SegoeFluentIcons.Home.Glyph, ParentId = 0 }; + + var deviceMenu = new DbMenu() + { + Name = "设备", Type = MenuType.MainMenu, Icon = SegoeFluentIcons.Devices3.Glyph, + ParentId = 0 + }; + var dataTransfromMenu = new DbMenu() + { + Name = "数据转换", Type = MenuType.MainMenu, + Icon = SegoeFluentIcons.ChromeSwitch.Glyph, ParentId = 0 + }; + var mqttMenu = new DbMenu() + { + Name = "Mqtt服务器", Type = MenuType.MainMenu, Icon = SegoeFluentIcons.Cloud.Glyph, + ParentId = 0 + }; + + var settingMenu = new DbMenu() + { + Name = "设置", Type = MenuType.MainMenu, Icon = SegoeFluentIcons.Settings.Glyph, + ParentId = 0 + }; + var aboutMenu = new DbMenu() + { Name = "关于", Type = MenuType.MainMenu, Icon = SegoeFluentIcons.Info.Glyph, ParentId = 0 }; + await CheckMainMenuExist(db, homeMenu); + await CheckMainMenuExist(db, deviceMenu); + await CheckMainMenuExist(db, dataTransfromMenu); + await CheckMainMenuExist(db, mqttMenu); + await CheckMainMenuExist(db, settingMenu); + await CheckMainMenuExist(db, aboutMenu); + } + } + + private static async Task CheckMainMenuExist(SqlSugarClient db, DbMenu menu) + { + var homeMenuExist = await db.Queryable() + .FirstAsync(dm => dm.Name == menu.Name); + if (homeMenuExist == null) + { + await db.Insertable(menu) + .ExecuteCommandAsync(); + } + } + + private void InitializeDataBase() + { + var _db = DbContext.GetInstance(); + _db.DbMaintenance.CreateDatabase(); + _db.CodeFirst.InitTables(); + _db.CodeFirst.InitTables(); + _db.CodeFirst.InitTables(); + _db.CodeFirst.InitTables(); + _db.CodeFirst.InitTables(); + _db.CodeFirst.InitTables(); + _db.CodeFirst.InitTables(); + _db.CodeFirst.InitTables(); + _db.CodeFirst.InitTables(); + _db.CodeFirst.InitTables(); + } +} \ No newline at end of file