Ilya

Как заставить формы Tilda всегда прокидывать utm-метки в лиды в стандартной интеграции Битрикс24

2025-01-21T11:33:47.726Z

Проблема: когда клиенты переходят на ваш сайт на Tilda из различных площадок, часто в URL можно увидеть так называемые utm-метки, например
https://example.com/page?utm_source=google&utm_medium=cpc&utm_campaign=search&utm_content=shower&utm_term=1

если клиент,находясь на этой же странице, откроет стандартную тильдовскую форму обратной связи и отправит заявку(при условии что вы уже сделали стандартное подключение к Битрикс24 по инструкции https://help-ru.tilda.cc/forms/bitrix) то UTM-метки передадутся в лид

Но! если клиент вздумает побродить по вашему сайту, переходя по различным страницам и только после этого действия заполнит форму обратной связи то никаких UTM меток в лиде не будет

Причина кроется в том, что в этом случае изначальные utm-метки в адресной строке браузера не сохраняются и не уходят в Тильду и соответственно Тильда не отправит их дальше в ваш Битрикс24

Решение:
1) при первом посещении сайта проверять url на наличие utm-меток и записывать их в куки, тогда utm-метки сохранятся между переходами по страницам
2) повесить обработчик который будет следить за тем, открыли ли вы любую форму и начали ли вводить в поле ввода свои данные. именно в этот момент автоматически подставлять в адресную строку браузера сохраненные в куки utm-метки
3) готово! теперь utm-метки всегда передаются в лид в Битрикс24 и вы спокойно можете отслеживать сквозную аналитику

Ниже скрипт который необходимо разместить в админке тильды(Настройка сайта->Еще->Html-код для вставки внутрь HEAD), после этого он будет работать на всех страницах сайта

// Получение значения куки по имени function getCookie(name) { const match = document.cookie.match(new RegExp(`(^| )${name}=([^;]+)`)); return match ? match[2] : null; }

// 1. Запись utm-меток из URL const urlParams = new URLSearchParams(window.location.search); const utmParams = ['utm_medium', 'utm_source', 'utm_term', 'utm_content', 'utm_campaign']; utmParams.forEach(param => { const value = urlParams.get(param); const existingCookie = getCookie(param);

// Перезаписываем куки, если utm-метка есть в URL if (value) { setCookie(param, value, 30); } else if (!value && existingCookie) { // Не перезаписываем, если метки нет в URL, но есть в куках return; } });

// 2. Обработка случая отсутствия utm_source и utm_medium const referrer = document.referrer; if (!urlParams.get('utm_source') && !urlParams.get('utm_medium')) { const existingUtmSource = getCookie('utm_source'); const existingUtmMedium = getCookie('utm_medium');

let utmSource = existingUtmSource || '(direct)'; let utmMedium = existingUtmMedium || '(none)'; const currentDomain = window.location.hostname;

if (referrer && new URL(referrer).hostname !== currentDomain){ if ((utmSource === '(direct)' && utmMedium === '(none)')) { const referrerDomain = new URL(referrer).hostname; const sourceMapping = { 'google.com': 'google', 'www.google.com': 'google', 'google.ru': 'google', 'www.google.ru': 'google', 'google.kz': 'google', 'www.google.kz': 'google', 'www.google.co.uk': 'google', 'bing.com': 'bing', 'www.bing.com': 'bing', 'duckduckgo.com': 'duckduckgo', 'yandex.ru': 'yandex', 'yandex.ru': 'yandex', 'www.yandex.ru': 'yandex', 'yandex.kz': 'yandex', 'www.yandex.kz': 'yandex', 'ya.ru': 'yandex', 'www.ya.ru': 'yandex', 'ya.kz': 'yandex', 'www.ya.kz': 'yandex', 'www.yahoo.com': 'yahoo', 'yahoo.cn': 'yahoo', 'm.yahoo.com': 'yahoo' };

const organicSources = Object.keys(sourceMapping);

if (organicSources.some(domain => referrerDomain.includes(domain))) { utmSource = sourceMapping[organicSources.find(domain => referrerDomain.includes(domain))] || referrer; utmMedium = 'organic'; } else { utmSource = referrer; utmMedium = 'referral'; }

setCookie('utm_source', utmSource, 30); setCookie('utm_medium', utmMedium, 30); } } if (!existingUtmSource && !existingUtmMedium) { setCookie('utm_source', utmSource, 30); setCookie('utm_medium', utmMedium, 30); }

}

// 3. Подстановка значений utm-меток из куков в URL при вводе в любой input function addUtmParamsToUrl() { const utmParams = ['utm_medium', 'utm_source', 'utm_term', 'utm_content', 'utm_campaign', 'client_id']; const currentUrl = new URL(window.location.href); let urlModified = false;

