Дмитрий Замалинский

<?php
require $_SERVER['DOCUMENT_ROOT'] . '/bitrix/modules/main/include/prolog_before.php';

$lock = fopen('/tmp/price-sync.lock', 'c');
if (!flock($lock, LOCK_EX | LOCK_NB)) {
    exit('sync already running');
}

$client = new \Local\OneC\Client(getenv('ONEC_URL'), getenv('ONEC_TOKEN'));
$page = 1;

do {
    $batch = $client->prices($page++, 500);
    foreach ($batch['items'] as $row) {
        \Local\Catalog\Price::upsert($row['sku'], (float)$row['price'], (int)$row['stock']);
    }
    \Local\Catalog\Price::flushCache();
} while ($batch['hasNext']);

flock($lock, LOCK_UN);

<?php
$payload = json_decode(file_get_contents('php://input'), true);
$lead = [
    'TITLE' => 'Заявка с сайта: ' . $payload['form'],
    'NAME' => $payload['name'],
    'PHONE' => [['VALUE' => $payload['phone'], 'VALUE_TYPE' => 'WORK']],
    'SOURCE_ID' => 'WEB',
    'UF_CRM_UTM' => $payload['utm']['source'] ?? '',
];

$ch = curl_init(getenv('B24_WEBHOOK') . 'crm.lead.add.json');
curl_setopt_array($ch, [
    CURLOPT_POST => true,
    CURLOPT_POSTFIELDS => http_build_query(['fields' => $lead]),
    CURLOPT_RETURNTRANSFER => true,
    CURLOPT_TIMEOUT => 5,
]);
$response = json_decode(curl_exec($ch), true);

if (curl_getinfo($ch, CURLINFO_HTTP_CODE) !== 200 || !empty($response['error'])) {
    \Local\Queue::push('lead', $lead); // повтор из очереди
}

<?php
AddEventHandler('sale', 'OnGetOrderPrice', 'b2bPrice');

function b2bPrice(int $productId, int $userId): float
{
    $client = \Local\B2B\Client::forUser($userId); // контрагент по ИНН
    $cache = \Bitrix\Main\Data\Cache::createInstance();
    $key = 'b2b_price_' . $client->id . '_' . $productId;

    if ($cache->initCache(900, $key, '/b2b/prices')) {
        return (float)$cache->getVars()['price'];
    }

    $price = $client->price($productId)
        ?? \Local\Catalog\Price::base($productId);

    $cache->startDataCache();
    $cache->endDataCache(['price' => $price]);

    return (float)$price;
}

from fastapi import FastAPI, Request
from app.rag import search
from app.crm import create_lead
from app.llm import answer

app = FastAPI()

@app.post("/webhook/chat")
async def chat(request: Request):
    data = await request.json()
    context = search(data["text"], limit=5)
    reply = await answer(data["text"], context)

    if reply.needs_manager:
        await create_lead(
            name=data.get("name"),
            phone=data.get("phone"),
            summary=reply.summary,
            dialog_id=data["dialog_id"],
        )

    return {"text": reply.text, "handoff": reply.needs_manager}

import asyncio
from app.bitrix import fetch_products, update_product
from app.llm import generate
from app.seo import validate

async def process(batch: list[int]) -> None:
    for product in await fetch_products(batch):
        text = await generate(product["name"], product["props"])
        if not validate(text, product["keywords"]):
            text = await generate(product["name"], product["props"], strict=True)
        await update_product(product["id"], text, version="ai-v3")

async def main() -> None:
    for start in range(0, 10000, 200):
        await process(list(range(start, start + 200)))

asyncio.run(main())

async def daily_report(day: str) -> None:
    rows = await fetch_stats(day)              # Директ + Google Ads
    metrics = compute(rows)                    # CTR, CPC, CPA, DRR
    anomalies = detect(metrics, history=90)    # отклонения от базы
    summary = await llm_summary(metrics, anomalies)

    await send_telegram(summary, metrics)
    await write_sheet(day, metrics)
    await save_snapshot(day, metrics)