${chatId}\n\nДобавьте его в настройках админ-панели Hotel 777 для получения уведомлений о новых заявках.`;
+ sendMessage(token, chatId, replyText);
+ }
+ });
+ }
+ schedulePolling(1000);
+ })
+ .catch(err => {
+ pollErrorCount++;
+ const backoff = Math.min(5000 * Math.pow(2, pollErrorCount - 1), 300000);
+ const errKey = `fetch:${err.message}`;
+ if (lastPollErrorKey !== errKey) {
+ lastPollErrorKey = errKey;
+ console.error(`Telegram polling: ${err.message}`);
+ }
+ schedulePolling(backoff);
+ });
+ });
+}
+
+function schedulePolling(ms) {
+ if (pollingTimeout) clearTimeout(pollingTimeout);
+ pollingTimeout = setTimeout(startPolling, ms);
+}
+
+function stopPolling() {
+ if (pollingTimeout) {
+ clearTimeout(pollingTimeout);
+ pollingTimeout = null;
+ }
+}
+
+function resetPollState() {
+ stopPolling();
+ lastUpdateId = 0;
+ pollErrorCount = 0;
+ lastPollErrorKey = null;
+ pollingFatalLogged = false;
+ pollingActiveLogged = false;
+ lastSendErrors = {};
+ startPolling();
+}
+
+function sendTestMessage(settings, callback) {
+ const token = settings.telegram_bot_token;
+ if (!token) return callback(new Error('Токен бота не настроен'));
+ const usersStr = settings.telegram_notify_users || '';
+ const chatIds = usersStr.split(',').map(s => s.trim()).filter(s => s);
+ if (chatIds.length === 0) return callback(new Error('Не указаны chat_id получателей'));
+
+ let sent = 0;
+ let errors = [];
+
+ chatIds.forEach((chatId, index) => {
+ sendMessage(token, chatId, 'Hotel 777 — Тестовое уведомление Telegram. Бот работает корректно.', (err) => {
+ if (err) {
+ errors.push(`chat_id ${chatId}: ${err.message}`);
+ } else {
+ sent++;
+ }
+ if (index === chatIds.length - 1) {
+ if (errors.length > 0) {
+ callback(null, { sent, total: chatIds.length, errors });
+ } else {
+ callback(null, { sent, total: chatIds.length, errors: [] });
+ }
+ }
+ });
+ });
+}
+
+function setupRoutes(app, authenticateToken, requireAdmin) {
+ app.get('/api/admin/settings/telegram', authenticateToken, requireAdmin, (req, res) => {
+ getSettings((err, settings) => {
+ if (err) return res.status(500).json({ error: 'Database error' });
+ const token = settings.telegram_bot_token || '';
+ res.json({
+ telegram_bot_token_masked: token ? maskToken(token) : '',
+ telegram_notify_enabled: settings.telegram_notify_enabled || 'false',
+ telegram_notify_users: settings.telegram_notify_users || ''
+ });
+ });
+ });
+
+ app.put('/api/admin/settings/telegram', authenticateToken, requireAdmin, (req, res) => {
+ const { telegram_bot_token, telegram_notify_enabled, telegram_notify_users } = req.body;
+ const updates = [];
+
+ if (telegram_bot_token !== undefined && !(telegram_bot_token || '').startsWith('****')) {
+ updates.push(['telegram_bot_token', telegram_bot_token]);
+ }
+ if (telegram_notify_enabled !== undefined) {
+ updates.push(['telegram_notify_enabled', telegram_notify_enabled]);
+ }
+ if (telegram_notify_users !== undefined) {
+ updates.push(['telegram_notify_users', telegram_notify_users]);
+ }
+
+ let processed = 0;
+ if (updates.length === 0) return res.json({ message: 'No changes' });
+
+ updates.forEach(([key, value]) => {
+ settingsModule.set(key, value, (err) => {
+ if (err) console.error('Telegram settings update error:', err);
+ processed++;
+ if (processed === updates.length) {
+ res.json({ message: 'Настройки Telegram сохранены' });
+ resetPollState();
+ }
+ });
+ });
+ });
+
+ app.post('/api/admin/settings/telegram/test', authenticateToken, requireAdmin, (req, res) => {
+ getSettings((err, settings) => {
+ if (err) return res.status(500).json({ error: 'Database error' });
+ sendTestMessage(settings, (sendErr, result) => {
+ if (sendErr) return res.status(400).json({ error: sendErr.message });
+ if (result.errors.length > 0) {
+ return res.json({
+ message: `Отправлено ${result.sent} из ${result.total}. Ошибки: ${result.errors.join('; ')}`,
+ sent: result.sent,
+ total: result.total
+ });
+ }
+ res.json({ message: `Тестовое сообщение отправлено (${result.sent}/${result.total})` });
+ });
+ });
+ });
+}
+
+function maskToken(val) {
+ if (!val) return '';
+ const parts = val.split(':');
+ if (parts.length === 2) {
+ const idPart = parts[0];
+ const hashPart = parts[1];
+ if (hashPart.length <= 4) return '****';
+ return idPart.slice(0, 3) + '***:' + '****' + hashPart.slice(-4);
+ }
+ return '****';
+}
+
+module.exports = { init, setupRoutes, sendBookingNotification, sendTestMessage, startPolling, stopPolling };
diff --git a/public/admin.html b/public/admin.html
index fec4d54..f8c48a4 100644
--- a/public/admin.html
+++ b/public/admin.html
@@ -581,6 +581,35 @@ tr.row-checkout-today { background: #fef2f2 !important; border-left: 4px solid #
+ + + Отправляет уведомления о новых бронях в Telegram. Бота можно создать через @BotFather. + Чтобы узнать свой chat_id — напишите боту любое сообщение, он ответит вашим ID. +
+