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

Merge branch 'job-group-filters' into dev

Browse Source
This commit is contained in:
Mikhail Trubnikov
2026-07-01 10:24:05 +10:00
parent 52bd0d8ce1 cb3c98ed8c
commit 55ac424f1a
29 changed files with 4756 additions and 445 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
.gitlab/issue_templates/Bug.md Normal file
View File

@@ -0,0 +1,21 @@
### 📋 Описание бага
Кратко и понятно опишите, что идет не так.
### 🔄 Шаги для воспроизведения
1. Перейти на страницу...
2. Нажать кнопку...
3. Ввести в поле поиска...
### ❌ Фактический результат
Что произошло на самом деле? (Например: Приложение завершилось с ошибкой 500).
### ✅ Ожидаемый результат
Что должно было произойти? (Например: Появился список найденных товаров).
### 🖥️ Окружение
* **ОС:** Windows 11 / macOS Sequoia
* **Браузер / Версия:** Chrome 124 / iOS App v2.1
* **Стенд:** Staging / Production
### 📎 Вложения
Скриншоты, гифки или логи, которые помогают понять проблему.

54
PARR.API/Contracts/V1/Requests/JobAutoControlRequest.cs
View File

@@ -1,52 +1,14 @@
using PARR.Domain.Enums; namespace PARR.API.Contracts.V1.Requests
namespace PARR.API.Contracts.V1.Requests
{ {
public class JobAutoControlRequest /// <summary>
/// Часть реквеста по управлению авто контролем для Job, JobGroup
/// </summary>
public record JobAutoControlRequest
{ {
/// <summary> public bool IsEnable { get; init; }
/// Создавать новые РР (из настроке РР)
/// </summary>
public bool CreateNew { get; set; }
/// <summary> public bool InitUsedTemplateState { get; init; }
/// Деактивировать не актуальные согласно ЭК (обратные статусы ЭК)
/// </summary>
public bool Deactivate { get; set; }
/// <summary> public bool InitUsedScheduleState { get; init; }
/// Активировать РР после смены ЭК (согласно настройкам статусов ЭК)
/// </summary>
public bool Activate { get; set; }
/// <summary>
/// Состояние для активированных РР, шаблоны
/// </summary>
public bool OnTemplateIsActive { get; set; }
/// <summary>
/// Состояние для активированных РР, расписания
/// </summary>
public bool OnScheduleIsActive { get; set; }
/// <summary>
/// Состояние для деактивированных РР, шаблоны
/// </summary>
public bool OffTemplateIsActive { get; set; }
/// <summary>
/// Состояние для деактивированных РР, расписания
/// </summary>
public bool OffScheduleIsActive { get; set; }
/// <summary>
/// Маски ЭК
/// </summary>
public required List<string> EkMasks { get; set; }
/// <summary>
/// Статусы ЭК для которых включена генерация РР и активация
/// </summary>
public required List<EkStatusEnum> EnabledEkStatuses { get; set; }
} }
} }

55
PARR.API/Contracts/V1/Requests/JobGroupRequest.cs
View File

@@ -1,47 +1,47 @@
namespace PARR.API.Contracts.V1.Requests namespace PARR.API.Contracts.V1.Requests
{ {
public class JobGroupRequest public record JobGroupRequest
{ {
public required string Name { get; set; } public required string Name { get; init; }
//public bool? IsUmbrella { get; set; } //public bool? IsUmbrella { get; set; }
public Guid GroupTypeId { get; set; } public Guid GroupTypeId { get; init; }
/// <summary> /// <summary>
/// Поле по которому групиируем, если тип - ГРУППА /// Поле по которому групиируем, если тип - ГРУППА
/// </summary> /// </summary>
public Guid? GroupingUnitFieldId { get; set; } public Guid? GroupingUnitFieldId { get; init; }
public bool? IsGroupByResponsible { get; set; } public bool? IsGroupByResponsible { get; init; }
public required string ShortDescription { get; set; } public required string ShortDescription { get; init; }
public required string FullDescription { get; set; } public required string FullDescription { get; init; }
public required string Solution { get; set; } public required string Solution { get; init; }
public required string TemplateDuration { get; set; } public required string TemplateDuration { get; init; }
public DateTimeOffset ReferenceDate { get; set; } public DateTimeOffset ReferenceDate { get; init; }
public int? UserTimeZoneOffsetMinutes { get; set; } public int? UserTimeZoneOffsetMinutes { get; init; }
/// <summary> /// <summary>
/// Использовать таймзону рабочей группы ответственного за ЭК шаблона /// Использовать таймзону рабочей группы ответственного за ЭК шаблона
/// </summary> /// </summary>
public bool IsWorkGroupTimezone { get; set; } public bool IsWorkGroupTimezone { get; init; }
public Guid ScheduleExcludeTypeId { get; set; } public Guid ScheduleExcludeTypeId { get; init; }
public Guid? ScheduleExcludeTypeCalendarId { get; set; } public Guid? ScheduleExcludeTypeCalendarId { get; init; }
public bool IsAutoDistributionEnabled { get; set; } public bool IsAutoDistributionEnabled { get; init; }
/// <summary> /// <summary>
/// Настройки автораспределения /// Настройки автораспределения
/// </summary> /// </summary>
public DistributionConfigRequest? DistributionConfig { get; set; } public DistributionConfigRequest? DistributionConfig { get; init; }
//public bool IsAgent { get; set; } //public bool IsAgent { get; set; }
@@ -51,28 +51,35 @@
//public string? AgentScript { get; set; } //public string? AgentScript { get; set; }
public List<EsppSchValueRequest> Schedule { get; set; } = new List<EsppSchValueRequest>(); public List<EsppSchValueRequest> Schedule { get; init; } = new List<EsppSchValueRequest>();
/// <summary>
/// Настройки автоконтроля (возможны только в случае, если JobGroupType.IsJobGroupAutocontrol==true)
/// </summary>
public JobAutoControlRequest? AutoControl { get; init; }
} }
public class EsppSchValueRequest public record EsppSchValueRequest
{ {
public Guid TypeValueId { get; set; } public Guid TypeValueId { get; init; }
public Guid TypeConfigId { get; set; } public Guid TypeConfigId { get; init; }
} }
public class DistributionConfigRequest public record DistributionConfigRequest
{ {
public Guid DistributionPeriodId { get; set; } public Guid DistributionPeriodId { get; init; }
/// <summary> /// <summary>
/// Исключать выходные и праздники /// Исключать выходные и праздники
/// </summary> /// </summary>
public bool IsExcludeWeekends { get; set; } public bool IsExcludeWeekends { get; init; }
/// <summary> /// <summary>
/// Группировать по рабочей группе /// Группировать по рабочей группе
/// </summary> /// </summary>
public bool IsGroupingByWorkGroup { get; set; } public bool IsGroupingByWorkGroup { get; init; }
} }
} }

74
PARR.API/Contracts/V1/Requests/JobRequest.cs
View File

@@ -1,79 +1,91 @@
namespace PARR.API.Contracts.V1.Requests namespace PARR.API.Contracts.V1.Requests
{ {
public class JobRequest public record JobRequest
{ {
public required Guid TnkId { get; set; } public required Guid TnkId { get; init; }
public required Guid GroupId { get; set; } public required Guid GroupId { get; init; }
public required string Name { get; set; } public required string Name { get; init; }
public int? MinValueRelationships { get; set; } //public int? MinValueRelationships { get; init; }
public int? MaxValueRelationships { get; set; } //public int? MaxValueRelationships { get; init; }
public bool? IsParentRelationships { get; set; } //public bool? IsParentRelationships { get; init; }
public required string TemplateNameMask { get; set; } public JobRelationships? Relationships { get; init; }
public required string WorkGroupMask { get; set; } public required string TemplateNameMask { get; init; }
public required string WorkName { get; set; } public required string WorkGroupMask { get; init; }
public required string ResponseAreaMask { get; set; } public required string WorkName { get; init; }
#region AutoControl public required string ResponseAreaMask { get; init; }
public bool IsEnableAutoControl { get; set; } //#region AutoControl
public bool InitUsedTemplateState { get; set; } //public bool IsEnableAutoControl { get; set; }
public bool InitUsedScheduleState { get; set; } //public bool InitUsedTemplateState { get; set; }
#endregion //public bool InitUsedScheduleState { get; set; }
public required List<UnitFilterRequest> UnitFilters { get; set; } //#endregion
public JobAutoControlRequest? AutoControl { get; init; }
public required List<UnitFilterRequest> UnitFilters { get; init; }
} }
public record JobRelationships
{
public int MinValueRelationships { get; init; }
public class UnitFilterRequest public int MaxValueRelationships { get; init; }
public bool IsParentRelationships { get; init; }
}
public record UnitFilterRequest
{ {
///// <summary> ///// <summary>
///// Id = null в методе Create, в Update обязателен ///// Id = null в методе Create, в Update обязателен
///// </summary> ///// </summary>
//public Guid? Id { get; set; } //public Guid? Id { get; set; }
public required string UnitFilterMask { get; set; } public required string UnitFilterMask { get; init; }
public List<FieldFilterRequest>? FieldFilters { get; set; } public List<FieldFilterRequest>? FieldFilters { get; init; }
public List<RelationshipFilterRequest>? RelationshipFilters { get; set; } public List<RelationshipFilterRequest>? RelationshipFilters { get; init; }
} }
public class FieldFilterRequest public record FieldFilterRequest
{ {
public Guid FieldId { get; set; } public Guid FieldId { get; init; }
public string? ValueMask { get; set; } public string? ValueMask { get; init; }
public bool IsInverse { get; set; } = false; public bool IsInverse { get; init; } = false;
} }
public class RelationshipFilterRequest public record RelationshipFilterRequest
{ {
public Guid FieldId { get; set; } public Guid FieldId { get; init; }
public bool? IsParent { get; set; } public bool? IsParent { get; init; }
public string? ValueMask { get; set; } public string? ValueMask { get; init; }
public bool? IsFullMatch { get; set; } public bool? IsFullMatch { get; init; }
public bool? IsInverse { get; set; } public bool? IsInverse { get; init; }
} }
} }

11
PARR.API/Contracts/V1/Responses/JobGroupResponse.cs
View File

