forked from ddrilling/AsbCloudServer
101 lines
3.6 KiB
C#
101 lines
3.6 KiB
C#
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="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, WellUpdateParamsDto 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);
|
||
|
||
}
|
||
}
|
||
}
|