Как сохранить сумму оплат в поле сделки

<?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.com/rest/USER_ID/TOKEN/'

// Один помощник на все вызовы сценария: имя метода и параметры передаются так же, как в REST
function callMethod($serviceBuilder, string $method, array $params = []): mixed
{
    return $serviceBuilder
        ->core
        ->call($method, $params)
        ->getResponseData()
        ->getResult();
}

$paidFieldId = callMethod($serviceBuilder, 'crm.deal.userfield.add', [
    'fields' => [
        'FIELD_NAME' => 'UF_CRM_MONEY_PAID',
        'USER_TYPE_ID' => 'money',
        'MULTIPLE' => 'N',
        'EDIT_FORM_LABEL' => ['ru' => 'Оплачено', 'en' => 'Paid amount'],
    ],
]);

print_r($paidFieldId);

import os

from b24pysdk import BitrixWebhook

bitrix_token = BitrixWebhook(
    domain="your-domain.bitrix24.com",
    webhook_token=os.environ["B24_HOOK_TOKEN"],
)
# B24_HOOK_TOKEN = 'USER_ID/TOKEN'

def call_method(method, params=None):
    # Один помощник на все вызовы сценария: имя метода и параметры передаются так же, как в REST
    return bitrix_token.call_method(
        api_method=method,
        params=params or {},
    )["result"]

paid_field_id = call_method(
    "crm.deal.userfield.add",
    {
        "fields": {
            "FIELD_NAME": "UF_CRM_MONEY_PAID",
            "USER_TYPE_ID": "money",
            "MULTIPLE": "N",
            "EDIT_FORM_LABEL": {"ru": "Оплачено", "en": "Paid amount"},
        },
    },
)

print(paid_field_id)

$payments = callMethod($serviceBuilder, 'crm.item.payment.list', [
    'entityTypeId' => 2,
    'entityId' => 8423,
]);

$paidPayments = array_values(
    array_filter($payments, static fn(array $payment): bool => $payment['paid'] === 'Y')
);

print_r($paidPayments);

payments = call_method(
    "crm.item.payment.list",
    {
        "entityTypeId": 2,
        "entityId": 8423,
    },
)

paid_payments = [payment for payment in payments if payment["paid"] == "Y"]

print(paid_payments)

function buildMoneyValue(array $payments): string
{
    $currencies = array_unique(array_column($payments, 'currency'));

    if (count($currencies) > 1) {
        throw new RuntimeException('Оплаты в разных валютах: ' . implode(', ', $currencies));
    }

    $total = array_sum(array_map(
        static fn(array $payment): float => (float)$payment['sum'],
        $payments
    ));

    return number_format($total, 2, '.', '') . '|' . reset($currencies);
}

$moneyValue = buildMoneyValue($paidPayments);

callMethod($serviceBuilder, 'crm.item.update', [
    'entityTypeId' => 2,
    'id' => 8423,
    'fields' => ['ufCrmMoneyPaid' => $moneyValue],
]);

print_r($moneyValue);

def build_money_value(payments):
    currencies = {payment["currency"] for payment in payments}

    if len(currencies) > 1:
        raise RuntimeError(f"Оплаты в разных валютах: {', '.join(sorted(currencies))}")

    total = sum(float(payment["sum"]) for payment in payments)

    return f"{total:.2f}|{currencies.pop()}"

money_value = build_money_value(paid_payments)

call_method(
    "crm.item.update",
    {
        "entityTypeId": 2,
        "id": 8423,
        "fields": {"ufCrmMoneyPaid": money_value},
    },
)

print(money_value)

$item = callMethod($serviceBuilder, 'crm.item.get', [
    'entityTypeId' => 2,
    'id' => 8423,
]);

[$paidSum, $paidCurrency] = explode('|', $item['item']['ufCrmMoneyPaid']);
$rest = (float)$item['item']['opportunity'] - (float)$paidSum;

echo 'Сделка: ' . $item['item']['opportunity'] . ' ' . $item['item']['currencyId'] . PHP_EOL;
echo 'Оплачено: ' . $paidSum . ' ' . $paidCurrency . PHP_EOL;
echo 'Осталось: ' . number_format($rest, 2, '.', '') . ' ' . $item['item']['currencyId'] . PHP_EOL;

item = call_method("crm.item.get", {"entityTypeId": 2, "id": 8423})["item"]

paid_sum, paid_currency = item["ufCrmMoneyPaid"].split("|")
rest = float(item["opportunity"]) - float(paid_sum)

print(f"Сделка: {item['opportunity']} {item['currencyId']}")
print(f"Оплачено: {paid_sum} {paid_currency}")
print(f"Осталось: {rest:.2f} {item['currencyId']}")

<?php

require_once 'vendor/autoload.php';

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

const DEAL_ID = 8423;
const DEAL_ENTITY_TYPE_ID = 2;

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

