From a726a81224b7f5dca86ee6471c8741d74525c4dc Mon Sep 17 00:00:00 2001 From: lanceyq <1982376970@qq.com> Date: Wed, 4 Mar 2026 13:39:21 +0800 Subject: [PATCH] [changes]Specifies the time zone divisions --- .../repositories/implicit_emotions_storage_repository.py | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/api/app/repositories/implicit_emotions_storage_repository.py b/api/app/repositories/implicit_emotions_storage_repository.py index 1d11f89e..97405ab6 100644 --- a/api/app/repositories/implicit_emotions_storage_repository.py +++ b/api/app/repositories/implicit_emotions_storage_repository.py @@ -5,7 +5,7 @@ Implicit Emotions Storage Repository 事务由调用方控制，仓储层只使用 flush/refresh """ import logging -from datetime import datetime, date +from datetime import datetime, date, timezone, timedelta from typing import Optional, Generator from sqlalchemy.orm import Session from sqlalchemy import select, not_, exists @@ -125,7 +125,10 @@ class ImplicitEmotionsStorageRepository: 用户ID字符串 """ from sqlalchemy import cast, String as SAString - today_start = datetime.combine(date.today(), datetime.min.time()) + CST = timezone(timedelta(hours=8)) + now_cst = datetime.now(CST) + today_start = now_cst.replace(hour=0, minute=0, second=0, microsecond=0).astimezone(timezone.utc).replace(tzinfo=None) + tomorrow_start = today_start + timedelta(days=1) offset = 0 while True: try: @@ -133,6 +136,7 @@ class ImplicitEmotionsStorageRepository: select(EndUser.id) .where( EndUser.created_at >= today_start, + EndUser.created_at < tomorrow_start, not_( exists( select(ImplicitEmotionsStorage.end_user_id).where(