用户登录、登出通知Wms定时服务的启动预关闭

WarehouseMgr/Tnb.WarehouseMgr/ConditionalBackgroundService.cs

@@ -0,0 +1,30 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using Microsoft.Extensions.Hosting;
+
+namespace Tnb.WarehouseMgr
+{
+    public class ConditionalBackgroundService : IHostedService
+    {
+        private readonly IHostedService _backgroundService;
+        //private readonly Func<bool> _condition;
+
+        public ConditionalBackgroundService(IHostedService backgroundService)
+        {
+            _backgroundService = backgroundService;
+        }
+
+        public async Task StartAsync(CancellationToken cancellationToken)
+        {
+            await _backgroundService.StartAsync(cancellationToken);
+        }
+        public async Task StopAsync(CancellationToken cancellationToken)
+        {
+            await _backgroundService.StopAsync(cancellationToken);
+        }
+
+    }
+}

WarehouseMgr/Tnb.WarehouseMgr/WareHouseService.cs

@@ -283,7 +283,6 @@ namespace Tnb.WarehouseMgr
                                         start = end;
                                         end = Math.Min((end + moveNum), arrary.Length);
                                     }
-
                                     foreach (var arr in arrList)
                                     {
                                         for (int j = 1, len = arr.Length; j <= len; j++)

apihost/Tnb.API.Entry/Startup.cs

@@ -64,7 +64,7 @@ public class Startup : AppStartup
         services.AddOverideVisualDev();
 
         //定时任务
-        services.AddHostedService<TimedTaskBackgroundService>();
+        services.AddHostedService(sp => new ConditionalBackgroundService(sp.GetRequiredService<TimedTaskBackgroundService>()));
 
     }
 

system/Tnb.OAuth/OAuthService.cs

@@ -41,6 +41,7 @@ using JNPF.Common.Core.Handlers;
 using JNPF.Message.Interfaces.Message;
 using JNPF.Extras.DatabaseAccessor.SqlSugar.Models;
 using Aop.Api.Domain;
+using Tnb.WarehouseMgr;
 
 namespace JNPF.OAuth;
 
@@ -382,6 +383,10 @@ public class OAuthService : IDynamicApiController, ITransient
     [HttpGet("Logout")]
     public async Task Logout([FromQuery] string ticket)
     {
+        //用户退出时停止Wms定时任务 modify by ly on 20230804
+        var conditionalBackgroundService = App.GetRequiredService<ConditionalBackgroundService>();
+        await conditionalBackgroundService.StopAsync(CancellationToken.None);
+
         var tenantId = _userManager.TenantId ?? "default";
         var userId = _userManager.UserId ?? "admim";
         var httpContext = _httpContextAccessor.HttpContext;
@@ -672,6 +677,10 @@ public class OAuthService : IDynamicApiController, ITransient
             }
         }
 
+        //启动Wms定时服务 modify by ly on 20230804
+        var conditionalBackgroundService = App.GetRequiredService<ConditionalBackgroundService>();
+        await conditionalBackgroundService.StartAsync(CancellationToken.None);
+
         return new
         {
             theme = user.Theme == null ? "classic" : user.Theme,

system/Tnb.OAuth/Tnb.OAuth.csproj

@@ -12,6 +12,7 @@
   <ItemGroup>
     <ProjectReference Include="..\..\common\Tnb.Common.Core\Tnb.Common.Core.csproj" />
     <ProjectReference Include="..\..\message\Tnb.Message.Interfaces\Tnb.Message.Interfaces.csproj" />
+    <ProjectReference Include="..\..\WarehouseMgr\Tnb.WarehouseMgr\Tnb.WarehouseMgr.csproj" />
     <ProjectReference Include="..\Tnb.Systems.Interfaces\Tnb.Systems.Interfaces.csproj" />
   </ItemGroup>