feat: add customer online status to conversation response and update UI accordingly

internal/builders/conversation_builder.go

@@ -37,6 +37,7 @@ func BuildConversation(item *models.Conversation) response.ConversationResponse
 		AgentLastReadMessageID:    readStateMessageID(agentReadState),
 		AgentLastReadSeqNo:        readStateSeqNo(agentReadState),
 		AgentLastReadAt:           readStateAt(agentReadState),
+		CustomerOnline:            services.WsService.IsVisitorOnline(item.ExternalID),
 		ClosedAt:                  utils.FormatTimePtr(item.ClosedAt),
 		ClosedBy:                  item.ClosedBy,
 		CloseReason:               item.CloseReason,

internal/pkg/dto/response/conversation_response.go

@@ -41,6 +41,7 @@ type ConversationResponse struct {
 	AgentLastReadMessageID    int64                           `json:"agentLastReadMessageId"`
 	AgentLastReadSeqNo        int64                           `json:"agentLastReadSeqNo"`
 	AgentLastReadAt           string                          `json:"agentLastReadAt,omitempty"`
+	CustomerOnline            bool                            `json:"customerOnline"`
 	ClosedAt                  string                          `json:"closedAt,omitempty"`
 	ClosedBy                  int64                           `json:"closedBy"`
 	ClosedByName              string                          `json:"closedByName,omitempty"`

internal/services/ws_connection_manager.go

@@ -104,6 +104,14 @@ func (m *WsConnectionManager) FindByTopics(topics []string) []*ClientSession {
 	return ret
 }
 
+func (m *WsConnectionManager) HasTopic(topic string) bool {
+	m.mu.RLock()
+	defer m.mu.RUnlock()
+
+	sessions := m.topics[topic]
+	return len(sessions) > 0
+}
+
 func (m *WsConnectionManager) subscribeLocked(session *ClientSession, topic string) {
 	if _, exists := session.Topics[topic]; exists {
 		return

internal/services/ws_service.go

@@ -386,6 +386,14 @@ func (s *wsService) PublishToTopics(topics []string, event RealtimeEvent) {
 	}
 }
 
+func (s *wsService) IsVisitorOnline(visitorID string) bool {
+	visitorID = strings.TrimSpace(visitorID)
+	if visitorID == "" {
+		return false
+	}
+	return s.manager.HasTopic(s.visitorTopic(visitorID))
+}
+
 func (s *wsService) routeConversationTopics(conversation *models.Conversation) []string {
 	if conversation == nil {
 		return nil

web/app/(console)/conversations/page.tsx

@@ -270,9 +270,27 @@ export default function ConversationsPage() {
               <AvatarFallback>客</AvatarFallback>
               </Avatar>
               <div className="min-w-0">
-                <p className="min-w-0 truncate font-medium leading-tight">
-                  {conversation.subject}
-                </p>
+                <div className="flex items-center gap-2">
+                  <p className="min-w-0 truncate font-medium leading-tight">
+                    {conversation.subject}
+                  </p>
+                  <span
+                    className={`inline-flex shrink-0 items-center gap-1 rounded-full border px-2 text-[11px] ${
+                      conversation.customerOnline
+                        ? "border-emerald-200 bg-emerald-50 text-emerald-700"
+                        : "border-slate-200 bg-slate-100 text-slate-600"
+                    }`}
+                  >
+                    <span
+                      className={`size-1.5 rounded-full ${
+                        conversation.customerOnline
+                          ? "bg-emerald-500"
+                          : "bg-slate-400"
+                      }`}
+                    />
+                    {conversation.customerOnline ? "用户在线" : "用户离线"}
+                  </span>
+                </div>
                 <p className="mt-0.5 truncate text-xs text-muted-foreground sm:text-sm">
                   <span>{conversation.externalSource}</span>
                   <span className="text-muted-foreground/60"> / </span>

web/lib/api/agent.ts

@@ -58,6 +58,7 @@ export type AgentConversation = {
   agentLastReadMessageId: number
   agentLastReadSeqNo: number
   agentLastReadAt?: string
+  customerOnline: boolean
   closedAt?: string
   tags?: AgentConversationTag[]
   participants?: AgentConversationParticipant[]