diff --git a/.gitlab/issue_templates/Bug.md b/.gitlab/issue_templates/Bug.md
new file mode 100644
index 00000000..0136e78a
--- /dev/null
+++ b/.gitlab/issue_templates/Bug.md
@@ -0,0 +1,21 @@
+### 📋 Описание бага
+Кратко и понятно опишите, что идет не так.
+
+### 🔄 Шаги для воспроизведения
+1. Перейти на страницу...
+2. Нажать кнопку...
+3. Ввести в поле поиска...
+
+### ❌ Фактический результат
+Что произошло на самом деле? (Например: Приложение завершилось с ошибкой 500).
+
+### ✅ Ожидаемый результат
+Что должно было произойти? (Например: Появился список найденных товаров).
+
+### 🖥️ Окружение
+* **ОС:** Windows 11 / macOS Sequoia
+* **Браузер / Версия:** Chrome 124 / iOS App v2.1
+* **Стенд:** Staging / Production
+
+### 📎 Вложения
+Скриншоты, гифки или логи, которые помогают понять проблему.
diff --git a/PARR.API/Contracts/V1/Requests/JobAutoControlRequest.cs b/PARR.API/Contracts/V1/Requests/JobAutoControlRequest.cs
index 8f2f3113..3d144acf 100644
--- a/PARR.API/Contracts/V1/Requests/JobAutoControlRequest.cs
+++ b/PARR.API/Contracts/V1/Requests/JobAutoControlRequest.cs
@@ -1,52 +1,14 @@
-using PARR.Domain.Enums;
-
-namespace PARR.API.Contracts.V1.Requests
+namespace PARR.API.Contracts.V1.Requests
{
- public class JobAutoControlRequest
+ ///
+ /// Часть реквеста по управлению авто контролем для Job, JobGroup
+ ///
+ public record JobAutoControlRequest
{
- ///
- /// Создавать новые РР (из настроке РР)
- ///
- public bool CreateNew { get; set; }
+ public bool IsEnable { get; init; }
- ///
- /// Деактивировать не актуальные согласно ЭК (обратные статусы ЭК)
- ///
- public bool Deactivate { get; set; }
+ public bool InitUsedTemplateState { get; init; }
- ///
- /// Активировать РР после смены ЭК (согласно настройкам статусов ЭК)
- ///
- public bool Activate { get; set; }
-
- ///
- /// Состояние для активированных РР, шаблоны
- ///
- public bool OnTemplateIsActive { get; set; }
-
- ///
- /// Состояние для активированных РР, расписания
- ///
- public bool OnScheduleIsActive { get; set; }
-
- ///
- /// Состояние для деактивированных РР, шаблоны
- ///
- public bool OffTemplateIsActive { get; set; }
-
- ///
- /// Состояние для деактивированных РР, расписания
- ///
- public bool OffScheduleIsActive { get; set; }
-
- ///
- /// Маски ЭК
- ///
- public required List EkMasks { get; set; }
-
- ///
- /// Статусы ЭК для которых включена генерация РР и активация
- ///
- public required List EnabledEkStatuses { get; set; }
+ public bool InitUsedScheduleState { get; init; }
}
}
diff --git a/PARR.API/Contracts/V1/Requests/JobGroupRequest.cs b/PARR.API/Contracts/V1/Requests/JobGroupRequest.cs
index de37af25..672ae79f 100644
--- a/PARR.API/Contracts/V1/Requests/JobGroupRequest.cs
+++ b/PARR.API/Contracts/V1/Requests/JobGroupRequest.cs
@@ -1,47 +1,47 @@
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 Guid GroupTypeId { get; set; }
+ public Guid GroupTypeId { get; init; }
///
/// Поле по которому групиируем, если тип - ГРУППА
///
- 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; }
///
/// Использовать таймзону рабочей группы ответственного за ЭК шаблона
///
- 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; }
///
/// Настройки автораспределения
///
- public DistributionConfigRequest? DistributionConfig { get; set; }
+ public DistributionConfigRequest? DistributionConfig { get; init; }
//public bool IsAgent { get; set; }
@@ -51,28 +51,35 @@
//public string? AgentScript { get; set; }
- public List Schedule { get; set; } = new List();
+ public List Schedule { get; init; } = new List();
+
+ ///
+ /// Настройки автоконтроля (возможны только в случае, если JobGroupType.IsJobGroupAutocontrol==true)
+ ///
+ 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; }
///
/// Исключать выходные и праздники
///
- public bool IsExcludeWeekends { get; set; }
+ public bool IsExcludeWeekends { get; init; }
///
/// Группировать по рабочей группе
///
- public bool IsGroupingByWorkGroup { get; set; }
+ public bool IsGroupingByWorkGroup { get; init; }
}
+
+
}
diff --git a/PARR.API/Contracts/V1/Requests/JobRequest.cs b/PARR.API/Contracts/V1/Requests/JobRequest.cs
index 18dc4c92..77730073 100644
--- a/PARR.API/Contracts/V1/Requests/JobRequest.cs
+++ b/PARR.API/Contracts/V1/Requests/JobRequest.cs
@@ -1,79 +1,91 @@
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 UnitFilters { get; set; }
+ //#endregion
+
+ public JobAutoControlRequest? AutoControl { get; init; }
+
+ public required List 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
{
/////
///// Id = null в методе Create, в Update обязателен
/////
//public Guid? Id { get; set; }
- public required string UnitFilterMask { get; set; }
+ public required string UnitFilterMask { get; init; }
- public List? FieldFilters { get; set; }
+ public List? FieldFilters { get; init; }
- public List? RelationshipFilters { get; set; }
+ public List? 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; }
}
}
\ No newline at end of file
diff --git a/PARR.API/Contracts/V1/Responses/JobGroupResponse.cs b/PARR.API/Contracts/V1/Responses/JobGroupResponse.cs
index 40e0550f..af15d2cf 100644
--- a/PARR.API/Contracts/V1/Responses/JobGroupResponse.cs
+++ b/PARR.API/Contracts/V1/Responses/JobGroupResponse.cs
@@ -40,6 +40,8 @@
///
public bool IsAutoDistributionEnabled { get; set; }
+ public JobGroupAutoControlResponse? AutoControl { get; set; }
+
// public bool IsAgent { get; set; }
// public string? AgentName { get; set; }
@@ -74,6 +76,15 @@
//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 string Timezone { get; set; } = string.Empty;
diff --git a/PARR.API/Contracts/V1/Responses/JobGroupTypeResponse.cs b/PARR.API/Contracts/V1/Responses/JobGroupTypeResponse.cs
index ab36b909..f00e7eef 100644
--- a/PARR.API/Contracts/V1/Responses/JobGroupTypeResponse.cs
+++ b/PARR.API/Contracts/V1/Responses/JobGroupTypeResponse.cs
@@ -2,14 +2,20 @@
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; }
}
}
diff --git a/PARR.API/Controllers/V1/JobController.cs b/PARR.API/Controllers/V1/JobController.cs
index fd2903b6..279e2dbc 100644
--- a/PARR.API/Controllers/V1/JobController.cs
+++ b/PARR.API/Controllers/V1/JobController.cs
@@ -35,46 +35,43 @@ namespace PARR.API.Controllers.V1
[Authorize(Roles = ParrRoles.Administrator.Role)]
public class JobController : BaseApiController
{
- private readonly ILogger logger;
- private readonly IMapper mapper;
- private readonly IUriService uriService;
- private readonly IJobRepository jobService;
- private readonly ITemplateRepository templateService;
- //private readonly IValidator jobValidator;
- private readonly IRabbitService mqService;
- private readonly MqSettings mqSettings;
- private readonly IClientService clientService;
- private readonly IJobAutoControlRepository jobAutoControlService;
- private readonly IMatchingStatusService matchingStatusService;
+ private readonly ILogger _logger;
+ private readonly IMapper _mapper;
+ private readonly IUriService _uriService;
+ private readonly IJobRepository _jobRepository;
+ private readonly ITemplateRepository _templateRepository;
+ private readonly IRabbitService _mqService;
+ private readonly MqSettings _mqSettings;
+ private readonly IClientService _clientService;
+ private readonly IJobAutoControlRepository _jobAutoControlRepository;
+ private readonly IMatchingStatusService _matchingStatusService;
public JobController(
ILogger logger,
IMapper mapper,
IUriService uriService,
- IJobRepository jobService,
- ITemplateRepository templateService,
- IJobGroupRepository jobGroupService,
- //IValidator jobValidator,
- IUnitFilterService unitFilterService,
- IUnitRepository unitService,
+ IJobRepository jobRepository,
+ ITemplateRepository templateRepository,
+ IJobGroupRepository jobGroupRepository,
+ IUnitFilterService unitFilterRepository,
+ IUnitRepository unitRepository,
IRabbitService mqService,
MqSettings mqSettings,
IClientService clientService,
- IJobAutoControlRepository jobAutoControlService,
+ IJobAutoControlRepository jobAutoControlRepository,
IMatchingStatusService matchingStatusService
)
{
- this.logger = logger;
- this.mapper = mapper;
- this.uriService = uriService;
- this.jobService = jobService;
- this.templateService = templateService;
- //this.jobValidator = jobValidator;
- this.mqService = mqService;
- this.mqSettings = mqSettings;
- this.clientService = clientService;
- this.jobAutoControlService = jobAutoControlService;
- this.matchingStatusService = matchingStatusService;
+ _logger = logger;
+ _mapper = mapper;
+ _uriService = uriService;
+ _jobRepository = jobRepository;
+ _templateRepository = templateRepository;
+ _mqService = mqService;
+ _mqSettings = mqSettings;
+ _clientService = clientService;
+ _jobAutoControlRepository = jobAutoControlRepository;
+ _matchingStatusService = matchingStatusService;
}
///
@@ -84,18 +81,20 @@ namespace PARR.API.Controllers.V1
[HttpGet(ApiRoutes.Job.GetAll)]
public async Task GetAll([FromQuery] PaginationQuery paginationQuery, [FromQuery] JobQuery filter)
{
- var paginationFilter = mapper.Map(paginationQuery);
+ var paginationFilter = _mapper.Map(paginationQuery);
+
+ IQueryable query = _jobRepository.Get()
+ .Include(t => t.AutoControl);
- IQueryable query = jobService.Get().Include(t => t.AutoControl);
query = query.OrderBy(t => t.Name);
if (!string.IsNullOrEmpty(filter.Name))
{
//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)
query = query.Where(t => t.GroupId == filter.GroupId.Value);
@@ -107,9 +106,10 @@ namespace PARR.API.Controllers.V1
if (filter.IsFull)
{
query = query
- .Include(t => t.Tnk)
- .Include(t => t.Group).ThenInclude(t => t.GroupType)
- .Include(t => t.Group).ThenInclude(t => t.GroupingUnitField);
+ .Include(t => t.Tnk)
+ .Include(t => t.Group).ThenInclude(t => t.GroupType)
+ .Include(t => t.Group).ThenInclude(t => t.GroupingUnitField)
+ .Include(t => t.Group).ThenInclude(t => t.AutoControl);
query = query
.Include(t => t.UnitFilters)
@@ -120,12 +120,12 @@ namespace PARR.API.Controllers.V1
.ThenInclude(t => t.UnitField);
}
- var jobs = await jobService.GetPage(query, paginationFilter).ToListAsync();
+ var jobs = await _jobRepository.GetPage(query, paginationFilter).ToListAsync();
if (!jobs.Any())
return NoContent();
- var response = mapper.Map>(jobs);//TODO Migration to job
+ var response = _mapper.Map>(jobs);//TODO Migration to job
foreach (var jobResponse in response)
{
@@ -152,9 +152,10 @@ namespace PARR.API.Controllers.V1
[HttpGet(ApiRoutes.Job.Get)]
public async Task GetById([FromRoute] Guid id)
{
- var job = await jobService.Get()
+ var job = await _jobRepository.Get()
.Include(t => t.Tnk)
.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.UnitFilters)
.ThenInclude(t => t.FieldFilters)
@@ -168,7 +169,7 @@ namespace PARR.API.Controllers.V1
if (job == null)
return NotFound();
- var response = mapper.Map(job);
+ var response = _mapper.Map(job);
response.TemplatesCount = await GetCountTemplatesAsync(id); //await templateService.Get().CountAsync(t => t.JobId == id);
response.MatchingStatus = await GetMatchingStatusAsync(id);
@@ -188,51 +189,56 @@ namespace PARR.API.Controllers.V1
[HttpPost(ApiRoutes.Job.Create)]
public async Task Create([FromBody] JobRequest request)
{
- //#region Валидация
- //var jobValidateResult = await jobValidator.ValidateAsync(request);//Валидация параметров самого задания
+ #region Проверка существования работы с такими же настройками связей параметрами
- //if (!jobValidateResult.IsValid)
- // return BadRequest(new Response(jobValidateResult.Errors));
- //#endregion
+ if (request.Relationships != null)
+ {
+ //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
-
- #region Проверка существования работы с такими же параметрами
-
- 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 { new ErrorModel { FieldName = nameof(request.Name), Message = $"Работа с указанным диапазоном связей пересекается с уже имеющейся в базе данных({request.MinValueRelationships}-{request.MaxValueRelationships})" } }));
+ if (isExistTheSameLinks > 0)
+ return BadRequest(new Response(false, new List { new ErrorModel {
+ FieldName = nameof(request.Name),
+ Message = $"Работа с указанным диапазоном связей пересекается с уже имеющейся в базе данных({request.Relationships.MinValueRelationships}-{request.Relationships.MaxValueRelationships})"
+ } }));
+ }
#endregion
- var job = mapper.Map(request);
+ var job = _mapper.Map(request);
- job.AutoControl = new JobAutoControl
+ if (request.AutoControl != null)
{
- JobId = job.Id,
- IsEnable = request.IsEnableAutoControl,
- InitUsedScheduleState = request.InitUsedScheduleState,
- InitUsedTemplateState = request.InitUsedTemplateState
- };
+ // разрешен автоконтроль или нет, проверил в валидаторе
+ job.AutoControl = new JobAutoControl
+ {
+ 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 { 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.Group).ThenInclude(t => t.GroupType)
+ .Include(t => t.Group).ThenInclude(t => t.AutoControl)
.Include(t => t.Group).ThenInclude(t => t.GroupingUnitField)
.Include(t => t.UnitFilters)
.ThenInclude(t => t.FieldFilters)
@@ -242,9 +248,9 @@ namespace PARR.API.Controllers.V1
.Include(t => t.AutoControl)
.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(createdJob);
+ var response = _mapper.Map(createdJob);
// так как мы только что создали Job, то у него нет шаблонов, смело ставим = 0 (ускоряем запрос)
response.TemplatesCount = 0;
response.MatchingStatus = await GetMatchingStatusAsync(response.Id);
@@ -262,11 +268,7 @@ namespace PARR.API.Controllers.V1
[HttpPut(ApiRoutes.Job.Update)]
public async Task Update([FromRoute] Guid id, [FromBody] JobRequest request)
{
- //var resultValidate = await jobValidator.ValidateAsync(request);
- //if (!resultValidate.IsValid)
- // return BadRequest(new Response(resultValidate.Errors));
-
- var orig = await jobService.Get()
+ var orig = await _jobRepository.Get()
.Include(t => t.Tnk)
.Include(t => t.Group).ThenInclude(t => t.GroupType)
.Include(t => t.Group).ThenInclude(t => t.GroupingUnitField)
@@ -287,77 +289,77 @@ namespace PARR.API.Controllers.V1
//TODO: ВОТ ЭТО ВООБЩЕ МЫ БУДЕМ ПРОВЕРЯТЬ, АААА???? - Проверка существования работы с такими же параметрами
- //TODO: !!!!!!! проверить, если тип ЗОНТИК или ГРУППИРОВКА, то обязательно должны быть заполнены поля min max
-
#region обновление полей задания на работу
orig.Name = request.Name.Trim();
orig.WorkName = request.WorkName.Trim();
- orig.MinValueRelationships = request.MinValueRelationships;
- orig.MaxValueRelationships = request.MaxValueRelationships;
- orig.IsParentRelationships = request.IsParentRelationships;
+ orig.MinValueRelationships = request.Relationships?.MinValueRelationships;
+ orig.MaxValueRelationships = request.Relationships?.MaxValueRelationships;
+ orig.IsParentRelationships = request.Relationships?.IsParentRelationships;
orig.TemplateNameMask = request.TemplateNameMask.Trim();
orig.WorkGroupMask = request.WorkGroupMask.Trim();
orig.TnkId = request.TnkId;
orig.GroupId = request.GroupId;
orig.ResponseAreaMask = request.ResponseAreaMask.Trim();
- if (orig.AutoControl != null)
+ #region Настройки автоконтроля
+
+ // валидатор проверяет корректность
+ if (request.AutoControl != null)
{
- orig.AutoControl.IsEnable = request.IsEnableAutoControl;
- orig.AutoControl.InitUsedScheduleState = request.InitUsedScheduleState;
- orig.AutoControl.InitUsedTemplateState = request.InitUsedTemplateState;
- }
- else
- {
- // автоконтрол не загружен, проверяем есть ли он в бд, если нет, то создадим
- var existAutoControl = await jobAutoControlService.Get().FirstOrDefaultAsync(t => t.JobId == id);
- if (existAutoControl != null)
+ // Создаем новую запись или обновляем существующую
+ if (orig.AutoControl != null)
{
- logger.LogError($"При обновлении job {id}, не загрузась связь с JobAutoControl, но она есть. Не стал обновлять Job, вернул ошибку.");
- return BadRequest(new Response(false, new List { new ErrorModel { Message = $"Ошибка при изменении задания на выполнение работ." } }));
+ orig.AutoControl.IsEnable = request.AutoControl.IsEnable;
+ orig.AutoControl.InitUsedScheduleState = request.AutoControl.InitUsedScheduleState;
+ orig.AutoControl.InitUsedTemplateState = request.AutoControl.InitUsedTemplateState;
}
else
{
- var autoControl = new JobAutoControl
+ orig.AutoControl = new JobAutoControl
{
JobId = id,
- InitUsedScheduleState = request.InitUsedScheduleState,
- InitUsedTemplateState = request.InitUsedTemplateState,
- IsEnable = request.IsEnableAutoControl
+ InitUsedScheduleState = request.AutoControl.InitUsedScheduleState,
+ InitUsedTemplateState = request.AutoControl.InitUsedTemplateState,
+ IsEnable = request.AutoControl.IsEnable
};
- orig.AutoControl = autoControl;
- logger.LogWarning($"При обновлении job {id}, отсутствовала запись в таблице JobAutoControl, создал ее. {autoControl.ToJson()}");
}
}
+ else
+ {
+ // Удаляем настройки, скорей всего автоконтролем управляет группа работ
+ orig.AutoControl = null;
+ }
+ #endregion
orig.DateModified = DateTimeOffset.UtcNow;
#endregion
- var job = mapper.Map(request);
+ var job = _mapper.Map(request);
job.Id = id;//На всякий. Пусть будет для чистоты
UpdateUnitFilters(orig, job);//Обновление вложенных дочерних элементов-фильтров
- if (!await jobService.CommitAsync())
+ if (!await _jobRepository.CommitAsync())
return BadRequest(new Response(false, new List { new ErrorModel { Message = "Ошибка при изменении задания на выполнение работ." } }));
// если изменили маску, отправим задание на переименование связанных шаблонов
if (isChangedTemplateNameMask)
{
- var mqResult = await SendRequestToUpdateTemplates(id);
+ var mqResult = await SendRequestToUpdateTemplates(orig);
//todo: если ошибка. пользователя не предупреждаем... возможно ему это и не нужно знать...ну не переименуются шаблоны, может они переименуются позже...
}
- logger.LogInformation($"Пользователь {User.Identity?.Name} обновил задание на выполнение работ: {orig.Id}," +
+ _logger.LogInformation($"Пользователь {User.Identity?.Name} обновил задание на выполнение работ: {orig.Id}," +
$" {orig.Name}, {orig.WorkName}, {orig.MinValueRelationships}, {orig.MaxValueRelationships}," +
$" {orig.TemplateNameMask}, {orig.TnkId}, {nameof(orig.GroupId)}");
- var updatedJob = await jobService.Get()
+ var updatedJob = await _jobRepository.Get()
.Include(t => t.Tnk)
.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.UnitFilters)
.ThenInclude(t => t.FieldFilters)
@@ -367,7 +369,7 @@ namespace PARR.API.Controllers.V1
.Include(t => t.AutoControl)
.FirstAsync(t => t.Id == orig.Id);
- var response = mapper.Map(updatedJob);
+ var response = _mapper.Map(updatedJob);
response.TemplatesCount = await GetCountTemplatesAsync(id); //await templateService.Get().CountAsync(t => t.JobId == id);
response.MatchingStatus = await GetMatchingStatusAsync(id);
@@ -564,7 +566,7 @@ namespace PARR.API.Controllers.V1
[HttpDelete(ApiRoutes.Job.Delete)]
public async Task 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);
if (job == null)
@@ -572,19 +574,19 @@ namespace PARR.API.Controllers.V1
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)
return BadRequest(new Response(false, new List { new ErrorModel {
Message = $"Ошибка при удалении задания на выполнение работ. С данным заданием связаны шаблоны: {templateCount} шт."
} }));
- if (!jobService.Delete(job) || !await jobService.CommitAsync())
+ if (!_jobRepository.Delete(job) || !await _jobRepository.CommitAsync())
return BadRequest(new Response(false, new List { new ErrorModel {
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.TemplateNameMask}, {job.TnkId}, {job.GroupId}");
@@ -599,7 +601,7 @@ namespace PARR.API.Controllers.V1
///
private async Task GetStatisticsAsync(Guid jobId)
{
- var statResult = await jobService.Get()
+ var statResult = await _jobRepository.Get()
.Include(t => t.Templates)
.ThenInclude(t => t.RobotConfigurations)
.Where(x => x.Id == jobId)
@@ -629,35 +631,53 @@ namespace PARR.API.Controllers.V1
}
- private async Task SendRequestToUpdateTemplates(Guid jobId)
+ private async Task 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
{
- Id = jobId,
- EntityType = SyncTaskEntityTypeEnum.Job,
+ Id = Id,
+ EntityType = EntityType,
Action = TemplateMatcherActionEnum.Update,
Initiator = new HistoryInitiator
{
- InitiatorIp = clientService.GetClientIp()?.ToString(),
+ InitiatorIp = _clientService.GetClientIp()?.ToString(),
InitiatorParrComponentId = ParrComponentsEnum.Api,
InitiatorComment = $"В GUI изменено имя шаблона, при сохранении Job отправлен запрос на обновление связанных шаблонов"
}
};
- //var msg = JsonSerializer.Serialize(request);
+ var result = await _mqService.SendAsync(_mqSettings.TemplatesMatcher, new List