diff --git a/server/routes/automation.routes.ts b/server/routes/automation.routes.ts index a546855..5ed477b 100644 --- a/server/routes/automation.routes.ts +++ b/server/routes/automation.routes.ts @@ -172,6 +172,12 @@ export async function runAutomationsByTrigger( organizationId, triggerData, ); + // Логи выполнения триггерных автоматизаций идут в консоль сервиса (иначе результаты теряются) + if (error) { + console.error(`[automation] ${automation.id} "${automation.name}" — ошибка:`, error, '| логи:', logs); + } else { + console.log(`[automation] ${automation.id} "${automation.name}" — выполнена | логи:`, logs); + } results.push({ automationId: automation.id, name: automation.name, logs, error, result }); } diff --git a/server/workers/automation-worker-code.ts b/server/workers/automation-worker-code.ts index 30c9b0d..abe1768 100644 --- a/server/workers/automation-worker-code.ts +++ b/server/workers/automation-worker-code.ts @@ -95,7 +95,7 @@ const ctx = { const task = await callStorage('getTask', [taskId, organizationId]); if (!task) throw new Error('Task ' + taskId + ' not found'); const formFields = await callStorage('getFormFields', [task.formId, organizationId]); - const field = formFields.find(function(f) { return f.fieldCode === fieldCode; }); + const field = formFields.find(function(f) { return (f.fieldCode || f.code) === fieldCode; }); if (!field) throw new Error('Field ' + fieldCode + ' not found'); const existing = fields.find(function(v) { return v.fieldId === field.id; }); if (existing) {