using AsbCloudApp.Data; using AsbCloudApp.Services; using Microsoft.AspNetCore.Authorization; using Microsoft.AspNetCore.Mvc; using System.Collections.Generic; using System.ComponentModel.DataAnnotations; using System.Threading; using System.Threading.Tasks; using AsbCloudApp.Services.WellReport; using Microsoft.AspNetCore.Http; namespace AsbCloudWebApi.Controllers; /// /// Инфо о скважине /// [Route("api/well")] [ApiController] [Authorize] public class WellController : ControllerBase { private readonly IWellService wellService; private readonly IWellReportExportService wellReportExportService; public WellController(IWellService wellService, IWellReportExportService wellReportExportService) { this.wellService = wellService; this.wellReportExportService = wellReportExportService; } /// /// Возвращает список доступных скважин /// /// Токен отмены задачи /// Список скважин [HttpGet] [Permission] [ProducesResponseType(typeof(IEnumerable), (int)System.Net.HttpStatusCode.OK)] public async Task GetWellsAsync(CancellationToken token) { var idCompany = User.GetCompanyId(); if (idCompany is null) return NoContent(); var wells = await wellService.GetAsync(new() { IdCompany = idCompany }, token).ConfigureAwait(false); return Ok(wells); } /// /// Возвращает список доступных скважин /// /// Токен отмены задачи /// Список скважин [HttpGet("wellTree")] [ProducesResponseType(typeof(IEnumerable), (int)System.Net.HttpStatusCode.OK)] public async Task GetWellTreeAsync(CancellationToken token) { var idCompany = User.GetCompanyId(); if (idCompany is null) return NoContent(); var wells = await wellService.GetWellTreeAsync((int)idCompany, token).ConfigureAwait(false); return Ok(wells); } /// /// Возвращает информацию о требуемой скважине /// /// Id требуемой скважины /// Токен отмены задачи /// Информация о требуемой скважине [HttpGet("{idWell}")] [Permission] [ProducesResponseType(typeof(WellMapInfoWithTelemetryStat), (int)System.Net.HttpStatusCode.OK)] [ProducesResponseType((int)System.Net.HttpStatusCode.NoContent)] public async Task GetAsync(int idWell, CancellationToken token) { var idCompany = User.GetCompanyId(); if (idCompany is null || !await wellService.IsCompanyInvolvedInWellAsync(idCompany ?? default, idWell, token).ConfigureAwait(false)) return Forbid(); var well = await wellService.GetOrDefaultStatAsync(idWell, token); return Ok(well); } /// /// Редактирует указанные поля скважины /// /// Объект параметров скважины. /// IdWellType: 1 - Наклонно-направленная, 2 - Горизонтальная. /// State: 0 - Неизвестно, 1 - В работе, 2 - Завершена. /// Токен отмены задачи /// [HttpPut] [Permission] [ProducesResponseType(typeof(int), (int)System.Net.HttpStatusCode.OK)] public async Task UpdateWellAsync(WellDto dto, CancellationToken token) { var idCompany = User.GetCompanyId(); if (idCompany is null || !await wellService.IsCompanyInvolvedInWellAsync((int)idCompany, dto.Id, token).ConfigureAwait(false)) return Forbid(); var result = await wellService.UpdateAsync(dto, token) .ConfigureAwait(false); return Ok(result); } /// /// Обновляет статус скважины /// /// ключ скважины /// статус: 0 - Неизвестно, 1 - В работе, 2 - Завершена. /// /// [HttpPut("{idWell}/state")] [Permission] [ProducesResponseType(typeof(int), (int)System.Net.HttpStatusCode.OK)] public async Task UpdateWellStateAsync(int idWell, [Range(0, 2, ErrorMessage = "Статус некорректен")] int idState, CancellationToken token) { var idCompany = User.GetCompanyId(); if (idCompany is null || !await wellService.IsCompanyInvolvedInWellAsync((int)idCompany, idWell, token).ConfigureAwait(false)) return Forbid(); var dto = await wellService.GetOrDefaultAsync(idWell, token); if (dto is null) return this.ValidationBadRequest(nameof(idWell), $"Скважина с id: {idWell} недоступна"); dto.IdState = idState; var result = await wellService.UpdateAsync(dto, token) .ConfigureAwait(false); return Ok(result); } //TODO: навзание пока такое. У нас в API уже есть метод с такой сигнатурой. /// /// Получить отчёт по скважине /// /// /// /// [HttpGet("{idWell}/report/export")] [ProducesResponseType(typeof(PhysicalFileResult), StatusCodes.Status200OK, "application/octet-stream")] [ProducesResponseType(StatusCodes.Status204NoContent)] public async Task ExportAsync(int idWell, CancellationToken token) { var report = await wellReportExportService.ExportAsync(idWell, token); if (report is null) return NoContent(); return File(report.Value.File, "application/octet-stream", report.Value.Name); } }