Production Service

Назначение

production обслуживает производственный домен: справочник продукции, производственные заказы, выпуск, качество, складские остатки, продажи, показания датчиков и агрегированные KPI. Сервис реализован как NestJS-приложение с RabbitMQ RPC-интерфейсом, PostgreSQL через Prisma и событийной интеграцией через RabbitMQ events/outbox.

Как сервис встроен в систему

Команды принимает через exchange efko.production.commands.
Запросы принимает через exchange efko.production.queries.
Доменные события публикует в exchange efko.production.events.
Очереди команд и запросов разделены: production-service.commands.queue и production-service.queries.queue.
Внешний HTTP есть только у bootstrap c префиксом api; бизнес-операции в коде экспонируются как RabbitRPC, а не как REST-контроллеры.

Основные модули

ProductsModule: создание и выборка продуктов.
OrdersModule: создание производственных заказов, смена статуса, чтение одного заказа и списка.
OutputModule: фиксация выпуска по партиям и выборка выпуска.
QualityModule: запись лабораторных результатов и выборка качества.
InventoryModule: upsert складских остатков и выборка остатков.
SalesModule: запись продаж и агрегированная/детальная аналитика по продажам.
SensorsModule: запись телеметрии и выборка показаний.
KpiModule: расчёт агрегированных производственных KPI.
ProductionInfrastructureModule: wiring Prisma-репозиториев, use case-ов и RmqEventEmitterService.
OutboxModule: интеграция общего outbox поверх Prisma с публикацией в efko.production.events.

RabbitMQ Commands и Queries

Все команды отправляются в exchange efko.production.commands, очередь production-service.commands.queue. Все запросы отправляются в exchange efko.production.queries, очередь production-service.queries.queue.

Все RPC handlers используют ValidationPipe с transform, whitelist, forbidNonWhitelisted, читают correlation/user metadata из Rabbit headers и обёрнуты в productionRpcErrorInterceptor.

Commands

ProductionCreateProductCommand

Создать продукт. При наличии sourceSystemId use case сначала пытается сделать upsert по внешнему идентификатору.

Exchange: efko.production.commands
Request Body:

{
  code: string;                    // Уникальный код продукта
  name: string;                    // Название продукта
  category: ProductCategory;       // RAW_MATERIAL | SEMI_FINISHED | FINISHED_PRODUCT | PACKAGING
  brand?: string;                  // Бренд (опционально)
  unitOfMeasure: string;           // Единица измерения (kg, l, piece и т.д.)
  shelfLifeDays?: number;          // Срок годности в днях (опционально)
  requiresQualityCheck?: boolean;  // Требуется ли контроль качества
  sourceSystemId?: string;         // ID из внешней системы (для ETL)
}

Response:

{
  id: string;
  code: string;
  name: string;
  category: ProductCategory;
  brand: string | null;
  unitOfMeasure: string;
  shelfLifeDays: number | null;
  requiresQualityCheck: boolean;
  sourceSystemId: string | null;
}

Ошибки: PRODUCT_CODE_ALREADY_EXISTS -> 409

ProductionCreateOrderCommand

Создать производственный заказ.

Exchange: efko.production.commands
Request Body:

{
  externalOrderId?: string;  // Номер заказа во внешней системе (опционально)
  productId: string;         // UUID продукта
  targetQuantity: number;    // Плановое количество
  unitOfMeasure: string;     // Единица измерения
  productionLine: string;    // Название производственной линии
  plannedStart: string;      // Плановое начало (ISO datetime)
  plannedEnd: string;        // Плановое окончание (ISO datetime)
}

Response:

{
  id: string;
  externalOrderId: string | null;
  productId: string;
  status: OrderStatus;  // PLANNED | IN_PROGRESS | COMPLETED | CANCELLED
}

Ошибки: PRODUCT_NOT_FOUND -> 404

ProductionUpdateOrderStatusCommand

Обновить статус производственного заказа.

Exchange: efko.production.commands
Request Body:

{
  id: string;
  action: 'start' | 'complete' | 'cancel';
  actualQuantity?: number;  // Фактическое количество (опционально)
}

Response:

{
  id: string;
  status: OrderStatus;
  actualQuantity: number | null;
  actualStart: string | null;  // ISO datetime
  actualEnd: string | null;    // ISO datetime
}

Ошибки: INVALID_ORDER_STATUS_TRANSITION -> 409

ProductionRecordOutputCommand

Зарегистрировать выпуск продукции.

Exchange: efko.production.commands
Request Body:

{
  orderId: string;     // UUID заказа
  productId: string;   // UUID продукта
  lotNumber: string;   // Номер партии (уникальный для этого выпуска)
  quantity: number;    // Количество выпущено
  shift: string;       // Смена (например: "morning", "night")
}

Response:

{
  id: string;
  orderId: string;
  lotNumber: string;
  quantity: number;
}

ProductionRecordQualityResultCommand

Записать результат контроля качества.

Exchange: efko.production.commands
Request Body:

{
  lotNumber: string;       // Номер партии
  productId: string;       // UUID продукта
  parameterName: string;   // Название параметра (moisture, pH, temperature и т.д.)
  resultValue: number;     // Значение результата
  lowerLimit: number;      // Нижний допустимый предел
  upperLimit: number;      // Верхний допустимый предел
  testDate: string;        // Дата теста (ISO date)
}

Response:

{
  id: string;
  lotNumber: string;
  productId: string;
  inSpec: boolean;        // Соответствует норме
  decision: QualityDecision;  // APPROVED | REJECTED | PENDING
}

ProductionUpsertInventoryCommand

Создать или обновить остаток на складе.

Exchange: efko.production.commands
Request Body:

{
  productId: string;         // UUID продукта
  warehouseCode: string;     // Код склада
  lotNumber?: string;        // Номер партии (опционально)
  quantity: number;          // Количество
  unitOfMeasure: string;     // Единица измерения
}

Response:

{
  id: string;
  productId: string;
  warehouseCode: string;
  quantity: number;
}

ProductionRecordSaleCommand

Зарегистрировать продажу.

Exchange: efko.production.commands
Request Body:

{
  externalId: string;    // Уникальный ID продажи во внешней системе
  productId: string;     // UUID продукта
  customerName: string;  // Название клиента
  quantity: number;      // Количество
  amount: number;        // Сумма продажи
  saleDate: string;      // Дата продажи (ISO date)
  region: string;        // Регион
  channel: SaleChannel;  // RETAIL | WHOLESALE | HORECA | EXPORT
}

Response:

{
  id: string;
  externalId: string;
  productId: string;
  amount: number;
}

ProductionRecordSensorReadingCommand

Записать показание датчика.

Exchange: efko.production.commands
Request Body:

{
  deviceId: string;            // ID датчика
  productionLine: string;      // Производственная линия
  parameterName: string;       // Название параметра (temperature, pressure и т.д.)
  value: number;               // Значение показания
  unit: string;                // Единица измерения
  quality: SensorQuality;      // GOOD | DEGRADED | BAD
}

Response:

{
  id: string;
  deviceId: string;
  productionLine: string;
  parameterName: string;
  quality: SensorQuality;
}