utmParams.forEach(param => { const cookieValue = getCookie(param); if (cookieValue && !currentUrl.searchParams.has(param)) { currentUrl.searchParams.set(param, cookieValue); urlModified = true; } });

if (urlModified) { window.history.replaceState({}, '', currentUrl); } }

// Слушатель событий для ввода в любой input на странице document.addEventListener('input', (event) => { if (event.target.tagName === 'INPUT') { addUtmParamsToUrl(); } }); </script>

После размещения скрипта не забудьте заново опубликовать все страницы

Связь Many-to-Many в Symfony

2025-01-07T11:33:55.456Z

При проектировании баз данных и работе с фреймворком Symfony, одной из самых распространённых задач является создание связи типа "многие ко многим" (Many-to-Many) между сущностями. Рассмотрим сценарий, где у нас есть две сущности: User (пользователь) и Group (группа). Каждый пользователь может принадлежать к нескольким группам, а каждая группа может содержать несколько пользователей. Это классический пример связи Many-to-Many.

Как реализовать связь Many-to-Many в Symfony

В Symfony связь Many-to-Many реализуется с использованием аннотаций Doctrine ORM. Давайте рассмотрим, как можно настроить такую связь и вывести данные из базы.

1. Создание сущностей

Сущность `User`

<?php

namespace App\Entity;

use Doctrine\Common\Collections\ArrayCollection;
use Doctrine\Common\Collections\Collection;
use Doctrine\ORM\Mapping as ORM;

#[ORM\Entity]
class User
{
    #[ORM\Id]
    #[ORM\GeneratedValue]
    #[ORM\Column(type: 'integer')]
    private int $id;

    #[ORM\Column(type: 'string', length: 255)]
    private string $name;

    #[ORM\ManyToMany(targetEntity: Group::class, inversedBy: 'users')]
    #[ORM\JoinTable(name: 'user_group')]
    private Collection $groups;

    public function __construct()
    {
        $this->groups = new ArrayCollection();
    }

    // Геттеры и сеттеры

    public function getId(): int
    {
        return $this->id;
    }

    public function getName(): string
    {
        return $this->name;
    }

    public function setName(string $name): self
    {
        $this->name = $name;

        return $this;
    }

    public function getGroups(): Collection
    {
        return $this->groups;
    }

    public function addGroup(Group $group): self
    {
        if (!$this->groups->contains($group)) {
            $this->groups[] = $group;
            $group->addUser($this);
        }

        return $this;
    }

    public function removeGroup(Group $group): self
    {
        if ($this->groups->removeElement($group)) {
            $group->removeUser($this);
        }

        return $this;
    }
}

Сущность `Group`

<?php

namespace App\Entity;

use Doctrine\Common\Collections\ArrayCollection;
use Doctrine\Common\Collections\Collection;
use Doctrine\ORM\Mapping as ORM;

#[ORM\Entity]
class Group
{
    #[ORM\Id]
    #[ORM\GeneratedValue]
    #[ORM\Column(type: 'integer')]
    private int $id;

    #[ORM\Column(type: 'string', length: 255)]
    private string $name;

    #[ORM\ManyToMany(targetEntity: User::class, mappedBy: 'groups')]
    private Collection $users;

    public function __construct()
    {
        $this->users = new ArrayCollection();
    }

    // Геттеры и сеттеры

    public function getId(): int
    {
        return $this->id;
    }

    public function getName(): string
    {
        return $this->name;
    }

    public function setName(string $name): self
    {
        $this->name = $name;

        return $this;
    }

    public function getUsers(): Collection
    {
        return $this->users;
    }

    public function addUser(User $user): self
    {
        if (!$this->users->contains($user)) {
            $this->users[] = $user;
        }

        return $this;
    }

    public function removeUser(User $user): self
    {
        $this->users->removeElement($user);

        return $this;
    }
}

2. Миграции

После того как мы создали сущности, необходимо сгенерировать и выполнить миграцию базы данных:

php bin/console make:migration
php bin/console doctrine:migrations:migrate

3. Пример с таблицами и тестовыми данными

Для того чтобы продемонстрировать работу с сущностями, давайте создадим таблицы и заполним их тестовыми данными. В базе данных будут следующие таблицы:

4. Пример работы с данными

Теперь давайте выведем группы для пользователя с ID = 1. Выполнив следующий код, мы получим:

$userRepository = $entityManager->getRepository(User::class);
$user = $userRepository->find(1);

// Выводим группы пользователя
foreach ($user->getGroups() as $group) {
    echo $group->getName();
}

Ожидаемый вывод для пользователя с ID = 1 (Иван Иванов):

Администраторы
Модераторы

Для пользователя с ID = 4 (Мария Смирнова) вывод будет:

Модераторы
Разработчики
Сотрудники

5. Заключение

Связь Many-to-Many в Symfony — это мощный инструмент, который позволяет организовать отношения между сущностями

Простой скрипт для отслеживания доступности сайта с уведомлением в Telegram

2024-12-21T15:04:24.664Z

Современные системы мониторинга позволяют гибко настроить мониторинг сайта и уведомления к нему, но что если вам нужно просто знать доступен ли ваш сайт на данный момент и посылать уведомление в телеграм-чат если что-то не так? Для этого можно использовать данный php-скрипт который можно разместить на сервере и запускать его по крону

Шаг 1. Устанавливаем необходимые зависимости

composer require guzzlehttp/guzzle telegram-bot/api

Шаг 2. Создаем файл site_health_checker.php

<?php

require 'vendor/autoload.php';

use GuzzleHttp\Exception\ConnectException;
use GuzzleHttp\Exception\RequestException;
use TelegramBot\Api\BotApi;
use GuzzleHttp\Client;

function checkSite($url)
{
    $client = new Client([
        'timeout'         => 30, //время ожидания ответа 30 секунд
        'connect_timeout' => 30,
    ]);

    $start = microtime(true);

    try {
        $response = $client->request('HEAD', $url);
        $httpCode = $response->getStatusCode();
    } catch (RequestException $e) {
        $httpCode = $e->getCode() ?: 0;
    } catch (ConnectException $e) {
        $httpCode = 0;
    }

    $totalTime = microtime(true) - $start;

    return [
        'httpCode'     => $httpCode,
        'responseTime' => $totalTime,
    ];
}

function sendTelegramNotification($token, $chatId, $message)
{
    $bot = new BotApi($token);
    $bot->sendMessage($chatId, $message);
}


$telegramToken  = 'ваш телеграм токен';
$telegramChatId = 'id чата телеграмм';
$sites          = [
    'https://example.ru',
    'https://google.com',
//ваш список сайтов
];

foreach ($sites as $site) {
    $result       = checkSite($site);
    $httpCode     = $result['httpCode'];
    $responseTime = $result['responseTime'];

//если код ответа отличается от успешного  (200) или время ответа больше 30 секунд посылаем уведомление в телеграмм чат
    if ($httpCode != 200 || $responseTime > 30) {
        $message = "❗ Проблема с сайтом: $site\n";
        $message .= "HTTP-код: $httpCode\n";
        $message .= sprintf("Время ответа: %.2f секунд\n", $responseTime);
        sendTelegramNotification($telegramToken, $telegramChatId, $message);
    } else {
        echo "✅ Сайт $site работает нормально (HTTP $httpCode, время ответа: " . sprintf("%.2f",
                $responseTime) . " секунд).\n";
    }
}

Шаг 3. Настраиваем задачу cron (команда в консоли crontab -e) чтобы ваш скрипт запускался, к примеру, раз в 3 минуты

*/3 * * * * php site_health_checker.php

Готово! Теперь в случае неполадок вы будете получать подобные сообщения в свой телеграмм-чат
❗ Проблема с сайтом: https://example.ru

HTTP-код: 503

Время ответа: 45.23 секунд

Обработка десятков тысяч заказов и смена статуса с ограничением по запросам API

2024-12-17T16:21:36.608Z

🚀 Задача: Обработка десятков тысяч заказов и смена статуса с ограничением по запросам API 📦

Представьте, что перед вами стоит задача обновить статус для нескольких десятков тысяч заказов в внешней системе, но API ограничивает количество запросов до 50 в секунду. Как эффективно решить такую задачу? 🤔

Давайте разберемся, как с помощью генераторов, пакетных запросов и параллельных запросов через Guzzle можно справиться с этой задачей без перегрузки системы! 😎

🔧 Решение проблемы с обработкой заказов:

1️⃣ Используем генераторы:
Вместо того, чтобы сразу загружать все заказы в память, мы применяем генератор, который будет извлекать данные "по частям". Это помогает эффективно работать с большими объемами данных без переполнения памяти.

2️⃣ Пакетная обработка данных:
Каждую порцию данных (например, 50 заказов) извлекаем и отправляем на API. Это позволяет избежать перегрузки БД и контролировать количество запросов, отправляемых на сервер.

3️⃣ Параллельные запросы с Guzzle:
API ограничивает нас 50 запросами в секунду, но это не значит, что мы не можем отправлять их параллельно! Мы используем асинхронные запросы через Guzzle, отправляя сразу 50 запросов за раз. Это позволяет значительно ускорить процесс обработки, не нарушая лимит.

use GuzzleHttp\Client; use GuzzleHttp\Promise; use GuzzleHttp\Exception\RequestException;

