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

Fix DetectedOperationExportService.ExportAsync exception type/text

Browse Source
This commit is contained in:
ngfrolov 2023-12-26 14:03:31 +05:00
parent fa3de75b85
commit 4c3f638bfb
Signed by: ng.frolov
GPG Key ID: E99907A0357B29A7
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
AsbCloudInfrastructure/Services/DetectOperations/DetectedOperationExportService.cs
View File

@ -12,6 +12,7 @@ using AsbCloudApp.Data.DetectedOperation;
using AsbCloudInfrastructure.Services.DetectOperations.Detectors; using AsbCloudInfrastructure.Services.DetectOperations.Detectors;
using AsbCloudApp.Repositories; using AsbCloudApp.Repositories;
using Microsoft.AspNetCore.Http.Extensions; using Microsoft.AspNetCore.Http.Extensions;
using AsbCloudApp.Exceptions;
namespace AsbCloudInfrastructure.Services.DetectOperations; namespace AsbCloudInfrastructure.Services.DetectOperations;
@ -57,21 +58,21 @@ public class DetectedOperationExportService
/// <param name="host">хост</param> /// <param name="host">хост</param>
/// <param name="cancellationToken"></param> /// <param name="cancellationToken"></param>
/// <returns></returns> /// <returns></returns>
/// <exception cref="ArgumentNullException"></exception> /// <exception cref="ArgumentInvalidException"></exception>
public async Task<Stream> ExportAsync(int idWell, string host, CancellationToken cancellationToken) public async Task<Stream> ExportAsync(int idWell, string host, CancellationToken cancellationToken)
{ {
var well = await dbContext.Wells var well = await dbContext.Set<Well>()
.Include(w => w.Cluster) .Include(w => w.Cluster)
.ThenInclude(c => c.Deposit) .ThenInclude(c => c.Deposit)
.SingleOrDefaultAsync(w => w.Id == idWell, cancellationToken); .FirstOrDefaultAsync(w => w.Id == idWell, cancellationToken);
if (well is null) if (well is null)
throw new ArgumentNullException(nameof(well)); throw new ArgumentInvalidException(nameof(idWell), $"Well {idWell} does not exist");
if (!well.IdTelemetry.HasValue) if (!well.IdTelemetry.HasValue)
throw new ArgumentNullException(nameof(well)); throw new ArgumentInvalidException(nameof(idWell), $"Well {idWell} has no telemetry");
var operations = await DetectOperationsAsync(well.IdTelemetry.Value, DateTime.UnixEpoch, cancellationToken); var operations = await DetectOperationsAsync(well.IdTelemetry.Value, DateTime.UnixEpoch, cancellationToken);
return await GenerateExcelFileStreamAsync(well, host, operations, cancellationToken); return await GenerateExcelFileStreamAsync(well, host, operations, cancellationToken);
} }