// Один помощник на все вызовы сценария: имя метода и параметры передаются так же, как в REST
function callMethod($serviceBuilder, string $method, array $params = []): mixed
{
    return $serviceBuilder
        ->core
        ->call($method, $params)
        ->getResponseData()
        ->getResult();
}

function buildMoneyValue(array $payments): string
{
    $currencies = array_unique(array_column($payments, 'currency'));

    if ($currencies === []) {
        return '';
    }

    if (count($currencies) > 1) {
        throw new RuntimeException('Оплаты в разных валютах: ' . implode(', ', $currencies));
    }

    $total = array_sum(array_map(
        static fn(array $payment): float => (float)$payment['sum'],
        $payments
    ));

    return number_format($total, 2, '.', '') . '|' . reset($currencies);
}

callMethod($serviceBuilder, 'crm.deal.userfield.add', [
    'fields' => [
        'FIELD_NAME' => 'UF_CRM_MONEY_PAID',
        'USER_TYPE_ID' => 'money',
        'MULTIPLE' => 'N',
        'EDIT_FORM_LABEL' => ['ru' => 'Оплачено', 'en' => 'Paid amount'],
    ],
]);

$payments = callMethod($serviceBuilder, 'crm.item.payment.list', [
    'entityTypeId' => DEAL_ENTITY_TYPE_ID,
    'entityId' => DEAL_ID,
]);

$paidPayments = array_values(
    array_filter($payments, static fn(array $payment): bool => $payment['paid'] === 'Y')
);

$moneyValue = buildMoneyValue($paidPayments);

callMethod($serviceBuilder, 'crm.item.update', [
    'entityTypeId' => DEAL_ENTITY_TYPE_ID,
    'id' => DEAL_ID,
    'fields' => ['ufCrmMoneyPaid' => $moneyValue],
]);

$item = callMethod($serviceBuilder, 'crm.item.get', [
    'entityTypeId' => DEAL_ENTITY_TYPE_ID,
    'id' => DEAL_ID,
]);

[$paidSum, $paidCurrency] = explode('|', (string)$item['item']['ufCrmMoneyPaid'] . '|');
$rest = (float)$item['item']['opportunity'] - (float)$paidSum;

echo 'Сделка: ' . $item['item']['opportunity'] . ' ' . $item['item']['currencyId'] . PHP_EOL;
echo 'Оплачено: ' . $paidSum . ' ' . $paidCurrency . PHP_EOL;
echo 'Осталось: ' . number_format($rest, 2, '.', '') . ' ' . $item['item']['currencyId'] . PHP_EOL;

import os

from b24pysdk import BitrixWebhook

DEAL_ID = 8423
DEAL_ENTITY_TYPE_ID = 2

bitrix_token = BitrixWebhook(
    domain="your-domain.bitrix24.com",
    webhook_token=os.environ["B24_HOOK_TOKEN"],
)
# B24_HOOK_TOKEN = 'USER_ID/TOKEN'

def call_method(method, params=None):
    # Один помощник на все вызовы сценария: имя метода и параметры передаются так же, как в REST
    return bitrix_token.call_method(
        api_method=method,
        params=params or {},
    )["result"]

def build_money_value(payments):
    currencies = {payment["currency"] for payment in payments}

    if not currencies:
        return ""

    if len(currencies) > 1:
        raise RuntimeError(f"Оплаты в разных валютах: {', '.join(sorted(currencies))}")

    total = sum(float(payment["sum"]) for payment in payments)

    return f"{total:.2f}|{currencies.pop()}"

call_method(
    "crm.deal.userfield.add",
    {
        "fields": {
            "FIELD_NAME": "UF_CRM_MONEY_PAID",
            "USER_TYPE_ID": "money",
            "MULTIPLE": "N",
            "EDIT_FORM_LABEL": {"ru": "Оплачено", "en": "Paid amount"},
        },
    },
)

payments = call_method(
    "crm.item.payment.list",
    {"entityTypeId": DEAL_ENTITY_TYPE_ID, "entityId": DEAL_ID},
)

paid_payments = [payment for payment in payments if payment["paid"] == "Y"]
money_value = build_money_value(paid_payments)

call_method(
    "crm.item.update",
    {
        "entityTypeId": DEAL_ENTITY_TYPE_ID,
        "id": DEAL_ID,
        "fields": {"ufCrmMoneyPaid": money_value},
    },
)

item = call_method(
    "crm.item.get",
    {"entityTypeId": DEAL_ENTITY_TYPE_ID, "id": DEAL_ID},
)["item"]

paid_sum, _, paid_currency = (item["ufCrmMoneyPaid"] or "").partition("|")
rest = float(item["opportunity"]) - float(paid_sum or 0)

print(f"Сделка: {item['opportunity']} {item['currencyId']}")
print(f"Оплачено: {paid_sum} {paid_currency}")
print(f"Осталось: {rest:.2f} {item['currencyId']}")