parr_api/PARR.API/Controllers/V1/AgentHistoryController.cs

using AutoMapper;
using FluentValidation;
using Microsoft.AspNetCore.Mvc;
using Microsoft.EntityFrameworkCore;
using PARR.API.Contracts.V1;
using PARR.API.Contracts.V1.Requests;
using PARR.API.Contracts.V1.Requests.Queries;
using PARR.API.Contracts.V1.Responses;
using PARR.API.Contracts.V1.Responses.Base;
using PARR.API.Controllers.V1.Base;
using PARR.API.Extensions;
using PARR.API.Services.Interfaces;
using PARR.DAL.DomainModels;
using PARR.DAL.Models;
using PARR.DAL.Services.Interfaces;

namespace PARR.API.Controllers.V1
{
    /// <summary>
    /// История работы агента
    /// </summary>
    public class AgentHistoryController : BaseApiController
    {
        private readonly IValidator<AgentHistoryRequest> validator;
        private readonly IAgentHistoryService agentHistoryService;
        private readonly IUriService uriService;
        private readonly IMapper mapper;

        public AgentHistoryController(
            IValidator<AgentHistoryRequest> validator,
            IAgentHistoryService agentHistoryService,
            IUriService uriService,
            IMapper mapper
            )
        {
            this.validator = validator;
            this.agentHistoryService = agentHistoryService;
            this.uriService = uriService;
            this.mapper = mapper;
        }


        /// <summary>
        /// Получить историю работы агента постранично
        /// </summary>
        /// <returns></returns>
        [HttpGet(ApiRoutes.AgentHistory.GetAll)]
        public async Task<IActionResult> GetAll([FromQuery] PaginationQuery paginationQuery, [FromQuery] AgentHistoryQuery request)
        {
            var paginationFilter = mapper.Map<PaginationFilter>(paginationQuery);

            IQueryable<AgentHistory> query = agentHistoryService.Get()
                                                .Include(t => t.AgentHistoryLevel);

            if (request.TemplateId.HasValue)
                query = query.Where(t => t.TemplateId == request.TemplateId);

            var history = await agentHistoryService.GetPage(query.OrderByDescending(t => t.DateCreated), paginationFilter).ToListAsync();

            if (!history.Any())
                return NoContent();

            var response = mapper.Map<List<AgentHistoryResponse>>(history);
            var paginationResponse = new PagedResponse<AgentHistoryResponse>(response, true).GetPaginatedProps(paginationFilter, query);

            return Ok(paginationResponse);
        }


        /// <summary>
        /// Получить запись истории работы агента по id
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        [HttpGet(ApiRoutes.AgentHistory.Get)]
        public async Task<IActionResult> GetById([FromRoute] Guid id)
        {
            var history = await agentHistoryService.Get().Include(t => t.AgentHistoryLevel).FirstAsync(t => t.Id == id);

            if (history == null)
                return NotFound();

            var response = mapper.Map<AgentHistoryResponse>(history);

            return Ok(new Response<AgentHistoryResponse>(response, true));
        }


        /// <summary>
        /// Добавить запись в историю работы агента
        /// </summary>
        /// <returns></returns>
        [HttpPost(ApiRoutes.AgentHistory.Create)]
        public async Task<IActionResult> Create([FromBody] AgentHistoryRequest request)
        {
            var resultValidate = await validator.ValidateAsync(request);
            if (!resultValidate.IsValid)
                return BadRequest(new Response(resultValidate.Errors));

            //todo: проверять что этот этот шаблон привязан к этому серверу по ip???

            var agentJournal = new AgentHistory
            {
                Id = Guid.NewGuid(),
                Message = request.Message,
                HistoryLevelId = (int)request.Level,
                TemplateId = request.TemplateId
            };

            if (!await agentHistoryService.CreateAsync(agentJournal) || !await agentHistoryService.CommitAsync())
                return BadRequest(new Response(false, new List<ErrorModel> { new ErrorModel { Message = "Ошибка при добавлении записи в историю работы агента." } }));

            var createdObject = await agentHistoryService.Get().Include(t => t.AgentHistoryLevel).FirstAsync(t => t.Id == agentJournal.Id);
            var response = mapper.Map<AgentHistoryResponse>(createdObject);

            var createdUri = uriService.GetUri(ApiRoutes.AgentHistory.Get, ApiRoutes.AgentHistory.getParam, agentJournal.Id);

            return Created(createdUri, new Response<AgentHistoryResponse>(response, true));
        }
    }
}