on.nemtina/DD.WellWorkover.Cloud
1
0
Fork 0
forked from ddrilling/AsbCloudServer
Code Pull Requests Activity

WorkWellInfoUpdate inceace Timeout to 30 min

Browse Source
This commit is contained in:
ngfrolov 2023-10-10 13:45:30 +05:00
parent 1f79a8f5f7
commit d7aea0f583
Signed by: ng.frolov
GPG Key ID: E99907A0357B29A7
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
AsbCloudInfrastructure/Services/WellInfoService.cs
View File

@ -27,7 +27,7 @@ public class WellInfoService
public WorkWellInfoUpdate() public WorkWellInfoUpdate()
: base("Well statistics update") : base("Well statistics update")
{ {
Timeout = TimeSpan.FromMinutes(20); Timeout = TimeSpan.FromMinutes(30);
} }
protected override async Task Action(string id, IServiceProvider services, Action<string, double?> onProgressCallback, CancellationToken token) protected override async Task Action(string id, IServiceProvider services, Action<string, double?> onProgressCallback, CancellationToken token)
@ -40,8 +40,9 @@ public class WellInfoService
var messageHub = services.GetRequiredService<IIntegrationEventHandler<UpdateWellInfoEvent>>(); var messageHub = services.GetRequiredService<IIntegrationEventHandler<UpdateWellInfoEvent>>();
var wells = await wellService.GetAllAsync(token); var wells = await wellService.GetAllAsync(token);
var activeWells = wells.Where(well => well.IdState == 1);
var wellsIds = wells.Select(w => w.Id); var wellsIds = activeWells.Select(w => w.Id);
var processMapRequests = wellsIds.Select(id => new ProcessMapRequest { IdWell = id }); var processMapRequests = wellsIds.Select(id => new ProcessMapRequest { IdWell = id });
var processMaps = await processMapRepository.GetProcessMapAsync(processMapRequests, token); var processMaps = await processMapRepository.GetProcessMapAsync(processMapRequests, token);
@ -58,9 +59,9 @@ public class WellInfoService
var subsystemStat = await subsystemOperationTimeService var subsystemStat = await subsystemOperationTimeService
.GetStatByActiveWells(wellsIds, token); .GetStatByActiveWells(wellsIds, token);
var count = wells.Count(); var count = activeWells.Count();
var i = 0d; var i = 0d;
WellMapInfo = wells.Select(well => { WellMapInfo = activeWells.Select(well => {
var wellMapInfo = well.Adapt<WellMapInfoWithComanies>(); var wellMapInfo = well.Adapt<WellMapInfoWithComanies>();
wellMapInfo.IdState = well.IdState; wellMapInfo.IdState = well.IdState;
onProgressCallback($"Start updating info by well({well.Id}): {well.Caption}", i++ / count); onProgressCallback($"Start updating info by well({well.Id}): {well.Caption}", i++ / count);