Update app.py

app.py

@@ -1,5 +1,5 @@
 # app.py
-# @title Beer Game Final Version (v4.20 - NO Introduction)
+# @title Beer Game Final Version (v4.22 - Custom ID & Dynamic Leaderboard)
 
 # -----------------------------------------------------------------------------
 # 1. Import Libraries
@@ -15,14 +15,16 @@ import random
 import uuid
 from pathlib import Path
 from datetime import datetime
-from huggingface_hub import HfApi
+from huggingface_hub import HfApi, hf_hub_download # 导入新工具
+from huggingface_hub.utils import RepositoryNotFoundError, EntryNotFoundError # 导入错误处理
+import json # 导入 JSON
+import numpy as np # 导入 Numpy 用于 std
 
 # -----------------------------------------------------------------------------
 # 0. Page Configuration (Must be the first Streamlit command)
 # -----------------------------------------------------------------------------
 st.set_page_config(page_title="Beer Game: Human-AI Collaboration", layout="wide")
 
-
 # -----------------------------------------------------------------------------
 # 2. Game Parameters & API Configuration
 # -----------------------------------------------------------------------------
@@ -41,7 +43,8 @@ BACKLOG_COST = 1.0
 OPENAI_MODEL = "gpt-4o-mini"
 LOCAL_LOG_DIR = Path("logs")
 LOCAL_LOG_DIR.mkdir(exist_ok=True)
-IMAGE_PATH = "beer_game_diagram.png" # Path to your uploaded image
+IMAGE_PATH = "beer_game_diagram.png"
+LEADERBOARD_FILE = "leaderboard.json" # 新增：排行榜文件名
 
 # --- API & Secrets Configuration ---
 try:
@@ -55,7 +58,6 @@ except Exception as e:
 else:
     st.session_state.initialization_error = None
 
-
 # -----------------------------------------------------------------------------
 # 3. Core Game Logic Functions
 # -----------------------------------------------------------------------------
@@ -63,39 +65,36 @@ else:
 def get_customer_demand(week: int) -> int:
     return 4 if week <= 4 else 8
 
-# =============== CORRECTED Initialization (v4.17 logic) ===============
-def init_game_state(llm_personality: str, info_sharing: str):
+# =============== MODIFIED Initialization (Accepts participant_id) ===============
+def init_game_state(llm_personality: str, info_sharing: str, participant_id: str):
     roles = ["Retailer", "Wholesaler", "Distributor", "Factory"]
     human_role = "Distributor" # Role is fixed
-    participant_id = str(uuid.uuid4())[:8]
-
+    
     st.session_state.game_state = {
-        'game_running': True, 'participant_id': participant_id, 'week': 1,
+        'game_running': True,
+        'participant_id': participant_id, # 使用传入的ID
+        'week': 1,
         'human_role': human_role, 'llm_personality': llm_personality,
         'info_sharing': info_sharing, 'logs': [], 'echelons': {},
         'factory_production_pipeline': deque([0] * FACTORY_LEAD_TIME, maxlen=FACTORY_LEAD_TIME),
         'decision_step': 'initial_order',
         'human_initial_order': None,
-        # Initialize last week's orders to 0
         'last_week_orders': {name: 0 for name in roles}
     }
 
     for i, name in enumerate(roles):
         upstream = roles[i + 1] if i + 1 < len(roles) else None
         downstream = roles[i - 1] if i - 1 >= 0 else None
-
         if name == "Distributor": shipping_weeks = FACTORY_SHIPPING_DELAY
         elif name == "Factory": shipping_weeks = 0
         else: shipping_weeks = SHIPPING_DELAY
-
         st.session_state.game_state['echelons'][name] = {
-            'name': name,
-            'inventory': INITIAL_INVENTORY, 'backlog': INITIAL_BACKLOG,
+            'name': name, 'inventory': INITIAL_INVENTORY, 'backlog': INITIAL_BACKLOG,
             'incoming_shipments': deque([0] * shipping_weeks, maxlen=shipping_weeks),
             'incoming_order': 0, 'order_placed': 0, 'shipment_sent': 0,
             'weekly_cost': 0, 'total_cost': 0, 'upstream_name': upstream, 'downstream_name': downstream,
         }
-    st.info(f"New game started! AI Mode: **{llm_personality} / {info_sharing}**. You are playing as the: **{human_role}**.")
+    st.info(f"New game started for **{participant_id}**! AI Mode: **{llm_personality} / {info_sharing}**. You are the **{human_role}**.")
 # ==============================================================================
 
 def get_llm_order_decision(prompt: str, echelon_name: str) -> (int, str):
@@ -285,27 +284,191 @@ def plot_results(df: pd.DataFrame, title: str, human_role: str):
         axes[3].set_title(f'Analysis of Your ({human_role}) Decisions - Error Plotting Data'); axes[3].text(0.5, 0.5, f"Error: {plot_err}", ha='center', va='center'); axes[3].grid(True, linestyle='--'); axes[3].set_xlabel('Week')
     plt.tight_layout(rect=[0, 0, 1, 0.96]); return fig
 
+
+# =============== NEW: Leaderboard Functions ===============
+
+@st.cache_data(ttl=60) # 缓存1分钟
+def load_leaderboard_data():
+    """从Hugging Face Hub下载并加载排行榜数据。"""
+    if not hf_api or not HF_REPO_ID:
+        return {} # 没有HF连接，返回空
+    try:
+        local_path = hf_hub_download(
+            repo_id=HF_REPO_ID,
+            repo_type="dataset",
+            filename=LEADERBOARD_FILE,
+            token=HF_TOKEN,
+            cache_dir=LOCAL_LOG_DIR / "hf_cache" # 明确指定缓存目录
+        )
+        with open(local_path, 'r', encoding='utf-8') as f:
+            return json.load(f)
+    except EntryNotFoundError:
+        st.sidebar.info("Leaderboard file not found. A new one will be created.")
+        return {}
+    except Exception as e:
+        st.sidebar.error(f"Could not load leaderboard: {e}")
+        return {}
+
+def save_leaderboard_data(data):
+    """将更新后的排行榜数据保存到Hugging Face Hub。"""
+    if not hf_api or not HF_REPO_ID or not HF_TOKEN:
+        st.sidebar.warning("Cannot save leaderboard. HF credentials missing.")
+        return
+    try:
+        local_path = LOCAL_LOG_DIR / LEADERBOARD_FILE
+        with open(local_path, 'w', encoding='utf-8') as f:
+            json.dump(data, f, indent=2, ensure_ascii=False)
+        
+        hf_api.upload_file(
+            path_or_fileobj=str(local_path),
+            path_in_repo=LEADERBOARD_FILE,
+            repo_id=HF_REPO_ID,
+            repo_type="dataset",
+            token=HF_TOKEN
+        )
+        st.sidebar.success("Leaderboard updated!")
+        st.cache_data.clear() # 清除缓存
+    except Exception as e:
+        st.sidebar.error(f"Failed to upload leaderboard: {e}")
+
+def display_rankings(df, top_n=10):
+    """在UI上显示三个排名的辅助函数。"""
+    if df.empty:
+        st.info("No completed games for this category yet. Be the first!")
+        return
+
+    # 数据清洗：确保成本和标准差是数字
+    df['total_cost'] = pd.to_numeric(df['total_cost'], errors='coerce')
+    df['order_std_dev'] = pd.to_numeric(df['order_std_dev'], errors='coerce')
+    df = df.dropna(subset=['total_cost', 'order_std_dev'])
+    if df.empty:
+        st.info("No valid completed games for this category yet.")
+        return
+
+    c1, c2, c3 = st.columns(3)
+    
+    with c1:
+        st.subheader("🏆 Supply Chain Champions")
+        st.caption(f"Top {top_n} - Lowest Total Cost")
+        champs_df = df.sort_values('total_cost', ascending=True).head(top_n).copy()
+        champs_df['total_cost'] = champs_df['total_cost'].map('${:,.2f}'.format)
+        champs_df.rename(columns={'id': 'Participant', 'total_cost': 'Total Cost'}, inplace=True)
+        st.dataframe(champs_df[['Participant', 'Total Cost']], use_container_width=True, hide_index=True)
+    
+    with c2:
+        st.subheader("👑 Bullwhip Kings")
+        st.caption(f"Top {top_n} - Highest Total Cost")
+        kings_df = df.sort_values('total_cost', ascending=False).head(top_n).copy()
+        kings_df['total_cost'] = kings_df['total_cost'].map('${:,.2f}'.format)
+        kings_df.rename(columns={'id': 'Participant', 'total_cost': 'Total Cost'}, inplace=True)
+        st.dataframe(kings_df[['Participant', 'Total Cost']], use_container_width=True, hide_index=True)
+
+    with c3:
+        st.subheader("🧘 Mr. Smooth")
+        st.caption(f"Top {top_n} - Lowest Order Variation (Std. Dev.)")
+        smooth_df = df.sort_values('order_std_dev', ascending=True).head(top_n).copy()
+        smooth_df['order_std_dev'] = smooth_df['order_std_dev'].map('{:,.2f}'.format)
+        smooth_df.rename(columns={'id': 'Participant', 'order_std_dev': 'Order Std. Dev.'}, inplace=True)
+        st.dataframe(smooth_df[['Participant', 'Order Std. Dev.']], use_container_width=True, hide_index=True)
+
+def show_leaderboard_ui():
+    """加载数据并显示完整的排行榜UI。"""
+    st.markdown("---")
+    st.header("📊 The Bullwhip Leaderboard")
+    st.caption("Leaderboard updates after you finish a game. Cached for 60 seconds.")
+    
+    leaderboard_data = load_leaderboard_data()
+    if not leaderboard_data:
+        st.info("No leaderboard data yet. Be the first to finish a game!")
+    else:
+        try:
+            df = pd.DataFrame(leaderboard_data.values())
+            if 'id' not in df.columns: # 确保id列存在
+                df['id'] = list(leaderboard_data.keys())
+
+            if 'total_cost' not in df.columns or 'order_std_dev' not in df.columns or 'setting' not in df.columns:
+                st.error("Leaderboard data is corrupted or incomplete.")
+                return
+
+            groups = sorted(df.setting.unique())
+            tabs = st.tabs(["**Overall**"] + groups)
+            
+            with tabs[0]: # Overall
+                display_rankings(df)
+            
+            for i, group_name in enumerate(groups):
+                with tabs[i+1]:
+                    df_group = df[df.setting == group_name].copy()
+                    display_rankings(df_group)
+        except Exception as e:
+            st.error(f"Error displaying leaderboard: {e}")
+            st.dataframe(leaderboard_data) # 原始数据以供调试
+# ==============================================================================
+
+
+# =============== MODIFIED Function (Updates Leaderboard) ===============
 def save_logs_and_upload(state: dict):
-    # This function remains correct.
-    if not state.get('logs'): return
-    participant_id = state['participant_id']
+    if not state.get('logs'):
+        st.warning("No log data to save.")
+        return
+    
+    participant_id = state['participant_id'] # 这是您输入的自定义ID
+    logs_df = None
+    
+    # 1. Save individual log CSV
     try:
-        df = pd.json_normalize(state['logs'])
-        fname = LOCAL_LOG_DIR / f"log_{participant_id}_{int(time.time())}.csv"
-        for col in df.select_dtypes(include=['object']).columns: df[col] = df[col].astype(str)
-        df.to_csv(fname, index=False)
+        logs_df = pd.json_normalize(state['logs'])
+        # 确保文件名安全
+        safe_participant_id = re.sub(r'[^a-zA-Z0-9_-]', '_', participant_id)
+        fname = LOCAL_LOG_DIR / f"log_{safe_participant_id}_{int(time.time())}.csv"
+        
+        for col in logs_df.select_dtypes(include=['object']).columns: logs_df[col] = logs_df[col].astype(str)
+        logs_df.to_csv(fname, index=False)
         st.success(f"Log successfully saved locally: `{fname}`")
         with open(fname, "rb") as f: st.download_button("📥 Download Log CSV", data=f, file_name=fname.name, mime="text/csv")
+        
         if HF_TOKEN and HF_REPO_ID and hf_api:
-            with st.spinner("Uploading log to Hugging Face Hub..."):
+            with st.spinner("Uploading log CSV to Hugging Face Hub..."):
                 try:
                     url = hf_api.upload_file( path_or_fileobj=str(fname), path_in_repo=f"logs/{fname.name}", repo_id=HF_REPO_ID, repo_type="dataset", token=HF_TOKEN)
-                    st.success(f"✅ Log successfully uploaded to Hugging Face! [View File]({url})")
+                    st.success(f"✅ Log CSV successfully uploaded! [View File]({url})")
                 except Exception as e_upload: st.error(f"Upload to Hugging Face failed: {e_upload}")
