更新版本号

优化设备线程启停逻辑
添加winform(blazor) demo
部分页面显示内容优化

framework/Directory.Build.props

@@ -1,20 +0,0 @@
-<Project>
-	<PropertyGroup>
-		
-		<ImplicitUsings>enable</ImplicitUsings>
-		<TargetFrameworks>net6.0;net8.0;</TargetFrameworks>
-		<Version>4.0.0.9</Version>
-		<LangVersion>latest</LangVersion>
-		<Authors>Diego</Authors>
-		<Product>ThingsGateway</Product>
-		<Copyright>© 2023-present Diego</Copyright>
-		<RepositoryUrl>https://gitee.com/diego2098/ThingsGateway</RepositoryUrl>
-		<SignAssembly>True</SignAssembly>
-		<DelaySign>False</DelaySign>
-		<SatelliteResourceLanguages>zh-Hans</SatelliteResourceLanguages>
-		<GenerateDocumentationFile>False</GenerateDocumentationFile>
-	</PropertyGroup>
-
-
-
-</Project>

framework/ThingsGateway - Admin.sln

@@ -1,101 +0,0 @@
-
-Microsoft Visual Studio Solution File, Format Version 12.00
-# Visual Studio Version 17
-VisualStudioVersion = 17.6.33927.249
-MinimumVisualStudioVersion = 10.0.40219.1
-Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "admin", "admin", "{4E66C22C-0636-4949-BF6A-9E3BBE1550BA}"
-	ProjectSection(SolutionItems) = preProject
-		admin\Directory.Build.props = admin\Directory.Build.props
-	EndProjectSection
-EndProject
-Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "ThingsGateway.Components", "admin\ThingsGateway.Components\ThingsGateway.Components.csproj", "{0A891D8E-23B3-46AD-8D30-565EE5004F93}"
-EndProject
-Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "ThingsGateway.Core", "admin\ThingsGateway.Core\ThingsGateway.Core.csproj", "{A712EAEE-94F2-4F01-8C1C-2EC802280DD7}"
-EndProject
-Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "ThingsGateway.Admin.Core", "admin\ThingsGateway.Admin.Core\ThingsGateway.Admin.Core.csproj", "{5DA3D2BD-6768-4479-B52F-49E022EFF310}"
-EndProject
-Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "ThingsGateway.Admin.Blazor", "admin\ThingsGateway.Admin.Blazor\ThingsGateway.Admin.Blazor.csproj", "{8DD5DF98-7FDE-4B49-8661-AEB44D923CFE}"
-EndProject
-Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "ThingsGateway.Admin.Application", "admin\ThingsGateway.Admin.Application\ThingsGateway.Admin.Application.csproj", "{D6685A42-2712-417A-92C5-5EFF90B9FA94}"
-EndProject
-Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "ThingsGateway.Admin.ApiController", "admin\ThingsGateway.Admin.ApiController\ThingsGateway.Admin.ApiController.csproj", "{0D17D801-6DAA-4FD1-9A99-F9F07FA6BA88}"
-EndProject
-Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "web", "web", "{F0C9A8CB-231B-45E0-B91B-4FEF7EF47197}"
-	ProjectSection(SolutionItems) = preProject
-		web\Directory.Build.props = web\Directory.Build.props
-	EndProjectSection
-EndProject
-Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "ThingsGateway.Web.Core", "web\ThingsGateway.Web.Core\ThingsGateway.Web.Core.csproj", "{D37EC028-EA46-4510-8261-6E780A906314}"
-EndProject
-Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "ThingsGateway.Web.Entry", "web\ThingsGateway.Web.Entry\ThingsGateway.Web.Entry.csproj", "{C5F662EB-991F-438D-BF61-EF87E7371C04}"
-EndProject
-Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "解决方案项", "解决方案项", "{97B23D8B-C6C0-4746-A21F-C7B49354B284}"
-	ProjectSection(SolutionItems) = preProject
-		..\.gitignore = ..\.gitignore
-	EndProjectSection
-EndProject
-Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "ThingsGateway.Foundation", "foundation\ThingsGateway.Foundation\ThingsGateway.Foundation.csproj", "{6961511A-8787-42AF-827D-B630B2AF4791}"
-EndProject
-Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "foundation", "foundation", "{268A1A81-2685-47E1-9986-5934A58A31A4}"
-EndProject
-Global
-	GlobalSection(SolutionConfigurationPlatforms) = preSolution
-		Debug|Any CPU = Debug|Any CPU
-		Release|Any CPU = Release|Any CPU
-	EndGlobalSection
-	GlobalSection(ProjectConfigurationPlatforms) = postSolution
-		{0A891D8E-23B3-46AD-8D30-565EE5004F93}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
-		{0A891D8E-23B3-46AD-8D30-565EE5004F93}.Debug|Any CPU.Build.0 = Debug|Any CPU
-		{0A891D8E-23B3-46AD-8D30-565EE5004F93}.Release|Any CPU.ActiveCfg = Release|Any CPU
-		{0A891D8E-23B3-46AD-8D30-565EE5004F93}.Release|Any CPU.Build.0 = Release|Any CPU
-		{A712EAEE-94F2-4F01-8C1C-2EC802280DD7}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
-		{A712EAEE-94F2-4F01-8C1C-2EC802280DD7}.Debug|Any CPU.Build.0 = Debug|Any CPU
-		{A712EAEE-94F2-4F01-8C1C-2EC802280DD7}.Release|Any CPU.ActiveCfg = Release|Any CPU
-		{A712EAEE-94F2-4F01-8C1C-2EC802280DD7}.Release|Any CPU.Build.0 = Release|Any CPU
-		{5DA3D2BD-6768-4479-B52F-49E022EFF310}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
-		{5DA3D2BD-6768-4479-B52F-49E022EFF310}.Debug|Any CPU.Build.0 = Debug|Any CPU
-		{5DA3D2BD-6768-4479-B52F-49E022EFF310}.Release|Any CPU.ActiveCfg = Release|Any CPU
-		{5DA3D2BD-6768-4479-B52F-49E022EFF310}.Release|Any CPU.Build.0 = Release|Any CPU
-		{8DD5DF98-7FDE-4B49-8661-AEB44D923CFE}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
-		{8DD5DF98-7FDE-4B49-8661-AEB44D923CFE}.Debug|Any CPU.Build.0 = Debug|Any CPU
-		{8DD5DF98-7FDE-4B49-8661-AEB44D923CFE}.Release|Any CPU.ActiveCfg = Release|Any CPU
-		{8DD5DF98-7FDE-4B49-8661-AEB44D923CFE}.Release|Any CPU.Build.0 = Release|Any CPU
-		{D6685A42-2712-417A-92C5-5EFF90B9FA94}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
-		{D6685A42-2712-417A-92C5-5EFF90B9FA94}.Debug|Any CPU.Build.0 = Debug|Any CPU
-		{D6685A42-2712-417A-92C5-5EFF90B9FA94}.Release|Any CPU.ActiveCfg = Release|Any CPU
-		{D6685A42-2712-417A-92C5-5EFF90B9FA94}.Release|Any CPU.Build.0 = Release|Any CPU
-		{0D17D801-6DAA-4FD1-9A99-F9F07FA6BA88}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
-		{0D17D801-6DAA-4FD1-9A99-F9F07FA6BA88}.Debug|Any CPU.Build.0 = Debug|Any CPU
-		{0D17D801-6DAA-4FD1-9A99-F9F07FA6BA88}.Release|Any CPU.ActiveCfg = Release|Any CPU
-		{0D17D801-6DAA-4FD1-9A99-F9F07FA6BA88}.Release|Any CPU.Build.0 = Release|Any CPU
-		{D37EC028-EA46-4510-8261-6E780A906314}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
-		{D37EC028-EA46-4510-8261-6E780A906314}.Debug|Any CPU.Build.0 = Debug|Any CPU
-		{D37EC028-EA46-4510-8261-6E780A906314}.Release|Any CPU.ActiveCfg = Release|Any CPU
-		{D37EC028-EA46-4510-8261-6E780A906314}.Release|Any CPU.Build.0 = Release|Any CPU
-		{C5F662EB-991F-438D-BF61-EF87E7371C04}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
-		{C5F662EB-991F-438D-BF61-EF87E7371C04}.Debug|Any CPU.Build.0 = Debug|Any CPU
-		{C5F662EB-991F-438D-BF61-EF87E7371C04}.Release|Any CPU.ActiveCfg = Release|Any CPU
-		{C5F662EB-991F-438D-BF61-EF87E7371C04}.Release|Any CPU.Build.0 = Release|Any CPU
-		{6961511A-8787-42AF-827D-B630B2AF4791}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
-		{6961511A-8787-42AF-827D-B630B2AF4791}.Debug|Any CPU.Build.0 = Debug|Any CPU
-		{6961511A-8787-42AF-827D-B630B2AF4791}.Release|Any CPU.ActiveCfg = Release|Any CPU
-		{6961511A-8787-42AF-827D-B630B2AF4791}.Release|Any CPU.Build.0 = Release|Any CPU
-	EndGlobalSection
-	GlobalSection(SolutionProperties) = preSolution
-		HideSolutionNode = FALSE
-	EndGlobalSection
-	GlobalSection(NestedProjects) = preSolution
-		{0A891D8E-23B3-46AD-8D30-565EE5004F93} = {4E66C22C-0636-4949-BF6A-9E3BBE1550BA}
-		{A712EAEE-94F2-4F01-8C1C-2EC802280DD7} = {4E66C22C-0636-4949-BF6A-9E3BBE1550BA}
-		{5DA3D2BD-6768-4479-B52F-49E022EFF310} = {4E66C22C-0636-4949-BF6A-9E3BBE1550BA}
-		{8DD5DF98-7FDE-4B49-8661-AEB44D923CFE} = {4E66C22C-0636-4949-BF6A-9E3BBE1550BA}
-		{D6685A42-2712-417A-92C5-5EFF90B9FA94} = {4E66C22C-0636-4949-BF6A-9E3BBE1550BA}
-		{0D17D801-6DAA-4FD1-9A99-F9F07FA6BA88} = {4E66C22C-0636-4949-BF6A-9E3BBE1550BA}
-		{D37EC028-EA46-4510-8261-6E780A906314} = {F0C9A8CB-231B-45E0-B91B-4FEF7EF47197}
-		{C5F662EB-991F-438D-BF61-EF87E7371C04} = {F0C9A8CB-231B-45E0-B91B-4FEF7EF47197}
-		{6961511A-8787-42AF-827D-B630B2AF4791} = {268A1A81-2685-47E1-9986-5934A58A31A4}
-	EndGlobalSection
-	GlobalSection(ExtensibilityGlobals) = postSolution
-		SolutionGuid = {C49B2D3E-6818-4E28-91B7-6E4E7E264BBB}
-	EndGlobalSection
-EndGlobal

framework/ThingsGateway.sln

@@ -82,8 +82,6 @@ EndProject
 Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "解决方案项", "解决方案项", "{97B23D8B-C6C0-4746-A21F-C7B49354B284}"
 	ProjectSection(SolutionItems) = preProject
 		..\.gitignore = ..\.gitignore
-		Directory.Build.props = Directory.Build.props
-		..\README.md = ..\README.md
 	EndProjectSection
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "ThingsGateway.Plugin.Kafka", "plugin\ThingsGateway.Plugin.Kafka\ThingsGateway.Plugin.Kafka.csproj", "{E4B8B8E6-FAE7-43BA-9A51-33A3CD9FB825}"

framework/admin/Directory.Build.props

@@ -1,7 +1,17 @@
 <Project>
-	<Import Project="$(SolutionDir)\Directory.Build.props" />
 	<PropertyGroup>
-
+		<ImplicitUsings>enable</ImplicitUsings>
+		<TargetFrameworks>net6.0;net8.0;</TargetFrameworks>
+		<Version>4.0.0.1</Version>
+		<LangVersion>latest</LangVersion>
+		<ImplicitUsings>enable</ImplicitUsings>
+		<Authors>Diego</Authors>
+		<Product>ThingsGateway</Product>
+		<Copyright>© 2023-present Diego</Copyright>
+		<RepositoryUrl>https://gitee.com/diego2098/ThingsGateway</RepositoryUrl>
+		<SignAssembly>True</SignAssembly>
+		<DelaySign>False</DelaySign>
+		<SatelliteResourceLanguages>zh-Hans</SatelliteResourceLanguages>
 	</PropertyGroup>
 
 

framework/admin/ThingsGateway.Admin.ApiController/Controllers/SwaggerController.cs

