using System;
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Mvc;
using AsbCloudApp.Data;
using AsbCloudApp.Services;
namespace AsbCloudWebApi.Controllers
{
///
/// Контроллер для корридоров бурения на панели
///
[Route("api/well/{idWell}/drillFlowChart/")]
[ApiController]
public class DrillFlowChartController : ControllerBase
{
private readonly IDrillFlowChartService drillFlowChartService;
private readonly ITelemetryService telemetryService;
private readonly IWellService wellService;
public DrillFlowChartController(IDrillFlowChartService drillFlowChartService,
ITelemetryService telemetryService, IWellService wellService)
{
this.drillFlowChartService = drillFlowChartService;
this.telemetryService = telemetryService;
this.wellService = wellService;
}
///
/// Возвращает все значения для корридоров бурения по id скважины
///
/// id скважины
/// Дата, с которой следует искать новые параметры
/// Токен отмены задачи
/// Список параметров для корридоров бурения
[HttpGet]
[ProducesResponseType(typeof(IEnumerable), (int) System.Net.HttpStatusCode.OK)]
public async Task GetAllAsync(int idWell, DateTime updateFrom,
CancellationToken token = default)
{
var idCompany = User.GetCompanyId();
if (idCompany is null || !await wellService.IsCompanyInvolvedInWellAsync((int)idCompany,
idWell, token).ConfigureAwait(false))
return Forbid();
var dto = await drillFlowChartService.GetAllAsync(idWell,
updateFrom, token);
return Ok(dto);
}
///
/// Возвращает все значения для корридоров бурения по uid панели
///
/// uid панели
/// Дата, с которой следует искать новые параметры
/// Токен отмены задачи
/// Список параметров для корридоров бурения
[HttpGet("{uid}")]
[ProducesResponseType(typeof(IEnumerable), (int) System.Net.HttpStatusCode.OK)]
public async Task GetAllAsync(string uid, DateTime updateFrom, CancellationToken token = default)
{
var idCompany = User.GetCompanyId();
var idWell = telemetryService.GetidWellByTelemetryUid(uid);
if (idCompany is null || idWell is null || !await wellService.IsCompanyInvolvedInWellAsync((int)idCompany,
(int)idWell, token).ConfigureAwait(false))
return Forbid();
var dto = await drillFlowChartService.GetAllAsync((int)idWell,
updateFrom, token);
return Ok(dto);
}
///
/// Сохраняет значения для корридоров бурения
///
/// id скважины
/// Параметры корридоров бурения
/// Токен отмены задачи
///
[HttpPost]
[ProducesResponseType(typeof(int), (int) System.Net.HttpStatusCode.OK)]
public async Task InsertAsync(int idWell,
DrillFlowChartDto drillFlowChartDto, 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 drillFlowChartService.InsertAsync(idWell, drillFlowChartDto, token);
return Ok(result);
}
///
/// Добавляет массив объектов корридоров бурения
///
/// id скважины
/// Массив объектов параметров корридоров бурения
/// Токен отмены задачи
///
[HttpPost("range")]
[ProducesResponseType(typeof(int), (int) System.Net.HttpStatusCode.OK)]
public async Task InsertRangeAsync(int idWell,
IEnumerable drillFlowChartParams, 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 drillFlowChartService.InsertRangeAsync(idWell, drillFlowChartParams,
token);
return Ok(result);
}
///
/// Изменяет значения выбранного корридора бурения
///
/// id скважины
/// Параметры корридоров бурения
/// Токен отмены задачи
///
[HttpPut]
[ProducesResponseType(typeof(int), (int) System.Net.HttpStatusCode.OK)]
public async Task EditAsync(int idWell,
DrillFlowChartDto drillFlowChart, 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 drillFlowChartService.UpdateAsync(idWell,
drillFlowChart, token);
return Ok(result);
}
///
/// Удаляет значения выбранного корридора бурения
///
/// id скважины
/// Id объекта корридоров бурения
/// Токен отмены задачи
///
[HttpDelete]
[ProducesResponseType(typeof(int), (int) System.Net.HttpStatusCode.OK)]
public async Task DeleteAsync(int idWell,
int drillFlowChartParamsId, 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 drillFlowChartService.DeleteAsync(drillFlowChartParamsId,
token);
return Ok(result);
}
}
}