@@ -40,6 +40,8 @@
/// </summary> /// </summary>
public bool IsAutoDistributionEnabled { get; set; } public bool IsAutoDistributionEnabled { get; set; }
public JobGroupAutoControlResponse? AutoControl { get; set; }
// public bool IsAgent { get; set; } // public bool IsAgent { get; set; }
// public string? AgentName { get; set; } // public string? AgentName { get; set; }
@@ -74,6 +76,15 @@
//public JobGroupDistributionConfigResponse? DistributionConfig { get; set; } //public JobGroupDistributionConfigResponse? DistributionConfig { get; set; }
} }
public class JobGroupAutoControlResponse
{
public bool IsEnable { get; set; }
public bool InitUsedTemplateState { get; set; }
public bool InitUsedScheduleState { get; set; }
}
public class JobGroupScheduleResponse public class JobGroupScheduleResponse
{ {
public string Timezone { get; set; } = string.Empty; public string Timezone { get; set; } = string.Empty;

16
PARR.API/Contracts/V1/Responses/JobGroupTypeResponse.cs
View File

@@ -2,14 +2,20 @@
namespace PARR.API.Contracts.V1.Responses namespace PARR.API.Contracts.V1.Responses
{ {
public class JobGroupTypeResponse public record JobGroupTypeResponse
{ {
public Guid Id { get; set; } public Guid Id { get; init; }
public required JobGroupTypesEnum Code { get; set; } public required JobGroupTypesEnum Code { get; init; }
public required string Name { get; set; } public required string Name { get; init; }
public required string Description { get; set; } public required string Description { get; init; }
public bool IsAllowJobUnitFilter { get; init; }
public bool IsJobGroupAutoControl { get; init; }
public bool IsRelationshipsAllowed { get; init; }
} }
} }

272
PARR.API/Controllers/V1/JobController.cs
View File

@@ -35,46 +35,43 @@ namespace PARR.API.Controllers.V1
[Authorize(Roles = ParrRoles.Administrator.Role)] [Authorize(Roles = ParrRoles.Administrator.Role)]
public class JobController : BaseApiController public class JobController : BaseApiController
{ {
private readonly ILogger<JobController> logger; private readonly ILogger<JobController> _logger;
private readonly IMapper mapper; private readonly IMapper _mapper;
private readonly IUriService uriService; private readonly IUriService _uriService;
private readonly IJobRepository jobService; private readonly IJobRepository _jobRepository;
private readonly ITemplateRepository templateService; private readonly ITemplateRepository _templateRepository;
//private readonly IValidator<JobRequest> jobValidator; private readonly IRabbitService _mqService;
private readonly IRabbitService mqService; private readonly MqSettings _mqSettings;
private readonly MqSettings mqSettings; private readonly IClientService _clientService;
private readonly IClientService clientService; private readonly IJobAutoControlRepository _jobAutoControlRepository;
private readonly IJobAutoControlRepository jobAutoControlService; private readonly IMatchingStatusService _matchingStatusService;
private readonly IMatchingStatusService matchingStatusService;
public JobController( public JobController(
ILogger<JobController> logger, ILogger<JobController> logger,
IMapper mapper, IMapper mapper,
IUriService uriService, IUriService uriService,
IJobRepository jobService, IJobRepository jobRepository,
ITemplateRepository templateService, ITemplateRepository templateRepository,
IJobGroupRepository jobGroupService, IJobGroupRepository jobGroupRepository,
//IValidator<JobRequest> jobValidator, IUnitFilterService unitFilterRepository,
IUnitFilterService unitFilterService, IUnitRepository unitRepository,
IUnitRepository unitService,
IRabbitService mqService, IRabbitService mqService,
MqSettings mqSettings, MqSettings mqSettings,
IClientService clientService, IClientService clientService,
IJobAutoControlRepository jobAutoControlService, IJobAutoControlRepository jobAutoControlRepository,
IMatchingStatusService matchingStatusService IMatchingStatusService matchingStatusService
) )
{ {
this.logger = logger; _logger = logger;
this.mapper = mapper; _mapper = mapper;
this.uriService = uriService; _uriService = uriService;
this.jobService = jobService; _jobRepository = jobRepository;
this.templateService = templateService; _templateRepository = templateRepository;
//this.jobValidator = jobValidator; _mqService = mqService;
this.mqService = mqService; _mqSettings = mqSettings;
this.mqSettings = mqSettings; _clientService = clientService;
this.clientService = clientService; _jobAutoControlRepository = jobAutoControlRepository;
this.jobAutoControlService = jobAutoControlService; _matchingStatusService = matchingStatusService;
this.matchingStatusService = matchingStatusService;
} }
/// <summary> /// <summary>
@@ -84,18 +81,20 @@ namespace PARR.API.Controllers.V1
[HttpGet(ApiRoutes.Job.GetAll)] [HttpGet(ApiRoutes.Job.GetAll)]
public async Task<IActionResult> GetAll([FromQuery] PaginationQuery paginationQuery, [FromQuery] JobQuery filter) public async Task<IActionResult> GetAll([FromQuery] PaginationQuery paginationQuery, [FromQuery] JobQuery filter)
{ {
var paginationFilter = mapper.Map<PaginationFilter>(paginationQuery); var paginationFilter = _mapper.Map<PaginationFilter>(paginationQuery);
IQueryable<Job> query = _jobRepository.Get()
.Include(t => t.AutoControl);
IQueryable<Job> query = jobService.Get().Include(t => t.AutoControl);
query = query.OrderBy(t => t.Name); query = query.OrderBy(t => t.Name);
if (!string.IsNullOrEmpty(filter.Name)) if (!string.IsNullOrEmpty(filter.Name))
{ {
//query = query.Where(t => t.Name.ToLower().Contains(filter.Name.ToLower())); //query = query.Where(t => t.Name.ToLower().Contains(filter.Name.ToLower()));
query = query.Where(t=>EF.Functions.Like(t.Name.ToLower(), SqlHelpers.RegexToLike(filter.Name))); query = query.Where(t => EF.Functions.Like(t.Name.ToLower(), SqlHelpers.RegexToLike(filter.Name)));
} }
if (filter.GroupId.HasValue) if (filter.GroupId.HasValue)
query = query.Where(t => t.GroupId == filter.GroupId.Value); query = query.Where(t => t.GroupId == filter.GroupId.Value);
@@ -107,9 +106,10 @@ namespace PARR.API.Controllers.V1
if (filter.IsFull) if (filter.IsFull)
{ {
query = query query = query
.Include(t => t.Tnk) .Include(t => t.Tnk)
.Include(t => t.Group).ThenInclude(t => t.GroupType) .Include(t => t.Group).ThenInclude(t => t.GroupType)
.Include(t => t.Group).ThenInclude(t => t.GroupingUnitField); .Include(t => t.Group).ThenInclude(t => t.GroupingUnitField)
.Include(t => t.Group).ThenInclude(t => t.AutoControl);
query = query query = query
.Include(t => t.UnitFilters) .Include(t => t.UnitFilters)
@@ -120,12 +120,12 @@ namespace PARR.API.Controllers.V1
.ThenInclude(t => t.UnitField); .ThenInclude(t => t.UnitField);
} }
var jobs = await jobService.GetPage(query, paginationFilter).ToListAsync(); var jobs = await _jobRepository.GetPage(query, paginationFilter).ToListAsync();
if (!jobs.Any()) if (!jobs.Any())
return NoContent(); return NoContent();
var response = mapper.Map<List<JobResponse>>(jobs);//TODO Migration to job var response = _mapper.Map<List<JobResponse>>(jobs);//TODO Migration to job
foreach (var jobResponse in response) foreach (var jobResponse in response)
{ {
@@ -152,9 +152,10 @@ namespace PARR.API.Controllers.V1
[HttpGet(ApiRoutes.Job.Get)] [HttpGet(ApiRoutes.Job.Get)]
public async Task<IActionResult> GetById([FromRoute] Guid id) public async Task<IActionResult> GetById([FromRoute] Guid id)
{ {
var job = await jobService.Get() var job = await _jobRepository.Get()
.Include(t => t.Tnk) .Include(t => t.Tnk)
.Include(t => t.Group).ThenInclude(t => t.GroupType) .Include(t => t.Group).ThenInclude(t => t.GroupType)
.Include(t => t.Group).ThenInclude(t => t.AutoControl)
.Include(t => t.Group).ThenInclude(t => t.GroupingUnitField) .Include(t => t.Group).ThenInclude(t => t.GroupingUnitField)
.Include(t => t.UnitFilters) .Include(t => t.UnitFilters)
.ThenInclude(t => t.FieldFilters) .ThenInclude(t => t.FieldFilters)
@@ -168,7 +169,7 @@ namespace PARR.API.Controllers.V1
if (job == null) if (job == null)
return NotFound(); return NotFound();
var response = mapper.Map<JobResponse>(job); var response = _mapper.Map<JobResponse>(job);
response.TemplatesCount = await GetCountTemplatesAsync(id); //await templateService.Get().CountAsync(t => t.JobId == id); response.TemplatesCount = await GetCountTemplatesAsync(id); //await templateService.Get().CountAsync(t => t.JobId == id);
response.MatchingStatus = await GetMatchingStatusAsync(id); response.MatchingStatus = await GetMatchingStatusAsync(id);
@@ -188,51 +189,56 @@ namespace PARR.API.Controllers.V1
[HttpPost(ApiRoutes.Job.Create)] [HttpPost(ApiRoutes.Job.Create)]
public async Task<IActionResult> Create([FromBody] JobRequest request) public async Task<IActionResult> Create([FromBody] JobRequest request)
{ {
//#region Валидация #region Проверка существования работы с такими же настройками связей параметрами
//var jobValidateResult = await jobValidator.ValidateAsync(request);//Валидация параметров самого задания
//if (!jobValidateResult.IsValid) if (request.Relationships != null)
// return BadRequest(new Response(jobValidateResult.Errors)); {
//#endregion //todo: не сильно правильный запрос, в нем проверяем полное совпадение, но не проверяем пересечения
var isExistTheSameLinks = await _jobRepository.Get()
//.Include(t => t.Group).ThenInclude(t => t.GroupType)
.AsNoTracking()
.CountAsync(t =>
//t.Group!.GroupType!.Code == JobGroupTypesEnum.Umbrella
//(t.Group!.GroupType!.Code == JobGroupTypesEnum.Umbrella || t.Group!.GroupType!.Code == JobGroupTypesEnum.Group) &&
t.Group!.GroupType!.IsRelationshipsAllowed &&
t.GroupId == request.GroupId &&
(t.MinValueRelationships == request.Relationships.MinValueRelationships ||
t.MaxValueRelationships == request.Relationships.MaxValueRelationships)
);
//TODO: !!!!!!! проверить, если тип ЗОНТИК или ГРУППИРОВКА, то обязательно должны быть заполнены поля min max if (isExistTheSameLinks > 0)
return BadRequest(new Response(false, new List<ErrorModel> { new ErrorModel {
#region Проверка существования работы с такими же параметрами FieldName = nameof(request.Name),
Message = $"Работа с указанным диапазоном связей пересекается с уже имеющейся в базе данных({request.Relationships.MinValueRelationships}-{request.Relationships.MaxValueRelationships})"
var isExistTheSameLinks = await jobService.Get() } }));
.Include(t => t.Group).ThenInclude(t => t.GroupType) }
.CountAsync(t =>
//t.Group!.GroupType!.Code == JobGroupTypesEnum.Umbrella
(t.Group!.GroupType!.Code == JobGroupTypesEnum.Umbrella || t.Group!.GroupType!.Code == JobGroupTypesEnum.Group) &&
t.GroupId == request.GroupId &&
(t.MinValueRelationships == request.MinValueRelationships ||
t.MaxValueRelationships == request.MaxValueRelationships)
);
if (isExistTheSameLinks > 0)
return BadRequest(new Response(false, new List<ErrorModel> { new ErrorModel { FieldName = nameof(request.Name), Message = $"Работа с указанным диапазоном связей пересекается с уже имеющейся в базе данных({request.MinValueRelationships}-{request.MaxValueRelationships})" } }));
#endregion #endregion
var job = mapper.Map<Job>(request); var job = _mapper.Map<Job>(request);
job.AutoControl = new JobAutoControl if (request.AutoControl != null)
{ {
JobId = job.Id, // разрешен автоконтроль или нет, проверил в валидаторе
IsEnable = request.IsEnableAutoControl, job.AutoControl = new JobAutoControl
InitUsedScheduleState = request.InitUsedScheduleState, {
InitUsedTemplateState = request.InitUsedTemplateState JobId = job.Id,
}; IsEnable = request.AutoControl.IsEnable,
InitUsedScheduleState = request.AutoControl.InitUsedScheduleState,
InitUsedTemplateState = request.AutoControl.InitUsedTemplateState
};
}
if (!await jobService.CreateAsync(job) || !await jobService.CommitAsync()) if (!await _jobRepository.CreateAsync(job) || !await _jobRepository.CommitAsync())
return BadRequest(new Response(false, new List<ErrorModel> { new ErrorModel { Message = "Ошибка при созании задания на выполнение работ" } })); return BadRequest(new Response(false, new List<ErrorModel> { new ErrorModel { Message = "Ошибка при созании задания на выполнение работ" } }));
logger.LogInformation($"Пользователь {User.Identity?.Name} добавил задание на выполнение работ: {job.Id}, {job.Name}, {job.WorkName}"); _logger.LogInformation($"Пользователь {User.Identity?.Name} добавил задание на выполнение работ: {job.Id}, {job.Name}, {job.WorkName}");
var createdJob = await jobService.Get() var createdJob = await _jobRepository.Get()
.Include(t => t.Tnk) .Include(t => t.Tnk)
.Include(t => t.Group).ThenInclude(t => t.GroupType) .Include(t => t.Group).ThenInclude(t => t.GroupType)
.Include(t => t.Group).ThenInclude(t => t.AutoControl)
.Include(t => t.Group).ThenInclude(t => t.GroupingUnitField) .Include(t => t.Group).ThenInclude(t => t.GroupingUnitField)
.Include(t => t.UnitFilters) .Include(t => t.UnitFilters)
.ThenInclude(t => t.FieldFilters) .ThenInclude(t => t.FieldFilters)
@@ -242,9 +248,9 @@ namespace PARR.API.Controllers.V1
.Include(t => t.AutoControl) .Include(t => t.AutoControl)
.FirstOrDefaultAsync(t => t.Id == job.Id); .FirstOrDefaultAsync(t => t.Id == job.Id);
var locationUri = uriService.GetUri(ApiRoutes.Job.Get, ApiRoutes.Job.getParam, createdJob!.Id); var locationUri = _uriService.GetUri(ApiRoutes.Job.Get, ApiRoutes.Job.getParam, createdJob!.Id);
var response = mapper.Map<JobResponse>(createdJob); var response = _mapper.Map<JobResponse>(createdJob);
// так как мы только что создали Job, то у него нет шаблонов, смело ставим = 0 (ускоряем запрос) // так как мы только что создали Job, то у него нет шаблонов, смело ставим = 0 (ускоряем запрос)
response.TemplatesCount = 0; response.TemplatesCount = 0;
response.MatchingStatus = await GetMatchingStatusAsync(response.Id); response.MatchingStatus = await GetMatchingStatusAsync(response.Id);
@@ -262,11 +268,7 @@ namespace PARR.API.Controllers.V1
[HttpPut(ApiRoutes.Job.Update)] [HttpPut(ApiRoutes.Job.Update)]
public async Task<IActionResult> Update([FromRoute] Guid id, [FromBody] JobRequest request) public async Task<IActionResult> Update([FromRoute] Guid id, [FromBody] JobRequest request)
{ {
//var resultValidate = await jobValidator.ValidateAsync(request); var orig = await _jobRepository.Get()
//if (!resultValidate.IsValid)
// return BadRequest(new Response(resultValidate.Errors));
var orig = await jobService.Get()
.Include(t => t.Tnk) .Include(t => t.Tnk)
.Include(t => t.Group).ThenInclude(t => t.GroupType) .Include(t => t.Group).ThenInclude(t => t.GroupType)
.Include(t => t.Group).ThenInclude(t => t.GroupingUnitField) .Include(t => t.Group).ThenInclude(t => t.GroupingUnitField)
@@ -287,77 +289,77 @@ namespace PARR.API.Controllers.V1
//TODO: ВОТ ЭТО ВООБЩЕ МЫ БУДЕМ ПРОВЕРЯТЬ, АААА???? - Проверка существования работы с такими же параметрами //TODO: ВОТ ЭТО ВООБЩЕ МЫ БУДЕМ ПРОВЕРЯТЬ, АААА???? - Проверка существования работы с такими же параметрами
//TODO: !!!!!!! проверить, если тип ЗОНТИК или ГРУППИРОВКА, то обязательно должны быть заполнены поля min max
#region обновление полей задания на работу #region обновление полей задания на работу
orig.Name = request.Name.Trim(); orig.Name = request.Name.Trim();
orig.WorkName = request.WorkName.Trim(); orig.WorkName = request.WorkName.Trim();
orig.MinValueRelationships = request.MinValueRelationships; orig.MinValueRelationships = request.Relationships?.MinValueRelationships;
orig.MaxValueRelationships = request.MaxValueRelationships; orig.MaxValueRelationships = request.Relationships?.MaxValueRelationships;
orig.IsParentRelationships = request.IsParentRelationships; orig.IsParentRelationships = request.Relationships?.IsParentRelationships;
orig.TemplateNameMask = request.TemplateNameMask.Trim(); orig.TemplateNameMask = request.TemplateNameMask.Trim();
orig.WorkGroupMask = request.WorkGroupMask.Trim(); orig.WorkGroupMask = request.WorkGroupMask.Trim();
orig.TnkId = request.TnkId; orig.TnkId = request.TnkId;
orig.GroupId = request.GroupId; orig.GroupId = request.GroupId;
orig.ResponseAreaMask = request.ResponseAreaMask.Trim(); orig.ResponseAreaMask = request.ResponseAreaMask.Trim();
if (orig.AutoControl != null) #region Настройки автоконтроля
// валидатор проверяет корректность
if (request.AutoControl != null)
{ {
orig.AutoControl.IsEnable = request.IsEnableAutoControl; // Создаем новую запись или обновляем существующую
orig.AutoControl.InitUsedScheduleState = request.InitUsedScheduleState; if (orig.AutoControl != null)
orig.AutoControl.InitUsedTemplateState = request.InitUsedTemplateState;
}
else
{
// автоконтрол не загружен, проверяем есть ли он в бд, если нет, то создадим
var existAutoControl = await jobAutoControlService.Get().FirstOrDefaultAsync(t => t.JobId == id);
if (existAutoControl != null)
{ {
logger.LogError($"При обновлении job {id}, не загрузась связь с JobAutoControl, но она есть. Не стал обновлять Job, вернул ошибку."); orig.AutoControl.IsEnable = request.AutoControl.IsEnable;
return BadRequest(new Response(false, new List<ErrorModel> { new ErrorModel { Message = $"Ошибка при изменении задания на выполнение работ." } })); orig.AutoControl.InitUsedScheduleState = request.AutoControl.InitUsedScheduleState;
orig.AutoControl.InitUsedTemplateState = request.AutoControl.InitUsedTemplateState;
} }
else else
{ {
var autoControl = new JobAutoControl orig.AutoControl = new JobAutoControl
{ {
JobId = id, JobId = id,
InitUsedScheduleState = request.InitUsedScheduleState, InitUsedScheduleState = request.AutoControl.InitUsedScheduleState,
InitUsedTemplateState = request.InitUsedTemplateState, InitUsedTemplateState = request.AutoControl.InitUsedTemplateState,
IsEnable = request.IsEnableAutoControl IsEnable = request.AutoControl.IsEnable
}; };
orig.AutoControl = autoControl;
logger.LogWarning($"При обновлении job {id}, отсутствовала запись в таблице JobAutoControl, создал ее. {autoControl.ToJson()}");
} }
} }
else
{
// Удаляем настройки, скорей всего автоконтролем управляет группа работ
orig.AutoControl = null;
}
#endregion
orig.DateModified = DateTimeOffset.UtcNow; orig.DateModified = DateTimeOffset.UtcNow;
#endregion #endregion
var job = mapper.Map<Job>(request); var job = _mapper.Map<Job>(request);
job.Id = id;//На всякий. Пусть будет для чистоты job.Id = id;//На всякий. Пусть будет для чистоты
UpdateUnitFilters(orig, job);//Обновление вложенных дочерних элементов-фильтров UpdateUnitFilters(orig, job);//Обновление вложенных дочерних элементов-фильтров
if (!await jobService.CommitAsync()) if (!await _jobRepository.CommitAsync())
return BadRequest(new Response(false, new List<ErrorModel> { new ErrorModel { Message = "Ошибка при изменении задания на выполнение работ." } })); return BadRequest(new Response(false, new List<ErrorModel> { new ErrorModel { Message = "Ошибка при изменении задания на выполнение работ." } }));
// если изменили маску, отправим задание на переименование связанных шаблонов // если изменили маску, отправим задание на переименование связанных шаблонов
if (isChangedTemplateNameMask) if (isChangedTemplateNameMask)
{ {
var mqResult = await SendRequestToUpdateTemplates(id); var mqResult = await SendRequestToUpdateTemplates(orig);
//todo: если ошибка. пользователя не предупреждаем... возможно ему это и не нужно знать...ну не переименуются шаблоны, может они переименуются позже... //todo: если ошибка. пользователя не предупреждаем... возможно ему это и не нужно знать...ну не переименуются шаблоны, может они переименуются позже...
} }
logger.LogInformation($"Пользователь {User.Identity?.Name} обновил задание на выполнение работ: {orig.Id}," + _logger.LogInformation($"Пользователь {User.Identity?.Name} обновил задание на выполнение работ: {orig.Id}," +
$" {orig.Name}, {orig.WorkName}, {orig.MinValueRelationships}, {orig.MaxValueRelationships}," + $" {orig.Name}, {orig.WorkName}, {orig.MinValueRelationships}, {orig.MaxValueRelationships}," +
$" {orig.TemplateNameMask}, {orig.TnkId}, {nameof(orig.GroupId)}"); $" {orig.TemplateNameMask}, {orig.TnkId}, {nameof(orig.GroupId)}");
var updatedJob = await jobService.Get() var updatedJob = await _jobRepository.Get()
.Include(t => t.Tnk) .Include(t => t.Tnk)
.Include(t => t.Group).ThenInclude(t => t.GroupType) .Include(t => t.Group).ThenInclude(t => t.GroupType)
.Include(t => t.Group).ThenInclude(t => t.AutoControl)
.Include(t => t.Group).ThenInclude(t => t.GroupingUnitField) .Include(t => t.Group).ThenInclude(t => t.GroupingUnitField)
.Include(t => t.UnitFilters) .Include(t => t.UnitFilters)
.ThenInclude(t => t.FieldFilters) .ThenInclude(t => t.FieldFilters)
@@ -367,7 +369,7 @@ namespace PARR.API.Controllers.V1
.Include(t => t.AutoControl) .Include(t => t.AutoControl)
.FirstAsync(t => t.Id == orig.Id); .FirstAsync(t => t.Id == orig.Id);
var response = mapper.Map<JobResponse>(updatedJob); var response = _mapper.Map<JobResponse>(updatedJob);
response.TemplatesCount = await GetCountTemplatesAsync(id); //await templateService.Get().CountAsync(t => t.JobId == id); response.TemplatesCount = await GetCountTemplatesAsync(id); //await templateService.Get().CountAsync(t => t.JobId == id);
response.MatchingStatus = await GetMatchingStatusAsync(id); response.MatchingStatus = await GetMatchingStatusAsync(id);
@@ -564,7 +566,7 @@ namespace PARR.API.Controllers.V1
[HttpDelete(ApiRoutes.Job.Delete)] [HttpDelete(ApiRoutes.Job.Delete)]
public async Task<IActionResult> Delete([FromRoute] Guid id) public async Task<IActionResult> Delete([FromRoute] Guid id)
{ {
var job = await jobService.Get().Include(t => t.Tnk) var job = await _jobRepository.Get().Include(t => t.Tnk)
.FirstOrDefaultAsync(t => t.Id == id); .FirstOrDefaultAsync(t => t.Id == id);
if (job == null) if (job == null)
@@ -572,19 +574,19 @@ namespace PARR.API.Controllers.V1
Message = $"Ошибка при удалении задания на выполнение работ. Не найдено задание на выполнение работ Id: {id}" Message = $"Ошибка при удалении задания на выполнение работ. Не найдено задание на выполнение работ Id: {id}"
} })); } }));
var templateCount = await templateService.Get().CountAsync(t => t.JobId == id); var templateCount = await _templateRepository.Get().CountAsync(t => t.JobId == id);
if (templateCount > 0) if (templateCount > 0)
return BadRequest(new Response(false, new List<ErrorModel> { new ErrorModel { return BadRequest(new Response(false, new List<ErrorModel> { new ErrorModel {
Message = $"Ошибка при удалении задания на выполнение работ. С данным заданием связаны шаблоны: {templateCount} шт." Message = $"Ошибка при удалении задания на выполнение работ. С данным заданием связаны шаблоны: {templateCount} шт."
} })); } }));
if (!jobService.Delete(job) || !await jobService.CommitAsync()) if (!_jobRepository.Delete(job) || !await _jobRepository.CommitAsync())
return BadRequest(new Response(false, new List<ErrorModel> { new ErrorModel { return BadRequest(new Response(false, new List<ErrorModel> { new ErrorModel {
Message = $"Ошибка при удалении задания на выполнение работ" Message = $"Ошибка при удалении задания на выполнение работ"
} })); } }));
logger.LogInformation($"Пользователь {User.Identity?.Name} удалил задание на выполнение работ: {job.Id},{job.Name}," + _logger.LogInformation($"Пользователь {User.Identity?.Name} удалил задание на выполнение работ: {job.Id},{job.Name}," +
$" {job.WorkName}, {job.MinValueRelationships}, {job.MaxValueRelationships}," + $" {job.WorkName}, {job.MinValueRelationships}, {job.MaxValueRelationships}," +
$" {job.TemplateNameMask}, {job.TnkId}, {job.GroupId}"); $" {job.TemplateNameMask}, {job.TnkId}, {job.GroupId}");
@@ -599,7 +601,7 @@ namespace PARR.API.Controllers.V1
/// <returns></returns> /// <returns></returns>
private async Task<JobStatModel> GetStatisticsAsync(Guid jobId) private async Task<JobStatModel> GetStatisticsAsync(Guid jobId)
{ {
var statResult = await jobService.Get() var statResult = await _jobRepository.Get()
.Include(t => t.Templates) .Include(t => t.Templates)
.ThenInclude(t => t.RobotConfigurations) .ThenInclude(t => t.RobotConfigurations)
.Where(x => x.Id == jobId) .Where(x => x.Id == jobId)
@@ -629,35 +631,53 @@ namespace PARR.API.Controllers.V1
} }
private async Task<bool> SendRequestToUpdateTemplates(Guid jobId) private async Task<bool> SendRequestToUpdateTemplates(Job job)
{ {
if (job.Group?.GroupType == null)
throw new ArgumentException("Не хватает include для job.Group.GroupType", nameof(job.Group.GroupType));
Guid Id = default;
SyncTaskEntityTypeEnum EntityType = default;
// Смотрим кто управляет автоконтролем, и какой объект можно синхронизировать
if (job.Group.GroupType.IsJobGroupAutoControl)
{
// Управляет JobGroup
Id = job.GroupId;
EntityType = SyncTaskEntityTypeEnum.JobGroup;
}
else
{
// Управляет Job
Id = job.Id;
EntityType = SyncTaskEntityTypeEnum.Job;
}
var request = new TemplateMatcherMq var request = new TemplateMatcherMq
{ {
Id = jobId, Id = Id,
EntityType = SyncTaskEntityTypeEnum.Job, EntityType = EntityType,
Action = TemplateMatcherActionEnum.Update, Action = TemplateMatcherActionEnum.Update,
Initiator = new HistoryInitiator Initiator = new HistoryInitiator
{ {
InitiatorIp = clientService.GetClientIp()?.ToString(), InitiatorIp = _clientService.GetClientIp()?.ToString(),
InitiatorParrComponentId = ParrComponentsEnum.Api, InitiatorParrComponentId = ParrComponentsEnum.Api,
InitiatorComment = $"В GUI изменено имя шаблона, при сохранении Job отправлен запрос на обновление связанных шаблонов" InitiatorComment = $"В GUI изменено имя шаблона, при сохранении Job отправлен запрос на обновление связанных шаблонов"
} }
}; };
//var msg = JsonSerializer.Serialize(request); var result = await _mqService.SendAsync(_mqSettings.TemplatesMatcher, new List<object> { request });
//var result = await mqService.SendAsync(mqSettings.TemplatesMatcher, new[] { msg }); _logger.LogDebug("Получен код отпрвки: {IsSuccess}", result.IsSuccess);
var result = await mqService.SendAsync(mqSettings.TemplatesMatcher, new List<object> { request });
logger.LogDebug("Получен код отпрвки: {IsSuccess}", result.IsSuccess);
if (!result.IsSuccess) if (!result.IsSuccess)
{ {
logger.LogError($"Ошибка при отправке запроса в очередь на обновление связанных шаблонов, после обновления маски шаблона. {request.ToJson()}"); _logger.LogError($"Ошибка при отправке запроса в очередь на обновление связанных шаблонов, после обновления маски шаблона. {request.ToJson()}");
return false; return false;
} }
logger.LogInformation($"После изменения маски шаблона в jobId: {jobId}, отправлен запрос в очередь на переименование связанных шаблонов: {request.ToJson()}"); _logger.LogInformation($"После изменения маски шаблона в jobId: {job.Id}, отправлен запрос в очередь на переименование связанных шаблонов: {request.ToJson()}");
return true; return true;
} }
@@ -671,7 +691,7 @@ namespace PARR.API.Controllers.V1
private async Task<int> GetCountTemplatesAsync(Guid jobId) private async Task<int> GetCountTemplatesAsync(Guid jobId)
{ {
// Получаем только шаблоны в статусе used // Получаем только шаблоны в статусе used
return await templateService.Get().CountAsync(t => t.JobId == jobId && t.StatusTypeId == TemplateStatusTypeEnum.Used); return await _templateRepository.Get().CountAsync(t => t.JobId == jobId && t.StatusTypeId == TemplateStatusTypeEnum.Used);
} }
/// <summary> /// <summary>
@@ -681,9 +701,9 @@ namespace PARR.API.Controllers.V1
/// <returns></returns> /// <returns></returns>
private async Task<MatchingStatusResponse?> GetMatchingStatusAsync(Guid jobId) private async Task<MatchingStatusResponse?> GetMatchingStatusAsync(Guid jobId)
{ {
var statusMatching = await matchingStatusService.GetStatusAsync(jobId, SyncTaskEntityTypeEnum.Job); var statusMatching = await _matchingStatusService.GetStatusAsync(jobId, SyncTaskEntityTypeEnum.Job);
return mapper.Map<MatchingStatusResponse>(statusMatching); return _mapper.Map<MatchingStatusResponse>(statusMatching);
} }
} }

237
PARR.API/Controllers/V1/JobGroupController.cs
View File

@@ -33,63 +33,64 @@ namespace PARR.API.Controllers.V1
[Authorize(Roles = ParrRoles.Administrator.Role)] [Authorize(Roles = ParrRoles.Administrator.Role)]
public class JobGroupController : BaseApiController public class JobGroupController : BaseApiController
{ {
private readonly ILogger<JobController> logger; private readonly ILogger<JobController> _logger;
private readonly IMapper mapper; private readonly IMapper _mapper;
private readonly IUriService uriService; private readonly IUriService _uriService;
private readonly IJobGroupRepository groupService; private readonly IJobGroupRepository _groupRepository;
private readonly IJobRepository jobService; private readonly IJobRepository _jobRepository;
private readonly IEsppSchTypeConfigRepository esppConfigService; private readonly IEsppSchTypeConfigRepository _esppConfigRepository;
//private readonly IValidator<JobGroupRequest> validator; private readonly IJobGroupTypeRepository _jobGroupTypeRepository;
private readonly IJobGroupTypeRepository jobGroupTypeService; private readonly IMatchingStatusService _matchingStatusRepository;
private readonly IMatchingStatusService matchingStatusService; private readonly IScheduleResponseAreaTimeOffsetRepository _scheduleResponseAreaTimeOffsetRepository;
private readonly IScheduleResponseAreaTimeOffsetRepository scheduleResponseAreaTimeOffsetService; private readonly IJobAutoControlRepository _jobAutoControlRepository;
private readonly IRabbitService mqService; private readonly IRabbitService _mqService;
private readonly MqSettings mqSettings; private readonly MqSettings _mqSettings;
public JobGroupController( public JobGroupController(
ILogger<JobController> logger, ILogger<JobController> logger,
IMapper mapper, IMapper mapper,
IUriService uriService, IUriService uriService,
IJobGroupRepository groupService, IJobGroupRepository groupRepository,
IJobRepository jobService, IJobRepository jobRepository,
IEsppSchTypeConfigRepository esppConfigService, IEsppSchTypeConfigRepository esppConfigRepository,
//IValidator<JobGroupRequest> validator, IJobGroupTypeRepository jobGroupTypeRepository,
IJobGroupTypeRepository jobGroupTypeService, IMatchingStatusService matchingStatusRepository,
IMatchingStatusService matchingStatusService, IScheduleResponseAreaTimeOffsetRepository scheduleResponseAreaTimeOffsetRepository,
IScheduleResponseAreaTimeOffsetRepository scheduleResponseAreaTimeOffsetService, IJobAutoControlRepository jobAutoControlRepository,
IRabbitService mqService, IRabbitService mqService,
MqSettings mqSettings MqSettings mqSettings
) )
{ {
this.logger = logger; this._logger = logger;
this.mapper = mapper; this._mapper = mapper;
this.uriService = uriService; this._uriService = uriService;
this.groupService = groupService; _groupRepository = groupRepository;
this.jobService = jobService; _jobRepository = jobRepository;
this.esppConfigService = esppConfigService; _esppConfigRepository = esppConfigRepository;
//this.validator = validator; _jobGroupTypeRepository = jobGroupTypeRepository;
this.jobGroupTypeService = jobGroupTypeService; _matchingStatusRepository = matchingStatusRepository;
this.matchingStatusService = matchingStatusService; _scheduleResponseAreaTimeOffsetRepository = scheduleResponseAreaTimeOffsetRepository;
this.scheduleResponseAreaTimeOffsetService = scheduleResponseAreaTimeOffsetService; _jobAutoControlRepository = jobAutoControlRepository;
this.mqService = mqService; this._mqService = mqService;
this.mqSettings = mqSettings; this._mqSettings = mqSettings;
} }
/// <summary> /// <summary>
/// Получить список групп заданий на выполнение работ постранично /// Получить список групп работ постранично
/// </summary> /// </summary>
/// <returns></returns> /// <returns></returns>
[HttpGet(ApiRoutes.JobGroup.GetAll)] [HttpGet(ApiRoutes.JobGroup.GetAll)]
public async Task<IActionResult> GetAll([FromQuery] PaginationQuery paginationQuery, [FromQuery] JobGroupQuery filter) public async Task<IActionResult> GetAll([FromQuery] PaginationQuery paginationQuery, [FromQuery] JobGroupQuery filter)
{ {
var paginationFilter = mapper.Map<PaginationFilter>(paginationQuery); var paginationFilter = _mapper.Map<PaginationFilter>(paginationQuery);
IQueryable<JobGroup> query = groupService.Get() IQueryable<JobGroup> query = _groupRepository.Get()
.Include(t => t.GroupType) .Include(t => t.GroupType)
.Include(t => t.GroupingUnitField) .Include(t => t.GroupingUnitField)
.Include(t => t.ScheduleExcludeType) .Include(t => t.ScheduleExcludeType)
.Include(t => t.ScheduleExcludeTypeCalendar); .Include(t => t.ScheduleExcludeTypeCalendar)
.Include(t => t.AutoControl);
query = query.OrderBy(t => t.GroupName); query = query.OrderBy(t => t.GroupName);
@@ -104,12 +105,12 @@ namespace PARR.API.Controllers.V1
.Include(t => t.Jobs).ThenInclude(t => t.Tnk) .Include(t => t.Jobs).ThenInclude(t => t.Tnk)
.Include(t => t.DistributionConfig).ThenInclude(t => t.DistributionPeriod); .Include(t => t.DistributionConfig).ThenInclude(t => t.DistributionPeriod);
var jobGroups = await groupService.GetPage(query, paginationFilter).ToListAsync(); var jobGroups = await _groupRepository.GetPage(query, paginationFilter).ToListAsync();
if (!jobGroups.Any()) if (!jobGroups.Any())
return NoContent(); return NoContent();
var response = mapper.Map<List<JobGroupResponse>>(jobGroups); var response = _mapper.Map<List<JobGroupResponse>>(jobGroups);
if (filter.IsFull) if (filter.IsFull)
foreach (var jobGroupResponse in response) foreach (var jobGroupResponse in response)
@@ -122,26 +123,27 @@ namespace PARR.API.Controllers.V1
/// <summary> /// <summary>
/// Получить группу заданий на выполнение работ по id /// Получить группу работ по id
/// </summary> /// </summary>
/// <param name="id"></param> /// <param name="id"></param>
/// <returns></returns> /// <returns></returns>
[HttpGet(ApiRoutes.JobGroup.Get)] [HttpGet(ApiRoutes.JobGroup.Get)]
public async Task<IActionResult> GetById([FromRoute] Guid id) public async Task<IActionResult> GetById([FromRoute] Guid id)
{ {
var jobGroup = await groupService.Get() var jobGroup = await _groupRepository.Get()
.Include(t => t.Jobs).ThenInclude(t => t.Tnk) .Include(t => t.Jobs).ThenInclude(t => t.Tnk)
.Include(t => t.GroupType) .Include(t => t.GroupType)
.Include(t => t.GroupingUnitField) .Include(t => t.GroupingUnitField)
.Include(t => t.ScheduleExcludeType) .Include(t => t.ScheduleExcludeType)
.Include(t => t.ScheduleExcludeTypeCalendar) .Include(t => t.ScheduleExcludeTypeCalendar)
.Include(t => t.DistributionConfig).ThenInclude(t => t.DistributionPeriod) .Include(t => t.DistributionConfig).ThenInclude(t => t.DistributionPeriod)
.Include(t => t.AutoControl)
.FirstOrDefaultAsync(t => t.Id == id); .FirstOrDefaultAsync(t => t.Id == id);
if (jobGroup == null) if (jobGroup == null)
return NotFound(); return NotFound();
var response = mapper.Map<JobGroupResponse>(jobGroup); var response = _mapper.Map<JobGroupResponse>(jobGroup);
await AppendMissingDataAsync(response); await AppendMissingDataAsync(response);
return Ok(new Response<JobGroupResponse>(response, true)); return Ok(new Response<JobGroupResponse>(response, true));
@@ -149,18 +151,13 @@ namespace PARR.API.Controllers.V1
/// <summary> /// <summary>
/// Создать группу заданий на выполнение работ (JobGroup) /// Создать группу работ (JobGroup)
/// </summary> /// </summary>
/// <param name="request"></param> /// <param name="request"></param>
/// <returns></returns> /// <returns></returns>
[HttpPost(ApiRoutes.JobGroup.Create)] [HttpPost(ApiRoutes.JobGroup.Create)]
public async Task<IActionResult> Create([FromBody] JobGroupRequest request) public async Task<IActionResult> Create([FromBody] JobGroupRequest request)
{ {
//var resultValidate = await validator.ValidateAsync(request);
//if (!resultValidate.IsValid)
// return BadRequest(new Response(resultValidate.Errors));
var jobGroup = new JobGroup var jobGroup = new JobGroup
{ {
Id = Guid.NewGuid(), Id = Guid.NewGuid(),
@@ -191,7 +188,7 @@ namespace PARR.API.Controllers.V1
// на всякий проверим, но вообще это проверяется в валидаторе // на всякий проверим, но вообще это проверяется в валидаторе
if (request.DistributionConfig == null) if (request.DistributionConfig == null)
{ {
logger.LogError("Ошибка при создании группы работ '{name}', отсутствуют настройки автораспределения", request.Name); _logger.LogError("Ошибка при создании группы работ '{name}', отсутствуют настройки автораспределения", request.Name);
return BadRequest(new Response(false, new List<ErrorModel> { new ErrorModel { Message = "Ошибка при создании группы заданий на выполнение работ" } })); return BadRequest(new Response(false, new List<ErrorModel> { new ErrorModel { Message = "Ошибка при создании группы заданий на выполнение работ" } }));
} }
@@ -199,6 +196,22 @@ namespace PARR.API.Controllers.V1
} }
#endregion #endregion
#region Настройки автоконтроля
// Корректность проверяется в валидаторе
if (request.AutoControl != null)
{
jobGroup.AutoControl = new JobGroupAutoControl
{
InitUsedScheduleState = request.AutoControl.InitUsedScheduleState,
InitUsedTemplateState = request.AutoControl.InitUsedTemplateState,
IsEnable = request.AutoControl.IsEnable,
JobGroupId = jobGroup.Id
};
}
#endregion
//Добавляем настройки планировщика //Добавляем настройки планировщика
request.Schedule.ForEach(item => request.Schedule.ForEach(item =>
{ {
@@ -210,23 +223,24 @@ namespace PARR.API.Controllers.V1
}); });
}); });
if (!await groupService.CreateAsync(jobGroup) || !await groupService.CommitAsync()) if (!await _groupRepository.CreateAsync(jobGroup) || !await _groupRepository.CommitAsync())
return BadRequest(new Response(false, new List<ErrorModel> { new ErrorModel { Message = "Ошибка при создании группы заданий на выполнение работ" } })); return BadRequest(new Response(false, new List<ErrorModel> { new ErrorModel { Message = "Ошибка при создании группы заданий на выполнение работ" } }));
logger.LogInformation($"Пользователь {User.Identity?.Name} добавил группу заданий на выполнение работ: {jobGroup.Id}, {jobGroup.GroupName}, {jobGroup.ShortDescription}"); _logger.LogInformation($"Пользователь {User.Identity?.Name} добавил группу заданий на выполнение работ: {jobGroup.Id}, {jobGroup.GroupName}, {jobGroup.ShortDescription}");
var createdJobGroup = await groupService.Get().Include(t => t.Jobs).ThenInclude(t => t.Tnk) var createdJobGroup = await _groupRepository.Get().Include(t => t.Jobs).ThenInclude(t => t.Tnk)
.Include(t => t.GroupType) .Include(t => t.GroupType)
.Include(t => t.GroupingUnitField) .Include(t => t.GroupingUnitField)
.Include(t => t.ScheduleExcludeType) .Include(t => t.ScheduleExcludeType)
.Include(t => t.ScheduleExcludeTypeCalendar) .Include(t => t.ScheduleExcludeTypeCalendar)
.Include(t => t.DistributionConfig).ThenInclude(t => t.DistributionPeriod) .Include(t => t.DistributionConfig).ThenInclude(t => t.DistributionPeriod)
.Include(t => t.AutoControl)
.FirstAsync(t => t.Id == jobGroup.Id); .FirstAsync(t => t.Id == jobGroup.Id);
var locationUri = uriService.GetUri(ApiRoutes.JobGroup.Get, ApiRoutes.JobGroup.getParam, createdJobGroup.Id); var locationUri = _uriService.GetUri(ApiRoutes.JobGroup.Get, ApiRoutes.JobGroup.getParam, createdJobGroup.Id);
var response = mapper.Map<JobGroupResponse>(createdJobGroup); var response = _mapper.Map<JobGroupResponse>(createdJobGroup);
await AppendMissingDataAsync(response); await AppendMissingDataAsync(response);
return Created(locationUri, new Response<JobGroupResponse>(response, true)); return Created(locationUri, new Response<JobGroupResponse>(response, true));
@@ -234,7 +248,7 @@ namespace PARR.API.Controllers.V1
/// <summary> /// <summary>
/// Обновить группу заданий на выполнение работ (JobGroup) /// Обновить группу работ (JobGroup)
/// </summary> /// </summary>
/// <param name="id"></param> /// <param name="id"></param>
/// <param name="request"></param> /// <param name="request"></param>
@@ -242,15 +256,11 @@ namespace PARR.API.Controllers.V1
[HttpPut(ApiRoutes.JobGroup.Update)] [HttpPut(ApiRoutes.JobGroup.Update)]
public async Task<IActionResult> Update([FromRoute] Guid id, [FromBody] JobGroupRequest request) public async Task<IActionResult> Update([FromRoute] Guid id, [FromBody] JobGroupRequest request)
{ {
//var resultValidate = await validator.ValidateAsync(request); var orig = await _groupRepository.Get()
//if (!resultValidate.IsValid)
// return BadRequest(new Response(resultValidate.Errors));
var orig = await groupService.Get()
.Include(t => t.Jobs) .Include(t => t.Jobs)
.ThenInclude(t => t.Tnk) .ThenInclude(t => t.Tnk)
.Include(t => t.EsppSchValues) .Include(t => t.EsppSchValues)
.Include(t => t.AutoControl)
.Include(t => t.DistributionConfig).ThenInclude(t => t.DistributionPeriod) .Include(t => t.DistributionConfig).ThenInclude(t => t.DistributionPeriod)
.FirstOrDefaultAsync(t => t.Id == id); .FirstOrDefaultAsync(t => t.Id == id);
@@ -287,7 +297,7 @@ namespace PARR.API.Controllers.V1
{ {
if (request.DistributionConfig == null) if (request.DistributionConfig == null)
{ {
logger.LogError("Ошибка при изменении группы работ '{name}', отсутствуют настройки автораспределения", request.Name); _logger.LogError("Ошибка при изменении группы работ '{name}', отсутствуют настройки автораспределения", request.Name);
return BadRequest(new Response(false, new List<ErrorModel> { new ErrorModel { Message = "Ошибка при изменении группы заданий на выполнение работ" } })); return BadRequest(new Response(false, new List<ErrorModel> { new ErrorModel { Message = "Ошибка при изменении группы заданий на выполнение работ" } }));
} }
@@ -309,12 +319,50 @@ namespace PARR.API.Controllers.V1
// удаляем настройки распределения если они были // удаляем настройки распределения если они были
if (orig.DistributionConfig != null) if (orig.DistributionConfig != null)
{ {
groupService.DeleteDistributionConfig(orig.DistributionConfig); _groupRepository.DeleteDistributionConfig(orig.DistributionConfig);
} }
} }
#endregion #endregion
#region Настройки автоконтроля
// валидатор проверяет корректность
if (request.AutoControl != null)
{
// автоконтролем управляет JobGroup
if (orig.AutoControl != null)
{
// обновляем
orig.AutoControl.IsEnable = request.AutoControl.IsEnable;
orig.AutoControl.InitUsedScheduleState = request.AutoControl.InitUsedScheduleState;
orig.AutoControl.InitUsedTemplateState = request.AutoControl.InitUsedTemplateState;
// удалить настройки автоконтроля для job
await RemoveJobAutoControlSettingsAsync(orig.Id);
}
else
{
// создаем новую запись
orig.AutoControl = new JobGroupAutoControl
{
InitUsedScheduleState = request.AutoControl.InitUsedScheduleState,
InitUsedTemplateState = request.AutoControl.InitUsedTemplateState,
IsEnable = request.AutoControl.IsEnable,
JobGroupId = orig.Id
};
// удалить настройки автоконтроля для job
await RemoveJobAutoControlSettingsAsync(orig.Id);
}
}
else
{
// автоконтролем управляет каждый job отдельно
// удаляем настройки, если они были
orig.AutoControl = null;
}
#endregion
//обновляем планировщик //обновляем планировщик
orig.EsppSchValues.Clear(); orig.EsppSchValues.Clear();
request.Schedule.ForEach(item => request.Schedule.ForEach(item =>
@@ -327,10 +375,10 @@ namespace PARR.API.Controllers.V1
}); });
}); });
if (!await groupService.CommitAsync()) if (!await _groupRepository.CommitAsync())
return BadRequest(new Response(false, new List<ErrorModel> { new ErrorModel { Message = "Ошибка при изменении группы заданий на выполнение работ." } })); return BadRequest(new Response(false, new List<ErrorModel> { new ErrorModel { Message = "Ошибка при изменении группы заданий на выполнение работ." } }));
logger.LogInformation($"Пользователь {User.Identity?.Name} обновил группу заданий на выполнение работ: {orig.Id}," + _logger.LogInformation($"Пользователь {User.Identity?.Name} обновил группу заданий на выполнение работ: {orig.Id}," +
$" {orig.GroupName}, {orig.ShortDescription}, {orig.FullDescription}," + $" {orig.GroupName}, {orig.ShortDescription}, {orig.FullDescription}," +
$" {orig.Solution}, {orig.TemplateDuration}, {orig.ReferenceDate}, {orig.IsAutoDistributionEnabled}" + $" {orig.Solution}, {orig.TemplateDuration}, {orig.ReferenceDate}, {orig.IsAutoDistributionEnabled}" +
$", {orig.IsAgent}, {orig.AgentName}, {orig.AgentTimeOutSec}, {orig.AgentScript}"); $", {orig.IsAgent}, {orig.AgentName}, {orig.AgentTimeOutSec}, {orig.AgentScript}");
@@ -345,17 +393,17 @@ namespace PARR.API.Controllers.V1
JobGroupId = id, JobGroupId = id,
Initiator = new HistoryInitiator { InitiatorComment = "Изменилось расписание группы работ в ГУИ, отправлен запрос на перерасчет nextRun", InitiatorParrComponentId = ParrComponentsEnum.Api } Initiator = new HistoryInitiator { InitiatorComment = "Изменилось расписание группы работ в ГУИ, отправлен запрос на перерасчет nextRun", InitiatorParrComponentId = ParrComponentsEnum.Api }
}; };
var sendResult = await mqService.SendAsync(mqSettings.NextRun, new List<object> { requestToMq }); var sendResult = await _mqService.SendAsync(_mqSettings.NextRun, new List<object> { requestToMq });
if (sendResult.IsSuccess) if (sendResult.IsSuccess)
logger.LogInformation("Задание на перерасчет NextRun успешно отправлено в очередь MQ {queueName}", mqSettings.NextRun.QueueName); _logger.LogInformation("Задание на перерасчет NextRun успешно отправлено в очередь MQ {queueName}", _mqSettings.NextRun.QueueName);
else else
logger.LogError("Ошибка при отправке задания на перерасчет NextRun в очередь MQ {queueName}", mqSettings.NextRun.QueueName); _logger.LogError("Ошибка при отправке задания на перерасчет NextRun в очередь MQ {queueName}", _mqSettings.NextRun.QueueName);
} }
#endregion #endregion
var updatedJobGroup = await groupService.Get() var updatedJobGroup = await _groupRepository.Get()
.Include(t => t.Jobs) .Include(t => t.Jobs)
.ThenInclude(t => t.Tnk) .ThenInclude(t => t.Tnk)
.Include(t => t.GroupType) .Include(t => t.GroupType)
@@ -363,9 +411,10 @@ namespace PARR.API.Controllers.V1
.Include(t => t.ScheduleExcludeType) .Include(t => t.ScheduleExcludeType)
.Include(t => t.ScheduleExcludeTypeCalendar) .Include(t => t.ScheduleExcludeTypeCalendar)
.Include(t => t.DistributionConfig).ThenInclude(t => t.DistributionPeriod) .Include(t => t.DistributionConfig).ThenInclude(t => t.DistributionPeriod)
.Include(t => t.AutoControl)
.FirstAsync(t => t.Id == orig.Id); .FirstAsync(t => t.Id == orig.Id);
var response = mapper.Map<JobGroupResponse>(updatedJobGroup); var response = _mapper.Map<JobGroupResponse>(updatedJobGroup);
await AppendMissingDataAsync(response); await AppendMissingDataAsync(response);
return Ok(new Response<JobGroupResponse>(response, true)); return Ok(new Response<JobGroupResponse>(response, true));
@@ -373,14 +422,14 @@ namespace PARR.API.Controllers.V1
/// <summary> /// <summary>
/// Удалить группу заданий на выполнение работ (только если нет связанных заданий) /// Удалить группу работ (только если нет связанных работ)
/// </summary> /// </summary>
/// <param name="id"></param> /// <param name="id"></param>
/// <returns></returns> /// <returns></returns>
[HttpDelete(ApiRoutes.JobGroup.Delete)] [HttpDelete(ApiRoutes.JobGroup.Delete)]
public async Task<IActionResult> Delete([FromRoute] Guid id) public async Task<IActionResult> Delete([FromRoute] Guid id)
{ {
var jobGroup = await groupService.Get() var jobGroup = await _groupRepository.Get()
.FirstOrDefaultAsync(t => t.Id == id); .FirstOrDefaultAsync(t => t.Id == id);
if (jobGroup == null) if (jobGroup == null)
@@ -388,18 +437,18 @@ namespace PARR.API.Controllers.V1
Message = $"Ошибка при удалении группы заданий на выполнение работ. Не найдена группа заданий на выполнение работ Id: {id}" Message = $"Ошибка при удалении группы заданий на выполнение работ. Не найдена группа заданий на выполнение работ Id: {id}"
} })); } }));
var jobCount = await jobService.Get().CountAsync(t => t.GroupId == id); var jobCount = await _jobRepository.Get().CountAsync(t => t.GroupId == id);
if (jobCount > 0) if (jobCount > 0)
return BadRequest(new Response(false, new List<ErrorModel> { new ErrorModel { return BadRequest(new Response(false, new List<ErrorModel> { new ErrorModel {
Message = $"Ошибка при удалении группы заданий на выполнение работ. С данным группой связаны задания: {jobCount} шт." Message = $"Ошибка при удалении группы заданий на выполнение работ. С данным группой связаны задания: {jobCount} шт."
} })); } }));
if (!groupService.Delete(jobGroup) || !await groupService.CommitAsync()) if (!_groupRepository.Delete(jobGroup) || !await _groupRepository.CommitAsync())
return BadRequest(new Response(false, new List<ErrorModel> { new ErrorModel { return BadRequest(new Response(false, new List<ErrorModel> { new ErrorModel {
Message = $"Ошибка при удалении группы заданий на выполнение работ" Message = $"Ошибка при удалении группы заданий на выполнение работ"
} })); } }));
logger.LogInformation($"Пользователь {User.Identity?.Name} удалил группу заданий на выполнение работ: {jobGroup.Id},{jobGroup.GroupName}," + _logger.LogInformation($"Пользователь {User.Identity?.Name} удалил группу заданий на выполнение работ: {jobGroup.Id},{jobGroup.GroupName}," +
$" {jobGroup.ShortDescription}, {jobGroup.FullDescription}," + $" {jobGroup.ShortDescription}, {jobGroup.FullDescription}," +
$" {jobGroup.Solution}, {jobGroup.TemplateDuration}, {jobGroup.ReferenceDate}," + $" {jobGroup.Solution}, {jobGroup.TemplateDuration}, {jobGroup.ReferenceDate}," +
$" {jobGroup.IsAutoDistributionEnabled}, {jobGroup.IsAgent}, {jobGroup.AgentName}," + $" {jobGroup.IsAutoDistributionEnabled}, {jobGroup.IsAgent}, {jobGroup.AgentName}," +
@@ -408,6 +457,24 @@ namespace PARR.API.Controllers.V1
return NoContent(); return NoContent();
} }
/// <summary>
/// Удалить настройки автоконтроля для связанных Job
/// </summary>
/// <param name="jobGroupId"></param>
/// <returns></returns>
private async Task RemoveJobAutoControlSettingsAsync(Guid jobGroupId)
{
var jobAutoControlsToRemove = await _jobAutoControlRepository.Get()
.Where(t => t.Job!.GroupId == jobGroupId)
.ToListAsync();
if (!jobAutoControlsToRemove.Any())
return;
_logger.LogInformation("У группы работ {JobGroupId}, у связанных работ {JobsCount} шт. удалены настройки автоконтроля, так как автоконтролем управляем группа работ.", jobGroupId, jobAutoControlsToRemove.Count);
_jobAutoControlRepository.RemoveRange(jobAutoControlsToRemove);
}
/// <summary> /// <summary>
/// Проверка, были ли изменения в расписании /// Проверка, были ли изменения в расписании
@@ -471,25 +538,25 @@ namespace PARR.API.Controllers.V1
/// <returns></returns> /// <returns></returns>
private async Task AppendMissingDataAsync(JobGroupResponse jobGroupResponse) private async Task AppendMissingDataAsync(JobGroupResponse jobGroupResponse)
{ {
var schedule = await esppConfigService.GetEsppScheduleDtoAsync(jobGroupResponse.Id); var schedule = await _esppConfigRepository.GetEsppScheduleDtoAsync(jobGroupResponse.Id);
if (schedule == null) if (schedule == null)
{ {
logger.LogError($"Не смог замапить расписание, так как оно null. JobGroupId: {jobGroupResponse.Id}"); _logger.LogError($"Не смог замапить расписание, так как оно null. JobGroupId: {jobGroupResponse.Id}");
return; return;
} }
var scheduleResponse = new JobGroupScheduleResponse var scheduleResponse = new JobGroupScheduleResponse
{ {
//Timezone = settingsFromDb.ScheduleTimezone, //Timezone = settingsFromDb.ScheduleTimezone,
Timezone = scheduleResponseAreaTimeOffsetService.GetDefault.EsppValue, Timezone = _scheduleResponseAreaTimeOffsetRepository.GetDefault.EsppValue,
TypeSchedule = mapper.Map<EsppScheduleTypeScheduleResponse>(schedule.TypeSchedule), TypeSchedule = _mapper.Map<EsppScheduleTypeScheduleResponse>(schedule.TypeSchedule),
Values = mapper.Map<List<EsppScheduleValResponse>>(schedule.Values).OrderBy(t => t.Order).ToList() Values = _mapper.Map<List<EsppScheduleValResponse>>(schedule.Values).OrderBy(t => t.Order).ToList()
}; };
jobGroupResponse.Schedule = scheduleResponse; jobGroupResponse.Schedule = scheduleResponse;
jobGroupResponse.JobsCount = await jobService.Get().CountAsync(t => t.GroupId == jobGroupResponse.Id); jobGroupResponse.JobsCount = await _jobRepository.Get().CountAsync(t => t.GroupId == jobGroupResponse.Id);
jobGroupResponse.MatchingStatus = await GetMatchingStatusAsync(jobGroupResponse.Id); jobGroupResponse.MatchingStatus = await GetMatchingStatusAsync(jobGroupResponse.Id);
} }
@@ -506,7 +573,7 @@ namespace PARR.API.Controllers.V1
return null; return null;
// Если есть значение, смотрим, групповой ли тип работ, и если нет, то вернем null // Если есть значение, смотрим, групповой ли тип работ, и если нет, то вернем null
var groupingType = await jobGroupTypeService.Get().FirstAsync(t => t.Code == JobGroupTypesEnum.Group); var groupingType = await _jobGroupTypeRepository.Get().FirstAsync(t => t.Code == JobGroupTypesEnum.Group);
if (request.GroupTypeId == groupingType.Id) if (request.GroupTypeId == groupingType.Id)
{ {
// это групповой тип работ, все ок // это групповой тип работ, все ок
@@ -515,7 +582,7 @@ namespace PARR.API.Controllers.V1
else else
{ {
// Это не сгруппированный тип, обнуляем IsGroupByResponsible // Это не сгруппированный тип, обнуляем IsGroupByResponsible
logger.LogInformation("При сохраненни JobGroup, был передан IsGroupByResponsible: {IsGroupByResponsible}, но при этом, тип группы не сгруппированный, а GroupTypeId: {GroupTypeId}, обнулил IsGroupByResponsible", _logger.LogInformation("При сохраненни JobGroup, был передан IsGroupByResponsible: {IsGroupByResponsible}, но при этом, тип группы не сгруппированный, а GroupTypeId: {GroupTypeId}, обнулил IsGroupByResponsible",
request.IsGroupByResponsible, request.GroupTypeId); request.IsGroupByResponsible, request.GroupTypeId);
return null; return null;
} }
@@ -534,7 +601,7 @@ namespace PARR.API.Controllers.V1
return request.GroupingUnitFieldId; return request.GroupingUnitFieldId;
var groupingType = await jobGroupTypeService.Get().FirstAsync(t => t.Code == JobGroupTypesEnum.Group); var groupingType = await _jobGroupTypeRepository.Get().FirstAsync(t => t.Code == JobGroupTypesEnum.Group);
if (request.GroupTypeId == groupingType.Id) if (request.GroupTypeId == groupingType.Id)
{ {
@@ -544,7 +611,7 @@ namespace PARR.API.Controllers.V1
else else
{ {
// Это не сгруппированный тип, обнуляем GroupingUnitFieldId // Это не сгруппированный тип, обнуляем GroupingUnitFieldId
logger.LogInformation("При сохраненни JobGroup, был передан GroupingUnitFieldId: {GroupingUnitFieldId}, но при этом, тип группы не сгруппированный, а GroupTypeId: {GroupTypeId}, обнулил GroupingUnitFieldId", _logger.LogInformation("При сохраненни JobGroup, был передан GroupingUnitFieldId: {GroupingUnitFieldId}, но при этом, тип группы не сгруппированный, а GroupTypeId: {GroupTypeId}, обнулил GroupingUnitFieldId",
request.GroupingUnitFieldId, request.GroupTypeId); request.GroupingUnitFieldId, request.GroupTypeId);
return null; return null;
} }
@@ -558,9 +625,9 @@ namespace PARR.API.Controllers.V1
/// <returns></returns> /// <returns></returns>
private async Task<MatchingStatusResponse?> GetMatchingStatusAsync(Guid jobGroupId) private async Task<MatchingStatusResponse?> GetMatchingStatusAsync(Guid jobGroupId)
{ {
var statusMatching = await matchingStatusService.GetStatusAsync(jobGroupId, SyncTaskEntityTypeEnum.JobGroup); var statusMatching = await _matchingStatusRepository.GetStatusAsync(jobGroupId, SyncTaskEntityTypeEnum.JobGroup);
return mapper.Map<MatchingStatusResponse>(statusMatching); return _mapper.Map<MatchingStatusResponse>(statusMatching);
} }

14
PARR.API/Controllers/V1/JobGroupTypeController.cs
View File

@@ -17,23 +17,29 @@ namespace PARR.API.Controllers.V1
[Authorize(Roles = ParrRoles.Administrator.Role)] [Authorize(Roles = ParrRoles.Administrator.Role)]
public class JobGroupTypeController : BaseApiController public class JobGroupTypeController : BaseApiController
{ {
private readonly IJobGroupTypeRepository jobGroupTypeService; private readonly IJobGroupTypeRepository jobGroupTypeRepository;
private readonly IMapper mapper; private readonly IMapper mapper;
public JobGroupTypeController( public JobGroupTypeController(
IJobGroupTypeRepository jobGroupTypeService, IJobGroupTypeRepository jobGroupTypeRepository,
IMapper mapper IMapper mapper
) )
{ {
this.jobGroupTypeService = jobGroupTypeService; this.jobGroupTypeRepository = jobGroupTypeRepository;
this.mapper = mapper; this.mapper = mapper;
} }
/// <summary>
/// Получить список типов групп работ
/// </summary>
/// <returns></returns>
[HttpGet(ApiRoutes.JobGroupType.GetAll)] [HttpGet(ApiRoutes.JobGroupType.GetAll)]
public async Task<IActionResult> GetAll() public async Task<IActionResult> GetAll()
{ {
var query = jobGroupTypeService.Get().OrderBy(t => t.Description); var query = jobGroupTypeRepository.Get()
.AsNoTracking()
.OrderBy(t => t.Description);
var types = await query.ToListAsync(); var types = await query.ToListAsync();

2
PARR.API/Controllers/V1/ShortcodeApplyController.cs
View File

@@ -32,7 +32,7 @@ namespace PARR.API.Controllers.V1
/// <summary> /// <summary>
/// Получить список всех переменных составляющих /// Применить шорткод
/// </summary> /// </summary>
/// <returns></returns> /// <returns></returns>
[HttpPost(ApiRoutes.ShortcodeApply.Apply)] [HttpPost(ApiRoutes.ShortcodeApply.Apply)]

2
PARR.API/Controllers/V1/ShortcodeController.cs
View File

@@ -33,7 +33,7 @@ namespace PARR.API.Controllers.V1
/// <summary> /// <summary>
/// Получить список всех переменных составляющих /// Получить список всех переменных составляющих (список шорткодов)
/// </summary> /// </summary>
/// <returns></returns> /// <returns></returns>
[HttpGet(ApiRoutes.Shortcode.GetAll)] [HttpGet(ApiRoutes.Shortcode.GetAll)]

3
PARR.API/Controllers/V1/SyncTaskController.cs
View File

@@ -48,9 +48,6 @@ namespace PARR.API.Controllers.V1
[HttpPost(ApiRoutes.SyncTask.MatchTemplates)] [HttpPost(ApiRoutes.SyncTask.MatchTemplates)]
public async Task<IActionResult> MatchTemplatesForJob([FromBody] MatchTemplatesRequest request) public async Task<IActionResult> MatchTemplatesForJob([FromBody] MatchTemplatesRequest request)
{ {
//todo: Валидатор! Валидатор то забыли!!!
// проверяем, если уже идет синхронизация по этому объекту, то ахтунг, ошибка // проверяем, если уже идет синхронизация по этому объекту, то ахтунг, ошибка
var matchingStatus = await matchingStatusService.GetStatusAsync(request.ObjectId, request.EntityType); var matchingStatus = await matchingStatusService.GetStatusAsync(request.ObjectId, request.EntityType);
if (matchingStatus.IsMatchingObject) if (matchingStatus.IsMatchingObject)

4
PARR.API/MappingProfiles/DomainToResponseProfile.cs
View File

@@ -368,7 +368,8 @@ namespace PARR.API.MappingProfiles
.Include<JobGroup, JobGroupWithDistributionConfigResponse>() .Include<JobGroup, JobGroupWithDistributionConfigResponse>()
.ForMember(d => d.GroupType, o => o.MapFrom(s => s.GroupType)) .ForMember(d => d.GroupType, o => o.MapFrom(s => s.GroupType))
.ForMember(d => d.GroupingUnitField, o => o.MapFrom(s => s.GroupingUnitField)) .ForMember(d => d.GroupingUnitField, o => o.MapFrom(s => s.GroupingUnitField))
.ForMember(d => d.IsWorkGroupTimezone, o => o.MapFrom(s => s.IsResponseAreaTimezone)); .ForMember(d => d.IsWorkGroupTimezone, o => o.MapFrom(s => s.IsResponseAreaTimezone))
.ForMember(d => d.AutoControl, o => o.MapFrom(s => s.AutoControl));
CreateMap<JobGroup, JobGroupBaseResponse>() CreateMap<JobGroup, JobGroupBaseResponse>()
.ForMember(d => d.Name, o => o.MapFrom(s => s.GroupName)) .ForMember(d => d.Name, o => o.MapFrom(s => s.GroupName))
@@ -382,6 +383,7 @@ namespace PARR.API.MappingProfiles
.ForMember(d => d.ScheduleExcludeTypeCalendar, o => o.MapFrom(s => s.ScheduleExcludeTypeCalendar)); .ForMember(d => d.ScheduleExcludeTypeCalendar, o => o.MapFrom(s => s.ScheduleExcludeTypeCalendar));
//.ForMember(d => d.DistributionConfig, o => o.MapFrom(s => s.DistributionConfig)); //.ForMember(d => d.DistributionConfig, o => o.MapFrom(s => s.DistributionConfig));
CreateMap<JobGroupAutoControl, JobGroupAutoControlResponse>();
#endregion #endregion

4
PARR.API/MappingProfiles/RequestToDomainProfile.cs
View File

@@ -17,7 +17,11 @@ namespace PARR.API.MappingProfiles
CreateMap<JobRequest, Job>() CreateMap<JobRequest, Job>()
.ForMember(d => d.Id, o => o.MapFrom(s => Guid.NewGuid())) .ForMember(d => d.Id, o => o.MapFrom(s => Guid.NewGuid()))
.ForMember(d => d.IsParentRelationships, o => o.MapFrom(s => s.Relationships != null ? s.Relationships.IsParentRelationships : (bool?)null))
.ForMember(d => d.MaxValueRelationships, o => o.MapFrom(s => s.Relationships != null ? s.Relationships.MaxValueRelationships : (int?)null))
.ForMember(d => d.MinValueRelationships, o => o.MapFrom(s => s.Relationships != null ? s.Relationships.MinValueRelationships : (int?)null))
.ForMember(d => d.DateCreated, o => o.MapFrom(s => DateTimeOffset.UtcNow)) .ForMember(d => d.DateCreated, o => o.MapFrom(s => DateTimeOffset.UtcNow))
.ForMember(d => d.AutoControl, o => o.Ignore())
.AfterMap((s, d) => .AfterMap((s, d) =>
{ {
if (d.UnitFilters != null) if (d.UnitFilters != null)

33
PARR.API/Validators/JobAutoControlRequestValidator.cs
View File

@@ -1,33 +0,0 @@
using FluentValidation;
using PARR.API.Contracts.V1.Requests;
using PARR.Domain.Enums;
namespace PARR.API.Validators
{
public class JobAutoControlRequestValidator : AbstractValidator<JobAutoControlRequest>
{
public JobAutoControlRequestValidator()
{
RuleFor(t => t.EkMasks).Must(items =>
items.Count(t => t.Trim().Length > 0) > 0
).WithMessage("Должна быть указана хотя бы одна маска ЭК");
RuleFor(t => t.EnabledEkStatuses).Must(
items => items.Distinct().Count() == items.Count()
).WithMessage("Статусы ЭК не должны повторяться");
RuleFor(t => t.EnabledEkStatuses).Must(items =>
{
return !items.Any(item => !Enum.IsDefined(typeof(EkStatusEnum), item)) && !items.Any(t => t == 0);
})
.WithMessage($"Допустимые значения: {(int)EkStatusEnum.New} ({EkStatusEnum.New}), " +
$"{(int)EkStatusEnum.Preapre} ({EkStatusEnum.Preapre}), " +
$"{(int)EkStatusEnum.Exploitation} ({EkStatusEnum.Exploitation}), " +
$"{(int)EkStatusEnum.Repair} ({EkStatusEnum.Repair}), " +
$"{(int)EkStatusEnum.Reserve} ({EkStatusEnum.Reserve}), " +
$"{(int)EkStatusEnum.OutOfService} ({EkStatusEnum.OutOfService}), " +
$"{(int)EkStatusEnum.Test} ({EkStatusEnum.Test}), " +
$"{(int)EkStatusEnum.Development} ({EkStatusEnum.Development})");
}
}
}

45
PARR.API/Validators/JobGroupValidator.cs
View File

@@ -12,11 +12,11 @@ namespace PARR.API.Validators
public class JobGroupValidator : AbstractValidator<JobGroupRequest> public class JobGroupValidator : AbstractValidator<JobGroupRequest>
{ {
public JobGroupValidator( public JobGroupValidator(
IJobGroupTypeRepository jobGroupTypeService, IJobGroupTypeRepository jobGroupTypeRepository,
IUnitFieldRepository unitFieldService, IUnitFieldRepository unitFieldRepository,
IScheduleExcludeTypeRepository scheduleExcludeTypeService, IScheduleExcludeTypeRepository scheduleExcludeTypeRepository,
IScheduleExcludeTypeCalendarRepository scheduleExcludeTypeCalendarService, IScheduleExcludeTypeCalendarRepository scheduleExcludeTypeCalendarRepository,
IDistributionPeriodRepository distributionPeriodService IDistributionPeriodRepository distributionPeriodRepository
) )
{ {
RuleFor(t => t.Name) RuleFor(t => t.Name)
@@ -35,7 +35,7 @@ namespace PARR.API.Validators
.NotNull().NotEmpty(); .NotNull().NotEmpty();
RuleFor(t => t.GroupTypeId) RuleFor(t => t.GroupTypeId)
.MustAsync(async (entity, value, c) => await jobGroupTypeService.GetAsync(value) != null) .MustAsync(async (entity, value, c) => await jobGroupTypeRepository.GetAsync(value) != null)
.WithMessage("Указан несуществующий Id типа"); .WithMessage("Указан несуществующий Id типа");
//Проверяем существует ли такой GroupingUnitFieldId в unitField //Проверяем существует ли такой GroupingUnitFieldId в unitField
@@ -47,7 +47,7 @@ namespace PARR.API.Validators
return true; return true;
} }
return await unitFieldService.GetAsync(value.Value) != null; return await unitFieldRepository.GetAsync(value.Value) != null;
}) })
.WithMessage("Указано несуществующий Id поля"); .WithMessage("Указано несуществующий Id поля");
@@ -55,7 +55,7 @@ namespace PARR.API.Validators
RuleFor(t => t.GroupingUnitFieldId) RuleFor(t => t.GroupingUnitFieldId)
.MustAsync(async (entity, value, c) => .MustAsync(async (entity, value, c) =>
{ {
var groupingJobType = await jobGroupTypeService.Get().FirstAsync(t => t.Code == JobGroupTypesEnum.Group); var groupingJobType = await jobGroupTypeRepository.Get().FirstAsync(t => t.Code == JobGroupTypesEnum.Group);
// Если это сгруппированный тип, то у него обязательно должно быть заполнено поле GroupingUnitFieldId // Если это сгруппированный тип, то у него обязательно должно быть заполнено поле GroupingUnitFieldId
if (entity.GroupTypeId == groupingJobType.Id) if (entity.GroupTypeId == groupingJobType.Id)
@@ -68,14 +68,14 @@ namespace PARR.API.Validators
RuleFor(t => t.ScheduleExcludeTypeId) RuleFor(t => t.ScheduleExcludeTypeId)
.NotNull() .NotNull()
.NotEmpty() .NotEmpty()
.MustAsync(async (entity, value, c) => await scheduleExcludeTypeService.GetAsync(value) != null) .MustAsync(async (entity, value, c) => await scheduleExcludeTypeRepository.GetAsync(value) != null)
.WithMessage("Некорректное значение"); .WithMessage("Некорректное значение");
RuleFor(t => t.ScheduleExcludeTypeCalendarId) RuleFor(t => t.ScheduleExcludeTypeCalendarId)
.MustAsync(async (entity, value, c) => .MustAsync(async (entity, value, c) =>
{ {
// Если выбрано "Нет исключений", то это поле должно быть пустое, иначе, должно быть валидное значение // Если выбрано "Нет исключений", то это поле должно быть пустое, иначе, должно быть валидное значение
var type = await scheduleExcludeTypeService.GetAsync(entity.ScheduleExcludeTypeId); var type = await scheduleExcludeTypeRepository.GetAsync(entity.ScheduleExcludeTypeId);
if (type == null) if (type == null)
return false; return false;
@@ -89,7 +89,7 @@ namespace PARR.API.Validators
if (!value.HasValue) if (!value.HasValue)
return false; return false;
return await scheduleExcludeTypeCalendarService.GetAsync(value.Value) != null; return await scheduleExcludeTypeCalendarRepository.GetAsync(value.Value) != null;
}) })
.WithMessage("Некорректное значение"); .WithMessage("Некорректное значение");
@@ -115,7 +115,7 @@ namespace PARR.API.Validators
if (periodId.HasValue) if (periodId.HasValue)
{ {
var exist = await distributionPeriodService.GetAsync(periodId.Value); var exist = await distributionPeriodRepository.GetAsync(periodId.Value);
return exist != null; return exist != null;
} }
@@ -129,7 +129,26 @@ namespace PARR.API.Validators
// если IsResponseAreaTimezone == true, то поле UserTimeZoneOffsetMinutes обязательно. // если IsResponseAreaTimezone == true, то поле UserTimeZoneOffsetMinutes обязательно.
// если IsResponseAreaTimezone == false, то UserTimeZoneOffsetMinutes должно быть null // если IsResponseAreaTimezone == false, то UserTimeZoneOffsetMinutes должно быть null
return (entity.IsWorkGroupTimezone && value != null) || (!entity.IsWorkGroupTimezone && value == null); return (entity.IsWorkGroupTimezone && value != null) || (!entity.IsWorkGroupTimezone && value == null);
}).WithMessage("Некорректное значение."); ; }).WithMessage("Некорректное значение.");
RuleFor(t => t.AutoControl)
.MustAsync(async (entity, value, c) =>
{
// Автоконтроль разрешен только типам работ у которых включен IsJobGroupAutoControl
var isAllowedAutocontrol = await jobGroupTypeRepository.Get()
.AnyAsync(t => t.Id == entity.GroupTypeId && t.IsJobGroupAutoControl == true);
// Разрешен автоконтроль и есть значение
if (isAllowedAutocontrol && value != null)
return true;
// Запрещен автоконтроль и нет значения
if (!isAllowedAutocontrol && value == null)
return true;
return false;
})
.WithMessage("Некорректные параметры автоконтроля");
} }
} }

85
PARR.API/Validators/JobRequestValidator.cs
View File

@@ -1,31 +1,32 @@
using FluentValidation; using FluentValidation;
using Microsoft.EntityFrameworkCore;
using Newtonsoft.Json.Linq;
using PARR.API.Contracts.V1.Requests; using PARR.API.Contracts.V1.Requests;
using PARR.Core.Repositories.Interfaces; using PARR.Core.Repositories.Interfaces;
using PARR.Core.Repositories.Interfaces.Job; using PARR.Core.Repositories.Interfaces.Job;
using PARR.Core.Repositories.Interfaces.Unit; using PARR.Core.Repositories.Interfaces.Unit;
using PARR.Domain.Entities.JobGroupEntities;
namespace PARR.API.Validators namespace PARR.API.Validators
{ {
public class JobRequestValidator : AbstractValidator<JobRequest> public class JobRequestValidator : AbstractValidator<JobRequest>
{ {
private readonly ITnkRepository tnkService; private readonly ITnkRepository _tnkRepository;
private readonly IJobGroupRepository jobGroupService; private readonly IJobGroupRepository _jobGroupRepository;
private readonly IJobRepository jobRepository; private readonly IJobRepository _jobRepository;
private readonly IUnitFieldRepository unitFieldService; private readonly IUnitFieldRepository _unitFieldRepository;
private JobGroup? jobGroup; //private JobGroup? jobGroup;
public JobRequestValidator( public JobRequestValidator(
ITnkRepository tnkService, ITnkRepository tnkRepository,
IJobGroupRepository jobGroupService, IJobGroupRepository jobGroupRepository,
IJobRepository jobService, IJobRepository jobRepository,
IUnitFieldRepository unitFieldService IUnitFieldRepository unitFieldRepository
) )
{ {
this.tnkService = tnkService; _tnkRepository = tnkRepository;
this.jobGroupService = jobGroupService; _jobGroupRepository = jobGroupRepository;
this.jobRepository = jobService; _jobRepository = jobRepository;
this.unitFieldService = unitFieldService; _unitFieldRepository = unitFieldRepository;
RuleFor(t => t.Name) RuleFor(t => t.Name)
.NotNull().NotEmpty(); .NotNull().NotEmpty();
@@ -48,14 +49,54 @@ namespace PARR.API.Validators
.MustAsync(async (entity, value, c) => await IsUnitFiltersCorrect(entity)) .MustAsync(async (entity, value, c) => await IsUnitFiltersCorrect(entity))
.WithMessage("Неверно заданы параметры фильтров. Внимательнее, пожалуйста!"); .WithMessage("Неверно заданы параметры фильтров. Внимательнее, пожалуйста!");
RuleFor(t => t.MinValueRelationships) RuleFor(t => t.Relationships)
.GreaterThanOrEqualTo(0); .MustAsync(async (entity, value, c) =>
{
// Relationships должны быть обязательно заполнены если в типе работ IsRelationshipsAllowed==true
var relationshipsIsRequired = await jobGroupRepository.Get()
.AnyAsync(t => t.Id == entity.GroupId && t.GroupType!.IsRelationshipsAllowed, c);
if (relationshipsIsRequired && value != null)
return true;
if (!relationshipsIsRequired && value == null)
return true;
return false;
})
.WithMessage("Некорректные настройки кол-ва связей");
When(t => t.Relationships != null, () =>
{
RuleFor(t => t.Relationships!.MinValueRelationships)
.GreaterThanOrEqualTo(0);
RuleFor(t => t.Relationships!.MaxValueRelationships)
.GreaterThanOrEqualTo(t => t.Relationships!.MinValueRelationships);
});
RuleFor(t => t.MaxValueRelationships)
.GreaterThanOrEqualTo(t => t.MinValueRelationships);
RuleFor(t => t.ResponseAreaMask) RuleFor(t => t.ResponseAreaMask)
.NotNull().NotEmpty(); .NotNull().NotEmpty();
RuleFor(t => t.AutoControl)
.MustAsync(async (entity, value, c) =>
{
// Автоконтроль разрешен только типам работ, у которых выключен IsJobGroupAutoControl
var isAllowedJobAutocontrol = await jobGroupRepository.Get()
.AnyAsync(t => t.Id == entity.GroupId && t.GroupType!.IsJobGroupAutoControl == false, c);
// Разрешен автоконтроль и есть значение
if (isAllowedJobAutocontrol && value != null)
return true;
// Запрещен автоконтроль и нет значения
if (!isAllowedJobAutocontrol && value == null)
return true;
return false;
})
.WithMessage("Некорректные параметры автоконтроля");
} }
private async Task<bool> IsUnitFiltersCorrect(JobRequest entity) private async Task<bool> IsUnitFiltersCorrect(JobRequest entity)
@@ -72,7 +113,7 @@ namespace PARR.API.Validators
foreach (var fieldFilter in unitFilter.FieldFilters) foreach (var fieldFilter in unitFilter.FieldFilters)
{ {
var fieldId = fieldFilter.FieldId; var fieldId = fieldFilter.FieldId;
if (await unitFieldService.GetAsync(fieldId) == null) if (await _unitFieldRepository.GetAsync(fieldId) == null)
return false; return false;
} }
@@ -80,7 +121,7 @@ namespace PARR.API.Validators
foreach (var relationshipFilter in unitFilter.RelationshipFilters!) foreach (var relationshipFilter in unitFilter.RelationshipFilters!)
{ {
var fieldId = relationshipFilter.FieldId; var fieldId = relationshipFilter.FieldId;
if (await unitFieldService.GetAsync(fieldId) == null) if (await _unitFieldRepository.GetAsync(fieldId) == null)
return false; return false;
} }
} }
@@ -90,7 +131,7 @@ namespace PARR.API.Validators
private async Task<bool> IsGroupExist(JobRequest entity) private async Task<bool> IsGroupExist(JobRequest entity)
{ {
jobGroup = await jobGroupService.GetAsync(entity.GroupId); var jobGroup = await _jobGroupRepository.GetAsync(entity.GroupId);
return jobGroup != null; return jobGroup != null;
} }
@@ -98,7 +139,7 @@ namespace PARR.API.Validators
private async Task<bool> IsTnkExist(JobRequest entity) private async Task<bool> IsTnkExist(JobRequest entity)
{ {
return await tnkService.GetAsync(entity.TnkId) != null; return await _tnkRepository.GetAsync(entity.TnkId) != null;
} }
} }
} }

50
PARR.API/Validators/MatchTemplatesRequestValidator.cs Normal file
View File

@@ -0,0 +1,50 @@
using FluentValidation;
using Microsoft.EntityFrameworkCore;
using PARR.API.Contracts.V1.Requests;
using PARR.Core.Repositories.Interfaces;
using PARR.Core.Repositories.Interfaces.Job;
using PARR.Domain.Enums;
namespace PARR.API.Validators
{
public class MatchTemplatesRequestValidator : AbstractValidator<MatchTemplatesRequest>
{
public MatchTemplatesRequestValidator(
IJobGroupRepository jobGroupRepository,
IJobRepository jobRepository,
ITemplateRepository templateRepository
)
{
RuleFor(t => t.ObjectId)
.NotNull()
.NotEmpty()
.WithMessage("Идентификатор объекта не может быть пустым.");
RuleFor(t => t)
.MustAsync(async (request, cancellation) =>
{
return request.EntityType switch
{
SyncTaskEntityTypeEnum.JobGroup =>
await jobGroupRepository.Get().AsNoTracking().AnyAsync(t => t.Id == request.ObjectId, cancellation),
SyncTaskEntityTypeEnum.Job =>
await jobRepository.Get().AsNoTracking().AnyAsync(t => t.Id == request.ObjectId && t.Group!.GroupType!.IsJobGroupAutoControl == false, cancellation),
SyncTaskEntityTypeEnum.Template =>
false, // TODO: Синхронизировать шаблоны нельзя
_ => false
};
})
.WithMessage(request => request.EntityType switch
{
SyncTaskEntityTypeEnum.Template => "Синхронизация шаблонов пока не поддерживается.",
SyncTaskEntityTypeEnum.Job => "Объект не найден или данные работы нельзя отправить на синхронизацию.",
_ => "Не найден объект с переданным ИД."
});
}
}
}

2
PARR.Core/Common/Interfaces/RabbitServices/IRabbitService.cs
View File

@@ -24,6 +24,6 @@ namespace PARR.Core.Common.Interfaces.RabbitServices
/// <param name="mqSettings"></param> /// <param name="mqSettings"></param>
/// <param name="msgObjectList"></param> /// <param name="msgObjectList"></param>
/// <returns></returns> /// <returns></returns>
Task<RabbitSendResult> SendAsync(IMqSettings mqSettings, List<object> msgObjectList); Task<RabbitSendResult> SendAsync(IMqSettings mqSettings, IEnumerable<object> msgObjectList);
} }
} }

1
PARR.Core/Repositories/Interfaces/Job/IJobAutoControlRepository.cs
View File

@@ -5,5 +5,6 @@ namespace PARR.Core.Repositories.Interfaces.Job
public interface IJobAutoControlRepository public interface IJobAutoControlRepository
{ {
IQueryable<JobAutoControl> Get(); IQueryable<JobAutoControl> Get();
void RemoveRange(List<JobAutoControl> autoControlList);
} }
} }

