Архивация списков (#9)

Co-authored-by: gorbenko.pavel <gorbenko.pavel@tansu.kz>
Reviewed-on: http://git.tnsu.kz/timur.gorodetskiy/request-portal/pulls/9

src/webparts/requestPortal/forms/Clearance/ClearanceForm.tsx

@@ -16,22 +16,35 @@ import {
   StatusBadge,
   useMatrixEditor,
   getPlannedMatrix,
+  resolveWriteListId,
   notifyActiveStep,
   useRequestTypeId,
   REQUEST_STATUS,
   isEditableStatus,
   IApproverToWrite,
   APPROVAL_PHASE,
-  findUnassignedStep
+  unassignedStepMessage
 } from '../../shared/approval';
 import { IRequestFormProps } from '../../models/types';
-import { approvalListTitle, dataListTitle } from '../../shared/listTitles';
+import {
+  approvalListTitle,
+  approvalListTitleForListId,
+  dataListTitle,
+  dataListTitleForListId
+} from '../../shared/listTitles';
 import { FORM_ID, IFormData, EMPTY_DATA, SetField } from './model';
 import { saveClearanceRequest, clearanceApprovalService } from './submit';
 import { loadClearanceRequest } from './load';
 import { RequestSection } from './sections/RequestSection';
 
-const ClearanceForm: React.FC<IRequestFormProps> = ({ requestType, context, onCancel, onSaved, editId }) => {
+const ClearanceForm: React.FC<IRequestFormProps> = ({
+  requestType,
+  context,
+  onCancel,
+  onSaved,
+  editId,
+  editListId
+}) => {
   const [data, setData] = useState<IFormData>(EMPTY_DATA);
   const [requestId, setRequestId] = useState<number | undefined>(editId);
   const [requestStatus, setRequestStatus] = useState<string | undefined>(undefined);
@@ -41,7 +54,10 @@ const ClearanceForm: React.FC<IRequestFormProps> = ({ requestType, context, onCa
   const readOnly = !isEditableStatus(requestStatus);
   const set: SetField = (key, value) => setData((prev) => ({ ...prev, [key]: value }));
 
-  const approval = useMemo(() => clearanceApprovalService(), []);
+  // editListId уже проверен в EditFeature (см. её комментарий) — если бы партиции
+  // не нашлось в реестре, форма сюда вообще не смонтировалась бы, поэтому здесь
+  // clearanceApprovalService можно звать не опасаясь исключения.
+  const approval = useMemo(() => clearanceApprovalService(editListId), [editListId]);
   // pageUrl формы (requestType.id совпадает с ним по конвенции портала, см.
   // data/requests.ts) → числовой RequestTypeId, нужный approval-route API.
   const requestTypeIdState = useRequestTypeId(context, requestType.id);
@@ -53,7 +69,7 @@ const ClearanceForm: React.FC<IRequestFormProps> = ({ requestType, context, onCa
       return;
     }
     let alive = true;
-    loadClearanceRequest(editId)
+    loadClearanceRequest(editId, editListId)
       .then((loaded) => {
         if (alive) {
           setData(loaded.data);
@@ -70,7 +86,7 @@ const ClearanceForm: React.FC<IRequestFormProps> = ({ requestType, context, onCa
       alive = false;
     };
     // eslint-disable-next-line react-hooks/exhaustive-deps
-  }, [editId]);
+  }, [editId, editListId]);
 
   // Новая заявка — дата расторжения по умолчанию сегодняшняя (типичный случай:
   // обходной лист оформляют в день увольнения). При открытии на редактирование
@@ -174,13 +190,22 @@ const ClearanceForm: React.FC<IRequestFormProps> = ({ requestType, context, onCa
     if (!rtId) {
       throw new Error('Тип заявки не определён — обновите страницу и повторите.');
     }
+    // requestId уже задан → редактируем существующую заявку, пишем в ту же
+    // партицию (editListId). Иначе — создаём новую, и партицию для записи
+    // спрашиваем у approval-route ПРЯМО СЕЙЧАС (а не берём из кеша onInit):
+    // это единственный запрос, который проверяет порог элементов текущего
+    // списка и ставит в очередь создание следующей партиции при достижении —
+    // без него архивация никогда не сработает. Сбой запроса не должен
+    // блокировать подачу заявки — откатываемся на список по конвенции имён.
+    const writeListId = await resolveWriteListId(context, FORM_ID, rtId, requestId, editListId);
     const { id, code } = await saveClearanceRequest(
       requestId,
       rtId,
       data,
       toApprovers(matrix.rows),
       toApprovers(executors.rows),
-      status
+      status,
+      writeListId
     );
     setRequestId(id);
     setRequestStatus(status);
@@ -191,11 +216,14 @@ const ClearanceForm: React.FC<IRequestFormProps> = ({ requestType, context, onCa
       onSaved();
     }
     // Отправка на согласование — уведомляем первый активный шаг (поток оповещения).
+    // Имена списков — той же партиции, куда фактически записали (writeListId),
+    // не обязательно текущей на момент рендера формы: поток ищет строку
+    // маршрута именно в НЕЙ.
     if (status === REQUEST_STATUS.onApproval) {
       await notifyActiveStep(context, approval, id, {
         requestTypeId: rtId,
-        dataListName: dataListTitle(FORM_ID),
-        approvalListName: approvalListTitle(FORM_ID)
+        dataListName: writeListId ? dataListTitleForListId(FORM_ID, writeListId) : dataListTitle(FORM_ID),
+        approvalListName: writeListId ? approvalListTitleForListId(FORM_ID, writeListId) : approvalListTitle(FORM_ID)
       });
     }
   };
@@ -208,14 +236,16 @@ const ClearanceForm: React.FC<IRequestFormProps> = ({ requestType, context, onCa
     if (matrix.error) {
       return `Не удалось определить маршрут согласования: ${matrix.error}. Попробуйте ещё раз или обратитесь к администратору.`;
     }
-    const unassigned = findUnassignedStep(matrix.rows);
-    if (unassigned) {
-      return `Шаг ${unassigned.order} маршрута согласования («${unassigned.position || 'без должности'}») без назначенного человека — выберите согласующего или удалите шаг.`;
-    }
-    const unassignedExecutor = findUnassignedStep(executors.rows);
-    if (unassignedExecutor) {
-      return `Шаг ${unassignedExecutor.order} исполнения («${unassignedExecutor.position || 'без должности'}») без назначенного человека — выберите исполнителя или удалите шаг.`;
-    }
+    const unassignedApproverError = unassignedStepMessage(
+      matrix.rows,
+      (r) => `Шаг ${r.order} маршрута согласования («${r.position || 'без должности'}») без назначенного человека — выберите согласующего или удалите шаг.`
+    );
+    if (unassignedApproverError) return unassignedApproverError;
+    const unassignedExecutorError = unassignedStepMessage(
+      executors.rows,
+      (r) => `Шаг ${r.order} исполнения («${r.position || 'без должности'}») без назначенного человека — выберите исполнителя или удалите шаг.`
+    );
+    if (unassignedExecutorError) return unassignedExecutorError;
     return undefined;
   };
 
@@ -234,7 +264,12 @@ const ClearanceForm: React.FC<IRequestFormProps> = ({ requestType, context, onCa
       <FormCard
         title={requestType.title}
         subtitle="Категория: Отдел кадров"
-        belowSubtitle={<InitiatorLine listTitle={dataListTitle(FORM_ID)} itemId={requestId} />}
+        belowSubtitle={
+          <InitiatorLine
+            listTitle={editListId ? dataListTitleForListId(FORM_ID, editListId) : dataListTitle(FORM_ID)}
+            itemId={requestId}
+          />
+        }
         headerRight={
           requestId || requestStatus ? (
             <>

src/webparts/requestPortal/forms/Clearance/ClearanceView.tsx

@@ -13,7 +13,12 @@ import {
   useRequestTypeId,
   APPROVAL_PHASE
 } from '../../shared/approval';
-import { approvalListTitle, dataListTitle } from '../../shared/listTitles';
+import {
+  approvalListTitle,
+  approvalListTitleForListId,
+  dataListTitle,
+  dataListTitleForListId
+} from '../../shared/listTitles';
 import { FORM_ID, IFormData, EMPTY_DATA, SetField } from './model';
 import { loadClearanceRequest } from './load';
 import {
@@ -29,6 +34,8 @@ interface IClearanceViewProps {
   itemId: number;
   /** pageUrl формы — см. IApprovalViewProps в forms/viewRegistry.ts. */
   formKey: string;
+  /** Партиция, где лежит ЭТА заявка — см. IApprovalViewProps.listId. */
+  listId?: string;
 }
 
 type SaveState = 'idle' | 'saving' | 'saved' | 'error';
@@ -36,7 +43,7 @@ type SaveState = 'idle' | 'saving' | 'saved' | 'error';
 // Обходной лист в режиме согласующего. Форма read-only, КРОМЕ отметок, которые
 // заполняет профильный отдел на своём шаге: КДП — карта СКУД и сумма обучения,
 // отдел подбора — парковочная карта (см. approverRights.ts).
-const ClearanceView: React.FC<IClearanceViewProps> = ({ context, itemId, formKey }) => {
+const ClearanceView: React.FC<IClearanceViewProps> = ({ context, itemId, formKey, listId }) => {
   const [data, setData] = useState<IFormData>(EMPTY_DATA);
   const [status, setStatus] = useState<string>('');
   const [code, setCode] = useState<string>('');
@@ -48,12 +55,14 @@ const ClearanceView: React.FC<IClearanceViewProps> = ({ context, itemId, formKey
 
   const set: SetField = (key, value) => setData((prev) => ({ ...prev, [key]: value }));
 
-  const approval = useMemo(() => clearanceApprovalService(), []);
+  // listId уже проверен в ApproveFeature (не смонтировались бы сюда иначе) —
+  // clearanceApprovalService можно звать не опасаясь исключения.
+  const approval = useMemo(() => clearanceApprovalService(listId), [listId]);
   const { id: requestTypeId } = useRequestTypeId(context, formKey);
-  const approverService = useMemo(
-    () => new ApproverService(approval, dataListTitle(FORM_ID)),
-    [approval]
-  );
+  // Ref списка данных для ApproverService.updateRequestStatus: listId (url) для
+  // архивной партиции, Title текущей — иначе (см. ApproverService.dataListRef).
+  const dataListRef = listId || dataListTitle(FORM_ID);
+  const approverService = useMemo(() => new ApproverService(approval, dataListRef), [approval, dataListRef]);
 
   // Матрица маршрута из фактических строк заявки (read-only), раздельно по
   // фазам: согласование и исполнение — два отдельных блока в UI (см. ниже).
@@ -84,7 +93,7 @@ const ClearanceView: React.FC<IClearanceViewProps> = ({ context, itemId, formKey
   useEffect(() => {
     let alive = true;
     setLoading(true);
-    loadClearanceRequest(itemId)
+    loadClearanceRequest(itemId, listId)
       .then((loaded) => {
         if (alive) {
           setData(loaded.data);
@@ -103,7 +112,7 @@ const ClearanceView: React.FC<IClearanceViewProps> = ({ context, itemId, formKey
     return () => {
       alive = false;
     };
-  }, [itemId]);
+  }, [itemId, listId]);
 
   // Права на отметки — по должности ТЕКУЩЕГО активного шага пользователя.
   // isDelegator намеренно не даёт прав: делегировавший не решает за делегата
@@ -141,8 +150,8 @@ const ClearanceView: React.FC<IClearanceViewProps> = ({ context, itemId, formKey
     if (parkingEditable) {
       fields.ParkingCard = data.ParkingCard;
     }
-    return updateApproverFields(itemId, fields);
-  }, [itemId, hrRecordsEditable, parkingEditable, data.AccessCard, data.TrainingAmount, data.ParkingCard]);
+    return updateApproverFields(itemId, fields, listId);
+  }, [itemId, listId, hrRecordsEditable, parkingEditable, data.AccessCard, data.TrainingAmount, data.ParkingCard]);
 
   const handleSaveFields = async (): Promise<void> => {
     setSaveState('saving');
@@ -175,8 +184,8 @@ const ClearanceView: React.FC<IClearanceViewProps> = ({ context, itemId, formKey
     if (!requestTypeId) return;
     notifyActiveStep(context, approval, itemId, {
       requestTypeId,
-      dataListName: dataListTitle(FORM_ID),
-      approvalListName: approvalListTitle(FORM_ID)
+      dataListName: listId ? dataListTitleForListId(FORM_ID, listId) : dataListTitle(FORM_ID),
+      approvalListName: listId ? approvalListTitleForListId(FORM_ID, listId) : approvalListTitle(FORM_ID)
     }).catch(() => undefined);
   };
 
@@ -205,7 +214,12 @@ const ClearanceView: React.FC<IClearanceViewProps> = ({ context, itemId, formKey
         <FormCard
           title="Обходной лист"
           subtitle={`№${code || itemId}`}
-          belowSubtitle={<InitiatorLine listTitle={dataListTitle(FORM_ID)} itemId={itemId} />}
+          belowSubtitle={
+            <InitiatorLine
+              listTitle={listId ? dataListTitleForListId(FORM_ID, listId) : dataListTitle(FORM_ID)}
+              itemId={itemId}
+            />
+          }
           headerRight={status ? <StatusBadge status={status} /> : undefined}
         >
           <FormModeProvider readOnly>

src/webparts/requestPortal/forms/Clearance/load.ts

@@ -11,10 +11,17 @@ export interface ILoadedRequest {
   code: string;
 }
 
-/** Прочитать обходной лист по id: модель формы + статус (правка / просмотр). */
-export async function loadClearanceRequest(itemId: number): Promise<ILoadedRequest> {
-  const item = (await getSP()
-    .web.lists.getByTitle(dataListTitle(FORM_ID))
+/**
+ * Прочитать обходной лист по id: модель формы + статус (правка / просмотр).
+ *
+ * listId — партиция, где лежит ИМЕННО эта заявка (см. shared/approval/
+ * listPartitions.ts). Не задан — читаем из ТЕКУЩЕЙ партиции (как раньше); задан —
+ * идём напрямую по url списка, а не по имени: так не нужно резолвить, как
+ * называется архивный список, и запрос не зависит от реестра партиций.
+ */
+export async function loadClearanceRequest(itemId: number, listId?: string): Promise<ILoadedRequest> {
+  const list = listId ? getSP().web.getList(listId) : getSP().web.lists.getByTitle(dataListTitle(FORM_ID));
+  const item = (await list
     .items.getById(itemId)
     .select(
       'Id',

src/webparts/requestPortal/forms/Clearance/submit.ts

@@ -1,12 +1,15 @@
-import { getSP } from '../../shared/pnp/pnpjs';
-import { ApprovalListService, IApproverToWrite, writeRoute } from '../../shared/approval';
-import { buildRequestUniqueCode } from '../../shared/requestCode';
-import { approvalListTitle, dataListTitle } from '../../shared/listTitles';
+import { ApprovalListService, IApproverToWrite, approvalServiceFor, writeRoute } from '../../shared/approval';
+import { ISaveItemResult, resolveDataList, saveRequestItem } from '../../shared/dataList';
+import { ensureEmployee } from '../../shared/employee';
 import { FORM_ID, IFormData } from './model';
 
-/** Экземпляр сервиса списка согласования этой формы. */
-export function clearanceApprovalService(): ApprovalListService {
-  return new ApprovalListService(approvalListTitle(FORM_ID));
+/**
+ * Экземпляр сервиса списка согласования этой формы — тонкая обёртка над
+ * approvalServiceFor (см. shared/approval/approvalServiceFactory.ts), под
+ * именем формы для читаемости вызывающего кода.
+ */
+export function clearanceApprovalService(listId?: string): ApprovalListService {
+  return approvalServiceFor(FORM_ID, listId);
 }
 
 /** Отметки, которые проставляет не инициатор, а профильный согласующий (см. approverRights.ts). */
@@ -20,10 +23,14 @@ export interface IApproverEditableFields {
  * Обновить только те отметки, что заполняет согласующий на своём шаге.
  * Пишутся ровно переданные поля: у каждого отдела свой набор прав, и лишние
  * ключи затёрли бы чужие отметки значениями из формы этого согласующего.
+ *
+ * listId — партиция ОБНОВЛЯЕМОЙ заявки (см. loadClearanceRequest); не задан —
+ * текущая партиция, как раньше.
  */
 export async function updateApproverFields(
   id: number,
-  fields: Partial<IApproverEditableFields>
+  fields: Partial<IApproverEditableFields>,
+  listId?: string
 ): Promise<void> {
   const item: Record<string, unknown> = {};
   if (fields.AccessCard !== undefined) item.AccessCard = fields.AccessCard;
@@ -34,13 +41,8 @@ export async function updateApproverFields(
       Number.isFinite(amount) && fields.TrainingAmount.trim() !== '' ? amount : null;
   }
   if (Object.keys(item).length === 0) return;
-  await getSP().web.lists.getByTitle(dataListTitle(FORM_ID)).items.getById(id).update(item);
-}
-
-/** email / claims-логин → пользователь сайта (Id для Person-поля + Title для заголовка). */
-async function ensureEmployee(login: string): Promise<{ Id: number; Title: string }> {
-  const full = login.indexOf('|') >= 0 ? login : `i:0#.f|membership|${login}`;
-  return getSP().web.ensureUser(full);
+  const list = resolveDataList(FORM_ID, listId);
+  await list.items.getById(id).update(item);
 }
 
 function pad2(n: number): string {
@@ -69,16 +71,20 @@ function buildItem(data: IFormData, status: string, employeeId: number, employee
   };
 }
 
-export interface ISaveResult {
-  id: number;
-  /** Задан только при создании новой заявки (существующий код не меняется). */
-  code?: string;
-}
+export type ISaveResult = ISaveItemResult;
 
 /**
  * Сохранить обходной лист: содержимое + маршрут (согласование + исполнение).
  * existingId задан → обновляем ту же запись (черновик/доработка), иначе создаём новую.
  * Возвращает Id заявки (+ код при создании).
+ *
+ * listId — партиция, в которую фактически пишем: при редактировании — партиция
+ * ОБНОВЛЯЕМОЙ заявки (см. loadClearanceRequest), при создании — партиция,
+ * полученная от approval-route API непосредственно перед вызовом (см.
+ * getCurrentListPartition в ClearanceForm.tsx) — именно этот вызов, а не кеш из
+ * onInit, проверяет порог элементов и запускает архивацию следующей партиции.
+ * Не задан (сбой запроса за текущей партицией) → откат на список по конвенции
+ * имён, как до появления партиционирования.
  */
 export async function saveClearanceRequest(
   existingId: number | undefined,
@@ -86,25 +92,13 @@ export async function saveClearanceRequest(
   data: IFormData,
   approvers: IApproverToWrite[],
   executors: IApproverToWrite[],
-  status: string
+  status: string,
+  listId?: string
 ): Promise<ISaveResult> {
-  const list = getSP().web.lists.getByTitle(dataListTitle(FORM_ID));
   const employee = await ensureEmployee(data.Employee);
   const item = buildItem(data, status, employee.Id, employee.Title || data.Employee);
 
-  let id: number;
-  let code: string | undefined;
-  if (existingId) {
-    await list.items.getById(existingId).update(item);
-    id = existingId;
-  } else {
-    const added = await list.items.add(item);
-    id = (added as { Id: number }).Id;
-    // Код известен только после создания элемента (нужен его Id).
-    code = buildRequestUniqueCode(requestTypeId, id, new Date());
-    await list.items.getById(id).update({ RequestUniqueCode: code });
-  }
-
-  await writeRoute(clearanceApprovalService(), id, approvers, executors, status);
-  return { id, code };
+  const result = await saveRequestItem(FORM_ID, existingId, listId, requestTypeId, item);
+  await writeRoute(clearanceApprovalService(listId), result.id, approvers, executors, status);
+  return result;
 }