aggregate-operator-actions

aggregate-operator-actions

Агрегація операторських дій

src/golden/workers/bull/queue/aggregate-operator-actions.worker.ts

Кожні 10 хвилин (cron */10 * * * *). Ephemeral: без ретраю.

Що відбувається

Послідовно виконує:

• Manual actions — бере усе з golden_temp_manual_operator_actions, групує (по supervisorFamilyId:operatorFamilyId + день + 5-хвилинне вікно), зберігає в денний golden_action_operators + аналог по TU, видаляє оброблені з temp
• Automatic (sender) actions — те саме з golden_temp_automatic_operator_actions для sender-екшенів

Кожна з двох фаз обкладена власним try/catch. Помилка однієї не блокує другу — просто логиться у Winston і йде далі.

Моніторинг

Лише logger.error() через Winston. ТГ-моніторинг не ввімкнений.

⚠️ TODO — каналу алертів про збій нема. Якщо temp-колекція не очищається або агрегати не пишуться — побачимо тільки у логах.