using AsbCloudApp.Data; using AsbCloudApp.Services; using Microsoft.AspNetCore.Authorization; using Microsoft.AspNetCore.Mvc; using System.Collections.Generic; using System.Linq; using System.Threading; using System.Threading.Tasks; namespace AsbCloudWebApi.Controllers { [Route("api/well")] [ApiController] [Authorize] public class WellController : ControllerBase { private readonly IWellService wellService; public WellController(IWellService wellService) { this.wellService = wellService; } /// <summary> /// Возвращает список доступных скважин /// </summary> /// <param name="token"> Токен отмены задачи </param> /// <returns>Список скважин</returns> [HttpGet] [ProducesResponseType(typeof(IEnumerable<WellDto>), (int)System.Net.HttpStatusCode.OK)] public async Task<IActionResult> GetWellsAsync(CancellationToken token = default) { var idCompany = User.GetCompanyId(); if (idCompany is null) { return NoContent(); } var wells = await wellService.GetWellsByCompanyAsync((int)idCompany, token).ConfigureAwait(false); if (wells is null || !wells.Any()) return NoContent(); return Ok(wells); } /// <summary> /// Возвращает информацию о требуемой скважине /// </summary> /// <param name="idWell"> Id требуемой скважины </param> /// <param name="token"> Токен отмены задачи </param> /// <returns>Информация о требуемой скважине </returns> [HttpGet("getWell")] [ProducesResponseType(typeof(WellDto), (int)System.Net.HttpStatusCode.OK)] public async Task<IActionResult> GetAsync(int idWell, CancellationToken token = default) { var idCompany = User.GetCompanyId(); if (idCompany is null || !await wellService.IsCompanyInvolvedInWellAsync(idCompany??default, idWell, token).ConfigureAwait(false)) return NoContent(); var well = await wellService.GetAsync(idWell, token).ConfigureAwait(false); return Ok(well); } /// <summary> /// Возвращает список скважин, передающих телеметрию в данный момент /// </summary> /// <param name="token"> Токен отмены задачи </param> /// <returns>Список скважин</returns> [HttpGet("transmittingWells")] [ProducesResponseType(typeof(IEnumerable<WellDto>), (int)System.Net.HttpStatusCode.OK)] public async Task<IActionResult> GetTransmittingWellsAsync(CancellationToken token = default) { var idCompany = User.GetCompanyId(); if (idCompany is null) return NoContent(); var transmittingWells = await wellService.GetTransmittingWellsAsync((int)idCompany, token).ConfigureAwait(false); if (transmittingWells is null || !transmittingWells.Any()) return NoContent(); return Ok(transmittingWells); } /// <summary> /// Редактирует указанные поля скважины /// </summary> /// <param name="idWell"> Id скважины </param> /// <param name="dto"> Объект параметров скважины. /// IdWellType: 1 - Наклонно-направленная, 2 - Горизонтальная. /// State: 0 - Неизвестно, 1 - В работе, 2 - Завершена.</param> /// <param name="token"> Токен отмены задачи </param> /// <returns></returns> [HttpPut] [ProducesResponseType(typeof(int), (int)System.Net.HttpStatusCode.OK)] public async Task<IActionResult> UpdateWellAsync(int idWell, WellParamsDto dto, CancellationToken token = default) { var idCompany = User.GetCompanyId(); if (idCompany is null || !await wellService.IsCompanyInvolvedInWellAsync((int)idCompany, idWell, token).ConfigureAwait(false)) return Forbid(); var result = await wellService.UpdateWellAsync(idWell, dto, token) .ConfigureAwait(false); return Ok(result); } } }