Fridge Service
Операционный Домен Склада и Покупок (INVENTORY)
fridge-service
Главное высоконагруженное транзакционное ядро (OLTP). Каскадный FIFO-расход объемов.
База данных: fridge_db (PostgreSQL).
Интерфейсы (Внутренний gRPC):
- rpc MutateBalances(FIFO_DeductRequest) returns (FIFO_DeductResponse) — основной исполнительный метод каскадного списания. Итеративно вычитает объемы, начиная со старых партий (ORDER BY created_at ASC). Блокирует операцию с кодом INSUFFICIENT_STOCK (HTTP 422) для контура OFFICE или разрешает теневой минус для контура HOME.
- rpc ReconcileExpiredBatches(CronTriggerRequest) returns (CronTriggerResponse) — вызывается ночным планировщиком Celery Beat в 03:00. Обнуляет просроченные партии (expired_at < NOW()) и переводит в статус EXPIRED.