using AsbCloudApp.Data; using AsbCloudApp.Data.User; using AsbCloudApp.Services; using AsbCloudDb.Model; using Microsoft.AspNetCore.Authorization; using Microsoft.AspNetCore.Mvc; using System.Collections.Generic; using System.Threading; using System.Threading.Tasks; namespace AsbCloudWebApi.Controllers { /// <summary> /// контроллер с контактной информацией по скважине /// </summary> [Route("api/well/{idWell}/[controller]")] [ApiController] [Authorize] public class WellContactController : ControllerBase { private readonly IWellContactService wellContactsRepository; private readonly IWellService wellService; public WellContactController(IWellContactService wellContactsRepository, IWellService wellService) { this.wellContactsRepository = wellContactsRepository; this.wellService = wellService; } /// <summary> /// получение списка типов контактов /// </summary> /// <param name="token"></param> /// <returns></returns> [HttpGet("type")] [ProducesResponseType(typeof(IEnumerable<CompanyTypeDto>), (int)System.Net.HttpStatusCode.OK)] public async Task<IActionResult> GetTypesAsync(CancellationToken token) { var result = await wellContactsRepository.GetTypesAsync(token); return Ok(result); } /// <summary> /// Получение контактов по типу контакта и ключу скважины /// </summary> /// <param name="idWell">ключ скважины</param> /// <param name="contactTypeId">тип контакта</param> /// <param name="token"></param> /// <returns></returns> [HttpGet("type/{contactTypeId}")] [ProducesResponseType(typeof(IEnumerable<ContactDto>), (int)System.Net.HttpStatusCode.OK)] public async Task<IActionResult> GetAllAsync(int idWell, int contactTypeId, CancellationToken token) { if (!await CanUserAccessToWellAsync(idWell, token).ConfigureAwait(false)) return Forbid(); var result = await wellContactsRepository.GetAllAsync(idWell, contactTypeId, token); return Ok(result); } /// <summary> /// Получение контакта по ключу /// </summary> /// <param name="idWell">ключ скважины</param> /// <param name="id">ключ контакта</param> /// <param name="token"></param> /// <returns></returns> [HttpGet("{id}")] [ProducesResponseType(typeof(ContactDto), (int)System.Net.HttpStatusCode.OK)] public async Task<IActionResult> GetAsync(int idWell, int id, CancellationToken token) { if (!await CanUserAccessToWellAsync(idWell, token).ConfigureAwait(false)) return Forbid(); var result = await wellContactsRepository.GetAsync(idWell, id, token); return Ok(result); } /// <summary> /// добавление нового контакта /// </summary> /// <param name="contactDto">контакт</param> /// <param name="token"></param> /// <returns></returns> [HttpPost] [Permission] [ProducesResponseType(typeof(int), (int)System.Net.HttpStatusCode.OK)] public async Task<IActionResult> InsertAsync( [FromBody] ContactDto contactDto, CancellationToken token) { if (!await CanUserAccessToWellAsync(contactDto.IdWell, token).ConfigureAwait(false)) return Forbid(); var result = await wellContactsRepository.InsertAsync(contactDto, token); return Ok(result); } /// <summary> /// изменение контакта /// </summary> /// <param name="contactDto">контакт</param> /// <param name="token"></param> /// <returns></returns> [HttpPut] [Permission] [ProducesResponseType(typeof(int), (int)System.Net.HttpStatusCode.OK)] public async Task<IActionResult> UpdateAsync( [FromBody] ContactDto contactDto, CancellationToken token) { if (!await CanUserAccessToWellAsync(contactDto.IdWell, token).ConfigureAwait(false)) return Forbid(); var result = await wellContactsRepository.UpdateAsync(contactDto, token); return Ok(result); } /// <summary> /// Удаление контакта /// </summary> /// <param name="idWell">ключ скважины</param> /// <param name="id">id контакта</param> /// <param name="token">Токен отмены задачи</param> /// <returns>Количество удаленных из БД строк</returns> [HttpDelete("{id}")] [Permission] [ProducesResponseType(typeof(int), (int)System.Net.HttpStatusCode.OK)] public async Task<IActionResult> DeleteAsync(int idWell, int id, CancellationToken token) { if (!await CanUserAccessToWellAsync(idWell, token).ConfigureAwait(false)) return Forbid(); var result = await wellContactsRepository.DeleteAsync(idWell, id, token); return Ok(result); } private async Task<bool> CanUserAccessToWellAsync(int idWell, CancellationToken token) { int? idCompany = User.GetCompanyId(); return idCompany is not null && await wellService.IsCompanyInvolvedInWellAsync((int)idCompany, idWell, token); } } }