Несколько условий шага, объединяемых через И/ИЛИ (#16)

<html>
<body>
<!--StartFragment-->
GetEmployeeByEmailAsync возвращает массив; новый HeadType.CompanyDirectors
--

<!--EndFragment-->
</body>
</html>[GetEmployeeByEmailAsync возвращает массив; новый HeadType.CompanyDirectors](http://git.tnsu.kz/gorbenko.pavel/tnsu-approval-route/commit/572749b4d7cc11bc8e1ef4184a93f18a14b710ab)

---------

Co-authored-by: gorbenko.pavel <gorbenko.pavel@tansu.kz>
Reviewed-on: http://git.tnsu.kz/gorbenko.pavel/tnsu-approval-route/pulls/16

backend/Tnsu.ApprovalRoute.Application/TemplateRoutes/ResolveTemplateRouteDto.cs

@@ -13,6 +13,13 @@ namespace Tnsu.ApprovalRoute.Application.TemplateRoutes;
 /// <param name="AskOverdueReason">
 /// Спрашивать ли причину просрочки — так же с уже применённым наследованием.
 /// </param>
+/// <param name="PositionCode">
+/// HeadType шага (Chief/DirectionHead/DirectorTansu/ManagingDirectorTansu/DepartmentHead),
+/// если исполнитель задан типом руководителя, иначе null. В отличие от <see cref="Position"/>
+/// (реальная должность резолвнутого сотрудника из справочника api.tnsu.kz — свободный
+/// текст), это код роли из самого шага маршрута — чтобы вызывающая сторона могла отличить,
+/// например, «директора Tansu» от «руководителя направления», не разбирая Position текстом.
+/// </param>
 public sealed record ResolvedRouteStepDto(
     int Id,
     int OrderNo,
@@ -21,7 +28,8 @@ public sealed record ResolvedRouteStepDto(
     bool AllowReassignToOtherApprovers,
     string? Warning = null,
     int? SlaHours = null,
-    bool? AskOverdueReason = null);
+    bool? AskOverdueReason = null,
+    HeadType? PositionCode = null);
 
 public sealed record ResolveTemplateRouteResultDto(
     int RouteId,

backend/Tnsu.ApprovalRoute.Application/TemplateRoutes/TemplateRouteService.cs

@@ -142,18 +142,30 @@ public sealed class TemplateRouteService(
         if (requestType is null)
             return Result.Fail<ResolveTemplateRouteResultDto>(new NotFoundError("Тип заявки", request.RequestTypeId));
 
-        var employee = await portalClient.GetEmployeeByEmailAsync(email, cancellationToken);
-        if (employee is null)
+        // /Employee/ByEmail отдаёт массив: сотрудник может числиться в нескольких
+        // компаниях одновременно. Для поиска маршрута и большинства резолвов ниже
+        // используем ПЕРВУЮ запись — так же, как раньше, когда портал отдавал ровно
+        // одну. Все компании инициатора учитываются только в HeadType.CompanyDirectors
+        // (см. ResolveStepAsync) — это единственный сценарий, которому они нужны все.
+        var employees = await portalClient.GetEmployeeByEmailAsync(email, cancellationToken);
+        if (employees.Count == 0)
             return Result.Fail<ResolveTemplateRouteResultDto>(
                 new NotFoundError("Сотрудник в справочнике api.tnsu.kz по email", email));
 
+        var primaryEmployee = employees[0];
+        var initiatorCompanies = employees
+            .Select(e => e.Company)
+            .Where(c => !string.IsNullOrWhiteSpace(c))
+            .Distinct(StringComparer.OrdinalIgnoreCase)
+            .ToList();
+
         var byProject = request.ProjectId is not null;
 
         // Приоритет — маршрут с компанией инициатора; если для этой компании
         // своего маршрута нет, берём запасной маршрут без указанной компании
         // (тот же принцип, что уже применяется к отделу внутри FindRouteAsync).
-        var route = await FindRouteAsync(request.RequestTypeId, employee.CompanyId, employee.DepartmentId, byProject, cancellationToken)
-            ?? await FindRouteAsync(request.RequestTypeId, null, employee.DepartmentId, byProject, cancellationToken);
+        var route = await FindRouteAsync(request.RequestTypeId, primaryEmployee.CompanyId, primaryEmployee.DepartmentId, byProject, cancellationToken)
+            ?? await FindRouteAsync(request.RequestTypeId, null, primaryEmployee.DepartmentId, byProject, cancellationToken);
 
         if (route is null)
             return Result.Fail<ResolveTemplateRouteResultDto>(new NotFoundError(
@@ -189,7 +201,7 @@ public sealed class TemplateRouteService(
 
         var matchingSteps = route.Steps
             .Where(s => s.Status == request.Status)
-            .Where(s => MatchesCondition(s, fieldValues) || HasUnevaluatableManagerCondition(s, positionMissing))
+            .Where(s => MatchesConditions(s, fieldValues) || HasUnevaluatableManagerCondition(s, positionMissing))
             .OrderBy(s => s.OrderNo)
             .ToList();
 
@@ -200,17 +212,51 @@ public sealed class TemplateRouteService(
         // соответствует порядку задач, а не порядку завершения), поэтому
         // OrderBy(OrderNo) выше и CollapseByExecutorEmail ниже (ей важно, ЧЕЙ
         // дубликат считается первым) продолжают работать так же, как при
-        // последовательном foreach.
-        var steps = await Task.WhenAll(matchingSteps.Select(step => ResolveStepAsync(
-            step, email, employee.Company, projectExecutors, request.DepartmentId, requestType,
+        // последовательном foreach. Один шаг теперь может развернуться в НЕСКОЛЬКО
+        // строк результата (HeadType.CompanyDirectors — по одной на компанию
+        // инициатора), поэтому ResolveStepAsync возвращает список, а не одну dto,
+        // и результат нужно сначала сгладить (SelectMany).
+        var stepResults = await Task.WhenAll(matchingSteps.Select(step => ResolveStepAsync(
+            step, email, primaryEmployee.Company, initiatorCompanies, projectExecutors, request.DepartmentId, requestType,
             HasUnevaluatableManagerCondition(step, positionMissing) ? PositionMissingWarning : null,
             cancellationToken)));
 
-        var collapsedSteps = CollapseByExecutorEmail(steps);
+        var flattenedSteps = RemoveCompanyDirectorsDuplicatedByDirectorTansu(stepResults.SelectMany(x => x).ToList());
+        var collapsedSteps = CollapseByExecutorEmail(flattenedSteps);
 
         return Result.Ok(new ResolveTemplateRouteResultDto(route.Id, route.RequiresControl, collapsedSteps));
     }
 
+    /// <summary>
+    /// Директор Tansu (HeadType.DirectorTansu) сплошь и рядом совпадает с директором
+    /// ОДНОЙ из компаний инициатора (HeadType.CompanyDirectors) — обычно с ТОО TANSU
+    /// Construction. Оба шага в маршруте законны сами по себе, но если так, из
+    /// CompanyDirectors нужно убрать именно ЭТУ строку — не смешивать её с шагом
+    /// DirectorTansu через обычное схлопывание по email (см. CollapseByExecutorEmail):
+    /// тот считает разные PositionCode у одного email конфликтом и пишет
+    /// предупреждение, а здесь это не конфликт, а одно и то же лицо, просто
+    /// увиденное с двух сторон. Шаг DirectorTansu в маршруте обычно идёт последним
+    /// (после всех CompanyDirectors), поэтому удаление дубликата из CompanyDirectors
+    /// оставляет его на своём месте — в конце.
+    /// </summary>
+    private static IReadOnlyList<ResolvedRouteStepDto> RemoveCompanyDirectorsDuplicatedByDirectorTansu(
+        IReadOnlyList<ResolvedRouteStepDto> steps)
+    {
+        var directorTansuEmails = steps
+            .Where(s => s.PositionCode == HeadType.DirectorTansu && !string.IsNullOrWhiteSpace(s.ExecutorEmail))
+            .Select(s => s.ExecutorEmail!)
+            .ToHashSet(StringComparer.OrdinalIgnoreCase);
+
+        if (directorTansuEmails.Count == 0)
+            return steps;
+
+        return steps
+            .Where(s => s.PositionCode != HeadType.CompanyDirectors
+                || string.IsNullOrWhiteSpace(s.ExecutorEmail)
+                || !directorTansuEmails.Contains(s.ExecutorEmail))
+            .ToList();
+    }
+
     /// <summary>
     /// Маршрут для компании/отдела инициатора с фолбэком по отделу: сначала точное
     /// совпадение отдела, если такого маршрута нет — запасной маршрут без отдела
@@ -220,7 +266,7 @@ public sealed class TemplateRouteService(
     private async Task<TemplateRoute?> FindRouteAsync(
         int requestTypeId, Guid? companyId, Guid? departmentId, bool byProject, CancellationToken cancellationToken) =>
         await db.TemplateRoutes.AsNoTracking()
-            .Include(x => x.Steps)
+            .Include(x => x.Steps).ThenInclude(s => s.Conditions)
             .Where(x =>
                 x.RequestTypeId == requestTypeId &&
                 x.CompanyId == companyId &&
@@ -228,7 +274,7 @@ public sealed class TemplateRouteService(
                 x.DepartmentId == departmentId)
             .FirstOrDefaultAsync(cancellationToken)
         ?? await db.TemplateRoutes.AsNoTracking()
-            .Include(x => x.Steps)
+            .Include(x => x.Steps).ThenInclude(s => s.Conditions)
             .Where(x =>
                 x.RequestTypeId == requestTypeId &&
                 x.CompanyId == companyId &&
@@ -252,12 +298,104 @@ public sealed class TemplateRouteService(
     /// в ResolveAsync, а не здесь. Если исполнитель к тому же не резолвится — тексты
     /// склеиваются, а не затирают друг друга: это независимые проблемы одного шага.
     /// </param>
-    private async Task<ResolvedRouteStepDto> ResolveStepAsync(
-        TemplateRouteStep step, string initiatorEmail, string initiatorCompany,
+    /// <summary>
+    /// Название должности директора для конкретной компании — по умолчанию «Директор»,
+    /// но в части компаний руководителя называют иначе (нет штатной единицы «Директор»),
+    /// поэтому для HeadType.CompanyDirectors ищем по этому названию через
+    /// GetEmployeeByPositionAsync, а не по захардкоженному email, как DirectorTansu/
+    /// ManagingDirectorTansu. Список компаний-исключений захардкожен здесь же:
+    /// отдельного источника правды для него в системе нет.
+    /// </summary>
+    private static readonly IReadOnlyDictionary<string, string> DirectorPositionByCompany =
+        new Dictionary<string, string>(StringComparer.OrdinalIgnoreCase)
+        {
+            ["ТОО KazPromService"] = "Главный механик",
+            ["ТОО СТ Global"] = "Генеральный директор"
+        };
+
+    private const string DefaultDirectorPosition = "Директор";
+
+    private static string DirectorPositionFor(string company) =>
+        DirectorPositionByCompany.TryGetValue(company, out var position) ? position : DefaultDirectorPosition;
+
+    /// <summary>
+    /// Резолвит один шаг маршрута. Обычно возвращает ровно одну строку — но для
+    /// HeadType.CompanyDirectors может вернуть несколько (по одной на компанию
+    /// инициатора), все с одним и тем же OrderNo: они и так значились бы в одном
+    /// шаге, то есть параллельны по построению, а не потому что кто-то расставил
+    /// им одинаковый порядок вручную.
+    /// </summary>
+    /// <param name="initiatorCompanies">
+    /// ВСЕ компании инициатора (сотрудник может числиться в нескольких) — нужны
+    /// только для HeadType.CompanyDirectors. Остальные ветки резолва по-прежнему
+    /// используют одну <paramref name="initiatorCompany"/> (первую по счёту).
+    /// </param>
+    /// <param name="conditionWarning">
+    /// Предупреждение про УСЛОВИЕ шага (в отличие от предупреждений ниже, которые все про
+    /// неопределившегося исполнителя). Приходит снаружи, потому что условия проверяются
+    /// в ResolveAsync, а не здесь. Если исполнитель к тому же не резолвится — тексты
+    /// склеиваются, а не затирают друг друга: это независимые проблемы одного шага.
+    /// </param>
+    private async Task<IReadOnlyList<ResolvedRouteStepDto>> ResolveStepAsync(
+        TemplateRouteStep step, string initiatorEmail, string initiatorCompany, IReadOnlyList<string> initiatorCompanies,
         IReadOnlyList<ProjectExecutorInfo> projectExecutors, Guid? departmentId, RequestType requestType,
         string? conditionWarning,
         CancellationToken cancellationToken)
     {
+        // Наследование SLA применяется ЗДЕСЬ, а не у вызывающей стороны: `??`
+        // работает именно так, как задумано — значение шага перекрывает типовое,
+        // и при этом заданный на шаге 0 остаётся нулём, а не подменяется типовым
+        // (0 — осознанное «напоминать сразу», см. TemplateRouteStep.SlaHours).
+        async Task<ResolvedRouteStepDto> BuildDtoAsync(string? resolvedEmail, string? warning)
+        {
+            string? resolvedPosition = null;
+            if (!string.IsNullOrWhiteSpace(resolvedEmail))
+            {
+                var resolvedEmployees = await portalClient.GetEmployeeByEmailAsync(resolvedEmail, cancellationToken);
+                resolvedPosition = resolvedEmployees.FirstOrDefault()?.Position;
+            }
+
+            var combinedWarning = string.Join(" ", new[] { conditionWarning, warning }
+                .Where(w => !string.IsNullOrWhiteSpace(w)));
+
+            return new ResolvedRouteStepDto(
+                step.Id,
+                step.OrderNo,
+                resolvedEmail,
+                resolvedPosition,
+                step.AllowReassignToOtherApprovers,
+                combinedWarning.Length == 0 ? null : combinedWarning,
+                step.SlaHours ?? requestType.SlaHours,
+                step.AskOverdueReason ?? requestType.AskOverdueReason,
+                step.HeadType is null or HeadType.None ? null : step.HeadType);
+        }
+
+        // CompanyDirectors — единственная ветка, которая резолвится в несколько строк
+        // (по директору на каждую компанию инициатора), поэтому обрабатывается отдельно
+        // и до общего "одна строка на шаг" пути ниже.
+        if (step.HeadType == HeadType.CompanyDirectors)
+        {
+            if (initiatorCompanies.Count == 0)
+                return [await BuildDtoAsync(null, "Не удалось определить ни одной компании инициатора для поиска директоров.")];
+
+            var dtos = new List<ResolvedRouteStepDto>();
+            foreach (var company in initiatorCompanies)
+            {
+                var directorPosition = DirectorPositionFor(company);
+                var employeeByPosition = await portalClient.GetEmployeeByPositionAsync(directorPosition, company, cancellationToken);
+                var directorEmail = employeeByPosition.Email;
+                string? directorWarning = null;
+                if (!employeeByPosition.Found)
+                    directorWarning = $"Не найден сотрудник на должности «{directorPosition}» в компании «{company}».";
+                else if (string.IsNullOrWhiteSpace(directorEmail))
+                    directorWarning = $"Сотрудник {employeeByPosition.Fio} на должности «{directorPosition}» в компании «{company}» найден, но email не указан в системе портала.";
+
+                dtos.Add(await BuildDtoAsync(directorEmail, directorWarning));
+            }
+
+            return dtos;
+        }
+
         string? resolvedEmail;
         string? warning = null;
 
@@ -318,47 +456,33 @@ public sealed class TemplateRouteService(
             warning = "Не удалось определить исполнителя шага: не заполнено ни одно из полей.";
         }
 
-        string? resolvedPosition = null;
-        if (!string.IsNullOrWhiteSpace(resolvedEmail))
-        {
-            var resolvedEmployee = await portalClient.GetEmployeeByEmailAsync(resolvedEmail, cancellationToken);
-            resolvedPosition = resolvedEmployee?.Position;
-        }
-
-        // Наследование SLA применяется ЗДЕСЬ, а не у вызывающей стороны: `??`
-        // работает именно так, как задумано — значение шага перекрывает типовое,
-        // и при этом заданный на шаге 0 остаётся нулём, а не подменяется типовым
-        // (0 — осознанное «напоминать сразу», см. TemplateRouteStep.SlaHours).
-        var combinedWarning = string.Join(" ", new[] { conditionWarning, warning }
-            .Where(w => !string.IsNullOrWhiteSpace(w)));
-
-        return new ResolvedRouteStepDto(
-            step.Id,
-            step.OrderNo,
-            resolvedEmail,
-            resolvedPosition,
-            step.AllowReassignToOtherApprovers,
-            combinedWarning.Length == 0 ? null : combinedWarning,
-            step.SlaHours ?? requestType.SlaHours,
-            step.AskOverdueReason ?? requestType.AskOverdueReason);
+        return [await BuildDtoAsync(resolvedEmail, warning)];
     }
 
     /// <summary>
-    /// Условие шага (field_name/operation/value) против значений полей, переданных в resolve-запросе.
-    /// Шаг без условия применяется всегда. Шаг с условием, для которого не передано значение поля
-    /// (fieldValues его не содержит), считается неприменимым — при resolve мы моделируем конкретный
-    /// сценарий, и отсутствие значения означает, что условие не выполняется.
+    /// Условия шага против значений полей, переданных в resolve-запросе. Шаг без условий
+    /// применяется всегда. Несколько условий объединяются через <see cref="TemplateRouteStep.ConditionsLogic"/>:
+    /// И — должны выполниться все, ИЛИ — достаточно одного. Условие, для которого не передано
+    /// значение поля (fieldValues его не содержит), считается невыполненным — при resolve мы
+    /// моделируем конкретный сценарий, и отсутствие значения означает, что условие не выполняется.
     /// </summary>
-    private static bool MatchesCondition(TemplateRouteStep step, IReadOnlyDictionary<string, string> fieldValues)
+    private static bool MatchesConditions(TemplateRouteStep step, IReadOnlyDictionary<string, string> fieldValues)
     {
-        if (string.IsNullOrWhiteSpace(step.FieldName) || step.Operation is null or ComparisonOperator.None)
+        if (step.Conditions.Count == 0)
             return true;
 
-        if (!fieldValues.TryGetValue(step.FieldName, out var actual) || string.IsNullOrWhiteSpace(actual))
+        return step.ConditionsLogic == ConditionsLogic.Or
+            ? step.Conditions.Any(c => MatchesCondition(c, fieldValues))
+            : step.Conditions.All(c => MatchesCondition(c, fieldValues));
+    }
+
+    private static bool MatchesCondition(TemplateRouteStepCondition condition, IReadOnlyDictionary<string, string> fieldValues)
+    {
+        if (!fieldValues.TryGetValue(condition.FieldName, out var actual) || string.IsNullOrWhiteSpace(actual))
             return false;
 
-        var expected = step.Value;
-        return step.Operation switch
+        var expected = condition.Value;
+        return condition.Operation switch
         {
             ComparisonOperator.Equal => IsEqual(actual, expected),
             ComparisonOperator.NotEqual => !IsEqual(actual, expected),
@@ -399,14 +523,14 @@ public sealed class TemplateRouteService(
         "поэтому шаг включён в маршрут, хотя условие могло и не выполниться.";
 
     /// <summary>
-    /// Условие шага завязано на IsManager, но вычислить его не из чего: должность
-    /// в заявке не передана. Такой шаг попадает в результат вопреки условию и с
-    /// предупреждением — см. ResolveAsync.
+    /// Одно из условий шага завязано на IsManager, но вычислить его не из чего: должность
+    /// в заявке не передана. Такой шаг попадает в результат вопреки условиям и с
+    /// предупреждением — см. ResolveAsync. Не различаем И/ИЛИ и остальные условия шага:
+    /// раз про IsManager мы не знаем правду, итоговый матч шага в принципе ненадёжен.
     /// </summary>
     private static bool HasUnevaluatableManagerCondition(TemplateRouteStep step, bool positionMissing) =>
         positionMissing &&
-        string.Equals(step.FieldName, ManagerConditionField, StringComparison.OrdinalIgnoreCase) &&
-        step.Operation is not (null or ComparisonOperator.None);
+        step.Conditions.Any(c => string.Equals(c.FieldName, ManagerConditionField, StringComparison.OrdinalIgnoreCase));
 
     /// <summary>
     /// Должность — свободный текст без структуры (нет отдельного флага «это
@@ -423,17 +547,50 @@ public sealed class TemplateRouteService(
         !string.IsNullOrWhiteSpace(position) &&
         ManagerPositionKeywords.Any(keyword => position.Contains(keyword, StringComparison.OrdinalIgnoreCase));
 
+    /// <summary>
+    /// Один и тот же исполнитель, полученный из разных шагов, в результате должен
+    /// остаться один раз (иначе он одобрял бы одну заявку дважды) — но PositionCode
+    /// схлопнутой строки не должен молча потеряться. Если у уже сохранённой строки
+    /// он пуст, а у дубликата задан — переносим его на сохранённую строку. Если он
+    /// задан у обеих строк и они РАЗНЫЕ (один и тот же email получен через две
+    /// несовместимые роли шага, например Chief и CompanyDirectors одновременно) —
+    /// это не должно молча выбрать одну из них без следа: добавляем предупреждение
+    /// и оставляем любую (первую) — потерять исполнителя из-за такой неоднозначности
+    /// хуже, чем показать чуть неточный PositionCode с пояснением.
+    /// </summary>
     private static IReadOnlyList<ResolvedRouteStepDto> CollapseByExecutorEmail(IReadOnlyList<ResolvedRouteStepDto> steps)
     {
-        var seenEmails = new HashSet<string>(StringComparer.OrdinalIgnoreCase);
+        var indexByEmail = new Dictionary<string, int>(StringComparer.OrdinalIgnoreCase);
         var result = new List<ResolvedRouteStepDto>();
 
         foreach (var step in steps)
         {
-            if (!string.IsNullOrWhiteSpace(step.ExecutorEmail) && !seenEmails.Add(step.ExecutorEmail))
+            if (string.IsNullOrWhiteSpace(step.ExecutorEmail))
+            {
+                result.Add(step);
                 continue;
+            }
 
-            result.Add(step);
+            if (!indexByEmail.TryGetValue(step.ExecutorEmail, out var index))
+            {
+                indexByEmail[step.ExecutorEmail] = result.Count;
+                result.Add(step);
+                continue;
+            }
+
+            var existing = result[index];
+            if (existing.PositionCode is null && step.PositionCode is not null)
+            {
+                result[index] = existing with { PositionCode = step.PositionCode };
+            }
+            else if (existing.PositionCode is not null && step.PositionCode is not null && existing.PositionCode != step.PositionCode)
+            {
+                var conflictWarning =
+                    $"Исполнитель «{step.ExecutorEmail}» получен через разные роли шага ({existing.PositionCode} и {step.PositionCode}) — оставлен {existing.PositionCode}.";
+                var combinedWarning = string.Join(" ", new[] { existing.Warning, conflictWarning }
+                    .Where(w => !string.IsNullOrWhiteSpace(w)));
+                result[index] = existing with { Warning = combinedWarning };
+            }
         }
 
         return result;