Обходной лист (#12)

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

backend/Tnsu.ApprovalRoute.Application/Reminders/ApprovalRow.cs

@@ -11,7 +11,6 @@ namespace Tnsu.ApprovalRoute.Application.Reminders;
 internal sealed record ApprovalRow(
     int Id,
     int TicketId,
-    int StepOrder,
     string Status,
     string Phase,
     DateTimeOffset? Date,
@@ -31,7 +30,6 @@ internal sealed record ApprovalRow(
         return new ApprovalRow(
             TryGetInt(item, "Id", out var id) ? id : 0,
             ticketId,
-            TryGetInt(item, "StepOrder", out var order) ? order : 0,
             GetString(item, "ApprovalStatus") ?? string.Empty,
             // Пустая фаза — старые строки, заведённые до появления колонки;
             // трактуем как «Согласование» (так же поступает request-portal).

backend/Tnsu.ApprovalRoute.Application/Reminders/ReminderService.cs

@@ -23,10 +23,6 @@ public sealed class ReminderService(
     IOptions<RemindersOptions> options,
     ILogger<ReminderService> logger)
 {
-    // Ограничение на длину OData-фильтра: Id заявок подставляются пачками, иначе
-    // на большом списке получится неподъёмной длины URL.
-    private const int IdChunkSize = 50;
-
     // $filter по Choice-колонке — сравнение на равенство, а не текстовый поиск,
     // поэтому кавычки вокруг значения достаточно (в самих статусах нет апострофов).
     private const string ActiveStatusFilter =
@@ -81,7 +77,7 @@ public sealed class ReminderService(
             return [];
         }
 
-        // Шаг 1. Активные строки — прямым $filter по полю ApprovalStatus.
+        // Активные строки — прямым $filter по полю ApprovalStatus.
         //
         // Ранее здесь стоял Search по managed property (ApprovalStatusOWSCHCS) —
         // тот же приём, что в request-portal (см. MP_STATUS). На практике он
@@ -91,29 +87,28 @@ public sealed class ReminderService(
         // подтверждена, а вот результат — нет. Прямой $filter по полю сработал:
         // он не отстаёт от реального состояния списка (не зависит от индексации
         // вовсе), и подтверждённой на практике проблемы с ним на этом списке нет.
+        //
+        // Дата активации строки — прямо в ней самой (колонка Date): request-portal
+        // проставляет её в момент перехода строки в «На согласовании»/«На
+        // исполнении» (см. approvalList.service.ts/setActive) и никак иначе,
+        // поэтому больше не нужно ни читать весь маршрут заявки, ни дату
+        // создания заявки, ни выводить активацию из решений соседних шагов.
         var active = await ReadRowsAsync(siteUrl, approvalListTitle, ActiveStatusFilter, cancellationToken);
         if (active.Count == 0) return [];
 
-        // Шаг 2. По заявкам с активными строками нужны ВСЕ строки маршрута —
-        // дата активации шага выводится из дат решений предыдущего шага.
-        var ticketIds = active.Select(r => r.TicketId).Distinct().ToList();
-        var allRows = await ReadRowsByTicketsAsync(siteUrl, approvalListTitle, ticketIds, cancellationToken);
-        var rowsByTicket = allRows.GroupBy(r => r.TicketId).ToDictionary(g => g.Key, g => g.ToList());
-
-        var createdByTicket = await ReadCreatedAsync(siteUrl, type.ListId!, ticketIds, cancellationToken);
-
         var reminders = new List<ReminderDto>();
         foreach (var row in active)
         {
             if (string.IsNullOrWhiteSpace(row.ApproverEmail)) continue;
-            if (!rowsByTicket.TryGetValue(row.TicketId, out var ticketRows)) continue;
 
-            createdByTicket.TryGetValue(row.TicketId, out var created);
-            var activatedAt = ActivatedAt(row, ticketRows, created);
-            if (activatedAt is null)
+            if (row.Date is not { } activatedAt)
             {
+                // Строка активна, но Date пуста — так бывает у строк, заведённых
+                // ДО появления колонки (см. ApprovalRow) или если request-portal
+                // почему-то не проставил её при активации. Без даты старта SLA не
+                // от чего отсчитывать — пропускаем, а не подставляем сейчас.
                 logger.LogWarning(
-                    "Не удалось определить дату активации строки {Row} заявки {Ticket} — пропущена",
+                    "Строка {Row} заявки {Ticket} активна, но дата активации (Date) не заполнена — пропущена",
                     row.Id, row.TicketId);
                 continue;
             }
@@ -121,7 +116,7 @@ public sealed class ReminderService(
             // SLA строки перекрывает типовой. У строк, созданных до появления
             // колонки, значения нет — тогда работает SLA типа заявки.
             var slaHours = row.SlaHours ?? type.SlaHours!.Value;
-            var deadline = activatedAt.Value.AddHours(slaHours);
+            var deadline = activatedAt.AddHours(slaHours);
             if (deadline >= now) continue;
 
             reminders.Add(new ReminderDto(
@@ -137,51 +132,6 @@ public sealed class ReminderService(
         return reminders;
     }
 
-    /// <summary>
-    /// Момент, с которого шаг считается активным, — начало отсчёта SLA.
-    ///
-    /// Отдельной колонки «когда шаг стал активным» в списке нет (активация — это
-    /// точечное обновление статуса, дату оно не пишет), поэтому момент выводится
-    /// из соседних строк:
-    ///  • первый шаг согласования — дата создания заявки;
-    ///  • первый шаг исполнения — последнее решение по фазе согласования
-    ///    (фаза исполнения активируется только когда согласование пройдено целиком);
-    ///  • остальные шаги — последнее решение по предыдущему шагу СВОЕЙ фазы.
-    ///
-    /// Везде именно MAX даты, а не «дата предыдущей строки»: шаг могут делить
-    /// несколько параллельных согласующих с одинаковым StepOrder, и следующий шаг
-    /// активируется только после решения последнего из них.
-    ///
-    /// «Предыдущий шаг» ищется как ближайший меньший существующий StepOrder, а не
-    /// как order-1: в нумерации бывают пропуски (шаг удалили, шаг не подошёл по
-    /// условию появления).
-    /// </summary>
-    private static DateTimeOffset? ActivatedAt(
-        ApprovalRow row, IReadOnlyList<ApprovalRow> ticketRows, DateTimeOffset? requestCreated)
-    {
-        var samePhase = ticketRows.Where(r => r.Phase == row.Phase).ToList();
-        var isFirstInPhase = samePhase.All(r => r.StepOrder >= row.StepOrder);
-
-        if (isFirstInPhase)
-        {
-            return row.Phase == ApprovalPhases.Execution
-                ? LastDecisionOf(ticketRows.Where(r => r.Phase == ApprovalPhases.Approval))
-                : requestCreated;
-        }
-
-        var previousOrder = samePhase
-            .Where(r => r.StepOrder < row.StepOrder)
-            .Max(r => r.StepOrder);
-
-        return LastDecisionOf(samePhase.Where(r => r.StepOrder == previousOrder));
-    }
-
-    private static DateTimeOffset? LastDecisionOf(IEnumerable<ApprovalRow> rows)
-    {
-        var dates = rows.Select(r => r.Date).Where(d => d is not null).Select(d => d!.Value).ToList();
-        return dates.Count == 0 ? null : dates.Max();
-    }
-
     /// <summary>
     /// Ссылка ведёт в тот раздел портала, которому принадлежит просроченный шаг:
     /// исполнителя незачем высаживать в «На согласовании». Сама заявка всё равно
@@ -207,7 +157,7 @@ public sealed class ReminderService(
     }
 
     private const string RowSelect =
-        "$select=Id,ApprovalStatus,StepOrder,Phase,Date,SLAhours,AskOverdueReason,TicketId," +
+        "$select=Id,ApprovalStatus,Phase,Date,SLAhours,AskOverdueReason,TicketId," +
         "TansuSiteApprover/EMail&$expand=TansuSiteApprover&$top=5000";
 
     private async Task<IReadOnlyList<ApprovalRow>> ReadRowsAsync(
@@ -219,43 +169,6 @@ public sealed class ReminderService(
         return Parse(items);
     }
 
-    private async Task<IReadOnlyList<ApprovalRow>> ReadRowsByTicketsAsync(
-        string siteUrl, string listTitle, IReadOnlyList<int> ticketIds, CancellationToken cancellationToken)
-    {
-        var rows = new List<ApprovalRow>();
-        foreach (var chunk in ticketIds.Chunk(IdChunkSize))
-        {
-            var filter = "$filter=" + string.Join(" or ", chunk.Select(id => $"TicketId eq {id}"));
-            rows.AddRange(await ReadRowsAsync(siteUrl, listTitle, filter, cancellationToken));
-        }
-
-        return rows;
-    }
-
-    /// <summary>Даты создания заявок — начало отсчёта для первого шага согласования.</summary>
-    private async Task<Dictionary<int, DateTimeOffset>> ReadCreatedAsync(
-        string siteUrl, string listUrl, IReadOnlyList<int> ids, CancellationToken cancellationToken)
-    {
-        var created = new Dictionary<int, DateTimeOffset>();
-
-        foreach (var chunk in ids.Chunk(IdChunkSize))
-        {
-            var query = "$select=Id,Created&$top=5000&$filter=" +
-                        string.Join(" or ", chunk.Select(id => $"Id eq {id}"));
-
-            var items = await sharePoint.GetItemsByListUrlAsync(siteUrl, listUrl, query, cancellationToken);
-            foreach (var item in items)
-            {
-                if (!item.TryGetProperty("Id", out var idValue) || !idValue.TryGetInt32(out var id)) continue;
-                if (!item.TryGetProperty("Created", out var createdValue)) continue;
-                if (createdValue.ValueKind != JsonValueKind.String) continue;
-                if (DateTimeOffset.TryParse(createdValue.GetString(), out var parsed)) created[id] = parsed;
-            }
-        }
-
-        return created;
-    }
-
     private static List<ApprovalRow> Parse(IEnumerable<JsonElement> items) =>
         items.Select(ApprovalRow.TryParse).Where(r => r is not null).Select(r => r!).ToList();
 }