скелет готов

src/webparts/requestPortal/features/myRequests/myRequests.service.ts

@@ -42,6 +42,15 @@ const MP_APPROVER = 'TansuSiteApproverOWSUSER';
 // отладочным перебором 2026-08-06; у Person-полей он OWSUSER, см. MP_APPROVER).
 const MP_STATUS = 'RequestStatusOWSCHCS';
 
+// То же самое для Choice-колонки «Статус» списка ДАННЫХ (внутреннее имя Status,
+// см. forms/*/provisioning.json) — по ней отбираются «Доработка» и фильтр по
+// статусу в «Моих заявках». Кириллица в значении проблемы не создаёт: KQL — не
+// $filter (там она действительно подводит, см. indexApprovalsForType), и по
+// MP_STATUS выше точно так же ищутся русские статусы строк маршрута.
+// Если отбор по статусу вдруг начнёт стабильно возвращать 0 — проверять надо в
+// первую очередь ЭТО имя в схеме поиска (см. предупреждение в searchOwnRequests).
+const MP_TICKET_STATUS = 'StatusOWSCHCS';
+
 export function currentUserEmail(context: WebPartContext): string {
   return (context.pageContext.user.email || '').toLowerCase();
 }
@@ -60,6 +69,31 @@ export async function getLinkedTypes(context: WebPartContext): Promise<IRequestT
 //               пользователь участвует или будет участвовать.
 export type ApprovalScope = 'myTurn' | 'involved';
 
+// Очереди и истории, построенные на СТРОКАХ МАРШРУТА текущего пользователя.
+// Отличаются только набором статусов его строки — сам механизм (найти свои
+// строки → взять их заявки) общий, поэтому статусы вынесены в параметр, а не
+// зашиты в indexApprovalsForType.
+//
+//   approvals/execution — очереди действий: ход за пользователем прямо сейчас.
+//     Раньше обе выдавались одним разделом «На согласовании» (фильтр включал
+//     оба статуса сразу); теперь это РАЗНЫЕ разделы и пересечения между ними
+//     нет — заявка ровно в одном из них.
+//   approved/rejected/executed — история уже принятых им решений
+//     (подвкладки «Моих заявок»).
+export type ApprovalQueueKind = 'approvals' | 'execution' | 'approved' | 'rejected' | 'executed';
+
+const QUEUE_STATUSES: Record<ApprovalQueueKind, string[]> = {
+  approvals: [REQUEST_STATUS.onApproval],
+  execution: [REQUEST_STATUS.onExecution],
+  approved: [REQUEST_STATUS.approved],
+  rejected: [REQUEST_STATUS.rejected],
+  executed: [REQUEST_STATUS.executed],
+};
+
+// Статусы строки, означающие «ход за пользователем» — для счётчиков в меню
+// (обе очереди считаются за один проход, см. getMyTurnCounts).
+const MY_TURN_STATUSES: string[] = [REQUEST_STATUS.onApproval, REQUEST_STATUS.onExecution];
+
 // ---------------------------------------------------------------------------
 // «На согласовании» — раньше сюда приходилось читать ВЕСЬ список согласования
 // (иначе на клиенте нечем было посчитать «чья очередь»). Теперь очередь