@@ -27,12 +27,12 @@ namespace ThingsGateway.Admin.ApiController;
 [Route("Swagger")]
 public class SwaggerController : IDynamicApiController, IScoped
 {
-    private readonly IConfigService _configService;
+    private readonly ConfigService _configService;
     /// <summary>
     /// <inheritdoc cref="SwaggerController"/>
     /// </summary>
     /// <param name="sysConfigService"></param>
-    public SwaggerController(IConfigService sysConfigService)
+    public SwaggerController(ConfigService sysConfigService)
     {
         _configService = sysConfigService;
     }

framework/admin/ThingsGateway.Admin.ApiController/ThingsGateway.Admin.ApiController.xml

@@ -79,7 +79,7 @@
             Swagger登录授权服务
             </summary>
         </member>
-        <member name="M:ThingsGateway.Admin.ApiController.SwaggerController.#ctor(ThingsGateway.Admin.Application.IConfigService)">
+        <member name="M:ThingsGateway.Admin.ApiController.SwaggerController.#ctor(ThingsGateway.Admin.Application.ConfigService)">
             <summary>
             <inheritdoc cref="T:ThingsGateway.Admin.ApiController.SwaggerController"/>
             </summary>

framework/admin/ThingsGateway.Admin.Application/Aop/OperDispatchProxy.cs

@@ -96,7 +96,7 @@ public class OperDispatchProxy : AspectDispatchProxy, IDispatchProxy
     /// <exception cref="NotImplementedException"></exception>
     public override async Task InvokeAsync(MethodInfo method, object[] args)
     {
-        var desc = method.GetActualCustomAttribute<OperDescAttribute>(Target, true);
+        var desc = method.GetActualCustomAttribute<OperDescAttribute>(Target);
         if (desc == null)
         {
             var task = method.Invoke(Target, args) as Task;
@@ -134,7 +134,7 @@ public class OperDispatchProxy : AspectDispatchProxy, IDispatchProxy
     /// <exception cref="NotImplementedException"></exception>
     public override async Task<T> InvokeAsyncT<T>(MethodInfo method, object[] args)
     {
-        var desc = method.GetActualCustomAttribute<OperDescAttribute>(Target, true);
+        var desc = method.GetActualCustomAttribute<OperDescAttribute>(Target);
         if (desc == null)
         {
             var taskT = method.Invoke(Target, args) as Task<T>;

framework/admin/ThingsGateway.Admin.Application/OpenApi/Services/Session/OpenApiSessionService.cs

@@ -83,7 +83,7 @@ public class OpenApiSessionService : DbRepository<OpenApiUser>, IOpenApiSessionS
                 var verificatInfos = await _verificatService.GetVerificatIdAsync(it.Id);
                 if (verificatInfos != null)
                 {
-                    GetVerificatInfos(ref verificatInfos);//获取剩余时间
+                    OpenApiSessionService.GetVerificatInfos(ref verificatInfos);//获取剩余时间
                     it.VerificatCount = verificatInfos.Count;//令牌数量
                     it.VerificatSignList = verificatInfos;//令牌列表
                 }

framework/admin/ThingsGateway.Admin.Application/System/Services/Session/SessionService.cs

@@ -73,7 +73,7 @@ public class SessionService : DbRepository<SysUser>, ISessionService
                   var verificatInfos = await _verificatService.GetVerificatIdAsync(it.Id);
                   if (verificatInfos != null)
                   {
-                      GetVerificatInfos(ref verificatInfos);//获取剩余时间
+                      SessionService.GetVerificatInfos(ref verificatInfos);//获取剩余时间
                       it.VerificatCount = verificatInfos.Count;//令牌数量
                       it.VerificatSignList = verificatInfos;//令牌列表
 

framework/admin/ThingsGateway.Admin.Application/ThingsGateway.Admin.Application.csproj

@@ -12,7 +12,7 @@
 	<ItemGroup>
 		<ProjectReference Include="..\ThingsGateway.Admin.Core\ThingsGateway.Admin.Core.csproj" />
 		<PackageReference Include="MiniExcel" Version="1.31.2" />
-		<PackageReference Include="System.Linq.Dynamic.Core" Version="1.3.7" />
+		<PackageReference Include="System.Linq.Dynamic.Core" Version="1.3.5" />
 	</ItemGroup>
 
 </Project>

framework/admin/ThingsGateway.Admin.Application/Util/SeedDataUtil.cs

@@ -10,8 +10,6 @@
 //------------------------------------------------------------------------------
 #endregion
 
-using System.Text.RegularExpressions;
-
 using ThingsGateway.Foundation.Extension.String;
 
 namespace ThingsGateway.Admin.Application;
@@ -36,8 +34,7 @@ public class SeedDataUtil
         if (!string.IsNullOrEmpty(dataString))//如果有内容
         {
             //字段没有数据的替换成null
-            dataString = Regex.Replace(dataString, "\\\"[^\"]+?\\\": \\\"\\\"", match => match.Value.Replace("\"\"", "null"));
-            //dataString = dataString.Replace("\"\"", "null");
+            dataString = dataString.Replace("\"\"", "null");
             //将json字符串转为实体，这里extjson可以正常转换为字符串
             var seedDataRecord = Newtonsoft.Json.JsonConvert.DeserializeObject<SeedDataRecords<T>>(dataString);
 

framework/admin/ThingsGateway.Admin.Blazor/Page/Base.razor.cs

@@ -37,7 +37,7 @@ namespace ThingsGateway.Admin.Blazor
             {
                 try
                 {
-                    var data = await _serviceScope.ServiceProvider.GetService<IUserCenterService>().GetLoginDefaultRazorAsync(UserManager.UserId);
+                    var data = await _serviceScope.ServiceProvider.GetService<UserCenterService>().GetLoginDefaultRazorAsync(UserManager.UserId);
                     var sameLevelMenus = await _serviceScope.ServiceProvider.GetService<IResourceService>().GetaMenuAndSpaListAsync();
                     if (NavigationManager.ToAbsoluteUri(NavigationManager.Uri).AbsolutePath == "/Login" || NavigationManager.ToAbsoluteUri(NavigationManager.Uri).AbsolutePath == "/")
                         NavigationManager.NavigateTo(sameLevelMenus.FirstOrDefault(a => a.Id == data)?.Component ?? "index", true);

framework/admin/ThingsGateway.Admin.Blazor/Page/Config.razor.cs

@@ -39,26 +39,26 @@ public partial class Config
     }
     private async Task AddCallAsync(ConfigAddInput input)
     {
-        await _serviceScope.ServiceProvider.GetService<IConfigService>().AddAsync(input);
+        await _serviceScope.ServiceProvider.GetService<ConfigService>().AddAsync(input);
     }
 
     private async Task DeleteCallAsync(IEnumerable<SysConfig> sysConfigs)
     {
-        await _serviceScope.ServiceProvider.GetService<IConfigService>().DeleteAsync(sysConfigs.Select(a => a.Id).ToArray());
+        await _serviceScope.ServiceProvider.GetService<ConfigService>().DeleteAsync(sysConfigs.Select(a => a.Id).ToArray());
     }
     private async Task EditCallAsync(ConfigEditInput sysConfigs)
     {
-        await _serviceScope.ServiceProvider.GetService<IConfigService>().EditAsync(sysConfigs);
+        await _serviceScope.ServiceProvider.GetService<ConfigService>().EditAsync(sysConfigs);
     }
 
     private async Task OnSaveAsync()
     {
-        await _serviceScope.ServiceProvider.GetService<IConfigService>().EditBatchAsync(_sysConfig);
+        await _serviceScope.ServiceProvider.GetService<ConfigService>().EditBatchAsync(_sysConfig);
         await _mainLayout.StateHasChangedAsync();
         await PopupService.EnqueueSnackbarAsync("成功", AlertTypes.Success);
     }
     private async Task<ISqlSugarPagedList<SysConfig>> QueryCallAsync(ConfigPageInput input)
     {
-        return await _serviceScope.ServiceProvider.GetService<IConfigService>().PageAsync(input);
+        return await _serviceScope.ServiceProvider.GetService<ConfigService>().PageAsync(input);
     }
 }

framework/admin/ThingsGateway.Admin.Blazor/Page/Menu.razor.cs

@@ -45,23 +45,23 @@ public partial class Menu
     private async Task AddCallAsync(MenuAddInput input)
     {
         input.ParentId = _search.ParentId;
-        await _serviceScope.ServiceProvider.GetService<IMenuService>().AddAsync(input);
+        await _serviceScope.ServiceProvider.GetService<MenuService>().AddAsync(input);
         await NavChangeAsync();
     }
     private async Task ButtonAddCallAsync(ButtonAddInput input)
     {
         input.ParentId = _buttonParentId;
-        await _serviceScope.ServiceProvider.GetService<IButtonService>().AddAsync(input);
+        await _serviceScope.ServiceProvider.GetService<ButtonService>().AddAsync(input);
     }
 
     private async Task ButtonDeleteCallAsync(IEnumerable<SysResource> input)
     {
-        await _serviceScope.ServiceProvider.GetService<IButtonService>().DeleteAsync(input.Select(a => a.Id).ToArray());
+        await _serviceScope.ServiceProvider.GetService<ButtonService>().DeleteAsync(input.Select(a => a.Id).ToArray());
     }
 
     private async Task ButtonEditCallAsync(ButtonEditInput input)
     {
-        await _serviceScope.ServiceProvider.GetService<IButtonService>().EditAsync(input);
+        await _serviceScope.ServiceProvider.GetService<ButtonService>().EditAsync(input);
 
     }
 
@@ -85,7 +85,7 @@ public partial class Menu
     private async Task<ISqlSugarPagedList<SysResource>> ButtonQueryCallAsync(ButtonPageInput input)
     {
         input.ParentId = _buttonParentId;
-        var data = await _serviceScope.ServiceProvider.GetService<IButtonService>().PageAsync(input);
+        var data = await _serviceScope.ServiceProvider.GetService<ButtonService>().PageAsync(input);
         return data;
     }
 
@@ -96,13 +96,13 @@ public partial class Menu
 
     private async Task DeleteCallAsync(IEnumerable<SysResource> input)
     {
-        await _serviceScope.ServiceProvider.GetService<IMenuService>().DeleteAsync(input.Select(a => a.Id).ToArray());
+        await _serviceScope.ServiceProvider.GetService<MenuService>().DeleteAsync(input.Select(a => a.Id).ToArray());
         await NavChangeAsync();
 
     }
     private async Task EditCallAsync(MenuEditInput input)
     {
-        await _serviceScope.ServiceProvider.GetService<IMenuService>().EditAsync(input);
+        await _serviceScope.ServiceProvider.GetService<MenuService>().EditAsync(input);
         await NavChangeAsync();
 
     }
@@ -123,7 +123,7 @@ public partial class Menu
     }
     private async Task<ISqlSugarPagedList<SysResource>> QueryCallAsync(MenuPageInput input)
     {
-        var data = await _serviceScope.ServiceProvider.GetService<IMenuService>().TreeAsync(input);
+        var data = await _serviceScope.ServiceProvider.GetService<MenuService>().TreeAsync(input);
         return data.ToPagedList(input);
     }
 

framework/admin/ThingsGateway.Admin.Blazor/Page/OpenApiSession.razor.cs

@@ -32,13 +32,13 @@ public partial class OpenApiSession
         var confirm = await PopupService.OpenConfirmDialogAsync("警告", "确定 ?");
         if (confirm)
         {
-            await _serviceScope.ServiceProvider.GetService<IOpenApiSessionService>().ExitSessionAsync(id);
+            await _serviceScope.ServiceProvider.GetService<OpenApiSessionService>().ExitSessionAsync(id);
         }
     }
 
     private async Task<ISqlSugarPagedList<OpenApiSessionOutput>> SessionQueryCallAsync(OpenApiSessionPageInput input)
     {
-        return await _serviceScope.ServiceProvider.GetService<IOpenApiSessionService>().PageAsync(input);
+        return await _serviceScope.ServiceProvider.GetService<OpenApiSessionService>().PageAsync(input);
     }
 
     private async Task ShowVerificatListAsync(List<VerificatInfo> verificatInfos)
@@ -56,7 +56,7 @@ public partial class OpenApiSession
             VerificatIds = verificats.Select(it => it.Id).ToList(),
             Id = verificats.First().UserId
         };
-        await _serviceScope.ServiceProvider.GetService<IOpenApiSessionService>().ExitVerificatAsync(send);
+        await _serviceScope.ServiceProvider.GetService<OpenApiSessionService>().ExitVerificatAsync(send);
         _verificatInfos.RemoveWhere(it => send.VerificatIds.Contains(it.Id));
     }
 

framework/admin/ThingsGateway.Admin.Blazor/Page/OpenApiUserR.razor.cs

@@ -32,17 +32,17 @@ public partial class OpenApiUserR
 
     private async Task AddCallAsync(OpenApiUserAddInput input)
     {
-        await _serviceScope.ServiceProvider.GetService<IOpenApiUserService>().AddAsync(input);
+        await _serviceScope.ServiceProvider.GetService<OpenApiUserService>().AddAsync(input);
     }
 
     private async Task DeleteCallAsync(IEnumerable<OpenApiUser> users)
     {
-        await _serviceScope.ServiceProvider.GetService<IOpenApiUserService>().DeleteAsync(users.Select(a => a.Id).ToArray());
+        await _serviceScope.ServiceProvider.GetService<OpenApiUserService>().DeleteAsync(users.Select(a => a.Id).ToArray());
     }
 
     private async Task EditCallAsync(OpenApiUserEditInput users)
     {
-        await _serviceScope.ServiceProvider.GetService<IOpenApiUserService>().EditAsync(users);
+        await _serviceScope.ServiceProvider.GetService<OpenApiUserService>().EditAsync(users);
     }
 
     private List<OpenApiPermissionTreeSelector> GetRouters()
@@ -58,7 +58,7 @@ public partial class OpenApiUserR
             OpenApiUserGrantPermissionInput userGrantRoleInput = new();
             userGrantRoleInput.Id = _choiceUserId;
             userGrantRoleInput.PermissionList = _rolesChoice.Select(it => it.ApiRoute).ToList();
-            await _serviceScope.ServiceProvider.GetService<IOpenApiUserService>().GrantRoleAsync(userGrantRoleInput);
+            await _serviceScope.ServiceProvider.GetService<OpenApiUserService>().GrantRoleAsync(userGrantRoleInput);
             _isShowRoles = false;
             await _datatable?.QueryClickAsync();
         }
@@ -70,7 +70,7 @@ public partial class OpenApiUserR
     }
     private async Task<ISqlSugarPagedList<OpenApiUser>> QueryCallAsync(OpenApiUserPageInput input)
     {
-        return await _serviceScope.ServiceProvider.GetService<IOpenApiUserService>().PageAsync(input);
+        return await _serviceScope.ServiceProvider.GetService<OpenApiUserService>().PageAsync(input);
     }
 
     private async Task UserStatusChangeAsync(OpenApiUser context, bool enable)
@@ -78,9 +78,9 @@ public partial class OpenApiUserR
         try
         {
             if (enable)
-                await _serviceScope.ServiceProvider.GetService<IOpenApiUserService>().EnableUserAsync(context.Id);
+                await _serviceScope.ServiceProvider.GetService<OpenApiUserService>().EnableUserAsync(context.Id);
             else
-                await _serviceScope.ServiceProvider.GetService<IOpenApiUserService>().DisableUserAsync(context.Id);
+                await _serviceScope.ServiceProvider.GetService<OpenApiUserService>().DisableUserAsync(context.Id);
         }
         finally
         {

framework/admin/ThingsGateway.Admin.Blazor/Page/Oplog.razor.cs

@@ -47,7 +47,7 @@ public partial class Oplog
         var confirm = await PopupService.OpenConfirmDialogAsync("删除", "确定 ?");
         if (confirm)
         {
-            await _serviceScope.ServiceProvider.GetService<IOperateLogService>().DeleteAsync(_categoryFilters.Select(it => it.Value).ToArray());
+            await _serviceScope.ServiceProvider.GetService<OperateLogService>().DeleteAsync(_categoryFilters.Select(it => it.Value).ToArray());
             await _datatable?.QueryClickAsync();
         }
     }
@@ -68,6 +68,6 @@ public partial class Oplog
         input.Account = _search.Account;
         input.Category = _search.Category;
         input.ExeStatus = _search.ExeStatus;
-        return await _serviceScope.ServiceProvider.GetService<IOperateLogService>().PageAsync(input);
+        return await _serviceScope.ServiceProvider.GetService<OperateLogService>().PageAsync(input);
     }
 }

framework/admin/ThingsGateway.Admin.Blazor/Page/Role.razor.cs

@@ -41,17 +41,17 @@ public partial class Role
 
     private async Task AddCallAsync(RoleAddInput input)
     {
-        await _serviceScope.ServiceProvider.GetService<IRoleService>().AddAsync(input);
+        await _serviceScope.ServiceProvider.GetService<RoleService>().AddAsync(input);
     }
     private async Task DeleteCallAsync(IEnumerable<SysRole> sysRoles)
     {
-        await _serviceScope.ServiceProvider.GetService<IRoleService>().DeleteAsync(sysRoles.Select(a => a.Id).ToArray());
+        await _serviceScope.ServiceProvider.GetService<RoleService>().DeleteAsync(sysRoles.Select(a => a.Id).ToArray());
         await _mainLayout.StateHasChangedAsync();
     }
 
     private async Task EditCallAsync(RoleEditInput input)
     {
-        await _serviceScope.ServiceProvider.GetService<IRoleService>().EditAsync(input);
+        await _serviceScope.ServiceProvider.GetService<RoleService>().EditAsync(input);
         await _mainLayout.StateHasChangedAsync();
     }
     private async Task OnRoleHasResuorcesSaveAsync(ModalActionEventArgs args)
@@ -62,7 +62,7 @@ public partial class Role
             var data = new List<SysResource>();
             userGrantRoleInput.Id = _choiceRoleId;
             userGrantRoleInput.GrantInfoList = _roleHasResuorces;
-            await _serviceScope.ServiceProvider.GetService<IRoleService>().GrantResourceAsync(userGrantRoleInput);
+            await _serviceScope.ServiceProvider.GetService<RoleService>().GrantResourceAsync(userGrantRoleInput);
             _isShowResuorces = false;
         }
         catch (Exception ex)
@@ -79,7 +79,7 @@ public partial class Role
             GrantUserInput userGrantRoleInput = new();
             userGrantRoleInput.Id = _choiceRoleId;
             userGrantRoleInput.GrantInfoList = _usersChoice.Select(it => it.Id).ToList();
-            await _serviceScope.ServiceProvider.GetService<IRoleService>().GrantUserAsync(userGrantRoleInput);
+            await _serviceScope.ServiceProvider.GetService<RoleService>().GrantUserAsync(userGrantRoleInput);
             _isShowUsers = false;
         }
         catch (Exception ex)
@@ -92,19 +92,19 @@ public partial class Role
 
     private async Task<ISqlSugarPagedList<SysRole>> QueryCallAsync(RolePageInput input)
     {
-        return await _serviceScope.ServiceProvider.GetService<IRoleService>().PageAsync(input);
+        return await _serviceScope.ServiceProvider.GetService<RoleService>().PageAsync(input);
     }
 
     private async Task ResuorceInitAsync()
     {
         _resTreeSelectors = (await _serviceScope.ServiceProvider.GetService<ResourceService>().GetRoleGrantResourceMenusAsync());
-        _roleHasResuorces = (await _serviceScope.ServiceProvider.GetService<IRoleService>().OwnResourceAsync(_choiceRoleId))?.GrantInfoList;
+        _roleHasResuorces = (await _serviceScope.ServiceProvider.GetService<RoleService>().OwnResourceAsync(_choiceRoleId))?.GrantInfoList;
     }
 
     private async Task<List<UserSelectorOutput>> UserInitAsync()
     {
-        _allUsers = await _serviceScope.ServiceProvider.GetService<ISysUserService>().UserSelectorAsync(_searchKey);
-        var data = await _serviceScope.ServiceProvider.GetService<IRoleService>().OwnUserAsync(_choiceRoleId);
+        _allUsers = await _serviceScope.ServiceProvider.GetService<SysUserService>().UserSelectorAsync(_searchKey);
+        var data = await _serviceScope.ServiceProvider.GetService<RoleService>().OwnUserAsync(_choiceRoleId);
         _usersChoice = _allUsers.Where(a => data.Contains(a.Id)).ToList();
         return _allUsers;
     }

framework/admin/ThingsGateway.Admin.Blazor/Page/Session.razor.cs

@@ -37,14 +37,14 @@ public partial class Session
         var confirm = await PopupService.OpenConfirmDialogAsync("警告", "确定 ?");
         if (confirm)
         {
-            await _serviceScope.ServiceProvider.GetService<ISessionService>().ExitSessionAsync(id);
+            await _serviceScope.ServiceProvider.GetService<SessionService>().ExitSessionAsync(id);
         }
     }
 
 
     private async Task<ISqlSugarPagedList<SessionOutput>> SessionQueryCallAsync(SessionPageInput input)
     {
-        return await _serviceScope.ServiceProvider.GetService<ISessionService>().PageAsync(input);
+        return await _serviceScope.ServiceProvider.GetService<SessionService>().PageAsync(input);
     }
 
     private async Task ShowVerificatListAsync(List<VerificatInfo> verificatInfos)
@@ -62,7 +62,7 @@ public partial class Session
             VerificatIds = verificats.Select(it => it.Id).ToList(),
             Id = verificats.First().UserId
         };
-        await _serviceScope.ServiceProvider.GetService<ISessionService>().ExitVerificatAsync(send);
+        await _serviceScope.ServiceProvider.GetService<SessionService>().ExitVerificatAsync(send);
         _verificatInfos.RemoveWhere(it => send.VerificatIds.Contains(it.Id));
     }
 

framework/admin/ThingsGateway.Admin.Blazor/Page/Spa.razor.cs

@@ -28,23 +28,23 @@ public partial class Spa
 
     private async Task AddCallAsync(SpaAddInput input)
     {
-        await _serviceScope.ServiceProvider.GetService<ISpaService>().AddAsync(input);
+        await _serviceScope.ServiceProvider.GetService<SpaService>().AddAsync(input);
         await _mainLayout.StateHasChangedAsync();
     }
     private async Task DeleteCallAsync(IEnumerable<SysResource> input)
     {
-        await _serviceScope.ServiceProvider.GetService<ISpaService>().DeleteAsync(input.Select(a => a.Id).ToArray());
+        await _serviceScope.ServiceProvider.GetService<SpaService>().DeleteAsync(input.Select(a => a.Id).ToArray());
         await _mainLayout.StateHasChangedAsync();
     }
 
     private async Task EditCallAsync(SpaEditInput input)
     {
-        await _serviceScope.ServiceProvider.GetService<ISpaService>().EditAsync(input);
+        await _serviceScope.ServiceProvider.GetService<SpaService>().EditAsync(input);
         await _mainLayout.StateHasChangedAsync();
     }
 
     private async Task<ISqlSugarPagedList<SysResource>> QueryCallAsync(SpaPageInput input)
     {
-        return await _serviceScope.ServiceProvider.GetService<ISpaService>().PageAsync(input);
+        return await _serviceScope.ServiceProvider.GetService<SpaService>().PageAsync(input);
     }
 }

framework/admin/ThingsGateway.Admin.Blazor/Page/User.razor.cs

@@ -35,17 +35,17 @@ public partial class User
 
     private async Task AddCallAsync(UserAddInput input)
     {
-        await _serviceScope.ServiceProvider.GetService<ISysUserService>().AddAsync(input);
+        await _serviceScope.ServiceProvider.GetService<SysUserService>().AddAsync(input);
     }
     private async Task DeleteCallAsync(IEnumerable<SysUser> users)
     {
-        await _serviceScope.ServiceProvider.GetService<ISysUserService>().DeleteAsync(users.Select(a => a.Id).ToArray());
+        await _serviceScope.ServiceProvider.GetService<SysUserService>().DeleteAsync(users.Select(a => a.Id).ToArray());
         await _mainLayout.StateHasChangedAsync();
     }
 
     private async Task EditCallAsync(UserEditInput users)
     {
-        await _serviceScope.ServiceProvider.GetService<ISysUserService>().EditAsync(users);
+        await _serviceScope.ServiceProvider.GetService<SysUserService>().EditAsync(users);
         await _mainLayout.StateHasChangedAsync();
     }
 
@@ -56,7 +56,7 @@ public partial class User
             UserGrantRoleInput userGrantRoleInput = new();
             userGrantRoleInput.Id = _choiceUserId;
             userGrantRoleInput.RoleIdList = _rolesChoice.Select(it => it.Id).ToList();
-            await _serviceScope.ServiceProvider.GetService<ISysUserService>().GrantRoleAsync(userGrantRoleInput);
+            await _serviceScope.ServiceProvider.GetService<SysUserService>().GrantRoleAsync(userGrantRoleInput);
             _isShowRoles = false;
         }
         catch (Exception ex)
@@ -68,20 +68,20 @@ public partial class User
     }
     private async Task<ISqlSugarPagedList<SysUser>> QueryCallAsync(UserPageInput input)
     {
-        return await _serviceScope.ServiceProvider.GetService<ISysUserService>().PageAsync(input);
+        return await _serviceScope.ServiceProvider.GetService<SysUserService>().PageAsync(input);
     }
 
     private async Task ResetPasswordAsync(SysUser sysUser)
     {
-        await _serviceScope.ServiceProvider.GetService<ISysUserService>().ResetPasswordAsync(sysUser.Id);
+        await _serviceScope.ServiceProvider.GetService<SysUserService>().ResetPasswordAsync(sysUser.Id);
         await PopupService.EnqueueSnackbarAsync(new("成功", AlertTypes.Success));
         await _mainLayout.StateHasChangedAsync();
     }
 
     private async Task RoleInitAsync()
     {
-        _allRoles = await _serviceScope.ServiceProvider.GetService<IRoleService>().RoleSelectorAsync();
-        var data = await _serviceScope.ServiceProvider.GetService<IRoleService>().GetRoleIdListByUserIdAsync(_choiceUserId);
+        _allRoles = await _serviceScope.ServiceProvider.GetService<RoleService>().RoleSelectorAsync();
+        var data = await _serviceScope.ServiceProvider.GetService<RoleService>().GetRoleIdListByUserIdAsync(_choiceUserId);
         _rolesChoice = _allRoles.Where(a => data.Contains(a.Id)).ToList();
     }
     private async Task UserStatusChangeAsync(SysUser context, bool enable)
