forked from ddrilling/AsbCloudServer
104 lines
3.9 KiB
C#
104 lines
3.9 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="caption"> Название скважины </param>
|
|
/// <param name="latitude"> Широта координат скважины </param>
|
|
/// <param name="longitude"> Долгота координат скважины </param>
|
|
/// <param name="idWellType"> Id типа скважины </param>
|
|
/// <param name="state"> Id текущего состояния скважины </param>
|
|
/// <param name="token"> Токен отмены задачи </param>
|
|
/// <returns></returns>
|
|
[HttpPut]
|
|
[ProducesResponseType(typeof(int), (int)System.Net.HttpStatusCode.OK)]
|
|
public async Task<IActionResult> UpdateWellAsync(int idWell, string caption = default,
|
|
double latitude = default, double longitude = default, int idWellType = default,
|
|
int state = default, 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, caption, latitude, longitude,
|
|
idWellType, state, token).ConfigureAwait(false);
|
|
|
|
return Ok(result);
|
|
|
|
}
|
|
}
|
|
}
|