wenkai.chen/tnb.server
Template
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'dev' of https://git.tuotong-tech.com/tnb/tnb.server into dev

Browse Source
This commit is contained in:
FanLian
2023-08-15 17:04:05 +08:00
parent 67c93bff19 0db51c4db2
commit a92a9d0082
1 changed files with 46 additions and 33 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
WarehouseMgr/Tnb.WarehouseMgr/TimedTaskBackgroundService.cs
View File

@@ -57,7 +57,9 @@ namespace Tnb.WarehouseMgr
_serviceProvider = serviceProvider; _serviceProvider = serviceProvider;
} }
protected override Task ExecuteAsync(CancellationToken stoppingToken) => Task.Run(async () => protected override Task ExecuteAsync(CancellationToken stoppingToken)
{
var queueTask = Task.Run(async () =>
{ {
var channelReader = _serviceProvider.GetRequiredService<ITaskMessageNotify>().Reader; var channelReader = _serviceProvider.GetRequiredService<ITaskMessageNotify>().Reader;
@@ -75,15 +77,17 @@ namespace Tnb.WarehouseMgr
} }
} }
#region 定时 }, stoppingToken);
//_eventPublisher = App.GetRequiredService<IEventPublisher>();
//List<string> toUserIds = new List<string>() { "25398501929509" }; var timedTask = Task.Run(() =>
{
_eventPublisher = App.GetRequiredService<IEventPublisher>();
////生成任务执行 ////生成任务执行
//CancellationTokenSource genTaskCTS = new(); //CancellationTokenSource genTaskCTS = new();
//CancellationTokenSource kittingOutAddCts = new(); CancellationTokenSource kittingOutAddCts = new();
//CancellationTokenSource kittingOutShippedCts = new(); CancellationTokenSource kittingOutShippedCts = new();
//CancellationTokenSource setSortingCts = new(); CancellationTokenSource setSortingCts = new();
CancellationTokenSource isMinStorageCts = new();
//var wareHouseService = App.GetRequiredService<IWareHouseService>(); //var wareHouseService = App.GetRequiredService<IWareHouseService>();
//TimedTask(cts => wareHouseService.GenTaskExecute(cts), genTaskCTS); //TimedTask(cts => wareHouseService.GenTaskExecute(cts), genTaskCTS);
//齐套出库 //齐套出库
@@ -93,8 +97,16 @@ namespace Tnb.WarehouseMgr
//齐套分拣 //齐套分拣
var setSortingService = App.GetRequiredService<IWmsSetSortingService>(); var setSortingService = App.GetRequiredService<IWmsSetSortingService>();
TimedTask(cts => setSortingService.PackSortingByAdd(cts), setSortingCts, 1); TimedTask(cts => setSortingService.PackSortingByAdd(cts), setSortingCts, 1);
#endregion
}, stoppingToken); var transferSignService = App.GetRequiredService<IWmsPDATransferSignService>();
TimedTask(cts => transferSignService.IsMinStorage(cts), isMinStorageCts, 30, TimeSpanUnit.Minutes);
});
return Task.WhenAll(queueTask, timedTask);
}
private Task TimedTask(Func<CancellationTokenSource, Task> action, CancellationTokenSource cts, int interval, TimeSpanUnit timeType = TimeSpanUnit.Seconds) private Task TimedTask(Func<CancellationTokenSource, Task> action, CancellationTokenSource cts, int interval, TimeSpanUnit timeType = TimeSpanUnit.Seconds)
{ {
@@ -136,6 +148,7 @@ namespace Tnb.WarehouseMgr
TimeSpanUnit.Minutes => Task.Delay(TimeSpan.FromMinutes(interval)), TimeSpanUnit.Minutes => Task.Delay(TimeSpan.FromMinutes(interval)),
TimeSpanUnit.Hours => Task.Delay(TimeSpan.FromHours(interval)), TimeSpanUnit.Hours => Task.Delay(TimeSpan.FromHours(interval)),
TimeSpanUnit.Days => Task.Delay(TimeSpan.FromDays(interval)), TimeSpanUnit.Days => Task.Delay(TimeSpan.FromDays(interval)),
_ => throw new NotImplementedException()
}; };
return delayTask; return delayTask;
} }