Контроль расходов на SMS через API: как сделать свою систему финансового мониторинга за вечер

Привет, Хабр. На связи Катя Саяпина, менеджер продуктов МТС Exolve. В этой статье разберём, как предотвратить приостановку бизнеса — вовремя пополнять баланс на отправку SMS. С минимальными усилиями соберём свою систему мониторинга расходов на сообщения. Будем фиксировать фактические траты, отслеживать аномалии, строить линейный прогноз и слать себе контрольные SMS.

В статье собрано решение на PHP с Composer, cron и MySQL. Всё максимально просто, чтобы за один вечер развернуть систему на любом сервере без внешних зависимостей.

Система состоит из двух скриптов

Один собирает данные, другой их анализирует и отправляет уведомления по двум триггерам.

Сбор данных

Скрипт запускается каждый час по cron, запрашивает у МТС Exolve количество отправленных SMS за последние 60 минут и текущий баланс и сохраняет всё в базу данных.

Анализ и отправка уведомлений

Запускаются после сбора данных и проверяют историю за последний 31 день. Здесь могут сработать два триггера.

Триггер 1. Баланс на исходе

Система рассчитывает, сколько SMS в среднем отправлялось в сутки за последний 31 день.
Для расчёта берётся медианное количество SMS и умножается на стоимость одного сообщения. В этом примере стоимость сообщения устанавливается вручную — в среднем 3 ₽ за аутентификационное уведомление. Затем сумма на балансе делится на полученное число — так мы видим количество дней, на которое хватит денег.

Если по текущему темпу расходов денег осталось на 5 дней или меньше, отправляется сообщение:

⏳ Баланс 35 000 ₽, хватит на 4 дня. Пополните счёт.

Триггер 2. Всплеск

Система считает количество SMS, отправленных за последние календарные сутки, и сравнивает с медианой за последний 31 день. Если за сутки отправлено в два раза и больше сообщений, чем медианное значение, то подразумевается, что произошёл всплеск. Получаем такое уведомление:

🚨 За сутки отправлено 5 100 SMS — это в 2,3 раза больше обычного. Проверьте активность. Баланса хватит ещё на 1,7 такого дня.

В уведомлении также указывается, на сколько дней хватит текущего баланса, если расход продолжится в подобном темпе.

Установка и запуск проекта

Вся логика разбита по папкам: app/ — сервисы, config/ — зависимости, artisan.php — точка входа для команд. Конфигурация хранится в .env.

Чтобы всё заработало, нужно

• Установить зависимости через Composer.

• Задать параметры окружения, такие как доступ к БД и API-ключ.

• Создать таблицу в MySQL.

• Настроить два cron-скрипта: один для сбора статистики, второй для анализа и уведомлений.

sms_monitoring/ ├── app/ │   ├── Console/ │   │   └── Command/ │   │       ├── CollectStatsCommand.php # Команда для сбора статистики SMS │   │       └── AnalyzeBalanceCommand.php  # Команда для анализа баланса │   ├── DTO/ │   │   └── SmsStatDTO.php    # Объект передачи данных для SMS статистики │   ├── Infrastructure/ │   │   └── Database.php  # Обёртка над PDO и конфигурация подключения к БД │   ├── Repository/ │   │   └── SmsStatRepository.php    # Работа с таблицей статистики │   ├── Service/ │   │   ├── BalanceAnalyzerService.php  # Сервис анализа баланса │   │   ├── ExolveApiService.php     # Сервис запроса статистики от МТС Exolve │   │   ├── SmsSenderService.php     # Сервис для отправки SMS ├── bootstrap/ │   └── app.php                   # Инициализация контейнера и автозагрузка ├── config/ │   └── container.php             # Конфигурация зависимостей PHP-DI ├── cron/ │   ├── collect_stats.sh     # Shell-скрипт запуска команды сбора статистики │   ├── analyze_balance.sh   # Shell-скрипт запуска команды анализа баланса ├── routes/ │   └── console.php              # Регистрация команд (маршруты CLI) ├── artisan.php                  # Точка входа CLI-приложения ├── .env                         # Переменные окружения (DB, API_KEY и т.д.) ├── composer.json                # Автозагрузка и зависимости ├── database.sql                 # SQL-дамп структуры базы данных

mkdir sms_monitoring cd sms_monitoring composer init composer require vlucas/phpdotenv guzzlehttp/guzzle

