Как передать или завершить дела уволенного сотрудника

<?php

require_once 'vendor/autoload.php';

use Bitrix24\SDK\Services\ServiceBuilderFactory;
use Psr\Log\NullLogger;
use Symfony\Component\EventDispatcher\EventDispatcher;

$serviceBuilder = (new ServiceBuilderFactory(new EventDispatcher(), new NullLogger()))
    ->initFromWebhook(getenv('B24_HOOK'));
// B24_HOOK = 'https://your-domain.bitrix24.ru/rest/USER_ID/TOKEN/'

$action = 'transfer';

function callMethod($serviceBuilder, string $method, array $params)
{
    return $serviceBuilder
        ->core
        ->call($method, $params)
        ->getResponseData()
        ->getResult();
}

function findOneUser($serviceBuilder, array $filter): array
{
    $result = callMethod(
        $serviceBuilder,
        'user.get',
        [
            'FILTER' => $filter,
            'SELECT' => ['ID', 'ACTIVE', 'NAME', 'LAST_NAME', 'EMAIL'],
        ]
    );

    if (count($result) !== 1) {
        throw new RuntimeException('Ожидался один пользователь, получено: ' . count($result));
    }

    return $result[0];
}

$firedUser = findOneUser(
    $serviceBuilder,
    [
        'ACTIVE' => false,
        'LAST_NAME' => 'Иванов',
    ]
);

$newResponsible = $action === 'transfer'
    ? findOneUser(
        $serviceBuilder,
        [
            'ACTIVE' => true,
            'EMAIL' => 'new.responsible@example.com',
        ]
    )
    : null;

from b24pysdk import BitrixWebhook, Client

action = "transfer"

token = BitrixWebhook(
    domain="your-domain.bitrix24.com",
    webhook_token="user_id/webhook_key",
)
client = Client(token)

def call_method(method, params):
    # Вызов через ядро SDK: в сценарии есть методы без типизированной обертки
    payload = token.call_method(method, params)

    if "error" in payload:
        raise RuntimeError(f"{payload['error']}: {payload.get('error_description', '')}")

    return payload["result"]

def find_one_user(filter):
    result = call_method(
        "user.get",
        {
            "FILTER": filter,
            "SELECT": ["ID", "ACTIVE", "NAME", "LAST_NAME", "EMAIL"],
        },
    )

    if len(result) != 1:
        raise RuntimeError(f"Ожидался один пользователь, получено: {len(result)}")

    return result[0]

fired_user = find_one_user(
    {
        "ACTIVE": False,
        "LAST_NAME": "Иванов",
    }
)

new_responsible = (
    find_one_user(
        {
            "ACTIVE": True,
            "EMAIL": "new.responsible@example.com",
        }
    )
    if action == "transfer"
    else None
)

function getEmployeeActivities($serviceBuilder, int $employeeId): array
{
    $activities = [];
    $start = 0;

    do {
        $page = callMethod(
            $serviceBuilder,
            'crm.activity.list',
            [
                'order' => ['ID' => 'asc'],
                'filter' => [
                    'RESPONSIBLE_ID' => $employeeId,
                    'COMPLETED' => 'N',
                ],
                'select' => [
                    'ID',
                    'OWNER_TYPE_ID',
                    'OWNER_ID',
                    'PROVIDER_ID',
                    'PROVIDER_TYPE_ID',
                    'SUBJECT',
                    'COMPLETED',
                    'RESPONSIBLE_ID',
                ],
                'start' => $start,
            ]
        );

        $activities = array_merge($activities, $page);
        $start += 50;
    } while (count($page) === 50);

    return $activities;
}

$activities = getEmployeeActivities($serviceBuilder, (int)$firedUser['ID']);

def get_employee_activities(employee_id):
    activities = []
    start = 0

    while True:
        page = call_method(
            "crm.activity.list",
            {
                "order": {"ID": "asc"},
                "filter": {
                    "RESPONSIBLE_ID": int(employee_id),
                    "COMPLETED": "N",
                },
                "select": [
                    "ID",
                    "OWNER_TYPE_ID",
                    "OWNER_ID",
                    "PROVIDER_ID",
                    "PROVIDER_TYPE_ID",
                    "SUBJECT",
                    "COMPLETED",
                    "RESPONSIBLE_ID",
                ],
                "start": start,
            },
        )

        activities.extend(page)

        if len(page) < 50:
            break

        start += 50

    return activities

activities = get_employee_activities(fired_user["ID"])

function splitActivitiesByProvider(array $activities): array
{
    $groups = [
        'todos' => [],
        'configurable' => [],
        'base' => [],
    ];

    foreach ($activities as $activity) {
        if (($activity['PROVIDER_ID'] ?? '') === 'CRM_TODO') {
            $groups['todos'][] = $activity;
        } elseif (($activity['PROVIDER_ID'] ?? '') === 'CONFIGURABLE_REST_APP') {
            $groups['configurable'][] = $activity;
        } else {
            $groups['base'][] = $activity;
        }
    }

    return $groups;
}

$groupedActivities = splitActivitiesByProvider($activities);

def split_activities_by_provider(activities):
    groups = {
        "todos": [],
        "configurable": [],
        "base": [],
    }

    for activity in activities:
        provider_id = activity.get("PROVIDER_ID", "")

        if provider_id == "CRM_TODO":
            groups["todos"].append(activity)
        elif provider_id == "CONFIGURABLE_REST_APP":
            groups["configurable"].append(activity)
        else:
            groups["base"].append(activity)

    return groups