@@ -89,9 +89,9 @@ public partial class User
         try
         {
             if (enable)
-                await _serviceScope.ServiceProvider.GetService<ISysUserService>().EnableUserAsync(context.Id);
+                await _serviceScope.ServiceProvider.GetService<SysUserService>().EnableUserAsync(context.Id);
             else
-                await _serviceScope.ServiceProvider.GetService<ISysUserService>().DisableUserAsync(context.Id);
+                await _serviceScope.ServiceProvider.GetService<SysUserService>().DisableUserAsync(context.Id);
         }
         finally
         {

framework/admin/ThingsGateway.Admin.Blazor/Page/UserCenter.razor.cs

@@ -44,14 +44,14 @@ public partial class UserCenter
 
     async Task OnDefaultRazorSaveAsync()
     {
-        await _serviceScope.ServiceProvider.GetService<IUserCenterService>().UpdateUserDefaultRazorAsync(UserManager.UserId, _defaultMenuId);
+        await _serviceScope.ServiceProvider.GetService<UserCenterService>().UpdateUserDefaultRazorAsync(UserManager.UserId, _defaultMenuId);
         await _mainLayout.StateHasChangedAsync();
         await PopupService.EnqueueSnackbarAsync("成功", AlertTypes.Success);
     }
 
     async Task OnShortcutSaveAsync()
     {
-        await _serviceScope.ServiceProvider.GetService<IUserCenterService>().UpdateWorkbenchAsync(_menusChoice);
+        await _serviceScope.ServiceProvider.GetService<UserCenterService>().UpdateWorkbenchAsync(_menusChoice);
         await _mainLayout.StateHasChangedAsync();
         await PopupService.EnqueueSnackbarAsync("成功", AlertTypes.Success);
     }
@@ -62,7 +62,7 @@ public partial class UserCenter
         {
             //验证成功，操作业务
             _passwordInfoInput.Id = UserResoures.CurrentUser.Id;
-            await _serviceScope.ServiceProvider.GetService<IUserCenterService>().EditPasswordAsync(_passwordInfoInput);
+            await _serviceScope.ServiceProvider.GetService<UserCenterService>().EditPasswordAsync(_passwordInfoInput);
             await _mainLayout.StateHasChangedAsync();
             await PopupService.EnqueueSnackbarAsync("成功，将重新登录", AlertTypes.Success);
             await Task.Delay(2000);
@@ -72,7 +72,7 @@ public partial class UserCenter
 
     async Task OnUpdateUserInfoAsync()
     {
-        await _serviceScope.ServiceProvider.GetService<IUserCenterService>().UpdateUserInfoAsync(_updateInfoInput);
+        await _serviceScope.ServiceProvider.GetService<UserCenterService>().UpdateUserInfoAsync(_updateInfoInput);
         await _mainLayout.StateHasChangedAsync();
         await PopupService.EnqueueSnackbarAsync("成功", AlertTypes.Success);
     }

framework/admin/ThingsGateway.Admin.Blazor/Page/Vislog.razor.cs

@@ -56,7 +56,7 @@ public partial class Vislog
         var confirm = await PopupService.OpenConfirmDialogAsync("删除", "确定 ?");
         if (confirm)
         {
-            await _serviceScope.ServiceProvider.GetService<IVisitLogService>().DeleteAsync(_categoryFilters.Select(it => it.Value).ToArray());
+            await _serviceScope.ServiceProvider.GetService<VisitLogService>().DeleteAsync(_categoryFilters.Select(it => it.Value).ToArray());
             await _datatable?.QueryClickAsync();
         }
     }
@@ -74,7 +74,7 @@ public partial class Vislog
 
     private async Task<ISqlSugarPagedList<SysVisitLog>> QueryCallAsync(VisitLogPageInput input)
     {
-        var data = await _serviceScope.ServiceProvider.GetService<IVisitLogService>().PageAsync(input);
+        var data = await _serviceScope.ServiceProvider.GetService<VisitLogService>().PageAsync(input);
         return data;
     }
 }

framework/admin/ThingsGateway.Admin.Blazor/Shared/Login.razor.cs

@@ -1,12 +1,12 @@
-#region copyright
+#region copyright
 //------------------------------------------------------------------------------
-//  此代码版权声明为全文件覆盖，如有原作者特别声明，会在下方手动补充
-//  此代码版权（除特别声明外的代码）归作者本人Diego所有
-//  源代码使用协议遵循本仓库的开源协议及附加协议
-//  Gitee源代码仓库：https://gitee.com/diego2098/ThingsGateway
-//  Github源代码仓库：https://github.com/kimdiego2098/ThingsGateway
-//  使用文档：https://diego2098.gitee.io/thingsgateway-docs/
-//  QQ群：605534569
+//  <EFBFBD>˴<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ȩ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ϊȫ<EFBFBD>ļ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>ǣ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ԭ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ر<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>·<EFBFBD><EFBFBD>ֶ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
+//  <EFBFBD>˴<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ȩ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ر<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ĵ<EFBFBD><EFBFBD>룩<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>߱<EFBFBD><EFBFBD><EFBFBD>Diego<EFBFBD><EFBFBD><EFBFBD><EFBFBD>
+//  Դ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʹ<EFBFBD><EFBFBD>Э<EFBFBD><EFBFBD><EFBFBD><EFBFBD>ѭ<EFBFBD><EFBFBD><EFBFBD>ֿ<EFBFBD><EFBFBD>Ŀ<EFBFBD>ԴЭ<EFBFBD>鼰<EFBFBD><EFBFBD><EFBFBD><EFBFBD>Э<EFBFBD><EFBFBD>
+//  GiteeԴ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ֿ⣺https://gitee.com/diego2098/ThingsGateway
+//  GithubԴ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ֿ⣺https://github.com/kimdiego2098/ThingsGateway
+//  ʹ<EFBFBD><EFBFBD><EFBFBD>ĵ<EFBFBD><EFBFBD><EFBFBD>https://diego2098.gitee.io/thingsgateway-docs/
+//  QQȺ<EFBFBD><EFBFBD>605534569
 //------------------------------------------------------------------------------
 #endregion
 
@@ -16,7 +16,8 @@ using Masa.Blazor.Presets;
 
 using Microsoft.AspNetCore.Components.Web;
 using Microsoft.Extensions.DependencyInjection;
-using Microsoft.Extensions.Hosting;
+
+using System.Diagnostics;
 
 using ThingsGateway.Foundation.Extension.String;
 
@@ -43,7 +44,7 @@ public partial class Login
     /// <inheritdoc/>
     protected override async Task OnParametersSetAsync()
     {
-        if (App.WebHostEnvironment.IsDevelopment())
+        if (Debugger.IsAttached)
         {
             _loginModel.Account = "superAdmin";
             _password = "111111";
@@ -53,7 +54,7 @@ public partial class Login
         _configTitle = (await _serviceScope.ServiceProvider.GetService<IConfigService>().GetByConfigKeyAsync(ConfigConst.SYS_CONFIGBASEDEFAULT, ConfigConst.CONFIG_TITLE))?.ConfigValue;
         _configRemark = (await _serviceScope.ServiceProvider.GetService<IConfigService>().GetByConfigKeyAsync(ConfigConst.SYS_CONFIGBASEDEFAULT, ConfigConst.CONFIG_REMARK))?.ConfigValue;
         _showCaptcha = (await _serviceScope.ServiceProvider.GetService<IConfigService>().GetByConfigKeyAsync(ConfigConst.SYS_CONFIGBASEDEFAULT, ConfigConst.CONFIG_CAPTCHA_OPEN))?.ConfigValue?.ToBool(false) == true;
-        _welcome = "欢迎使用" + _configTitle + "!";
+        _welcome = "<EFBFBD><EFBFBD>ӭʹ<EFBFBD><EFBFBD>" + _configTitle + "!";
         await base.OnParametersSetAsync();
     }
 
@@ -101,14 +102,14 @@ public partial class Login
                     await _captcha.RefreshCode();
                 }
 
-                await PopupService.EnqueueSnackbarAsync(new("登录错误" + ": " + ret.Msg.ToString(), AlertTypes.Error));
+                await PopupService.EnqueueSnackbarAsync(new("<EFBFBD><EFBFBD>¼<EFBFBD><EFBFBD><EFBFBD><EFBFBD>" + ": " + ret.Msg.ToString(), AlertTypes.Error));
             }
             else
             {
-                await PopupService.EnqueueSnackbarAsync(new("登录成功", AlertTypes.Success));
+                await PopupService.EnqueueSnackbarAsync(new("<EFBFBD><EFBFBD>¼<EFBFBD>ɹ<EFBFBD>", AlertTypes.Success));
                 await Task.Delay(500);
-                var userId = await _serviceScope.ServiceProvider.GetService<ISysUserService>().GetIdByAccountAsync(_loginModel.Account);
-                var data = await _serviceScope.ServiceProvider.GetService<IUserCenterService>().GetLoginDefaultRazorAsync(userId);
+                var userId = await _serviceScope.ServiceProvider.GetService<SysUserService>().GetIdByAccountAsync(_loginModel.Account);
+                var data = await _serviceScope.ServiceProvider.GetService<UserCenterService>().GetLoginDefaultRazorAsync(userId);
                 var sameLevelMenus = await _serviceScope.ServiceProvider.GetService<ResourceService>().GetaMenuAndSpaListAsync();
                 if (_NavigationManager.ToAbsoluteUri(_NavigationManager.Uri).AbsolutePath == "/Login" || _NavigationManager.ToAbsoluteUri(_NavigationManager.Uri).AbsolutePath == "/")
                     await _ajaxService.GotoAsync(sameLevelMenus.FirstOrDefault(a => a.Id == data)?.Component ?? "index");
@@ -123,7 +124,7 @@ public partial class Login
                 await _captcha.RefreshCode();
             }
 
-            await PopupService.EnqueueSnackbarAsync(new("登录错误", AlertTypes.Error));
+            await PopupService.EnqueueSnackbarAsync(new("<EFBFBD><EFBFBD>¼<EFBFBD><EFBFBD><EFBFBD><EFBFBD>", AlertTypes.Error));
         }
     }
     private async Task<string> RefreshCode()

framework/admin/ThingsGateway.Admin.Blazor/Shared/MainLayout.razor.cs

@@ -1,12 +1,12 @@
-#region copyright
+#region copyright
 //------------------------------------------------------------------------------
-//  此代码版权声明为全文件覆盖，如有原作者特别声明，会在下方手动补充
-//  此代码版权（除特别声明外的代码）归作者本人Diego所有
-//  源代码使用协议遵循本仓库的开源协议及附加协议
-//  Gitee源代码仓库：https://gitee.com/diego2098/ThingsGateway
-//  Github源代码仓库：https://github.com/kimdiego2098/ThingsGateway
-//  使用文档：https://diego2098.gitee.io/thingsgateway-docs/
-//  QQ群：605534569
+//  <EFBFBD>˴<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ȩ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ϊȫ<EFBFBD>ļ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>ǣ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ԭ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ر<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>·<EFBFBD><EFBFBD>ֶ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
+//  <EFBFBD>˴<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ȩ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ر<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ĵ<EFBFBD><EFBFBD>룩<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>߱<EFBFBD><EFBFBD><EFBFBD>Diego<EFBFBD><EFBFBD><EFBFBD><EFBFBD>
+//  Դ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʹ<EFBFBD><EFBFBD>Э<EFBFBD><EFBFBD><EFBFBD><EFBFBD>ѭ<EFBFBD><EFBFBD><EFBFBD>ֿ<EFBFBD><EFBFBD>Ŀ<EFBFBD>ԴЭ<EFBFBD>鼰<EFBFBD><EFBFBD><EFBFBD><EFBFBD>Э<EFBFBD><EFBFBD>
+//  GiteeԴ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ֿ⣺https://gitee.com/diego2098/ThingsGateway
+//  GithubԴ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ֿ⣺https://github.com/kimdiego2098/ThingsGateway
+//  ʹ<EFBFBD><EFBFBD><EFBFBD>ĵ<EFBFBD><EFBFBD><EFBFBD>https://diego2098.gitee.io/thingsgateway-docs/
+//  QQȺ<EFBFBD><EFBFBD>605534569
 //------------------------------------------------------------------------------
 #endregion
 
@@ -16,7 +16,7 @@ using ThingsGateway.Foundation.Extension.String;
 
 namespace ThingsGateway.Admin.Blazor;
 
-public partial class MainLayout : IDisposable
+public partial class MainLayout
 {
     private List<SysResource> _breadcrumbSysResources = new();
     private string _configCopyRight = "";
@@ -43,23 +43,16 @@ public partial class MainLayout : IDisposable
     private IServiceScopeFactory _serviceScopeFactory { get; set; }
     [Inject]
     private UserResoures _userResoures { get; set; }
-
-    public void Dispose()
-    {
-        _serviceScope.Dispose();
-    }
-
     /// <summary>
-    /// 页面刷新
+    /// ҳ<EFBFBD><EFBFBD>ˢ<EFBFBD><EFBFBD>
     /// </summary>
     /// <returns></returns>
     public async Task StateHasChangedAsync()
     {
-        var configService = _serviceScope.ServiceProvider.GetService<IConfigService>();
-        _configCopyRight = (await configService.GetByConfigKeyAsync(ConfigConst.SYS_CONFIGBASEDEFAULT, ConfigConst.CONFIG_COPYRIGHT)).ConfigValue;
-        _configTitle = (await configService.GetByConfigKeyAsync(ConfigConst.SYS_CONFIGBASEDEFAULT, ConfigConst.CONFIG_TITLE)).ConfigValue;
-        _configCopyRightUrl = (await configService.GetByConfigKeyAsync(ConfigConst.SYS_CONFIGBASEDEFAULT, ConfigConst.CONFIG_COPYRIGHT_URL)).ConfigValue;
-        _configPageTab = (await configService.GetByConfigKeyAsync(ConfigConst.SYS_CONFIGBASEDEFAULT, ConfigConst.CONFIG_PAGETAB)).ConfigValue.ToBool(true);
+        _configCopyRight = (await _serviceScope.ServiceProvider.GetService<IConfigService>().GetByConfigKeyAsync(ConfigConst.SYS_CONFIGBASEDEFAULT, ConfigConst.CONFIG_COPYRIGHT)).ConfigValue;
+        _configTitle = (await _serviceScope.ServiceProvider.GetService<IConfigService>().GetByConfigKeyAsync(ConfigConst.SYS_CONFIGBASEDEFAULT, ConfigConst.CONFIG_TITLE)).ConfigValue;
+        _configCopyRightUrl = (await _serviceScope.ServiceProvider.GetService<IConfigService>().GetByConfigKeyAsync(ConfigConst.SYS_CONFIGBASEDEFAULT, ConfigConst.CONFIG_COPYRIGHT_URL)).ConfigValue;
+        _configPageTab = (await _serviceScope.ServiceProvider.GetService<IConfigService>().GetByConfigKeyAsync(ConfigConst.SYS_CONFIGBASEDEFAULT, ConfigConst.CONFIG_PAGETAB)).ConfigValue.ToBool(true);
 
         await _userResoures.InitUserAsync();
         await _userResoures.InitMenuAsync();

framework/admin/ThingsGateway.Admin.Blazor/Startup.cs

@@ -24,6 +24,7 @@ public class Startup : AppStartup
     public void ConfigureServices(IServiceCollection services)
     {
         services.ThingsGatewayComponentsConfigureServices();
+
         services.AddScoped<UserResoures>();
 
     }

framework/admin/ThingsGateway.Admin.Blazor/ThingsGateway.Admin.Blazor.csproj

@@ -3,7 +3,6 @@
 
 	<ItemGroup>
 		<PackageReference Include="Microsoft.AspNetCore.SignalR.Client" Version="8.0.0" />
-		<PackageReference Include="Masa.Blazor.SomethingSkia" Version="1.2.2" />
 	</ItemGroup>
 
 

framework/admin/ThingsGateway.Admin.Core/Startup.cs

@@ -35,7 +35,6 @@ public class Startup : AppStartup
         {
             WorkerId = 4// 取值范围0~63
         });
-        services.ThingsGatewayCoreConfigureServices();
 
         services.AddComponent<LoggingConsoleComponent>();//启动控制台日志格式化组件
         ThingsGateway.Core.TypeExtensions.DefaultFuncs.Add(a => a.GetCustomAttribute<SqlSugar.SugarColumn>()?.ColumnDescription);

framework/admin/ThingsGateway.Admin.Core/ThingsGateway.Admin.Core.csproj

@@ -5,10 +5,8 @@
 	</PropertyGroup>
 
 	<ItemGroup>
-		<PackageReference Include="Furion.Pure" Version="4.9.1.11" />
-		<PackageReference Include="Furion.Extras.ObjectMapper.Mapster" Version="4.9.1.11" />
-		<PackageReference Include="Furion.Extras.Authentication.JwtBearer" Version="4.9.1.11" />
-		<PackageReference Include="SqlSugarCore" Version="5.1.4.122" />
+		<PackageReference Include="Furion.Extras.Authentication.JwtBearer" Version="4.9.1.4" />
+		<PackageReference Include="SqlSugarCore" Version="5.1.4.117" />
 		<PackageReference Include="UAParser" Version="3.1.47" />
 		<PackageReference Include="Yitter.IdGenerator" Version="1.0.14" />
 	</ItemGroup>

framework/admin/ThingsGateway.Components/BaseComponent/BaseComponentBase.cs

@@ -56,7 +56,6 @@ public abstract class BaseComponentBase : ComponentBase, IDisposable
     /// </summary>
     public virtual void Dispose()
     {
-        _serviceScope.Dispose();
     }
 
     /// <summary>

framework/admin/ThingsGateway.Components/ConfigureService.cs

@@ -19,7 +19,7 @@ using Microsoft.Extensions.DependencyInjection;
 
 namespace ThingsGateway.Components;
 
-public static class ServiceExtensions
+public static class ConfigureService
 {
     /// <inheritdoc/>
     public static void ThingsGatewayComponentsConfigureServices(this IServiceCollection services)
@@ -65,7 +65,9 @@ public static class ServiceExtensions
         { nameof(MTimeline), new Dictionary<string, object>() { { nameof(MTimeline.Dense), true } } },
         { nameof(MToolbar), new Dictionary<string, object>() { { nameof(MToolbar.Dense), true } } },
         { "MTreeview", new Dictionary<string, object>() { { "Dense", true } } },
-        { "PImageCaptcha", new Dictionary<string, object>() { { "Dense", true } } }
+        { nameof(PImageCaptcha), new Dictionary<string, object>() { { nameof(PImageCaptcha.Dense), true } } }
+
+
 
             };
             options.ConfigureTheme(theme =>
@@ -96,7 +98,6 @@ public static class ServiceExtensions
         services.AddScoped<InitTimezone>();
         services.AddScoped<AjaxService>();
         services.AddScoped<CookieStorage>();
-        services.AddScoped<IDefaultTimezoneOffsetAccessor, DefaultTimezoneOffsetAccessor>();
 
     }
 }

framework/admin/ThingsGateway.Components/JS/IDefaultTimezoneOffsetAccessor.cs

@@ -1,8 +0,0 @@
-
-namespace ThingsGateway.Components
-{
-    public interface IDefaultTimezoneOffsetAccessor
-    {
-        TimeSpan GetTimezoneOffsetResult();
-    }
-}

framework/admin/ThingsGateway.Components/JS/InitTimezone.cs