6
PARR.DAL/Context/DataContext.cs
View File

@@ -179,9 +179,9 @@ namespace PARR.DAL.Context
modelBuilder.Entity<JobGroupType>(f => modelBuilder.Entity<JobGroupType>(f =>
{ {
f.HasData( f.HasData(
new() { Id = new Guid("4FA62E79-86BB-47C2-BE1A-72A716A170FA"), DateCreated = dateCreated, DateModified = null, Name = JobGroupTypesEnum.Simple.ToString(), Code = JobGroupTypesEnum.Simple, Description = "Обычный", IsAllowJobUnitFilter = true, IsJobGroupAutoControl = false }, new() { Id = new Guid("4FA62E79-86BB-47C2-BE1A-72A716A170FA"), DateCreated = dateCreated, DateModified = null, Name = JobGroupTypesEnum.Simple.ToString(), Code = JobGroupTypesEnum.Simple, Description = "Обычный", IsAllowJobUnitFilter = true, IsJobGroupAutoControl = false, IsRelationshipsAllowed = false },
new() { Id = new Guid("6EC58B1A-5C40-47B9-B036-4FA490E8D503"), DateCreated = dateCreated, DateModified = null, Name = JobGroupTypesEnum.Umbrella.ToString(), Code = JobGroupTypesEnum.Umbrella, Description = "Зонтик", IsAllowJobUnitFilter = false, IsJobGroupAutoControl = true }, new() { Id = new Guid("6EC58B1A-5C40-47B9-B036-4FA490E8D503"), DateCreated = dateCreated, DateModified = null, Name = JobGroupTypesEnum.Umbrella.ToString(), Code = JobGroupTypesEnum.Umbrella, Description = "Зонтик", IsAllowJobUnitFilter = false, IsJobGroupAutoControl = true, IsRelationshipsAllowed = true },
new() { Id = new Guid("318625E5-F833-436A-99DF-2A382A1E71C7"), DateCreated = dateCreated, DateModified = null, Name = JobGroupTypesEnum.Group.ToString(), Code = JobGroupTypesEnum.Group, Description = "Сгруппированный", IsAllowJobUnitFilter = false, IsJobGroupAutoControl = true } new() { Id = new Guid("318625E5-F833-436A-99DF-2A382A1E71C7"), DateCreated = dateCreated, DateModified = null, Name = JobGroupTypesEnum.Group.ToString(), Code = JobGroupTypesEnum.Group, Description = "Сгруппированный", IsAllowJobUnitFilter = false, IsJobGroupAutoControl = true, IsRelationshipsAllowed = true }
); );
}); });
#endregion #endregion

