feat(dal,api): удалены таблицы которые относились к старому JobAutoControl. Добавлена новая таблица JobAutoControl
This commit is contained in:
Mikhail Trubnikov
@@ -36,166 +36,166 @@ 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>();
|
||||
|
||||
if (jobAutoControlService == null || mqService == null)
|
||||
throw new Exception($"Не смог получить серивс {nameof(IJobAutoControlService)} или {nameof(IMqService)}");
|
||||
|
||||
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);
|
||||
}
|
||||
|
||||
|
||||
/// <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();
|
||||
|
||||
logger.LogInformation($"Найдено РР с включенным авто-контролем для генерации шаблонов и расписаний: {jobsToGenerate.Count()} шт.");
|
||||
|
||||
if (!jobsToGenerate.Any())
|
||||
return;
|
||||
|
||||
|
||||
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 =>
|
||||
//await intervalService.IntervalInitAsync(async () =>
|
||||
//{
|
||||
// var request = new TemplateActivatorMq
|
||||
// using (var scope = serviceProvider.CreateScope())
|
||||
// {
|
||||
// Action = TemplateActivatorActionsEnum.DeactivateAllForAutoControl,
|
||||
// JobId = applicationInWorkId,
|
||||
// HistoryInitiator = new HistoryInitiator { InitiatorComment = "Запрос на деактивацию с авто-контроля", InitiatorParrComponentId = ParrComponentsEnum.JobAutoControl }
|
||||
// };
|
||||
// var jobAutoControlService = scope.ServiceProvider.GetService<IJobAutoControlService>();
|
||||
// var mqService = scope.ServiceProvider.GetService<IMqService>();
|
||||
|
||||
// var msg = JsonSerializer.Serialize(request);
|
||||
// if (jobAutoControlService == null || mqService == null)
|
||||
// throw new Exception($"Не смог получить серивс {nameof(IJobAutoControlService)} или {nameof(IMqService)}");
|
||||
|
||||
// var result = await mqService.SendAsync(mqSettings.Activator, new[] { msg });
|
||||
|
||||
// if (result.IsSuccess)
|
||||
// logger.LogInformation($"Отправлен запрос на деактивацию: {msg}");
|
||||
// else
|
||||
// logger.LogError($"Ошибка при отправке запроса на деактивацию: {msg}");
|
||||
//});
|
||||
// await HandlerAsync(jobAutoControlService, mqService);
|
||||
// }
|
||||
//}, workerSettings.RepeatEvery);
|
||||
}
|
||||
|
||||
|
||||
/// <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();
|
||||
//private async Task HandlerAsync(IJobAutoControlService jobAutoControlService, IMqService mqService)
|
||||
//{
|
||||
// await GenerateAsync(jobAutoControlService, mqService);
|
||||
// await DeactivateAsync(jobAutoControlService, mqService);
|
||||
// await ActivateAsync(jobAutoControlService, mqService);
|
||||
//}
|
||||
|
||||
// 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 }
|
||||
// };
|
||||
///// <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 msg = JsonSerializer.Serialize(request);
|
||||
// logger.LogInformation($"Найдено РР с включенным авто-контролем для генерации шаблонов и расписаний: {jobsToGenerate.Count()} шт.");
|
||||
|
||||
// var result = await mqService.SendAsync(mqSettings.Activator, new[] { msg });
|
||||
// if (!jobsToGenerate.Any())
|
||||
// return;
|
||||
|
||||
// if (result.IsSuccess)
|
||||
// logger.LogInformation($"Отправлен запрос на активацию: {msg}");
|
||||
// else
|
||||
// logger.LogError($"Ошибка при отправке запроса на активацию: {msg}");
|
||||
// });
|
||||
}
|
||||
|
||||
// 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}");
|
||||
// // });
|
||||
//}
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user