forked from ddrilling/AsbCloudServer
123 lines
5.0 KiB
C#
123 lines
5.0 KiB
C#
using AsbCloudApp.Data.GTR;
|
|
using AsbCloudApp.Repositories;
|
|
using AsbCloudApp.Services;
|
|
using AsbCloudDb.Model;
|
|
using AsbCloudWebApi.SignalR;
|
|
using Microsoft.AspNetCore.Mvc;
|
|
using Microsoft.AspNetCore.SignalR;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Threading;
|
|
using System.Threading.Tasks;
|
|
|
|
namespace AsbCloudWebApi.Controllers.SAUB
|
|
{
|
|
|
|
[Route("api/[controller]")]
|
|
[ApiController]
|
|
public class GtrWitsController : ControllerBase
|
|
|
|
{
|
|
protected readonly IWellService wellService;
|
|
private readonly ITelemetryService telemetryService;
|
|
private readonly IGtrRepository gtrRepository;
|
|
private readonly IHubContext<TelemetryHub> telemetryHubContext;
|
|
|
|
public string SignalRMethodGetDataName { get; protected set; } = "ReceiveData";
|
|
|
|
public GtrWitsController(
|
|
ITelemetryService telemetryService,
|
|
IGtrRepository gtrRepository,
|
|
IWellService wellService,
|
|
IHubContext<TelemetryHub> telemetryHubContext)
|
|
{
|
|
this.telemetryService = telemetryService;
|
|
this.gtrRepository = gtrRepository;
|
|
this.wellService = wellService;
|
|
this.telemetryHubContext = telemetryHubContext;
|
|
}
|
|
|
|
/// <summary>
|
|
/// Получить загруженные данные ГТИ по скважине
|
|
/// </summary>
|
|
/// <param name = "idWell" > id скважины</param>
|
|
/// <param name = "begin" > дата начала выборки.По умолчанию: текущее время - intervalSec</param>
|
|
/// <param name = "intervalSec" > интервал времени даты начала выборки, секунды</param>
|
|
/// <param name = "approxPointsCount" > желаемое количество точек. Если в выборке точек будет больше, то выборка будет прорежена.</param>
|
|
/// <param name = "token" > Токен завершения задачи</param>
|
|
/// <returns></returns>
|
|
[HttpGet("{idWell}")]
|
|
[Permission]
|
|
public async Task<ActionResult<IEnumerable<WitsRecordDto>>> GetDataAsync(int idWell, DateTime? begin,
|
|
int intervalSec = 600, int approxPointsCount = 1024, CancellationToken token = default)
|
|
{
|
|
int? idCompany = User.GetCompanyId();
|
|
|
|
if (idCompany is null)
|
|
return Forbid();
|
|
|
|
bool isCompanyOwnsWell = await wellService.IsCompanyInvolvedInWellAsync((int)idCompany,
|
|
idWell, token).ConfigureAwait(false);
|
|
|
|
if (!isCompanyOwnsWell)
|
|
return Forbid();
|
|
|
|
var content = await gtrRepository.GetAsync(idWell, begin,
|
|
intervalSec, approxPointsCount, token).ConfigureAwait(false);
|
|
|
|
return Ok(content);
|
|
}
|
|
|
|
/// <summary>
|
|
/// получение последних данных ГТИ по ключу record
|
|
/// </summary>
|
|
/// <param name="idWell">id скважины</param>
|
|
/// <param name="idRecord">id record</param>
|
|
/// <param name="token"></param>
|
|
/// <returns></returns>
|
|
[HttpGet("{idWell}/{idRecord}")]
|
|
[Permission]
|
|
public async Task<ActionResult<IEnumerable<WitsItemRecordDto>>> GetLastDataByRecordIdAsync(int idWell, int idRecord, CancellationToken token = default)
|
|
{
|
|
int? idCompany = User.GetCompanyId();
|
|
|
|
if (idCompany is null)
|
|
return Forbid();
|
|
|
|
bool isCompanyOwnsWell = await wellService.IsCompanyInvolvedInWellAsync((int)idCompany,
|
|
idWell, token).ConfigureAwait(false);
|
|
|
|
if (!isCompanyOwnsWell)
|
|
return Forbid();
|
|
|
|
var content = await gtrRepository.GetLastDataByRecordIdAsync(idWell, idRecord, token).ConfigureAwait(false);
|
|
|
|
return Ok(content);
|
|
}
|
|
|
|
/// <summary>
|
|
/// Метод для получения WITS записи от панели оператора.
|
|
/// Сохраняет в БД.
|
|
/// </summary>
|
|
/// <param name="uid">уникальный идентификатор телеметрии</param>
|
|
/// <param name="dtos">WITS запись</param>
|
|
/// <param name="token"></param>
|
|
/// <returns></returns>
|
|
[HttpPost("{uid}")]
|
|
public async Task<IActionResult> PostDataAsync(
|
|
string uid,
|
|
[FromBody] IEnumerable<WitsRecordDto> dtos,
|
|
CancellationToken token = default)
|
|
{
|
|
var idTelemetry = telemetryService.GetOrCreateTelemetryIdByUid(uid);
|
|
await gtrRepository.SaveDataAsync(idTelemetry, dtos, token).ConfigureAwait(false);
|
|
var idWell = telemetryService.GetIdWellByTelemetryUid(uid);
|
|
if (idWell is not null && dtos is not null)
|
|
_ = Task.Run(() => telemetryHubContext.Clients.Group($"well_{idWell}_gtr")
|
|
.SendAsync(SignalRMethodGetDataName, dtos), CancellationToken.None);
|
|
return Ok();
|
|
}
|
|
}
|
|
|
|
}
|