From 30d460245806ab022f4d2e3f5193ce50b560df6c Mon Sep 17 00:00:00 2001
From: flying-hero <462087392@qq.com>
Date: Sun, 5 Apr 2026 09:47:11 +0800
Subject: [PATCH] =?UTF-8?q?=F0=9F=92=AC=20=E5=8A=9F=E8=83=BD=203=EF=BC=9A@?=
 =?UTF-8?q?=E9=BE=99=E8=99=BE=E8=87=AA=E5=8A=A8=E5=9B=9E=E5=BA=94=E5=8A=9F?=
 =?UTF-8?q?=E8=83=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 backend/meetings/views.py | 36 ++++++++++++++++++++++++++++++++++++
 1 file changed, 36 insertions(+)

diff --git a/backend/meetings/views.py b/backend/meetings/views.py
index c3a55c6c..aa20694b 100644
--- a/backend/meetings/views.py
+++ b/backend/meetings/views.py
@@ -178,8 +178,44 @@ class MeetingViewSet(viewsets.ModelViewSet):
             requires_response=request.data.get('requires_response', False)
         )
         
+        # 如果是@消息，触发龙虾自动回复
+        if content.startswith('@') and message.requires_response:
+            self.auto_reply(message)
+        
         return Response(MessageSerializer(message).data, status=status.HTTP_201_CREATED)
     
+    def auto_reply(self, message):
+        """龙虾自动回复"""
+        # 获取会议中所有龙虾
+        agents = Participant.objects.filter(
+            meeting=message.meeting,
+            agent_type='openclaw',
+            left_at__isnull=True
+        )
+        
+        # 每个龙虾都有 30% 概率回复
+        import random
+        for agent in agents:
+            if random.random() < 0.3:  # 30% 概率
+                replies = [
+                    '收到！',
+                    '明白了~',
+                    '好的，我会处理',
+                    '👌',
+                    '嗯嗯',
+                    '在的！',
+                ]
+                import random
+                reply_content = random.choice(replies)
+                
+                Message.objects.create(
+                    meeting=message.meeting,
+                    sender=agent,
+                    content=reply_content,
+                    is_broadcast=True,
+                    in_reply_to=message
+                )
+    
     @action(detail=True, methods=['get'])
     def messages(self, request, pk=None):
         """获取消息"""