From 25436c881c630f15620954a47771c38e5bc2352c Mon Sep 17 00:00:00 2001 From: liguoyang Date: Fri, 29 Dec 2023 16:54:30 +0800 Subject: [PATCH] =?UTF-8?q?fix=20=E4=BB=A3=E7=A0=81=E5=91=BD=E5=90=8D?= =?UTF-8?q?=E4=BF=AE=E6=94=B9,=E6=A0=BC=E5=BC=8F=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../Dlhis.ScheduledTask.csproj | 1 - Src/Dlhis.ScheduledTask/HangfirePack.cs | 37 +++++++++++++++++++ .../MyBackgroundJobService.cs | 12 ------ Src/Dlhis.ScheduledTask/Program.cs | 1 - Src/Dlhis.ScheduledTask/SqlSugarPack1.cs | 34 ----------------- 5 files changed, 37 insertions(+), 48 deletions(-) create mode 100644 Src/Dlhis.ScheduledTask/HangfirePack.cs delete mode 100644 Src/Dlhis.ScheduledTask/MyBackgroundJobService.cs delete mode 100644 Src/Dlhis.ScheduledTask/SqlSugarPack1.cs diff --git a/Src/Dlhis.ScheduledTask/Dlhis.ScheduledTask.csproj b/Src/Dlhis.ScheduledTask/Dlhis.ScheduledTask.csproj index 9f0fa6c7..f4eb9a6e 100644 --- a/Src/Dlhis.ScheduledTask/Dlhis.ScheduledTask.csproj +++ b/Src/Dlhis.ScheduledTask/Dlhis.ScheduledTask.csproj @@ -19,7 +19,6 @@ - diff --git a/Src/Dlhis.ScheduledTask/HangfirePack.cs b/Src/Dlhis.ScheduledTask/HangfirePack.cs new file mode 100644 index 00000000..e74dda28 --- /dev/null +++ b/Src/Dlhis.ScheduledTask/HangfirePack.cs @@ -0,0 +1,37 @@ +using Hangfire; +using Hangfire.MySql; +using Kurisu.AspNetCore.Startup; + +namespace Dlhis.ScheduledTask +{ + public class HangfirePack : BaseAppPack + { + public override bool IsBeforeUseRouting { get; } + + public override void ConfigureServices(IServiceCollection services) + { + services.AddHangfire(configuration => + { + var options = new MySqlStorageOptions + { + TablesPrefix = "Hangfire" + }; + + configuration.UseSimpleAssemblyNameTypeSerializer() + .UseRecommendedSerializerSettings() + .UseStorage(new MySqlStorage(Configuration.GetConnectionString("HangfireConnection"), options)); + + }); + + services.AddHangfireServer(); + } + + public override void Configure(IApplicationBuilder app, IWebHostEnvironment env) + { + app.UseHangfireDashboard(); //使用hangfire面板 + //app.UseHangfireServer(); //启动hangfire服务 + + BackgroundJob.Enqueue(() => Console.WriteLine("This is a background job.")); + } + } +} diff --git a/Src/Dlhis.ScheduledTask/MyBackgroundJobService.cs b/Src/Dlhis.ScheduledTask/MyBackgroundJobService.cs deleted file mode 100644 index 1d45c79e..00000000 --- a/Src/Dlhis.ScheduledTask/MyBackgroundJobService.cs +++ /dev/null @@ -1,12 +0,0 @@ -using Hangfire; - -namespace Dlhis.ScheduledTask -{ - public class MyBackgroundJobService - { - public void EnqueueMyJob() - { - BackgroundJob.Enqueue(() => Console.WriteLine("This is a background job.")); - } - } -} diff --git a/Src/Dlhis.ScheduledTask/Program.cs b/Src/Dlhis.ScheduledTask/Program.cs index ace73d18..66b0e63e 100644 --- a/Src/Dlhis.ScheduledTask/Program.cs +++ b/Src/Dlhis.ScheduledTask/Program.cs @@ -16,5 +16,4 @@ public class Startup : DefaultStartup { } - } \ No newline at end of file diff --git a/Src/Dlhis.ScheduledTask/SqlSugarPack1.cs b/Src/Dlhis.ScheduledTask/SqlSugarPack1.cs deleted file mode 100644 index a1f45d7c..00000000 --- a/Src/Dlhis.ScheduledTask/SqlSugarPack1.cs +++ /dev/null @@ -1,34 +0,0 @@ -using Hangfire; -using Hangfire.MySql; -using Kurisu.AspNetCore.Startup; - -namespace Dlhis.ScheduledTask -{ - public class SqlSugarPack1 : BaseAppPack - { - public override bool IsBeforeUseRouting { get; } - - public override void ConfigureServices(IServiceCollection services) - { - services.AddHangfire(configuration => configuration - .SetDataCompatibilityLevel(CompatibilityLevel.Version_170) - .UseSimpleAssemblyNameTypeSerializer() - .UseRecommendedSerializerSettings() - .UseStorage( - new MySqlStorage( - Configuration.GetConnectionString("HangfireConnection"), - new MySqlStorageOptions - { - TablesPrefix = "Hangfire" // Adjust other options as needed - } - ) - )); - services.AddHangfireServer(); - } - public override void Configure(IApplicationBuilder app, IWebHostEnvironment env) - { - app.UseHangfireDashboard(); //使用hangfire面板 - app.UseHangfireServer(); //启动hangfire服务 - } - } -}