diff --git a/message_storage/message_to_db.py b/message_storage/message_to_db.py
index 406c095..724a04e 100644
--- a/message_storage/message_to_db.py
+++ b/message_storage/message_to_db.py
@@ -139,21 +139,40 @@ class MessageStorage:
 
             if not results:
                 logging.info(f"没有找到 {yesterday} 的群聊 {groupId} 发言记录")
-                return f"{yesterday} 没有发言记录"
+                return f"📊 {yesterday} 没有发言记录"
 
-            # 格式化输出字符串
-            ranking_str = yesterday + "发言数量前20的用户排名:\n"
+            # 格式化输出字符串，添加emoji和美化格式
+            ranking_str = f"🏆 {yesterday} 发言之星排行榜 🏆\n"
+            ranking_str += "━━━━━━━━━━━━━━━━━━\n"
+            
+            # 为不同名次添加不同的奖杯和样式
             for rank, result in enumerate(results, start=1):
                 username = result['wx_id']
                 speech_count = result['speech_count']
-                ranking_str += f"{rank}. {allContacts.get(username, username)}: {speech_count} 次发言\n"
+                display_name = allContacts.get(username, username)
+                
+                # 根据排名添加不同的emoji
+                if rank == 1:
+                    ranking_str += f"🥇 {rank}. {display_name}: {speech_count}次 🔥\n"
+                elif rank == 2:
+                    ranking_str += f"🥈 {rank}. {display_name}: {speech_count}次 ✨\n"
+                elif rank == 3:
+                    ranking_str += f"🥉 {rank}. {display_name}: {speech_count}次 👏\n"
+                elif rank <= 10:
+                    ranking_str += f"🌟 {rank}. {display_name}: {speech_count}次\n"
+                else:
+                    ranking_str += f"👍 {rank}. {display_name}: {speech_count}次\n"
+            
+            # 添加结尾
+            ranking_str += "━━━━━━━━━━━━━━━━━━\n"
+            ranking_str += "💪 继续加油，明天争取更高排名！"
 
             logging.info(f"成功生成 {yesterday} 的群聊 {groupId} 发言排名")
             return ranking_str
 
         except Exception as e:
             logging.error(f"生成发言排名出错: {e}")
-            return f"生成发言排名出错: {e}"
+            return f"❌ 生成发言排名出错: {e}"
 
     def get_messages(self, group_id, all_contacts: dict):
         try: