+
+
+
+
+
+
+
+
+
+```
+
+### Script Setup
+
+```vue
+
+```
+
+### Styles
+
+```vue
+
+```
+
+## Component Naming
+
+```vue
+
+{{ title }}
+
+
+
+
+
+
+
+
+
+
+
+```
+
+## Lists
+
+```vue
+
+
+
+ {{ item.name }}
+
+
+
+
+ {{ item.name }}
+
+
+```
+
+## Form Handling
+
+```vue
+
+
+
+
+
+```
+
+## PrimeVue Components
+
+```vue
+
+
+
+
+
+
+
+
+
+
+
+
+
+ {{ data.id }}
+ {{ data.telegram_user_id }}
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/frontend/spa/src/main.js b/frontend/spa/src/main.js
index ab7671c..f7aa5d7 100644
--- a/frontend/spa/src/main.js
+++ b/frontend/spa/src/main.js
@@ -8,6 +8,7 @@ import {useSettingsStore} from "@/stores/SettingsStore.js";
import ApplicationError from "@/ApplicationError.vue";
import AppMetaInitializer from "@/utils/AppMetaInitializer.ts";
import {injectYaMetrika} from "@/utils/yaMetrika.js";
+import {saveTelegramCustomer} from "@/utils/ftch.js";
import {register} from 'swiper/element/bundle';
import 'swiper/element/bundle';
@@ -44,6 +45,20 @@ settings.load()
throw new Error('App disabled (maintenance mode)');
}
})
+ .then(async () => {
+ // Сохраняем данные Telegram-пользователя в базу данных
+ const userData = window.Telegram?.WebApp?.initDataUnsafe?.user;
+ if (userData) {
+ try {
+ console.debug('[Init] Saving Telegram customer data');
+ await saveTelegramCustomer(userData);
+ console.debug('[Init] Telegram customer data saved successfully');
+ } catch (error) {
+ // Не прерываем загрузку приложения, если не удалось сохранить пользователя
+ console.warn('[Init] Failed to save Telegram customer data:', error);
+ }
+ }
+ })
.then(() => blocks.processBlocks(settings.mainpage_blocks))
.then(async () => {
console.debug('Load default filters for the main page');
diff --git a/frontend/spa/src/utils/ftch.js b/frontend/spa/src/utils/ftch.js
index b0a8d2c..c036c21 100644
--- a/frontend/spa/src/utils/ftch.js
+++ b/frontend/spa/src/utils/ftch.js
@@ -96,4 +96,15 @@ export async function processBlock(block) {
return await ftch('processBlock', null, block);
}
+/**
+ * Сохранить или обновить данные Telegram-пользователя
+ * @param {Object} userData - Данные пользователя из Telegram.WebApp.initDataUnsafe.user
+ * @returns {Promise}
+ */
+export async function saveTelegramCustomer(userData) {
+ return await ftch('saveTelegramCustomer', null, {
+ user: userData,
+ });
+}
+
export default ftch;
diff --git a/module/oc_telegram_shop/upload/oc_telegram_shop/bastion/Handlers/SendMessageHandler.php b/module/oc_telegram_shop/upload/oc_telegram_shop/bastion/Handlers/SendMessageHandler.php
new file mode 100644
index 0000000..b0e8e59
--- /dev/null
+++ b/module/oc_telegram_shop/upload/oc_telegram_shop/bastion/Handlers/SendMessageHandler.php
@@ -0,0 +1,126 @@
+telegramService = $telegramService;
+ $this->telegramCustomerModel = $telegramCustomerModel;
+ $this->logger = $logger;
+ }
+
+ /**
+ * Отправить сообщение Telegram-пользователю
+ *
+ * @param Request $request HTTP запрос с id (ID записи в таблице) и message
+ * @return JsonResponse JSON ответ с результатом операции
+ * @throws TelegramCustomerNotFoundException Если пользователь не найден
+ * @throws TelegramCustomerWriteNotAllowedException Если пользователь не разрешил писать в PM
+ * @throws RuntimeException Если данные невалидны
+ * @throws \Exception
+ * @throws GuzzleException
+ */
+ public function sendMessage(Request $request): JsonResponse
+ {
+ $customerId = $this->extractCustomerId($request);
+ $message = $this->extractMessage($request);
+
+ // Находим запись по ID
+ $customer = $this->telegramCustomerModel->findById($customerId);
+ if (! $customer) {
+ throw new TelegramCustomerNotFoundException($customerId);
+ }
+
+ $telegramUserId = (int) $customer['telegram_user_id'];
+
+ // Проверяем, что пользователь разрешил писать ему в PM
+ if (! $customer['allows_write_to_pm']) {
+ throw new TelegramCustomerWriteNotAllowedException($telegramUserId);
+ }
+
+ // Отправляем сообщение (telegram_user_id используется как chat_id)
+ // Используем пустую строку для parse_mode чтобы отправлять обычный текст
+ $this->telegramService->sendMessage(
+ $telegramUserId,
+ $message,
+ [],
+ \Openguru\OpenCartFramework\Telegram\Enums\ChatAction::TYPING,
+ '' // Обычный текст без форматирования
+ );
+
+ $this->logger->info('Message sent to Telegram user', [
+ 'oc_customer_id' => $customerId,
+ 'telegram_user_id' => $telegramUserId,
+ 'message_length' => strlen($message),
+ ]);
+
+ return new JsonResponse([
+ 'success' => true,
+ 'message' => 'Message sent successfully',
+ ]);
+ }
+
+ /**
+ * Извлечь ID записи из запроса
+ *
+ * @param Request $request HTTP запрос
+ * @return int ID записи в таблице telecart_customers
+ * @throws RuntimeException Если ID отсутствует или невалиден
+ */
+ private function extractCustomerId(Request $request): int
+ {
+ $jsonData = $request->json();
+ $customerId = isset($jsonData['id']) ? (int) $jsonData['id'] : 0;
+
+ if ($customerId <= 0) {
+ throw new RuntimeException('Customer ID is required and must be positive');
+ }
+
+ return $customerId;
+ }
+
+ /**
+ * Извлечь сообщение из запроса
+ *
+ * @param Request $request HTTP запрос
+ * @return string Текст сообщения
+ * @throws RuntimeException Если сообщение отсутствует или пустое
+ */
+ private function extractMessage(Request $request): string
+ {
+ $jsonData = $request->json();
+ $message = isset($jsonData['message']) ? trim($jsonData['message']) : '';
+
+ if (empty($message)) {
+ throw new RuntimeException('Message is required and cannot be empty');
+ }
+
+ return $message;
+ }
+}
diff --git a/module/oc_telegram_shop/upload/oc_telegram_shop/bastion/Handlers/TelegramCustomersHandler.php b/module/oc_telegram_shop/upload/oc_telegram_shop/bastion/Handlers/TelegramCustomersHandler.php
new file mode 100644
index 0000000..bca93da
--- /dev/null
+++ b/module/oc_telegram_shop/upload/oc_telegram_shop/bastion/Handlers/TelegramCustomersHandler.php
@@ -0,0 +1,330 @@
+builder = $builder;
+ }
+
+ /**
+ * Получить список Telegram-кастомеров с пагинацией, фильтрацией и сортировкой
+ *
+ * @param Request $request HTTP запрос с параметрами пагинации, сортировки и фильтров
+ * @return JsonResponse JSON ответ с данными и метаинформацией
+ */
+ public function getCustomers(Request $request): JsonResponse
+ {
+ $page = max(1, (int) $request->json('page', self::DEFAULT_PAGE));
+ $rows = max(1, (int) $request->json('rows', self::DEFAULT_ROWS));
+ $first = ($page - 1) * $rows;
+
+ $sortField = $request->json('sortField', self::DEFAULT_SORT_FIELD) ?? self::DEFAULT_SORT_FIELD;
+ $sortOrder = $this->normalizeSortOrder((string)$request->json('sortOrder', self::DEFAULT_SORT_ORDER));
+
+ $filters = $request->json('filters', []);
+ $globalFilter = Arr::get($filters, 'global.value');
+
+ // Создаем базовый query с фильтрами
+ $query = $this->buildBaseQuery();
+ $this->applyFilters($query, $filters, $globalFilter);
+
+ // Получаем общее количество записей
+ $countQuery = $this->buildCountQuery();
+ $this->applyFilters($countQuery, $filters, $globalFilter);
+ $totalRecords = (int) ($countQuery->value('total') ?? 0);
+
+ // Применяем сортировку и пагинацию
+ $customers = $query
+ ->orderBy($sortField, $sortOrder)
+ ->offset($first)
+ ->limit($rows)
+ ->get();
+
+ return new JsonResponse([
+ 'data' => [
+ 'data' => $this->mapToResponse($customers),
+ 'totalRecords' => $totalRecords,
+ ],
+ ]);
+ }
+
+ /**
+ * Создать базовый query для выборки данных
+ *
+ * @return Builder
+ */
+ private function buildBaseQuery(): Builder
+ {
+ return $this->builder->newQuery()
+ ->select([
+ 'id',
+ 'telegram_user_id',
+ 'oc_customer_id',
+ 'username',
+ 'first_name',
+ 'last_name',
+ 'language_code',
+ 'is_premium',
+ 'allows_write_to_pm',
+ 'photo_url',
+ 'last_seen_at',
+ 'referral',
+ 'created_at',
+ 'updated_at',
+ ])
+ ->from(self::TABLE_NAME);
+ }
+
+ /**
+ * Создать query для подсчета общего количества записей
+ *
+ * @return Builder
+ */
+ private function buildCountQuery(): Builder
+ {
+ return $this->builder->newQuery()
+ ->select([new RawExpression('COUNT(*) as total')])
+ ->from(self::TABLE_NAME);
+ }
+
+ /**
+ * Применить фильтры к query
+ *
+ * @param Builder $query Query builder
+ * @param array $filters Массив фильтров
+ * @param string|null $globalFilter Глобальный фильтр поиска
+ * @return void
+ */
+ private function applyFilters(Builder $query, array $filters, ?string $globalFilter): void
+ {
+ // Применяем глобальный фильтр
+ if ($globalFilter) {
+ $this->applyGlobalFilter($query, $globalFilter);
+ }
+
+ // Применяем фильтры по колонкам
+ $this->applyColumnFilters($query, $filters);
+ }
+
+ /**
+ * Применить глобальный фильтр поиска
+ *
+ * @param Builder $query Query builder
+ * @param string $searchTerm Поисковый запрос
+ * @return void
+ */
+ private function applyGlobalFilter(Builder $query, string $searchTerm): void
+ {
+ $query->whereNested(function ($q) use ($searchTerm) {
+ $q->where('telegram_user_id', 'LIKE', "%{$searchTerm}%")
+ ->orWhere('username', 'LIKE', "%{$searchTerm}%")
+ ->orWhere('first_name', 'LIKE', "%{$searchTerm}%")
+ ->orWhere('last_name', 'LIKE', "%{$searchTerm}%")
+ ->orWhere('language_code', 'LIKE', "%{$searchTerm}%");
+ });
+ }
+
+ /**
+ * Применить фильтры по колонкам
+ *
+ * @param Builder $query Query builder
+ * @param array $filters Массив фильтров
+ * @return void
+ */
+ private function applyColumnFilters(Builder $query, array $filters): void
+ {
+ foreach ($filters as $field => $filter) {
+ if ($field === 'global') {
+ continue;
+ }
+
+ // Обработка сложных фильтров (constraints)
+ if (isset($filter['constraints']) && is_array($filter['constraints'])) {
+ $this->applyConstraintFilters($query, $field, $filter);
+ continue;
+ }
+
+ // Обработка простых фильтров (обратная совместимость)
+ if (! isset($filter['value']) || $filter['value'] === null || $filter['value'] === '') {
+ continue;
+ }
+
+ $value = $filter['value'];
+ $matchMode = Arr::get($filter, 'matchMode', 'contains');
+
+ $this->applyColumnFilter($query, $field, $value, $matchMode);
+ }
+ }
+
+ /**
+ * Применить сложные фильтры с условиями (AND/OR)
+ *
+ * @param Builder $query Query builder
+ * @param string $field Имя поля
+ * @param array $filter Данные фильтра
+ * @return void
+ */
+ private function applyConstraintFilters(Builder $query, string $field, array $filter): void
+ {
+ $operator = strtolower($filter['operator'] ?? 'and');
+ $constraints = $filter['constraints'];
+
+ // Фильтруем пустые значения (но учитываем false как валидное значение для boolean полей)
+ $activeConstraints = array_filter($constraints, function ($constraint) {
+ if (!isset($constraint['value'])) {
+ return false;
+ }
+ $value = $constraint['value'];
+ // null означает "любой", пропускаем
+ if ($value === null) {
+ return false;
+ }
+ // Пустая строка пропускаем
+ if ($value === '') {
+ return false;
+ }
+ // false - валидное значение для boolean полей
+ return true;
+ });
+
+ if (empty($activeConstraints)) {
+ return;
+ }
+
+ $query->whereNested(function ($q) use ($field, $activeConstraints, $operator) {
+ // Для первого элемента всегда используем where, чтобы начать группу
+ $first = true;
+
+ foreach ($activeConstraints as $constraint) {
+ $value = $constraint['value'];
+ $matchMode = $constraint['matchMode'] ?? 'contains';
+
+ if ($first) {
+ $this->applyColumnFilter($q, $field, $value, $matchMode);
+ $first = false;
+ continue;
+ }
+
+ if ($operator === 'or') {
+ $q->orWhere(function ($subQ) use ($field, $value, $matchMode) {
+ $this->applyColumnFilter($subQ, $field, $value, $matchMode);
+ });
+ } else {
+ $this->applyColumnFilter($q, $field, $value, $matchMode);
+ }
+ }
+ });
+ }
+
+ /**
+ * Применить фильтр для одной колонки
+ *
+ * @param Builder $query Query builder
+ * @param string $field Имя поля
+ * @param mixed $value Значение фильтра
+ * @param string $matchMode Режим совпадения (contains, startsWith, endsWith, equals, notEquals)
+ * @return void
+ */
+ private function applyColumnFilter(Builder $query, string $field, $value, string $matchMode): void
+ {
+ if (in_array($matchMode, ['contains', 'startsWith', 'endsWith'], true)) {
+ $likeValue = $this->buildLikeValue($value, $matchMode);
+ $query->where($field, 'LIKE', $likeValue);
+ } elseif ($matchMode === 'equals') {
+ $query->where($field, '=', $value);
+ } elseif ($matchMode === 'notEquals') {
+ $query->where($field, '!=', $value);
+ } elseif ($matchMode === 'dateIs') {
+ // Для точного совпадения даты используем диапазон от 00:00:00 до 23:59:59
+ $date = date('Y-m-d', strtotime($value));
+ $query->where($field, '>=', $date . ' 00:00:00')
+ ->where($field, '<=', $date . ' 23:59:59');
+ } elseif ($matchMode === 'dateIsNot') {
+ // Для отрицания проверяем, что дата меньше начала дня ИЛИ больше конца дня
+ $date = date('Y-m-d', strtotime($value));
+ $query->whereNested(function ($q) use ($field, $date) {
+ $q->where($field, '<', $date . ' 00:00:00')
+ ->orWhere($field, '>', $date . ' 23:59:59');
+ });
+ } elseif ($matchMode === 'dateBefore') {
+ $query->where($field, '<', date('Y-m-d 00:00:00', strtotime($value)));
+ } elseif ($matchMode === 'dateAfter') {
+ // "После" означает после конца указанного дня
+ $query->where($field, '>', date('Y-m-d 23:59:59', strtotime($value)));
+ }
+ }
+
+ /**
+ * Построить значение для LIKE запроса
+ *
+ * @param string $value Значение
+ * @param string $matchMode Режим совпадения
+ * @return string
+ */
+ private function buildLikeValue(string $value, string $matchMode): string
+ {
+ if ($matchMode === 'startsWith') {
+ return "{$value}%";
+ }
+
+ if ($matchMode === 'endsWith') {
+ return "%{$value}";
+ }
+
+ return "%{$value}%";
+ }
+
+ /**
+ * Нормализовать порядок сортировки
+ *
+ * @param string $sortOrder Порядок сортировки
+ * @return string 'ASC' или 'DESC'
+ */
+ private function normalizeSortOrder(string $sortOrder): string
+ {
+ $normalized = strtoupper($sortOrder);
+
+ return in_array($normalized, ['ASC', 'DESC'], true) ? $normalized : self::DEFAULT_SORT_ORDER;
+ }
+
+ private function mapToResponse(array $customers): array
+ {
+ return array_map(static function (array $customer) {
+ return [
+ 'id' => (int) $customer['id'],
+ 'telegram_user_id' => (int) $customer['telegram_user_id'],
+ 'oc_customer_id' => (int) $customer['oc_customer_id'],
+ 'username' => $customer['username'],
+ 'first_name' => $customer['first_name'],
+ 'last_name' => $customer['last_name'],
+ 'language_code' => $customer['language_code'],
+ 'is_premium' => filter_var($customer['is_premium'], FILTER_VALIDATE_BOOLEAN),
+ 'allows_write_to_pm' => filter_var($customer['allows_write_to_pm'], FILTER_VALIDATE_BOOLEAN),
+ 'photo_url' => $customer['photo_url'],
+ 'last_seen_at' => $customer['last_seen_at'],
+ 'referral' => $customer['referral'],
+ 'created_at' => $customer['created_at'],
+ 'updated_at' => $customer['updated_at'],
+ ];
+ }, $customers);
+ }
+}
diff --git a/module/oc_telegram_shop/upload/oc_telegram_shop/bastion/routes.php b/module/oc_telegram_shop/upload/oc_telegram_shop/bastion/routes.php
index 7eae492..70ec2a1 100755
--- a/module/oc_telegram_shop/upload/oc_telegram_shop/bastion/routes.php
+++ b/module/oc_telegram_shop/upload/oc_telegram_shop/bastion/routes.php
@@ -4,27 +4,28 @@ use Bastion\Handlers\AutocompleteHandler;
use Bastion\Handlers\DictionariesHandler;
use Bastion\Handlers\FormsHandler;
use Bastion\Handlers\LogsHandler;
+use Bastion\Handlers\SendMessageHandler;
use Bastion\Handlers\SettingsHandler;
use Bastion\Handlers\StatsHandler;
+use Bastion\Handlers\TelegramCustomersHandler;
use Bastion\Handlers\TelegramHandler;
return [
'configureBotToken' => [SettingsHandler::class, 'configureBotToken'],
- 'getChatId' => [TelegramHandler::class, 'getChatId'],
- 'getSettingsForm' => [SettingsHandler::class, 'getSettingsForm'],
- 'saveSettingsForm' => [SettingsHandler::class, 'saveSettingsForm'],
- 'testTgMessage' => [TelegramHandler::class, 'testTgMessage'],
- 'getProductsById' => [AutocompleteHandler::class, 'getProductsById'],
- 'getCategoriesById' => [AutocompleteHandler::class, 'getCategoriesById'],
- 'getDashboardStats' => [StatsHandler::class, 'getDashboardStats'],
- 'tgGetMe' => [TelegramHandler::class, 'tgGetMe'],
-
- 'getCategories' => [DictionariesHandler::class, 'getCategories'],
-
'getAutocompleteCategories' => [AutocompleteHandler::class, 'getCategories'],
'getAutocompleteCategoriesFlat' => [AutocompleteHandler::class, 'getCategoriesFlat'],
- 'resetCache' => [SettingsHandler::class, 'resetCache'],
- 'getLogs' => [LogsHandler::class, 'getLogs'],
-
+ 'getCategories' => [DictionariesHandler::class, 'getCategories'],
+ 'getCategoriesById' => [AutocompleteHandler::class, 'getCategoriesById'],
+ 'getChatId' => [TelegramHandler::class, 'getChatId'],
+ 'getDashboardStats' => [StatsHandler::class, 'getDashboardStats'],
'getFormByAlias' => [FormsHandler::class, 'getFormByAlias'],
+ 'getLogs' => [LogsHandler::class, 'getLogs'],
+ 'getProductsById' => [AutocompleteHandler::class, 'getProductsById'],
+ 'getSettingsForm' => [SettingsHandler::class, 'getSettingsForm'],
+ 'getTelegramCustomers' => [TelegramCustomersHandler::class, 'getCustomers'],
+ 'resetCache' => [SettingsHandler::class, 'resetCache'],
+ 'saveSettingsForm' => [SettingsHandler::class, 'saveSettingsForm'],
+ 'sendMessageToCustomer' => [SendMessageHandler::class, 'sendMessage'],
+ 'testTgMessage' => [TelegramHandler::class, 'testTgMessage'],
+ 'tgGetMe' => [TelegramHandler::class, 'tgGetMe'],
];
diff --git a/module/oc_telegram_shop/upload/oc_telegram_shop/database/migrations/20260101000005_create_telecart_customers_table.php b/module/oc_telegram_shop/upload/oc_telegram_shop/database/migrations/20260101000005_create_telecart_customers_table.php
new file mode 100644
index 0000000..e800c1d
--- /dev/null
+++ b/module/oc_telegram_shop/upload/oc_telegram_shop/database/migrations/20260101000005_create_telecart_customers_table.php
@@ -0,0 +1,36 @@
+database->statement($sql);
+ }
+};
+
diff --git a/module/oc_telegram_shop/upload/oc_telegram_shop/framework/Telegram/Enums/TelegramHeader.php b/module/oc_telegram_shop/upload/oc_telegram_shop/framework/Telegram/Enums/TelegramHeader.php
new file mode 100644
index 0000000..7108e9c
--- /dev/null
+++ b/module/oc_telegram_shop/upload/oc_telegram_shop/framework/Telegram/Enums/TelegramHeader.php
@@ -0,0 +1,8 @@
+botToken = $botToken;
$this->settings = $settings;
$this->logger = $logger;
+ $this->initDataDecoder = $initDataDecoder;
}
+ /**
+ * @throws TelegramInvalidSignatureException
+ */
public function validate(Request $request): void
{
if ($this->settings->config()->getApp()->isAppDebug()) {
@@ -32,13 +43,15 @@ class SignatureValidator
return;
}
- $initDataString = base64_decode($request->header('X-Telegram-Initdata'));
-
- if (! $initDataString) {
- throw new TelegramInvalidSignatureException('Invalid Telegram signature!');
+ if (! $request->header(TelegramHeader::INIT_DATA)) {
+ throw new TelegramInvalidSignatureException('Telegram Signature not exists.');
}
- $data = $this->parseInitDataStringToArray($initDataString);
+ try {
+ $data = $this->initDataDecoder->decode($request->header(TelegramHeader::INIT_DATA));
+ } catch (DecodeTelegramInitDataException $e) {
+ throw new TelegramInvalidSignatureException('Invalid Telegram Signature.', 500, $e);
+ }
if (! isset($data['hash'])) {
throw new TelegramInvalidSignatureException('Missing hash in init data');
@@ -55,26 +68,6 @@ class SignatureValidator
}
}
- private function parseInitDataStringToArray(string $initData): array
- {
- parse_str($initData, $parsed);
-
- foreach ($parsed as $key => $value) {
- if ($this->isValidJson($value)) {
- $parsed[$key] = json_decode(urldecode($value), true);
- }
- }
-
- return $parsed;
- }
-
- private function isValidJson(string $jsonString): bool
- {
- json_decode($jsonString);
-
- return (json_last_error() === JSON_ERROR_NONE);
- }
-
private function getCheckString(array $data): string
{
unset($data['hash']);
diff --git a/module/oc_telegram_shop/upload/oc_telegram_shop/framework/Telegram/TelegramInitDataDecoder.php b/module/oc_telegram_shop/upload/oc_telegram_shop/framework/Telegram/TelegramInitDataDecoder.php
new file mode 100644
index 0000000..74e2eb9
--- /dev/null
+++ b/module/oc_telegram_shop/upload/oc_telegram_shop/framework/Telegram/TelegramInitDataDecoder.php
@@ -0,0 +1,60 @@
+parseInitDataStringToArray($initDataString);
+ } catch (JsonException $e) {
+ throw new DecodeTelegramInitDataException(
+ 'Error decoding Telegram init data JSON: ' . $e->getMessage(),
+ 500,
+ $e
+ );
+ }
+ }
+
+ /**
+ * @throws JsonException
+ */
+ private function parseInitDataStringToArray(string $initData): array
+ {
+ parse_str($initData, $parsed);
+
+ foreach ($parsed as $key => $value) {
+ if ($this->isValidJson($value)) {
+ $parsed[$key] = json_decode(urldecode($value), true, 512, JSON_THROW_ON_ERROR);
+ } else {
+ $parsed[$key] = $value;
+ }
+ }
+
+ return $parsed;
+ }
+
+ private function isValidJson(string $string): bool
+ {
+ try {
+ json_decode($string, true, 512, JSON_THROW_ON_ERROR);
+
+ return true;
+ } catch (JsonException $e) {
+ return false;
+ }
+ }
+}
diff --git a/module/oc_telegram_shop/upload/oc_telegram_shop/framework/Telegram/TelegramServiceProvider.php b/module/oc_telegram_shop/upload/oc_telegram_shop/framework/Telegram/TelegramServiceProvider.php
index 2da537a..c4d32a7 100755
--- a/module/oc_telegram_shop/upload/oc_telegram_shop/framework/Telegram/TelegramServiceProvider.php
+++ b/module/oc_telegram_shop/upload/oc_telegram_shop/framework/Telegram/TelegramServiceProvider.php
@@ -21,6 +21,7 @@ class TelegramServiceProvider extends ServiceProvider
return new SignatureValidator(
$app->get(SettingsService::class),
$app->get(LoggerInterface::class),
+ $app->get(TelegramInitDataDecoder::class),
$app->getConfigValue('telegram.bot_token'),
);
});
diff --git a/module/oc_telegram_shop/upload/oc_telegram_shop/src/Exceptions/TelegramCustomerNotFoundException.php b/module/oc_telegram_shop/upload/oc_telegram_shop/src/Exceptions/TelegramCustomerNotFoundException.php
new file mode 100644
index 0000000..1fc3f50
--- /dev/null
+++ b/module/oc_telegram_shop/upload/oc_telegram_shop/src/Exceptions/TelegramCustomerNotFoundException.php
@@ -0,0 +1,24 @@
+telegramCustomerService = $telegramCustomerService;
+ $this->logger = $logger;
+ $this->initDataDecoder = $initDataDecoder;
+ }
+
+ /**
+ * Сохранить или обновить Telegram-пользователя
+ *
+ * @param Request $request HTTP запрос с данными пользователя
+ * @return JsonResponse JSON ответ с результатом операции
+ */
+ public function saveOrUpdate(Request $request): JsonResponse
+ {
+ try {
+ $this->telegramCustomerService->saveOrUpdate(
+ $this->extractTelegramUserData($request)
+ );
+
+ return new JsonResponse([], Response::HTTP_NO_CONTENT);
+ } catch (Throwable $e) {
+ $this->logger->error('Could not save telegram customer data', ['exception' => $e]);
+
+ return new JsonResponse([], Response::HTTP_INTERNAL_SERVER_ERROR);
+ }
+ }
+
+ /**
+ * Извлечь данные Telegram пользователя из запроса
+ *
+ * @param Request $request HTTP запрос
+ * @return array Данные пользователя
+ * @throws RuntimeException|DecodeTelegramInitDataException невозможно извлечь данные пользователя из Request
+ */
+ private function extractTelegramUserData(Request $request): array
+ {
+ $telegramUserData = $request->json('user');
+
+ if (! $telegramUserData) {
+ $telegramUserData = $this->extractUserDataFromInitData($request);
+ }
+
+ return $telegramUserData;
+ }
+
+ /**
+ * @throws DecodeTelegramInitDataException
+ */
+ private function extractUserDataFromInitData(Request $request): array
+ {
+ $raw = $request->header(TelegramHeader::INIT_DATA);
+ if (! $raw) {
+ throw new RuntimeException('No init data found in http request header');
+ }
+
+ $initData = $this->initDataDecoder->decode($raw);
+
+ return Arr::get($initData, 'user');
+ }
+}
diff --git a/module/oc_telegram_shop/upload/oc_telegram_shop/src/Models/TelegramCustomer.php b/module/oc_telegram_shop/upload/oc_telegram_shop/src/Models/TelegramCustomer.php
new file mode 100644
index 0000000..c4a0aca
--- /dev/null
+++ b/module/oc_telegram_shop/upload/oc_telegram_shop/src/Models/TelegramCustomer.php
@@ -0,0 +1,123 @@
+database = $database;
+ $this->builder = $builder;
+ }
+
+ /**
+ * Найти запись по ID
+ *
+ * @param int $id ID записи
+ * @return array|null Данные пользователя или null если не найдено
+ */
+ public function findById(int $id): ?array
+ {
+ return $this->builder
+ ->newQuery()
+ ->select(['*'])
+ ->from(self::TABLE_NAME)
+ ->where('id', '=', $id)
+ ->firstOrNull();
+ }
+
+ /**
+ * Найти запись по Telegram user ID
+ *
+ * @param int $telegramUserId Telegram user ID
+ * @return array|null Данные пользователя или null если не найдено
+ */
+ public function findByTelegramUserId(int $telegramUserId): ?array
+ {
+ return $this->builder
+ ->newQuery()
+ ->select(['*'])
+ ->from(self::TABLE_NAME)
+ ->where('telegram_user_id', '=', $telegramUserId)
+ ->firstOrNull();
+ }
+
+ /**
+ * Найти запись по oc_customer_id
+ *
+ * @param int $customerId ID покупателя в OpenCart
+ * @return array|null Данные пользователя или null если не найдено
+ */
+ public function findByCustomerId(int $customerId): ?array
+ {
+ return $this->builder
+ ->newQuery()
+ ->select(['*'])
+ ->from(self::TABLE_NAME)
+ ->where('oc_customer_id', '=', $customerId)
+ ->firstOrNull();
+ }
+
+ /**
+ * Создать новую запись
+ *
+ * @param array $data Данные для создания записи
+ * @return int ID созданной записи
+ * @throws RuntimeException Если не удалось создать запись
+ */
+ public function create(array $data): int
+ {
+ $data['created_at'] = date('Y-m-d H:i:s');
+ $data['updated_at'] = date('Y-m-d H:i:s');
+
+ $success = $this->database->insert(self::TABLE_NAME, $data);
+
+ if (! $success) {
+ $error = $this->database->getLastError();
+ $errorMessage = $error ? $error[1] : 'Unknown error';
+ throw new RuntimeException("Failed to insert telegram customer. Error: {$errorMessage}");
+ }
+
+ return $this->database->lastInsertId();
+ }
+
+ /**
+ * Обновить запись по Telegram user ID
+ *
+ * @param int $telegramUserId Telegram user ID
+ * @param array $data Данные для обновления
+ * @return bool true если обновление успешно
+ */
+ public function updateByTelegramUserId(int $telegramUserId, array $data): bool
+ {
+ $data['updated_at'] = date('Y-m-d H:i:s');
+
+ return $this->builder->newQuery()
+ ->where('telegram_user_id', '=', $telegramUserId)
+ ->update(self::TABLE_NAME, $data);
+ }
+
+ /**
+ * Обновить last_seen_at для пользователя
+ *
+ * @param int $telegramUserId Telegram user ID
+ * @return bool true если обновление успешно
+ */
+ public function updateLastSeen(int $telegramUserId): bool
+ {
+ return $this->updateByTelegramUserId($telegramUserId, [
+ 'last_seen_at' => date('Y-m-d H:i:s'),
+ ]);
+ }
+}
diff --git a/module/oc_telegram_shop/upload/oc_telegram_shop/src/Services/TelegramCustomerService.php b/module/oc_telegram_shop/upload/oc_telegram_shop/src/Services/TelegramCustomerService.php
new file mode 100644
index 0000000..b766e32
--- /dev/null
+++ b/module/oc_telegram_shop/upload/oc_telegram_shop/src/Services/TelegramCustomerService.php
@@ -0,0 +1,96 @@
+telegramCustomerModel = $telegramCustomerModel;
+ }
+
+ /**
+ * Сохранить или обновить Telegram-пользователя
+ *
+ * @param array $telegramUserData Данные пользователя из Telegram.WebApp.initDataUnsafe
+ * @return void
+ * @throws RuntimeException Если данные невалидны или не удалось сохранить
+ */
+ public function saveOrUpdate(array $telegramUserData): void
+ {
+ $telegramUserId = $this->extractTelegramUserId($telegramUserData);
+ $telegramCustomerData = $this->prepareCustomerData($telegramUserData, $telegramUserId);
+
+ $existingRecord = $this->telegramCustomerModel->findByTelegramUserId($telegramUserId);
+
+ if ($existingRecord) {
+ $this->telegramCustomerModel->updateByTelegramUserId($telegramUserId, $telegramCustomerData);
+ } else {
+ $this->telegramCustomerModel->create($telegramCustomerData);
+ }
+ }
+
+ /**
+ * Извлечь Telegram user ID из данных
+ *
+ * @param array $telegramUserData Данные пользователя
+ * @return int Telegram user ID
+ * @throws RuntimeException Если ID отсутствует или невалиден
+ */
+ private function extractTelegramUserId(array $telegramUserData): int
+ {
+ $telegramUserId = (int) Arr::get($telegramUserData, 'id');
+
+ if ($telegramUserId <= 0) {
+ throw new RuntimeException('Telegram user ID is required and must be positive');
+ }
+
+ return $telegramUserId;
+ }
+
+ /**
+ * Подготовить данные для сохранения в БД
+ *
+ * @param array $telegramUserData Исходные данные пользователя
+ * @param int $telegramUserId Telegram user ID
+ * @return array Подготовленные данные
+ */
+ private function prepareCustomerData(array $telegramUserData, int $telegramUserId): array
+ {
+ return [
+ 'telegram_user_id' => $telegramUserId,
+ 'username' => Arr::get($telegramUserData, 'username'),
+ 'first_name' => Arr::get($telegramUserData, 'first_name'),
+ 'last_name' => Arr::get($telegramUserData, 'last_name'),
+ 'language_code' => Arr::get($telegramUserData, 'language_code'),
+ 'is_premium' => $this->convertToInt(Arr::get($telegramUserData, 'is_premium', false)),
+ 'allows_write_to_pm' => $this->convertToInt(Arr::get($telegramUserData, 'allows_write_to_pm', false)),
+ 'photo_url' => Arr::get($telegramUserData, 'photo_url'),
+ 'last_seen_at' => date('Y-m-d H:i:s'),
+ ];
+ }
+
+ /**
+ * Конвертировать булево значение в int для БД
+ *
+ * @param mixed $value Значение для конвертации
+ * @return int 1 или 0
+ */
+ private function convertToInt($value): int
+ {
+ return ($value === true || $value === 1 || $value === '1') ? 1 : 0;
+ }
+}
diff --git a/module/oc_telegram_shop/upload/oc_telegram_shop/src/routes.php b/module/oc_telegram_shop/upload/oc_telegram_shop/src/routes.php
index c8930f6..aa5dfc2 100755
--- a/module/oc_telegram_shop/upload/oc_telegram_shop/src/routes.php
+++ b/module/oc_telegram_shop/upload/oc_telegram_shop/src/routes.php
@@ -10,26 +10,22 @@ use App\Handlers\OrderHandler;
use App\Handlers\ProductsHandler;
use App\Handlers\SettingsHandler;
use App\Handlers\TelegramHandler;
+use App\Handlers\TelegramCustomerHandler;
return [
- 'health' => [HealthCheckHandler::class, 'handle'],
-
- 'products' => [ProductsHandler::class, 'index'],
- 'product_show' => [ProductsHandler::class, 'show'],
- 'storeOrder' => [OrderHandler::class, 'store'],
- 'filtersForMainPage' => [FiltersHandler::class, 'getFiltersForMainPage'],
-
'categoriesList' => [CategoriesHandler::class, 'index'],
-
'checkout' => [CartHandler::class, 'checkout'],
+ 'filtersForMainPage' => [FiltersHandler::class, 'getFiltersForMainPage'],
'getCart' => [CartHandler::class, 'index'],
-
- 'settings' => [SettingsHandler::class, 'index'],
- 'manifest' => [SettingsHandler::class, 'manifest'],
- 'testTgMessage' => [SettingsHandler::class, 'testTgMessage'],
-
- 'webhook' => [TelegramHandler::class, 'webhook'],
- 'processBlock' => [BlocksHandler::class, 'processBlock'],
-
'getForm' => [FormsHandler::class, 'getForm'],
+ 'health' => [HealthCheckHandler::class, 'handle'],
+ 'manifest' => [SettingsHandler::class, 'manifest'],
+ 'processBlock' => [BlocksHandler::class, 'processBlock'],
+ 'product_show' => [ProductsHandler::class, 'show'],
+ 'products' => [ProductsHandler::class, 'index'],
+ 'saveTelegramCustomer' => [TelegramCustomerHandler::class, 'saveOrUpdate'],
+ 'settings' => [SettingsHandler::class, 'index'],
+ 'storeOrder' => [OrderHandler::class, 'store'],
+ 'testTgMessage' => [SettingsHandler::class, 'testTgMessage'],
+ 'webhook' => [TelegramHandler::class, 'webhook'],
];
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ {{ data.first_name || '—' }}
+ {{ data.last_name || '—' }}
+
+
+ {{ data.language_code.toUpperCase() }}
+
+ —
+
+
+
+ —
+
+
+ {{ data.oc_customer_id }}
+ —
+
+
+
+ {{ formatDate(data.last_seen_at) }}
+
+ —
+
+
+ {{ formatDate(data.created_at) }}
+
+
+
+
+
+ ![]()
+
+
+ @{{ data.username }}
+ —
+
+
+
+
+
+
+ Нет данных о кастомерах
+
+ Пользователи появятся здесь после первого входа в Telegram Mini App
+
+
+
+
+
+ Загрузка данных...
+