from aiogram import Bot, types
from aiogram.dispatcher import Dispatcher
from aiogram.types import ReplyKeyboardMarkup, KeyboardButton
from aiogram.utils import executor
import parseLevel
import parseAct
import datetime
import asyncio
import threading
BOT_TOKEN = 'TOKEN'
import time
counter_act = 0
counter1 = 0
counter2 = 0
counter3 = 0
counter4 = 0
counter5 = 0
parserLvl = parseLevel.WordsParser()
count_stop = 0
now = datetime.datetime.now()
tim = f'{now.hour}:{now.minute}'
bot = Bot(BOT_TOKEN)
dp = Dispatcher(bot)
CHANGE_KEYBOARD = ReplyKeyboardMarkup(resize_keyboard=True).add(
KeyboardButton("/Змінити рівень або сферу діяльності")
)
LEVEL_KEYBOARD = ReplyKeyboardMarkup(resize_keyboard=True, one_time_keyboard=True).add(
KeyboardButton('/level A1'),
KeyboardButton('/level A2'),
KeyboardButton('/level B1'),
KeyboardButton('/level B2'),
KeyboardButton('/level C1/2'),
)
ACTIVITY_KEYBOARD = ReplyKeyboardMarkup(resize_keyboard=True, one_time_keyboard=True).add(
KeyboardButton('/Сфера медицини'),
KeyboardButton('/Сфера ІТ'),
KeyboardButton('/Сфера економіки'),
KeyboardButton('/Сфера політики'),
KeyboardButton('/Сфера мистецтво')
)
MAIN_KEYBOARD = ReplyKeyboardMarkup(resize_keyboard=True).add(
KeyboardButton('/0брати за рівнем'),
KeyboardButton('/Обрати за сферою діяльності')
)
@dp.message_handler(commands='start')
async def start_handler(message: types.Message):
global count_stop
await bot.send_message(message.from_user.id,
"Привіт, це бот для вивчення аглійських слів, тут можно обрати свою сферу або свій рівень англійскої мови(А1,В2.....). Обери нижче! \n Після того як оберете тип слів що вам треба вивчати вам буде приходити 5 слів кожний день о 12:00 день.",
reply_markup=MAIN_KEYBOARD)
count_stop+=1
@dp.message_handler(commands='0брати')
async def choose_level_handler(message: types.Message):
await bot.send_message(message.from_user.id, "Оберіть рівень.", reply_markup=LEVEL_KEYBOARD)
@dp.message_handler(commands='Обрати')
async def choose_activity_handler(message: types.Message):
await bot.send_message(message.from_user.id, "Оберіть свою сферу", reply_markup=ACTIVITY_KEYBOARD)
@dp.message_handler(commands='Змінити')
async def stop(message: types.Message):
await bot.send_message(message.from_user.id,
"Привіт, це бот для вивчення аглійських слів, тут можно обрати свою сферу або свій рівень англійскої мови(А1,В2.....). Обери нижче! \n Після того як оберете тип слів що вам треба вивчати вам буде приходити 5 слів кожний день о 12:00 день.",
reply_markup=MAIN_KEYBOARD)
@dp.message_handler(commands='level')
async def level_handler(message: types.Message):
level = message.text.split(' ')[1] # Получаем уровень из текста сообщения
if level == 'A1':
a1_thread = threading.Thread(target=a1(message))
a1_thread.start()
a1_thread.join()
elif level == 'A2':
a2_thread = threading.Thread(target=a2(message))
a2_thread.start()
a2_thread.join()
elif level == 'B1':
b1_thread = threading.Thread(target=b1(message))
b1_thread.start()
b1_thread.join()
elif level == 'B2':
b2_thread = threading.Thread(target=b2(message))
b2_thread.start()
b2_thread.join()
elif level == 'C1/2':
c1_thread = threading.Thread(target=c1(message))
c1_thread.start()
c1_thread.join()
await bot.send_message(message.from_user.id,
f"Ви обрали рівень {level}, тепер вам буде приходить кожен день по 5 слів рівня{level}",
reply_markup=CHANGE_KEYBOARD)
@dp.message_handler(commands='Сфера')
async def act_handler(message: types.Message):
act = message.text.split(' ')[1] # Получаем сферу из текста сообщения
global counter_act
sfera(message, act)
await bot.send_message(message.from_user.id,
f"Ви обрали сферу {act}, тепер вам буде приходить кожен день по 5 слів зі сфери {act}",
reply_markup=CHANGE_KEYBOARD)
def sfera(message : types.Message, act):
global count_stop
global counter1
list = []
if act == 'ІТ':
obj = parseAct.ParseAct()
list = obj.parse_IT()
if act == 'медицини':
obj = parseAct.ParseAct()
list = obj.parse_med()
if act == 'економіки':
obj = parseAct.ParseAct()
list = obj.parse_economic()
if act == 'політики':
obj = parseAct.ParseAct()
list = obj.parse_politice()
if act == 'мистецтво':
obj = parseAct.ParseAct()
list = obj.parse_art()
while True:
now = datetime.datetime.now()
tim = now.strftime('%H:%M')
if tim == '12:00':
if counter1+5 <= len(list):
bot.send_message(message.from_user.id, list[counter1])
bot.send_message(message.from_user.id, list[counter1 + 1])
bot.send_message(message.from_user.id, list[counter1 + 2])
bot.send_message(message.from_user.id, list[counter1 + 3])
bot.send_message(message.from_user.id, list[counter1 + 4])
time.sleep(60)
counter1 += 5
if message.text == '/Змінити рівень або сферу діяльності':
print(1)
break
def a1(message: types.Message):
global count_stop
global counter1
list = parserLvl.parse_words('A1')
while True:
now = datetime.datetime.now()
tim = now.strftime('%H:%M')
print(1)
if tim == '20:59':
bot.send_message(message.from_user.id, list[counter1])
bot.send_message(message.from_user.id, list[counter1 + 1])
bot.send_message(message.from_user.id, list[counter1 + 2])
bot.send_message(message.from_user.id, list[counter1 + 3])
bot.send_message(message.from_user.id, list[counter1 + 4])
time.sleep(60)
counter1 += 5
if message.text == '/Змінити рівень або сферу діяльності':
print(2)
break
def a2(message: types.Message):
global count_stop
global counter2
list = parserLvl.parse_words('A2')
while True:
now = datetime.datetime.now()
tim = now.strftime('%H:%M')
if tim == '12:00':
bot.send_message(message.from_user.id, list[counter2])
bot.send_message(message.from_user.id, list[counter2 + 1])
bot.send_message(message.from_user.id, list[counter2 + 2])
bot.send_message(message.from_user.id, list[counter2 + 3])
bot.send_message(message.from_user.id, list[counter2 + 4])
time.sleep(60)
counter2 += 5
if message.text == '/Змінити рівень або сферу діяльності':
print(1)
break
def b1(message: types.Message):
global count_stop
global counter1
list = parserLvl.parse_words('B1')
while True:
now = datetime.datetime.now()
tim = now.strftime('%H:%M')
if tim == '12:00':
bot.send_message(message.from_user.id, list[counter3])
bot.send_message(message.from_user.id, list[counter3 + 1])
bot.send_message(message.from_user.id, list[counter3 + 2])
bot.send_message(message.from_user.id, list[counter3 + 3])
bot.send_message(message.from_user.id, list[counter3 + 4])
time.sleep(60)
counter1 += 5
if message.text == '/Змінити рівень або сферу діяльності':
print(1)
break
def b2(message: types.Message):
global count_stop
global counter4
list = parserLvl.parse_words('B2')
while True:
now = datetime.datetime.now()
tim = now.strftime('%H:%M')
if tim == '12:00':
bot.send_message(message.from_user.id, list[counter4])
bot.send_message(message.from_user.id, list[counter4 + 1])
bot.send_message(message.from_user.id, list[counter4 + 2])
bot.send_message(message.from_user.id, list[counter4 + 3])
bot.send_message(message.from_user.id, list[counter4 + 4])
time.sleep(60)
counter4 += 5
if message.text == '/Змінити рівень або сферу діяльності':
print(1)
break
def c1(message: types.Message):
global count_stop
global counter5
list = parserLvl.parse_words('C1')
while True:
now = datetime.datetime.now()
tim = now.strftime('%H:%M')
if tim == '12:00':
bot.send_message(message.from_user.id, list[counter5])
bot.send_message(message.from_user.id, list[counter5 + 1])
bot.send_message(message.from_user.id, list[counter5 + 2])
bot.send_message(message.from_user.id, list[counter5 + 3])
bot.send_message(message.from_user.id, list[counter5 + 4])
time.sleep(60)
counter5 += 5
if message.text == '/Змінити рівень або сферу діяльності':
print(1)
break
executor.start_polling(dp, skip_updates=True)
Вот весь код. Помогите решить проблемы. Пытался использовать asyncio
и threading
. Буду очень рад!