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服务 - } - } -}