@@ -10,6 +10,9 @@
 //------------------------------------------------------------------------------
 #endregion
 
+using Microsoft.AspNetCore.Http;
+using Microsoft.Extensions.DependencyInjection;
+
 namespace ThingsGateway.Components;
 
 /// <summary>
@@ -40,11 +43,17 @@ public class InitTimezone : IDisposable
     /// <param name="jsRuntime"></param>
     /// <param name="storage"></param>
     /// <param name="serviceProvider"></param>
-    public InitTimezone(IJSRuntime jsRuntime, CookieStorage storage, IDefaultTimezoneOffsetAccessor defaultTimezoneOffsetAccessor)
+    public InitTimezone(IJSRuntime jsRuntime, CookieStorage storage, IServiceProvider serviceProvider)
     {
+        IHttpContextAccessor httpContextAccessor = serviceProvider.GetService<IHttpContextAccessor>();
         _jsRuntime = jsRuntime;
         _storage = storage;
-        _timezoneOffset = defaultTimezoneOffsetAccessor.GetTimezoneOffsetResult();
+        var httpContext = httpContextAccessor?.HttpContext;
+        if (httpContext is not null)
+        {
+            var timezoneOffsetResult = httpContext.Request.Cookies[_timezoneOffsetKey];
+            _timezoneOffset = TimeSpan.FromMinutes(Convert.ToDouble(timezoneOffsetResult));
+        }
     }
     /// <summary>
     /// 获取Web客户端时差

framework/admin/ThingsGateway.Components/ThingsGateway.Components.csproj

@@ -3,6 +3,7 @@
 	
 	<ItemGroup>
 		<PackageReference Include="Masa.Blazor" Version="1.2.2" />
+		<PackageReference Include="Masa.Blazor.SomethingSkia" Version="1.2.2" />
 	</ItemGroup>
 	
 	<ItemGroup>

framework/admin/ThingsGateway.Core/Cache/MemoryCache.cs

@@ -10,6 +10,8 @@
 //------------------------------------------------------------------------------
 #endregion
 
+using Furion.DependencyInjection;
+
 using Mapster;
 
 using Microsoft.Extensions.Caching.Memory;
@@ -21,9 +23,8 @@ namespace ThingsGateway.Core;
 /// <summary>
 /// 系统内存缓存
 /// </summary>