@@ -93,13 +127,14 @@ const PENDING_PAGE_SIZE = 20;
 // см. filterPendingByQuery и вызывающую сторону в RequestsTableView).
 async function buildPendingIndex(
   context: WebPartContext,
-  scope: ApprovalScope
+  scope: ApprovalScope,
+  statuses: string[]
 ): Promise<{ types: IRequestType[]; index: IMyRequest[]; debug: IMyRequestsTypeDebug[] }> {
   const types = await getLinkedTypes(context);
   const tokenEmail = currentUserEmail(context);
 
   const perType = await Promise.all(
-    types.map((t) => indexApprovalsForType(context, t, tokenEmail, scope))
+    types.map((t) => indexApprovalsForType(context, t, tokenEmail, scope, statuses))
   );
 
   // Свежие сверху — типы объединяются в один список, сортировать нужно после слияния.
@@ -112,12 +147,12 @@ async function buildPendingIndex(
 
 // Без текстового поиска: страница нарезается ЗДЕСЬ (сервер решает, какие 20
 // заявок отдать), автор дочитывается только для них.
-export async function getPendingApproval(
+export async function getApprovalQueue(
   context: WebPartContext,
-  scope: ApprovalScope = 'myTurn',
+  kind: ApprovalQueueKind,
   page: number = 1
 ): Promise<IPendingApprovalPage> {
-  const { types, index, debug } = await buildPendingIndex(context, scope);
+  const { types, index, debug } = await buildPendingIndex(context, 'myTurn', QUEUE_STATUSES[kind]);
 
   const pageRows = index.slice((page - 1) * PENDING_PAGE_SIZE, page * PENDING_PAGE_SIZE);
   await hydrateAuthors(context, types, pageRows);
@@ -128,14 +163,59 @@ export async function getPendingApproval(
 // С текстовым поиском: полный индекс (без автора) — фильтрует его вызывающая
 // сторона через filterPendingByQuery, а страницу и автора берёт из уже
 // отфильтрованного результата (см. hydratePendingAuthors).
+//
+// Область поиска — та же, что и у самой вкладки (статусы очереди уходят в KQL):
+// раньше при вводе текста «На согласовании» расширялась до «где я вообще есть в
+// маршруте», но теперь для сквозного поиска есть отдельный раздел «Поиск», а
+// внутри вкладки предсказуемее искать по тому же набору, который в ней виден.
+export async function getApprovalQueueIndex(
+  context: WebPartContext,
+  kind: ApprovalQueueKind
+): Promise<{ rows: IMyRequest[]; types: IRequestType[]; debug: IMyRequestsTypeDebug[] }> {
+  const { types, index, debug } = await buildPendingIndex(context, 'involved', QUEUE_STATUSES[kind]);
+  return { rows: index, types, debug };
+}
+
+// Полный индекс «где я вообще есть в маршруте», без отбора по статусу — нужен
+// только разделу «Поиск» (см. searchMyRequests).
 export async function getPendingApprovalIndex(
   context: WebPartContext,
   scope: ApprovalScope
 ): Promise<{ rows: IMyRequest[]; types: IRequestType[]; debug: IMyRequestsTypeDebug[] }> {
-  const { types, index, debug } = await buildPendingIndex(context, scope);
+  const { types, index, debug } = await buildPendingIndex(context, scope, []);
   return { rows: index, types, debug };
 }
 
+/** Счётчики очередей для бокового меню. */
+export interface INavCounts {
+  approvals: number;
+  execution: number;
+  rework: number;
+}
+
+// «На согласовании» и «На исполнении» считаются за ОДИН проход: разделять их по
+// отдельным запросам значило бы дважды просканировать одни и те же списки
+// согласования. Статус своей строки приходит в myStepStatus (см.
+// indexApprovalsForType), по нему и разносим.
+//
+// «Доработка» живёт в других списках (данные, по автору), поэтому считается
+// своим запросом — но параллельно, и ровно тем же вызовом, что наполняет саму
+// вкладку: иначе счётчик и список могли бы разойтись.
+export async function getNavCounts(context: WebPartContext): Promise<INavCounts> {
+  const types = await getLinkedTypes(context);
+
+  const [turn, rework] = await Promise.all([
+    buildPendingIndex(context, 'myTurn', MY_TURN_STATUSES),
+    getOwnRequests(context, types, 1, REQUEST_STATUS.returned),
+  ]);
+
+  return {
+    approvals: turn.index.filter((r) => r.myStepStatus === REQUEST_STATUS.onApproval).length,
+    execution: turn.index.filter((r) => r.myStepStatus === REQUEST_STATUS.onExecution).length,
+    rework: rework.totalRows,
+  };
+}
+
 // Публичная обёртка над hydrateAuthors — для дочитывания автора по уже
 // отфильтрованной и нарезанной на страницу выборке (см. getPendingApprovalIndex).
 export async function hydratePendingAuthors(
@@ -156,7 +236,8 @@ async function indexApprovalsForType(
   context: WebPartContext,
   type: IRequestType,
   tokenEmail: string,
-  scope: ApprovalScope
+  scope: ApprovalScope,
+  statuses: string[]
 ): Promise<{ rows: IMyRequest[]; debug: IMyRequestsTypeDebug }> {
   const debug: IMyRequestsTypeDebug = {
     requestTypeId: type.id,
@@ -211,20 +292,15 @@ async function indexApprovalsForType(
         .select('Id', 'TicketId', 'RequestStatus')
         .top(2000)()) as Array<Record<string, unknown>>;
 
-      // Статусы уходят в KQL: сервер сразу отдаёт только активные строки,
+      // Статусы уходят в KQL: сервер сразу отдаёт только нужные строки,
       // а не всё, где пользователь есть в маршруте.
-      const searchRows = await getInvolvedRowsViaSearch(context, type, approvalList, [
-        REQUEST_STATUS.onApproval,
-        REQUEST_STATUS.onExecution,
-      ]);
+      const searchRows = await getInvolvedRowsViaSearch(context, type, approvalList, statuses);
       const seenIds = new Set(recentRows.map((r) => r.Id));
       const allRows = recentRows.concat(searchRows.filter((r) => !seenIds.has(r.Id)));
 
-      stepRows = allRows.filter(
-        (r) =>
-          r.RequestStatus === REQUEST_STATUS.onApproval ||
-          r.RequestStatus === REQUEST_STATUS.onExecution
-      );
+      // REST-довесок берётся по Modified без учёта статуса (кириллица в $filter
+      // ненадёжна, см. выше) — отбор по статусу делаем здесь, на клиенте.
+      stepRows = allRows.filter((r) => statuses.indexOf(r.RequestStatus as string) !== -1);
     } else {
       // 'involved' — используется ТОЛЬКО для текстового поиска (см.
       // getPendingApprovalIndex/searchMyRequests) — здесь важна не мгновенная
@@ -233,7 +309,7 @@ async function indexApprovalsForType(
       // давал неустойчивый результат (заявка то находилась, то нет, в
       // зависимости от того, успел ли Search её проиндексировать к моменту
       // REST-окна).
-      stepRows = await getInvolvedRowsViaSearch(context, type, approvalList);
+      stepRows = await getInvolvedRowsViaSearch(context, type, approvalList, statuses);
     }
 
     debug.approvalRowCount = stepRows.length;
@@ -243,6 +319,18 @@ async function indexApprovalsForType(
     const ticketIds = Array.from(
       new Set(stepRows.map((r) => r.TicketId as number | undefined).filter((id): id is number => !!id))
     );
+
+    // Статус СВОЕЙ строки по заявке — нужен, чтобы разнести заявки по очередям
+    // одним проходом (см. getMyTurnCounts). Если строк по заявке несколько,
+    // берём первую подошедшую: все они уже отобраны по statuses, а очередь у
+    // заявки на практике одна.
+    const stepStatusByTicket = new Map<number, string>();
+    stepRows.forEach((r) => {
+      const ticketId = r.TicketId as number | undefined;
+      if (ticketId && !stepStatusByTicket.has(ticketId)) {
+        stepStatusByTicket.set(ticketId, (r.RequestStatus as string) || '');
+      }
+    });
     if (ticketIds.length === 0) {
       debug.approvalPendingTickets = 0;
       return { rows: [], debug };
@@ -256,7 +344,10 @@ async function indexApprovalsForType(
       .select('Id', 'Title', 'Status', 'Created')
       .top(ticketIds.length)()) as Array<Record<string, unknown>>;
 
-    const rows = ticketRows.map((r) => toMyRequest(r, undefined, type, 'approval'));
+    const rows = ticketRows.map((r) => ({
+      ...toMyRequest(r, undefined, type, 'approval'),
+      myStepStatus: stepStatusByTicket.get(r.Id as number),
+    }));
 
     debug.approvalPendingTickets = rows.length;
     return { rows, debug };
@@ -494,19 +585,17 @@ async function loadByIds(
   return byKey;
 }
 
-// Свежие (созданные за последние RECENT_MS) заявки автора — обычным REST-ом,
-// в обход Search (индекс мог их ещё не подхватить). Без текстового запроса —
-// матчить название не нужно, отдаём как есть.
-async function getFreshOwnRowsForType(context: WebPartContext, type: IRequestType): Promise<IMyRequest[]> {
+// Последние OWN_REST_TOP заявок автора одного типа обычным REST-ом, в обход
+// Search — сырьё для довеска по свежести (см. getFreshOwnRowsForType).
+// Фильтруем только по AuthorId: статус в $filter не используем, потому что
+// кириллица в сравнении там уже подводила (см. indexApprovalsForType) — отбор
+// по статусу делает вызывающая сторона. В самом Search кириллица проблемой не
+// является, там статус уходит прямо в KQL (см. MP_TICKET_STATUS).
+async function getOwnRowsForType(context: WebPartContext, type: IRequestType): Promise<IMyRequest[]> {
   try {
     const sp = spForSite(type.siteUrl as string, context);
     const me = await sp.web.currentUser.select('Id')();
-    const cutoff = new Date(Date.now() - RECENT_MS).toISOString();
 
-    // Фильтруем только по AuthorId, а «свежая или черновик» решаем в JS: статус
-    // в $filter не используем, потому что кириллица в сравнении там уже подводила
-    // (см. indexApprovalsForType). Берём последние OWN_REST_TOP заявок автора —
-    // это его собственные записи, их немного, и запрос ограничен по объёму.
     const rows = (await sp.web
       .getList(type.listId as string)
       .items.filter(`AuthorId eq ${me.Id}`)
@@ -521,21 +610,28 @@ async function getFreshOwnRowsForType(context: WebPartContext, type: IRequestTyp
       );
     }
 
-    // Черновик берём ЛЮБОГО возраста: он живёт только у автора, правится часто и
-    // именно по нему индекс Search отстаёт заметнее всего, а увидеть свой
-    // черновик в «Моих заявках» пользователь ожидает сразу.
-    return rows
-      .filter((r) => {
-        const created = (r.Created as string) || '';
-        return r.Status === REQUEST_STATUS.draft || created >= cutoff;
-      })
-      .map((r) => toMyRequest(r, r.Author as { EMail?: string; Title?: string } | undefined, type, 'own'));
+    return rows.map((r) =>
+      toMyRequest(r, r.Author as { EMail?: string; Title?: string } | undefined, type, 'own')
+    );
   } catch (e) {
-    console.error(`[Текущие заявки] «${type.name}»: не удалось дочитать свежие заявки:`, (e as Error).message);
+    console.error(`[Текущие заявки] «${type.name}»: не удалось прочитать свои заявки:`, (e as Error).message);
     return [];
   }
 }
 
+// Свежие (созданные за последние RECENT_MS) заявки автора — довесок к Search,
+// индекс мог их ещё не подхватить.
+async function getFreshOwnRowsForType(context: WebPartContext, type: IRequestType): Promise<IMyRequest[]> {
+  const cutoff = new Date(Date.now() - RECENT_MS).toISOString();
+
+  // Черновик берём ЛЮБОГО возраста: он живёт только у автора, правится часто и
+  // именно по нему индекс Search отстаёт заметнее всего, а увидеть свой
+  // черновик в «Моих заявках» пользователь ожидает сразу.
+  return (await getOwnRowsForType(context, type)).filter(
+    (r) => r.status === REQUEST_STATUS.draft || r.created >= cutoff
+  );
+}
+
 // «Мои заявки» БЕЗ поиска — гибрид для масштаба: Search с серверной пагинацией
 // (RowLimit/StartRow) находит страницу без сканирования всего архива, REST по
 // «последним N минутам» добирает то, что Search мог не успеть проиндексировать
@@ -544,18 +640,20 @@ async function getFreshOwnRowsForType(context: WebPartContext, type: IRequestTyp
 export async function getOwnRequests(
   context: WebPartContext,
   types: IRequestType[],
-  page: number
+  page: number,
+  status: string = ''
 ): Promise<IOwnRequestsPage> {
   if (types.length === 0) return { rows: [], totalRows: 0 };
 
-  const searchPage = await searchOwnRequests(context, types, '', page);
+  const searchPage = await searchOwnRequests(context, types, '', page, status);
 
   if (page !== 1) return searchPage;
 
-  const freshRows = (await Promise.all(types.map((t) => getFreshOwnRowsForType(context, t)))).reduce(
-    (all, r) => all.concat(r),
-    [] as IMyRequest[]
-  );
+  // Довесок по свежести отбираем по статусу здесь: он приходит REST-ом, где
+  // сравнивать статус в $filter нельзя (кириллица), — зато набор маленький.
+  const freshRows = (await Promise.all(types.map((t) => getFreshOwnRowsForType(context, t))))
+    .reduce((all, r) => all.concat(r), [] as IMyRequest[])
+    .filter((r) => !status || r.status === status);
 
   const searchKeys = new Set(searchPage.rows.map((r) => `${r.requestTypeId}-${r.id}`));
   const onlyFresh = freshRows.filter((r) => !searchKeys.has(`${r.requestTypeId}-${r.id}`));
@@ -575,7 +673,8 @@ export async function searchOwnRequests(
   context: WebPartContext,
   types: IRequestType[],
   query: string,
-  page: number
+  page: number,
+  status: string = ''
 ): Promise<IOwnRequestsPage> {
   if (types.length === 0) return { rows: [], totalRows: 0 };
 
@@ -586,6 +685,9 @@ export async function searchOwnRequests(
     `(${types.map((t) => `Path:"${listAbsUrl(t)}*"`).join(' OR ')})`,
     `AuthorOWSUSER:"${claimsLogin}"`,
   ];
+  // Отбор по статусу заявки — на СЕРВЕРЕ, вместе с постраничностью: иначе
+  // пришлось бы вычитывать весь архив автора и резать его в памяти.
+  if (status) clauses.push(`${MP_TICKET_STATUS}:"${status}"`);
   const text = freeTextClause(query);
   if (text) clauses.push(text);
   const kql = clauses.join(' AND ');
@@ -601,12 +703,25 @@ export async function searchOwnRequests(
   });
 
 
+  const totalRows = results.TotalRows || 0;
+
+  // Отбор по статусу опирается на managed property, имя которой мы выводим по
+  // конвенции, а не читаем из схемы (см. MP_TICKET_STATUS). Если она названа
+  // иначе или не заведена, запрос отработает без ошибки и просто вернёт 0 —
+  // такое молчание слишком дорого отлаживать вслепую, поэтому подсказываем.
+  if (status && totalRows === 0) {
+    console.warn(
+      `[Мои заявки] По статусу «${status}» ничего не найдено. Если так на ЛЮБОМ статусе — ` +
+        `проверьте managed property «${MP_TICKET_STATUS}» в схеме поиска SharePoint.`
+    );
+  }
+
   const entries = hitsToEntries(results, types);
   const byKey = entries.length > 0 ? await loadByIds(context, entries, 'own') : new Map<string, IMyRequest>();
   // Порядок задаёт релевантность поиска, а не порядок ответов REST.
   const rows = entries.map((e) => byKey.get(`${e.type.id}-${e.id}`)).filter((r): r is IMyRequest => !!r);
 
-  return { rows, totalRows: results.TotalRows || 0 };
+  return { rows, totalRows };
 }
 
 // «На согласовании»: список заявок уже отобран по строкам согласования