4021
PARR.DAL/Migrations/20260615235401_tblGroupTypesAddRelationshipsSettings.Designer.cs generated Normal file
View File

File diff suppressed because it is too large Load Diff

57
PARR.DAL/Migrations/20260615235401_tblGroupTypesAddRelationshipsSettings.cs Normal file
View File

@@ -0,0 +1,57 @@
using System;
using Microsoft.EntityFrameworkCore.Migrations;
#nullable disable
namespace PARR.DAL.Migrations
{
/// <inheritdoc />
public partial class tblGroupTypesAddRelationshipsSettings : Migration
{
/// <inheritdoc />
protected override void Up(MigrationBuilder migrationBuilder)
{
migrationBuilder.AddColumn<bool>(
name: "IsRelationshipsAllowed",
schema: "jobGroup",
table: "GroupTypes",
type: "boolean",
nullable: false,
defaultValue: false,
comment: "Разрешена настройка кол-ва связей");
migrationBuilder.UpdateData(
schema: "jobGroup",
table: "GroupTypes",
keyColumn: "Id",
keyValue: new Guid("318625e5-f833-436a-99df-2a382a1e71c7"),
column: "IsRelationshipsAllowed",
value: true);
migrationBuilder.UpdateData(
schema: "jobGroup",
table: "GroupTypes",
keyColumn: "Id",
keyValue: new Guid("4fa62e79-86bb-47c2-be1a-72a716a170fa"),
column: "IsRelationshipsAllowed",
value: false);
migrationBuilder.UpdateData(
schema: "jobGroup",
table: "GroupTypes",
keyColumn: "Id",
keyValue: new Guid("6ec58b1a-5c40-47b9-b036-4fa490e8d503"),
column: "IsRelationshipsAllowed",
value: true);
}
/// <inheritdoc />
protected override void Down(MigrationBuilder migrationBuilder)
{
migrationBuilder.DropColumn(
name: "IsRelationshipsAllowed",
schema: "jobGroup",
table: "GroupTypes");
}
}
}

