' +
'▾' +
'📄 Договор №' + escHtml(g.contract_number || '?') + ' — ' + escHtml(g.counterparty || 'контрагент не определён') +
@@ -475,16 +493,15 @@ function markGroupDone(gi, time) {
}
// Текущий активный EventSource (только один одновременно)
-var _activeCompareES = null;
-var _activeCompareTimer = null;
+// state._activeCompare — теперь в state.js (Фаза 0: state + render)
window.runCompareForGroup = async function(gi, btn) {
- var group = window._groupsData[gi];
+ var group = state.groups[gi];
if (!group || group.contract_number === '__unresolved__') return;
// Остановить предыдущее сравнение
- if (_activeCompareES) { _activeCompareES.close(); _activeCompareES = null; }
- if (_activeCompareTimer) { clearInterval(_activeCompareTimer); _activeCompareTimer = null; }
+ if (state._activeCompare.es) { state._activeCompare.es.close(); state._activeCompare.es = null; }
+ if (state._activeCompare.timer) { clearInterval(state._activeCompare.timer); state._activeCompare.timer = null; }
// Свернуть ТОЛЬКО тело текущей группы
var curBody = document.getElementById('cmpBody_' + gi);
@@ -498,7 +515,7 @@ window.runCompareForGroup = async function(gi, btn) {
var ar = await fetch(VM_API + '/api/apply-groups', {
method: 'POST',
headers: {'Content-Type': 'application/json'},
- body: JSON.stringify({batch_id: batchId, groups: [group]})
+ body: JSON.stringify({batch_id: state.batchId, groups: [group]})
});
var ad = await ar.json();
if (!ad.ok || !ad.contract_ids || !ad.contract_ids.length) {
@@ -530,12 +547,12 @@ window.runCompareForGroup = async function(gi, btn) {
cmpBody.appendChild(statusEl);
var start = Date.now();
- _activeCompareTimer = setInterval(function() {
+ state._activeCompare.timer = setInterval(function() {
statusEl.textContent = '⏳ ' + ((Date.now() - start) / 1000).toFixed(1) + 'с';
}, 200);
var es = new EventSource(VM_API + '/process-v2?contract_id=' + cid);
- _activeCompareES = es;
+ state._activeCompare.es = es;
var sections = {};
es.onmessage = function(e) {
@@ -573,8 +590,8 @@ window.runCompareForGroup = async function(gi, btn) {
}
}
else if (d.type === 'done') {
- clearInterval(_activeCompareTimer); _activeCompareTimer = null;
- es.close(); _activeCompareES = null;
+ clearInterval(state._activeCompare.timer); state._activeCompare.timer = null;
+ es.close(); state._activeCompare.es = null;
statusEl.textContent = '✓ ' + d.total_time_s + 'с';
statusEl.style.color = 'var(--green)';
// Заменить карточку на обработанную (другая вёрстка, нет кнопок)
@@ -584,16 +601,16 @@ window.runCompareForGroup = async function(gi, btn) {
stepDone('stepCompare');
}
else if (d.type === 'error') {
- clearInterval(_activeCompareTimer); _activeCompareTimer = null;
- es.close(); _activeCompareES = null;
+ clearInterval(state._activeCompare.timer); state._activeCompare.timer = null;
+ es.close(); state._activeCompare.es = null;
cmpBody.innerHTML += '
- Сверка договоров — LLM AI-driven Event Sourcing v1.0.177
+ Сверка договоров — LLM AI-driven Event Sourcing v1.0.178
-
-
+
+
+
✗ ' + d.message + '
';
btn.innerHTML = '✗'; btn.disabled = false;
document.querySelectorAll('.cmp-btn').forEach(function(b) { b.disabled = false; });
}
};
es.onerror = function() {
- clearInterval(_activeCompareTimer); _activeCompareTimer = null;
- es.close(); _activeCompareES = null;
+ clearInterval(state._activeCompare.timer); state._activeCompare.timer = null;
+ es.close(); state._activeCompare.es = null;
btn.innerHTML = '✗ соединение'; btn.disabled = false;
document.querySelectorAll('.cmp-btn').forEach(function(b) { b.disabled = false; });
};
@@ -610,8 +627,8 @@ function uploadFile(file, onProgress) {
var xhr = new XMLHttpRequest();
var fd = new FormData();
fd.append('files', uploadFile, uploadName);
- if (contractId) fd.append('contract_id', contractId);
- fd.append('batch_id', batchId);
+ if (state.contractId) fd.append('contract_id', state.contractId);
+ fd.append('batch_id', state.batchId);
xhr.open('POST', UPLOAD_URL);
xhr.upload.onprogress = function(e) {
if (e.lengthComputable && onProgress) onProgress(Math.round(e.loaded / e.total * 100));
@@ -652,7 +669,7 @@ function uploadFile(file, onProgress) {
// ── LLM: Общее сравнение (Event Sourcing) ────────────────────────
document.getElementById('llmBtn').addEventListener('click', function() {
- if (!contractId) return;
+ if (!state.contractId) return;
var btn = this;
btn.disabled = true;
btn.innerHTML = ' Сравнение...';
@@ -669,8 +686,8 @@ document.getElementById('llmBtn').addEventListener('click', function() {
compareStatus.textContent = '⏳ ' + ((Date.now() - llmStart) / 1000).toFixed(1) + 'с';
}, 200);
- var order = fileQueue.map(function(f) { return f.supp_id; }).filter(Boolean).join(',');
- var es = new EventSource('https://contracts.kube5s.ru/process-v2?contract_id=' + contractId + (order ? '&order=' + encodeURIComponent(order) : ''));
+ var order = state.files.map(function(f) { return f.supp_id; }).filter(Boolean).join(',');
+ var es = new EventSource('https://contracts.kube5s.ru/process-v2?contract_id=' + state.contractId + (order ? '&order=' + encodeURIComponent(order) : ''));
var sections = {}; // supplement_id → DOM element
es.onmessage = function(e) {
@@ -723,7 +740,7 @@ document.getElementById('llmBtn').addEventListener('click', function() {
btn.innerHTML = ' ✓ Готово';
stepDone('stepCompare');
if (d.total_unresolved > 0) {
- compareBody.innerHTML += '⚠ ' + d.total_unresolved + ' неразрешённых строк — разобрать
';
+ compareBody.innerHTML += '⚠ ' + d.total_unresolved + ' неразрешённых строк — разобрать
';
}
document.getElementById('chatCard').style.display = 'block';
lucide.createIcons();
@@ -751,22 +768,22 @@ document.getElementById('llmBtn').addEventListener('click', function() {
// ── Обновить supplement_id/type для radio ──────────────────
async function refreshSupps() {
- if (!contractId) { console.log('refreshSupps: no contractId'); return; }
+ if (!state.contractId) { console.log('refreshSupps: no state.contractId'); return; }
try {
- var resp = await fetch(VM_API + '/api/supplements?contract_id=' + contractId);
+ var resp = await fetch(VM_API + '/api/supplements?contract_id=' + state.contractId);
var data = await resp.json();
console.log('refreshSupps: data=', data);
if (data.ok && data.supplements) {
data.supplements.forEach(function(supp) {
console.log('refreshSupps: supp=', supp);
- for (var i = 0; i < fileQueue.length; i++) {
- if (fileQueue[i].doc_id === supp.document_id) {
- fileQueue[i].supp_id = supp.id;
- fileQueue[i].supp_type = supp.type;
+ for (var i = 0; i < state.files.length; i++) {
+ if (state.files[i].doc_id === supp.document_id) {
+ state.files[i].supp_id = supp.id;
+ state.files[i].supp_type = supp.type;
}
}
});
- renderTable();
+ render(state);
}
} catch(e) { console.log('refreshSupps error:', e); }
}
@@ -775,7 +792,7 @@ async function refreshSupps() {
document.getElementById('chatSend').addEventListener('click', function() {
var input = document.getElementById('chatInput');
var q = input.value.trim();
- if (!q || !contractId) return;
+ if (!q || !state.contractId) return;
var msgs = document.getElementById('chatMessages');
msgs.innerHTML += 'Вы: ' + q + '
';
input.value = '';
@@ -785,7 +802,7 @@ document.getElementById('chatSend').addEventListener('click', function() {
var fd = new FormData();
fd.append('question', q);
- fetch('/chat.cfm?contract_id=' + contractId, { method: 'POST', body: fd })
+ fetch('/chat.cfm?contract_id=' + state.contractId, { method: 'POST', body: fd })
.then(function(r) { return r.json(); })
.then(function(d) {
msgs.lastChild.remove();
@@ -811,7 +828,7 @@ function closeModal(e) {
}
async function showText(i) {
- var f = fileQueue[i];
+ var f = state.files[i];
var docId = f.doc_id;
document.getElementById('modalTitle').textContent = f.name;
document.getElementById('modalBody').innerHTML = 'Загрузка...';
diff --git a/deploy/app_utils.js b/deploy/app_utils.js
index 32879fd..d65a8a5 100644
--- a/deploy/app_utils.js
+++ b/deploy/app_utils.js
@@ -28,11 +28,14 @@ function formatDate(ts) {
/**
* Удаляет файл из очереди по индексу.
* Вызывается по кнопке ✕ в таблице файлов.
+ *
+ * Фаза 0 (state + render): мутирует state.files, затем render(state).
+ * Если очередь опустела — сбрасывает state.contractId.
*/
function removeFile(i) {
- fileQueue.splice(i, 1);
- if (fileQueue.length === 0) contractId = null;
- renderTable();
+ state.files.splice(i, 1);
+ if (state.files.length === 0) state.contractId = null;
+ render(state);
// Синхронизировать БД с таблицей
if (typeof syncDB === 'function') syncDB();
// Сбросить прогресс при изменении состава файлов
@@ -45,21 +48,25 @@ window.removeFile = removeFile;
/**
* Переместить файл на одну позицию ВВЕРХ (сохранено для возможного возврата ручной сортировки).
* В текущей версии (v1.0.164+) не используется — порядок определяет авто-классификация.
+ *
+ * Фаза 0 (state + render): мутирует state.files, затем render(state).
*/
function moveUp(i) {
if (i <= 0) return;
- var tmp = fileQueue[i]; fileQueue[i] = fileQueue[i-1]; fileQueue[i-1] = tmp;
- renderTable();
+ var tmp = state.files[i]; state.files[i] = state.files[i-1]; state.files[i-1] = tmp;
+ render(state);
}
/**
* Переместить файл на одну позицию ВНИЗ (сохранено для возможного возврата ручной сортировки).
* В текущей версии (v1.0.164+) не используется — порядок определяет авто-классификация.
+ *
+ * Фаза 0 (state + render): мутирует state.files, затем render(state).
*/
function moveDown(i) {
- if (i >= fileQueue.length - 1) return;
- var tmp = fileQueue[i]; fileQueue[i] = fileQueue[i+1]; fileQueue[i+1] = tmp;
- renderTable();
+ if (i >= state.files.length - 1) return;
+ var tmp = state.files[i]; state.files[i] = state.files[i+1]; state.files[i+1] = tmp;
+ render(state);
}
window.moveUp = moveUp;
window.moveDown = moveDown;
diff --git a/deploy/state.js b/deploy/state.js
new file mode 100644
index 0000000..4905df5
--- /dev/null
+++ b/deploy/state.js
@@ -0,0 +1,73 @@
+/**
+ * state.js — Центральное состояние приложения.
+ *
+ * ПАТТЕРН (из decoupling-final-plan.md, Фаза 0):
+ * action → мутация state → render(state)
+ *
+ * ПРАВИЛА:
+ * 1. ВСЕ состояния приложения — только здесь, в объекте state.
+ * 2. DOM — проекция state, никто не читает данные из DOM.
+ * Если что-то нужно узнать — смотри в state, а не в element.innerHTML.
+ * 3. Мутировал любое поле state → обязан вызвать render(state).
+ * Никаких прямых манипуляций DOM в обход render().
+ * 4. В любой момент console.log(state) показывает ВСЁ состояние приложения.
+ *
+ * СТРУКТУРА (Фаза 0 — минимальная, будет расширяться в Фазах 1-4):
+ *
+ * state.files — бывший fileQueue, массив загруженных файлов.
+ * Каждый элемент: { name, size, lastModified, file, doc_id,
+ * uploaded, parsed, parseInfo, supp_id, supp_type, status }
+ *
+ * state.contractId — бывший contractId, ID контракта в БД.
+ * Приходит с бэкенда после первого успешного upload.
+ * null пока не загружен ни один файл.
+ *
+ * state.batchId — бывший batchId, уникальный ID сессии (UUID).
+ * Используется для привязки всех файлов сессии при классификации.
+ * Генерируется один раз при загрузке страницы.
+ *
+ * state.groups — бывший window._groupsData.
+ * Массив групп после классификации. Каждая группа:
+ * { contract_number, counterparty, documents[], unresolved? }
+ * null если классификация ещё не запускалась.
+ *
+ * state._activeCompare — бывшие _activeCompareES и _activeCompareTimer.
+ * Управляет ОДНИМ активным SSE-сравнением.
+ * Правило: только одно сравнение одновременно — все кнопки блокируются.
+ * { es: EventSource|null, timer: intervalId|null }
+ *
+ * state.ui — UI-состояние, не связанное с данными.
+ * ui.steps: { upload, classify, groups, compare }
+ * Каждый шаг: '○' (не начат) | '⏳' (в процессе) | '✓' (завершён)
+ * В Фазе 4 будет renderStepper(state).
+ */
+var state = {
+ // ── Файлы (бывший fileQueue) ──────────────────────────────
+ files: [],
+
+ // ── Контракт (бывший contractId) ──────────────────────────
+ contractId: null,
+
+ // ── Сессия (бывший batchId) ───────────────────────────────
+ // crypto.randomUUID() — браузерный API, поддержка 92%+ (Chrome 92+, FF 95+, Safari 15.4+)
+ batchId: crypto.randomUUID(),
+
+ // ── Группы (бывший window._groupsData) ────────────────────
+ groups: null,
+
+ // ── Активное сравнение ────────────────────────────────────
+ _activeCompare: {
+ es: null, // EventSource (SSE-соединение с /process-v2)
+ timer: null // setInterval ID для индикатора времени
+ },
+
+ // ── UI-состояние ──────────────────────────────────────────
+ ui: {
+ steps: {
+ upload: '○',
+ classify: '○',
+ groups: '○',
+ compare: '○'
+ }
+ }
+};
diff --git a/index.cfm b/index.cfm
index 118cfc5..a099003 100644
--- a/index.cfm
+++ b/index.cfm
@@ -75,7 +75,7 @@
- Сверка договоров — LLM AI-driven Event Sourcing v1.0.177
+ Сверка договоров — LLM AI-driven Event Sourcing v1.0.178
○ Загрузка→
○ Классификация→
@@ -245,7 +245,8 @@