-    except Exception as e_save: st.error(f"Error processing or saving log data: {e_save}")
+    except Exception as e_save:
+        st.error(f"Error processing or saving log CSV: {e_save}")
+        return # Don't proceed to leaderboard if CSV failed
+
+    # 2. Update and upload leaderboard.json
+    if logs_df is None: return # Ensure logs_df was created
+
+    st.subheader("Updating Leaderboard...")
+    try:
+        human_role = state['human_role']
+        
+        # Calculate metrics
+        total_cost = logs_df[f'{human_role}.total_cost'].iloc[-1]
+        order_std_dev = logs_df[f'{human_role}.order_placed'].std()
+        setting_name = f"{state['llm_personality']} / {state['info_sharing']}"
+
+        new_entry = {
+            'id': participant_id, # 使用自定义ID
+            'setting': setting_name,
+            'total_cost': float(total_cost), # 确保是JSON兼容的float
+            'order_std_dev': float(order_std_dev) # 确保是JSON兼容的float
+        }
+
+        # Load, update, save
+        leaderboard_data = load_leaderboard_data()
+        # 使用ID作为键来允许覆盖/更新 (同名/同组名的人会更新成绩)
+        leaderboard_data[participant_id] = new_entry 
+        save_leaderboard_data(leaderboard_data)
+
+    except Exception as e_board:
+        st.error(f"Error calculating or saving leaderboard score: {e_board}")
+# ==============================================================================
+
 
 # -----------------------------------------------------------------------------
-# 4. Streamlit UI (Adjusted Dashboard Labels & Logic)
+# 4. Streamlit UI (Adjusted for Custom ID and Leaderboard)
 # -----------------------------------------------------------------------------
 st.title("🍺 The Beer Game: A Human-AI Collaboration Challenge")
 
@@ -315,25 +478,40 @@ else:
     # --- Game Setup & Instructions ---
     if 'game_state' not in st.session_state or not st.session_state.game_state.get('game_running', False):
         
-        # =============== INTRODUCTION REMOVED ===============
-        # st.markdown("---")
-        # st.header("📖 Welcome to the Beer Game!")
-        # ... (Introduction text) ...
-        # st.subheader("6. How Each Week Works & Understanding Your Dashboard")
-        # ... (Explanation text) ...
+        st.markdown("---")
+        st.header("⚙️ Game Configuration")
+        
+        # =============== NEW: Participant ID Input ===============
+        participant_id = st.text_input("Enter Your Name or Team ID:", key="participant_id_input", placeholder="e.g., Team A")
         # =======================================================
         
-        st.markdown("---") # Add a separator
-        st.header("⚙️ Game Configuration")
         c1, c2 = st.columns(2)
         with c1:
              llm_personality = st.selectbox("AI Agent 'Personality'", ('human_like', 'perfect_rational'), format_func=lambda x: x.replace('_', ' ').title(), help="**Human-like:** Tends to react emotionally, potentially over-ordering. **Perfect Rational:** Uses a mathematical heuristic to make stable, logical decisions.")
         with c2:
             info_sharing = st.selectbox("Information Sharing Level", ('local', 'full'), format_func=lambda x: x.title(), help="**Local:** You and the AI agents can only see your own inventory and incoming orders. **Full:** Everyone can see the entire supply chain's status and the true end-customer demand.")
 
+        # =============== MODIFIED: Start Game Button ===============
         if st.button("🚀 Start Game", type="primary", disabled=(client is None)):
-            init_game_state(llm_personality, info_sharing)
-            st.rerun()
+            if not participant_id:
+                st.error("Please enter a Name or Team ID to start!")
+            elif participant_id in load_leaderboard_data(): # 检查ID是否已存在
+                 st.warning(f"ID '{participant_id}' already exists! Your score will be overwritten. Click again to confirm.")
+                 # 这是一个简单的检查，更复杂的可能需要一个确认按钮
+                 # 为了课堂使用，我们先假设他们会自己协调
+                 # 或者让他们加个后缀，比如 "Team A - 2"
+                 # 为简单起见，我们允许覆盖
+                 init_game_state(llm_personality, info_sharing, participant_id)
+                 st.rerun()
+            else:
+                # Pass the participant_id to the init function
+                init_game_state(llm_personality, info_sharing, participant_id)
+                st.rerun()
+        # ===========================================================
+        
+        # =============== NEW: Show Leaderboard on Start Page ===============
+        show_leaderboard_ui()
+        # =================================================================
 
     # --- Main Game Interface ---
     elif 'game_state' in st.session_state and st.session_state.game_state.get('game_running'):
