How to Retrieve a List of Tasks from Deals
Scope:
crm, user_briefWho can execute the method: a user with read access to deals in CRM
If you are developing integrations for Bitrix24 using AI tools (Codex, Claude Code, Cursor), connect to the MCP server so that the assistant can utilize the official REST documentation.
The task list allows you to track current tasks and calls related to deals, deadlines, and responsible parties. To create a task table, we will sequentially execute the following methods:
-
user.current — find the
IDof the current user, -
crm.item.list — retrieve the
IDof all deals for which the employee is responsible, -
crm.activity.list — generate a list of tasks related to the deals,
-
user.get — obtain information about the individuals responsible for the tasks.
1. Retrieve the ID of the Current User
To get the identifier of the current user, we will use the user.current method.
How to Use Examples in Documentation
JS
PHP
Python
Go
import { B24Hook } from '@bitrix24/b24jssdk'
const $b24 = B24Hook.fromWebhookUrl(process.env.B24_HOOK)
// B24_HOOK = 'https://your-domain.bitrix24.com/rest/USER_ID/TOKEN/'
const result = await $b24.actions.v2.call.make({
method: 'user.current',
params: {}
});
// composer require bitrix24/b24phpsdk:"^3.0"
require_once 'vendor/autoload.php';
use Bitrix24\SDK\Services\ServiceBuilderFactory;
use Symfony\Component\EventDispatcher\EventDispatcher;
use Monolog\Logger;
use Monolog\Handler\StreamHandler;
$log = new Logger('b24');
$log->pushHandler(new StreamHandler('php://stdout'));
$sb = (new ServiceBuilderFactory(new EventDispatcher(), $log))
->initFromWebhook('https://your-domain.bitrix24.com/rest/USER_ID/TOKEN/');
$currentUser = $sb->getUserScope()->user()->current()->user();
from b24pysdk import BitrixWebhook, Client
client = Client(
BitrixWebhook(
domain="your-domain.bitrix24.com",
webhook_token="user_id/webhook_key",
)
)
result = client.user.current().response.result
res, err := core.Call(ctx, "user.current", nil, b24.WithIdempotent())
if err != nil {
return fmt.Errorf("user.current: %w", err)
}
// The ID arrives AS A STRING ("29"): b24.ID parses both a number and a string
// containing a number, a plain int fails here.
var me struct {
ID b24.ID `json:"ID"`
Name string `json:"NAME"`
LastName string `json:"LAST_NAME"`
}
if err := json.Unmarshal(res.Result, &me); err != nil {
return fmt.Errorf("parse the current user: %w", err)
}
As a result, we will receive the user identifier "ID": "29".
{
"result": {
"ID": "29",
"ACTIVE": true,
"NAME": "Klaus",
"LAST_NAME": "Weber",
...
}
}
2. Retrieve the List of Deal IDs for the Employee
To obtain the identifiers of the deals assigned to the employee, we will call the crm.item.list method. We will pass the following parameters:
-
entityTypeId— the identifier for the CRM object type. You can retrieve the identifiers using the crm.enum.ownertype method. We will specify the value —2, which corresponds to a deal. -
select— an array of fields to select. We will specifyselect: ['id','title']to get the identifiers and titles of the deals. -
filter— a selection filter. To filter deals by theIDof the responsible employee, we will specify the user identifier obtained in the previous requestassignedById: 29.
To make the request faster and return only relevant data, add a filter by stages stageId. For example, you can select deals in the In Progress stage.
JS
PHP
Python
Go
const result = await $b24.actions.v2.call.make({
method: 'crm.item.list',
params: {
entityTypeId: 2,
select: ['id', 'title'],
filter: {
assignedById: 29
}
}
});
$items = $sb->getCRMScope()->item()->list(
2,
[],
['assignedById' => 29],
['id', 'title']
)->getItems();
result = client.crm.item.list(
entity_type_id=2,
select=["id", "title"],
filter={"assignedById": 29},
).response.result
// A list method returns at most 50 records per request. Pages walks
// the cursor itself: the ABSENCE of next ends the list, because next: 0 is
// a legitimate first offset rather than a sign of the end.
pager, err := core.Pages("crm.item.list", b24.Params{
"entityTypeId": entityTypeDeal,
"select": []string{"id", "title"},
"filter": b24.Params{"assignedById": me.ID},
}, b24.WithCallOptions(b24.WithIdempotent()))
if err != nil {
return fmt.Errorf("crm.item.list: %w", err)
}
var deals []struct {
ID int `json:"id"`
Title string `json:"title"`
}
for pager.Next(ctx) {
for _, row := range pager.Rows() {
var d struct {
ID int `json:"id"`
Title string `json:"title"`
}
if err := json.Unmarshal(row, &d); err != nil {
return fmt.Errorf("parse deal: %w", err)
}
deals = append(deals, d)
}
if len(deals) >= maxDeals {
break
}
}
// The error surfaces HERE, after the loop: Next returns false both at the end
// of the list and on an error.
if err := pager.Err(); err != nil {
return fmt.Errorf("traverse deals: %w", err)
}
As a result, we will receive an array items with deal identifiers like "id": 5111.
{
"result": {
"items": [
{ "id": 5111, "title": "Deal №1" },
{ "id": 5199, "title": "Deal №2" },
{ "id": 5257, "title": "Deal №3" }
]
},
"total": 3
}
3. Retrieve the List of Tasks for the Found Deals
To obtain the list of tasks, we will use the crm.activity.list method.
To select tasks from multiple deals, we will use the binding key BINDINGS in the filter. We will pass an array of objects, where each object contains:
-
OWNER_TYPE_ID— the identifier for the CRM object type. You can retrieve the identifiers using the crm.enum.ownertype method. We will specify the value —2, which corresponds to a deal. -
OWNER_ID— the identifier of the deal from the result of the previous request.
We will also filter only active tasks COMPLETED: 'N'.
We will output the following fields in the select:
-
ID— the identifier of the task, -
OWNER_ID— the identifier of the deal, -
SUBJECT— the description of the task, -
DEADLINE— the date and time of the deadline, -
RESPONSIBLE_ID— the identifier of the user responsible for the task.
JS
PHP
Python
Go
const result = await $b24.actions.v2.call.make({
method: 'crm.activity.list',
params: {
filter: {
BINDINGS: [
{ OWNER_TYPE_ID: 2, OWNER_ID: 5111 },
{ OWNER_TYPE_ID: 2, OWNER_ID: 5199 },
{ OWNER_TYPE_ID: 2, OWNER_ID: 5257 }
],
COMPLETED: 'N'
},
select: ['ID', 'OWNER_ID', 'SUBJECT', 'DEADLINE', 'RESPONSIBLE_ID']
}
});
$activities = $sb->getCRMScope()->activity()->list(
[],
[
'BINDINGS' => [
['OWNER_TYPE_ID' => 2, 'OWNER_ID' => 5111],
['OWNER_TYPE_ID' => 2, 'OWNER_ID' => 5199],
['OWNER_TYPE_ID' => 2, 'OWNER_ID' => 5257]
],
'COMPLETED' => 'N'
],
['ID', 'OWNER_ID', 'SUBJECT', 'DEADLINE', 'RESPONSIBLE_ID'],
0
)->getActivities();
result = client.crm.activity.list(
filter={
"BINDINGS": [
{"OWNER_TYPE_ID": 2, "OWNER_ID": 5111},
{"OWNER_TYPE_ID": 2, "OWNER_ID": 5199},
{"OWNER_TYPE_ID": 2, "OWNER_ID": 5257},
],
"COMPLETED": "N",
},
select=["ID", "OWNER_ID", "SUBJECT", "DEADLINE", "RESPONSIBLE_ID"],
).response.result
// BINDINGS is an array of bindings: one object per deal.
bindings := make([]b24.Params, 0, len(deals))
for _, d := range deals {
bindings = append(bindings, b24.Params{"OWNER_TYPE_ID": entityTypeDeal, "OWNER_ID": d.ID})
}
pager, err = core.Pages("crm.activity.list", b24.Params{
"filter": b24.Params{"BINDINGS": bindings, "COMPLETED": "N"},
"select": []string{"ID", "OWNER_ID", "SUBJECT", "DEADLINE", "RESPONSIBLE_ID"},
}, b24.WithCallOptions(b24.WithIdempotent()))
if err != nil {
return fmt.Errorf("crm.activity.list: %w", err)
}
// Activity fields are in UPPERCASE, whereas crm.item.list returns camelCase.
var activities []activity
for pager.Next(ctx) {
for _, row := range pager.Rows() {
var a activity
if err := json.Unmarshal(row, &a); err != nil {
return fmt.Errorf("parse activity: %w", err)
}
activities = append(activities, a)
}
}
if err := pager.Err(); err != nil {
return fmt.Errorf("traverse activities: %w", err)
}
As a result, you will obtain a list of activities with a description for each activity.
{
"result": [
{
"ID": "10120",
"OWNER_ID": "5111",
"SUBJECT": "Call client",
"DEADLINE": "2025-08-21T16:00:00+03:00",
"RESPONSIBLE_ID": "29"
},
{
"ID": "10131",
"OWNER_ID": "5199",
"SUBJECT": "Check contract",
"DEADLINE": "2025-08-29T16:00:00+03:00",
"RESPONSIBLE_ID": "47"
},
...
],
"total": 5
}
4. Retrieve User Data by RESPONSIBLE_ID
The individual responsible for a task in a deal can be any user, not just the one responsible for the deal. To display the name and surname of the person responsible for the task in the table, we will use the user.get method.
Pass the assigned user identifiers ID: [29, 47, ...] in the filter filter.
JS
PHP
Python
Go
const result = await $b24.actions.v2.call.make({
method: 'user.get',
params: {
filter: {
ID: [29, 47]
}
}
});
$users = $sb->getUserScope()->user()->get(
[],
['ID' => [29, 47]]
)->getUsers();
result = client.user.get(
filter={
"ID": [29, 47],
}
).response.result
res, err := core.Call(ctx, "user.get", b24.Params{
"filter": b24.Params{"ID": ids},
}, b24.WithIdempotent())
if err != nil {
return fmt.Errorf("user.get: %w", err)
}
var rows []struct {
ID b24.ID `json:"ID"`
Name string `json:"NAME"`
LastName string `json:"LAST_NAME"`
}
if err := json.Unmarshal(res.Result, &rows); err != nil {
return fmt.Errorf("parse employees: %w", err)
}
for _, u := range rows {
users[u.ID] = u.Name + " " + u.LastName
}
As a result, we will receive information about the users.
{
"result": [
{
"ID": "29",
"XML_ID": "23699770",
"ACTIVE": true,
"NAME": "Klaus",
"LAST_NAME": "Weber"
},
{
"ID": "47",
"XML_ID": "63726962",
"ACTIVE": true,
"NAME": "Peter",
"LAST_NAME": "Schmidt"
},
...
],
"total": 3,
}
Code Example
JS
PHP
Python
Go
import { B24Hook } from '@bitrix24/b24jssdk'
const $b24 = B24Hook.fromWebhookUrl(process.env.B24_HOOK)
// B24_HOOK = 'https://your-domain.bitrix24.com/rest/USER_ID/TOKEN/'
// Function for forming an array of links to deals
// CRM object type OWNER_TYPE_ID — 2, i.e., deal
function buildBindingsFromDealIds(dealIds) {
return dealIds.map((id) => ({ OWNER_TYPE_ID: 2, OWNER_ID: id }));
}
// Function to get all elements using pagination
// Required for list methods, as one request retrieves a maximum of 50 records
async function fetchAllItems(method, params) {
let allResults = [];
let start = 0;
const batchSize = 50;
while (true) {
const result = await $b24.actions.v2.call.make({
method,
params: { ...params, start }
});
if (!result.isSuccess) {
throw new Error(`Error getting data from ${method}: ${result.getErrorMessages().join('; ')}`);
}
const data = result.getData().result;
// Processing results depending on the method
let pageItems;
if (method === 'crm.item.list') {
pageItems = data.items || [];
} else if (Array.isArray(data)) {
pageItems = data;
} else {
pageItems = data.result || [];
}
allResults = allResults.concat(pageItems);
// Checking if there is more data
if (pageItems.length < batchSize) {
break;
}
start += batchSize;
}
return allResults;
}
// Step 1: Get information about the current user
const userResult = await $b24.actions.v2.call.make({ method: 'user.current', params: {} });
if (!userResult.isSuccess) {
throw new Error('Error getting user: ' + userResult.getErrorMessages().join('; '));
}
const userId = Number(userResult.getData().result.ID);
console.log('Current user ID:', userId);
// Step 2: Get the list of all deals
const allItems = await fetchAllItems('crm.item.list', {
entityTypeId: 2,
select: ['id', 'title'],
filter: { assignedById: userId }
});
const dealIds = allItems.map(it => it.id);
const dealMap = allItems.reduce((map, deal) => {
map[deal.id] = deal.title;
return map;
}, {});
console.log('Deals:', dealMap);
if (dealIds.length === 0) {
console.log('Employee has no deals');
} else {
// Forming links to search for tasks by deals
const bindings = buildBindingsFromDealIds(dealIds);
// Step 3: Get all tasks linked to these deals
const allActivities = await fetchAllItems('crm.activity.list', {
filter: { BINDINGS: bindings, COMPLETED: 'N' },
select: ['ID', 'OWNER_ID', 'SUBJECT', 'DEADLINE', 'RESPONSIBLE_ID']
});
const userIds = [...new Set(allActivities.map(a => a.RESPONSIBLE_ID))];
if (userIds.length === 0) {
console.log('No incomplete tasks for these deals.');
console.table([]);
} else {
// Step 4: Get user data
const usersResult = await $b24.actions.v2.call.make({
method: 'user.get',
params: { filter: { ID: userIds } }
});
let userMap = {};
if (usersResult.isSuccess) {
userMap = usersResult.getData().result.reduce((map, user) => {
map[user.ID] = `${user.NAME || ''} ${user.LAST_NAME || ''}`.trim() || user.LOGIN;
return map;
}, {});
} else {
console.error('Error getting users:', usersResult.getErrorMessages().join('; '));
}
const table = allActivities.map(a => ({
activityId: a.ID,
dealTitle: dealMap[a.OWNER_ID] || `Deal #${a.OWNER_ID}`,
subject: a.SUBJECT,
deadline: a.DEADLINE,
responsibleId: a.RESPONSIBLE_ID,
responsibleName: userMap[a.RESPONSIBLE_ID] || `User ${a.RESPONSIBLE_ID}`
}));
console.table(table);
}
}
<?php
// composer require bitrix24/b24phpsdk:"^3.0"
require_once 'vendor/autoload.php';
use Bitrix24\SDK\Services\ServiceBuilderFactory;
use Symfony\Component\EventDispatcher\EventDispatcher;
use Monolog\Logger;
use Monolog\Handler\StreamHandler;
$log = new Logger('b24');
$log->pushHandler(new StreamHandler('php://stdout'));
$sb = (new ServiceBuilderFactory(new EventDispatcher(), $log))
->initFromWebhook('https://your-domain.bitrix24.com/rest/USER_ID/TOKEN/');
// Function for forming an array of links to deals
// OWNER_TYPE_ID: 2 — CRM object type — deal
function buildBindingsFromDealIds($dealIds) {
$bindings = [];
foreach ($dealIds as $id) {
$bindings[] = [
'OWNER_TYPE_ID' => 2,
'OWNER_ID' => (int)$id,
];
}
return $bindings;
}
// Function to get all elements using pagination
// Required for list methods, as one request retrieves a maximum of 50 records
// $fetchPage($start) returns an array of elements for one page
function fetchAllItems(callable $fetchPage) {
$allResults = [];
$start = 0;
$batchSize = 50;
do {
$pageItems = $fetchPage($start);
$allResults = array_merge($allResults, $pageItems);
if (count($pageItems) < $batchSize) {
break;
}
$start += $batchSize;
} while (true);
return $allResults;
}
$crm = $sb->getCRMScope();
// Step 1: Get information about the current user
$userId = $sb->getUserScope()->user()->current()->user()->ID;
echo "Current user ID: $userId\n";
// Step 2: Get the list of all deals
$allItems = fetchAllItems(fn($start) => $crm->item()->list(
2,
[],
['assignedById' => $userId],
['id', 'title'],
$start
)->getItems());
$dealMap = [];
$dealIds = [];
foreach ($allItems as $item) {
$id = $item->id;
$dealIds[] = $id;
$dealMap[$id] = $item->title;
}
echo "Deals found: " . count($dealIds) . "\n";
if (empty($dealIds)) {
echo "Employee has no deals\n";
exit;
}
// Forming links to search for tasks by deals
$bindings = buildBindingsFromDealIds($dealIds);
// Step 3: Get all tasks linked to these deals
$allActivities = fetchAllItems(fn($start) => $crm->activity()->list(
[],
[
'BINDINGS' => $bindings,
'COMPLETED' => 'N',
],
['ID', 'OWNER_ID', 'SUBJECT', 'DEADLINE', 'RESPONSIBLE_ID'],
$start
)->getActivities());
if (empty($allActivities)) {
echo "No incomplete tasks for these deals.\n";
echo implode("\t", ['Task ID', 'Deal', 'Subject', 'Deadline', 'Responsible person']) . "\n";
exit;
}
// Collecting unique IDs of responsible persons
$responsibleIds = [];
foreach ($allActivities as $a) {
$responsibleIds[$a->RESPONSIBLE_ID] = true;
}
$responsibleIds = array_keys($responsibleIds);
$userMap = [];
if (!empty($responsibleIds)) {
// Step 4: Get user data
$users = $sb->getUserScope()->user()->get([], ['ID' => $responsibleIds])->getUsers();
foreach ($users as $user) {
$fullName = trim(($user->NAME ?? '') . ' ' . ($user->LAST_NAME ?? ''));
$userMap[$user->ID] = $fullName ?: ($user->LOGIN ?? "User {$user->ID}");
}
}
// Forming and displaying the table
$header = ['Task ID', 'Deal', 'Subject', 'Deadline', 'Responsible person'];
echo implode("\t", $header) . "\n";
foreach ($allActivities as $a) {
$activityId = $a->ID;
$ownerId = (int)$a->OWNER_ID;
$dealTitle = $dealMap[$ownerId] ?? "Deal #{$ownerId}";
$subject = $a->SUBJECT ?? '';
$deadline = $a->DEADLINE;
$responsibleId = $a->RESPONSIBLE_ID;
$responsibleName = $userMap[$responsibleId] ?? "User {$responsibleId} (not found)";
echo implode("\t", [
$activityId,
$dealTitle,
$subject,
$deadline,
$responsibleName
]) . "\n";
}
from b24pysdk import BitrixWebhook, Client
def build_bindings_from_deal_ids(deal_ids):
return [{"OWNER_TYPE_ID": 2, "OWNER_ID": deal_id} for deal_id in deal_ids]
def fetch_all_items(fetch_page, data_key=None):
all_results = []
start = 0
batch_size = 50
while True:
response = fetch_page(start)
if data_key is None:
page_items = response.result or []
else:
page_items = response.result.get(data_key, [])
all_results.extend(page_items)
if len(page_items) < batch_size:
break
start += batch_size
return all_results
client = Client(
BitrixWebhook(
domain="your-domain.bitrix24.com",
webhook_token="user_id/webhook_key",
)
)
current = client.user.current().response.result
user_id = int(current["ID"])
print(f"Current user ID: {user_id}")
all_items = fetch_all_items(
lambda start: client.crm.item.list(
entity_type_id=2,
select=["id", "title"],
filter={"assignedById": user_id},
start=start,
).response,
data_key="items",
)
deal_ids = [int(item["id"]) for item in all_items]
deal_map = {int(item["id"]): item["title"] for item in all_items}
print(f"Deals found: {len(deal_ids)}")
if not deal_ids:
print("Employee has no deals")
else:
bindings = build_bindings_from_deal_ids(deal_ids)
all_activities = fetch_all_items(
lambda start: client.crm.activity.list(
filter={
"BINDINGS": bindings,
"COMPLETED": "N",
},
select=["ID", "OWNER_ID", "SUBJECT", "DEADLINE", "RESPONSIBLE_ID"],
start=start,
).response
)
if not all_activities:
print("No incomplete tasks for these deals.")
print("\t".join(["Task ID", "Deal", "Subject", "Deadline", "Responsible person"]))
else:
responsible_ids = sorted(
{
int(item["RESPONSIBLE_ID"])
for item in all_activities
if item.get("RESPONSIBLE_ID")
}
)
user_map = {}
if responsible_ids:
users = fetch_all_items(
lambda start: client.user.get(
filter={"ID": responsible_ids},
start=start,
).response
)
for user in users:
full_name = f"{user.get('NAME', '')} {user.get('LAST_NAME', '')}".strip()
user_map[str(user["ID"])] = full_name or user.get("LOGIN", f"User {user['ID']}")
print("\t".join(["Task ID", "Deal", "Subject", "Deadline", "Responsible person"]))
for activity in all_activities:
activity_id = activity.get("ID", "")
owner_id = int(activity.get("OWNER_ID", 0))
deal_title = deal_map.get(owner_id, f"Deal #{owner_id}")
subject = activity.get("SUBJECT", "")
deadline = activity.get("DEADLINE", "")
responsible_id = activity.get("RESPONSIBLE_ID", "")
responsible_name = user_map.get(str(responsible_id), f"User {responsible_id} (not found)")
print(
"\t".join(
[
str(activity_id),
str(deal_title),
str(subject),
str(deadline),
str(responsible_name),
]
)
)
// Setup in an empty directory — go get will not work without go mod init:
//
// go mod init example && go get github.com/bitrix24/b24gosdk
//
// Run:
//
// export B24_WEBHOOK_URL='https://your-portal.bitrix24.com/rest/1/token/' && go run .
//
// The example is self-contained: it creates two deals of its own with activities, collects for them
// a table of activities with the responsible persons and cleans up after itself. It runs on any
// portal, nothing needs to be edited.
package main
import (
"context"
"encoding/json"
"fmt"
"log"
"os"
"sort"
"time"
b24 "github.com/bitrix24/b24gosdk"
)
// entityTypeDeal is the ID of the "deal" object type from crm.enum.ownertype.
const entityTypeDeal = 2
// maxDeals limits the deal selection. BINDINGS is a FILTER rather than a batch:
// an array of a thousand bindings goes in a single request and weighs it down. On a production
// portal, the deals should be narrowed down by a stage filter as well.
const maxDeals = 50
func main() {
if err := run(context.Background()); err != nil {
log.Fatal(err)
}
}
func run(ctx context.Context) error {
// The webhook path is a secret, so it comes from the environment, not from the code.
core := b24.NewClient(os.Getenv("B24_WEBHOOK_URL")).Core()
// --- step 1: the current user ID
res, err := core.Call(ctx, "user.current", nil, b24.WithIdempotent())
if err != nil {
return fmt.Errorf("user.current: %w", err)
}
// The ID arrives AS A STRING ("29"): b24.ID parses both a number and a string
// containing a number, a plain int fails here.
var me struct {
ID b24.ID `json:"ID"`
Name string `json:"NAME"`
LastName string `json:"LAST_NAME"`
}
if err := json.Unmarshal(res.Result, &me); err != nil {
return fmt.Errorf("parse the current user: %w", err)
}
fmt.Printf("current user %d: %s %s\n", me.ID, me.Name, me.LastName)
// --- setup: our own deals with activities, so the table has something to show
cleanup, err := createDealsWithActivities(ctx, core, me.ID)
defer cleanup()
if err != nil {
return err
}
// --- step 2: the deals the employee is responsible for
// A list method returns at most 50 records per request. Pages walks
// the cursor itself: the ABSENCE of next ends the list, because next: 0 is
// a legitimate first offset rather than a sign of the end.
pager, err := core.Pages("crm.item.list", b24.Params{
"entityTypeId": entityTypeDeal,
"select": []string{"id", "title"},
"filter": b24.Params{"assignedById": me.ID},
}, b24.WithCallOptions(b24.WithIdempotent()))
if err != nil {
return fmt.Errorf("crm.item.list: %w", err)
}
var deals []struct {
ID int `json:"id"`
Title string `json:"title"`
}
for pager.Next(ctx) {
for _, row := range pager.Rows() {
var d struct {
ID int `json:"id"`
Title string `json:"title"`
}
if err := json.Unmarshal(row, &d); err != nil {
return fmt.Errorf("parse deal: %w", err)
}
deals = append(deals, d)
}
if len(deals) >= maxDeals {
break
}
}
// The error surfaces HERE, after the loop: Next returns false both at the end
// of the list and on an error.
if err := pager.Err(); err != nil {
return fmt.Errorf("traverse deals: %w", err)
}
fmt.Printf("deals of the employee taken: %d\n", len(deals))
if len(deals) == 0 {
return nil
}
// --- step 3: the activities of these deals
// BINDINGS is an array of bindings: one object per deal.
bindings := make([]b24.Params, 0, len(deals))
for _, d := range deals {
bindings = append(bindings, b24.Params{"OWNER_TYPE_ID": entityTypeDeal, "OWNER_ID": d.ID})
}
pager, err = core.Pages("crm.activity.list", b24.Params{
"filter": b24.Params{"BINDINGS": bindings, "COMPLETED": "N"},
"select": []string{"ID", "OWNER_ID", "SUBJECT", "DEADLINE", "RESPONSIBLE_ID"},
}, b24.WithCallOptions(b24.WithIdempotent()))
if err != nil {
return fmt.Errorf("crm.activity.list: %w", err)
}
// Activity fields are in UPPERCASE, whereas crm.item.list returns camelCase.
var activities []activity
for pager.Next(ctx) {
for _, row := range pager.Rows() {
var a activity
if err := json.Unmarshal(row, &a); err != nil {
return fmt.Errorf("parse activity: %w", err)
}
activities = append(activities, a)
}
}
if err := pager.Err(); err != nil {
return fmt.Errorf("traverse activities: %w", err)
}
fmt.Printf("active activities: %d\n", len(activities))
// --- step 4: the persons responsible for the activities
// The person responsible for an activity may differ from the one responsible for the deal, so
// the IDs are taken from the activities themselves.
ids := uniqueIDs(activities)
users := map[b24.ID]string{}
if len(ids) > 0 {
res, err := core.Call(ctx, "user.get", b24.Params{
"filter": b24.Params{"ID": ids},
}, b24.WithIdempotent())
if err != nil {
return fmt.Errorf("user.get: %w", err)
}
var rows []struct {
ID b24.ID `json:"ID"`
Name string `json:"NAME"`
LastName string `json:"LAST_NAME"`
}
if err := json.Unmarshal(res.Result, &rows); err != nil {
return fmt.Errorf("parse employees: %w", err)
}
for _, u := range rows {
users[u.ID] = u.Name + " " + u.LastName
}
}
titles := map[int]string{}
for _, d := range deals {
titles[d.ID] = d.Title
}
fmt.Println("Activity\tDeal\tDescription\tDeadline\tResponsible")
for _, a := range activities {
who := users[a.ResponsibleID]
if who == "" {
who = "Unknown"
}
fmt.Printf("%d\t%s\t%s\t%s\t%s\n", a.ID, titles[int(a.OwnerID)], a.Subject, a.Deadline, who)
}
return nil
}
// activity is a single row of the crm.activity.list response.
type activity struct {
ID b24.ID `json:"ID"`
OwnerID b24.ID `json:"OWNER_ID"`
Subject string `json:"SUBJECT"`
Deadline string `json:"DEADLINE"`
ResponsibleID b24.ID `json:"RESPONSIBLE_ID"`
}
func uniqueIDs(activities []activity) []b24.ID {
seen := map[b24.ID]bool{}
out := make([]b24.ID, 0, len(activities))
for _, a := range activities {
if a.ResponsibleID > 0 && !seen[a.ResponsibleID] {
seen[a.ResponsibleID] = true
out = append(out, a.ResponsibleID)
}
}
sort.Slice(out, func(i, j int) bool { return out[i] < out[j] })
return out
}
// --- helpers: data setup and cleanup
// createDealsWithActivities creates two deals and one activity in each. It returns
// a cleanup function — it is called even if the setup broke off halfway.
func createDealsWithActivities(ctx context.Context, core *b24.Core, userID b24.ID) (func(), error) {
var dealIDs []b24.ID
cleanup := func() {
// Deleting a deal also removes its activities.
for _, id := range dealIDs {
del(ctx, core, "crm.item.delete", b24.Params{"entityTypeId": entityTypeDeal, "id": id})
}
}
for i, spec := range []struct {
title string
task string
in time.Duration
}{
{"Oven procurement (b24gosdk example)", "Call client", 24 * time.Hour},
{"Blender procurement (b24gosdk example)", "Send the invoice", 48 * time.Hour},
} {
res, err := core.Call(ctx, "crm.item.add", b24.Params{
"entityTypeId": entityTypeDeal,
"fields": b24.Params{
"title": spec.title,
"assignedById": userID,
"opportunity": (i + 1) * 100,
},
})
if err != nil {
return cleanup, fmt.Errorf("crm.item.add: %w", err)
}
raw, ok := b24.Unwrap(res.Result, "item", "id")
if !ok {
return cleanup, fmt.Errorf("no item.id in %s", res.Result)
}
var dealID b24.ID
if err := json.Unmarshal(raw, &dealID); err != nil {
return cleanup, err
}
dealIDs = append(dealIDs, dealID)
if _, err := core.Call(ctx, "crm.activity.todo.add", b24.Params{
"ownerTypeId": entityTypeDeal,
"ownerId": dealID,
"title": spec.task,
"description": "Activity created by the b24gosdk example",
"deadline": time.Now().Add(spec.in).Format(time.RFC3339),
"responsibleId": userID,
}); err != nil {
return cleanup, fmt.Errorf("crm.activity.todo.add: %w", err)
}
}
return cleanup, nil
}
// del removes what was created. A cleanup error is printed but not returned: it must not
// mask the real error of the scenario.
func del(ctx context.Context, core *b24.Core, method string, params b24.Params) {
if _, err := core.Call(ctx, method, params); err != nil {
fmt.Fprintf(os.Stderr, "cleanup, %s: %v