Update app.py

app.py

@@ -343,22 +343,52 @@ def simple_push_allocation_record(repo, space_name, student_id):
         print(f"[simple_push_allocation_record] Allocation recorded locally, sync will happen eventually")
         return False
 
-def analyze_space_activity(available_spaces, repo_dir):
-    """Analyze activity status of all spaces and return sorted list"""
+def get_last_activity_time_optimized(csv_file_path):
+    """优化版本：使用文件修改时间而不是读取文件内容"""
+    try:
+        if not os.path.exists(csv_file_path):
+            print(f"[get_last_activity_time_optimized] File not found: {csv_file_path}")
+            return datetime.min  # Never used
+        
+        # 获取文件的修改时间戳
+        file_mtime = os.path.getmtime(csv_file_path)
+        last_modified = datetime.fromtimestamp(file_mtime)
+        
+        print(f"[get_last_activity_time_optimized] {os.path.basename(csv_file_path)} last modified: {last_modified}")
+        return last_modified
+        
+    except Exception as e:
+        print(f"[get_last_activity_time_optimized] Error getting file mtime for {csv_file_path}: {e}")
+        return datetime.min
+
+def get_file_size_for_validation(csv_file_path):
+    """获取文件大小，用于验证文件是否有实际内容"""
+    try:
+        if not os.path.exists(csv_file_path):
+            return 0
+        return os.path.getsize(csv_file_path)
+    except:
+        return 0
+
+def analyze_space_activity_optimized(available_spaces, repo_dir):
+    """优化版本：使用文件修改时间分析空间活动"""
     space_activity = []
     current_time = datetime.now()
     
     # Read allocation records to filter out recently allocated spaces
     active_allocations = read_allocation_records(repo_dir)
     
-    print(f"[analyze_space_activity] Analyzing {len(available_spaces)} spaces...")
+    print(f"[analyze_space_activity_optimized] Analyzing {len(available_spaces)} spaces using file modification time...")
     
     for space_name in available_spaces:
         csv_file = os.path.join(repo_dir, f"{space_name}_query_log.csv")
-        last_activity = get_last_activity_time(csv_file)
+        
+        # 使用文件修改时间而不是读取文件内容
+        last_activity = get_last_activity_time_optimized(csv_file)
+        file_size = get_file_size_for_validation(csv_file)
         
         # Calculate idle time in minutes
-        if last_activity == datetime.min:
+        if last_activity == datetime.min or file_size <= 100:  # 小于100字节认为是空文件或只有header
             idle_minutes = float('inf')  # Never used
             status = "Never used"
             last_activity_str = "Never"
@@ -386,10 +416,11 @@ def analyze_space_activity(available_spaces, repo_dir):
             'idle_minutes': idle_minutes,
             'status': status,
             'is_recently_allocated_remote': is_recently_allocated_remote,
-            'is_recently_allocated_local': is_recently_allocated_local
+            'is_recently_allocated_local': is_recently_allocated_local,
+            'file_size': file_size  # 添加文件大小信息用于调试
         })
         
-        print(f"[analyze_space_activity] {space_name}: {status}")
+        print(f"[analyze_space_activity_optimized] {space_name}: {status} (file size: {file_size} bytes)")
     
     # Sort by idle time (most idle first)
     space_activity.sort(key=lambda x: x['idle_minutes'], reverse=True)