From cf5a465546fc08bfb8fcc64160d210a84731a940 Mon Sep 17 00:00:00 2001
From: Mikhail Kuznetsov <ivc_kuznetsovmv@dvgd.rzd>
Date: Tue, 2 Jul 2024 15:04:23 +1000
Subject: [PATCH] =?UTF-8?q?feat(templateDistributor):=20=D0=B7=D0=B0=D0=B3?=
 =?UTF-8?q?=D0=BE=D1=82=D0=BE=D0=B2=D0=BA=D0=B0=20=D0=BE=D1=81=D0=BD=D0=BE?=
 =?UTF-8?q?=D0=B2=D0=BD=D1=8B=D1=85=20=D0=BC=D0=B5=D1=82=D0=BE=D0=B4=D0=BE?=
 =?UTF-8?q?=D0=B2?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 PARR.BLL/Domain/Mq/TemplateDistributorMq.cs    | 10 ++++++++++
 .../ITemplateDistributor.cs                    | 18 +++++++++++++++++-
 .../MqTemplateDistributor.cs                   |  5 ++++-
 .../TemplateDistributor.cs                     | 17 ++++++++++++-----
 4 files changed, 43 insertions(+), 7 deletions(-)
 create mode 100644 PARR.BLL/Domain/Mq/TemplateDistributorMq.cs

diff --git a/PARR.BLL/Domain/Mq/TemplateDistributorMq.cs b/PARR.BLL/Domain/Mq/TemplateDistributorMq.cs
new file mode 100644
index 00000000..38bcfd5e
--- /dev/null
+++ b/PARR.BLL/Domain/Mq/TemplateDistributorMq.cs
@@ -0,0 +1,10 @@
+namespace PARR.BLL.Domain.Mq
+{
+    /// <summary>
+    /// Модель в MQ, обновления расписаний шаблонов связанных с РР (для TemplateDistributor)
+    /// </summary>
+    public class TemplateDistributorMq
+    {
+        public Guid ApplicationInWorkId { get; set; }
+    }
+}
diff --git a/PARR.TemplateDistributor/ITemplateDistributor.cs b/PARR.TemplateDistributor/ITemplateDistributor.cs
index 6d08dda0..ceacc2a3 100644
--- a/PARR.TemplateDistributor/ITemplateDistributor.cs
+++ b/PARR.TemplateDistributor/ITemplateDistributor.cs
@@ -1,6 +1,22 @@
-namespace PARR.TemplateDistributor
+using PARR.DAL.Models;
+
+namespace PARR.TemplateDistributor
 {
     public interface ITemplateDistributor
     {
+        /// <summary>
+        /// Формирует расписание запуска для шаблонов относительно одной РР (без сохранения в БД), (реализует оба режима распределения РР)
+        /// </summary>
+        /// <param name="templates"></param>
+        /// <param name="applicationInWorkId"></param>
+        /// <returns></returns>
+        Task<List<Template>> DistributeTemplateAsync(List<Template> templates, Guid applicationInWorkId);
+
+        /// <summary>
+        /// Обновляет расписание запуска шаблонов по РР (сохраняет в БД)
+        /// </summary>
+        /// <param name="applicationInWorkId"></param>
+        /// <returns></returns>
+        Task UpdateScheduleAsync(Guid applicationInWorkId);
     }
 }
diff --git a/PARR.TemplateDistributor/MqTemplateDistributor.cs b/PARR.TemplateDistributor/MqTemplateDistributor.cs
index 166596f2..2f5dcd35 100644
--- a/PARR.TemplateDistributor/MqTemplateDistributor.cs
+++ b/PARR.TemplateDistributor/MqTemplateDistributor.cs
@@ -2,7 +2,10 @@
 {
     internal class MqTemplateDistributor : IMqTemplateDistributor
     {
-        public void Start() { }
+        public void Start() {
+
+            // принимать TemplateDistributorMq
+        }
 
         public void Stop() { }
     }
diff --git a/PARR.TemplateDistributor/TemplateDistributor.cs b/PARR.TemplateDistributor/TemplateDistributor.cs
index ddc763cb..1042d371 100644
--- a/PARR.TemplateDistributor/TemplateDistributor.cs
+++ b/PARR.TemplateDistributor/TemplateDistributor.cs
@@ -14,16 +14,23 @@ namespace PARR.TemplateDistributor
         }
 
 
-        //TODO: AppInWorkId - перераспределение, очередь
-        //public async Task 
-        // распределить? 
-        // не распределить, NextRun = appInWork.ReferenceDate
+        public async Task UpdateScheduleAsync(Guid applicationInWorkId)
+        {
+            // все шаблоны по applicationInWorkId
+            // группирует по РР
+            // -> DistributeTemplateForPeriodAsync
+            // сохранить в БД
+        }
 
 
-        public async Task<List<Template>> DistributeTemplateForPeriodAsync(List<Template> templates, Guid applicationInWorkId)
+
+        public async Task<List<Template>> DistributeTemplateAsync(List<Template> templates, Guid applicationInWorkId)
         {
             //TODO: ЗАГУЛШКА переделать!
 
+            // распределить? 
+            // не распределить, NextRun = appInWork.ReferenceDate
+
             var appInWork = await applicationsInWorkService.Get().FirstOrDefaultAsync(t => t.Id == applicationInWorkId);
             if (appInWork == null)
             {