discours.io/core
5
0
Fork 0
Code Pull Requests Actions Projects Activity

viewes-service-refactor
Some checks failed
Deploy on push / deploy (push) Failing after 19s
Details

Browse Source
This commit is contained in:
Untone 2024-02-29 13:18:17 +03:00
parent 9f30f251d6
commit 435279735b
1 changed files with 17 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
services/viewed.py
View File

@ -52,18 +52,6 @@ class ViewedStorage:
# Загрузка предварительно подсчитанных просмотров из файла JSON # Загрузка предварительно подсчитанных просмотров из файла JSON
self.load_precounted_views() self.load_precounted_views()
if os.path.exists(VIEWS_FILEPATH):
file_timestamp = os.path.getctime(VIEWS_FILEPATH)
self.start_date = datetime.fromtimestamp(file_timestamp).strftime(
'%Y-%m-%d'
)
now_date = datetime.now().strftime('%Y-%m-%d')
if now_date == self.start_date:
logger.info(' * Данные актуализованы!')
else:
logger.info(f' * Файл просмотров {VIEWS_FILEPATH} создан: {self.start_date}')
# Запуск фоновой задачи # Запуск фоновой задачи
_task = asyncio.create_task(self.worker()) _task = asyncio.create_task(self.worker())
else: else:
@ -75,12 +63,24 @@ class ViewedStorage:
"""Загрузка предварительно подсчитанных просмотров из файла JSON""" """Загрузка предварительно подсчитанных просмотров из файла JSON"""
self = ViewedStorage self = ViewedStorage
try: try:
with open(VIEWS_FILEPATH, 'r') as file: if os.path.exists(VIEWS_FILEPATH):
precounted_views = json.load(file) file_timestamp = os.path.getctime(VIEWS_FILEPATH)
self.views_by_shout.update(precounted_views) self.start_date = datetime.fromtimestamp(file_timestamp).strftime(
logger.info( '%Y-%m-%d'
f' * {len(precounted_views)} публикаций с просмотрами успешно загружены.'
) )
now_date = datetime.now().strftime('%Y-%m-%d')
if now_date == self.start_date:
logger.info(' * Данные актуализованы!')
else:
logger.info(f' * Файл просмотров {VIEWS_FILEPATH} создан: {self.start_date}')
with open(VIEWS_FILEPATH, 'r') as file:
precounted_views = json.load(file)
self.views_by_shout.update(precounted_views)
logger.info(
f' * {len(precounted_views)} публикаций с просмотрами успешно загружены.'
)
except Exception as e: except Exception as e:
logger.error(f'Ошибка загрузки предварительно подсчитанных просмотров: {e}') logger.error(f'Ошибка загрузки предварительно подсчитанных просмотров: {e}')