feat(api): DistributorController

PARR.API/Controllers/V1/DistributorController.cs

@@ -0,0 +1,65 @@
+using FluentValidation;
+using Microsoft.AspNetCore.Authorization;
+using Microsoft.AspNetCore.Mvc;
+using PARR.API.Contracts.V1;
+using PARR.API.Contracts.V1.Requests;
+using PARR.API.Contracts.V1.Responses.Base;
+using PARR.API.Controllers.V1.Base;
+using PARR.API.Settings;
+using PARR.BLL.Domain.Mq;
+using PARR.BLL.Services.Interfaces;
+using PARR.Constants;
+using System.Text.Json;
+
+namespace PARR.API.Controllers.V1
+{
+    /// <summary>
+    /// Распределитель РР
+    /// </summary>
+    [Authorize(Roles = ParrRoles.Administrator.Role)]
+    public class DistributorController : BaseApiController
+    {
+        private readonly IMqService mqService;
+        private readonly MqSettings mqSettings;
+        private readonly IValidator<DistributeRequest> validator;
+
+        public DistributorController(
+            IMqService mqService,
+            MqSettings mqSettings,
+            IValidator<DistributeRequest> validator
+            )
+        {
+            this.mqService = mqService;
+            this.mqSettings = mqSettings;
+            this.validator = validator;
+        }
+
+
+        /// <summary>
+        /// Перераспределить шаблоны для регламентной работы
+        /// </summary>
+        /// <returns></returns>
+        [HttpPost(ApiRoutes.Distributor.Distribute)]
+        public async Task<IActionResult> Distribute([FromBody] DistributeRequest request)
+        {
+            var resultValidate = await validator.ValidateAsync(request);
+            if (!resultValidate.IsValid)
+                return BadRequest(new Response(resultValidate.Errors));
+
+            var requestToMq = new TemplateDistributorMq
+            {
+                ApplicationInWorkId = request.ApplicationInWorkId
+            };
+
+            var msg = JsonSerializer.Serialize(requestToMq);
+
+            var sendResult = mqService.Send(mqSettings.TemplateDistributor, new[] { msg });
+
+            if (sendResult.IsSuccess)
+                return Created("", new Response<string?>(null, true, new List<ErrorModel>(), "Отправлен запрос на перераспределение регламентных работ."));
+            else
+                return BadRequest(new Response(false, new List<ErrorModel> { new ErrorModel { Message="Ошибка при отправке данных."} }));
+
+        }
+    }
+}