Агрегация сделок

POST /v1/deals/aggregate

Подсчёт количества, сумма, среднее, минимум и максимум по сделкам с фильтрацией и группировкой.

Стандартные поля:

• amount — сумма сделки (числовое агрегирование имеет смысл)
• stageId — стадия (для groupBy)
• categoryId — воронка (для groupBy)
• assignedById — ответственный (для groupBy)
• sourceId — источник (для groupBy)

Пользовательские поля (UF): поля типов integer, double, money — для числовых функций, поля любого типа — для groupBy. Полный список UF-полей конкретного портала приходит в тексте ошибки INVALID_PARAMS, если передать несуществующее имя.

Поля запроса (body)

Примеры

curl — личный ключ

curl -X POST "https://vibecode.bitrix24.tech/v1/deals/aggregate" \
  -H "X-Api-Key: YOUR_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "aggregate": [
      { "field": "amount", "function": "sum" },
      { "field": "amount", "function": "avg" }
    ],
    "filter": { "categoryId": 0 },
    "groupBy": "stageId"
  }'

curl — OAuth-приложение

curl -X POST "https://vibecode.bitrix24.tech/v1/deals/aggregate" \
  -H "X-Api-Key: YOUR_APP_KEY" \
  -H "Authorization: Bearer USER_SESSION_TOKEN" \
  -H "Content-Type: application/json" \
  -d '{
    "aggregate": [
      { "field": "amount", "function": "sum" },
      { "field": "amount", "function": "avg" }
    ],
    "filter": { "categoryId": 0 },
    "groupBy": "stageId"
  }'

JavaScript — личный ключ

const res = await fetch('https://vibecode.bitrix24.tech/v1/deals/aggregate', {
  method: 'POST',
  headers: {
    'X-Api-Key': 'YOUR_API_KEY',
    'Content-Type': 'application/json',
  },
  body: JSON.stringify({
    aggregate: [
      { field: 'amount', function: 'sum' },
      { field: 'amount', function: 'avg' },
    ],
    filter: { categoryId: 0 },
    groupBy: 'stageId',
  }),
})

const { success, data } = await res.json()
console.log('Всего сделок в воронке:', data.count)
console.log('По стадиям:', data.groups)

JavaScript — OAuth-приложение

const res = await fetch('https://vibecode.bitrix24.tech/v1/deals/aggregate', {
  method: 'POST',
  headers: {
    'X-Api-Key': 'YOUR_APP_KEY',
    'Authorization': 'Bearer USER_SESSION_TOKEN',
    'Content-Type': 'application/json',
  },
  body: JSON.stringify({
    aggregate: [
      { field: 'amount', function: 'sum' },
      { field: 'amount', function: 'avg' },
    ],
    filter: { categoryId: 0 },
    groupBy: 'stageId',
  }),
})

const { success, data } = await res.json()

Для группировки по нескольким полям передайте массив: "groupBy": ["stageId", "sourceId"] (максимум 5).

Другие сценарии

Подсчёт записей — count с полем "*", самый быстрый запрос без выгрузки записей. Без массива aggregate результат тот же:

{ "aggregate": [{ "field": "*", "function": "count" }] }

Работа с пользовательскими полями (UF) — sum по UF + группировка по другому UF. Имя поля берётся из схемы GET /v1/deals/fields, на другое написание приходит 400 INVALID_PARAMS со списком доступных полей:

{
  "aggregate": [{ "field": "ufCrmBudget", "function": "sum" }],
  "groupBy": "ufCrmPriority"
}

Сводка по воронке — один запрос с группировкой по стадии и суммой даёт разбивку, из которой на стороне приложения считается конверсия в выигранные:

{
  "aggregate": [{ "field": "amount", "function": "sum" }],
  "filter": { "categoryId": 0 },
  "groupBy": "stageId"
}

В ответе data.count — всего сделок в воронке, data.groups — разбивка по стадиям с суммой и количеством. Идентификаторы стадий зависят от воронки — получить их можно из Поля. Конверсия считается из групп без отдельного запроса:

const total = data.count
const won = data.groups.find(g => g.stageId === 'WON')?.count ?? 0
const conversion = total ? Math.round((won / total) * 100) : 0
console.log(`Сделок в воронке: ${total}, выиграно: ${won}, конверсия: ${conversion}%`)

Поля ответа

Пример ответа

Ответ на основной запрос (агрегации + groupBy: "stageId"):

