优化时间戳处理逻辑，确保时间范围过滤条件正确

logging_helper.py

@@ -167,9 +167,11 @@ class LoggingHelper:
                     parts = remotepath.split("/")
                     year, month, day = parts[0], parts[1], parts[2]
                     date_obj = date(int(year), int(month), int(day))
-                    timestamp = datetime.combine(
-                        date_obj, datetime.min.time()
-                    ).isoformat(timespec="microseconds")
+                    timestamp = (
+                        datetime.combine(date_obj, datetime.min.time())
+                        .astimezone(TIMEZONE)
+                        .isoformat(timespec="microseconds")
+                    )
                     self.timestamps[remotepath] = timestamp
                 except Exception as e:
                     print(f"[pull] Error parsing timestamp of {remotepath}: {e}")
@@ -208,8 +210,8 @@ class LoggingHelper:
 
             start_timestamp = self.cutoff_timestamp()
             end_timestamp = (
-                (beijing() + timedelta(days=1))
-                .replace(hour=0, minute=0, second=0, microsecond=0)
+                beijing()
+                .replace(hour=23, minute=59, second=59, microsecond=999999)
                 .isoformat(timespec="microseconds")
             )
             from_timestamp = from_timestamp or start_timestamp
@@ -343,9 +345,11 @@ class LoggingHelper:
             from_timestamp = from_datetime.isoformat(timespec="microseconds")
         to_timestamp = None
         if to_date is not None:
-            to_datetime = datetime.strptime(to_date, "%Y-%m-%d").astimezone(
-                TIMEZONE
-            ) + timedelta(days=1)
+            to_datetime = (
+                datetime.strptime(to_date, "%Y-%m-%d")
+                .astimezone(TIMEZONE)
+                .replace(hour=23, minute=59, second=59, microsecond=999999)
+            )
             to_timestamp = to_datetime.isoformat(timespec="microseconds")
 
         print(
@@ -362,7 +366,7 @@ class LoggingHelper:
         if from_timestamp is not None:
             filter_condition = filter_condition & (df["timestamp"] >= from_timestamp)
         if to_timestamp is not None:
-            filter_condition = filter_condition & (df["timestamp"] < to_timestamp)
+            filter_condition = filter_condition & (df["timestamp"] <= to_timestamp)
         df = df[filter_condition]
         # 按timestamp降序排序（最新日志在前）
         df = df.sort_values(by="timestamp", ascending=False)