{    "autoload": {        "psr-4": {            "App\\": "app/"        }    },    "require": {        "vlucas/phpdotenv": "^5.6",        "guzzlehttp/guzzle": "^7.9"    } }

composer dump-autoload

DB_HOST=ваш хост DB_PORT=ваш порт DB_NAME=sms_monitoring DB_USER=root DB_PASS=root   EXOLVE_API_KEY=ваш_ключ EXOLVE_API_URL=https://api.exolve.ru EXOLVE_SENDER=номер_отправителя ALERT_PHONE=номер_получателя

CREATE DATABASE sms_monitoring CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci;   CREATE TABLE sms_stats (    id        INT AUTO_INCREMENT PRIMARY KEY,    date_hour DATETIME       NOT NULL UNIQUE,    sms_count INT            NOT NULL,    balance   DECIMAL(12, 2) NOT NULL );

Шаг 1. Инициализация приложения

Файл bootstrap/app.php загружает переменные из .env, подключает автозагрузку Composer и собирает мини-контейнер DI. Остальная логика берёт зависимости именно отсюда, так что перенос сервиса сводится к composer install и правильному .env.

<?php   require_once __DIR__ . '/../vendor/autoload.php';   use Dotenv\Dotenv;   $dotenv = Dotenv::createImmutable(__DIR__ . '/../'); $dotenv->load();   $definitions = require __DIR__ . '/../config/container.php';   $container = [];   foreach ($definitions as $key => $factory) {    $container[$key] = fn() => $factory($container); }   return $container;

Шаг 2. Основные компоненты приложения

Вся бизнес-логика приложения собрана в одном месте и состоит из восьми компонентов: она подключается к базе данных, получает статистику по API, сохраняет данные, анализирует их и отправляет SMS.

Они работают вместе: раз в час данные попадают в базу, раз в день анализируются, и при необходимости отправляется уведомление. Далее — подробно про каждый компонент.

Подключение к БД — Infrastructure/Database.php

Отвечает за соединение с MySQL через PDO, используя параметры из .env. Реализован как Singleton — подключение создаётся один раз и переиспользуется всеми сервисами.

<?php   namespace App\Infrastructure;   use PDO; use PDOException; use RuntimeException;   final class Database {    private static ?PDO $pdo = null;      private function __construct()    {    }      public static function getConnection(): PDO    {        if (self::$pdo === null) {            $host = getenv('DB_HOST') ?? null;            $port = getenv('DB_PORT') ?? '3306';            $db = getenv('DB_NAME') ?? null;            $user= getenv('DB_USER') ?? null;            $pass = getenv('DB_PASS') ?? null;              if (!$host || !$db || !$user) {                throw new RuntimeException('Конфигурация базы данных отсутствует в переменных среды.');            }              $dsn = sprintf(                'mysql:host=%s;port=%s;dbname=%s;charset=utf8mb4',                $host,                $port,                $db            );              try {                self::$pdo = new PDO(                    $dsn,                    $user,                    $pass,                    [                        PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,                        PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,                        PDO::ATTR_EMULATE_PREPARES => false,                    ]                );            } catch (PDOException $e) {                throw new RuntimeException('Подключение к базе данных не удалось: ' . $e->getMessage());            }        }          return self::$pdo;    } }

Передача статистики — app/DTO/SmsStatDTO.php

Хранит данные за каждый час: количество отправленных сообщений, баланс, временную метку. Используется для передачи информации между слоями — от API до базы и анализа.

<?php   namespace App\DTO;   use DateTimeImmutable;   class SmsStatDTO {    public DateTimeImmutable $dateHour;    public int $smsCount;    public float $balance;      public function __construct(DateTimeImmutable $dateHour, int $smsCount, float $balance)    {        $this->dateHour = $dateHour;        $this->smsCount = $smsCount;        $this->balance = $balance;    } } 

Сохранение и извлечение данных из БД — app/Repository/SmsStatRepository.php

Репозиторий для работы с таблицей sms_stats. Сохраняет полученную статистику и отдаёт данные за последний 31 день. Использует PDO для SQL-запросов, обрабатывает дубли и возвращает данные в удобном для анализа виде.

