ychernenko/RFB
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

поправил некоторые выводы в телеграм

Browse Source
This commit is contained in:
Алексей Барабанов
2025-10-24 10:35:02 +00:00
parent a13cb945c7
commit c62c8a31a6
1 changed files with 14 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
get_data.py
View File

@@ -1239,7 +1239,7 @@ class OnlinePoller:
daemon=True, daemon=True,
) )
self._thread.start() self._thread.start()
self._log.info("Онлайн-поллер для игры %s запущен.", self.game_id) self._log.info(f"Онлайн-поллер для игры {self.game_id} запущен.")
def monitor_game_loop(league: str, game_id: str, lang:str, stop_event: threading.Event) -> None: def monitor_game_loop(league: str, game_id: str, lang:str, stop_event: threading.Event) -> None:
logger.info(f"Старт мониторинга игры {game_id} ({league}).") logger.info(f"Старт мониторинга игры {game_id} ({league}).")
@@ -1253,14 +1253,14 @@ def monitor_game_loop(league: str, game_id: str, lang:str, stop_event: threading
is_finished = status in {"resultconfirmed", "result"} is_finished = status in {"resultconfirmed", "result"}
if is_finished: if is_finished:
logger.info(f"Матч {game_id} завершён. Останавливаем мониторинг.") logger.info(f"Матч {game_id} завершён.\nОстанавливаем мониторинг.")
break break
if is_online and not was_online: if is_online and not was_online:
logger.info(f"Матч {game_id} перешёл в онлайн. Запускаем быстрый опрос (1 сек).") logger.info(f"Матч {game_id} перешёл в онлайн.\nЗапускаем быстрый опрос (1 сек).")
poller.start() poller.start()
elif not is_online and was_online: elif not is_online and was_online:
logger.info(f"Матч {game_id} вышел из онлайна (или ещё не стартовал). Останавливаем быстрый опрос.") logger.info(f"Матч {game_id} вышел из онлайна (или ещё не стартовал).\nОстанавливаем быстрый опрос.")
poller.stop() poller.stop()
was_online = is_online was_online = is_online
@@ -1303,9 +1303,11 @@ def daily_rollover_loop(
while not stop_event.is_set(): while not stop_event.is_set():
now = datetime.now(APP_TZ) now = datetime.now(APP_TZ)
wakeup_at = next_midnight_local(now) wakeup_at = next_midnight_local(now)
print(type(wakeup_at))
seconds = (wakeup_at - now).total_seconds() seconds = (wakeup_at - now).total_seconds()
logger.info( logger.info(
f"Ежедневная перекладка: проснусь {wakeup_at.isoformat()} (через {int(seconds)} сек)." # f"Ежедневка: проснусь {datetime.fromisoformat(wakeup_at.isoformat())} (через {int(seconds)} сек)."
f"Ежедневная проверка матча:\nпроснусь {wakeup_at.strftime('%Y-%m-%d %H:%M:%S')} (через {int(seconds)} сек)."
) )
if stop_event.wait(seconds): if stop_event.wait(seconds):
break break
@@ -1316,7 +1318,7 @@ def daily_rollover_loop(
games = schedule_getter(league, season, team, lang) games = schedule_getter(league, season, team, lang)
if not games: if not games:
logger.info( logger.info(
f"Ежедневная проверка: у {team} нет игр в расписании сезона {season}." f"Ежедневная проверка:\nу {team} нет игр в расписании сезона {season}."
) )
continue continue
@@ -1326,13 +1328,13 @@ def daily_rollover_loop(
if today_game: if today_game:
gid = today_game["game"]["id"] gid = today_game["game"]["id"]
logger.info( logger.info(
f"Сегодня у {team} есть игра: gameID={gid}. Перезапуск мониторинга." f"Сегодня у {team} есть игра: gameID={gid}. \nПерезапуск мониторинга."
) )
monitor_mgr.restart(gid, lang) monitor_mgr.restart(gid, lang)
elif last_played: elif last_played:
gid = last_played["game"]["id"] gid = last_played["game"]["id"]
logger.info( logger.info(
f"Сегодня у {team} нет игры. Последняя сыгранная: gameID={gid}. Мониторинг НЕ запускаем." f"Сегодня у {team} нет игры. \nПоследняя сыгранная: gameID={gid}.\nМониторинг НЕ запускаем."
) )
else: else:
logger.info(f"Сегодня у {team} нет игры и нет предыдущих сыгранных.") logger.info(f"Сегодня у {team} нет игры и нет предыдущих сыгранных.")
@@ -1392,7 +1394,7 @@ def main():
args = parser.parse_args() args = parser.parse_args()
# logger.info(f"Запуск программы пользователем: {MYHOST}") # logger.info(f"Запуск программы пользователем: {MYHOST}")
logger.info(f"Запуск с параметрами: league={args.league}, team={args.team}, lang={args.lang}") logger.info(f"Запуск с параметрами:\nleague={args.league}\nteam={args.team}\nlang={args.lang}")
league = validate_league_or_die(args.league) league = validate_league_or_die(args.league)
team = args.team.strip().lower() team = args.team.strip().lower()
@@ -1416,7 +1418,7 @@ def main():
# В исходном расписании предполагалось наличие game.id # В исходном расписании предполагалось наличие game.id
game_id = today_game["game"]["id"] game_id = today_game["game"]["id"]
logger.info( logger.info(
f"Сегодня у {team} есть игра: gameID={game_id}. Запускаю мониторинг." f"Сегодня у {team} есть игра: gameID={game_id}.\nЗапускаю мониторинг."
) )
monitor_mgr.restart(game_id, args.lang) monitor_mgr.restart(game_id, args.lang)
else: else:
@@ -1436,11 +1438,11 @@ def main():
Json_Team_Generation(merged, out_dir="static", who="team2") Json_Team_Generation(merged, out_dir="static", who="team2")
# print(merged) # print(merged)
logger.info( logger.info(
f"Сегодня у {team} нет игры. Последняя сыгранная: gameID={game_id}. Мониторинг не запускаю." f"Сегодня у {team} нет игры.\nПоследняя сыгранная: gameID={game_id}.\nМониторинг не запускаю."
) )
except Exception as e: except Exception as e:
logging.exception( logging.exception(
"Оффлайн-сохранение для gameID=%s упало: %s", game_id, e f"Оффлайн-сохранение для gameID={game_id}\nупало: {e}"
) )
else: else:
logger.info(f"Сегодня у {team} нет игры и нет предыдущих сыгранных.") logger.info(f"Сегодня у {team} нет игры и нет предыдущих сыгранных.")