-public class MemoryCache
+public class MemoryCache : ISingleton
 {
-    public static MemoryCache Instance { get; private set; } = new();
     private const string intervalStr = "---___---";
     private readonly Microsoft.Extensions.Caching.Memory.MemoryCache _memoryCache = new(new MemoryCacheOptions());
     private readonly Microsoft.Extensions.Caching.Memory.MemoryCache _prefixmemoryCache = new(new MemoryCacheOptions());

framework/admin/ThingsGateway.Core/Extension/TypeExtensions.cs

@@ -10,6 +10,8 @@
 //------------------------------------------------------------------------------
 #endregion
 
+using Furion;
+
 using System.ComponentModel;
 using System.ComponentModel.DataAnnotations;
 using System.Globalization;
@@ -88,7 +90,7 @@ public static class TypeExtensions
     public static string GetDescription(this Type modelType, string name, Func<MemberInfo, string> func = null)
     {
         var cacheKey = $"{nameof(GetDescription)}-{CultureInfo.CurrentUICulture.Name}-{modelType.FullName}-{name}-{modelType.TypeHandle.Value}";
-        var str = MemoryCache.Instance.GetOrCreate(cacheKey, entry =>
+        var str = App.GetService<MemoryCache>().GetOrCreate(cacheKey, entry =>
         {
             string dn = default;
             {

framework/admin/ThingsGateway.Core/Startup.cs

@@ -10,15 +10,20 @@
 //------------------------------------------------------------------------------
 #endregion
 
+using Furion;
+
 using Microsoft.Extensions.DependencyInjection;
 
 namespace ThingsGateway.Core;
 
-public static class ServiceExtensions
+/// <summary>
+/// Startup
+/// </summary>
+[AppStartup(9999)]
+public class Startup : AppStartup
 {
-    /// <inheritdoc/>
-    public static void ThingsGatewayCoreConfigureServices(this IServiceCollection services)
+    public void ConfigureServices(IServiceCollection services)
     {
-        services.AddSingleton(a => MemoryCache.Instance);
+
     }
 }

framework/admin/ThingsGateway.Core/ThingsGateway.Core.csproj

@@ -1,11 +1,8 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
 	<ItemGroup>
-
-		<PackageReference Include="Mapster" Version="7.4.0" />
-
-		<PackageReference Include="Microsoft.Extensions.Caching.Memory" Version="8.0.0" />
-
+		<PackageReference Include="Furion.Pure" Version="4.9.1.4" />
+		<PackageReference Include="Furion.Extras.ObjectMapper.Mapster" Version="4.9.1.4" />
 		<PackageReference Include="Newtonsoft.Json" Version="13.0.3" />
 	</ItemGroup>
 

framework/demo/Directory.Build.props

@@ -1,7 +1,14 @@
 <Project>
-	<Import Project="$(SolutionDir)\Directory.Build.props" />
 	<PropertyGroup>
-
+		<TargetFrameworks>net6.0;net8.0;</TargetFrameworks>
+		<Version>4.0.0.1</Version>
+		<LangVersion>latest</LangVersion>
+		<Authors>Diego</Authors>
+		<Product>ThingsGateway</Product>
+		<Copyright>© 2023-present Diego</Copyright>
+		<RepositoryUrl>https://gitee.com/diego2098/ThingsGateway</RepositoryUrl>
+		<SatelliteResourceLanguages>zh-Hans</SatelliteResourceLanguages>
+		<GenerateDocumentationFile>False</GenerateDocumentationFile>
 	</PropertyGroup>
 
 

framework/demo/ThingsGateway.Foundation.Demo.Photino/Program.cs

@@ -12,8 +12,6 @@
 
 using Photino.Blazor;
 
-using ThingsGateway.Core;
-
 namespace ThingsGateway.Foundation.Demo;
 
 internal class Program
@@ -25,10 +23,11 @@ internal class Program
 
         var appBuilder = PhotinoBlazorAppBuilder.CreateDefault(args);
 
+        Serve.RunNative();
+
         appBuilder.RootComponents.Add<App>("#app");
 
         appBuilder.Services.ThingsGatewayComponentsConfigureServices();
-        appBuilder.Services.ThingsGatewayCoreConfigureServices();
         var app = appBuilder.Build();
         app.MainWindow.SetTitle("ThingsGateway.Foundation.Demo");
         app.MainWindow.SetIconFile("wwwroot/favicon.ico");

framework/demo/ThingsGateway.Foundation.Demo.Rcl/Components/DebugPage/DriverDebugUIBase.cs

@@ -12,9 +12,6 @@
 
 using Microsoft.AspNetCore.Components;
 
-using ThingsGateway.Components;
-
-
 namespace ThingsGateway.Foundation.Demo;
 using LogLevel = Microsoft.Extensions.Logging.LogLevel;
 /// <summary>

framework/demo/ThingsGateway.Foundation.Demo.Rcl/Components/DebugPage/SerialSessionPage.razor

@@ -18,10 +18,10 @@
 <MCard Flat Class="pa-2 my-1" Style="width:100%">
     <div class="mb-4">通道配置</div>
     <MRow Justify="JustifyTypes.Start" Align="AlignTypes.Center">
-        <MTextField Style="max-width:100px" Class="ma-1" Outlined Label=@(_serialPortOption.Description(x => x.PortName)) Dense HideDetails="@("auto")" @bind-Value=@_serialPortOption.PortName />
-        <MTextField Style="max-width:100px" Class="ma-1" Outlined Label=@(_serialPortOption.Description(x => x.BaudRate)) Dense HideDetails="@("auto")" @bind-Value=@_serialPortOption.BaudRate />
-        <MTextField Style="max-width:100px" Class="ma-1" Outlined Label=@(_serialPortOption.Description(x => x.DataBits)) Dense HideDetails="@("auto")" @bind-Value=@_serialPortOption.DataBits />
-        <MSelect Class="ma-1 " Style="max-width:200px" Outlined @bind-Value="_serialPortOption.Parity" Label="@(_serialPortOption.Description(x => x.Parity))"
+        <MTextField Style="max-width:100px" Class="ma-1" Outlined Label=@(_serialProperty.Description(x => x.PortName)) Dense HideDetails="@("auto")" @bind-Value=@_serialProperty.PortName />
+        <MTextField Style="max-width:100px" Class="ma-1" Outlined Label=@(_serialProperty.Description(x => x.BaudRate)) Dense HideDetails="@("auto")" @bind-Value=@_serialProperty.BaudRate />
+        <MTextField Style="max-width:100px" Class="ma-1" Outlined Label=@(_serialProperty.Description(x => x.DataBits)) Dense HideDetails="@("auto")" @bind-Value=@_serialProperty.DataBits />
+        <MSelect Class="ma-1 " Style="max-width:200px" Outlined @bind-Value="_serialProperty.Parity" Label="@(_serialProperty.Description(x => x.Parity))"
                  Items=@(typeof(Parity).GetEnumList())
                  MenuProps="@(props => { props.Auto = true; props.OffsetY = true; })"
                  ItemText=@((u) =>u.Description)
@@ -29,7 +29,7 @@
                  HideDetails=@("auto") Height="30"
                  Dense>
         </MSelect>
-        <MSelect Class="ma-1 " Style="max-width:200px" Outlined @bind-Value="_serialPortOption.StopBits" Label="@(_serialPortOption.Description(x => x.StopBits))"
+        <MSelect Class="ma-1 " Style="max-width:200px" Outlined @bind-Value="_serialProperty.StopBits" Label="@(_serialProperty.Description(x => x.StopBits))"
                  Items=@(typeof(StopBits).GetEnumList())
                  MenuProps="@(props => { props.Auto = true; props.OffsetY = true; })"
                  ItemText=@((u) =>u.Description)

framework/demo/ThingsGateway.Foundation.Demo.Rcl/Components/DebugPage/SerialSessionPage.razor.cs

@@ -13,39 +13,39 @@
 namespace ThingsGateway.Foundation.Demo;
 
 /// <inheritdoc/>
-public partial class SerialPortClientPage : IDisposable
+public partial class SerialSessionPage : IDisposable
 {
     /// <summary>
     /// 日志输出
     /// </summary>
     public Action<LogLevel, object, string, Exception> LogAction;
 
-    private readonly SerialPortOption _serialPortOption = new();
+    private readonly SerialProperty _serialProperty = new();
     private TouchSocketConfig _config;
-    private SerialPortClient _serialPortClient { get; set; } = new();
+    private SerialSession _serialSession { get; set; } = new();
 
     /// <summary>
     /// <inheritdoc/>
     /// </summary>
     public void Dispose()
     {
-        _serialPortClient.SafeDispose();
+        _serialSession.SafeDispose();
     }
 
     /// <summary>
     /// 获取对象
     /// </summary>
     /// <returns></returns>
-    public SerialPortClient GetSerialPortClient()
+    public SerialSession GetSerialSession()
     {
         _config ??= new TouchSocketConfig();
         var LogMessage = new LoggerGroup() { LogLevel = LogLevel.Trace };
         LogMessage.AddLogger(new EasyLogger(LogOut) { LogLevel = LogLevel.Trace });
         _config.ConfigureContainer(a => a.RegisterSingleton<ILog>(LogMessage));
-        _config.SetSerialPortOption(_serialPortOption);
+        _config.SetSerialProperty(_serialProperty);
         //载入配置
-        _serialPortClient.Setup(_config);
-        return _serialPortClient;
+        _serialSession.Setup(_config);
+        return _serialSession;
     }
     internal void StateHasChangedAsync()
     {
@@ -63,7 +63,7 @@ public partial class SerialPortClientPage : IDisposable
             var LogMessage = new LoggerGroup() { LogLevel = LogLevel.Trace };
             LogMessage.AddLogger(new EasyLogger(LogOut) { LogLevel = LogLevel.Trace });
             _config.ConfigureContainer(a => a.RegisterSingleton<ILog>(LogMessage));
-            _serialPortClient.Setup(_config);
+            _serialSession.Setup(_config);
         }
         base.OnAfterRender(firstRender);
     }
@@ -80,8 +80,8 @@ public partial class SerialPortClientPage : IDisposable
     {
         try
         {
-            _serialPortClient.Close();
-            await GetSerialPortClient().ConnectAsync();
+            _serialSession.Close();
+            await GetSerialSession().ConnectAsync();
         }
         catch (Exception ex)
         {
@@ -93,7 +93,7 @@ public partial class SerialPortClientPage : IDisposable
     {
         try
         {
-            _serialPortClient.Close();
+            _serialSession.Close();
         }
         catch (Exception ex)
         {

framework/demo/ThingsGateway.Foundation.Demo.Rcl/GlobalUsings.cs

@@ -16,6 +16,6 @@ global using System.Threading.Tasks;
 
 global using ThingsGateway.Components;
 global using ThingsGateway.Foundation.Core;
-global using ThingsGateway.Foundation.SerialPorts;
+global using ThingsGateway.Foundation.Serial;
 global using ThingsGateway.Foundation.Sockets;
 

framework/demo/ThingsGateway.Foundation.Demo.Rcl/Pages/DLT645/DLT645_2007DebugPage.razor

@@ -19,7 +19,7 @@
 @using Masa.Blazor;
 @namespace ThingsGateway.Foundation.Demo
 
-<SerialPortClientPage @ref=_serialPortClientPage></SerialPortClientPage>
+<SerialSessionPage @ref=_serialSessionPage></SerialSessionPage>
 
 <MCard Flat Class="pa-2 my-1" Style="width:100%">
     <div class="mb-4">驱动配置</div>

framework/demo/ThingsGateway.Foundation.Demo.Rcl/Pages/DLT645/DLT645_2007DebugPage.razor.cs

@@ -17,9 +17,9 @@ namespace ThingsGateway.Foundation.Demo;
 public partial class DLT645_2007DebugPage
 {
     /// <summary>
-    /// SerialPortClientPage
+    /// SerialSessionPage
     /// </summary>
-    private SerialPortClientPage _serialPortClientPage;
+    private SerialSessionPage _serialSessionPage;
     private DriverDebugUIPage _driverDebugUIPage;
     private ThingsGateway.Foundation.Adapter.DLT645.DLT645_2007 _plc;
     /// <summary>
@@ -37,15 +37,15 @@ public partial class DLT645_2007DebugPage
                     //链路基础配置项
                     var config = new TouchSocketConfig();
                     config
-                    .SetSerialPortOption(new SerialPortOption() //串口链路才需要
+                    .SetSerialProperty(new SerialProperty() //串口链路才需要
                     {
                         PortName = "COM1"
                     });
-                    var serialPortClient = new SerialPortClient();//链路对象
-                    serialPortClient.Setup(config);
+                    var serialSession = new SerialSession();//链路对象
+                    serialSession.Setup(config);
 
                     //创建协议对象,构造函数需要传入对应链路对象
-                    DLT645_2007 plc = new(serialPortClient)//传入链路
+                    DLT645_2007 plc = new(serialSession)//传入链路
                     {
                         //协议配置
                         DataFormat = DataFormat.ABCD,
@@ -69,9 +69,9 @@ public partial class DLT645_2007DebugPage
                 """, "csharp"));
 
 
-            if (_serialPortClientPage != null)
-                _serialPortClientPage.LogAction = _driverDebugUIPage.LogOut;
-            _plc = new ThingsGateway.Foundation.Adapter.DLT645.DLT645_2007(_serialPortClientPage.GetSerialPortClient());
+            if (_serialSessionPage != null)
+                _serialSessionPage.LogAction = _driverDebugUIPage.LogOut;
+            _plc = new ThingsGateway.Foundation.Adapter.DLT645.DLT645_2007(_serialSessionPage.GetSerialSession());
             _driverDebugUIPage.Plc = _plc;
 
             //初始化

framework/demo/ThingsGateway.Foundation.Demo.Rcl/Pages/DLT645/DLT645_2007OverTcpDebugPage.razor.cs

@@ -17,7 +17,7 @@ namespace ThingsGateway.Foundation.Demo;
 public partial class DLT645_2007OverTcpDebugPage
 {
     /// <summary>
-    /// SerialPortClientPage
+    /// SerialSessionPage
     /// </summary>
     private TcpClientPage _tcpClientPage;
     private DriverDebugUIPage _driverDebugUIPage;

framework/demo/ThingsGateway.Foundation.Demo.Rcl/Pages/Modbus/ModbusRtuDebugPage.razor

@@ -19,7 +19,7 @@
 @using Masa.Blazor;
 @namespace ThingsGateway.Foundation.Demo
 
-<SerialPortClientPage @ref=_serialPortClientPage></SerialPortClientPage>
+<SerialSessionPage @ref=_serialSessionPage></SerialSessionPage>
 
 <MCard Flat Class="pa-2 my-1" Style="width:100%">
      <div class="mb-4">驱动配置</div>

framework/demo/ThingsGateway.Foundation.Demo.Rcl/Pages/Modbus/ModbusRtuDebugPage.razor.cs

@@ -19,9 +19,9 @@ namespace ThingsGateway.Foundation.Demo;
 public partial class ModbusRtuDebugPage
 {
     /// <summary>
-    /// SerialPortClientPage
+    /// SerialSessionPage
     /// </summary>
-    private SerialPortClientPage _serialPortClientPage;
+    private SerialSessionPage _serialSessionPage;
     private readonly List<(string Code, string Language)> _sections = new();
     private DriverDebugUIPage _driverDebugUIPage;
 
@@ -41,15 +41,15 @@ public partial class ModbusRtuDebugPage
                     //链路基础配置项
                     var config = new TouchSocketConfig();
                     config
-                    .SetSerialPortOption(new SerialPortOption() //串口链路才需要
+                    .SetSerialProperty(new SerialProperty() //串口链路才需要
                     {
                         PortName = "COM1"
                     });
-                    var serialPortClient = new SerialPortClient();//链路对象
-                    serialPortClient.Setup(config);
+                    var serialSession = new SerialSession();//链路对象
+                    serialSession.Setup(config);
 
                     //创建协议对象,构造函数需要传入对应链路对象
-                    ModbusRtu plc = new(serialPortClient)//传入链路
+                    ModbusRtu plc = new(serialSession)//传入链路
                     {
                         //协议配置
                         DataFormat = DataFormat.ABCD,
@@ -72,9 +72,9 @@ public partial class ModbusRtuDebugPage
                 """, "csharp"));
 
 
-            if (_serialPortClientPage != null)
-                _serialPortClientPage.LogAction = _driverDebugUIPage.LogOut;
-            _plc = new ThingsGateway.Foundation.Adapter.Modbus.ModbusRtu(_serialPortClientPage.GetSerialPortClient());
+            if (_serialSessionPage != null)
+                _serialSessionPage.LogAction = _driverDebugUIPage.LogOut;
+            _plc = new ThingsGateway.Foundation.Adapter.Modbus.ModbusRtu(_serialSessionPage.GetSerialSession());
             _driverDebugUIPage.Plc = _plc;
             //载入配置
             StateHasChanged();

framework/demo/ThingsGateway.Foundation.Demo.Rcl/Pages/Modbus/ModbusRtuOverTcpDebugPage.razor.cs

@@ -19,7 +19,7 @@ namespace ThingsGateway.Foundation.Demo;
 public partial class ModbusRtuOverTcpDebugPage
 {
     /// <summary>
-    /// SerialPortClientPage
+    /// SerialSessionPage
     /// </summary>
     private TcpClientPage _tcpClientPage;
     private DriverDebugUIPage _driverDebugUIPage;

framework/demo/ThingsGateway.Foundation.Demo.Rcl/Pages/Modbus/ModbusRtuOverUdpDebugPage.razor.cs

@@ -17,7 +17,7 @@ namespace ThingsGateway.Foundation.Demo;
 public partial class ModbusRtuOverUdpDebugPage
 {
     /// <summary>
-    /// SerialPortClientPage
+    /// SerialSessionPage
     /// </summary>
     private UdpSessionPage _udpSessionPage;
     private DriverDebugUIPage _driverDebugUIPage;

framework/demo/ThingsGateway.Foundation.Demo.Rcl/Pages/Modbus/ModbusSerialServerDebugPage.razor

@@ -19,7 +19,7 @@
 @using Masa.Blazor;
 @namespace ThingsGateway.Foundation.Demo
 
-<SerialPortClientPage @ref=_serialPortClientPage></SerialPortClientPage>
+<SerialSessionPage @ref=_serialSessionPage></SerialSessionPage>
 
 <MCard Flat Class="pa-2 my-1" Style="width:100%">
     <div class="mb-4">驱动配置</div>

framework/demo/ThingsGateway.Foundation.Demo.Rcl/Pages/Modbus/ModbusSerialServerDebugPage.razor.cs

@@ -17,9 +17,9 @@ namespace ThingsGateway.Foundation.Demo;
 public partial class ModbusSerialServerDebugPage
 {
     /// <summary>
-    /// SerialPortClientPage
+    /// SerialSessionPage
     /// </summary>
-    private SerialPortClientPage _serialPortClientPage;
+    private SerialSessionPage _serialSessionPage;
     private DriverDebugUIPage _driverDebugUIPage;
 
     private ThingsGateway.Foundation.Adapter.Modbus.ModbusSerialServer _plc;
@@ -39,15 +39,15 @@ public partial class ModbusSerialServerDebugPage
                     //链路基础配置项
                     var config = new TouchSocketConfig();
                     config
-                    .SetSerialPortOption(new SerialPortOption() //串口链路才需要
+                    .SetSerialProperty(new SerialProperty() //串口链路才需要
                     {
                         PortName = "COM1"
                     });
-                    var serialPortClient = new SerialPortClient();//链路对象
-                    serialPortClient.Setup(config);
+                    var serialSession = new SerialSession();//链路对象
+                    serialSession.Setup(config);
 
                     //创建协议对象,构造函数需要传入对应链路对象
-                    ModbusSerialServer plc = new(serialPortClient)//传入链路
+                    ModbusSerialServer plc = new(serialSession)//传入链路
                     {
                         //协议配置
                         DataFormat = DataFormat.ABCD,
@@ -70,9 +70,9 @@ public partial class ModbusSerialServerDebugPage
                 """, "csharp"));
 
 
-            if (_serialPortClientPage != null)
-                _serialPortClientPage.LogAction = _driverDebugUIPage.LogOut;
-            _plc = new ThingsGateway.Foundation.Adapter.Modbus.ModbusSerialServer(_serialPortClientPage.GetSerialPortClient());
+            if (_serialSessionPage != null)
+                _serialSessionPage.LogAction = _driverDebugUIPage.LogOut;
+            _plc = new ThingsGateway.Foundation.Adapter.Modbus.ModbusSerialServer(_serialSessionPage.GetSerialSession());
             _driverDebugUIPage.Plc = _plc;
             //载入配置
             StateHasChanged();

framework/demo/ThingsGateway.Foundation.Demo.Rcl/Pages/Modbus/ModbusTcpDebugPage.razor.cs

@@ -21,7 +21,7 @@ public partial class ModbusTcpDebugPage
     private ThingsGateway.Foundation.Adapter.Modbus.ModbusTcp _plc;
 
     /// <summary>
-    /// SerialPortClientPage
+    /// SerialSessionPage
     /// </summary>
     private TcpClientPage _tcpClientPage;
     /// <summary>

framework/demo/ThingsGateway.Foundation.Demo.Rcl/Pages/Modbus/ModbusTcpDtuDebugPage.razor

@@ -40,9 +40,7 @@
                   Dense>
         </MSelect>
 
-            <MCheckbox Class="ma-1" Style="max-width:200px" Label=@(_plc.Description(x => x.IsRtu)) Dense HideDetails="@("auto")" @bind-Value=@_plc.IsRtu></MCheckbox>
             <MCheckbox Class="ma-1" Style="max-width:200px" Label=@(_plc.Description(x => x.IsCheckMessageId)) Dense HideDetails="@("auto")" @bind-Value=@_plc.IsCheckMessageId></MCheckbox>
-            <MCheckbox Class="ma-1" Style="max-width:200px" Label=@(_plc.Description(x => x.Crc16CheckEnable)) Dense HideDetails="@("auto")" @bind-Value=@_plc.Crc16CheckEnable></MCheckbox>
 
         }
     </MRow>

framework/demo/ThingsGateway.Foundation.Demo.Rcl/Pages/Modbus/ModbusTcpDtuDebugPage.razor.cs

@@ -13,9 +13,9 @@
 namespace ThingsGateway.Foundation.Demo;
 
 /// <summary>
-/// ModbusDtuDebugPage
+/// ModbusTcpDtuDebugPage
 /// </summary>
-public partial class ModbusDtuDebugPage
+public partial class ModbusTcpDtuDebugPage
 {
     /// <summary>
     /// TcpServerPage
@@ -23,7 +23,7 @@ public partial class ModbusDtuDebugPage
     private TcpServerPage _tcpServerPage;
     private DriverDebugUIPage _driverDebugUIPage;
 
-    private ThingsGateway.Foundation.Adapter.Modbus.ModbusDtu _plc;
+    private ThingsGateway.Foundation.Adapter.Modbus.ModbusTcpDtu _plc;
 
     /// <summary>
     /// <inheritdoc/>
@@ -70,7 +70,7 @@ public partial class ModbusDtuDebugPage
 
             if (_tcpServerPage != null)
                 _tcpServerPage.LogAction = _driverDebugUIPage.LogOut;
-            _plc = new ThingsGateway.Foundation.Adapter.Modbus.ModbusDtu(_tcpServerPage.GetTcpServer());
+            _plc = new ThingsGateway.Foundation.Adapter.Modbus.ModbusTcpDtu(_tcpServerPage.GetTcpServer());
             _driverDebugUIPage.Plc = _plc;
             //载入配置
             StateHasChanged();

framework/demo/ThingsGateway.Foundation.Demo.Rcl/Pages/Modbus/ModbusUdpDebugPage.razor.cs

@@ -17,7 +17,7 @@ namespace ThingsGateway.Foundation.Demo;
 public partial class ModbusUdpDebugPage
 {
     /// <summary>
-    /// SerialPortClientPage
+    /// SerialSessionPage
     /// </summary>
     private UdpSessionPage _udpSessionPage;
     private DriverDebugUIPage _driverDebugUIPage;

framework/demo/ThingsGateway.Foundation.Demo.Rcl/Pages/OPCDA/OPCDAClientDebugPage.razor

@@ -23,7 +23,7 @@
 @using ThingsGateway.Foundation.Core;
 @using ThingsGateway.Foundation.Adapter.OPCDA.Da;
 @using ThingsGateway.Foundation.Extension;
-@using ThingsGateway.Foundation.SerialPorts;
+@using ThingsGateway.Foundation.Serial;
 @using Masa.Blazor
 
 

framework/demo/ThingsGateway.Foundation.Demo.Rcl/Pages/OPCDA/OPCDAClientDebugPage.razor.cs

@@ -20,6 +20,8 @@ using Microsoft.JSInterop;
 
 using Newtonsoft.Json.Linq;
 
+using System.Collections.Generic;
+
 using ThingsGateway.Foundation.Adapter.OPCDA;
 using ThingsGateway.Foundation.Adapter.OPCDA.Da;
 
@@ -43,7 +45,6 @@ public partial class OPCDAClientDebugPage : IDisposable
     {
         _plc.SafeDispose();
         opcDAClientPage.SafeDispose();
-        base.Dispose();
     }
 
     /// <inheritdoc/>
@@ -104,7 +105,7 @@ public partial class OPCDAClientDebugPage : IDisposable
                     await PopupService.EnqueueSnackbarAsync("无可用变量", AlertTypes.Warning);
                     return;
                 }
-                await _serviceScope.ServiceProvider.GetService<ICollectDeviceService>().AddAsync(data?.Item1);
+                await _serviceScope.ServiceProvider.GetService<CollectDeviceService>().AddAsync(data?.Item1);
                 await _serviceScope.ServiceProvider.GetService<VariableService>().AddBatchAsync(data?.Item2);
                 await PopupService.EnqueueSnackbarAsync("成功", AlertTypes.Success);
             }
@@ -150,7 +151,7 @@ public partial class OPCDAClientDebugPage : IDisposable
     /// <returns></returns>
     public async Task DownDeviceExportAsync(CollectDevice data)
     {
-        using var memoryStream = await _serviceScope.ServiceProvider.GetService<ICollectDeviceService>().ExportFileAsync(new List<CollectDevice>() { data });
+        using var memoryStream = await _serviceScope.ServiceProvider.GetService<CollectDeviceService>().ExportFileAsync(new List<CollectDevice>() { data });
         using var streamRef = new DotNetStreamReference(stream: memoryStream);
         JSObjectReference ??= await JSRuntime.LoadModuleAsync("js/downloadFileFromStream");
         await JSObjectReference.InvokeVoidAsync("downloadFileFromStream", $"设备导出{DateTimeExtensions.CurrentDateTime.ToFileDateTimeFormat()}.xlsx", streamRef);

framework/demo/ThingsGateway.Foundation.Demo.Rcl/Pages/OPCDA/OPCDAImportVariable.razor

@@ -14,6 +14,7 @@
 @using BlazorComponent;
 @using Microsoft.AspNetCore.Components.Web;
 @using System.Reflection;
+@inherits BaseComponentBase
 
 @using ThingsGateway.Foundation.Adapter.OPCDA;
 @using ThingsGateway.Foundation.Core;

framework/demo/ThingsGateway.Foundation.Demo.Rcl/Pages/OPCDA/OPCDAImportVariable.razor.cs

@@ -12,6 +12,8 @@
 
 using Microsoft.AspNetCore.Components;
 
+using System.Collections.Generic;
+using System.Linq;
 using System.Reflection;
 
 using ThingsGateway.Foundation.Adapter.OPCDA.Rcw;
@@ -139,7 +141,6 @@ public partial class OPCDAImportVariable
             overlay = false;
             await InvokeAsync(StateHasChanged);
         });
-        await base.OnInitializedAsync();
     }
 
 

framework/demo/ThingsGateway.Foundation.Demo.Rcl/Pages/OPCUA/OPCUAClientDebugPage.razor

@@ -25,7 +25,7 @@
 @using ThingsGateway.Foundation.Core;
 @using ThingsGateway.Foundation.Adapter.OPCUA;
 @using ThingsGateway.Foundation.Extension;
-@using ThingsGateway.Foundation.SerialPorts;
+@using ThingsGateway.Foundation.Serial;
 @using Masa.Blazor
 
 

framework/demo/ThingsGateway.Foundation.Demo.Rcl/Pages/OPCUA/OPCUAClientDebugPage.razor.cs

@@ -96,7 +96,7 @@ public partial class OPCUAClientDebugPage
                 await PopupService.EnqueueSnackbarAsync("无可用变量", AlertTypes.Warning);
                 return;
             }
-            await _serviceScope.ServiceProvider.GetService<ICollectDeviceService>().AddAsync(data.Item1);
+            await _serviceScope.ServiceProvider.GetService<CollectDeviceService>().AddAsync(data.Item1);
             await _serviceScope.ServiceProvider.GetService<VariableService>().AddBatchAsync(data.Item2);
             await PopupService.EnqueueSnackbarAsync("成功", AlertTypes.Success);
         }
@@ -141,7 +141,7 @@ public partial class OPCUAClientDebugPage
     /// <returns></returns>
     public async Task DownDeviceExportAsync(CollectDevice data)
     {
-        using var memoryStream = await _serviceScope.ServiceProvider.GetService<ICollectDeviceService>().ExportFileAsync(new List<CollectDevice>() { data });
+        using var memoryStream = await _serviceScope.ServiceProvider.GetService<CollectDeviceService>().ExportFileAsync(new List<CollectDevice>() { data });
         using var streamRef = new DotNetStreamReference(stream: memoryStream);
         JSObjectReference ??= await JSRuntime.LoadModuleAsync("js/downloadFileFromStream");
         await JSObjectReference.InvokeVoidAsync("downloadFileFromStream", $"设备导出{DateTimeExtensions.CurrentDateTime.ToFileDateTimeFormat()}.xlsx", streamRef);

framework/demo/ThingsGateway.Foundation.Demo.Rcl/Pages/OPCUA/OPCUAImportVariable.razor

@@ -11,6 +11,7 @@
 *@
 
 @namespace ThingsGateway.Foundation.Demo
+@inherits BaseComponentBase
 
 @using BlazorComponent;
 @using Microsoft.AspNetCore.Components.Web;

framework/demo/ThingsGateway.Foundation.Demo.Rcl/Pages/OPCUA/OPCUAImportVariable.razor.cs

@@ -14,6 +14,8 @@ using Microsoft.AspNetCore.Components;
 
 using Opc.Ua;
 
+using System.Collections.Generic;
+using System.Linq;
 using System.Reflection;
 
 using ThingsGateway.Foundation.Adapter.OPCUA;
@@ -171,7 +173,6 @@ public partial class OPCUAImportVariable
             overlay = false;
             await InvokeAsync(StateHasChanged);
         });
-        base.OnInitialized();
     }
 
 

framework/demo/ThingsGateway.Foundation.Demo.Rcl/Pages/Siemens/SiemensDebugPage.razor

@@ -20,7 +20,7 @@
 @using ThingsGateway.Foundation.Adapter.Siemens;
 @using ThingsGateway.Foundation.Core;
 @using ThingsGateway.Foundation.Extension;
-@using ThingsGateway.Foundation.SerialPorts;
+@using ThingsGateway.Foundation.Serial;
 
 @using Masa.Blazor
 

framework/demo/ThingsGateway.Foundation.Demo.Rcl/Pages/Siemens/SiemensDebugPage.razor.cs

@@ -21,7 +21,7 @@ public partial class SiemensDebugPage
     private ThingsGateway.Foundation.Adapter.Siemens.SiemensS7PLC _plc;
 
     /// <summary>
-    /// SerialPortClientPage
+    /// SerialSessionPage
     /// </summary>
     private TcpClientPage _tcpClientPage;
     /// <summary>

framework/demo/ThingsGateway.Foundation.Demo.Rcl/Shared/MainLayout.razor.cs

@@ -10,6 +10,8 @@
 //------------------------------------------------------------------------------
 #endregion
 
+using System.Collections.Generic;
+
 namespace ThingsGateway.Foundation.Demo;
 
 public partial class MainLayout
@@ -103,16 +105,16 @@ public partial class MainLayout
         "Title": "OPCUAClient"
       }
     ]
+  },
+  {
+    "Title": "Mqtt",
+    "Children": [
+      {
+        "Href": "/MqttClient",
+        "Title": "MqttClient"
+      }
+    ]
   }
-  //{
-  //  "Title": "Mqtt",
-  //  "Children": [
-  //    {
-  //      "Href": "/MqttClient",
-  //      "Title": "MqttClient"
-  //    }
-  //  ]
-  //}
 ]
 
 

framework/demo/ThingsGateway.Foundation.Demo.Rcl/_Imports.razor

@@ -25,5 +25,5 @@
 @using System.Net.Http.Json
 @using System.IO;
 @using System.Text.Json;
-@using ThingsGateway.Foundation.SerialPorts;
+@using ThingsGateway.Foundation.Serial;
 @using ThingsGateway.Foundation.Sockets;

framework/demo/ThingsGateway.Foundation.Demo.Winform/MainFrom.cs

@@ -14,9 +14,9 @@ using Microsoft.AspNetCore.Components.WebView.WindowsForms;
 using Microsoft.Extensions.DependencyInjection;
 
 using System.Diagnostics;
+using System.Threading.Tasks;
 
 using ThingsGateway.Components;
-using ThingsGateway.Core;
 
 namespace ThingsGateway.Foundation.Demo.Winform
 {
@@ -26,12 +26,14 @@ namespace ThingsGateway.Foundation.Demo.Winform
         {
             InitializeComponent();
 
-            IServiceCollection services = new ServiceCollection();
+            IServiceCollection services = null;
 
-
-            services.AddWindowsFormsBlazorWebView();
-            services.ThingsGatewayComponentsConfigureServices();
-            services.ThingsGatewayCoreConfigureServices();
+            Serve.RunNative(a =>
+            {
+                services = a;
+                services.AddWindowsFormsBlazorWebView();
+                services.ThingsGatewayComponentsConfigureServices();
+            });
 
             blazorWebView1.HostPage = "wwwroot/index.html";
             blazorWebView1.Services = services.BuildServiceProvider();

framework/demo/ThingsGateway.Foundation.Demo.Winform/ThingsGateway.Foundation.Demo.Winform.csproj

@@ -7,7 +7,6 @@
 		<UseWindowsForms>true</UseWindowsForms>
 	</PropertyGroup>
 
-
 	<ItemGroup>
 		<None Remove="favicon.ico" />
 	</ItemGroup>

framework/foundation/Directory.Build.props

@@ -1,14 +1,16 @@
 <Project>
-	<Import Project="$(SolutionDir)\Directory.Build.props" />
-	<!--如果编译net45报错无支持，用一下方法添加net45包-->
-	<!--VS顶部菜单栏 -> 视图 -> 其他 -> 程序包控制台
-	Install-Package Microsoft.NETFramework.ReferenceAssemblies.net45
-	-->
 	<PropertyGroup>
+		<Version>4.0.0.1</Version>
+		<GenerateDocumentationFile>True</GenerateDocumentationFile>
+		<LangVersion>latest</LangVersion>
 		<TargetFrameworks>net45;netstandard2.0;net6.0;net8.0;</TargetFrameworks>
 		<Description>
 			ThingsGateway.Foundation是工业设备通讯类库，归属于ThingsGateway边缘网关项目，说明文档：https://diego2098.gitee.io/thingsgateway-docs/
 		</Description>
+		<Authors>Diego</Authors>
+		<Product>ThingsGateway</Product>
+		<Copyright>© 2023-present Diego</Copyright>
+		<RepositoryUrl>https://gitee.com/diego2098/ThingsGateway</RepositoryUrl>
 		<PublishRepositoryUrl>true</PublishRepositoryUrl>
 		<EmbedUntrackedSource>true</EmbedUntrackedSource>
 		<EmbedAllSources>true</EmbedAllSources>
@@ -20,11 +22,17 @@
 		<PackageLicenseExpression>Apache-2.0</PackageLicenseExpression>
 		<PackageProjectUrl>https://diego2098.gitee.io/thingsgateway-docs/</PackageProjectUrl>
 		<PackageTags>ThingsGateway;Diego;dotNET China;Blazor;设备采集;边缘网关</PackageTags>
+		<SignAssembly>True</SignAssembly>
+		<DelaySign>False</DelaySign>
+		<SatelliteResourceLanguages>zh-Hans</SatelliteResourceLanguages>
 		<PackageOutputPath>..\..\nupkgs</PackageOutputPath>
 		<AssemblyOriginatorKeyFile>..\..\..\snks/ThingsGateway.snk</AssemblyOriginatorKeyFile>
-		<GenerateDocumentationFile>True</GenerateDocumentationFile>
 	</PropertyGroup>
 
+	<PropertyGroup>
+	</PropertyGroup>
+
+
 	<ItemGroup>
 		<None Include="..\..\..\README.md" Pack="true" PackagePath="\" />
 	</ItemGroup>

framework/foundation/ThingsGateway.Foundation.Adapter.DLT645/DLT645/DLT645_2007.cs

@@ -16,13 +16,13 @@ namespace ThingsGateway.Foundation.Adapter.DLT645;
 /// <summary>
 /// DLT645_2007
 /// </summary>
-public class DLT645_2007 : ReadWriteDevicesSerialPortClientBase, IDLT645_2007
+public class DLT645_2007 : ReadWriteDevicesSerialSessionBase, IDLT645_2007
 {
     /// <summary>
     /// DLT645_2007
     /// </summary>
-    /// <param name="serialPortClient"></param>
-    public DLT645_2007(SerialPortClient serialPortClient) : base(serialPortClient)
+    /// <param name="serialSession"></param>
+    public DLT645_2007(SerialSession serialSession) : base(serialSession)
     {
         ThingsGatewayBitConverter = new DLT645_2007BitConverter(EndianType.Big);
         RegisterByteLength = 2;
@@ -62,7 +62,7 @@ public class DLT645_2007 : ReadWriteDevicesSerialPortClientBase, IDLT645_2007
         {
             EnableFEHead = EnableFEHead
         };
-        SerialPortClient.SetDataHandlingAdapter(dataHandleAdapter);
+        SerialSession.SetDataHandlingAdapter(dataHandleAdapter);
     }
 
 
@@ -106,7 +106,7 @@ public class DLT645_2007 : ReadWriteDevicesSerialPortClientBase, IDLT645_2007
     public override OperResult Write(string address, bool[] value, CancellationToken cancellationToken = default) => Write(address, value.ToString(), cancellationToken);
 
     /// <inheritdoc/>
-    public override Task<OperResult> WriteAsync(string address, byte[] value, CancellationToken cancellationToken = default) => Task.FromResult(new OperResult());
+    public override Task<OperResult> WriteAsync(string address, byte[] value, CancellationToken cancellationToken = default) => throw new NotImplementedException();
     /// <inheritdoc/>
     public override Task<OperResult> WriteAsync(string address, uint value, CancellationToken cancellationToken = default) => WriteAsync(address, value.ToString(), cancellationToken);
     /// <inheritdoc/>
@@ -125,7 +125,7 @@ public class DLT645_2007 : ReadWriteDevicesSerialPortClientBase, IDLT645_2007
     public override Task<OperResult> WriteAsync(string address, int value, CancellationToken cancellationToken = default) => WriteAsync(address, value.ToString(), cancellationToken);
 
     /// <inheritdoc/>
-    public override Task<OperResult> WriteAsync(string address, bool[] value, CancellationToken cancellationToken = default) => Task.FromResult(new OperResult());
+    public override Task<OperResult> WriteAsync(string address, bool[] value, CancellationToken cancellationToken = default) => throw new NotImplementedException();
 
 
     #region 其他方法

framework/foundation/ThingsGateway.Foundation.Adapter.DLT645/DLT645/DLT645_2007OverTcp.cs

@@ -106,7 +106,7 @@ public class DLT645_2007OverTcp : ReadWriteDevicesTcpClientBase, IDLT645_2007
     public override OperResult Write(string address, bool[] value, CancellationToken cancellationToken = default) => Write(address, value.ToString(), cancellationToken);
 
     /// <inheritdoc/>
-    public override Task<OperResult> WriteAsync(string address, byte[] value, CancellationToken cancellationToken = default) => Task.FromResult(new OperResult());
+    public override Task<OperResult> WriteAsync(string address, byte[] value, CancellationToken cancellationToken = default) => throw new NotImplementedException();
     /// <inheritdoc/>
     public override Task<OperResult> WriteAsync(string address, uint value, CancellationToken cancellationToken = default) => WriteAsync(address, value.ToString(), cancellationToken);
     /// <inheritdoc/>
@@ -125,7 +125,7 @@ public class DLT645_2007OverTcp : ReadWriteDevicesTcpClientBase, IDLT645_2007
     public override Task<OperResult> WriteAsync(string address, int value, CancellationToken cancellationToken = default) => WriteAsync(address, value.ToString(), cancellationToken);
 
     /// <inheritdoc/>
-    public override Task<OperResult> WriteAsync(string address, bool[] value, CancellationToken cancellationToken = default) => Task.FromResult(new OperResult());
+    public override Task<OperResult> WriteAsync(string address, bool[] value, CancellationToken cancellationToken = default) => throw new NotImplementedException();
 
 
     #region 其他方法

framework/foundation/ThingsGateway.Foundation.Adapter.DLT645/GlobalUsings.cs

@@ -17,5 +17,5 @@ global using System.Threading;
 global using System.Threading.Tasks;
 
 global using ThingsGateway.Foundation.Core;
-global using ThingsGateway.Foundation.SerialPorts;
+global using ThingsGateway.Foundation.Serial;
 global using ThingsGateway.Foundation.Sockets;

framework/foundation/ThingsGateway.Foundation.Adapter.Modbus/GlobalUsings.cs

@@ -17,5 +17,5 @@ global using System.Threading;
 global using System.Threading.Tasks;
 
 global using ThingsGateway.Foundation.Core;
-global using ThingsGateway.Foundation.SerialPorts;
+global using ThingsGateway.Foundation.Serial;
 global using ThingsGateway.Foundation.Sockets;

framework/foundation/ThingsGateway.Foundation.Adapter.Modbus/Modbus/Dtu/ModbusTcpDtu/ModbusTcpDtu.cs

@@ -14,14 +14,14 @@ using System.ComponentModel;
 
 namespace ThingsGateway.Foundation.Adapter.Modbus;
 /// <inheritdoc/>
-public class ModbusDtu : ReadWriteDevicesTcpServerBase
+public class ModbusTcpDtu : ReadWriteDevicesTcpServerBase
 {
     /// <inheritdoc/>
-    public ModbusDtu(TcpService tcpService) : base(tcpService)
+    public ModbusTcpDtu(TcpService tcpService) : base(tcpService)
     {
         ThingsGatewayBitConverter = new ThingsGatewayBitConverter(EndianType.Big);
         RegisterByteLength = 2;
-        ModbusDtuPlugin modbusTcpSalvePlugin = new ModbusDtuPlugin();
+        ModbusTcpDtuPlugin modbusTcpSalvePlugin = new ModbusTcpDtuPlugin();
         tcpService.Config.ConfigurePlugins(a =>
          {
              a.Add(modbusTcpSalvePlugin);
@@ -35,18 +35,6 @@ public class ModbusDtu : ReadWriteDevicesTcpServerBase
     [Description("检测事务标识符")]
     public bool IsCheckMessageId { get; set; }
 
-    /// <summary>
-    /// 是否Rtu格式
-    /// </summary>
-    [Description("是否Rtu格式")]
-    public bool IsRtu { get; set; }
-
-    /// <summary>
-    /// Crc校验
-    /// </summary>
-    [Description("Crc校验")]
-    public bool Crc16CheckEnable { get; set; } = true;
-
     /// <summary>
     /// 站号
     /// </summary>
@@ -104,49 +92,23 @@ public class ModbusDtu : ReadWriteDevicesTcpServerBase
     {
         if (socketClient != default)
         {
-            if (!IsRtu)
+            ModbusTcpDataHandleAdapter dataHandleAdapter = new()
+            {
+                IsCheckMessageId = IsCheckMessageId,
+                CacheTimeout = TimeSpan.FromMilliseconds(CacheTimeout)
+            };
+            socketClient.SetDataHandlingAdapter(dataHandleAdapter);
+        }
+        else
+        {
+            foreach (var item in TcpService.GetClients())
             {
                 ModbusTcpDataHandleAdapter dataHandleAdapter = new()
                 {
                     IsCheckMessageId = IsCheckMessageId,
                     CacheTimeout = TimeSpan.FromMilliseconds(CacheTimeout)
                 };
-                socketClient.SetDataHandlingAdapter(dataHandleAdapter);
-            }
-            else
-            {
-                ModbusRtuDataHandleAdapter dataHandleAdapter = new()
-                {
-                    Crc16CheckEnable = Crc16CheckEnable,
-                    CacheTimeout = TimeSpan.FromMilliseconds(CacheTimeout)
-                };
-                socketClient.SetDataHandlingAdapter(dataHandleAdapter);
-            }
-        }
-        else
-        {
-            //只适配第一个
-            var item = TcpService.GetClients().FirstOrDefault();
-            if (item != null)
-            {
-                if (!IsRtu)
-                {
-                    ModbusTcpDataHandleAdapter dataHandleAdapter = new()
-                    {
-                        IsCheckMessageId = IsCheckMessageId,
-                        CacheTimeout = TimeSpan.FromMilliseconds(CacheTimeout)
-                    };
-                    item.SetDataHandlingAdapter(dataHandleAdapter);
-                }
-                else
-                {
-                    ModbusRtuDataHandleAdapter dataHandleAdapter = new()
-                    {
-                        Crc16CheckEnable = Crc16CheckEnable,
-                        CacheTimeout = TimeSpan.FromMilliseconds(CacheTimeout)
-                    };
-                    item.SetDataHandlingAdapter(dataHandleAdapter);
-                }
+                item.SetDataHandlingAdapter(dataHandleAdapter);
             }
         }
     }
@@ -225,7 +187,7 @@ public class ModbusDtu : ReadWriteDevicesTcpServerBase
         if (TcpService.TryGetSocketClient($"ID={id}", out var client))
         {
             SetDataAdapter(client);
-            return SendThenReturn<MessageBase>(command, cancellationToken, client);
+            return SendThenReturn<ModbusTcpMessage>(command, cancellationToken, client);
         }
         else
         {
@@ -238,7 +200,7 @@ public class ModbusDtu : ReadWriteDevicesTcpServerBase
         if (TcpService.TryGetSocketClient($"ID={id}", out var client))
         {
             SetDataAdapter(client);
-            return await SendThenReturnAsync<MessageBase>(command, cancellationToken, client);
+            return await SendThenReturnAsync<ModbusTcpMessage>(command, cancellationToken, client);
         }
         else if (TcpService.SocketClients.Count == 1)
         {
@@ -246,13 +208,13 @@ public class ModbusDtu : ReadWriteDevicesTcpServerBase
             if (client1 != null)
             {
                 SetDataAdapter(client1);
-                return await SendThenReturnAsync<MessageBase>(command, cancellationToken, client1);
+                return await SendThenReturnAsync<ModbusTcpMessage>(command, cancellationToken, client1);
             }
         }
         return new OperResult<byte[]>("客户端未连接");
     }
 
-    internal class ModbusDtuPlugin : PluginBase, ITcpReceivingPlugin
+    internal class ModbusTcpDtuPlugin : PluginBase, ITcpReceivingPlugin
     {
         public async Task OnTcpReceiving(ITcpClientBase client, ByteBlockEventArgs e)
         {

framework/foundation/ThingsGateway.Foundation.Adapter.Modbus/Modbus/ModbusHelper.cs

@@ -134,19 +134,21 @@ internal class ModbusHelper
 
         if (response[1] >= 0x80)//错误码
             return new OperResult<byte[], FilterResult>(GetDescriptionByErrorCode(response[2])) { Content2 = FilterResult.Success };
-        if (response[1] <= 0x04)
+        if (response[1] <= 0x05)
         {
             if ((response.Length < response[2] + 5))
                 return new OperResult<byte[], FilterResult>("数据长度不足" + response.ToHexString()) { Content2 = FilterResult.Cache };
+
         }
         else
         {
             if ((response.Length < 8))
                 return new OperResult<byte[], FilterResult>("数据长度不足" + response.ToHexString()) { Content2 = FilterResult.Cache };
+
         }
 
 
-        var data = response.SelectMiddle(0, response[1] <= 0x04 ? response[2] != 0 ? response[2] + 5 : 8 : 8);
+        var data = response.SelectMiddle(0, response[2] != 0 ? response[2] + 5 : 8);
         if (crcCheck && !CRC16Utils.CheckCRC16(data))
             return new OperResult<byte[], FilterResult>("Crc校验失败" + DataTransUtil.ByteToHexString(data, ' ')) { Content2 = FilterResult.Success };
         return GetModbusData(send, data.RemoveLast(2));

framework/foundation/ThingsGateway.Foundation.Adapter.Modbus/Modbus/ModbusRtu/ModbusRtu.cs

@@ -16,13 +16,13 @@ namespace ThingsGateway.Foundation.Adapter.Modbus;
 /// <summary>
 /// ModbusRtu
 /// </summary>
-public class ModbusRtu : ReadWriteDevicesSerialPortClientBase
+public class ModbusRtu : ReadWriteDevicesSerialSessionBase
 {
     /// <summary>
     /// ModbusRtu
     /// </summary>
-    /// <param name="serialPortClient"></param>
-    public ModbusRtu(SerialPortClient serialPortClient) : base(serialPortClient)
+    /// <param name="serialSession"></param>
+    public ModbusRtu(SerialSession serialSession) : base(serialSession)
     {
         ThingsGatewayBitConverter = new ThingsGatewayBitConverter(EndianType.Big);
         RegisterByteLength = 2;
@@ -93,7 +93,7 @@ public class ModbusRtu : ReadWriteDevicesSerialPortClientBase
             Crc16CheckEnable = Crc16CheckEnable,
             CacheTimeout = TimeSpan.FromMilliseconds(CacheTimeout)
         };
-        SerialPortClient.SetDataHandlingAdapter(dataHandleAdapter);
+        SerialSession.SetDataHandlingAdapter(dataHandleAdapter);
     }
 
     /// <inheritdoc/>

framework/foundation/ThingsGateway.Foundation.Adapter.Modbus/Modbus/ModbusTcp/ModbusTcpDataHandleAdapter.cs

@@ -19,7 +19,7 @@ namespace ThingsGateway.Foundation.Adapter.Modbus;
 /// </summary>
 internal class ModbusTcpDataHandleAdapter : ReadWriteDevicesSingleStreamDataHandleAdapter<ModbusTcpMessage>
 {
-    private readonly IncrementCount _incrementCount = new(ushort.MaxValue);
+    private readonly IncrementCount easyIncrementCount = new(ushort.MaxValue);
 
     /// <summary>
     /// 检测事务标识符
@@ -39,7 +39,7 @@ internal class ModbusTcpDataHandleAdapter : ReadWriteDevicesSingleStreamDataHand
     /// <inheritdoc/>
     public override byte[] PackCommand(byte[] command)
     {
-        return ModbusHelper.AddModbusTcpHead(command, (ushort)_incrementCount.GetCurrentValue());
+        return ModbusHelper.AddModbusTcpHead(command, (ushort)easyIncrementCount.GetCurrentValue());
     }
 
     /// <inheritdoc/>

framework/foundation/ThingsGateway.Foundation.Adapter.Modbus/Modbus/ModbusUdp/ModbusUdpDataHandleAdapter.cs

@@ -18,7 +18,7 @@ namespace ThingsGateway.Foundation.Adapter.Modbus;
 /// </summary>
 internal class ModbusUdpDataHandleAdapter : ReadWriteDevicesUdpDataHandleAdapter<ModbusTcpMessage>
 {
-    private readonly IncrementCount _incrementCount = new(ushort.MaxValue);
+    private readonly IncrementCount easyIncrementCount = new(ushort.MaxValue);
 
     /// <summary>
     /// 检测事务标识符
@@ -38,7 +38,7 @@ internal class ModbusUdpDataHandleAdapter : ReadWriteDevicesUdpDataHandleAdapter
     /// <inheritdoc/>
     public override byte[] PackCommand(byte[] command)
     {
-        return ModbusHelper.AddModbusTcpHead(command, (ushort)_incrementCount.GetCurrentValue());
+        return ModbusHelper.AddModbusTcpHead(command, (ushort)easyIncrementCount.GetCurrentValue());
     }
 
     /// <inheritdoc/>

framework/foundation/ThingsGateway.Foundation.Adapter.Modbus/Modbus/Server/ModbusSerialServer/ModbusSerialServer.cs

@@ -16,10 +16,10 @@ namespace ThingsGateway.Foundation.Adapter.Modbus;
 /// <summary>
 /// <inheritdoc/>
 /// </summary>
-public class ModbusSerialServer : ReadWriteDevicesSerialPortClientBase, IModbusServer
+public class ModbusSerialServer : ReadWriteDevicesSerialSessionBase, IModbusServer
 {
     /// <inheritdoc/>
-    public ModbusSerialServer(SerialPortClient serialPortClient) : base(serialPortClient)
+    public ModbusSerialServer(SerialSession serialSession) : base(serialSession)
     {
         ThingsGatewayBitConverter = new ThingsGatewayBitConverter(EndianType.Big);
         RegisterByteLength = 2;
@@ -130,7 +130,7 @@ public class ModbusSerialServer : ReadWriteDevicesSerialPortClientBase, IModbusS
     {
         ModbusSerialServerDataHandleAdapter dataHandleAdapter = new();
         dataHandleAdapter.CacheTimeout = TimeSpan.FromMilliseconds(CacheTimeout);
-        SerialPortClient.SetDataHandlingAdapter(dataHandleAdapter);
+        SerialSession.SetDataHandlingAdapter(dataHandleAdapter);
     }
 
 
@@ -165,7 +165,7 @@ public class ModbusSerialServer : ReadWriteDevicesSerialPortClientBase, IModbusS
     }
 
     /// <inheritdoc/>
-    protected override async Task Received(SerialPortClient client, ReceivedDataEventArgs e)
+    protected override async Task Received(SerialSession client, ReceivedDataEventArgs e)
     {
         try
         {

framework/foundation/ThingsGateway.Foundation.Adapter.Modbus/ThingsGateway.Foundation.Adapter.Modbus.xml

@@ -253,11 +253,11 @@
             ModbusRtu
             </summary>
         </member>
-        <member name="M:ThingsGateway.Foundation.Adapter.Modbus.ModbusRtu.#ctor(ThingsGateway.Foundation.SerialPorts.SerialPortClient)">
+        <member name="M:ThingsGateway.Foundation.Adapter.Modbus.ModbusRtu.#ctor(ThingsGateway.Foundation.Serial.SerialSession)">
             <summary>
             ModbusRtu
             </summary>
-            <param name="serialPortClient"></param>
+            <param name="serialSession"></param>
         </member>
         <member name="P:ThingsGateway.Foundation.Adapter.Modbus.ModbusRtu.Crc16CheckEnable">
             <summary>

framework/foundation/ThingsGateway.Foundation/Foundation/BaseReadWrite/IReadWrite.cs

@@ -143,7 +143,7 @@ public interface IReadWrite : IDisposable
     /// <param name="cancellationToken">取消令箭</param>
     /// <param name="senderClient">传入改参数时，将新建等待线程</param>
     /// <returns></returns>
-    T SendThenReturn<T>(byte[] command, CancellationToken cancellationToken, ISenderClient senderClient = default) where T : OperResult<byte[]>;
+    T SendThenReturn<T>(byte[] command, CancellationToken cancellationToken, ISenderClient senderClient = default) where T : OperResult<byte[]>, new();
 
     /// <summary>
     /// 异步发送并返回结果
@@ -153,7 +153,7 @@ public interface IReadWrite : IDisposable
     /// <param name="cancellationToken">取消令箭</param>
     /// <param name="senderClient">传入改参数时，将新建等待线程</param>
     /// <returns></returns>
-    Task<T> SendThenReturnAsync<T>(byte[] command, CancellationToken cancellationToken, ISenderClient senderClient = default) where T : OperResult<byte[]>;
+    Task<T> SendThenReturnAsync<T>(byte[] command, CancellationToken cancellationToken, ISenderClient senderClient = default) where T : OperResult<byte[]>, new();
 
     /// <summary>
     /// 发送获取数据

framework/foundation/ThingsGateway.Foundation/Foundation/BaseReadWrite/ReadWriteDevicesBase.cs

@@ -148,7 +148,7 @@ public abstract class ReadWriteDevicesBase : IReadWrite
     public abstract void Send(byte[] command, string id = default);
 
     /// <inheritdoc/>
-    public virtual T SendThenReturn<T>(byte[] command, CancellationToken cancellationToken, ISenderClient senderClient = default) where T : OperResult<byte[]>
+    public virtual T SendThenReturn<T>(byte[] command, CancellationToken cancellationToken, ISenderClient senderClient = default) where T : OperResult<byte[]>, new()
     {
         var item = command;
         if (FrameTime != 0)
@@ -157,7 +157,7 @@ public abstract class ReadWriteDevicesBase : IReadWrite
         return (T)result.RequestInfo;
     }
     /// <inheritdoc/>
-    public virtual async Task<T> SendThenReturnAsync<T>(byte[] command, CancellationToken cancellationToken, ISenderClient senderClient = default) where T : OperResult<byte[]>
+    public virtual async Task<T> SendThenReturnAsync<T>(byte[] command, CancellationToken cancellationToken, ISenderClient senderClient = default) where T : OperResult<byte[]>, new()
     {
         var item = command;
         await Task.Delay(FrameTime, cancellationToken);

framework/foundation/ThingsGateway.Foundation/Foundation/BaseReadWrite/ReadWriteDevicesSerialSessionBase.cs

@@ -10,34 +10,33 @@
 //------------------------------------------------------------------------------
 #endregion
 
-
 namespace ThingsGateway.Foundation.Core;
 
 /// <summary>
 /// 串口读写设备
 /// </summary>
-public abstract class ReadWriteDevicesSerialPortClientBase : ReadWriteDevicesBase
+public abstract class ReadWriteDevicesSerialSessionBase : ReadWriteDevicesBase
 {
     /// <summary>
-    /// <inheritdoc cref="ReadWriteDevicesSerialPortClientBase"/>
+    /// <inheritdoc cref="ReadWriteDevicesSerialSessionBase"/>
     /// </summary>
-    /// <param name="serialPortClient"></param>
-    public ReadWriteDevicesSerialPortClientBase(SerialPortClient serialPortClient)
+    /// <param name="serialSession"></param>
+    public ReadWriteDevicesSerialSessionBase(SerialSession serialSession)
     {
-        SerialPortClient = serialPortClient;
-        WaitingClientEx = SerialPortClient.CreateWaitingClient(new() { });
-        SerialPortClient.Received -= Received;
-        SerialPortClient.Connecting -= Connecting;
-        SerialPortClient.Connected -= Connected;
-        SerialPortClient.Disconnecting -= Disconnecting;
-        SerialPortClient.Disconnected -= Disconnected;
-        SerialPortClient.Connecting += Connecting;
-        SerialPortClient.Connected += Connected;
-        SerialPortClient.Disconnecting += Disconnecting;
-        SerialPortClient.Disconnected += Disconnected;
-        SerialPortClient.Received += Received;
+        SerialSession = serialSession;
+        WaitingClientEx = SerialSession.CreateWaitingClient(new() { });
+        SerialSession.Received -= Received;
+        SerialSession.Connecting -= Connecting;
+        SerialSession.Connected -= Connected;
+        SerialSession.Disconnecting -= Disconnecting;
+        SerialSession.Disconnected -= Disconnected;
+        SerialSession.Connecting += Connecting;
+        SerialSession.Connected += Connected;
+        SerialSession.Disconnecting += Disconnecting;
+        SerialSession.Disconnected += Disconnected;
+        SerialSession.Received += Received;
 
-        Logger = SerialPortClient.Logger;
+        Logger = SerialSession.Logger;
     }
     /// <summary>
     /// 接收解析
@@ -45,88 +44,88 @@ public abstract class ReadWriteDevicesSerialPortClientBase : ReadWriteDevicesBas
     /// <param name="client"></param>
     /// <param name="e"></param>
     /// <returns></returns>
-    protected virtual Task Received(SerialPortClient client, ReceivedDataEventArgs e)
+    protected virtual Task Received(SerialSession client, ReceivedDataEventArgs e)
     {
         return EasyTask.CompletedTask;
     }
 
     /// <inheritdoc/>
-    public override ChannelEnum ChannelEnum => ChannelEnum.SerialPortClient;
+    public override ChannelEnum ChannelEnum => ChannelEnum.SerialSession;
 
     /// <summary>
     /// 串口管理对象
     /// </summary>
-    public SerialPortClient SerialPortClient { get; }
+    public SerialSession SerialSession { get; }
 
     /// <summary>
     /// 默认WaitingClientEx
     /// </summary>
-    public virtual IWaitingClient<SerialPortClient> WaitingClientEx { get; }
+    public virtual IWaitingClient<SerialSession> WaitingClientEx { get; }
     /// <inheritdoc/>
     public override bool IsConnected()
     {
-        return SerialPortClient?.CanSend == true;
+        return SerialSession?.CanSend == true;
     }
     /// <inheritdoc/>
     public override void Connect(CancellationToken cancellationToken)
     {
-        SerialPortClient.Connect();
+        SerialSession.Connect();
     }
 
     /// <inheritdoc/>
     public override Task ConnectAsync(CancellationToken cancellationToken)
     {
-        return SerialPortClient.ConnectAsync();
+        return SerialSession.ConnectAsync();
     }
 
     /// <inheritdoc/>
     public override void Disconnect()
     {
         if (CascadeDisposal && IsConnected())
-            SerialPortClient.Close();
+            SerialSession.Close();
     }
 
     /// <inheritdoc/>
     public override void Dispose()
     {
         Disconnect();
-        SerialPortClient.Received -= Received;
-        SerialPortClient.Connecting -= Connecting;
-        SerialPortClient.Connected -= Connected;
-        SerialPortClient.Disconnecting -= Disconnecting;
-        SerialPortClient.Disconnected -= Disconnected;
-        if (CascadeDisposal && !SerialPortClient.DisposedValue)
-            SerialPortClient.SafeDispose();
+        SerialSession.Received -= Received;
+        SerialSession.Connecting -= Connecting;
+        SerialSession.Connected -= Connected;
+        SerialSession.Disconnecting -= Disconnecting;
+        SerialSession.Disconnected -= Disconnected;
+        if (CascadeDisposal && !SerialSession.DisposedValue)
+            SerialSession.SafeDispose();
     }
 
     /// <inheritdoc/>
     public override string ToString()
     {
-        return SerialPortClient.ToString();
+        return SerialSession.SerialProperty.ToString();
     }
 
-    private async Task Connected(ISerialPortClient client, ConnectedEventArgs e)
+    private async Task Connected(ISerialSession client, ConnectedEventArgs e)
     {
-        Logger?.Debug(client.ToString() + "连接成功");
+        Logger?.Debug(client.SerialProperty.ToString() + "连接成功");
         SetDataAdapter();
         await EasyTask.CompletedTask;
     }
 
-    private async Task Connecting(ISerialPortClient client, SerialConnectingEventArgs e)
+    private async Task Connecting(ISerialSession client, SerialConnectingEventArgs e)
     {
-        Logger?.Debug(client.ToString() + "正在连接");
+        Logger?.Debug(client.SerialProperty.ToString() + "正在连接");
         await EasyTask.CompletedTask;
     }
 
-    private async Task Disconnected(ISerialPortClient client, DisconnectEventArgs e)
+    private async Task Disconnected(ISerialSessionBase client, DisconnectEventArgs e)
     {
-        Logger?.Debug(client.ToString() + "断开连接-" + e.Message);
+        Logger?.Debug(client.SerialProperty.ToString() + "断开连接-" + e.Message);
         await EasyTask.CompletedTask;
     }
 
-    private async Task Disconnecting(ISerialPortClient client, DisconnectEventArgs e)
+    private async Task Disconnecting(ISerialSessionBase client, DisconnectEventArgs e)
     {
-        Logger?.Debug(client.ToString() + "正在主动断开连接-" + e.Message);
+        Logger?.Debug(client.SerialProperty.ToString() + "正在主动断开连接-" + e.Message);
         await EasyTask.CompletedTask;
     }
 
@@ -151,6 +150,6 @@ public abstract class ReadWriteDevicesSerialPortClientBase : ReadWriteDevicesBas
     /// <inheritdoc/>
     public override void Send(byte[] command, string id = default)
     {
-        SerialPortClient.Send(command);
+        SerialSession.Send(command);
     }
 }

framework/foundation/ThingsGateway.Foundation/Foundation/BaseReadWrite/ReadWriteDevicesTcpServerBase.cs

@@ -53,7 +53,8 @@ public abstract class ReadWriteDevicesTcpServerBase : ReadWriteDevicesBase
     /// <inheritdoc/>
     public override Task ConnectAsync(CancellationToken cancellationToken)
     {
-        return TcpService.StartAsync();
+        Connect(cancellationToken);
+        return EasyTask.CompletedTask;
     }
 
     /// <inheritdoc/>

framework/foundation/ThingsGateway.Foundation/Foundation/BaseReadWrite/ReadWriteDevicesUdpSessionBase.cs

@@ -48,7 +48,7 @@ public abstract class ReadWriteDevicesUdpSessionBase : ReadWriteDevicesBase
     /// <inheritdoc/>
     public override Task ConnectAsync(CancellationToken cancellationToken)
     {
-        return UdpSession.StartAsync();
+        return Task.FromResult(UdpSession.Start());
     }
 
     /// <inheritdoc/>
@@ -69,7 +69,7 @@ public abstract class ReadWriteDevicesUdpSessionBase : ReadWriteDevicesBase
     /// <inheritdoc/>
     public override string ToString()
     {
-        return UdpSession.RemoteIPHost?.ToString();
+        return UdpSession.RemoteIPHost.ToString();
     }
 
     /// <inheritdoc/>

framework/foundation/ThingsGateway.Foundation/Foundation/DataHandleAdapter/ReadWriteDevicesSingleStreamDataHandleAdapter.cs

@@ -29,7 +29,6 @@ public abstract class ReadWriteDevicesSingleStreamDataHandleAdapter<TRequest> :
     public ReadWriteDevicesSingleStreamDataHandleAdapter()
     {
         Request = GetInstance();
-        CacheTimeoutEnable = true;
     }
     /// <inheritdoc/>
     public override bool CanSendRequestInfo => false;

framework/foundation/ThingsGateway.Foundation/Foundation/DataHandleAdapter/ReadWriteDevicesUdpDataHandleAdapter.cs

@@ -53,7 +53,7 @@ public abstract class ReadWriteDevicesUdpDataHandleAdapter<TRequest> : UdpDataHa
     /// <inheritdoc/>
     public override string ToString()
     {
-        return (Owner as UdpSession)?.RemoteIPHost?.ToString();
+        return (Owner as UdpSession)?.RemoteIPHost.ToString();
     }
 
     /// <summary>
@@ -83,11 +83,11 @@ public abstract class ReadWriteDevicesUdpDataHandleAdapter<TRequest> : UdpDataHa
         var allBytes = byteBlock.ToArray(0, byteBlock.Len);
         Logger?.Trace($"{FoundationConst.LogMessageHeader}{ToString()}- 接收:{(IsHexData ? allBytes.ToHexString(' ') : Encoding.UTF8.GetString(allBytes))}");
 
-        //if (Request?.SendBytes == null)
-        //{
-        //    GoReceived(remoteEndPoint, byteBlock, null);
-        //    return;
-        //}
+        if (Request?.SendBytes == null)
+        {
+            GoReceived(remoteEndPoint, byteBlock, null);
+            return;
+        }
         byte[] header = new byte[] { };
         if (Request.HeadBytesLength > 0)
         {

framework/foundation/ThingsGateway.Foundation/Foundation/Enums/ChannelEnum.cs

@@ -22,7 +22,7 @@ public enum ChannelEnum
     /// <inheritdoc/>
     TcpClient = 1,
     /// <inheritdoc/>
-    SerialPortClient = 2,
+    SerialSession = 2,
     /// <inheritdoc/>
     UdpSession = 4,
     /// <inheritdoc/>

framework/foundation/ThingsGateway.Foundation/Foundation/Extensions/StringExtensions.cs

@@ -421,74 +421,6 @@ public static class StringExtensions
     {
         return value.IsNullOrEmpty() ? defaultValue : ushort.TryParse(value, out var n) ? n : defaultValue;
     }
-    /// <summary>
-    /// ToDouble
-    /// </summary>
-    /// <returns></returns>
-    public static double ToDouble(this object value, double defaultValue = 0)
-    {
-        if (value is Double d)
-        {
-            return Double.IsNaN(d) ? defaultValue : (Double)d;
-        }
-        var str = value?.ToString();
-        if (str.IsNullOrEmpty())
-        {
-            return (double)defaultValue;
-        }
-        else
-        {
-            if (value is bool boolValue)
-            {
-                return boolValue ? 1 : 0;
-            }
-            return (double)(double.TryParse(str, out var n) ? n : defaultValue);
-        }
-    }
-
-    /// <summary>
-    /// ToDecimal
-    /// </summary>
-    /// <returns></returns>
-    public static decimal ToDecimal(this object value, int defaultValue = 0)
-    {
-        if (value is Double d)
-        {
-            return Double.IsNaN(d) ? defaultValue : (Decimal)d;
-        }
-        var str = value?.ToString();
-        if (str.IsNullOrEmpty())
-        {
-            return defaultValue;
-        }
-        else
-        {
-            if (value is bool boolValue)
-            {
-                return boolValue ? 1 : 0;
-            }
-            return Decimal.TryParse(str, out var n) ? n : defaultValue;
-        }
-    }
-    /// <summary>
-    /// ToInt
-    /// </summary>
-    /// <returns></returns>
-    public static int ToInt(this object value, int defaultValue = 0)
-    {
-        if (value == null || value.ToString().IsNullOrEmpty())
-        {
-            return defaultValue;
-        }
-        else
-        {
-            if (value is bool boolValue)
-            {
-                return boolValue ? 1 : 0;
-            }
-            return int.TryParse(value.ToString(), out int n) ? n : defaultValue;
-        }
-    }
 
     /// <summary>
     /// 用 正则表达式 判断字符是不是汉字

framework/foundation/ThingsGateway.Foundation/Foundation/SerialPort/EventArgs/SerialConnectingEventArgs.cs

@@ -0,0 +1,48 @@
+#region copyright
+//------------------------------------------------------------------------------
+//  此代码版权声明为全文件覆盖，如有原作者特别声明，会在下方手动补充
+//  此代码版权（除特别声明外的代码）归作者本人Diego所有
+//  源代码使用协议遵循本仓库的开源协议及附加协议
+//  Gitee源代码仓库：https://gitee.com/diego2098/ThingsGateway
+//  Github源代码仓库：https://github.com/kimdiego2098/ThingsGateway
+//  使用文档：https://diego2098.gitee.io/thingsgateway-docs/
+//  QQ群：605534569
+//------------------------------------------------------------------------------
+#endregion
+
+using System.IO.Ports;
+
+namespace ThingsGateway.Foundation.Serial;
+/// <summary>
+/// Connecting
+/// </summary>
+/// <typeparam name="TClient"></typeparam>
+/// <param name="client"></param>
+/// <param name="e"></param>
+public delegate Task SerialConnectingEventHandler<TClient>(TClient client, SerialConnectingEventArgs e);
+
+/// <summary>
+/// 客户端连接事件。
+/// </summary>
+public class SerialConnectingEventArgs : MsgPermitEventArgs
+{
+    /// <summary>
+    /// 构造函数
+    /// </summary>
+    /// <param name="serialPort"></param>
+    public SerialConnectingEventArgs(SerialPort serialPort)
+    {
+        this.SerialPort = serialPort;
+        this.IsPermitOperation = true;
+    }
+
+    /// <summary>
+    /// 客户端Id。该Id的赋值，仅在服务器适用。
+    /// </summary>
+    public string Id { get; set; }
+
+    /// <summary>
+    /// 新初始化的通信器
+    /// </summary>
+    public SerialPort SerialPort { get; private set; }
+}

framework/foundation/ThingsGateway.Foundation/Foundation/SerialPort/EventArgs/SerialReceivedEventArgs.cs

@@ -1,4 +1,4 @@
-#region copyright
+#region copyright
 //------------------------------------------------------------------------------
 //  此代码版权声明为全文件覆盖，如有原作者特别声明，会在下方手动补充
 //  此代码版权（除特别声明外的代码）归作者本人Diego所有
@@ -10,12 +10,15 @@
 //------------------------------------------------------------------------------
 #endregion
 
-namespace ThingsGateway.Components;
+namespace ThingsGateway.Foundation.Serial;
 
-public class DefaultTimezoneOffsetAccessor : IDefaultTimezoneOffsetAccessor
+/// <summary>
+/// 字节事件
+/// </summary>
+public class SerialReceivedEventArgs : TouchSocketEventArgs
 {
-    public TimeSpan GetTimezoneOffsetResult()
-    {
-        return TimeSpan.FromHours(8);
-    }
-}
+    /// <summary>
+    /// 数据块
+    /// </summary>
+    public ByteBlock UserToken { get; set; }
+}

framework/foundation/ThingsGateway.Foundation/Foundation/SerialPort/Extension/SerialConfigExtension.cs

@@ -0,0 +1,38 @@
+#region copyright
+//------------------------------------------------------------------------------
+//  此代码版权声明为全文件覆盖，如有原作者特别声明，会在下方手动补充
+//  此代码版权（除特别声明外的代码）归作者本人Diego所有
+//  源代码使用协议遵循本仓库的开源协议及附加协议
+//  Gitee源代码仓库：https://gitee.com/diego2098/ThingsGateway
+//  Github源代码仓库：https://github.com/kimdiego2098/ThingsGateway
+//  使用文档：https://diego2098.gitee.io/thingsgateway-docs/
+//  QQ群：605534569
+//------------------------------------------------------------------------------
+#endregion
+
+namespace ThingsGateway.Foundation.Serial;
+
+/// <summary>
+/// 串口附加属性
+/// </summary>
+public static class SerialConfigExtension
+{
+    /// <summary>
+    /// 串口属性
+    /// </summary>
+    public static readonly DependencyProperty<SerialProperty> SerialProperty =
+        DependencyProperty<SerialProperty>.Register("SerialProperty", new());
+
+    /// <summary>
+    /// 设置串口
+    /// </summary>
+    /// <param name="config"></param>
+    /// <param name="value"></param>
+    /// <returns></returns>
+    public static TouchSocketConfig SetSerialProperty(this TouchSocketConfig config, SerialProperty value)
+    {
+        config.SetValue(SerialProperty, value);
+        return config;
+    }
+
+}

framework/foundation/ThingsGateway.Foundation/Foundation/SerialPort/Extension/SerialPortExtensions.cs

@@ -0,0 +1,58 @@
+#region copyright
+//------------------------------------------------------------------------------
+//  此代码版权声明为全文件覆盖，如有原作者特别声明，会在下方手动补充
+//  此代码版权（除特别声明外的代码）归作者本人Diego所有
+//  源代码使用协议遵循本仓库的开源协议及附加协议
+//  Gitee源代码仓库：https://gitee.com/diego2098/ThingsGateway
+//  Github源代码仓库：https://github.com/kimdiego2098/ThingsGateway
+//  使用文档：https://diego2098.gitee.io/thingsgateway-docs/
+//  QQ群：605534569
+//------------------------------------------------------------------------------
+#endregion
+
+using System.IO.Ports;
+
+namespace ThingsGateway.Foundation.Serial;
+
+/// <summary>
+/// SocketExtension
+/// </summary>
+public static class SerialPortExtensions
+{
+    /// <summary>
+    /// 会使用同步锁，保证所有数据上缓存区。
+    /// </summary>
+    /// <param name="serialPort"></param>
+    /// <param name="buffer"></param>
+    /// <param name="offset"></param>
+    /// <param name="length"></param>
+    public static void AbsoluteSend(this SerialPort serialPort, byte[] buffer, int offset, int length)
+    {
+        lock (serialPort)
+        {
+            serialPort.Write(buffer, offset, length);
+        }
+    }
+
+    /// <summary>
+    /// 尝试关闭<see cref="SerialPort"/>。不会抛出异常。
+    /// </summary>
+    /// <param name="serialPort"></param>
+    public static void TryClose(this SerialPort serialPort)
+    {
+        lock (serialPort)
+        {
+            try
+            {
+                if (serialPort.IsOpen)
+                {
+                    serialPort.Close();
+                }
+            }
+            catch
+            {
+
+            }
+        }
+    }
+}

framework/foundation/ThingsGateway.Foundation/Foundation/SerialPort/Interface/ISerialSession.cs

@@ -0,0 +1,36 @@
+#region copyright
+//------------------------------------------------------------------------------
+//  此代码版权声明为全文件覆盖，如有原作者特别声明，会在下方手动补充
+//  此代码版权（除特别声明外的代码）归作者本人Diego所有
+//  源代码使用协议遵循本仓库的开源协议及附加协议
+//  Gitee源代码仓库：https://gitee.com/diego2098/ThingsGateway
+//  Github源代码仓库：https://github.com/kimdiego2098/ThingsGateway
+//  使用文档：https://diego2098.gitee.io/thingsgateway-docs/
+//  QQ群：605534569
+//------------------------------------------------------------------------------
+#endregion
+
+namespace ThingsGateway.Foundation.Serial;
+
+/// <summary>
+/// <inheritdoc cref="ISerialSessionBase"/>
+/// </summary>
+public interface ISerialSession : ISerialSessionBase, IClientSender, IPluginObject, ISetupConfigObject
+{
+    /// <summary>
+    /// 成功打开串口
+    /// </summary>
+    ConnectedEventHandler<ISerialSession> Connected { get; set; }
+
+    /// <summary>
+    /// 准备连接串口的时候
+    /// </summary>
+    SerialConnectingEventHandler<ISerialSession> Connecting { get; set; }
+
+    /// <summary>
+    /// 连接串口
+    /// </summary>
+    /// <exception cref="Exception"></exception>
+    ISerialSession Connect();
+
+}

framework/foundation/ThingsGateway.Foundation/Foundation/SerialPort/Interface/ISerialSessionBase.cs

@@ -0,0 +1,66 @@
+#region copyright
+//------------------------------------------------------------------------------
+//  此代码版权声明为全文件覆盖，如有原作者特别声明，会在下方手动补充
+//  此代码版权（除特别声明外的代码）归作者本人Diego所有
+//  源代码使用协议遵循本仓库的开源协议及附加协议
+//  Gitee源代码仓库：https://gitee.com/diego2098/ThingsGateway
+//  Github源代码仓库：https://github.com/kimdiego2098/ThingsGateway
+//  使用文档：https://diego2098.gitee.io/thingsgateway-docs/
+//  QQ群：605534569
+//------------------------------------------------------------------------------
+#endregion
+
+using System.IO.Ports;
+
+namespace ThingsGateway.Foundation.Serial;
+
+/// <summary>
+/// 串口连接接口。
+/// </summary>
+public interface ISerialSessionBase : ISenderClient, IClient, ISender, IDefaultSender, IPluginObject, IRequsetInfoSender, IConfigObject, IOnlineClient
+{
+    /// <summary>
+    /// 是否允许自由调用<see cref="SetDataHandlingAdapter"/>进行赋值。
+    /// </summary>
+    bool CanSetDataHandlingAdapter { get; }
+
+    /// <summary>
+    /// 数据处理适配器
+    /// </summary>
+    SingleStreamDataHandlingAdapter DataHandlingAdapter { get; }
+
+    /// <summary>
+    /// 断开连接
+    /// </summary>
+    DisconnectEventHandler<ISerialSessionBase> Disconnected { get; set; }
+
+    /// <summary>
+    /// 即将断开连接(仅主动断开时有效)。
+    /// <para>
+    /// </para>
+    /// </summary>
+    DisconnectEventHandler<ISerialSessionBase> Disconnecting { get; set; }
+
+    /// <summary>
+    /// 主通信器
+    /// </summary>
+    SerialPort MainSerialPort { get; }
+
+
+    /// <summary>
+    /// 串口描述
+    /// </summary>
+    SerialProperty SerialProperty { get; }
+    /// <summary>
+    /// 关闭客户端。
+    /// </summary>
+    /// <param name="msg"></param>
+    /// <exception cref="Exception"></exception>
+    void Close(string msg = TouchSocketCoreUtility.Empty);
+
+    /// <summary>
+    /// 设置数据处理适配器
+    /// </summary>
+    /// <param name="adapter"></param>
+    void SetDataHandlingAdapter(SingleStreamDataHandlingAdapter adapter);
+}

framework/foundation/ThingsGateway.Foundation/Foundation/SerialPort/SerialPort/SerialCore.cs

@@ -0,0 +1,388 @@
+#region copyright
+//------------------------------------------------------------------------------
+//  此代码版权声明为全文件覆盖，如有原作者特别声明，会在下方手动补充
+//  此代码版权（除特别声明外的代码）归作者本人Diego所有
+//  源代码使用协议遵循本仓库的开源协议及附加协议
+//  Gitee源代码仓库：https://gitee.com/diego2098/ThingsGateway
+//  Github源代码仓库：https://github.com/kimdiego2098/ThingsGateway
+//  使用文档：https://diego2098.gitee.io/thingsgateway-docs/
+//  QQ群：605534569
+//------------------------------------------------------------------------------
+#endregion
+
+using System.IO.Ports;
+
+namespace ThingsGateway.Foundation.Serial;
+internal sealed class InternalSerialCore : SerialCore
+{
+
+}
+/// <summary>
+/// Serial核心
+/// </summary>
+public class SerialCore : IDisposable, ISender
+{
+    /// <summary>
+    /// 最小缓存尺寸
+    /// </summary>
+    public int MinBufferSize { get; set; } = 1024 * 10;
+
+    /// <summary>
+    /// 最大缓存尺寸
+    /// </summary>
+    public int MaxBufferSize { get; set; } = 1024 * 1024 * 10;
+    #region 字段
+
+    /// <summary>
+    /// 同步根
+    /// </summary>
+    public readonly object SyncRoot = new object();
+
+    private long m_bufferRate;
+    private bool m_online => m_serialPort?.IsOpen == true;
+    private int m_receiveBufferSize = 1024 * 10;
+    private ValueCounter m_receiveCounter;
+    private int m_sendBufferSize = 1024 * 10;
+    private ValueCounter m_sendCounter;
+    private readonly EasyLock m_semaphoreForSend = new EasyLock();
+    private SerialPort m_serialPort;
+
+    #endregion 字段
+
+    /// <summary>
+    /// Tcp核心
+    /// </summary>
+    public SerialCore()
+    {
+        this.m_receiveCounter = new ValueCounter
+        {
+            Period = TimeSpan.FromSeconds(1),
+            OnPeriod = this.OnReceivePeriod
+        };
+
+        this.m_sendCounter = new ValueCounter
+        {
+            Period = TimeSpan.FromSeconds(1),
+            OnPeriod = this.OnSendPeriod
+        };
+    }
+
+    /// <summary>
+    /// 析构函数
+    /// </summary>
+    ~SerialCore()
+    {
+        this.SafeDispose();
+    }
+
+    /// <inheritdoc/>
+    public bool CanSend => this.m_online;
+
+    /// <summary>
+    /// 当中断Tcp的时候。当为<see langword="true"/>时，意味着是调用<see cref="Close(string)"/>。当为<see langword="false"/>时，则是其他中断。
+    /// </summary>
+    public Action<SerialCore, bool, string> OnBreakOut { get; set; }
+
+    /// <summary>
+    /// 当发生异常的时候
+    /// </summary>
+    public Action<SerialCore, Exception> OnException { get; set; }
+
+    /// <summary>
+    /// 在线状态
+    /// </summary>
+    public bool Online { get => this.m_online; }
+    /// <summary>
+    /// UserToken
+    /// </summary>
+    public ByteBlock UserToken { get; set; }
+
+    /// <summary>
+    /// 当收到数据的时候
+    /// </summary>
+    public Action<SerialCore, ByteBlock> OnReceived { get; set; }
+
+    /// <summary>
+    /// 接收缓存池,运行时的值会根据流速自动调整
+    /// </summary>
+    public int ReceiveBufferSize
+    {
+        get => this.m_receiveBufferSize;
+    }
+
+    /// <summary>
+    /// 接收计数器
+    /// </summary>
+    public ValueCounter ReceiveCounter { get => this.m_receiveCounter; }
+
+    /// <summary>
+    /// 发送缓存池,运行时的值会根据流速自动调整
+    /// </summary>
+    public int SendBufferSize
+    {
+        get => this.m_sendBufferSize;
+    }
+
+    /// <summary>
+    /// 发送计数器
+    /// </summary>
+    public ValueCounter SendCounter { get => this.m_sendCounter; }
+
+    /// <summary>
+    /// SerialPort
+    /// </summary>
+    public SerialPort MainSerialPort { get => this.m_serialPort; }
+
+
+    /// <summary>
+    /// 开始以Iocp方式接收
+    /// </summary>
+    public virtual void BeginIocpReceive()
+    {
+        var byteBlock = BytePool.Default.GetByteBlock(this.ReceiveBufferSize);
+        this.UserToken = byteBlock;
+        byteBlock.SetLength(0);
+        if (this.m_serialPort.BytesToRead > 0)
+        {
+            this.m_bufferRate += 2;
+            this.ProcessReceived();
+        }
+        m_serialPort.DataReceived += MainSerialPort_DataReceived;
+    }
+
+    private void MainSerialPort_DataReceived(object sender, SerialDataReceivedEventArgs e)
+    {
+        try
+        {
+            this.m_bufferRate = 1;
+            this.ProcessReceived();
+        }
+        catch (Exception ex)
+        {
+            this.PrivateBreakOut(false, ex.ToString());
+        }
+    }
+
+    /// <summary>
+    /// 请求关闭
+    /// </summary>
+    /// <param name="msg"></param>
+    public virtual void Close(string msg)
+    {
+        this.PrivateBreakOut(true, msg);
+    }
+
+    /// <summary>
+    /// 释放对象
+    /// </summary>
+    public void Dispose()
+    {
+        GC.SuppressFinalize(this);
+        UserToken.SafeDispose();
+    }
+
+    /// <summary>
+    /// 重置环境，并设置新的<see cref="m_serialPort"/>。
+    /// </summary>
+    /// <param name="socket"></param>
+    public virtual void Reset(SerialPort socket)
+    {
+        if (socket is null)
+        {
+            throw new ArgumentNullException(nameof(socket));
+        }
+
+        if (!socket.IsOpen)
+        {
+            throw new Exception("新的SerialPort必须在连接状态。");
+        }
+        this.Reset();
+        this.m_serialPort = socket;
+    }
+
+    /// <summary>
+    /// 重置环境。
+    /// </summary>
+    public virtual void Reset()
+    {
+        this.m_receiveCounter.Reset();
+        this.m_sendCounter.Reset();
+        this.m_serialPort = null;
+        this.OnReceived = null;
+        this.OnBreakOut = null;
+        this.UserToken = null;
+        this.m_bufferRate = 1;
+        this.m_receiveBufferSize = this.MinBufferSize;
+        this.m_sendBufferSize = this.MinBufferSize;
+    }
+    /// <summary>
+    /// 判断，当不在连接状态时触发异常。
+    /// </summary>
+    /// <exception cref="NotConnectedException"></exception>
+    protected void ThrowIfNotConnected()
+    {
+        if (!this.m_online)
+        {
+            throw new NotConnectedException();
+        }
+    }
+
+    /// <summary>
+    /// 发送数据。
+    /// <para>
+    /// 内部会根据是否启用Ssl，进行直接发送，还是Ssl发送。
+    /// </para>
+    /// </summary>
+    /// <param name="buffer"></param>
+    /// <param name="offset"></param>
+    /// <param name="length"></param>
+    public virtual void Send(byte[] buffer, int offset, int length)
+    {
+        this.ThrowIfNotConnected();
+        try
+        {
+            this.m_semaphoreForSend.Wait();
+            this.m_serialPort.Write(buffer, offset, length);
+            this.m_sendCounter.Increment(length);
+        }
+        finally
+        {
+            this.m_semaphoreForSend.Release();
+        }
+    }
+
+    /// <summary>
+    /// 异步发送数据。
+    /// </summary>
+    /// <param name="buffer"></param>
+    /// <param name="offset"></param>
+    /// <param name="length"></param>
+    /// <returns></returns>
+    /// <exception cref="Exception"></exception>
+    public virtual async Task SendAsync(byte[] buffer, int offset, int length)
+    {
+        this.ThrowIfNotConnected();
+        try
+        {
+            await this.m_semaphoreForSend.WaitAsync();
+
+            this.m_serialPort.Write(buffer, offset, length);
+            this.m_sendCounter.Increment(length);
+        }
+        finally
+        {
+            this.m_semaphoreForSend.Release();
+        }
+
+    }
+
+    /// <summary>
+    /// 当中断Tcp时。
+    /// </summary>
+    /// <param name="manual">当为<see langword="true"/>时，意味着是调用<see cref="Close(string)"/>。当为<see langword="false"/>时，则是其他中断。</param>
+    /// <param name="msg"></param>
+    protected virtual void BreakOut(bool manual, string msg)
+    {
+        this.OnBreakOut?.Invoke(this, manual, msg);
+    }
+
+
+
+    /// <summary>
+    /// 当发生异常的时候
+    /// </summary>
+    /// <param name="ex"></param>
+    protected virtual void Exception(Exception ex)
+    {
+        this.OnException?.Invoke(this, ex);
+    }
+
+    /// <summary>
+    /// 当收到数据的时候
+    /// </summary>
+    /// <param name="byteBlock"></param>
+    protected virtual void Received(ByteBlock byteBlock)
+    {
+        this.OnReceived?.Invoke(this, byteBlock);
+    }
+
+    private void HandleBuffer(ByteBlock byteBlock)
+    {
+        try
+        {
+            this.m_receiveCounter.Increment(byteBlock.Length);
+            this.Received(byteBlock);
+        }
+        catch (Exception ex)
+        {
+            this.Exception(ex);
+        }
+        finally
+        {
+            byteBlock.Dispose();
+        }
+    }
+
+    private void OnReceivePeriod(long value)
+    {
+        this.m_receiveBufferSize = Math.Max(TouchSocketUtility.HitBufferLength(value), this.MinBufferSize);
+        if (this.MainSerialPort != null && !MainSerialPort.IsOpen)
+        {
+            this.MainSerialPort.ReadBufferSize = this.m_receiveBufferSize;
+        }
+    }
+
+    private void OnSendPeriod(long value)
+    {
+        this.m_sendBufferSize = Math.Max(TouchSocketUtility.HitBufferLength(value), this.MinBufferSize);
+        if (this.MainSerialPort != null && !MainSerialPort.IsOpen)
+        {
+            this.MainSerialPort.WriteBufferSize = this.m_sendBufferSize;
+        }
+    }
+
+    private void PrivateBreakOut(bool manual, string msg)
+    {
+        lock (this.SyncRoot)
+        {
+            if (this.m_online)
+            {
+                this.BreakOut(manual, msg);
+            }
+        }
+    }
+
+    private void ProcessReceived()
+    {
+        if (!this.m_online)
+        {
+            UserToken?.SafeDispose();
+            return;
+        }
+        if (m_serialPort.BytesToRead > 0)
+        {
+            var byteBlock = UserToken;
+            byte[] buffer = BytePool.Default.Rent(m_serialPort.BytesToRead);
+            int num = m_serialPort.Read(buffer, 0, m_serialPort.BytesToRead);
+            byteBlock.Write(buffer, 0, num);
+            byteBlock.SetLength(num);
+            this.HandleBuffer(byteBlock);
+            try
+            {
+                var newByteBlock = BytePool.Default.GetByteBlock((int)Math.Min(this.ReceiveBufferSize * this.m_bufferRate, this.MaxBufferSize));
+                newByteBlock.SetLength(0);
+                UserToken = newByteBlock;
+
+                if (m_serialPort.BytesToRead > 0)
+                {
+                    this.m_bufferRate += 2;
+                    this.ProcessReceived();
+                }
+            }
+            catch (Exception ex)
+            {
+                this.PrivateBreakOut(false, ex.ToString());
+            }
+        }
+    }
+}

framework/foundation/ThingsGateway.Foundation/Foundation/SerialPort/SerialPort/SerialProperty.cs

@@ -0,0 +1,53 @@
+#region copyright
+//------------------------------------------------------------------------------
+//  此代码版权声明为全文件覆盖，如有原作者特别声明，会在下方手动补充
+//  此代码版权（除特别声明外的代码）归作者本人Diego所有
+//  源代码使用协议遵循本仓库的开源协议及附加协议
+//  Gitee源代码仓库：https://gitee.com/diego2098/ThingsGateway
+//  Github源代码仓库：https://github.com/kimdiego2098/ThingsGateway
+//  使用文档：https://diego2098.gitee.io/thingsgateway-docs/
+//  QQ群：605534569
+//------------------------------------------------------------------------------
+#endregion
+
+using System.ComponentModel;
+using System.IO.Ports;
+
+namespace ThingsGateway.Foundation.Serial;
+
+/// <summary>
+/// 串口属性
+/// </summary>
+public class SerialProperty
+{
+    /// <summary>
+    /// COM
+    /// </summary>
+    [Description("COM口")]
+    public string PortName { get; set; } = "COM1";
+    /// <summary>
+    /// 波特率
+    /// </summary>
+    [Description("波特率")]
+    public int BaudRate { get; set; } = 9600;
+    /// <summary>
+    /// 数据位
+    /// </summary>
+    [Description("数据位")]
+    public int DataBits { get; set; } = 8;
+    /// <summary>
+    /// 校验位
+    /// </summary>
+    [Description("校验位")]
+    public Parity Parity { get; set; } = Parity.None;
+    /// <summary>
+    /// 停止位
+    /// </summary>
+    [Description("停止位")]
+    public StopBits StopBits { get; set; } = StopBits.One;
+    /// <inheritdoc/>
+    public override string ToString()
+    {
+        return $"{PortName}[{BaudRate},{DataBits},{StopBits},{Parity}]";
+    }
+}