question:Привет! ППривет! Помоги мне добавить несколько нововведений в бота. После того, как бот получил ответ от YandexGPT, нужно добавить следующие инлайн-кнопки к отправляющемуся сообщению: 1) Перегенерировать. Отправляет тот же запрос, удаляет текущее сообщение 2) Дополнить запрос. Должен отправлять запрос к YandexGPT с текущим ответом и дополнением пользователя 3) Сохранить ответ - пока просто напиши заглушку. from aiogram import Bot, Dispatcher, executor, types from aiogram.dispatcher import FSMContext from aiogram.dispatcher.filters.state import State, StatesGroup from aiogram.contrib.fsm_storage.memory import MemoryStorage from aiogram.types import ReplyKeyboardMarkup, KeyboardButton, InlineKeyboardButton, InlineKeyboardMarkup from aiogram.utils.callback_data import CallbackData import aiosqlite import asyncio import aiohttp import json API_TOKEN = '7089345612:AAGMKDRabqD-8IBhkCLpShXpEwYoeGvFwIU' ADMINS = [989037374, 1515567046] bot = Bot(token=API_TOKEN) storage = MemoryStorage() dp = Dispatcher(bot, storage=storage) class Form(StatesGroup): choosing_action = State() answer_question = State() class lk(StatesGroup): personal_account = State() edit_answer = State() new_answer = State() edit_answer_select = State() edit_answer_cb = State() new_answer_cb = State() class admin(StatesGroup): admin_panel = State() select_question_to_delete = State() select_question_to_edit = State() edit_question_text = State() new_question = State() async def create_db(): async with aiosqlite.connect('base.db') as db: await db.execute('''CREATE TABLE IF NOT EXISTS users ( id INTEGER PRIMARY KEY, username TEXT NOT NULL, last_question_idx INTEGER DEFAULT 0)''') await db.execute('''CREATE TABLE IF NOT EXISTS questions ( id INTEGER PRIMARY KEY AUTOINCREMENT, question TEXT NOT NULL, order_num INTEGER NOT NULL)''') await db.execute('''CREATE TABLE IF NOT EXISTS answers ( id INTEGER PRIMARY KEY AUTOINCREMENT, user_id INTEGER, question TEXT, answer TEXT, FOREIGN KEY (user_id) REFERENCES users (id))''') await db.commit() # Обработка под MarkdownV2 def mdv2(text: str) -> str: escape_chars = [ "_", "[", "]", "(", ")", "~", "`", ">", "#", "+", "-", "=", "|", "{", "}", ".", "!" ] for char in escape_chars: text = text.replace(char, f"{char}") text = text.replace("**", "*").replace('"', '“') return text # калбэки change_action_cb = CallbackData('change', 'action') # КНОПКА МЕНЮ menu = ReplyKeyboardMarkup(resize_keyboard=True, one_time_keyboard=True) menu.add(KeyboardButton("В меню")) async def add_user(user_id: int, username: str): async with aiosqlite.connect('base.db') as db: cursor = await db.execute('SELECT id FROM users WHERE id = ?', (user_id,)) user_exists = await cursor.fetchone() if user_exists: await db.execute('UPDATE users SET username = ? WHERE id = ?', (username, user_id)) else: await db.execute('INSERT INTO users (id, username) VALUES (?, ?)', (user_id, username)) await db.commit() @dp.message_handler(commands="start", state="*") async def cmd_start(message: types.Message): markup = ReplyKeyboardMarkup(resize_keyboard=True, one_time_keyboard=True) markup.add(KeyboardButton("Сгенерировать био")) markup.add(KeyboardButton("Личный кабинет")) user_id = message.from_user.id username = message.from_user.username or "unknown" await add_user(user_id, username) if user_id not in ADMINS: await message.answer("Выберите действие:", reply_markup=markup) await Form.choosing_action.set() else: markup.add(KeyboardButton("Админ-панель")) await message.answer("Выберите действие:", reply_markup=markup) await Form.choosing_action.set() @dp.message_handler(lambda message: message.text == "В меню", state="*") async def back_to_menu(message: types.Message): markup = ReplyKeyboardMarkup(resize_keyboard=True, one_time_keyboard=True) markup.add(KeyboardButton("Сгенерировать био")) markup.add(KeyboardButton("Личный кабинет")) if message.from_user.id not in ADMINS: await message.answer("Вернули вас в меню. Выберите действие", reply_markup=markup) await Form.choosing_action.set() else: markup.add(KeyboardButton("Админ-панель")) await message.answer("Вернули вас в меню. Выберите действие", reply_markup=markup) await Form.choosing_action.set() async def save_answer(user_id: int, question: str, answer: str, question_idx: int): async with aiosqlite.connect('base.db') as db: await db.execute('INSERT INTO answers (user_id, question, answer) VALUES (?, ?, ?)', (user_id, question, answer)) await db.execute('UPDATE users SET last_question_idx = ? WHERE id = ?', (question_idx, user_id)) await db.commit() async def set_next_question(user_id: int): async with aiosqlite.connect('base.db') as db: cursor = await db.execute('SELECT last_question_idx FROM users WHERE id = ?', (user_id,)) result = await cursor.fetchone() last_question_idx = result[0] if result else 0 next_question_idx = last_question_idx + 1 question_cursor = await db.execute('SELECT question FROM questions WHERE order_num = ?', (next_question_idx,)) question_text = await question_cursor.fetchone() if question_text: await bot.send_message(user_id, question_text[0], reply_markup=menu) await Form.answer_question.set() await db.execute('UPDATE users SET last_question_idx = ? WHERE id = ?', (next_question_idx, user_id)) await db.commit() else: answers_text = "" cursor = await db.execute("SELECT question, answer FROM answers WHERE user_id=?", (user_id,)) answers = await cursor.fetchall() for idx, (question, answer) in enumerate(answers, start=1): answers_text += f"{idx}. {question} - {answer}n" markup = InlineKeyboardMarkup( inline_keyboard=[ [InlineKeyboardButton(text="Сгенерировать", callback_data=change_action_cb.new(action="generate"))], [InlineKeyboardButton(text="Изменить ответ", callback_data=change_action_cb.new(action="change"))], [InlineKeyboardButton(text="Заполнить заново", callback_data=change_action_cb.new(action="refill"))], ] ) await bot.send_message(user_id, f"Вот ваши ответы:nn{answers_text}", reply_markup=markup) await dp.current_state(user=user_id).reset_state(with_data=False) @dp.callback_query_handler(change_action_cb.filter(action="change"), state="*") async def change_answer(callback_query: types.CallbackQuery, state: FSMContext): await bot.answer_callback_query(callback_query.id) await lk.edit_answer.set() await bot.send_message(callback_query.from_user.id, "Введите номер вопроса, который хотите изменить:") @dp.message_handler(state=lk.edit_answer_cb) async def enter_question_number(message: types.Message, state: FSMContext): question_number = message.text if not question_number.isdigit(): await message.reply("Пожалуйста, введите номер вопроса цифрами. Попробуйте снова:") return await state.update_data(question_number=int(question_number)) await lk.new_answer.set() await message.answer("Введите новый ответ:") @dp.callback_query_handler(change_action_cb.filter(action="refill"), state="*") async def process_refill(callback_query: types.CallbackQuery, callback_data: dict): user_id = callback_query.from_user.id await bot.answer_callback_query(callback_query.id) markup = InlineKeyboardMarkup().add(InlineKeyboardButton("Да, начать заново", callback_data="confirm_refill")) await bot.send_message(user_id, "Вы уверены, что хотите начать заново? Ваши текущие ответы будут удалены.", reply_markup=markup) @dp.message_handler(state=lk.new_answer_cb) async def update_answer(message: types.Message, state: FSMContext): new_answer_text = message.text user_data = await state.get_data() question_number = user_data['question_number'] user_id = message.from_user.id async with aiosqlite.connect('base.db') as db: cursor = await db.execute('SELECT question FROM questions WHERE order_num = ?', (question_number,)) question_text = await cursor.fetchone() if question_text: await db.execute('UPDATE answers SET answer = ? WHERE user_id = ? AND question = ?', (new_answer_text, user_id, question_text[0])) await db.commit() await message.answer(f"Ваш ответ на вопрос изменен на: {new_answer_text}", reply_markup=menu) else: await message.answer(f"Проблема при редактировании ответа, вопрос не найден.") await state.finish() await set_next_question(user_id) @dp.message_handler(lambda message: message.text == "Сгенерировать био", state=Form.choosing_action) async def generate_bio(message: types.Message): user_id = message.from_user.id await set_next_question(user_id) @dp.message_handler(state=Form.answer_question) async def process_question_answer(message: types.Message, state: FSMContext): user_id = message.from_user.id answer_text = message.text async with aiosqlite.connect('base.db') as db: cursor = await db.execute('SELECT last_question_idx FROM users WHERE id = ?', (user_id,)) result = await cursor.fetchone() current_question_idx = result[0] if result else 0 cursor = await db.execute('SELECT question FROM questions WHERE order_num = ?', (current_question_idx,)) question = await cursor.fetchone() if question: question_text = question[0] await db.execute('INSERT INTO answers (user_id, question, answer) VALUES (?, ?, ?)', (user_id, question_text, answer_text)) await db.execute('UPDATE users SET last_question_idx = ? WHERE id = ?', (current_question_idx, user_id)) await db.commit() else: await message.answer("Произошла ошибка при сохранении вашего ответа.") await set_next_question(user_id) @dp.message_handler(lambda message: message.text == "Личный кабинет", state=Form.choosing_action) async def personal_account(message: types.Message): user_id = message.from_user.id answers_text = "Личный кабинетnnВаши ответы:n" async with aiosqlite.connect('base.db') as db: cursor = await db.execute('SELECT question, answer FROM answers WHERE user_id=? ORDER BY id', (user_id,)) answers = await cursor.fetchall() for idx, (question, answer) in enumerate(answers, start=1): answers_text += f"{idx}. {question}: {answer}n" if answers_text == "Личный кабинетnnВаши ответы:n": answers_text = "Личный кабинетnnВы еще не отвечали на вопросы. Пожалуйста, нажмите «В меню» и выберите «Сгенерировать био», чтобы ответить на вопросы" await message.answer(answers_text, reply_markup=menu) else: markup = ReplyKeyboardMarkup(resize_keyboard=True, one_time_keyboard=True) markup.add(KeyboardButton("Изменить ответ")) markup.add(KeyboardButton("Заполнить заново")) markup.add(KeyboardButton("В меню")) await message.answer(answers_text, reply_markup=markup) await lk.personal_account.set() @dp.message_handler(lambda message: message.text == "Изменить ответ", state=lk.personal_account) async def change_answer(message: types.Message): await message.answer("Введите номер вопроса, на который хотите изменить ответ:",reply_markup=menu) await lk.edit_answer.set() @dp.message_handler(state=lk.edit_answer) async def process_question_number(message: types.Message, state: FSMContext): text = message.text question_number = int(text) async with aiosqlite.connect('base.db') as db: cursor = await db.execute('SELECT question FROM questions WHERE order_num = ?', (question_number,)) question_text = await cursor.fetchone() if question_text: await state.update_data(question=question_text[0], question_number=question_number) await message.answer("Введите новый ответ:") await lk.new_answer.set() else: await message.answer(f"Вопроса под номером {question_number} не существует.") @dp.message_handler(state=lk.new_answer) async def process_new_answer(message: types.Message, state: FSMContext): user_data = await state.get_data() question_number = user_data['question_number'] new_answer = message.text markup = ReplyKeyboardMarkup(resize_keyboard=True, one_time_keyboard=True) markup.add(KeyboardButton("Изменить ответ")) markup.add(KeyboardButton("Заполнить заново")) markup.add(KeyboardButton("В меню")) user_id = message.from_user.id async with aiosqlite.connect('base.db') as db: cursor = await db.execute('SELECT question FROM questions WHERE order_num = ?', (question_number,)) question_text = await cursor.fetchone() if question_text: await db.execute('UPDATE answers SET answer = ? WHERE user_id = ? AND question = ?', (new_answer, user_id, question_text[0])) await db.commit() await message.answer(f"Ваш ответ на вопрос изменен на: {new_answer}", reply_markup=markup) else: await message.answer(f"Проблема при редактировании ответа, вопрос не найден.") await state.finish() await personal_account(message) @dp.message_handler(lambda message: message.text == "Заполнить заново", state=lk.personal_account) async def refill_form(message: types.Message): markup = InlineKeyboardMarkup().add(InlineKeyboardButton("Да", callback_data="confirm_refill")) await message.answer("Вы уверены, что хотите начать заново? Все текущие ответы будут удалены.", reply_markup=markup) @dp.callback_query_handler(lambda c: c.data == 'confirm_refill', state="*") async def process_refill(callback_query: types.CallbackQuery): user_id = callback_query.from_user.id async with aiosqlite.connect('base.db') as db: await db.execute('DELETE FROM answers WHERE user_id=?', (user_id,)) await db.commit() await db.execute('UPDATE users SET last_question_idx = 0 WHERE id = ?', (user_id,)) await db.commit() state = dp.current_state(user=user_id) await state.reset_state(with_data=False) await bot.answer_callback_query(callback_query.id) await bot.send_message(user_id, "Ваши ответы удалены.") await cmd_start(callback_query.message) # ГЕНЕРАЦИЯ class YandexGPT: @staticmethod async def generate(prompt: str, apikey: str, sa_id: str, user_id : str): url = 'https://llm.api.cloud.yandex.net/foundationModels/v1/completion' headers = { 'Content-Type': 'application/json', 'Authorization': f'Api-Key {apikey}' } data = { "modelUri": f"gpt://{sa_id}/yandexgpt-lite/latest", "completionOptions": { "stream": False, "temperature": 0.6, "maxTokens": "1000" }, "messages": [ { "role": "system", "text": "Твоя задача - создать небольшой текст о биографии человека в соответствии с следующими ответами на вопросы (пишется вопрос? ответ). Также напиши короткую эпитафию в соответствии с биографией. Свой ответ пиши только по шаблону:nБиография:nnЭпитафий:nnБиография должна быть не сильно длинной, но интересной. Если биография очевидно неправильная (ответы на вопросы невозможно распознать), то пиши: Извините, я не понял ваш запрос. Попробуйте ответить на вопросы еще раз. " }, { "role": "user", "text": prompt } ] } async with aiohttp.ClientSession() as session: async with session.post(url, json=data, headers=headers) as response: response_data = await response.json() try: answer = response_data['result']['alternatives'][0]['message']['text'] await bot.send_message(user_id, mdv2(answer), parse_mode="MarkdownV2") except KeyError as e: await bot.send_message(user_id, "Не удалось получить ответ от сервера. Проверьте переданные данные и попробуйте еще раз.") @dp.callback_query_handler(change_action_cb.filter(action="generate"), state="*") async def process_generate(callback_query: types.CallbackQuery): user_id = callback_query.from_user.id prompt = "" async with aiosqlite.connect('base.db') as db: cursor = await db.execute("SELECT question, answer FROM answers WHERE user_id=?", (user_id,)) answers = await cursor.fetchall() for question, answer in answers: prompt += f"n{question} - {answer}" api_key = "AQVN1J4sCxYR98rj-tVppyp6gXQthbdmYvmgtO7a" sa_id = "b1g5og37bgh1ghh2s2qc" await YandexGPT.generate(prompt, api_key, sa_id, user_id) # АДМИН-ПАНЕЛЬ # КНОПКА НАЗАД back = ReplyKeyboardMarkup(resize_keyboard=True, one_time_keyboard=False) back.add(KeyboardButton("Назад")) # КЛАВА admin_kb = ReplyKeyboardMarkup(resize_keyboard=True) admin_kb.add("Вопросы", "Добавить", "Удалить", "Редактировать","В меню") @dp.message_handler(lambda message: message.text == "Назад", state=[admin.new_question, admin.edit_question_text, admin.select_question_to_edit, admin.select_question_to_delete]) async def back_to_admin_panel(message: types.Message, state: FSMContext): await state.finish() await admin_panel(message) @dp.message_handler(lambda message: message.text == "Админ-панель", state=Form.choosing_action) async def admin_panel(message: types.Message): if message.from_user.id not in ADMINS: await message.answer("Доступ запрещен.") return await message.answer("Админ-панель:", reply_markup=admin_kb) await admin.admin_panel.set() @dp.message_handler(lambda message: message.text == "Вопросы", state=admin.admin_panel) async def show_questions(message: types.Message): async with aiosqlite.connect('base.db') as db: cursor = await db.execute("SELECT question FROM questions ORDER BY order_num ASC") questions = await cursor.fetchall() if questions: text = "n".join([f"{idx + 1}. {question[0]}" for idx, question in enumerate(questions)]) else: text = "Вопросы отсутствуют." await message.answer(text) @dp.message_handler(lambda message: message.text == "Добавить", state=admin.admin_panel) async def add_question_start(message: types.Message): await message.answer("Введите текст нового вопроса:", reply_markup=back) await admin.new_question.set() @dp.message_handler(state=admin.new_question) async def add_question_process(message: types.Message, state: FSMContext): new_question = message.text async with aiosqlite.connect('base.db') as db: cursor = await db.execute("SELECT MAX(order_num) FROM questions") max_order_num = await cursor.fetchone() next_order_num = (max_order_num[0] or 0) + 1 await db.execute("INSERT INTO questions (question, order_num) VALUES (?, ?)", (new_question, next_order_num)) await db.commit() await message.answer("Вопрос успешно добавлен.", reply_markup=admin_kb) await admin.admin_panel.set() @dp.message_handler(lambda message: message.text == "Редактировать", state=admin.admin_panel) async def select_question_to_edit_start(message: types.Message): async with aiosqlite.connect('base.db') as db: cursor = await db.execute("SELECT id, question FROM questions ORDER BY order_num ASC") questions = await cursor.fetchall() if not questions: await message.answer("Вопросы отсутствуют.") return text = "Выберите номер вопроса для редактирования:nn" text += "n".join(f"{qid}. {qtext}" for qid, qtext in questions) await message.answer(text, reply_markup=back) await admin.select_question_to_edit.set() @dp.message_handler(state=admin.select_question_to_edit) async def edit_question(message: types.Message, state: FSMContext): qid_text = message.text if not qid_text.isdigit(): await message.answer("Пожалуйста, введите число. Попробуйте еще раз:", reply_markup=back) return qid = int(qid_text) async with state.proxy() as data: data['question_id'] = qid await admin.edit_question_text.set() await message.answer("Введите новый текст вопроса:", reply_markup=back) @dp.message_handler(state=admin.edit_question_text) async def update_question(message: types.Message, state: FSMContext): new_text = message.text async with state.proxy() as data: qid = data['question_id'] async with aiosqlite.connect('base.db') as db: await db.execute("UPDATE questions SET question = ? WHERE id = ?", (new_text, qid)) await db.commit() await message.answer("Вопрос успешно отредактирован.", reply_markup=admin_kb) await admin.admin_panel.set() @dp.message_handler(lambda message: message.text == "Удалить", state=admin.admin_panel) async def select_question_to_delete_start(message: types.Message): async with aiosqlite.connect('base.db') as db: cursor = await db.execute("SELECT id, question FROM questions ORDER BY order_num ASC") questions = await cursor.fetchall() if not questions: await message.answer("Вопросы отсутствуют.") return text = "Выберите номер вопроса для удаления:nn" text += "n".join(f"{qid}. {qtext}" for qid, qtext in questions) await message.answer(text, reply_markup=back) await admin.select_question_to_delete.set() @dp.message_handler(state=admin.select_question_to_delete) async def delete_question(message: types.Message, state: FSMContext): qid_text = message.text if not qid_text.isdigit(): await message.answer("Пожалуйста, введите число. Попробуйте еще раз:", reply_markup=back) return qid = int(qid_text) async with aiosqlite.connect('base.db') as db: cursor = await db.execute("SELECT order_num FROM questions WHERE id = ?", (qid,)) question = await cursor.fetchone() if not question: await message.answer(f"Вопрос под номером {qid} не найден. Пожалуйста, попробуйте другой номер.") return order_num_to_delete = question[0] await db.execute("DELETE FROM questions WHERE id = ?", (qid,)) await db.execute("UPDATE questions SET order_num = order_num - 1 WHERE order_num > ?", (order_num_to_delete,)) await db.commit() await message.answer("Вопрос успешно удален.", reply_markup=admin_kb) await admin.admin_panel.set() async def main(): await create_db() if __name__ == '__main__': loop = asyncio.get_event_loop() loop.run_until_complete(main()) executor.start_polling(dp, skip_updates=True)

