重构项目中(临时提交)
This commit is contained in:
@@ -1,9 +1,21 @@
|
||||
<Application x:Class="DMS.WPF.App"
|
||||
xmlns="http://schemas.microsoft.com/winfx/2006/xaml/presentation"
|
||||
xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml"
|
||||
xmlns:local="clr-namespace:DMS.WPF"
|
||||
StartupUri="MainWindow.xaml">
|
||||
<Application
|
||||
x:Class="DMS.App"
|
||||
xmlns="http://schemas.microsoft.com/winfx/2006/xaml/presentation"
|
||||
xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml"
|
||||
|
||||
xmlns:ui="http://schemas.inkore.net/lib/ui/wpf/modern">
|
||||
<Application.Resources>
|
||||
<ResourceDictionary>
|
||||
<ResourceDictionary.MergedDictionaries>
|
||||
<ui:ThemeResources />
|
||||
<ui:XamlControlsResources />
|
||||
<ResourceDictionary Source="Resources/DevicesItemTemplateDictionary.xaml" />
|
||||
|
||||
<ResourceDictionary Source="pack://application:,,,/HandyControl;component/Themes/SkinDefault.xaml" />
|
||||
<ResourceDictionary Source="pack://application:,,,/HandyControl;component/Themes/Theme.xaml" />
|
||||
</ResourceDictionary.MergedDictionaries>
|
||||
|
||||
</ResourceDictionary>
|
||||
|
||||
</Application.Resources>
|
||||
</Application>
|
||||
@@ -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;
|
||||
|
||||
/// <summary>
|
||||
/// Interaction logic for App.xaml
|
||||
/// </summary>
|
||||
public partial class App : Application
|
||||
{
|
||||
/// <summary>
|
||||
/// Interaction logic for App.xaml
|
||||
/// </summary>
|
||||
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<GrowlNotificationService>();
|
||||
|
||||
// 初始化数据处理链
|
||||
var dataProcessingService = Host.Services.GetRequiredService<IDataProcessingService>();
|
||||
dataProcessingService.AddProcessor(Host.Services.GetRequiredService<CheckValueChangedProcessor>());
|
||||
dataProcessingService.AddProcessor(Host.Services.GetRequiredService<LoggingProcessor>());
|
||||
dataProcessingService.AddProcessor(Host.Services.GetRequiredService<MqttPublishProcessor>());
|
||||
dataProcessingService.AddProcessor(Host.Services.GetRequiredService<UpdateDbVariableProcessor>());
|
||||
dataProcessingService.AddProcessor(Host.Services.GetRequiredService<HistoryProcessor>());
|
||||
}
|
||||
catch (Exception exception)
|
||||
{
|
||||
NotificationHelper.ShowError("加载数据时发生错误，如果是连接字符串不正确，可以在设置界面更改：{exception.Message}", exception);
|
||||
}
|
||||
|
||||
MainWindow = Host.Services.GetRequiredService<MainView>();
|
||||
MainWindow.Show();
|
||||
|
||||
// 根据配置启动服务
|
||||
// var connectionSettings = DMS.Config.ConnectionSettings.Load();
|
||||
// if (connectionSettings.EnableMqttService)
|
||||
// {
|
||||
// Host.Services.GetRequiredService<MqttBackgroundService>().StartService();
|
||||
// }
|
||||
// if (connectionSettings.EnableOpcUaService)
|
||||
// {
|
||||
// Host.Services.GetRequiredService<OpcUaBackgroundService>().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<DataServices>();
|
||||
services.AddSingleton<NavgatorServices>();
|
||||
services.AddSingleton<IDialogService, DialogService>();
|
||||
services.AddSingleton<GrowlNotificationService>();
|
||||
services.AddHostedService<S7BackgroundService>();
|
||||
services.AddHostedService<OpcUaBackgroundService>();
|
||||
services.AddSingleton<MqttBackgroundService>();
|
||||
services.AddHostedService(provider => provider.GetRequiredService<MqttBackgroundService>());
|
||||
services.AddSingleton<OpcUaBackgroundService>();
|
||||
|
||||
// 注册 AutoMapper
|
||||
services.AddAutoMapper(typeof(App).Assembly);
|
||||
|
||||
// 注册数据处理服务和处理器
|
||||
services.AddSingleton<IDataProcessingService, DataProcessingService>();
|
||||
services.AddHostedService(provider => (DataProcessingService)provider.GetRequiredService<IDataProcessingService>());
|
||||
services.AddSingleton<CheckValueChangedProcessor>();
|
||||
services.AddSingleton<LoggingProcessor>();
|
||||
services.AddSingleton<UpdateDbVariableProcessor>();
|
||||
services.AddSingleton<HistoryProcessor>();
|
||||
services.AddSingleton<MqttPublishProcessor>();
|
||||
|
||||
// 注册数据仓库
|
||||
services.AddSingleton<DeviceRepository>();
|
||||
services.AddSingleton<MenuRepository>();
|
||||
services.AddSingleton<MqttRepository>();
|
||||
services.AddSingleton<UserRepository>();
|
||||
services.AddSingleton<VarDataRepository>();
|
||||
services.AddSingleton<VarTableRepository>();
|
||||
services.AddSingleton<VariableMqttAliasRepository>();
|
||||
// 注册视图模型
|
||||
services.AddSingleton<MainViewModel>();
|
||||
services.AddSingleton<HomeViewModel>();
|
||||
services.AddSingleton<DevicesViewModel>();
|
||||
services.AddSingleton<DataTransformViewModel>();
|
||||
services.AddSingleton<SettingViewModel>();
|
||||
services.AddSingleton<DataTransformViewModel>();
|
||||
services.AddSingleton<VariableTableViewModel>();
|
||||
services.AddScoped<MqttServerDetailViewModel>();
|
||||
services.AddSingleton<DeviceDetailViewModel>();
|
||||
services.AddScoped<MqttsViewModel>();
|
||||
//注册View视图
|
||||
services.AddSingleton<SettingView>();
|
||||
services.AddSingleton<MainView>();
|
||||
services.AddSingleton<HomeView>();
|
||||
services.AddSingleton<DevicesView>();
|
||||
services.AddSingleton<VariableTableView>();
|
||||
services.AddScoped<DeviceDetailView>();
|
||||
services.AddScoped<MqttsView>();
|
||||
}
|
||||
|
||||
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(); // 标记为已观察，防止进程终止
|
||||
};
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 初始化菜单
|
||||
/// </summary>
|
||||
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<DbMenu>()
|
||||
.FirstAsync(dm => dm.Name == menu.Name);
|
||||
if (homeMenuExist == null)
|
||||
{
|
||||
await db.Insertable<DbMenu>(menu)
|
||||
.ExecuteCommandAsync();
|
||||
}
|
||||
}
|
||||
|
||||
private void InitializeDataBase()
|
||||
{
|
||||
var _db = DbContext.GetInstance();
|
||||
_db.DbMaintenance.CreateDatabase();
|
||||
_db.CodeFirst.InitTables<DbNlog>();
|
||||
_db.CodeFirst.InitTables<DbNlog>();
|
||||
_db.CodeFirst.InitTables<DbDevice>();
|
||||
_db.CodeFirst.InitTables<DbVariableTable>();
|
||||
_db.CodeFirst.InitTables<DbVariable>();
|
||||
_db.CodeFirst.InitTables<DbVariableHistory>();
|
||||
_db.CodeFirst.InitTables<DbUser>();
|
||||
_db.CodeFirst.InitTables<DbMqtt>();
|
||||
_db.CodeFirst.InitTables<DbVariableMqtt>();
|
||||
_db.CodeFirst.InitTables<DbMenu>();
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user