From ad316cf596e20720a023b7363a12273c192f4f58 Mon Sep 17 00:00:00 2001 From: zayac Date: Thu, 29 Feb 2024 20:30:42 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BF=BD=E7=95=A5=E5=AE=9A=E6=97=B6=E4=BB=BB?= =?UTF-8?q?=E5=8A=A1=E6=89=A7=E8=A1=8C=E8=BF=87=E7=A8=8B=E4=B8=AD=E5=8F=91?= =?UTF-8?q?=E7=94=9F=E7=9A=84=E9=94=99=E8=AF=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/core/定时任务.py | 38 +++++++++++++++++++++++--------------- 1 file changed, 23 insertions(+), 15 deletions(-) diff --git a/src/core/定时任务.py b/src/core/定时任务.py index 71d3e2a..19deac0 100644 --- a/src/core/定时任务.py +++ b/src/core/定时任务.py @@ -1,5 +1,4 @@ import time - import schedule from loguru import logger @@ -13,24 +12,33 @@ from src.entity.visual_list import text_count_by_user def job_count(username, password): - logger.info(f'Running job_count for username: {username}') - user = get_user_by_username_and_password(username, password) - send_message(BOT_TOKEN, COUNT_GROUP_ID, text_count_by_user(user, get_curr_day())) - logger.info(f'Finished job_count for username: {username}') + try: + logger.info(f'Running job_count for username: {username}') + user = get_user_by_username_and_password(username, password) + send_message(BOT_TOKEN, COUNT_GROUP_ID, text_count_by_user(user, get_curr_day())) + logger.info(f'Finished job_count for username: {username}') + except Exception as e: + logger.error(f'Error running job_count for username: {username}, Error: {e}') def query_failed_deposit(username, password): - logger.info(f'Running query_failed_deposit for username: {username}') - user = get_user_by_username_and_password(username, password) - send_message(BOT_TOKEN, COUNT_GROUP_ID, get_pay_failed_by_user(user, get_curr_day())) - logger.info(f'Finished query_failed_deposit for username: {username}') + try: + logger.info(f'Running query_failed_deposit for username: {username}') + user = get_user_by_username_and_password(username, password) + send_message(BOT_TOKEN, COUNT_GROUP_ID, get_pay_failed_by_user(user, get_curr_day())) + logger.info(f'Finished query_failed_deposit for username: {username}') + except Exception as e: + logger.error(f'Error running query_failed_deposit for username: {username}, Error: {e}') -def query_net_win(username, password) -> None: - logger.info(f'Running query_net_win for username: {username}') - user = get_user_by_username_and_password(username, password) - send_message(BOT_TOKEN, COUNT_GROUP_ID, get_net_win_by_user(user, date=get_curr_day())) - logger.info(f'Finished query_net_win for username: {username}') +def query_net_win(username, password): + try: + logger.info(f'Running query_net_win for username: {username}') + user = get_user_by_username_and_password(username, password) + send_message(BOT_TOKEN, COUNT_GROUP_ID, get_net_win_by_user(user, date=get_curr_day())) + logger.info(f'Finished query_net_win for username: {username}') + except Exception as e: + logger.error(f'Error running query_net_win for username: {username}, Error: {e}') if __name__ == '__main__': @@ -43,4 +51,4 @@ if __name__ == '__main__': while True: schedule.run_pending() time.sleep(1) - # logger.info('Running scheduled tasks') + # logger.info('Running scheduled tasks') # This line is commented out to reduce log verbosity