7
PARR.DAL/Migrations/DataContextModelSnapshot.cs
View File

@@ -599,6 +599,10 @@ namespace PARR.DAL.Migrations
.HasColumnType("boolean") .HasColumnType("boolean")
.HasComment("Автоконтролем управляет JobGroup? true - да JobGroup, false - Job. Влияет на интерфейс и на логику работы автоконтроля."); .HasComment("Автоконтролем управляет JobGroup? true - да JobGroup, false - Job. Влияет на интерфейс и на логику работы автоконтроля.");
b.Property<bool>("IsRelationshipsAllowed")
.HasColumnType("boolean")
.HasComment("Разрешена настройка кол-ва связей");
b.Property<string>("Name") b.Property<string>("Name")
.IsRequired() .IsRequired()
.HasColumnType("text"); .HasColumnType("text");
@@ -619,6 +623,7 @@ namespace PARR.DAL.Migrations
Description = "Обычный", Description = "Обычный",
IsAllowJobUnitFilter = true, IsAllowJobUnitFilter = true,
IsJobGroupAutoControl = false, IsJobGroupAutoControl = false,
IsRelationshipsAllowed = false,
Name = "Simple" Name = "Simple"
}, },
new new
@@ -629,6 +634,7 @@ namespace PARR.DAL.Migrations
Description = "Зонтик", Description = "Зонтик",
IsAllowJobUnitFilter = false, IsAllowJobUnitFilter = false,
IsJobGroupAutoControl = true, IsJobGroupAutoControl = true,
IsRelationshipsAllowed = true,
Name = "Umbrella" Name = "Umbrella"
}, },
new new
@@ -639,6 +645,7 @@ namespace PARR.DAL.Migrations
Description = "Сгруппированный", Description = "Сгруппированный",
IsAllowJobUnitFilter = false, IsAllowJobUnitFilter = false,
IsJobGroupAutoControl = true, IsJobGroupAutoControl = true,
IsRelationshipsAllowed = true,
Name = "Group" Name = "Group"
}); });
}); });

