优化TimedTaskBackgroundService类代码

This commit is contained in:
alex
2023-08-07 13:49:36 +08:00
parent 3923c6a698
commit d99d38e0c1

View File

@@ -26,9 +26,7 @@ namespace Tnb.WarehouseMgr
{ {
private ISendMessageService? _sendService; private ISendMessageService? _sendService;
protected override Task ExecuteAsync(CancellationToken stoppingToken) protected override Task ExecuteAsync(CancellationToken stoppingToken) => Task.Run(() =>
{
return Task.Run(() =>
{ {
//_sendService = App.GetRequiredService<ISendMessageService>(); //_sendService = App.GetRequiredService<ISendMessageService>();
List<string> toUserIds = new List<string>() { "25398501929509" }; List<string> toUserIds = new List<string>() { "25398501929509" };
@@ -48,8 +46,8 @@ namespace Tnb.WarehouseMgr
//齐套分拣 //齐套分拣
var setSortingService = App.GetRequiredService<IWmsSetSortingService>(); var setSortingService = App.GetRequiredService<IWmsSetSortingService>();
TimedTask(cts => setSortingService.PackSortingByAdd(cts), setSortingCts, toUserIds); TimedTask(cts => setSortingService.PackSortingByAdd(cts), setSortingCts, toUserIds);
}); }, stoppingToken);
}
private Task TimedTask(Func<CancellationTokenSource, Task> action, CancellationTokenSource cts, List<string>? toUserIds = default) private Task TimedTask(Func<CancellationTokenSource, Task> action, CancellationTokenSource cts, List<string>? toUserIds = default)
{ {
var token = cts.Token; var token = cts.Token;