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

feat(templateActivator,templateDistributor): добавлено журналирование

Browse Source
This commit is contained in:
Mikhail Kuznetsov
2024-08-09 16:36:37 +10:00
parent 5b9a325b59
commit a333589c77
4 changed files with 24 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
PARR.TemplateActivator/TemplateActivator.cs
View File

@@ -75,9 +75,9 @@ internal class TemplateActivator : ITemplateActivator
break; break;
case TemplateActivatorActionsEnum.DeactivateSchedulesWithTemplateSyncErrors: case TemplateActivatorActionsEnum.DeactivateSchedulesWithTemplateSyncErrors:
logger.LogInformation($"Получен запрос на деактивацию всех расписаний, у которых шаблоны синхронизированы с ошибкой"); logger.LogInformation($"Получен запрос на деактивацию всех расписаний, у которых шаблоны синхронизированы с ошибкой");
query = query.Where(t => !t.IsActiveTemplate && query = query.Where(t => !t.IsActiveTemplate &&
t.RobotConfigurations.Any(t => t.RobotConfigurations.Any(t =>
t.RobotCode == (int) RobotsEnum.TemplateOrder && t.RobotCode == (int)RobotsEnum.TemplateOrder &&
t.RobotStatusCode == (int)RobotStatusEnum.Error) t.RobotStatusCode == (int)RobotStatusEnum.Error)
); );
changes = await UpdateScheduleStateAsync(query, false); changes = await UpdateScheduleStateAsync(query, false);
@@ -86,8 +86,9 @@ internal class TemplateActivator : ITemplateActivator
break; break;
} }
if (changes > 0 && !await templateService.CommitAsync()) if (changes > 0)
logger.LogError($"{this.GetType} не удалось записать измения в БД о новых состояниях шаблонов и расписаний регламентной работы Id {applicationInWorkId}"); if (!await templateService.CommitAsync()) logger.LogError($"{this.GetType} не удалось записать измения в БД о новых состояниях шаблонов и расписаний регламентной работы Id {applicationInWorkId}");
else logger.LogDebug($"{GetType} изменил состояние шаблонов/расписаний({changes}) регламентной работы Id {applicationInWorkId}");
} }

5
PARR.TemplateDistributor/TemplateDistributor.cs
View File

@@ -114,7 +114,10 @@ namespace PARR.TemplateDistributor
var templateToDistrib = new List<Template>(); var templateToDistrib = new List<Template>();
if (existingTemplates.Count > 0) if (existingTemplates.Count > 0)
{
templateToDistrib = GetTemplatesToDistribute(ref distrPlan, existingTemplates); templateToDistrib = GetTemplatesToDistribute(ref distrPlan, existingTemplates);
logger.LogInformation($"{GetType().Name}(AppInWId:{applicationInWorkId}, WorkGroup:{existingTemplates.Select(t =>t.Host!.WorkGroup!.Name).First()}) запланировал изменение даты следующего срабатывания у {templateToDistrib.Count()} существующих шаблона(ов), {existingTemplates.Count() - templateToDistrib.Count()} остались без изменений");
}
templateToDistrib.AddRange(templates); templateToDistrib.AddRange(templates);
@@ -286,7 +289,7 @@ namespace PARR.TemplateDistributor
//Определим шаблоны за границами рабочих дней. Их тоже необходимо перераспределить //Определим шаблоны за границами рабочих дней. Их тоже необходимо перераспределить
var workDays = distributionPlan.Keys.ToList(); var workDays = distributionPlan.Keys.ToList();
var templateWithNextRunOut = templates.Where(t => workDays.All(w => w != DateOnly.FromDateTime(t.NextRun.DateTime))).ToList(); var templateWithNextRunOut = templates.Where(t => workDays.All(w => w != DateOnly.FromDateTime(t.NextRun.DateTime))).ToList();
if (templateWithNextRunOut.Any()) if (templateWithNextRunOut.Any())
result.AddRange(templateWithNextRunOut); result.AddRange(templateWithNextRunOut);

12
PARR.TemplateDistributor/TemplateDistributorInstaller.cs
View File

@@ -22,5 +22,17 @@ namespace PARR.TemplateDistributor
services.AddTransient<IMqTemplateDistributor, MqTemplateDistributor>(); services.AddTransient<IMqTemplateDistributor, MqTemplateDistributor>();
services.AddTransient<IValidatorService,ValidatorService>(); services.AddTransient<IValidatorService,ValidatorService>();
} }
public static IConfigurationBuilder AddTemplateDistributorConfigurations(this IConfigurationBuilder builder, IServiceCollection services)
{
builder.AddDalConfigurations(services);
return builder;
}
public static void AddTemplateDistributorSettings(this IServiceCollection services, IConfiguration configuration)
{
services.AddDallSettings(configuration);
}
} }
} }

2
PARR.TemplateDistributorWorker/Program.cs
View File

@@ -22,6 +22,8 @@ builder.Services.AddLogging(config =>
}); });
builder.Services.InstallTemplateDistributorSerivces(builder.Configuration); builder.Services.InstallTemplateDistributorSerivces(builder.Configuration);
builder.Configuration.AddTemplateDistributorConfigurations(builder.Services);
builder.Services.AddTemplateDistributorSettings(builder.Configuration);
builder.Services.AddHostedService<Worker>(); builder.Services.AddHostedService<Worker>();