Асинхронная очередь¶

Асинхронная очередь позволяет создать одну или несколько фоновых задач и получить результат позднее. Для партнёрских сервисов доступны только заявки типа Bid.

Методы¶

POST /api/integrations/Tasks/Queue — поставить команды в очередь;
GET /api/integrations/Tasks/Queue — получить состояние и результат задачи;
POST /api/integrations/Tasks/Ping — проверить доставку webhook на настроенный callbackTarget.

POST <baseUrl>/api/integrations/Tasks/Queue
GET  <baseUrl>/api/integrations/Tasks/Queue?id={taskId}
POST <baseUrl>/api/integrations/Tasks/Ping

Поддерживаемые комбинации¶

`action`	`type`	`modelType`	Назначение	Результат `body`
`Write`	`Bid`	`Default`	Создать или обновить заявку	`body` не возвращается; ID находится в `objects[].id`
`Read`	`Bid`	`Default`	Получить полные данные заявки	`IntegrationBidDetailsModel`
`Read`	`Bid`	`Summary`	Получить краткие данные заявки	`IntegrationBidListModel`
`ReadQuery`	`Bid`	`Default`	Получить собственные и транслируемые заявки всех доступных организаций	`IntegrationBidListModel[]`

Delete и ReadConfirmation для партнёрских сервисов не поддерживаются.

Write использует ту же модель и валидацию, что синхронный Bids/Apply, включая counterparty, vehicleType, temperatureRegime и геокодирование точек без координат. ReadQuery эквивалентен Bids/GetList без X-Organization-Id.

Поля isCreatedByPlatform, points и events гарантированы для результата ReadQuery. Прямой Read / Bid / Summary остаётся минимальной краткой моделью; не используйте его для определения источника заявки. Для этого выполните ReadQuery, а для полной карточки — Read / Bid / Default.

Постановка задачи¶

POST <baseUrl>/api/integrations/Tasks/Queue
Authorization: Bearer <accessToken.token>
Content-Type: application/json
Idempotency-Key: read-bid-12345-v1

{
  "commands": [
    {
      "action": "Read",
      "objects": [
        {
          "type": "Bid",
          "modelType": "Default",
          "id": 12345
        }
      ]
    }
  ]
}

На каждый элемент commands[] создаётся отдельная задача. Ответ постановки содержит массив commands с id, action, status и ориентировочным readyInMsec.

Жизненный цикл¶

Awaiting → InProgress → Completed
                    ↘ Error

Статус Completed означает завершение задачи, но не гарантирует успех каждого объекта. Всегда проверяйте objects[].status.

Получение результата¶

GET <baseUrl>/api/integrations/Tasks/Queue?id={taskId}
Authorization: Bearer <accessToken.token>

Пока задача выполняется, используйте Retry-After или readyInMsec как минимальную паузу до следующего запроса.

Результат также может быть доставлен webhook queued-task.finished, если настроен callback.

Два уровня ошибок¶

Ниже показан сокращённый фрагмент ответа, содержащий только поля, важные для обработки ошибки объекта:

{
  "status": "Completed",
  "objects": [
    {
      "type": "Bid",
      "id": 12345,
      "status": "Error",
      "message": "Заявка не найдена или недоступна интеграционному клиенту.",
      "body": null
    }
  ]
}

HTTP-запрос и задача могут завершиться успешно, а отдельный объект — ошибкой.

Идемпотентность¶

Idempotency-Key необязателен, но рекомендуется для повторяемых запросов.

максимальная длина — 100 символов;
срок действия — 24 часа;
область уникальности — текущий clientId;
для нескольких команд сервер добавляет к ключу индекс команды;
повтор возвращает прежний taskId;
тело повторного запроса не сравнивается с первоначальным.

Не используйте один ключ для разных логических операций.