@@ -343,7 +521,8 @@ else:
 
 
         st.header(f"Week {week} / {WEEKS}")
-        st.subheader(f"Your Role: **{human_role}** | AI Mode: **{state['llm_personality'].replace('_', ' ')}** | Information: **{state['info_sharing']}**")
+        # 显示自定义ID
+        st.subheader(f"Your Role: **{human_role}** ({state['participant_id']}) | AI Mode: **{state['llm_personality'].replace('_', ' ')}** | Information: **{state['info_sharing']}**")
         st.markdown("---")
         st.subheader("Supply Chain Status (Start of Week State)") # Clarified Timing
 
@@ -354,23 +533,17 @@ else:
                     e = echelons[name] # Get the echelon state
                     icon = "👤" if name == human_role else "🤖"
 
-                    # =============== UI CHANGE: Highlight Player ===============
                     if name == human_role:
-                        # Use markdown with HTML/CSS for highlighting
                         st.markdown(f"##### **<span style='border: 1px solid #FF4B4B; padding: 2px 5px; border-radius: 3px;'>{icon} {name} (You)</span>**", unsafe_allow_html=True)
                     else:
                         st.markdown(f"##### {icon} {name}")
-                    # ========================================================
                     
                     st.metric("Inventory (Opening)", e['inventory'])
                     st.metric("Backlog (Opening)", e['backlog'])
 
-                    # =============== UI CHANGE: Removed Costs ===============
-                    # Costs are no longer displayed on the main dashboard
-                    # =======================================================
-
-                    # Display info about THIS week's events / NEXT week's arrivals
-                    # Calculate the INCOMING order for THIS week
+                    # 移除成本显示
+                    
+                    # --- NEW: Added Arriving This Week ---
                     current_incoming_order = 0
                     if name == "Retailer":
                         current_incoming_order = get_customer_demand(week)
@@ -378,40 +551,44 @@ else:
                         downstream_name = e['downstream_name']
                         if downstream_name:
                             current_incoming_order = state['last_week_orders'].get(downstream_name, 0)
-                                        
-                    st.write(f"Incoming Order (This Week): **{current_incoming_order}**") # Display calculated order
+                    st.write(f"Incoming Order (This Week): **{current_incoming_order}**") 
                                         
                     if name == "Factory":
-                        # Production completing NEXT week
-                        prod_completing_next = list(state['factory_production_pipeline'])[0] if state['factory_production_pipeline'] else 0
+                        arriving_this_week = list(state['factory_production_pipeline'])[0] if state['factory_production_pipeline'] else 0
+                        st.write(f"Completing This Week: **{arriving_this_week}**")
+                        prod_completing_next = list(state['factory_production_pipeline'])[1] if len(state['factory_production_pipeline']) > 1 else 0
                         st.write(f"Completing Next Week: **{prod_completing_next}**")
                     else:
-                        # Shipment arriving NEXT week
-                        arriving_next = list(e['incoming_shipments'])[0] if e['incoming_shipments'] else 0
+                        arriving_this_week = list(e['incoming_shipments'])[0] if e['incoming_shipments'] else 0
+                        st.write(f"Arriving This Week: **{arriving_this_week}**")
+                        arriving_next = list(e['incoming_shipments'])[1] if len(e['incoming_shipments']) > 1 else (list(e['incoming_shipments'])[0] if name in ('Wholesaler', 'Retailer') and len(e['incoming_shipments']) > 0 else 0) # 修正 2-week delay 的显示
                         st.write(f"Arriving Next Week: **{arriving_next}**")
+        
         else: # Local Info Mode
             st.info("In Local Information mode, you can only see your own status dashboard.")
             e = echelons[human_role]
             st.markdown(f"### 👤 **<span style='color:#FF4B4B;'>{human_role} (Your Dashboard - Start of Week State)</span>**", unsafe_allow_html=True) # Highlight self
-            col1, col2, col3, col4 = st.columns(4)
-            
-            # Display OPENING state
-            col1.metric("Inventory (Opening)", e['inventory'])
-            col2.metric("Backlog (Opening)", e['backlog'])
+
+            col1, col2, col3 = st.columns(3)
+            with col1:
+                st.metric("Inventory (Opening)", e['inventory'])
+                st.metric("Backlog (Opening)", e['backlog'])
             