<?php   namespace App\Repository;   use App\DTO\SmsStatDTO; use PDO;   class SmsStatRepository {    private PDO $pdo;      public function __construct(PDO $pdo)    {        $this->pdo = $pdo;    }      public function save(SmsStatDTO $stat): void    {        $stmt = $this->pdo->prepare("            INSERT INTO sms_stats (date_hour, sms_count, balance)            VALUES (?, ?, ?)            ON DUPLICATE KEY UPDATE                sms_count = VALUES(sms_count),                balance = VALUES(balance)        ");          $stmt->execute([            $stat->dateHour->format('Y-m-d H:00:00'),            $stat->smsCount,            $stat->balance        ]);    }      public function getLast31DaysStats(): array    {        $stmt = $this->pdo->query("            SELECT               date_hour,               sms_count,               balance            FROM sms_stats            WHERE date_hour >= NOW() - INTERVAL 31 DAY        ");        return $stmt->fetchAll(PDO::FETCH_ASSOC);    } } 

Получение баланса и статистики отправок по API — app/Service/ExolveApiService.php

Обращается к МТС Exolve по API — получает текущий баланс и количество отправленных SMS. Инкапсулирует работу с HTTP-клиентом Guzzle, автоматически подставляя заголовки и параметры. Обрабатывает ответы от API, проверяя их корректность и отбрасывая исключения при обнаружении ошибок. Используется другими сервисами приложения для получения актуальных данных о состоянии счёта и активности.

<?php   namespace App\Service;   use GuzzleHttp\Client; use RuntimeException; use stdClass;   class ExolveApiService {    private Client $client;    private string $apiKey;    private string $baseUri;    private float $timeout;      public function __construct()    {        $this->apiKey = getenv('EXOLVE_API_KEY') ?? '';        $this->baseUri = getenv('EXOLVE_API_URL') ?? 'https://api.exolve.ru';        $this->timeout = (float)(getenv('EXOLVE_API_TIMEOUT') ?? 10.0);          if (empty($this->apiKey)) {            throw new RuntimeException('EXOLVE_API_KEY не задан в переменных окружения.');        }          $this->client = new Client([            'base_uri' => 'https://api.exolve.ru',            'headers' => [                'Authorization' => 'Bearer ' . $this->apiKey,                'Content-Type' => 'application/json',                'Accept' => 'application/json',            ],            'timeout' => 10.0,        ]);    }      public function getBalance(): array    {        $response = $this->client->post('/finance/v1/GetBalance', [            'json' => new stdClass()        ]);          $data = json_decode($response->getBody()->getContents(), true);          if (!isset($data['balance'])) {            throw new RuntimeException('Неверный ответ от GetBalance');        }          return [            'balance' => (float)$data['balance'],            'credit_limit' => isset($data['credit_limit']) ? (float)$data['credit_limit'] : 0.0,        ];    }      public function getSmsCount(array $filters = []): int    {        $response = $this->client->post('/messaging/v1/GetCount', [            'json' => $filters ?: new stdClass()        ]);          $data = json_decode($response->getBody()->getContents(), true);          if (!isset($data['count'])) {            throw new RuntimeException('Неверный ответ от GetCount');        }          return (int)$data['count'];    } } 

Отправка уведомлений — app/Service/SmsSenderService.php

Отправляет уведомления через SMS API при низком балансе или резком росте трафика. Проверяет наличие параметров в окружении и обрабатывает ошибки при отправке.

<?php   namespace App\Service;   use GuzzleHttp\Client; use Throwable;   class SmsSenderService {    private Client $client;      public function __construct()    {        $this->client = new Client();    }      public function send(string $to, string $message): void    {        $url = getenv('EXOLVE_API_URL') . '/messaging/v1/SendSMS';        $sender = getenv('EXOLVE_SENDER') ?? null;          if (empty($sender)) {            echo 'В env отсутствует номер для отправки!';            return;        }          try {            $this->client->post($url, [                'headers' => [                    'Authorization' => 'Bearer ' . getenv('EXOLVE_API_KEY'),                    'Content-Type' => 'application/json',                ],                'json' => [                    'number' =>  getenv('EXOLVE_SENDER'),                    'destination' => $to,                    'text' => $message                ]            ]);            echo "SMS отправлено: {$to}\n";        } catch (Throwable $e) {            echo "Ошибка отправки SMS: {$e->getMessage()}\n";        }    } }

Считает медиану и отправляет предупреждения при рисках — app/Service/BalanceAnalyzerService.php

Считает медиану суточных отправок, прогнозирует, на сколько дней хватит баланса. Отправляет SMS, если денег осталось мало или активность резко выросла.

