// Обработка входящих сообщений
bot.on('message', (msg) => {
const chatId = msg.chat.id;
const userMessage = msg.text;
// Пример данных для вставки (вместо userMessage можно обработать другие поля)
const sql = `INSERT INTO users (user_id, message) VALUES (?, ?)`;
// Выполняем запрос к базе данных
connection.query(sql, [chatId, userMessage], (err, result) => {
if (err) {
return bot.sendMessage(chatId, 'Ошибка при записи в базу данных: ' + err.message);
}
// Уведомляем пользователя об успешной записи
bot.sendMessage(chatId, 'Ваши данные успешно записаны!');
});
});