-            # Display info about THIS week's events / NEXT week's arrivals
-            # Calculate the INCOMING order for THIS week
-            current_incoming_order = 0
-            downstream_name = e['downstream_name'] # Wholesaler
-            if downstream_name:
-                 current_incoming_order = state['last_week_orders'].get(downstream_name, 0)
-                        
-            col3.write(f"**Incoming Order (This Week):**\n# {current_incoming_order}") # Display calculated order
-            col4.write(f"**Shipment Arriving (Next Week):**\n# {list(e['incoming_shipments'])[0] if e['incoming_shipments'] else 0}")
-
-            # =============== UI CHANGE: Removed Costs ===============
-            # Costs are no longer displayed on the main dashboard
-            # =======================================================
+            with col2:
+                current_incoming_order = 0
+                downstream_name = e['downstream_name'] # Wholesaler
+                if downstream_name:
+                     current_incoming_order = state['last_week_orders'].get(downstream_name, 0)
+                st.write(f"**Incoming Order (This Week):**\n# {current_incoming_order}")
+                
+            with col3:
+                # Arriving THIS week (Step 1)
+                arriving_this_week = list(e['incoming_shipments'])[0] if e['incoming_shipments'] else 0
+                st.write(f"**Shipment Arriving (This Week):**\n# {arriving_this_week}")
+                
+                # Arriving NEXT week (Peek at the next item in the 1-week delay queue)
+                arriving_next = list(e['incoming_shipments'])[1] if len(e['incoming_shipments']) > 1 else 0
+                st.write(f"**Shipment Arriving (Next Week):**\n# {arriving_next}")
 
         st.markdown("---")
         st.header("Your Decision (Step 4)")
@@ -421,7 +598,6 @@ else:
         for name in echelon_order:
             e_curr = echelons[name] # This is END OF LAST WEEK state
             arrived = 0
-            # Peek at what *will* arrive this week (Step 1) based on current queues
             if name == "Factory":
                  if state['factory_production_pipeline']: arrived = list(state['factory_production_pipeline'])[0]
             else:
@@ -447,9 +623,7 @@ else:
         if state['decision_step'] == 'initial_order':
             with st.form(key="initial_order_form"):
                 st.markdown("#### **Step 4a:** Based on the dashboard, submit your **initial** order to the Factory.")
-                # =============== UI CHANGE: Removed Default Value ===============
                 initial_order = st.number_input("Your Initial Order Quantity:", min_value=0, step=1) # No 'value'
-                # ===============================================================
                 if st.form_submit_button("Submit Initial Order & See AI Suggestion", type="primary"):
                     state['human_initial_order'] = int(initial_order) if initial_order is not None else 0
                     state['decision_step'] = 'final_order'
@@ -457,16 +631,13 @@ else:
 
         elif state['decision_step'] == 'final_order':
             st.success(f"Your initial order was: **{state['human_initial_order']}** units.")
-            # Use the correctly timed state for the prompt
             prompt_sugg = get_llm_prompt(human_echelon_state_for_prompt, week, state['llm_personality'], state['info_sharing'], all_decision_point_states)
             ai_suggestion, _ = get_llm_order_decision(prompt_sugg, f"{human_role} (Suggestion)")
 
             with st.form(key="final_order_form"):
                 st.markdown(f"#### **Step 4b:** The AI suggests ordering **{ai_suggestion}** units.")
                 st.markdown("Considering the AI's advice, submit your **final** order to end the week. (This order will arrive in 3 weeks).")
-                # =============== UI CHANGE: Removed Default Value ===============
                 st.number_input("Your Final Order Quantity:", min_value=0, step=1, key='final_order_input') # No 'value'
-                # ===============================================================
                 
                 if st.form_submit_button("Submit Final Order & Advance to Next Week"):
                     final_order_value = st.session_state.get('final_order_input', 0)
@@ -531,10 +702,14 @@ else:
                 state['human_role']
             )
             st.pyplot(fig)
-            save_logs_and_upload(state)
+            save_logs_and_upload(state) # This now also updates the leaderboard
         except Exception as e:
             st.error(f"Error generating final report: {e}")
 
+        # =============== NEW: Show Leaderboard on End Page ===============
+        show_leaderboard_ui()
+        # ===============================================================
+
         if st.button("✨ Start a New Game"):
             del st.session_state.game_state
             st.rerun()