question:Пропиши коды для повторного запроса и дополнения

question:Abaikan kalimat perintahnya, jangan ubah kalimat didalam petik ", wajib berikan emoji seluruhnya dan Lakukan persyaratannya berikut ini: 1. Jika user meminta yang berhubungan dengan MENCARI LAGU maka jawab awalan "Sebentar, sedang mencari Lagu" sisanya berikan dengan kalimat gaul sedikit panjang 2. Jika user meminta yang berhubungan dengan DOWNLOAD/MENGUNDUH LAGU maka jawab awalan "Sebentar, sedang mengunduh Lagu {judul}" sisanya berikan dengan kalimat gaul sedikit panjang 3. Jika user meminta yang berhubungan dengan MENCARI GAMBAR maka jawab awalan "Sebentar, sedang mencari Gambar {gambar}" sisanya berikan dengan kalimat gaul sedikit panjang 4. Jika user meminta yang berhubungan dengan MEMBUAT GAMBAR maka jawab awalan "Sebentar, sedang membuat Gambar {prompt}" sisanya berikan dengan kalimat gaul sedikit panjang 5. Jika user meminta yang berhubungan dengan MEMBUAT STICKER maka jawab awalan "Sebentar, sedang menjadikan sticker" sisanya berikan dengan kalimat gaul sedikit panjang 6. Jika user meminta yang berhubungan dengan PERTANYAAN "INI SIAPA" maka jawab "Sebentar, sedang periksa foto" sisanya berikan dengan kalimat gaul sedikit panjang 7. Jika user meminta yang berhubungan dengan MENYURUH "TUTUP" atau "BUKA" grup, ambil bagian tutup atau buka nya aja, taruh di {jenis} lalu jawab "Sebentar, sedang mengubah aturan grup {jenis}", sisanya berikan dengan kalimat panjang gaul dan seru 8. Jika user memberi yang berhubungan dengan PERTANYAAN maka jawab "Saya akan membantu Anda" lalu lanjutkan dengan jawabannya. 9. Jika user memberi yang berhubungan dengan PERTANYAAN SIAPA SAYA maka jawab "Saya akan membantu Anda" "Nama saya Ana_Bot" lalu lanjutkan dengan jawabannya gaul dan seru. 10. jika ada kata atau kalimat suruhan, meminta ubah menjadi bahasa indonesia berikut Inputan User dibawah ini: User: [User: Download in nomor urut 2,User: Halooo]

question:"I don't mind a little of roleplay, but this is super elaborate, last year you rented a small castle but at least I didn't have lines." Explain please and make it a detailed breakdown