manage_worker.py 文件源码

def recover(bot, update, db, users_state):
    user_id = update.message.from_user.id

    users_state[user_id] = dict()
    users_state[user_id]['channels'] = dict()
    keyboard = []
    keyboard_row = []
    for channel in db.query(DisabledChannel).filter(DisabledChannel.owner_id == str(user_id)).order_by(DisabledChannel.created_at.desc()):
        title = '{} ({})'.format(channel.vk_group_id, channel.channel_id)
        users_state[user_id]['channels'][title] = channel.channel_id
        keyboard_row.append(title)
        if len(keyboard_row) == 2:
            keyboard.append(keyboard_row)
            keyboard_row = []
    if len(keyboard_row) != 0:
        keyboard.append(keyboard_row)

    if len(keyboard) == 0:
        update.message.reply_text('??? ???????, ??????? ????? ????????????')
        del_state(update, users_state)
        return ConversationHandler.END
    else:
        update.message.reply_text('???????? ?????', reply_markup=ReplyKeyboardMarkup(keyboard, one_time_keyboard=True))
        return ASKED_CHANNEL_ID_IN_RECOVER