From 504a17b301212b92db64bed27ff5a514b930de05 Mon Sep 17 00:00:00 2001 From: Mikhail Kuznetsov Date: Wed, 18 Jun 2025 15:22:28 +1000 Subject: [PATCH] =?UTF-8?q?feat(aihitRelationshipsSyncer):=20=D0=B8=D0=B7?= =?UTF-8?q?=D0=BC=D0=B5=D0=BD=D0=B5=D0=BD=D0=B0=20=D1=87=D0=B0=D1=81=D1=82?= =?UTF-8?q?=D0=BE=D1=82=D0=B0=20=D0=BA=D0=BE=D0=BC=D0=BC=D0=B8=D1=82=D0=BE?= =?UTF-8?q?=D0=B2=20=D0=BF=D1=80=D0=B8=20=D0=BE=D0=B1=D0=BD=D0=BE=D0=B2?= =?UTF-8?q?=D0=BB=D0=B5=D0=BD=D0=B8=D0=B8=20=D0=BF=D0=BE=D0=BB=D1=8F=20syn?= =?UTF-8?q?ced?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../appsettings.json | 2 +- PARR.Test/Worker.cs | 34 +++++++++++++++++-- 2 files changed, 33 insertions(+), 3 deletions(-) diff --git a/PARR.AIHITRelationshipsSyncerWorker/appsettings.json b/PARR.AIHITRelationshipsSyncerWorker/appsettings.json index 07e76ce6..9d239867 100644 --- a/PARR.AIHITRelationshipsSyncerWorker/appsettings.json +++ b/PARR.AIHITRelationshipsSyncerWorker/appsettings.json @@ -29,6 +29,6 @@ }, "WorkerSettings": { "RepeatEvery": "12:00:00", - "CommitAfter": 5000 + "CommitAfter": 500 } } diff --git a/PARR.Test/Worker.cs b/PARR.Test/Worker.cs index a1f18c04..3444e80d 100644 --- a/PARR.Test/Worker.cs +++ b/PARR.Test/Worker.cs @@ -4,6 +4,7 @@ using PARR.BLL.Services.Interfaces; using PARR.Constants; using PARR.DAL.DomainServices; using PARR.DAL.Services.Interfaces; +using PARR.DAL.Services.Interfaces.Job; using PARR.DAL.Services.Interfaces.Unit; using PARR.EsppApi; using PARR.EsppApi.Constants; @@ -40,9 +41,38 @@ namespace PARR.Test #region test using (var scope = serviceProvider.CreateScope()) { - var service = scope.ServiceProvider.GetService(); + /*var service = scope.ServiceProvider.GetService(); - var ttt = await service.GetTemplateNameAsync(Guid.Parse("ba05948b-b040-48cc-ab77-0accc9c223a0"), Guid.Parse("d4a86f24-6975-4614-98ab-431f26e3eb69")); + var ttt = await service.GetTemplateNameAsync(Guid.Parse("ba05948b-b040-48cc-ab77-0accc9c223a0"), Guid.Parse("d4a86f24-6975-4614-98ab-431f26e3eb69"));*/ + //var service = scope.ServiceProvider.GetService(); + //var templates = await service.Get() + // .Include(t => t.ApplicationsInWork) + // .ThenInclude(t=>t.Work) + // //.Select(s => new { s.Id, s.Host, s.HostId, s.JobId, s.UnitId }) + // .Where(t => t.JobId == Guid.Parse("ba05948b-b040-48cc-ab77-0accc9c223a0") + // ).ToListAsync(); + + //var workNames = templates.Select(t=>t.ApplicationsInWork!.Work!.TemplateSuffix).Distinct(); + + //var jobService = scope.ServiceProvider.GetService(); + //var jobs = await jobService!.Get().Where(t => workNames.Any(tt => tt == t.Name)).ToListAsync(); + ////var hostsName = templates.Select(t => t.Host!.Ek); + ////var unitService = scope.ServiceProvider.GetService(); + ////var units = await unitService.Get() + //// //.Select(s => new { s.Id, s.Name }) + //// .Where(t => hostsName.Any(tt => tt == t.Name)) + //// .ToListAsync(); + + //foreach (var t in templates) { + + // var workName = t.ApplicationsInWork!.Work!.TemplateSuffix; + // //var unitId = units.FirstOrDefault(u => u.Name == hostName); + // var jobId = jobs.FirstOrDefault(t => t.Name == workName); + // if (jobId != null) + // t.JobId = jobId.Id; + //} + + //await service.CommitAsync(); } //var tName = "ДВС-ЭИТИ-ПТК-ПАРР__ВРТ-VCD-02-ДВС__ПРОЧЕЕ(РАБОТЫ)";