{
  "success": true,
  "data": {
    "count": 41,
    "aggregates": {
      "amount": { "sum": 100000, "avg": 2439 }
    },
    "groups": [
      {
        "stageId": "NEW",
        "count": 25,
        "aggregates": { "amount": { "sum": 60000 } }
      },
      {
        "stageId": "WON",
        "count": 16,
        "aggregates": { "amount": { "sum": 40000 } }
      }
    ],
    "meta": {
      "totalRecords": 41,
      "recordsProcessed": 41,
      "truncated": false
    }
  }
}

Без groupBy поле data.groups в ответе отсутствует.

Пример ответа при ошибке

400 — неверное имя функции, несуществующее поле или groupBy по неаггрегируемому полю:

{
  "success": false,
  "error": {
    "code": "INVALID_PARAMS",
    "message": "Field 'foo' not found. Available numeric fields: amount, stageId, categoryId, assignedById, sourceId"
  }
}

Ошибки

Полный список общих ошибок API — Ошибки.

Известные особенности

count и числовые функции — в чём разница. count без groupBy считается одним вызовом в Битрикс24 на любом объёме данных. Функции sum/avg/min/max подгружают записи постранично (максимум 5000) и считают на стороне Вайбкод — если под фильтр попадает больше 5000 записей, meta.truncated будет true, агрегация выполнится по первым 5000. Для точных счётчиков на больших выборках используйте count или сужайте фильтр. Потолок общий для всех сущностей — Агрегация POST — потолок 5000 записей. Потолок не единственная причина такой пометки: она появляется и когда прочитано меньше записей, чем обещал ответ, — а в режиме счётчиков по стадиям обещанное это большее из data.count и суммы счётчиков. Размер нехватки лежит в data.meta.recordsShortfall.

Крупная воронка: два режима, включаются администратором платформы по аккаунтам.

Оба выключены по умолчанию. Пока они выключены, поведение ровно такое, как описано выше.

• Отказ вместо усечения. Запрос, которому для ответа нужны строки (числовые функции и/или groupBy), при total > 5000 отвечает 422 AGGREGATION_LIMIT_EXCEEDED и не выгружает ни одной записи. Раньше он всё равно выгружал первые 5000 — на крупной воронке эта выгрузка не успевала и запрос обрывался по таймауту. В тексте ошибки перечислено, что делать дальше.
• Счётчики по стадиям без чтения строк. groupBy: ["stageId"] или ["stageSemanticId"] со скалярным categoryId в фильтре отвечает на воронке любого размера: количество по каждой стадии берётся отдельным дешёвым подсчётом на стороне Битрикс24. Признак такого ответа — meta.aggregatePath: "fanout" при meta.recordsProcessed: 0: строки не читались вовсе, поэтому счётчики точны. Числовые функции по стадиям остаются доступны, пока суммарный размер групп укладывается в 5000 — но им строки уже нужны, и такой ответ может прийти усечённым: тогда meta.truncated станет true, а числа получат пометку. Сами счётчики стадий при этом остаются точными — они берутся пробой, а не из прочитанных строк. Потолок не единственная причина такой пометки: она появляется и когда прочитано меньше записей, чем обещал ответ, — а в режиме счётчиков по стадиям обещанное это большее из data.count и суммы счётчиков. Размер нехватки лежит в data.meta.recordsShortfall.

meta.stageCountDelta приходит только в ответе со счётчиками по стадиям: разница между общим количеством и суммой по стадиям. Ноль означает, что разбиение полное. Ненулевое значение означает, что часть записей не попала в разбиение — записи изменились между подсчётами либо часть из них лежит в стадии, которой больше нет в справочнике стадий воронки. Счётчики стадий и count от этого точны: count всегда равен общему количеству, а не сумме групп. А вот числовые агрегаты в таком ответе посчитаны по меньшему набору строк, поэтому он приходит с meta.truncated: true и пометками у чисел.

Money-поля. UF-поля типа money хранятся в формате "сумма|валюта" ("1500|RUB") — агрегат извлекает числовую часть автоматически, складывать можно без парсинга.

Фильтрация по UF работает. В filter можно передавать любые поля — стандартные и пользовательские, любого типа. Например, { "filter": { "ufCrm_1234": "value" } } вернёт количество сделок с этим значением UF.

Смотрите также

• Список сделок
• Поиск сделок
• Синтаксис фильтрации
• Лимиты и оптимизация