5
PARR.DAL/Repositories/Job/JobAutoControlRepository.cs
View File

@@ -17,5 +17,10 @@ namespace PARR.DAL.Repositories.Job
{ {
return dataContext.JobAutoControls; return dataContext.JobAutoControls;
} }
public void RemoveRange(List<JobAutoControl> autoControlList)
{
dataContext.JobAutoControls.RemoveRange(autoControlList);
}
} }
} }

7
PARR.Domain/Entities/JobGroupEntities/JobGroupType.cs
View File

@@ -35,10 +35,17 @@ namespace PARR.Domain.Entities.JobGroupEntities
/// <summary> /// <summary>
/// Автоконтролем управляет JobGroup? true - да JobGroup, false - Job. /// Автоконтролем управляет JobGroup? true - да JobGroup, false - Job.
/// Влияет на интерфейс и на логику работы автоконтроля. /// Влияет на интерфейс и на логику работы автоконтроля.
/// Если true - то в GUI, кнопку синхронизировать можно нажать только в группах.
/// </summary> /// </summary>
[Comment("Автоконтролем управляет JobGroup? true - да JobGroup, false - Job. Влияет на интерфейс и на логику работы автоконтроля.")] [Comment("Автоконтролем управляет JobGroup? true - да JobGroup, false - Job. Влияет на интерфейс и на логику работы автоконтроля.")]
public bool IsJobGroupAutoControl { get; set; } = false; public bool IsJobGroupAutoControl { get; set; } = false;
/// <summary>
/// Разрешена настройка кол-ва связей
/// </summary>
[Comment("Разрешена настройка кол-ва связей")]
public bool IsRelationshipsAllowed { get; set; } = false;
public ICollection<JobGroup> JobGroups { get; set; } = new HashSet<JobGroup>(); public ICollection<JobGroup> JobGroups { get; set; } = new HashSet<JobGroup>();
} }
} }