// Генератор для выборки заказов из базы данных function getOrdersFromDatabase($batchSize = 50) {

$offset = 0;

while (true) { // Выполнение SQL-запроса для выборки заказов $stmt = $db->prepare("SELECT * FROM orders WHERE status = 'pending' LIMIT :batchSize OFFSET :offset"); $stmt->bindParam(':batchSize', $batchSize, PDO::PARAM_INT); $stmt->bindParam(':offset', $offset, PDO::PARAM_INT); $stmt->execute();

$data = $stmt->fetchAll();

// Если данных больше нет, выходим из цикла if (empty($data)) { break; }

// Возвращаем порцию заказов yield $data;

// Переходим к следующей порции $offset += $batchSize; } }

// Функция для отправки статуса заказов на API function updateOrderStatus(Client $client, $orders) { $requests = []; foreach ($orders as $order) { // Создаем асинхронный запрос для обновления статуса $requests[] = $client->postAsync('https://api.example.com/update-status', [ 'json' => [ 'order_id' => $order['id'], 'status' => 'completed', // Пример статуса ] ]); }

// Возвращаем массив промисов return Promise\settle($requests); }

// Основная логика обработки заказов function processOrders() { $client = new Client(); // Инициализация Guzzle клиента $batchSize = 50; // Размер пачки заказов $maxRequestsPerSecond = 50; // Лимит API запросов в секунду $delayBetweenBatches = 1; // Задержка между батчами (сек)

// Процесс обработки заказов по батчам foreach (getOrdersFromDatabase($batchSize) as $batch) { try { // Отправляем 50 параллельных запросов на API $results = updateOrderStatus($client, $batch)->wait();

// Логируем успешные обновления (по желанию) foreach ($results as $result) { if ($result['state'] === 'fulfilled') { echo "Order {$batch[0]['id']} successfully updated\n"; // Пример логирования } else { echo "Failed to update order {$batch[0]['id']}: {$result['reason']->getMessage()}\n"; } }

} catch (RequestException $e) { // Обработка ошибок API или подключения echo "Request failed: " . $e->getMessage() . "\n"; } // Задержка между батчами для соблюдения лимита запросов в секунду sleep($delayBetweenBatches); } }

// Вызов основной функции processOrders();

Как использовать Puppeteer с NestJS для парсинга рейтинга

2024-12-17T16:13:38.669Z

В этом посте покажу, как с помощью библиотеки Puppeteer спарсить рейтинг с сайта с использованием фреймворка NestJS.

📌 Шаг 1: Установка зависимостей

Для начала установим необходимые пакеты:

npm install puppeteer
npm install @nestjs/axios
npm install --save-dev @types/puppeteer

📌 Шаг 2: Создаем сервис для парсинга

Теперь создадим сервис в NestJS, который будет парсить данные с сайта. В нашем примере мы будем извлекать рейтинг из элемента с определенным классом.

rating.service.ts
import { Injectable } from '@nestjs/common';
import * as puppeteer from 'puppeteer';

@Injectable()
export class RatingService {
  async getRating(url: string): Promise<number> {
    const browser = await puppeteer.launch({ headless: true });
    const page = await browser.newPage();

    await page.goto(url, { waitUntil: 'domcontentloaded' });

    // Пример: извлекаем рейтинг с элемента с классом '.rating'
    const rating = await page.$eval('.rating', (el) => {
      return parseFloat(el.textContent.trim());
    });

    await browser.close();

    return rating;
  }
}

📌 Шаг 3: Создаем контроллер для API

Теперь создадим контроллер, который будет обрабатывать запросы и отдавать рейтинг в формате JSON.

rating.controller.ts
import { Controller, Get, Query } from '@nestjs/common';
import { RatingService } from './rating.service';

@Controller('rating')
export class RatingController {
  constructor(private readonly ratingService: RatingService) {}

  @Get()
  async getRating(@Query('url') url: string) {
    const rating = await this.ratingService.getRating(url);
    return { rating };
  }
}

📌 Шаг 4: Добавляем сервис и контроллер в модуль

Не забываем добавить сервис и контроллер в наш модуль:

app.module.ts
import { Module } from '@nestjs/common';
import { RatingService } from './rating.service';
import { RatingController } from './rating.controller';

@Module({
  imports: [],
  controllers: [RatingController],
  providers: [RatingService],
})
export class AppModule {}

📌 Шаг 5: Запуск проекта

Теперь запускаем приложение:

npm run start

🔗 Шаг 6: Тестируем

Отправляем запрос к API, передав URL сайта:

GET /rating?url=https://example.com

В ответе получим рейтинг:

{
  "rating": 4.5
}

🎉 Поздравляем! Теперь у вас есть сервис, который парсит рейтинг с сайтов с помощью Puppeteer и NestJS!