mikhail/parr_api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(job-auto-control): Переделал согласно новой структуры. Отправляет задания в matcher.

Browse Source
This commit is contained in:
Mikhail Trubnikov
2025-12-09 08:40:05 +10:00
parent 5e3da5bf08
commit 24759bb3e0
6 changed files with 59 additions and 180 deletions
Download Patch File Download Diff File Expand all files Collapse all files

195
PARR.JobAutoControl/JobAutoControlManager.cs
View File

@@ -3,9 +3,7 @@ using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Logging;
using PARR.BLL.Domain.Mq;
using PARR.BLL.Services.Interfaces;
using PARR.Common.Domain;
using PARR.Constants;
using PARR.DAL.Services.Interfaces;
using PARR.DAL.Services.Interfaces.Job;
using PARR.JobAutoControl.Settings;
using System.Text.Json;
@@ -36,166 +34,59 @@ namespace PARR.JobAutoControl
public async Task StartAsync()
{
//logger.LogInformation("Запуск сервиса управления авто-контролем РР (JobAutoControl)");
logger.LogInformation("Запуск сервиса управления авто-контролем РР (JobAutoControl)");
//await intervalService.IntervalInitAsync(async () =>
//{
// using (var scope = serviceProvider.CreateScope())
// {
// var jobAutoControlService = scope.ServiceProvider.GetService<IJobAutoControlService>();
// var mqService = scope.ServiceProvider.GetService<IMqService>();
await intervalService.IntervalInitAsync(async () =>
{
await using (var scope = serviceProvider.CreateAsyncScope())
//using (var scope = serviceProvider.CreateScope())
{
var jobAutoControlService = scope.ServiceProvider.GetService<IJobAutoControlService>();
var mqService = scope.ServiceProvider.GetService<IMqService>();
// if (jobAutoControlService == null || mqService == null)
// throw new Exception($"Не смог получить серивс {nameof(IJobAutoControlService)} или {nameof(IMqService)}");
if (jobAutoControlService == null || mqService == null)
throw new Exception($"Не смог получить серивс {nameof(IJobAutoControlService)} или {nameof(IMqService)}");
// await HandlerAsync(jobAutoControlService, mqService);
// }
//}, workerSettings.RepeatEvery);
await HandlerAsync(jobAutoControlService, mqService);
}
}, workerSettings.RepeatEvery);
}
//private async Task HandlerAsync(IJobAutoControlService jobAutoControlService, IMqService mqService)
//{
// await GenerateAsync(jobAutoControlService, mqService);
// await DeactivateAsync(jobAutoControlService, mqService);
// await ActivateAsync(jobAutoControlService, mqService);
//}
private async Task HandlerAsync(IJobAutoControlService jobAutoControlService, IMqService mqService)
{
var jobsWithAutoControl = await jobAutoControlService.Get().Where(t => t.IsEnable).ToListAsync();
logger.LogInformation($"Работ с включенным авто-контролем: {jobsWithAutoControl.Count} шт.");
if (jobsWithAutoControl.Count == 0)
return;
///// <summary>
///// Генерировать новые РР
///// </summary>
///// <param name="jobAutoControlService"></param>
///// <param name="mqService"></param>
///// <returns></returns>
//private async Task GenerateAsync(IJobAutoControlService jobAutoControlService, IMqService mqService)
//{
// var jobsToGenerate = await jobAutoControlService.Get()
// .Include(t => t.JobEkMasks)
// .Include(t => t.JobAutoControlInEkStatuses)
// .Include(t => t.ApplicationsInWork)
// .Where(t => t.CreateNew && t.JobEkMasks.Any() && t.JobAutoControlInEkStatuses.Any())
// .ToListAsync();
// формируем сообщения
var msgList = jobsWithAutoControl.Select(t => new TemplateMatcherMq
{
Action = Constants.TemplateMatcherActionEnum.Sync,
EntityType = Constants.SyncTaskEntityTypeEnum.Job,
Id = t.JobId,
Initiator = new Common.Domain.HistoryInitiator
{
InitiatorComment = $"Инициатор авто-контроль, периодичность: {workerSettings.RepeatEvery}",
InitiatorIp = null,
InitiatorParrComponentId = Constants.ParrComponentsEnum.JobAutoControl
}
});
// logger.LogInformation($"Найдено РР с включенным авто-контролем для генерации шаблонов и расписаний: {jobsToGenerate.Count()} шт.");
var msgStrList = msgList.Select(t => JsonSerializer.Serialize(t));
// if (!jobsToGenerate.Any())
// return;
// отправляем задания в очередь template matcher`a
var sendResult = await mqService.SendAsync(mqSettings.TemplateMatcher, msgStrList.ToArray());
// jobsToGenerate.ForEach(job =>
// {
// job.JobEkMasks.ToList().ForEach(ek =>
// {
// //todo: проверить, нормально ли отрабатывает async в Foreach
// job.JobAutoControlInEkStatuses.ToList().ForEach(async ekStatus =>
// {
// var request = new GeneratorTemplateMq
// {
// Action = "create",
// ApplicationId = job.ApplicationsInWork!.ApplicationId,
// Ek = ek.Name,
// WorkId = job.ApplicationsInWork!.WorkId,
// StatusEk = ekStatus.EkStatusCode,
// IsActiveTemplate = job.OnTemplateIsActive,
// IsActiveSchedule = job.OnScheduleIsActive,
// HistoryInitiator = new HistoryInitiator { InitiatorComment = "Запрос на генерацию с авто-контроля", InitiatorParrComponentId = ParrComponentsEnum.JobAutoControl }
// };
// var msg = JsonSerializer.Serialize(request);
// var result = await mqService.SendAsync(mqSettings.Generator, new[] { msg });
// if (result.IsSuccess)
// logger.LogInformation($"Отправлен запрос на генерацию: {msg}");
// else
// logger.LogError($"Ошибка при отправке запроса на генерацию: {msg}");
// });
// });
// });
//}
///// <summary>
///// Деактивировать РР
///// </summary>
///// <param name="jobAutoControlService"></param>
///// <param name="mqService"></param>
///// <returns></returns>
//private async Task DeactivateAsync(IJobAutoControlService jobAutoControlService, IMqService mqService)
//{
// //var jobsToDeactivate = await jobAutoControlService.Get()
// // .Include(t => t.JobEkMasks)
// // .Include(t => t.JobAutoControlInEkStatuses)
// // .Where(t => t.Deactivate && t.JobEkMasks.Any() && t.JobAutoControlInEkStatuses.Any())
// // .Select(t => t.ApplicationInWorkId)
// // .ToListAsync();
// //logger.LogInformation($"Найдено РР с включенным авто-контролем для деактивации шаблонов и расписаний: {jobsToDeactivate.Count()} шт.");
// //if (!jobsToDeactivate.Any())
// // return;
// ////todo: проверить, нормально ли отрабатывает async в foreach
// //jobsToDeactivate.ForEach(async applicationInWorkId =>
// //{
// // var request = new TemplateActivatorMq
// // {
// // Action = TemplateActivatorActionsEnum.DeactivateAllForAutoControl,
// // JobId = applicationInWorkId,
// // HistoryInitiator = new HistoryInitiator { InitiatorComment = "Запрос на деактивацию с авто-контроля", InitiatorParrComponentId = ParrComponentsEnum.JobAutoControl }
// // };
// // var msg = JsonSerializer.Serialize(request);
// // var result = await mqService.SendAsync(mqSettings.Activator, new[] { msg });
// // if (result.IsSuccess)
// // logger.LogInformation($"Отправлен запрос на деактивацию: {msg}");
// // else
// // logger.LogError($"Ошибка при отправке запроса на деактивацию: {msg}");
// //});
//}
///// <summary>
///// Активировать РР
///// </summary>
///// <param name="jobAutoControlService"></param>
///// <param name="mqService"></param>
///// <returns></returns>
//private async Task ActivateAsync(IJobAutoControlService jobAutoControlService, IMqService mqService)
//{
// // var jobsToActivate = await jobAutoControlService.Get()
// // .Include(t => t.JobEkMasks)
// // .Include(t => t.JobAutoControlInEkStatuses)
// // .Where(t => t.Activate && t.JobEkMasks.Any() && t.JobAutoControlInEkStatuses.Any())
// // .Select(t => t.ApplicationInWorkId)
// // .ToListAsync();
// // if (!jobsToActivate.Any())
// // return;
// // //todo: проверить, нормально ли отрабатывает async в foreach
// // jobsToActivate.ForEach(async applicationInWorkId =>
// // {
// // var request = new TemplateActivatorMq
// // {
// // Action = TemplateActivatorActionsEnum.ActivateAllForAutoControl,
// // JobId = applicationInWorkId,
// // HistoryInitiator = new HistoryInitiator { InitiatorComment = "Запрос на активацию с авто-контроля", InitiatorParrComponentId = ParrComponentsEnum.JobAutoControl }
// // };
// // var msg = JsonSerializer.Serialize(request);
// // var result = await mqService.SendAsync(mqSettings.Activator, new[] { msg });
// // if (result.IsSuccess)
// // logger.LogInformation($"Отправлен запрос на активацию: {msg}");
// // else
// // logger.LogError($"Ошибка при отправке запроса на активацию: {msg}");
// // });
//}
if (!sendResult.IsSuccess)
logger.LogError($"Ошибка при отправке сообщений ({msgStrList.Count()} шт.) в очередь.");
else
logger.LogInformation($"Выполнена отправка сообщений в очередь, {msgStrList.Count()} шт.");
}
}
}