2
PARR.Infrastructure/Rabbit/RabbitService.cs
View File

@@ -115,7 +115,7 @@ namespace PARR.Infrastructure.Rabbit
} }
} }
public async Task<RabbitSendResult> SendAsync(IMqSettings mqSettings, List<object> msgObjectList) public async Task<RabbitSendResult> SendAsync(IMqSettings mqSettings, IEnumerable<object> msgObjectList)
{ {
var msgStringList = msgObjectList.Select(t => JsonSerializer.Serialize(t, jsonOptions)).ToArray(); var msgStringList = msgObjectList.Select(t => JsonSerializer.Serialize(t, jsonOptions)).ToArray();

102
PARR.JobAutoControl/JobAutoControlManager.cs
View File

@@ -4,6 +4,7 @@ using Microsoft.Extensions.Logging;
using PARR.Core.Common.Interfaces; using PARR.Core.Common.Interfaces;
using PARR.Core.Common.Interfaces.RabbitServices; using PARR.Core.Common.Interfaces.RabbitServices;
using PARR.Core.Repositories.Interfaces.Job; using PARR.Core.Repositories.Interfaces.Job;
using PARR.Core.Repositories.Interfaces.JobGroupRepositories;
using PARR.Domain.Common.Rabbit.Messages; using PARR.Domain.Common.Rabbit.Messages;
using PARR.Domain.Entities.Base.History; using PARR.Domain.Entities.Base.History;
using PARR.Domain.Enums; using PARR.Domain.Enums;
@@ -13,11 +14,11 @@ namespace PARR.JobAutoControl
{ {
internal class JobAutoControlManager : IJobAutoControlManager internal class JobAutoControlManager : IJobAutoControlManager
{ {
private readonly WorkerSettings workerSettings; private readonly WorkerSettings _workerSettings;
private readonly ILogger<JobAutoControlManager> logger; private readonly ILogger<JobAutoControlManager> _logger;
private readonly IIntervalService intervalService; private readonly IIntervalService _intervalService;
private readonly IServiceProvider serviceProvider; private readonly IServiceProvider _serviceProvider;
private readonly MqSettings mqSettings; private readonly MqSettings _mqSettings;
public JobAutoControlManager( public JobAutoControlManager(
WorkerSettings workerSettings, WorkerSettings workerSettings,
@@ -27,68 +28,87 @@ namespace PARR.JobAutoControl
MqSettings mqSettings MqSettings mqSettings
) )
{ {
this.workerSettings = workerSettings; _workerSettings = workerSettings;
this.logger = logger; _logger = logger;
this.intervalService = intervalService; _intervalService = intervalService;
this.serviceProvider = serviceProvider; _serviceProvider = serviceProvider;
this.mqSettings = mqSettings; _mqSettings = mqSettings;
} }
public async Task StartAsync() public async Task StartAsync()
{ {
logger.LogInformation("Запуск сервиса управления авто-контролем РР (JobAutoControl)"); _logger.LogInformation("Запуск сервиса управления авто-контролем РР (JobAutoControl)");
await intervalService.IntervalInitAsync(async () => await _intervalService.IntervalInitAsync(async () =>
{ {
await using (var scope = serviceProvider.CreateAsyncScope()) await using (var scope = _serviceProvider.CreateAsyncScope())
//using (var scope = serviceProvider.CreateScope())
{ {
var jobAutoControlService = scope.ServiceProvider.GetService<IJobAutoControlRepository>(); var jobAutoControlRepository = scope.ServiceProvider.GetRequiredService<IJobAutoControlRepository>();
var mqService = scope.ServiceProvider.GetService<IRabbitService>(); var jobGroupAutoControlRepository = scope.ServiceProvider.GetRequiredService<IJobGroupAutoControlRepository>();
var mqService = scope.ServiceProvider.GetRequiredService<IRabbitService>();
if (jobAutoControlService == null || mqService == null) await HandlerAsync(jobAutoControlRepository, jobGroupAutoControlRepository, mqService);
throw new Exception($"Не смог получить серивс {nameof(IJobAutoControlRepository)} или {nameof(IRabbitService)}");
await HandlerAsync(jobAutoControlService, mqService);
} }
}, workerSettings.RepeatEvery); }, _workerSettings.RepeatEvery);
} }
private async Task HandlerAsync(IJobAutoControlRepository jobAutoControlService, IRabbitService mqService) private async Task HandlerAsync(IJobAutoControlRepository jobAutoControlRepository, IJobGroupAutoControlRepository jobGroupAutoControlRepository, IRabbitService mqService)
{ {
var jobsWithAutoControl = await jobAutoControlService.Get().Where(t => t.IsEnable).ToListAsync(); // Список JobGroup с включенным автоконтролем
var jobGroupsIds = await jobGroupAutoControlRepository.Get()
.AsNoTracking()
.Where(t => t.IsEnable)
.Select(t => t.JobGroupId)
.ToListAsync();
logger.LogInformation($"Работ с включенным авто-контролем: {jobsWithAutoControl.Count} шт."); // Список Job с включенным автоконтролем, но у которых в JobGroupType.IsJobGroupAutocOntrol==false
var jobIds = await jobAutoControlRepository.Get()
.AsNoTracking()
.Where(t => t.IsEnable && t.Job!.Group!.GroupType!.IsJobGroupAutoControl == false)
.Select(t => t.JobId)
.ToListAsync();
if (jobsWithAutoControl.Count == 0) _logger.LogInformation("Найдено объектов с включенным автоконтролем, групп: {JobGroupCount} шт., работ: {JobCount} шт.", jobGroupsIds.Count, jobIds.Count);
if (jobGroupsIds.Count == 0 && jobIds.Count == 0)
return; return;
// формируем сообщения // формируем сообщения
var msgList = jobsWithAutoControl.Select(t => new TemplateMatcherMq var msgList = new List<TemplateMatcherMq>(jobGroupsIds.Count + jobIds.Count);
var initiator = new HistoryInitiator
{
InitiatorComment = $"Инициатор авто-контроль, периодичность: {_workerSettings.RepeatEvery}",
InitiatorIp = null,
InitiatorParrComponentId = ParrComponentsEnum.JobAutoControl
};
// группы
msgList.AddRange(jobGroupsIds.Select(id => new TemplateMatcherMq
{
Action = TemplateMatcherActionEnum.Sync,
EntityType = SyncTaskEntityTypeEnum.JobGroup,
Id = id,
Initiator = initiator
}));
// работы
msgList.AddRange(jobIds.Select(id => new TemplateMatcherMq
{ {
Action = TemplateMatcherActionEnum.Sync, Action = TemplateMatcherActionEnum.Sync,
EntityType = SyncTaskEntityTypeEnum.Job, EntityType = SyncTaskEntityTypeEnum.Job,
Id = t.JobId, Id = id,
Initiator = new HistoryInitiator Initiator = initiator
{ }));
InitiatorComment = $"Инициатор авто-контроль, периодичность: {workerSettings.RepeatEvery}",
InitiatorIp = null,
InitiatorParrComponentId = ParrComponentsEnum.JobAutoControl
}
}).ToList();
//var msgStrList = msgList.Select(t => JsonSerializer.Serialize(t));
// отправляем задания в очередь template matcher`a // отправляем задания в очередь template matcher`a
//var sendResult = await mqService.SendAsync(mqSettings.TemplateMatcher, msgStrList.ToArray()); var sendResult = await mqService.SendAsync(_mqSettings.TemplateMatcher, msgList);
var sendResult = await mqService.SendAsync(mqSettings.TemplateMatcher, msgList.ToList<object>());
if (!sendResult.IsSuccess) if (!sendResult.IsSuccess)
logger.LogError($"Ошибка при отправке сообщений ({msgList.Count()} шт.) в очередь."); _logger.LogError("Ошибка при отправке сообщений ({Count} шт.) в очередь.", msgList.Count);
else else
logger.LogInformation($"Выполнена отправка сообщений в очередь, {msgList.Count()} шт."); _logger.LogInformation("Выполнена отправка сообщений в очередь, {Count} шт.", msgList.Count);
} }
} }

9
docker-compose.yml
View File

@@ -48,15 +48,16 @@ services:
# REDIS STACK # REDIS STACK
parr-redis: parr-redis:
image: redis/redis-stack:7.2.0-v6 #image: redis/redis-stack:7.2.0-v6
image: redis:8.8.0
restart: always restart: always
ports: ports:
- 6379:6379 - 6379:6379
volumes: volumes:
- parr_redis_data:/data - parr_redis_data:/data
#- parr_redis_config/redis.conf:/usr/local/etc/redis/redis.conf #environment:
environment: #- REDIS_ARGS=--requirepass ParrP@ssPtk202MMdevDvs
- REDIS_ARGS=--requirepass ParrP@ssPtk202MMdevDvs command: redis-server --requirepass ParrP@ssPtk202MMdevDvs
deploy: deploy:
replicas: 1 replicas: 1
networks: networks: