core.py 文件源码

def monitor_train(bot, job):
    """ Job to Send Train Message """
    msg = train_alert.get_new_breakdowns_message()

    if msg is None:
        print('No new breakdowns')
    else:
        all_users = train_alert.get_all_users()
        to_send = chunks(all_users, 10)

        for group in to_send:
            for user in group:
                try:
                    bot.sendMessage(int(user), text=emojize(msg, use_aliases=True),
                                    parse_mode='HTML')
                except:
                    print("Error! Sending Message to " + str(user))
            sleep(1.2)