<?php   namespace App\Service;   use App\Repository\SmsStatRepository;   class BalanceAnalyzerService {    private SmsStatRepository $repository;    private SmsSenderService $smsSender;    private const SMS_COST = 3;    public function __construct(SmsStatRepository $repository, SmsSenderService $smsSender)    {        $this->repository = $repository;        $this->smsSender = $smsSender;    }      public function analyze(): void    {        $stats = $this->repository->getLast31DaysStats();          if (count($stats) < 10) {            echo "Недостаточно данных для анализа\n";            return;        }          // Подсчет количества SMS по дням.        $dailySums = [];        foreach ($stats as $row) {            $day = substr($row['date_hour'], 0, 10);            $dailySums[$day] = ($dailySums[$day] ?? 0) + $row['sms_count'];        }          // Вычисление медианы отправленных SMS за сутки.        $dailyValues = array_values($dailySums);        sort($dailyValues);        $count = count($dailyValues);        $median = $count % 2 === 0            ? ($dailyValues[$count / 2 - 1] + $dailyValues[$count / 2]) / 2            : $dailyValues[floor($count / 2)];          $smsCost = self::SMS_COST;        $lastBalance = $stats[count($stats) - 1]['balance'];        $daysLeft = $median > 0 ? round($lastBalance / ($median * $smsCost), 1) : PHP_INT_MAX;          // Отправка уведомления при малом остатке баланса.        if ($daysLeft <= 5) {            $this->smsSender->send(                getenv('ALERT_PHONE'),                "⏳ Баланс {$lastBalance} ₽, хватит на {$daysLeft} дней. Пополните счёт."            );        }          // Отправка уведомления при резком росте отправленных SMS.        $today = date('Y-m-d');        $lastDaySum = $dailySums[$today] ?? 0;        if ($median > 0 && $lastDaySum > $median * 2) {            $criticalDaysLeft = round($lastBalance / ($lastDaySum * $smsCost), 1);            $ratio = round($lastDaySum / $median, 1);            $this->smsSender->send(                getenv('ALERT_PHONE'),                "🚨 За сутки отправлено {$lastDaySum} SMS — это в {$ratio} раза больше обычного. Проверьте активность. Баланса хватит ещё на {$criticalDaysLeft} таких дней."            );        }    } } 

Сбор статистики по API — app/Console/Command/AnalyzeBalanceCommand.php

Консольная команда проверяет текущий баланс и уровень трафика. Делегирует работу BalanceAnalyzerService и выводит результаты в консоль. Может использоваться в cron или по расписанию для регулярного мониторинга состояния.

<?php   namespace App\Console\Command;   use App\Service\BalanceAnalyzerService;   class AnalyzeBalanceCommand {    private BalanceAnalyzerService $analyzer;      public function __construct(BalanceAnalyzerService $analyzer)    {        $this->analyzer = $analyzer;    }      public function handle(): void    {        $this->analyzer->analyze();    } } 

Анализ данных и отправка SMS — app/Console/Command/CollectStatsCommand.php

Консольная команда для сбора статистики и сохранения её в базу данных. Получает количество отправленных SMS и текущий баланс, формируя запись с временной меткой.

Собирает данные для последующего анализа динамики расходов и активности сервиса.
В случае ошибки информирует пользователя о причине сбоя через консоль.

<?php   namespace App\Console\Command;   use App\Repository\SmsStatRepository; use App\Service\ExolveApiService; use App\DTO\SmsStatDTO; use DateTimeImmutable; use DateTimeZone; use Exception;   class CollectStatsCommand {    private SmsStatRepository $repository;    private ExolveApiService $api;      public function __construct(SmsStatRepository $repository, ExolveApiService $api)    {        $this->repository = $repository;        $this->api = $api;    }      /**     * @throws Exception     */    public function handle(): void    {        try {            $smsCount = $this->api->getSmsCount();            $balanceData = $this->api->getBalance();              $dto = new SmsStatDTO(                new DateTimeImmutable('now', new DateTimeZone('UTC')),                $smsCount,                $balanceData['balance']            );              $this->repository->save($dto);              echo "Данные сохранены: {$smsCount} SMS, баланс {$balanceData['balance']} ₽\n";        } catch (Exception $e) {            echo "Произошла ошибка: " . $e->getMessage() . "\n";        }    } }  

Шаг 3. Определение зависимостей и маршрутов

Все компоненты приложения связываются через простой контейнер зависимостей и вызываются по имени через CLI-маршруты — чтобы управлять логикой централизованно и запускать команды без лишней связки между файлами.

Контейнер зависимостей config/container.php

Описывает, как создавать экземпляры сервисов, команд и репозиториев с учётом их зависимостей. Упрощает управление связями между классами и поддерживает единый стиль инициализации компонентов.

<?php   use App\Console\Command\AnalyzeBalanceCommand; use App\Console\Command\CollectStatsCommand; use App\Infrastructure\Database; use App\Repository\SmsStatRepository; use App\Service\ExolveApiService; use App\Service\SmsSenderService; use App\Service\BalanceAnalyzerService;   return [    'pdo' => fn() => Database::getConnection(),      'sms_stat_repository' => fn($c) => new SmsStatRepository($c['pdo']()),    'exolve_api_service' => fn() => new ExolveApiService(),    'sms_sender_service' => fn() => new SmsSenderService(),      'balance_analyzer_service' => fn($c) => new BalanceAnalyzerService(        $c['sms_stat_repository'](),        $c['sms_sender_service']()    ),      'collect_stats_command' => fn($c) => new CollectStatsCommand(        $c['sms_stat_repository'](),        $c['exolve_api_service']()    ),      'analyze_balance_command' => fn($c) => new AnalyzeBalanceCommand(        $c['balance_analyzer_service']()    ), ];   

Маршруты CLI-команд routes/console.php

Позволяет запускать команды через artisan.php, указывая их имя в аргументах командной строки. Обеспечивает удобный способ управления командами без жёсткой привязки к конкретным файлам или структурам.

<?php   use App\Console\Command\CollectStatsCommand; use App\Console\Command\AnalyzeBalanceCommand;   return [    'collect:stats' => fn($c) => new CollectStatsCommand(        $c['sms_stat_repository'](),        $c['exolve_api_service']()    ),      'analyze:balance' => fn($c) => new AnalyzeBalanceCommand(        $c['balance_analyzer_service']()    ), ];   

Шаг 4.  Точка входа для консольных команд — artisan.php

Загружает контейнер и маршруты команд, обрабатывает ввод пользователя из командной строки. Проверяет существование и корректность команды, передавая управление соответствующему обработчику. Позволяет централизованно управлять консольными сценариями без использования сторонних фреймворков.

<?php   $container = require __DIR__ . '/bootstrap/app.php'; $routes = require __DIR__ . '/routes/console.php';   $command = $argv[1] ?? null;   if (!$command || !isset($routes[$command])) {    echo "Неизвестная команда. Доступные команды:\n";    foreach (array_keys($routes) as $name) {        echo "  - $name\n";    }    exit(1); }   $handlerFactory = $routes[$command];   if (!is_callable($handlerFactory)) {    echo "Ошибка: обработчик команды не является функцией\n";    exit(1); }   $handler = $handlerFactory($container);   if (!method_exists($handler, 'handle')) {    echo "Ошибка: у команды нет метода handle()\n";    exit(1); }   $handler->handle();

Шаг 5.  Автоматизация с cron

Сбор статистики с cron/collect_stats.sh:

#!/bin/bash php /var/www/html/artisan.php collect:stats

Анализ баланса с cron/analyze_balance.sh:

#!/bin/bash php /var/www/html/artisan.php analyze:balance

Шаг 6.  Настройка cron-задач

Для регулярного сбора статистики и анализа баланса настроим cron.

Скрипты уже готовы

cron/collect_stats.sh — для сбора статистики, запускаем каждый час.
cron/analyze_balance.sh — для анализа баланса и проверки аномалий, запускаем раз в день.

Пример crontab-записи для пользователя www-data:

0 * * * * /var/www/html/cron/collect_stats.sh 45 23 * * * /var/www/html/cron/analyze_balance.sh

Шаг 7. Получаем SMS

Заключение

Теперь у нас есть структурированный и современный проект по контролю расходов на SMS — на базе МТС Exolve с хранением статистики в MySQL. В итоге за вечер можно развернуть собственную систему мониторинга расходов, которая будет автоматически собирать данные, анализировать их и присылать уведомления о рисках снижения баланса или неожиданных всплесках активности. Весь код — на GitHub.

Для повышения точности прогнозов можно добавить учёт количества сегментов через параметр segments_count в методе GetList. Также за счёт параметра category можно разделить сообщения на рекламные, авторизационные, транзакционные и сервисные, так как их стоимость различается. Если вам интересно, пишите в комментариях. Мы доработаем решение и опубликуем продолжение статьи.