MrKey8840's questions

必须让bot捕获一条消息中发送的多张照片，并通过一条消息将它们发送到频道。我尝试这样做：

@dp.message_handler(content_types=["photo"])
async def get_foto(message: types.Message, state: FSMContext):
    async with state.proxy() as data:
        if type(data.get('photo')) is list:
            data['photo'].append(message.photo[-1].file_id)
            data["time"] = time()
            return
        else:
            data['photo'] = [message.photo[-1].file_id]
            data["time"] = time()
    wait_time = 3
    while time() - data["time"] < wait_time:
        await sleep(0.1)
    print(data['photo'])
    #poli = data['photo'][0]
    poli = types.MediaGroup()
    poli.attach_photo(data['photo'][0])
    #print(poli['media'][0])
    await bot.send_media_group( chat_id = config.chat_id, media = poli)
    async with state.proxy() as data:
        del data["time"]
        del data["photo"]

但没有用。仅捕获并发送第一张照片

写作：

post = cur.execute("""SELECT id FROM ochered""")
print(post)

我得到：

<sqlite3.Cursor object at 0x0000000003E0FB20>

所有代码：

import config
import json

from aiogram import Bot, Dispatcher, executor, types
import sqlite3 as sq
import asyncio
import aioschedule

bot = Bot(token=config.TOKEN)
dp = Dispatcher(bot)

global base, cur
base = sq.connect('ochered.db')
cur = base.cursor()

async def on_startup(_):
    scheduler()
    
async def scheduler():
    aioschedule.every(1).minutes.do(public)
    while True:
        await aioschedule.run_pending()
        await asyncio.sleep(1)

@dp.message_handler(content_types=['photo', 'video'])
async def dobavlenie(message: types.Message):
    base.execute('CREATE TABLE IF NOT EXISTS ochered(id, type)')
    if message.photo:
        params = ( message.photo[0].file_id, 'photo')
    elif message.video:
        params = ( message.video.file_id, 'video')
    cur.execute('INSERT INTO ochered VALUES (?, ?)', params)
    base.commit()
    
#@dp.message_handler()
async def dobavlenie(message: types.Message):
    chmo = cur.fetchone()
    print(chmo)

@dp.message_handler()
async def public(message: types.Message):
    post = cur.execute("""SELECT id FROM ochered""")
    print(post)
    #await bot.send_photo( chat_id = config.chat_id, photo = post[0])
    #cur.execute('DELETE id FROM ochered WHERE ROW_NOMBER == 1')
executor.start_polling(dp, skip_updates=True)

写作：

@dp.message_handler(text = 'Проверка')
async def privet(message: types.Message):
   cur.execute("SELECT id FROM podpiska WHERE dt == datetime.date.today().day AND oplata == 0")
   result = cur.fetchall()
   await bot.send_message(result)

分发：

  File "C:\Users\Anna\Desktop\python\рр\bot.py", line 33, in privet
    cur.execute("SELECT id FROM podpiska WHERE dt == datetime.date.today().day A
ND oplata == 0")
sqlite3.OperationalError: near "(": syntax error