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);
}
}