grouped_activities = split_activities_by_provider(activities)

$skippedConfigurableActivities = $groupedActivities['configurable'];

skipped_configurable_activities = grouped_activities["configurable"]

function updateBaseActivities($serviceBuilder, array $activities, string $action, int $newResponsibleId): array
{
    $updated = [];

    foreach ($activities as $activity) {
        $fields = $action === 'transfer'
            ? ['RESPONSIBLE_ID' => $newResponsibleId]
            : ['COMPLETED' => 'Y'];

        $result = callMethod(
            $serviceBuilder,
            'crm.activity.update',
            [
                'id' => (int)$activity['ID'],
                'fields' => $fields,
            ]
        );

        $updated[] = [
            'id' => $activity['ID'],
            'method' => 'crm.activity.update',
            'result' => $result,
        ];
    }

    return $updated;
}

$activitiesForBaseUpdate = $action === 'complete'
    ? array_merge($groupedActivities['base'], $groupedActivities['todos'])
    : $groupedActivities['base'];

$updatedBaseActivities = updateBaseActivities(
    $serviceBuilder,
    $activitiesForBaseUpdate,
    $action,
    $newResponsible !== null ? (int)$newResponsible['ID'] : 0
);

def update_base_activities(activities, action, new_responsible_id):
    updated = []

    for activity in activities:
        fields = (
            {"RESPONSIBLE_ID": int(new_responsible_id)}
            if action == "transfer"
            else {"COMPLETED": "Y"}
        )

        result = call_method(
            "crm.activity.update",
            {
                "id": int(activity["ID"]),
                "fields": fields,
            },
        )

        updated.append(
            {
                "id": activity["ID"],
                "method": "crm.activity.update",
                "result": result,
            }
        )

    return updated

activities_for_base_update = (
    grouped_activities["base"] + grouped_activities["todos"]
    if action == "complete"
    else grouped_activities["base"]
)

updated_base_activities = update_base_activities(
    activities_for_base_update,
    action,
    new_responsible["ID"] if action == "transfer" else 0,
)

function transferTodoActivities($serviceBuilder, array $activities, int $newResponsibleId): array
{
    $updated = [];

    foreach ($activities as $activity) {
        $result = callMethod(
            $serviceBuilder,
            'crm.activity.todo.updateResponsibleUser',
            [
                'id' => (int)$activity['ID'],
                'ownerTypeId' => (int)$activity['OWNER_TYPE_ID'],
                'ownerId' => (int)$activity['OWNER_ID'],
                'responsibleId' => $newResponsibleId,
            ]
        );

        $updated[] = [
            'id' => $activity['ID'],
            'method' => 'crm.activity.todo.updateResponsibleUser',
            'result' => $result,
        ];
    }

    return $updated;
}

$updatedTodoActivities = $action === 'transfer'
    ? transferTodoActivities($serviceBuilder, $groupedActivities['todos'], (int)$newResponsible['ID'])
    : [];

def transfer_todo_activities(activities, new_responsible_id):
    updated = []

    for activity in activities:
        result = call_method(
            "crm.activity.todo.updateResponsibleUser",
            {
                "id": int(activity["ID"]),
                "ownerTypeId": int(activity["OWNER_TYPE_ID"]),
                "ownerId": int(activity["OWNER_ID"]),
                "responsibleId": int(new_responsible_id),
            },
        )

        updated.append(
            {
                "id": activity["ID"],
                "method": "crm.activity.todo.updateResponsibleUser",
                "result": result,
            }
        )

    return updated

updated_todo_activities = (
    transfer_todo_activities(grouped_activities["todos"], new_responsible["ID"])
    if action == "transfer"
    else []
)

$updatedActivityIds = array_map(
    static fn(array $activity): string => (string)$activity['id'],
    array_merge($updatedBaseActivities, $updatedTodoActivities)
);

if (!empty($updatedActivityIds)) {
    $filter = [
        '@ID' => $updatedActivityIds,
    ];

    if ($action === 'transfer') {
        $filter['RESPONSIBLE_ID'] = (int)$newResponsible['ID'];
    } else {
        $filter['COMPLETED'] = 'Y';
    }

    $checkResult = callMethod(
        $serviceBuilder,
        'crm.activity.list',
        [
            'filter' => $filter,
            'select' => ['ID', 'SUBJECT', 'COMPLETED', 'RESPONSIBLE_ID', 'PROVIDER_ID'],
        ]
    );

    print_r($checkResult);
}

updated_activity_ids = [
    activity["id"]
    for activity in (
        updated_base_activities
        + updated_todo_activities
    )
]

if updated_activity_ids:
    filter_params = {
        "@ID": updated_activity_ids,
    }

    if action == "transfer":
        filter_params["RESPONSIBLE_ID"] = int(new_responsible["ID"])
    else:
        filter_params["COMPLETED"] = "Y"

    check_result = call_method(
        "crm.activity.list",
        {
            "filter": filter_params,
            "select": ["ID", "SUBJECT", "COMPLETED", "RESPONSIBLE_ID", "PROVIDER_ID"],
        },
    )

    print(check_result)