This commit is contained in:
+3
-9
@@ -1,7 +1,7 @@
|
|||||||
import os
|
import os
|
||||||
import mysql.connector
|
import mysql.connector
|
||||||
from mysql.connector import Error
|
from mysql.connector import Error
|
||||||
from datetime import datetime, timedelta, timezone
|
from datetime import datetime, timezone
|
||||||
from dotenv import load_dotenv
|
from dotenv import load_dotenv
|
||||||
|
|
||||||
# Загрузка переменных окружения
|
# Загрузка переменных окружения
|
||||||
@@ -18,7 +18,6 @@ def prefetch_all_events():
|
|||||||
для записей, которые:
|
для записей, которые:
|
||||||
- имеют флаг is_visible = 1
|
- имеют флаг is_visible = 1
|
||||||
- не имеют флага marked_to_publication = 1
|
- не имеют флага marked_to_publication = 1
|
||||||
- modified более часа назад от текущего времени (UTC)
|
|
||||||
"""
|
"""
|
||||||
try:
|
try:
|
||||||
# Подключение к базе данных
|
# Подключение к базе данных
|
||||||
@@ -36,21 +35,16 @@ def prefetch_all_events():
|
|||||||
|
|
||||||
cursor = connection.cursor()
|
cursor = connection.cursor()
|
||||||
|
|
||||||
# Текущее время в UTC
|
|
||||||
current_time_utc = datetime.now(timezone.utc).replace(tzinfo=None)
|
|
||||||
one_hour_ago = current_time_utc - timedelta(hours=1)
|
|
||||||
|
|
||||||
# SQL запрос для обновления записей
|
# SQL запрос для обновления записей
|
||||||
update_query = """
|
update_query = """
|
||||||
UPDATE events
|
UPDATE events
|
||||||
SET marked_to_publication = 1
|
SET marked_to_publication = 1
|
||||||
WHERE is_visible = 1
|
WHERE is_visible = 1
|
||||||
AND marked_to_publication = 0
|
AND marked_to_publication = 0
|
||||||
AND modified < %s
|
|
||||||
"""
|
"""
|
||||||
|
|
||||||
# Выполнение запроса
|
# Выполнение запроса
|
||||||
cursor.execute(update_query, (one_hour_ago,))
|
cursor.execute(update_query)
|
||||||
updated_count = cursor.rowcount
|
updated_count = cursor.rowcount
|
||||||
|
|
||||||
# Фиксация изменений
|
# Фиксация изменений
|
||||||
|
|||||||
Reference in New Issue
Block a user